Provision Http Extension

[jannotti-glaucio]

Guys, anyone here already used the provision http extension (https://github.com/eclipse-edc/Connector/tree/main/extensions/control-plane/provision/provision-http) ? I'm trying to use it, but the payload example on the swagger documentation is not working:
https://eclipse-edc.github.io/Connector/openapi/management-api/#/Contract%20Negotiation%20V3/initiateContractNegotiationV3

[ndr-brt]

that extension didn't get a lot of love ultimately, you could take a look at the E2E test that's covering that feature:

Connector/system-tests/e2e-transfer-test/runner/src/test/java/org/eclipse/edc/test/e2e/TransferPullEndToEndTest.java

Line 208 in c5dbf9d

void pullFromHttp_httpProvision() {

for the non-working documentation, could you open an issue about it? thanks

[jannotti-glaucio]

Thanks @ndr-brt for the help, but I already understood how the extension works. My issue is related to knowing how to call the provision endpoint to move the transfer process from the provision requested status to the next status on the process.

The latest swagger is defining the /provision payload as below, but this format doesn`t work and there is no information about what we need to inform for each tag:

I will open the documentation issue, but I need to know where I can find any example or documentation explaining how to use this endpoint to make the transfer process continue. It can be a source code comment or a test case.

[ndr-brt]

the test I linked in the previous message does exactly this, please look at the HttpProvisionerCallback object:

Connector/system-tests/e2e-transfer-test/runner/src/test/java/org/eclipse/edc/test/e2e/TransferPullEndToEndTest.java

Lines 302 to 325 in c5dbf9d

	var requestBody = MAPPER.readValue(httpRequest.getBodyAsString(), Map.class);
	var callbackRequestBody = Map.of(
	"edctype", "dataspaceconnector:provisioner-callback-request",
	"resourceDefinitionId", requestBody.get("resourceDefinitionId"),
	"assetId", requestBody.get("assetId"),
	"resourceName", "aName",
	"contentDataAddress", Map.of("properties", httpSourceDataAddress()),
	"apiKeyJwt", "unused",
	"hasToken", false
	);
	Executors.newScheduledThreadPool(1).schedule(() -> {
	try {
	var request = new Request.Builder()
	.url("%s/%s/provision".formatted(requestBody.get("callbackAddress"), requestBody.get("transferProcessId")))
	.post(RequestBody.create(MAPPER.writeValueAsString(callbackRequestBody), get("application/json")))
	.build();
	testHttpClient().execute(request).close();
	} catch (Exception e) {
	throw new EdcException(e);
	}
	}, 1, SECONDS);

plus, "doesn't work" is not a good report: some errors or stack traces would be really helpful