working (but awkward) example of a message provider test

Author: thombergs

pact/pact-message-provider/src/test/java/io/reflectoring/CustomAmqpTarget.java

@@ -0,0 +1,35 @@
+package io.reflectoring;
+
+import java.util.List;
+
+import au.com.dius.pact.model.Interaction;
+import au.com.dius.pact.model.ProviderState;
+import au.com.dius.pact.provider.ConsumerInfo;
+import au.com.dius.pact.provider.ProviderInfo;
+import au.com.dius.pact.provider.ProviderVerifier;
+import au.com.dius.pact.provider.junit.target.AmqpTarget;
+import org.jetbrains.annotations.NotNull;
+
+public class CustomAmqpTarget extends AmqpTarget {
+
+	public CustomAmqpTarget(List<String> packagesToScan) {
+		super(packagesToScan);
+	}
+
+	@NotNull
+	@Override
+	protected ProviderVerifier setupVerifier(Interaction interaction, ProviderInfo provider, ConsumerInfo consumer) {
+		ProviderVerifier verifier = new CustomProviderVerifier(getPackagesToScan());
+		setupReporters(verifier, provider.getName(), interaction.getDescription());
+		verifier.initialiseReporters(provider);
+		verifier.reportVerificationForConsumer(consumer, provider);
+
+		if (!interaction.getProviderStates().isEmpty()) {
+			for (ProviderState state : interaction.getProviderStates()) {
+				verifier.reportStateForInteraction(state.getName(), provider, consumer, true);
+			}
+		}
+		verifier.reportInteractionDescription(interaction);
+		return verifier;
+	}
+}

pact/pact-message-provider/src/test/java/io/reflectoring/CustomProviderVerifier.java

@@ -0,0 +1,62 @@
+package io.reflectoring;
+
+import java.lang.reflect.Method;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+import au.com.dius.pact.model.Interaction;
+import au.com.dius.pact.model.v3.messaging.Message;
+import au.com.dius.pact.provider.ConsumerInfo;
+import au.com.dius.pact.provider.PactVerifyProvider;
+import au.com.dius.pact.provider.ProviderInfo;
+import au.com.dius.pact.provider.ProviderVerifier;
+import org.reflections.Reflections;
+import org.reflections.scanners.MethodAnnotationsScanner;
+import org.reflections.util.ConfigurationBuilder;
+
+public class CustomProviderVerifier extends ProviderVerifier {
+
+	private List<String> packagesToScan;
+
+	public CustomProviderVerifier(List<String> packagesToScan) {
+		this.packagesToScan = packagesToScan;
+	}
+
+	@Override
+	public boolean verifyResponseByInvokingProviderMethods(ProviderInfo providerInfo, ConsumerInfo consumer,
+																												 Object interaction, String interactionMessage, Map failures) {
+		try {
+
+			ConfigurationBuilder configurationBuilder = new ConfigurationBuilder()
+							.setScanners(new MethodAnnotationsScanner())
+							.forPackages(packagesToScan.toArray(new String[]{}));
+
+			Reflections reflections = new Reflections(configurationBuilder);
+			Set<Method> methodsAnnotatedWith = reflections.getMethodsAnnotatedWith(PactVerifyProvider.class);
+			Set<Method> providerMethods = methodsAnnotatedWith.stream()
+							.filter(m -> {
+								PactVerifyProvider annotation = m.getAnnotation(PactVerifyProvider.class);
+								return annotation.value().equals(((Interaction)interaction).getDescription());
+							})
+							.collect(Collectors.toSet());
+
+			if (providerMethods.isEmpty()) {
+				throw new RuntimeException("No annotated methods were found for interaction " +
+								"'${interaction.description}'. You need to provide a method annotated with " +
+								"@PactVerifyProvider(\"${interaction.description}\") that returns the message contents.");
+			} else {
+				if (interaction instanceof Message) {
+					verifyMessagePact(providerMethods, (Message) interaction, interactionMessage, failures);
+				} else {
+					throw new RuntimeException("only supports Message interactions!");
+				}
+			}
+		} catch (Exception e) {
+			throw new RuntimeException("verification failed", e);
+		}
+		return true;
+	}
+
+}

pact/pact-message-provider/src/test/java/io/reflectoring/ReflectionsTest.java

@@ -11,8 +11,10 @@
 import au.com.dius.pact.provider.junit.target.AmqpTarget;
 import au.com.dius.pact.provider.junit.target.Target;
 import au.com.dius.pact.provider.junit.target.TestTarget;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.junit.runner.RunWith;
 import org.mockito.ArgumentCaptor;
+import org.mockito.Mockito;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.boot.test.mock.mockito.MockBean;
@@ -21,17 +23,14 @@
 @RunWith(PactRunner.class)
 @Provider("userservice")
 @PactFolder("../pact-message-consumer/target/pacts")
-@SpringBootTest
 public class UserCreatedMessageProviderTest {
 
 	@TestTarget
-	public final Target target = new AmqpTarget(Collections.singletonList("io.reflectoring"));
+	public final Target target = new CustomAmqpTarget(Collections.singletonList("io.reflectoring"));
 
-	@Autowired
-	private UserCreatedMessageProvider messageProvider;
+	private UserCreatedMessagePublisher publisher = Mockito.mock(UserCreatedMessagePublisher.class);
 
-	@MockBean
-	private UserCreatedMessagePublisher publisher;
+	private UserCreatedMessageProvider messageProvider = new UserCreatedMessageProvider(new ObjectMapper(), publisher);
 
 	@PactVerifyProvider("a user created message")
 	public String verifyUserCreatedMessage() throws IOException {