如何使用Pact在Java契约中动态注入ID

import au.com.dius.pact.provider.junit5.PactVerificationContext;
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 au.com.dius.pact.provider.junitsupport.verification.VerificationReports;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.TestTemplate;
import org.junit.jupiter.api.extension.ExtendWith;
import java.util.HashMap;
import java.util.Map;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Provider("Assignments API") // 定义生产者名称
//@PactBroker(url = "YOUR_PACT_BROKER_URL", authentication = @PactBrokerAuth(token = "${pactbroker.auth.token}"))
@VerificationReports(value = {"console", "markdown"}, reportDir = "target/pacts")
class PactProviderLTIAGSIT {

    private String updateAssignmentId; // 存储动态生成的ID

    @BeforeEach
    void createAssignmentBeforeEachTest() {
        // 模拟在测试前创建资源，并获取其ID
        // 实际场景中，这里会调用API或数据库操作来创建数据
        // 假设我们通过某种方式获得了动态ID
        this.updateAssignmentId = "dynamic-assignment-id-" + System.currentTimeMillis();
        log.info("动态生成的 assignment id 是: " + updateAssignmentId);
    }

    @State("Scoring info is passed between ags-tool and assignmentapi")
    public Map<String, Object> getScoringInfo() {
        Map<String, Object> map = new HashMap<>();
        // 将动态ID放入Map中，供消费者契约使用
        map.put("assignmentId", updateAssignmentId);
        return map;
    }

    // 其他Pact验证相关的配置和测试方法
    @BeforeEach
    void before(PactVerificationContext context) {
        // 设置目标服务，例如：
        // context.setTarget(new HttpsTestTarget(BASE_PACT_TEACHER_ASSIGNMENTS_URL, 443, ""));
    }

    @TestTemplate
    @ExtendWith(PactVerificationInvocationContextProvider.class)
    void pactTestTemplate(PactVerificationContext context) {
        context.verifyInteraction();
    }
}

import au.com.dius.pact.consumer.dsl.DslPart;
import au.com.dius.pact.consumer.dsl.PactDslJsonBody;
import au.com.dius.pact.consumer.junit5.PactConsumerTestExt;
import au.com.dius.pact.consumer.junit5.PactTestFor;
import au.com.dius.pact.core.model.RequestResponsePact;
import au.com.dius.pact.core.model.annotations.Pact;
import au.com.dius.pact.core.model.PactSpecVersion;
import au.com.dius.pact.consumer.MockServer;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import java.util.HashMap;
import java.util.Map;
import static org.junit.jupiter.api.Assertions.assertEquals;

@ExtendWith(PactConsumerTestExt.class)
class PactConsumerSendScoreIT {

    private static final String PACT_PROVIDER = "Assignments API";
    private static final String PACT_CONSUMER = "LTI-AGS-Tool";
    private final Map<String, String> headers = new HashMap<>();
    private final String path = "/v5/assignmentStatus/update";

    @Pact(provider = PACT_PROVIDER, consumer = PACT_CONSUMER)
    public RequestResponsePact scoreConsumerPact(PactDslWithProvider builder) {

        headers.put("Content-Type", "application/json");

        // 定义请求体
        DslPart requestBody = new PactDslJsonBody()
                // 关键：使用valueFromProviderState来动态注入ID
                // 第一个参数是JSON字段名，第二个参数是Provider State中对应的键名，
                // 第三个参数是消费者端测试时的默认值（当Provider State不活跃时使用）
                .valueFromProviderState("assignmentId", "${assignmentId}", "c1ef3bbf-55a2-4638-8f93-22b2916fe085")
                .stringType("timestamp", "2023-10-27T10:00:00.000+08:00") // 示例时间戳
                .decimalType("scoreGiven", 75.00)
                .decimalType("scoreMaximum", 100.00)
                .stringType("comment", "Good work!")
                .stringType("status", "IN_PROGRESS")
                .stringType("userId", "c2ef3bbf-55a2-4638-8f93-22b2916fe085");

        return builder
                .given("Scoring info is passed between ags-tool and assignmentapi") // 引用生产者状态
                .uponReceiving("Send scoring info to assignmentapi")
                .path(path)
                .method("POST")
                .body(requestBody)
                .headers(headers)
                .willRespondWith()
                .status(201)
                .body(requestBody) // 响应体也可以包含动态ID，如果需要的话
                .toPact();
    }

    @Test
    @PactTestFor(pactMethod = "scoreConsumerPact", providerName = PACT_PROVIDER, port = "8080", pactVersion = PactSpecVersion.V3)
    void runTest(MockServer mockServer) {
        // 消费者端测试时，需要提供一个具体的ID值来与MockServer交互
        // 这个ID值通常是契约中定义的默认值，或者是一个固定的测试值
        String testAssignmentId = "c1ef3bbf-55a2-4638-8f93-22b2916fe085";

        Map<String, Object> requestMap = new HashMap<>();
        requestMap.put("assignmentId", testAssignmentId);
        requestMap.put("timestamp", "2023-10-27T10:00:00.000+08:00");
        requestMap.put("scoreGiven", 75.00);
        requestMap.put("scoreMaximum", 100.00);
        requestMap.put("comment", "Good work!");
        requestMap.put("status", "IN_PROGRESS");
        requestMap.put("userId", "c2ef3bbf-55a2-4638-8f93-22b2916fe085");

        // 模拟调用生产者服务
        // RequestSpecification rq = Util.getRequestSpecification().baseUri(mockServer.getUrl()).headers(headers);
        // Response response = rq.body(requestMap).post(path);
        // assertEquals(201, response.getStatusCode());
        // 简化示例，实际应使用HTTP客户端发起请求
        // 假设这里调用了一个客户端方法，并验证结果
        System.out.println("Consumer test simulating request to MockServer with ID: " + testAssignmentId);
        // 实际的HTTP请求和断言
        // ...
        assertEquals(201, 201); // 模拟成功
    }
}

.valueFromProviderState("assignmentId", "${assignmentId}", "c1ef3bbf-55a2-4638-8f93-22b2916fe085")