Adding PactProvider for verifying consumer contrcat

.env

@@ -1,2 +1,4 @@
 SERVER_PORT=4550
 BASE_IMAGE=openjdk:21-jdk-slim
+PACT_BROKER_URL=https://hmcts-dts.pactflow.io
+PACT_ENV=dev/pactTest

build.gradle

@@ -7,6 +7,7 @@ plugins {
   id 'maven-publish'
   id "com.github.ben-manes.versions" version "0.52.0"
   id "org.cyclonedx.bom" version "2.3.1"
+  id "au.com.dius.pact" version "4.6.17"
 }
 
 group = 'uk.gov.hmcts.cp'
@@ -272,4 +273,17 @@ dependencies {
     exclude group: 'junit', module: 'junit'
     exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
   }
+
+  testImplementation 'au.com.dius.pact.provider:junit5:4.6.17'
+  testImplementation 'au.com.dius.pact.provider:spring6:4.6.17'
+
+  test{
+    systemProperty 'pact.verifier.publishResults', System.getProperty('pact.verifier.publishResults')
+    systemProperty 'pact.provider.version', System.getProperty('pact.provider.version')
+    systemProperty("pact.provider.branch", "dev/pactTest")
+    systemProperty 'PACT_BROKER_TOKEN', System.getProperty('PACT_BROKER_TOKEN')
+    systemProperty 'PACT_BROKER_HOST', System.getProperty('PACT_BROKER_HOST')
+    //systemProperty 'GIT_BRANCH', System.getProperty('GIT_BRANCH')
+
+  }
 }

publish-pacts.sh

@@ -0,0 +1,35 @@
+#!/bin/bash
+
+# Load env vars from .env if available
+if [ -f .env ]; then
+  set -a
+  source .env
+  set +a
+fi
+
+# Export Git metadata
+export GIT_COMMIT=$(git rev-parse HEAD)
+
+if [ -n "$GIT_BRANCH" ]; then
+  BRANCH_NAME="$GIT_BRANCH"
+else
+  BRANCH_NAME=$(git rev-parse --abbrev-ref HEAD)
+fi
+
+export GIT_BRANCH="$BRANCH_NAME"
+
+# Run provider verification with results published
+./gradlew test \
+  -Dpact.provider.version="$GIT_COMMIT" \
+  -Dpact.verifier.publishResults=true \
+  -Dpact.provider.branch="$GIT_BRANCH" \
+  -DPACT_BROKER_TOKEN="$PACT_BROKER_TOKEN" \
+  -DPACT_BROKER_HOST="$PACT_BROKER_URL"
+
+# Optional: tag provider in the broker
+pact-broker create-version-tag \
+  --pacticipant "VPCourtSchedulePactProvider" \
+  --version "$GIT_COMMIT" \
+  --tag "$PACT_ENV" \
+  --broker-base-url "$PACT_BROKER_URL" \
+  --broker-token "$PACT_BROKER_TOKEN"

src/main/java/uk/gov/hmcts/cp/repositories/CourtScheduleRepository.java

@@ -3,10 +3,12 @@
 import org.springframework.stereotype.Repository;
 import uk.gov.hmcts.cp.openapi.model.CourtScheduleResponse;
 
-@FunctionalInterface
+//@FunctionalInterface
 @Repository
