fix: Provider states

Author: ArneLimburg

.github/workflows/build.yaml

@@ -88,7 +88,7 @@ jobs:
         working-directory: customer-client
 
       - name: Build customer-service
-        run: mvn clean package -f customer-service/pom.xml -Dservice.name=customer-service -DskipTests
+        run: mvn clean package -f customer-service/pom.xml -Dservice.name=customer-service
 
       - name: Build billing-service
         run: mvn clean package -f billing-service/pom.xml -Dservice.name=billing-service

customer-client/test/create-customer.spec.ts

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 import { test, expect } from '@playwright/test';
-import { setupApiProxy } from './pact-proxy';
+import { createProvider, setupApiProxy } from './pact-proxy';
 import { PactV4 } from '@pact-foundation/pact';
 import path from 'path';
 
@@ -32,12 +32,7 @@ test.describe('Neuer Kunde', () => {
   });
 
   test('erstellt Kunden erfolgreich und navigiert zur Liste', async ({ page }) => {
-    const provider = new PactV4({
-      consumer: 'create-customer',
-      provider: 'customer-service',
-      dir: path.resolve(process.cwd(), '../pacts'),
-      logLevel: 'warn',
-    });
+    const provider = createProvider();
 
     provider
       .addInteraction()
@@ -51,7 +46,8 @@ test.describe('Neuer Kunde', () => {
 
     await provider
       .addInteraction()
-      .uponReceiving('a request to get all customers')
+	  .given("Sherlock is available")
+      .uponReceiving('a request to get all customers (inkl. Sherlock)')
       .withRequest('GET', '/customers/')
       .willRespondWith(200, (builder) => {
         builder.headers({ 'Content-Type': 'application/json' }).jsonBody([

customer-service/src/main/java/de/openknowledge/sample/customer/domain/CustomerRepository.java

@@ -42,6 +42,7 @@ public class CustomerRepository {
     @PostConstruct
     public void initialize() {
 
+        CUSTOMER_NUMBERS.set(0);
         customers = new ConcurrentHashMap<>();
         customers.put(new CustomerNumber("0815"),
             new Customer(new CustomerNumber("0815"), new CustomerName("Max Mustermann")));

customer-service/src/test/java/de/openknowledge/sample/customer/CustomerServiceTest.java

@@ -37,11 +37,15 @@
 import au.com.dius.pact.provider.junit5.PactVerificationContext;
 import au.com.dius.pact.provider.junit5.PactVerificationInvocationContextProvider;
 import au.com.dius.pact.provider.junitsupport.Provider;
+import au.com.dius.pact.provider.junitsupport.State;
 import au.com.dius.pact.provider.junitsupport.loader.PactFolder;
 import de.openknowledge.sample.address.domain.Address;
 import de.openknowledge.sample.address.domain.BillingAddressRepository;
 import de.openknowledge.sample.address.domain.DeliveryAddressRepository;
+import de.openknowledge.sample.customer.domain.Customer;
+import de.openknowledge.sample.customer.domain.CustomerName;
 import de.openknowledge.sample.customer.domain.CustomerNumber;
+import de.openknowledge.sample.customer.domain.CustomerRepository;
 import rocks.limburg.cdimock.MockitoBeans;
 
 @Provider("customer-service")
@@ -53,6 +57,9 @@ public class CustomerServiceTest {
     @ConfigurationInject
     private Meecrowave.Builder config;
 
+    @Inject
+    private CustomerRepository customerRepository;
+
     @Inject
     private BillingAddressRepository billingAddressRepository;
 
@@ -96,4 +103,9 @@ public void setUp(PactVerificationContext verificationContext) {
     void pactVerificationTestTemplate(PactVerificationContext context) {
         ofNullable(context).ifPresent(PactVerificationContext::verifyInteraction);
     }
+
+    @State("Sherlock is available")
+    public void insertSherlock() {
+        customerRepository.persist(new Customer(new CustomerName("Sherlock Holmes")));
+    }
 }

customer-service/src/test/java/de/openknowledge/sample/customer/domain/TestCustomerRepository.java

@@ -15,11 +15,15 @@
  */
 package de.openknowledge.sample.customer.domain;
 
+import jakarta.enterprise.context.Destroyed;
 import jakarta.enterprise.context.RequestScoped;
+import jakarta.enterprise.event.Observes;
 import jakarta.enterprise.inject.Specializes;
 
 @Specializes
-@RequestScoped
 public class TestCustomerRepository extends CustomerRepository {
 
+    public void reset(@Observes @Destroyed(RequestScoped.class) Object event) {
+        super.initialize();
+    }
 }