From 3d850439e62f2cb0ffbf52e180b569d7d91de92d Mon Sep 17 00:00:00 2001 From: AndrYurk Date: Tue, 21 Jan 2025 09:35:01 +0100 Subject: [PATCH] refactor: initiate run checks --- .../edc/test/e2e/TransferPullEndToEndTest.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 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 193db5dde9..6104aa5de4 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 @@ -122,7 +122,7 @@ void httpPull_dataTransfer_withCallbacks() { var events = new ConcurrentHashMap(); callbacksEndpoint.when(request).respond(req -> this.cacheEdr(req, events)); - StartedTransferContext startedTransferContext = startTransferProcess(assetId, callbacks); + var startedTransferContext = startTransferProcess(assetId, callbacks); assertDataIsAccessible(startedTransferContext.consumerTransferProcessId, events); providerDataSource.verify(request("/source").withMethod("GET")); @@ -133,8 +133,8 @@ void httpPull_dataTransfer_withCallbacks() { void httpPull_dataTransfer_withEdrCache() { var assetId = UUID.randomUUID().toString(); createResourcesOnProvider(assetId, PolicyFixtures.contractExpiresIn("10s"), httpSourceDataAddress()); - StartedTransferContext startedTransferContext = startTransferProcess(assetId); - EdrMessageContext edrMessageContext = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); + var startedTransferContext = startTransferProcess(assetId); + var edrMessageContext = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); assertDataIsNotAccessible(startedTransferContext.consumerTransferProcessId, edrMessageContext); providerDataSource.verify(request("/source").withMethod("GET")); } @@ -143,8 +143,8 @@ void httpPull_dataTransfer_withEdrCache() { void suspendAndResumeByConsumer_httpPull_dataTransfer_withEdrCache() { var assetId = UUID.randomUUID().toString(); createResourcesOnProvider(assetId, httpSourceDataAddress()); - StartedTransferContext startedTransferContext = startTransferProcess(assetId); - EdrMessageContext edrMessageContext = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); + var startedTransferContext = startTransferProcess(assetId); + var edrMessageContext = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); CONSUMER.suspendTransfer(startedTransferContext.consumerTransferProcessId, "suspension"); CONSUMER.awaitTransferToBeInState(startedTransferContext.consumerTransferProcessId, SUSPENDED); @@ -163,8 +163,8 @@ void suspendAndResumeByConsumer_httpPull_dataTransfer_withEdrCache() { void suspendAndResumeByProvider_httpPull_dataTransfer_withEdrCache() { var assetId = UUID.randomUUID().toString(); createResourcesOnProvider(assetId, httpSourceDataAddress()); - StartedTransferContext startedTransferContext = startTransferProcess(assetId); - EdrMessageContext edrMessageContext = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); + var startedTransferContext = startTransferProcess(assetId); + var edrMessageContext = assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); PROVIDER.suspendTransfer(startedTransferContext.providerTransferProcessId, "suspension"); PROVIDER.awaitTransferToBeInState(startedTransferContext.providerTransferProcessId, SUSPENDED); @@ -192,7 +192,7 @@ void pullFromHttp_httpProvision() { "proxyQueryParams", "true" )); - StartedTransferContext startedTransferContext = startTransferProcess(assetId); + var startedTransferContext = startTransferProcess(assetId); assertDataIsAccessible(startedTransferContext.consumerTransferProcessId); provisionServer.verify(request("/provision"));