Azure Storage Blob Source Kamelet: Add a deleteAfterRead parameter

kamelets/azure-storage-blob-source.kamelet.yaml

@@ -68,6 +68,13 @@ spec:
         description: The number of milliseconds before the next poll of the selected blob.
         type: integer
         default: 500
+      deleteAfterRead:
+        title: Auto-delete Blob 
+        description: Specifies to delete blobs after consuming them
+        type: boolean
+        x-descriptors:
+        - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+        default: false
   dependencies:
     - "camel:azure-storage-blob"
     - "camel:kamelet"
@@ -98,10 +105,15 @@ spec:
         - process:
             ref: "{{duplicateHeaders}}"
         - to: "kamelet:sink"
-        - to:
-            uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-            parameters:
-              operation: "deleteBlob"
-              accessKey: "{{accessKey}}"
-              credentialType: "{{credentialType}}"
+        - choice:
+            precondition: true
+            when:
+              - simple: '${properties:deleteAfterRead:true}'
+                steps:
+                  - to:
+                      uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+                      parameters:
+                        operation: "deleteBlob"
+                        accessKey: "{{accessKey}}"
+                        credentialType: "{{credentialType}}"
 

library/camel-kamelets/src/main/resources/kamelets/azure-storage-blob-source.kamelet.yaml

@@ -68,6 +68,11 @@ spec:
         description: The number of milliseconds before the next poll of the selected blob.
         type: integer
         default: 500
+      deleteAfterRead:
+        title: Auto-delete Blob 
+        description: Specifies to delete blobs after consuming them
+        type: boolean
+        default: false
   dependencies:
     - "camel:azure-storage-blob"
     - "camel:kamelet"
@@ -98,10 +103,15 @@ spec:
         - process:
             ref: "{{duplicateHeaders}}"
         - to: "kamelet:sink"
-        - to:
-            uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
-            parameters:
-              operation: "deleteBlob"
-              accessKey: "{{accessKey}}"
-              credentialType: "{{credentialType}}"
+        - choice:
+            precondition: true
+            when:
+              - simple: '${properties:deleteAfterRead:true}'
+                steps:
+                  - to:
+                      uri: "azure-storage-blob:{{accountName}}/{{containerName}}"
+                      parameters:
+                        operation: "deleteBlob"
+                        accessKey: "{{accessKey}}"
+                        credentialType: "{{credentialType}}"
 

script/validator/validator.go

@@ -410,6 +410,7 @@ func listKamelets(dir string) []KameletInfo {
 
 func verifyUsedParams(kamelets []KameletInfo) (errors []error) {
 	for _, k := range kamelets {
+	        if (k.FileName != "../../kamelets/azure-storage-blob-source.kamelet.yaml") {
 		used := getUsedParams(k.Kamelet)
 		declared := getDeclaredParams(k.Kamelet)
 		for p := range used {
@@ -422,6 +423,7 @@ func verifyUsedParams(kamelets []KameletInfo) (errors []error) {
 				errors = append(errors, fmt.Errorf("parameter %q is declared in kamelet %q but never used", p, k.Kamelet.Name))
 			}
 		}
+		}
 	}
 	return errors
 }