Skip to content

Commit 60cad22

Browse files
fix: add mandatory transfer type (#187)
1 parent e217155 commit 60cad22

File tree

2 files changed

+9
-4
lines changed

2 files changed

+9
-4
lines changed

extensions/common/azure/azure-blob-core/src/main/java/org/eclipse/edc/azure/blob/AzureBlobStoreSchema.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,14 +20,15 @@
2020
*/
2121
public class AzureBlobStoreSchema {
2222

23-
private AzureBlobStoreSchema() {
24-
}
25-
2623
public static final String TYPE = "AzureStorage";
24+
public static final String TRANSFERTYPE_PUSH = TYPE + "-PUSH";
2725
public static final String CONTAINER_NAME = "container";
2826
public static final String ACCOUNT_NAME = "account";
2927
public static final String BLOB_NAME = "blobName";
3028
public static final String BLOB_PREFIX = "blobPrefix";
3129
public static final String FOLDER_NAME = "folderName";
3230
public static final String CORRELATION_ID = "correlationId";
31+
32+
private AzureBlobStoreSchema() {
33+
}
3334
}

system-tests/azure-blob-transfer-fixtures/src/testFixtures/java/org/eclipse/edc/test/system/blob/BlobTransferParticipant.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,11 @@ public String requestAssetAndTransferToBlob(Participant provider, String assetId
8686
.add(AzureBlobStoreSchema.ACCOUNT_NAME, accountName))
8787
.build();
8888

89-
return super.requestAsset(provider, assetId, createObjectBuilder().build(), destination);
89+
return this.requestAssetFrom(assetId, provider)
90+
.withPrivateProperties(createObjectBuilder().build())
91+
.withDestination(destination)
92+
.withTransferType(AzureBlobStoreSchema.TRANSFERTYPE_PUSH)
93+
.execute();
9094
}
9195

9296
public static final class Builder extends Participant.Builder<BlobTransferParticipant, Builder> {

0 commit comments

Comments
 (0)