feat: adds AzureStorage blob dataplane provisioning extension (#405)

* feat: add dataplane-provision-blob extension

* Changed e2e tests

* fix ut

* checkstyle

* Deprecation warning

* cs

* added e2e coverage

* nits

* comment

* cs

* suggestions

Author: rafaelmag110

extensions/control-plane/provision/provision-blob/src/main/java/org/eclipse/edc/connector/provision/azure/AzureProvisionExtension.java

@@ -33,7 +33,10 @@
 
 /**
  * Provides data transfer {@link Provisioner}s backed by Azure services.
+ *
+ * @deprecated "The control-plane based azure provision extension is DEPRECATED. Please use the data-plane based provisioner instead."
  */
+@Deprecated(since = "0.15.0")
 public class AzureProvisionExtension implements ServiceExtension {
 
     @Configuration
@@ -59,12 +62,14 @@ public class AzureProvisionExtension implements ServiceExtension {
 
     @Override
     public String name() {
-        return "Azure Provision";
+        return "DEPRECATED: Azure Provision";
     }
 
     @Override
     public void initialize(ServiceExtensionContext context) {
-        provisionManager.register(new ObjectStorageProvisioner(retryPolicy, context.getMonitor(), blobStoreApi, azureProvisionConfiguration));
+        var monitor = context.getMonitor();
+        monitor.warning("The control-plane based azure provision extension is DEPRECATED. Please use the data-plane based provisioner instead.");
+        provisionManager.register(new ObjectStorageProvisioner(retryPolicy, monitor, blobStoreApi, azureProvisionConfiguration));
         manifestGenerator.registerGenerator(new ObjectStorageConsumerResourceDefinitionGenerator(transferTypeParser));
 
         registerTypes(typeManager);

extensions/data-plane/data-plane-provision-blob/build.gradle.kts

@@ -0,0 +1,31 @@
+/*
+ *  Copyright (c) 2025 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ */
+
+
+plugins {
+    `java-library`
+}
+
+dependencies {
+    api(libs.edc.spi.core)
+    api(libs.edc.spi.dataplane)
+
+    implementation(libs.edc.lib.util)
+    implementation(project(":extensions:common:azure:azure-blob-core"))
+    implementation(libs.azure.storageblob)
+
+    testImplementation(testFixtures(project(":extensions:common:azure:azure-test")))
+}
+
+

extensions/data-plane/data-plane-provision-blob/src/main/java/org/eclipse/edc/connector/dataplane/provision/azure/AzureProvisionConfiguration.java

@@ -0,0 +1,24 @@
+/*
+ *  Copyright (c) 2025 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ */
+
+package org.eclipse.edc.connector.dataplane.provision.azure;
+
+import org.eclipse.edc.runtime.metamodel.annotation.Setting;
+import org.eclipse.edc.runtime.metamodel.annotation.Settings;
+
+@Settings
+public record AzureProvisionConfiguration(
+        @Setting(key = "edc.azure.token.expiry.time", description = "Expiration time, in hours, for the SAS token.", defaultValue = "1")
+        long tokenExpiryTime) {
+}

extensions/data-plane/data-plane-provision-blob/src/main/java/org/eclipse/edc/connector/dataplane/provision/azure/AzureProvisionExtension.java

@@ -0,0 +1,81 @@
+/*
+ *  Copyright (c) 2025 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ */
+
+package org.eclipse.edc.connector.dataplane.provision.azure;
+
+import dev.failsafe.RetryPolicy;
+import org.eclipse.edc.azure.blob.AzureSasToken;
+import org.eclipse.edc.azure.blob.api.BlobStoreApi;
+import org.eclipse.edc.connector.controlplane.transfer.spi.provision.Provisioner;
+import org.eclipse.edc.connector.dataplane.provision.azure.blob.ObjectStorageConsumerProvisionResourceGenerator;
+import org.eclipse.edc.connector.dataplane.provision.azure.blob.ObjectStorageDeprovisioner;
+import org.eclipse.edc.connector.dataplane.provision.azure.blob.ObjectStorageProvisioner;
+import org.eclipse.edc.connector.dataplane.spi.provision.ProvisionerManager;
+import org.eclipse.edc.connector.dataplane.spi.provision.ResourceDefinitionGeneratorManager;
+import org.eclipse.edc.runtime.metamodel.annotation.Configuration;
+import org.eclipse.edc.runtime.metamodel.annotation.Inject;
+import org.eclipse.edc.spi.monitor.Monitor;
+import org.eclipse.edc.spi.security.Vault;
+import org.eclipse.edc.spi.system.ServiceExtension;
+import org.eclipse.edc.spi.system.ServiceExtensionContext;
+import org.eclipse.edc.spi.types.TypeManager;
+
+/**
+ * Provides data transfer {@link Provisioner}s backed by Azure services.
+ */
+public class AzureProvisionExtension implements ServiceExtension {
+
+    @Configuration
+    private AzureProvisionConfiguration azureProvisionConfiguration;
+
+    @Inject
+    private BlobStoreApi blobStoreApi;
+
+    @Inject
+    private RetryPolicy<Object> retryPolicy;
+
+    @Inject
+    private ResourceDefinitionGeneratorManager manifestGenerator;
+
+    @Inject
+    private TypeManager typeManager;
+
+    @Inject
+    private Vault vault;
+
+    @Inject
+    private ProvisionerManager provisionManager;
+
+    @Inject
+    private Monitor monitor;
+
+    @Override
+    public String name() {
+        return "Dataplane Azure Provisioner";
+    }
+
+    @Override
+    public void initialize(ServiceExtensionContext context) {
+        provisionManager.register(new ObjectStorageProvisioner(retryPolicy, context.getMonitor(), blobStoreApi, azureProvisionConfiguration, vault, typeManager));
+        provisionManager.register(new ObjectStorageDeprovisioner());
+        manifestGenerator.registerConsumerGenerator(new ObjectStorageConsumerProvisionResourceGenerator(monitor.withPrefix("AzureStorageProvisioner")));
+
+        registerTypes(typeManager);
+    }
+
+    private void registerTypes(TypeManager typeManager) {
+        typeManager.registerTypes(AzureSasToken.class);
+    }
+
+}

extensions/data-plane/data-plane-provision-blob/src/main/java/org/eclipse/edc/connector/dataplane/provision/azure/blob/ObjectStorageConsumerProvisionResourceGenerator.java

@@ -0,0 +1,68 @@
+/*
+ *  Copyright (c) 2025 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ */
+
+package org.eclipse.edc.connector.dataplane.provision.azure.blob;
+
+import org.eclipse.edc.azure.blob.AzureBlobStoreSchema;
+import org.eclipse.edc.connector.dataplane.spi.DataFlow;
+import org.eclipse.edc.connector.dataplane.spi.provision.ProvisionResource;
+import org.eclipse.edc.connector.dataplane.spi.provision.ResourceDefinitionGenerator;
+import org.eclipse.edc.spi.monitor.Monitor;
+import org.eclipse.edc.spi.types.domain.DataAddress;
+
+import java.util.UUID;
+
+import static org.eclipse.edc.spi.constants.CoreConstants.EDC_NAMESPACE;
+import static org.eclipse.edc.util.string.StringUtils.isNullOrEmpty;
+
+
+public class ObjectStorageConsumerProvisionResourceGenerator implements ResourceDefinitionGenerator {
+
+    private final Monitor monitor;
+
+    public ObjectStorageConsumerProvisionResourceGenerator(Monitor monitor) {
+        this.monitor = monitor;
+    }
+
+    @Override
+    public String supportedType() {
+        return AzureBlobStoreSchema.TYPE;
+    }
+
+    @Override
+    public ProvisionResource generate(DataFlow dataFlow) {
+
+        var originalDataDestination = dataFlow.getDestination();
+        var toProvision = DataAddress.Builder.newInstance()
+                .type(AzureBlobStoreSchema.TYPE)
+                .property(EDC_NAMESPACE + AzureBlobStoreSchema.ACCOUNT_NAME, UUID.randomUUID().toString())
+                .property(EDC_NAMESPACE + AzureBlobStoreSchema.CONTAINER_NAME, UUID.randomUUID().toString());
+
+        if (originalDataDestination != null) {
+            toProvision.properties(originalDataDestination.getProperties());
+            if (isNullOrEmpty(originalDataDestination.getStringProperty(AzureBlobStoreSchema.CONTAINER_NAME))) {
+                monitor.debug("Container name on destination is null or empty. A random one will be used during provisioning.");
+            }
+            if (isNullOrEmpty(originalDataDestination.getStringProperty(AzureBlobStoreSchema.ACCOUNT_NAME))) {
+                monitor.debug("Account name on destination is null or empty. A random one will be used during provisioning.");
+            }
+        }
+
+        return ProvisionResource.Builder.newInstance()
+                .flowId(dataFlow.getId())
+                .type(AzureBlobStoreSchema.TYPE)
+                .dataAddress(toProvision.build())
+                .build();
+    }
+}

extensions/data-plane/data-plane-provision-blob/src/main/java/org/eclipse/edc/connector/dataplane/provision/azure/blob/ObjectStorageDeprovisioner.java

@@ -0,0 +1,41 @@
+/*
+ *  Copyright (c) 2025 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ *  This program and the accompanying materials are made available under the
+ *  terms of the Apache License, Version 2.0 which is available at
+ *  https://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ *
+ *  Contributors:
+ *       Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+ *
+ */
+
+package org.eclipse.edc.connector.dataplane.provision.azure.blob;
+
+import org.eclipse.edc.azure.blob.AzureBlobStoreSchema;
+import org.eclipse.edc.connector.dataplane.spi.provision.DeprovisionedResource;
+import org.eclipse.edc.connector.dataplane.spi.provision.Deprovisioner;
+import org.eclipse.edc.connector.dataplane.spi.provision.ProvisionResource;
+import org.eclipse.edc.spi.response.StatusResult;
+
+import java.util.concurrent.CompletableFuture;
+
+
+public class ObjectStorageDeprovisioner implements Deprovisioner {
+
+    public ObjectStorageDeprovisioner() {
+    }
+
+    @Override
+    public String supportedType() {
+        return AzureBlobStoreSchema.TYPE;
+    }
+
+    @Override
+    public CompletableFuture<StatusResult<DeprovisionedResource>> deprovision(ProvisionResource resource) {
+        //the sas token will expire automatically.
+        return CompletableFuture.supplyAsync(() -> StatusResult.success(DeprovisionedResource.Builder.from(resource).build()));
+    }
+}