refactor: initiate run checks

eclipse-edc · Jan 21, 2025 · 3d85043 · 3d85043
1 parent c88fee7
commit 3d85043
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/...transfer-test/runner/src/test/java/org/eclipse/edc/test/e2e/TransferPullEndToEndTest.java b/...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<String, TransferProcessStarted>();
             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"));