@Provider(PACT_PROVIDER)
/* Uncomment this and comment @PactBroker instead to test locally by pasting a .json file for the contract under
 the target/pacts folder */
@PactFolder("target/pacts")
// @PactBroker(host = BROKER_PACT_URL, consumers = {"MY_CONSUMER"})
@VerificationReports(value = {"markdown"}, reportDir = "target/pacts")
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@Sql(scripts = {"classpath:clean-up.sql", "classpath:init.sql"}, executionPhase = BEFORE_TEST_METHOD)
@TestInstance(TestInstance.Lifecycle.PER_CLASS)
class ProviderIT extends BasePostgresConfig {

    @LocalServerPort
    int port;

    RequestSpecification rq;

    @BeforeAll
    void setUp() {
        Map<String, String> headers = new HashMap<>();
        rq = getRequestSpecification().baseUri("<http://localhost>:" + port)
                .contentType(ContentType.JSON)
                .headers(headers);
    }

    @TestTemplate
    @ExtendWith(PactVerificationInvocationContextProvider.class)
    void pactTestTemplate(PactVerificationContext context, HttpRequest request) {
        logCurlFromPact(context, request, "<http://localhost>:" + port);
        context.verifyInteraction();
    }

    @BeforeEach
    void before(PactVerificationContext context) {
        context.setTarget(new HttpTestTarget("localhost", port, ""));
    }

    @State("A request to retrieve a product")
    Map<String, Object> getProduct() {
        Map<String, Object> map = new HashMap<>();
        map.put("productId", "d3256c76-62d7-4481-9d1c-a0ccc4da380f");
        return map;
    }

public static void logCurlFromPact(PactVerificationContext context, HttpRequest request, String baseUri) {
    String bodyParam = ((RequestResponseInteraction) context.getInteraction()).getRequest().getBody().valueAsString();
    String bodyResponse = ((RequestResponseInteraction) context.getInteraction()).getResponse().getBody().valueAsString();
    String method = ((RequestResponseInteraction) context.getInteraction()).getRequest().getMethod();

    String url = baseUri + request.getPath();

    Header[] headers = request.getHeaders();
    String headersString = "";
    for (Header s : headers) {
        headersString = headersString + "--header " + "'" + s.getName() + ": " + s.getValue() + "'" + "\\" + "\n";
    }

    String curl = """
            curl --request %s '%s' \
            %s --data-binary '%s' \
            --compressed --insecure --verbose
            """.formatted(method, url, headersString, bodyParam);


    log.debug(curl + "\n\n " + bodyResponse + "\n ---- \n\n");
}