import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@PactVerification("test_provider")
@Test
public void get_serval() throws IOException {
    AnimalServiceClient providerRestClient = new AnimalServiceClient();
    Animals response = providerRestClient.getAnimalInformation("http://localhost:1234", "serval");
    assertThat(response.getAnimals().get(0).getName(), is("サーバルちゃん"));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@PactVerification(value = SAML_ENGINE_SERVICE, fragment = "shouldGetValidatedEidasAuthnResponseFromSamlEngine")
@Test
public void shouldGetValidatedEidasAuthnResponseFromSamlEngineVerification() throws Exception {
    configStub.setupStubForEidasRPCountries(TEST_RP, EIDAS_COUNTRIES.stream().map(EidasCountryDto::getEntityId).collect(Collectors.toList()));
    SessionId sessionId = createSessionInCountrySelectingState();
    selectACountry(sessionId);

    Response response = postAuthnResponseToPolicy(sessionId);

    assertThatResponseIsSuccess(response);
    assertThatAQRReceivedBySamlSoapProxyHasSameDataAsSamlEngineSent();
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification
public void getsNullWhenNoCustomerFound() throws IOException {
    CustomerSession customerSession = userService.validateCustomerSession(sessionId);

    assertThat(customerSession, is(nullValue()));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification
public void validatesCustomerWithSessionId() throws IOException {
    CustomerSession actual = userService.validateCustomerSession(customerSessionInfo.getId());

    assertThat(actual, is(customerSessionInfo));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification
public void fetchesExpectedCustomer() throws IOException {
    try {
        userService.getCustomerInfo("mike");
        expectFailing(NoSuchElementException.class);
    } catch (NoSuchElementException e) {
        assertThat(e.getMessage(), is("No such customer with id mike"));
    }
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification
public void fetchesExpectedCustomer() throws IOException {
    CustomerInfo actual = userService.getCustomerInfo(customerInfo.getId());

    assertThat(actual, is(customerInfo));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification
public void blowsUpWhenRemoteIsNotAvailable() throws IOException {
    try {
        customerLoader.loadCustomers(5);
        expectFailing(RuntimeException.class);
    } catch (RuntimeException e) {
        assertThat(e.getMessage(), is("Remote customer loader returns status code 500"));
    }
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@PactVerification
@Test
public void validatesUserToken() {
  when(serviceInstance.getUri()).thenReturn(URI.create(providerRule.getConfig().url()));

  ResponseEntity<String> responseEntity = authenticationService.validate(token);

  assertThat(responseEntity.getStatusCode()).isEqualTo(HttpStatus.FORBIDDEN);
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@PactVerification
@Test
public void validatesUserToken() {
  when(serviceInstance.getUri()).thenReturn(URI.create(providerRule.getConfig().url()));

  ResponseEntity<String> responseEntity = authenticationService.validate(token);

  assertThat(responseEntity.getStatusCode()).isEqualTo(HttpStatus.OK);
  assertThat(responseEntity.getBody()).isEqualTo(username);
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification("our_provider")
public void should_process_the_json_payload_from_provider() {
  TestObserver<ServiceResponse> observer = service.fetchResponse(DATE_TIME).test();
  observer.assertNoErrors();
  observer.assertValue(new ServiceResponse(null, Collections.emptyList()));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification("our_provider")
public void should_process_the_json_payload_from_provider() {
  TestObserver<ServiceResponse> observer = service.fetchResponse(DATE_TIME).test();
  observer.assertNoErrors();
  observer.assertValue(ServiceResponse.create(DATE_TIME, Arrays.asList(
      Animal.create("Doggy", "dog"),
      Animal.create("Doggy", "dog"),
      Animal.create("Doggy", "dog")
  )));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@PactVerification(value = CREDIT_SCORE_SERVICE, fragment = "tonyStarkCreditScore")
@Test
public void createSpecialMembershipToTonyStark() throws Exception {
    Map<String, Object> specialMembershipDto = singletonMap("email", "[email protected]");
    Response response = resourcesClient.postSpecialMembership(specialMembershipDto);
    response.close();
    assertThat(response.getStatus(), equalTo(200));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@PactVerification(value = CREDIT_SCORE_SERVICE, fragment = "hawleyGriffinCreditScore")
@Test
public void denySpecialMembershipToHawleyGriffin() throws Exception {
    Map<String, Object> specialMembershipDto = singletonMap("email", "[email protected]");
    Response response = resourcesClient.postSpecialMembership(specialMembershipDto);
    response.close();
    assertThat(response.getStatus(), equalTo(403));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@PactVerification(value = SPECIAL_MEMBERSHIP_SERVICE, fragment = "newMemberTonyStark")
@Test
public void sendWelcomeEmailToTonyStark() throws Exception {
    String memberSignedUpEvent = new String(specialMembershipServiceRule.getMessage(), UTF_8);
    publishMembershipMessageAndWaitToBeConsumed(memberSignedUpEvent);
    assertAnEmailWasSent();
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification("one-pact-present")
public void downloadPactFromBroker() throws Exception {
    File pactFoder = new File(temporaryFolder.newFolder() + "/target/pacts-dependents");

    brokerRepositoryProvider.downloadPactsFromLinks(Collections.singletonList(pactLink), pactFoder);

    assertThat(
            new File(pactFoder.getAbsoluteFile() + "/" + CONSUMER_NAME + "-" + PROVIDER_NAME + ".json").exists(),
            is(true));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification("one-provider-pact-link-present")
public void downloadProviderPactInformation() throws Exception {
    List<String> links = brokerRepositoryProvider.downloadPactLinks(PROVIDER_NAME, null);

    assertThat(links.size(), is(1));
    assertThat(links.get(0), is(pactLink));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification("one-prod-provider-pact-link-present")
public void downloadProviderPactInformationForProdTag() throws Exception {
    List<String> links = brokerRepositoryProvider.downloadPactLinks(PROVIDER_NAME, "prod");

    assertThat(links.size(), is(1));
    assertThat(links.get(0), is(pactLink));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification("provider-no-pact-link-present")
public void doNotFailDownloadForProviderWithNoPactLinkPresent() throws Exception {
    List<String> links = brokerRepositoryProvider.downloadPactLinks("provider-no-pact-link-present", null);

    assertThat(links.size(), is(0));
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification
public void requestsRemoteToLoadCustomers() throws IOException {
    customerLoader.loadCustomers(5);
}
 

import au.com.dius.pact.consumer.PactVerification; //导入依赖的package包/类
@Test
@PactVerification("our_provider")
public void should_process_the_json_payload_from_provider() {
  TestObserver<ServiceResponse> observer = service.fetchResponse(null).test();
  observer.assertError(BadRequestException.class);
}