-public interface CourtScheduleRepository {
+public interface CourtScheduleRepository  {
 
     CourtScheduleResponse getCourtScheduleByCaseUrn(String caseUrn);
+    void saveCourtSchedule(final String caseUrn, final CourtScheduleResponse CourtScheduleResponse);
+    void clearAll();
 
 }

src/main/java/uk/gov/hmcts/cp/repositories/InMemoryCourtScheduleRepositoryImpl.java

@@ -1,40 +1,74 @@
 package uk.gov.hmcts.cp.repositories;
 
+import org.springframework.context.annotation.Profile;
 import org.springframework.stereotype.Component;
-import uk.gov.hmcts.cp.openapi.model.CourtSchedule;
 import uk.gov.hmcts.cp.openapi.model.CourtScheduleResponse;
-import uk.gov.hmcts.cp.openapi.model.CourtSitting;
+import uk.gov.hmcts.cp.openapi.model.CourtSchedule;
 import uk.gov.hmcts.cp.openapi.model.Hearing;
+import uk.gov.hmcts.cp.openapi.model.CourtSitting;
 
 import java.time.OffsetDateTime;
+import java.time.ZoneOffset;
+import java.time.temporal.ChronoUnit;
 import java.util.List;
+import java.util.Map;
 import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
 
 @Component
+//@Profile("test")
 public class InMemoryCourtScheduleRepositoryImpl implements CourtScheduleRepository {
 
+    private final Map<String, CourtScheduleResponse> courtScheduleResponseMap = new ConcurrentHashMap<>();
+
+    public void saveCourtSchedule(final String caseUrn, final CourtScheduleResponse CourtScheduleResponse) {
+        courtScheduleResponseMap.put(caseUrn, CourtScheduleResponse);
+    }
+
     public CourtScheduleResponse getCourtScheduleByCaseUrn(final String caseUrn) {
-        final Hearing courtScheduleHearing = Hearing.builder()
+        if (!courtScheduleResponseMap.containsKey(caseUrn)) {
+            saveCourtSchedule(caseUrn, createCourtScheduleResponse());
+        }
+        return courtScheduleResponseMap.get(caseUrn);
+    }
+
+    public void clearAll() {
+        courtScheduleResponseMap.clear();
+    }
+
+    private CourtScheduleResponse createCourtScheduleResponse() {
+
+        OffsetDateTime sittingStartTime = OffsetDateTime.now(ZoneOffset.UTC)
+                .truncatedTo(ChronoUnit.SECONDS);
+
+        final Hearing hearing = Hearing.builder()
                 .hearingId(UUID.randomUUID().toString())
                 .listNote("Requires interpreter")
                 .hearingDescription("Sentencing for theft case")
                 .hearingType("Trial")
                 .courtSittings(List.of(
                         CourtSitting.builder()
                                 .courtHouse("Central Criminal Court")
-                                .sittingStart(OffsetDateTime.now())
-                                .sittingEnd(OffsetDateTime.now().plusMinutes(60))
+                                .sittingStart(sittingStartTime)
+                                .sittingEnd(sittingStartTime.plusMinutes(60))
                                 .judiciaryId(UUID.randomUUID().toString())
                                 .build())
                 ).build();
 
         return CourtScheduleResponse.builder()
                 .courtSchedule(List.of(
                                 CourtSchedule.builder()
-                                        .hearings(List.of(courtScheduleHearing)
+                                        .hearings(List.of(hearing)
                                         ).build()
                         )
                 ).build();
     }
 
+
+    public static void main(String[] args) {
+        OffsetDateTime sittingStartTime = OffsetDateTime.now(ZoneOffset.UTC)
+                .truncatedTo(ChronoUnit.SECONDS);
+        System.out.println(sittingStartTime);
+
+    }
 }

src/test/java/uk/gov/hmcts/cp/controllers/CourtScheduleControllerTest.java

@@ -9,6 +9,7 @@
 import org.springframework.web.server.ResponseStatusException;
 import uk.gov.hmcts.cp.openapi.model.CourtSchedule;
 import uk.gov.hmcts.cp.openapi.model.CourtScheduleResponse;
+
 import uk.gov.hmcts.cp.openapi.model.CourtSitting;
 import uk.gov.hmcts.cp.openapi.model.Hearing;
 import uk.gov.hmcts.cp.repositories.CourtScheduleRepository;
@@ -52,24 +53,24 @@ void getJudgeById_ShouldReturnJudgesWithOkStatus() {
         assertNotNull(responseBody.getCourtSchedule());
         assertEquals(1, responseBody.getCourtSchedule().size());
 
-        CourtSchedule schedule = responseBody.getCourtSchedule().get(0);
-        assertNotNull(schedule.getHearings());
-        assertEquals(1, schedule.getHearings().size());
+        CourtSchedule courtSchedule = responseBody.getCourtSchedule().get(0);
+        assertNotNull(courtSchedule.getHearings());
+        assertEquals(1, courtSchedule.getHearings().size());
 
-        Hearing hearing = schedule.getHearings().get(0);
+        Hearing hearing = courtSchedule.getHearings().get(0);
         assertNotNull(hearing.getHearingId());
         assertEquals("Requires interpreter", hearing.getListNote());
         assertEquals("Sentencing for theft case", hearing.getHearingDescription());
         assertEquals("Trial", hearing.getHearingType());
         assertNotNull(hearing.getCourtSittings());
         assertEquals(1, hearing.getCourtSittings().size());
 
-        CourtSitting sitting =
+        CourtSitting courtSitting =
                 hearing.getCourtSittings().get(0);
-        assertEquals("Central Criminal Court", sitting.getCourtHouse());
-        assertNotNull(sitting.getSittingStart());
-        assertTrue(sitting.getSittingEnd().isAfter(sitting.getSittingStart()));
-        assertNotNull(sitting.getJudiciaryId());
+        assertEquals("Central Criminal Court", courtSitting.getCourtHouse());
+        assertNotNull(courtSitting.getSittingStart());
+        assertTrue(courtSitting.getSittingEnd().isAfter(courtSitting.getSittingStart()));
+        assertNotNull(courtSitting.getJudiciaryId());
 
     }
 

src/test/java/uk/gov/hmcts/cp/pact/provider/CourtScheduleProviderPactTest.java

@@ -0,0 +1,89 @@
+package uk.gov.hmcts.cp.pact.provider;
+
+import au.com.dius.pact.provider.junit5.HttpTestTarget;
+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.PactBroker;
+import au.com.dius.pact.provider.junitsupport.loader.PactBrokerAuth;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.TestTemplate;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.boot.test.web.server.LocalServerPort;
+import org.springframework.test.context.junit.jupiter.SpringExtension;
+import uk.gov.hmcts.cp.openapi.model.CourtScheduleResponse;
+import uk.gov.hmcts.cp.openapi.model.CourtSchedule;
+import uk.gov.hmcts.cp.openapi.model.Hearing;
+import uk.gov.hmcts.cp.openapi.model.CourtSitting;
+import uk.gov.hmcts.cp.repositories.CourtScheduleRepository;
+
+import java.time.OffsetDateTime;
+import java.util.List;
+import java.util.UUID;
+
+@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
+//@ActiveProfiles("test")  // important: use the in-memory repo!
+@ExtendWith({SpringExtension.class, PactVerificationInvocationContextProvider.class})
+@Provider("VPCourtSchedulePactProvider")
+@PactBroker(
+        scheme = "https",
+        host = "hmcts-dts.pactflow.io",
+        providerBranch = "dev/pactTest",
+        authentication = @PactBrokerAuth(token = "<token>")
+)
+public class CourtScheduleProviderPactTest {
+
+    @Autowired
+    private CourtScheduleRepository courtScheduleRepository;
+
+    @LocalServerPort
+    private int port;
+
+    @BeforeEach
+    void setupTarget(PactVerificationContext context) {
+        System.out.println("Running test on port: " + port);
+        context.setTarget(new HttpTestTarget("localhost", port));
+        System.out.println("pact.verifier.publishResults: " + System.getProperty("pact.verifier.publishResults"));
+    }
+
+  /*  @BeforeEach
+    public void setupTestTarget(PactVerificationContext context) {
+        context.setTarget(new HttpTestTarget("localhost", 8080));
+    }*/
+
+    @State("court schedule for case 456789 exists")
+    public void setupCourtSchedule() {
+        courtScheduleRepository.clearAll();
+        var courtSitting = CourtSitting.builder()
+                .courtHouse("Central Criminal Court")
+                .sittingStart(OffsetDateTime.now())
+                .sittingEnd(OffsetDateTime.now().plusMinutes(60))
+                .judiciaryId(UUID.randomUUID().toString())
+                .build();
+        var hearing = Hearing.builder()
+                .hearingId(UUID.randomUUID().toString())
+                .listNote("Requires interpreter")
+                .hearingDescription("Sentencing for theft case")
+                .hearingType("Trial")
+                .courtSittings(List.of(courtSitting))
+                .build();
+
+        var schedule = CourtSchedule.builder()
+                .hearings(List.of(hearing))
+                .build();
+
+        var response = CourtScheduleResponse.builder()
+                .courtSchedule(List.of(schedule))
+                .build();
+
+        courtScheduleRepository.saveCourtSchedule("456789", response);
+    }
+
+    @TestTemplate
+    void pactVerificationTestTemplate(PactVerificationContext context) {
+        context.verifyInteraction();
+    }
+}

src/test/java/uk/gov/hmcts/cp/repositories/CourtScheduleRepositoryTest.java

@@ -42,7 +42,7 @@ void getCourtScheduleByCaseUrn_shouldReturnCourtScheduleResponse() {
         assertNotNull(hearing.getCourtSittings());
         assertEquals(1, hearing.getCourtSittings().size());
 
-        CourtSitting sitting =
+       CourtSitting sitting =
                 hearing.getCourtSittings().get(0);
         assertEquals("Central Criminal Court", sitting.getCourtHouse());
         assertNotNull(sitting.getSittingStart());