From b1f6c3acd9802f09eab0a08c378a97ddc8475372 Mon Sep 17 00:00:00 2001 From: AndrYurk Date: Fri, 20 Dec 2024 13:19:13 +0100 Subject: [PATCH] fix:Termination of pull transfer process from consumer side --- .../eclipse/edc/test/e2e/TransferPullEndToEndTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/system-tests/e2e-transfer-test/runner/src/test/java/org/eclipse/edc/test/e2e/TransferPullEndToEndTest.java b/system-tests/e2e-transfer-test/runner/src/test/java/org/eclipse/edc/test/e2e/TransferPullEndToEndTest.java index 1c057e9527..b8b0727724 100644 --- a/system-tests/e2e-transfer-test/runner/src/test/java/org/eclipse/edc/test/e2e/TransferPullEndToEndTest.java +++ b/system-tests/e2e-transfer-test/runner/src/test/java/org/eclipse/edc/test/e2e/TransferPullEndToEndTest.java @@ -172,7 +172,7 @@ void httpPull_dataTransfer_withEdrCache() { @Test void suspendAndResumeByConsumer_httpPull_dataTransfer_withEdrCache() { var assetId = createResources(); - var startedTransferContext = assertTransferProcessIsStarted(assetId); + var startedTransferContext = startTransferProcess(assetId); var edrMessage = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); CONSUMER.suspendTransfer(startedTransferContext.consumerTransferProcessId, "any reason"); @@ -191,7 +191,7 @@ void suspendAndResumeByConsumer_httpPull_dataTransfer_withEdrCache() { @Test void suspendAndResumeByProvider_httpPull_dataTransfer_withEdrCache() { var assetId = createResources(); - var startedTransferContext = assertTransferProcessIsStarted(assetId); + var startedTransferContext = startTransferProcess(assetId); var edrMessage = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); PROVIDER.suspendTransfer(startedTransferContext.providerTransferProcessId, "any reason"); @@ -211,7 +211,7 @@ void suspendAndResumeByProvider_httpPull_dataTransfer_withEdrCache() { @Test void terminateByProvider_httpPull_dataTransfer() { var assetId = createResources(); - var startedTransferContext = assertTransferProcessIsStarted(assetId); + var startedTransferContext = startTransferProcess(assetId); var edrMessage = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); PROVIDER.terminateTransfer(startedTransferContext.providerTransferProcessId); @@ -225,7 +225,7 @@ void terminateByProvider_httpPull_dataTransfer() { @Test void terminateByConsumer_httpPull_dataTransfer() { var assetId = createResources(); - var startedTransferContext = assertTransferProcessIsStarted(assetId); + var startedTransferContext = startTransferProcess(assetId); var edrMessage = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); CONSUMER.terminateTransfer(startedTransferContext.consumerTransferProcessId); @@ -341,7 +341,7 @@ private String createResources(){ return assetId; } - private StartedTransferContext assertTransferProcessIsStarted(String assetId){ + private StartedTransferContext startTransferProcess(String assetId){ var consumerTransferProcessId = CONSUMER.requestAssetFrom(assetId, PROVIDER) .withTransferType("HttpData-PULL") .execute();