Skip to content

Commit

Permalink
fix:Termination of pull transfer process from consumer side
Browse files Browse the repository at this point in the history
  • Loading branch information
AndrYurk committed Dec 20, 2024
1 parent 535a8e3 commit b1f6c3a
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand All @@ -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");
Expand All @@ -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);
Expand All @@ -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);
Expand Down Expand Up @@ -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();
Expand Down

0 comments on commit b1f6c3a

Please sign in to comment.