diff --git a/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/Streaming01httpToHttpTest.java b/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/Streaming01httpToHttpTest.java index 93dea471..fed0453e 100644 --- a/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/Streaming01httpToHttpTest.java +++ b/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/Streaming01httpToHttpTest.java @@ -96,22 +96,22 @@ void streamData() throws IOException { PROVIDER.createPolicyDefinition(getFileContentFromRelativePath(SAMPLE_FOLDER + "/policy-definition.json")); PROVIDER.createContractDefinition(getFileContentFromRelativePath(SAMPLE_FOLDER + "/contract-definition.json")); - var catalogDatasetId = CONSUMER.fetchDatasetFromCatalog(getFileContentFromRelativePath(SAMPLE_FOLDER + "/get-dataset.json")); + var catalogDatasetId = CONSUMER.fetchDatasetFromCatalog(getFileContentFromRelativePath(SAMPLE_FOLDER + "/get-dataset.json")); var negotiateContractBody = getFileContentFromRelativePath(SAMPLE_FOLDER + "/negotiate-contract.json") .replace("{{offerId}}", catalogDatasetId); - //assertThat(catalogDatasetId).isEqualTo("test", catalogDatasetId); + //assertThat(catalogDatasetId).isEqualTo("test", catalogDatasetId); var contractNegotiationId = CONSUMER.negotiateContract(negotiateContractBody); await().atMost(TIMEOUT).untilAsserted(() -> { - var contractAgreementId = CONSUMER.getContractAgreementId(contractNegotiationId); - assertThat(contractAgreementId).isNotNull(); + var contractAgreementId = CONSUMER.getContractAgreementId(contractNegotiationId); + assertThat(contractAgreementId).isNotNull(); }); var contractAgreementId = CONSUMER.getContractAgreementId(contractNegotiationId); - var requestBody = getFileContentFromRelativePath(SAMPLE_FOLDER + "/transfer.json") + var requestBody = getFileContentFromRelativePath(SAMPLE_FOLDER + "/transfer.json") .replace("{{contract-agreement-id}}", contractAgreementId) - .replace("4000", ""+httpReceiverPort); + .replace("4000", "" + httpReceiverPort); var transferProcessId = CONSUMER.startTransfer(requestBody); diff --git a/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/StreamingParticipant.java b/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/StreamingParticipant.java index d1a2e167..c1f8718a 100644 --- a/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/StreamingParticipant.java +++ b/system-tests/src/test/java/org/eclipse/edc/samples/transfer/streaming/StreamingParticipant.java @@ -18,7 +18,6 @@ import static io.restassured.http.ContentType.JSON; import static org.eclipse.edc.jsonld.spi.JsonLdKeywords.ID; -import static org.hamcrest.Matchers.theInstance; /** * Essentially a wrapper around the management API enabling to test interactions with other participants, eg. catalog, transfer...