test: integration test (#29)

* test: integration test

* test: modified name

* test: remove unnecessary code

google-cloud-talent/pom.xml

@@ -69,7 +69,11 @@
       <artifactId>junit</artifactId>
       <scope>test</scope>
     </dependency>
-
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-core</artifactId>
+      <scope>test</scope>
+    </dependency>
     <dependency>
       <groupId>com.google.api.grpc</groupId>
       <artifactId>grpc-google-cloud-talent-v4beta1</artifactId>

google-cloud-talent/src/test/java/com/google/cloud/talent/v4beta1/it/ITSystemTest.java

@@ -0,0 +1,348 @@
+/*
+ * Copyright 2019 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.cloud.talent.v4beta1.it;
+
+import static org.junit.Assert.assertEquals;
+
+import com.google.cloud.ServiceOptions;
+import com.google.cloud.talent.v4beta1.ClientEvent;
+import com.google.cloud.talent.v4beta1.Company;
+import com.google.cloud.talent.v4beta1.CompanyName;
+import com.google.cloud.talent.v4beta1.CompanyServiceClient;
+import com.google.cloud.talent.v4beta1.CompanyWithTenantName;
+import com.google.cloud.talent.v4beta1.CompleteQueryRequest;
+import com.google.cloud.talent.v4beta1.CompleteQueryResponse;
+import com.google.cloud.talent.v4beta1.CompletionClient;
+import com.google.cloud.talent.v4beta1.CreateClientEventRequest;
+import com.google.cloud.talent.v4beta1.CreateCompanyRequest;
+import com.google.cloud.talent.v4beta1.CreateJobRequest;
+import com.google.cloud.talent.v4beta1.CreateTenantRequest;
+import com.google.cloud.talent.v4beta1.DeleteCompanyRequest;
+import com.google.cloud.talent.v4beta1.DeleteJobRequest;
+import com.google.cloud.talent.v4beta1.DeleteTenantRequest;
+import com.google.cloud.talent.v4beta1.EventServiceClient;
+import com.google.cloud.talent.v4beta1.GetCompanyRequest;
+import com.google.cloud.talent.v4beta1.GetJobRequest;
+import com.google.cloud.talent.v4beta1.GetTenantRequest;
+import com.google.cloud.talent.v4beta1.Job;
+import com.google.cloud.talent.v4beta1.JobEvent;
+import com.google.cloud.talent.v4beta1.JobName;
+import com.google.cloud.talent.v4beta1.JobServiceClient;
+import com.google.cloud.talent.v4beta1.JobWithTenantName;
+import com.google.cloud.talent.v4beta1.ListCompaniesRequest;
+import com.google.cloud.talent.v4beta1.ListJobsRequest;
+import com.google.cloud.talent.v4beta1.ListTenantsRequest;
+import com.google.cloud.talent.v4beta1.ProjectName;
+import com.google.cloud.talent.v4beta1.Tenant;
+import com.google.cloud.talent.v4beta1.TenantName;
+import com.google.cloud.talent.v4beta1.TenantOrProjectName;
+import com.google.cloud.talent.v4beta1.TenantServiceClient;
+import com.google.cloud.talent.v4beta1.UpdateCompanyRequest;
+import com.google.cloud.talent.v4beta1.UpdateJobRequest;
+import com.google.cloud.talent.v4beta1.UpdateTenantRequest;
+import com.google.protobuf.Timestamp;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.UUID;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.threeten.bp.Instant;
+
+public class ITSystemTest {
+
+  private static TenantServiceClient tenantServiceClient;
+  private static CompanyServiceClient companyServiceClient;
+  private static JobServiceClient jobServiceClient;
+  private static EventServiceClient eventServiceClient;
+  private static CompletionClient completionClient;
+  private static Tenant tenant;
+  private static String tenantId;
+  private static TenantName tenantName;
+  private static Company company;
+  private static String companyId;
+  private static CompanyName companyName;
+  private static Job job;
+  private static String jobId;
+  private static JobName jobName;
+  private static final String PROJECT_ID = ServiceOptions.getDefaultProjectId();
+  private static final String TENANT_NAME =
+      "projects/"
+          + PROJECT_ID
+          + "/tenants/"
+          + "tenant-test-"
+          + UUID.randomUUID().toString().substring(0, 8);
+  private static final ProjectName PROJECT_NAME = ProjectName.of(PROJECT_ID);
+  private static TenantOrProjectName projectName;
+  private static final String DISPLAY_NAME =
+      "display-name-test-" + UUID.randomUUID().toString().substring(0, 8);
+  private static final String EXTERNAL_ID = String.valueOf(Instant.now().getEpochSecond());
+  private static final String REQUISITION_ID = String.valueOf(Instant.now().getEpochSecond());
+  private static final String DESCRIPTION = "This is a description of this <i>wonderful</i> job!";
+  private static final String TITLE = "Software Engineer";
+  private static final String JOB_APPLICATION_URL = "https://www.example.org/job-posting/123";
+  private static final String ADDRESS_ONE = "1600 Amphitheatre Parkway, Mountain View, CA 94043";
+  private static final String ADDRESS_TWO = "111 8th Avenue, New York, NY 10011";
+  private static final String LANGUAGE_CODE = "en-US";
+
+  @BeforeClass
+  public static void beforeTest() throws IOException {
+
+    /* create tenant */
+    tenantServiceClient = TenantServiceClient.create();
+    Tenant createTenant =
+        Tenant.newBuilder().setName(TENANT_NAME).setExternalId(EXTERNAL_ID).build();
+    CreateTenantRequest request =
+        CreateTenantRequest.newBuilder()
+            .setParent(PROJECT_NAME.toString())
+            .setTenant(createTenant)
+            .build();
+    tenant = tenantServiceClient.createTenant(request);
+    tenantId = getId(tenant.getName());
+    tenantName = TenantName.of(PROJECT_ID, tenantId);
+
+    /* create company */
+    companyServiceClient = CompanyServiceClient.create();
+    projectName = TenantName.of(PROJECT_ID, tenantId);
+    Company createCompany =
+        Company.newBuilder().setDisplayName(DISPLAY_NAME).setExternalId(EXTERNAL_ID).build();
+    CreateCompanyRequest companyRequest =
+        CreateCompanyRequest.newBuilder()
+            .setParent(projectName.toString())
+            .setCompany(createCompany)
+            .build();
+    company = companyServiceClient.createCompany(companyRequest);
+    companyId = getId(company.getName());
+    companyName = CompanyWithTenantName.of(PROJECT_ID, tenantId, companyId);
+
+    /* create job */
+    jobServiceClient = JobServiceClient.create();
+    Job.ApplicationInfo applicationInfo =
+        Job.ApplicationInfo.newBuilder().addAllUris(Arrays.asList(JOB_APPLICATION_URL)).build();
+    Job createJob =
+        Job.newBuilder()
+            .setCompany(companyId)
+            .setRequisitionId(REQUISITION_ID)
+            .setTitle(TITLE)
+            .setDescription(DESCRIPTION)
+            .setApplicationInfo(applicationInfo)
+            .addAllAddresses(Arrays.asList(ADDRESS_ONE, ADDRESS_TWO))
+            .setLanguageCode(LANGUAGE_CODE)
+            .build();
+    CreateJobRequest jobRequest =
+        CreateJobRequest.newBuilder().setParent(projectName.toString()).setJob(createJob).build();
+    job = jobServiceClient.createJob(jobRequest);
+    jobId = getId(job.getName());
+    jobName = JobWithTenantName.of(PROJECT_ID, tenantId, jobId);
+
+    /*create event */
+    eventServiceClient = EventServiceClient.create();
+
+    // create completion
+    completionClient = CompletionClient.create();
+  }
+
+  @AfterClass
+  public static void afterTest() {
+
+    completionClient.close();
+    eventServiceClient.close();
+
+    /* delete job */
+    DeleteJobRequest jobRequest = DeleteJobRequest.newBuilder().setName(jobName.toString()).build();
+    jobServiceClient.deleteJob(jobRequest);
+    jobServiceClient.close();
+
+    /* delete company */
+    DeleteCompanyRequest companyRequest =
+        DeleteCompanyRequest.newBuilder().setName(companyName.toString()).build();
+    companyServiceClient.deleteCompany(companyRequest);
+    companyServiceClient.close();
+
+    /* delete tenant */
+    DeleteTenantRequest request =
+        DeleteTenantRequest.newBuilder().setName(tenantName.toString()).build();
+    tenantServiceClient.deleteTenant(request);
+    tenantServiceClient.close();
+  }
+
+  @Test
+  public void getTenantTest() {
+    GetTenantRequest request = GetTenantRequest.newBuilder().setName(tenantName.toString()).build();
+    Tenant actual = tenantServiceClient.getTenant(request);
+    assertEquals(tenant.getName(), actual.getName());
+    assertEquals(tenant.getExternalId(), actual.getExternalId());
+  }
+
+  @Test
+  public void listTenantsTest() {
+    ListTenantsRequest request =
+        ListTenantsRequest.newBuilder().setParent(PROJECT_NAME.toString()).build();
+    for (Tenant actual : tenantServiceClient.listTenants(request).iterateAll()) {
+      if (tenant.getName().equals(actual.getName())) {
+        assertEquals(tenant.getExternalId(), actual.getExternalId());
+        assertEquals(tenant.getName(), actual.getName());
+      }
+    }
+  }
+
+  @Test
+  public void updateTenantTest() {
+    String external_id = String.valueOf(Instant.now().getEpochSecond());
+    Tenant updateTenant = tenant.toBuilder().setExternalId(external_id).build();
+    UpdateTenantRequest request = UpdateTenantRequest.newBuilder().setTenant(updateTenant).build();
+    Tenant actual = tenantServiceClient.updateTenant(request);
+    assertEquals(tenant.getName(), actual.getName());
+    assertEquals(external_id, actual.getExternalId());
+  }
+
+  @Test
+  public void getCompanyTest() {
+    GetCompanyRequest request =
+        GetCompanyRequest.newBuilder().setName(companyName.toString()).build();
+    Company actual = companyServiceClient.getCompany(request);
+    assertEquals(company.getName(), actual.getName());
+    assertEquals(company.getDisplayName(), actual.getDisplayName());
+    assertEquals(company.getExternalId(), actual.getExternalId());
+  }
+
+  @Test
+  public void listCompaniesTest() {
+    ListCompaniesRequest request =
+        ListCompaniesRequest.newBuilder().setParent(projectName.toString()).build();
+    for (Company actual : companyServiceClient.listCompanies(request).iterateAll()) {
+      if (company.getName().equals(actual.getName())) {
+        assertEquals(company.getName(), actual.getName());
+        assertEquals(company.getDisplayName(), actual.getDisplayName());
+        assertEquals(company.getExternalId(), actual.getExternalId());
+      }
+    }
+  }
+
+  @Test
+  public void updateCompanyTest() {
+    String careerSiteUri = "www.example.com";
+    Company updateCompany = company.toBuilder().setCareerSiteUri(careerSiteUri).build();
+    UpdateCompanyRequest request =
+        UpdateCompanyRequest.newBuilder().setCompany(updateCompany).build();
+    Company actual = companyServiceClient.updateCompany(request);
+    assertEquals(company.getName(), actual.getName());
+    assertEquals(company.getDisplayName(), actual.getDisplayName());
+    assertEquals(careerSiteUri, actual.getCareerSiteUri());
+  }
+
+  @Test
+  public void getJobTest() {
+    GetJobRequest request = GetJobRequest.newBuilder().setName(jobName.toString()).build();
+    Job actual = jobServiceClient.getJob(request);
+    assertEquals(job.getName(), actual.getName());
+    assertEquals(job.getCompany(), actual.getCompany());
+    assertEquals(job.getRequisitionId(), actual.getRequisitionId());
+    assertEquals(job.getTitle(), actual.getTitle());
+    assertEquals(job.getDescription(), actual.getDescription());
+    assertEquals(job.getApplicationInfo(), actual.getApplicationInfo());
+    assertEquals(job.getAddressesCount(), actual.getAddressesCount());
+    assertEquals(job.getLanguageCode(), actual.getLanguageCode());
+  }
+
+  @Test
+  public void listJobsTest() {
+    String filter = "companyName =" + "\"" + company.getName() + "\"";
+    ListJobsRequest request =
+        ListJobsRequest.newBuilder().setParent(projectName.toString()).setFilter(filter).build();
+    for (Job actual : jobServiceClient.listJobs(request).iterateAll()) {
+      if (job.getName().equals(actual.getName())) {
+        assertEquals(job.getName(), actual.getName());
+        assertEquals(job.getCompany(), actual.getCompany());
+        assertEquals(job.getRequisitionId(), actual.getRequisitionId());
+        assertEquals(job.getTitle(), actual.getTitle());
+        assertEquals(job.getDescription(), actual.getDescription());
+        assertEquals(job.getApplicationInfo(), actual.getApplicationInfo());
+        assertEquals(job.getAddressesCount(), actual.getAddressesCount());
+        assertEquals(job.getLanguageCode(), actual.getLanguageCode());
+      }
+    }
+  }
+
+  @Test
+  public void updateJobTest() {
+    String department = "Information technology";
+    Job updateJob = job.toBuilder().setDepartment(department).build();
+    UpdateJobRequest request = UpdateJobRequest.newBuilder().setJob(updateJob).build();
+    Job actual = jobServiceClient.updateJob(request);
+    assertEquals(job.getName(), actual.getName());
+    assertEquals(job.getCompany(), actual.getCompany());
+    assertEquals(job.getRequisitionId(), actual.getRequisitionId());
+    assertEquals(job.getTitle(), actual.getTitle());
+    assertEquals(job.getDescription(), actual.getDescription());
+    assertEquals(job.getApplicationInfo(), actual.getApplicationInfo());
+    assertEquals(job.getAddressesCount(), actual.getAddressesCount());
+    assertEquals(job.getLanguageCode(), actual.getLanguageCode());
+    assertEquals(department, actual.getDepartment());
+  }
+
+  @Test
+  public void createEventTest() {
+    String requestId = String.valueOf(Instant.now().getEpochSecond());
+    String eventId = String.valueOf(Instant.now().getEpochSecond());
+    Instant now = Instant.now();
+    Timestamp createTime =
+        Timestamp.newBuilder().setSeconds(now.getEpochSecond()).setNanos(now.getNano()).build();
+    JobEvent jobEvent =
+        JobEvent.newBuilder()
+            .setType(JobEvent.JobEventType.VIEW)
+            .addAllJobs(Arrays.asList(job.getName()))
+            .build();
+    ClientEvent clientEvent =
+        ClientEvent.newBuilder()
+            .setRequestId(requestId)
+            .setEventId(eventId)
+            .setCreateTime(createTime)
+            .setJobEvent(jobEvent)
+            .build();
+    CreateClientEventRequest request =
+        CreateClientEventRequest.newBuilder()
+            .setParent(projectName.toString())
+            .setClientEvent(clientEvent)
+            .build();
+    ClientEvent actual = eventServiceClient.createClientEvent(request);
+    assertEquals(requestId, actual.getRequestId());
+    assertEquals(eventId, actual.getEventId());
+    assertEquals(createTime, actual.getCreateTime());
+    assertEquals(jobEvent.getType(), actual.getJobEvent().getType());
+  }
+
+  @Test
+  public void completeQueryTest() {
+    CompleteQueryRequest request =
+        CompleteQueryRequest.newBuilder()
+            .setParent(projectName.toString())
+            .setQuery("Soft")
+            .setPageSize(5)
+            .addAllLanguageCodes(Arrays.asList(LANGUAGE_CODE))
+            .build();
+    CompleteQueryResponse queryResponse = completionClient.completeQuery(request);
+    for (CompleteQueryResponse.CompletionResult result : queryResponse.getCompletionResultsList()) {
+      if (TITLE.equals(result.getSuggestion())) {
+        assertEquals(CompleteQueryRequest.CompletionType.JOB_TITLE, result.getType());
+      }
+    }
+  }
+
+  static String getId(String name) {
+    return name.substring(name.lastIndexOf("/")).replace("/", "");
+  }
+}

pom.xml

@@ -136,6 +136,11 @@
         <artifactId>proto-google-common-protos</artifactId>
         <version>${google.common-protos.version}</version>
       </dependency>
+      <dependency>
+        <groupId>com.google.cloud</groupId>
+        <artifactId>google-cloud-core</artifactId>
+        <version>${google.core.version}</version>
+      </dependency>
       <dependency>
         <groupId>org.threeten</groupId>
         <artifactId>threetenbp</artifactId>