CAMEL-24961: Catalog body types for object storage

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-s3.json

@@ -145,6 +145,11 @@
     "CamelAwsS3UploadLinkHttpRequestHeaders": { "index": 52, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Map<String, List<String>>", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The headers that are needed by the service for upload (not needed when BrowserCompatible is true)", "constantName": "org.apache.camel.component.aws2.s3.AWS2S3Constants#UPLOAD_LINK_HTTP_REQUEST_HEADERS" },
     "CamelAwsS3UploadLinkSignedPayload": { "index": 53, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The request payload that is needed by the service for upload (not needed when BrowserCompatible is true)", "constantName": "org.apache.camel.component.aws2.s3.AWS2S3Constants#UPLOAD_LINK_SIGNED_PAYLOAD" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "bytes" ], "javaType": "byte[]", "byOption": [ { "option": "includeBody", "value": "false", "carriers": [ "stream" ] }, { "option": "ignoreBody", "value": "true", "carriers": [ "null" ] } ], "description": "The content of the object as a byte array, one message per object, with its key and metadata in headers. With includeBody=false the stream of the object, and with ignoreBody=true no body" },
+    "producerIn": { "carriers": [ "text", "bytes", "stream", "file" ], "dependsOn": [ "operation", "pojoRequest" ], "description": "The content to upload, when no operation is set: text, bytes, a stream or a file. A Map or a List fails: marshal it first. The operations take their input from headers, or with pojoRequest=true from the request of the AWS SDK in the body, such as a GetObjectRequest" },
+    "producerOut": { "carriers": [ "unchanged" ], "byOption": [ { "option": "operation", "value": "getObject", "carriers": [ "stream" ] }, { "option": "operation", "value": "getObjectRange", "carriers": [ "stream" ] }, { "option": "operation", "value": "listObjects", "carriers": [ "list" ], "javaType": "java.util.List<software.amazon.awssdk.services.s3.model.S3Object>" }, { "option": "operation", "value": "listBuckets", "carriers": [ "list" ], "javaType": "java.util.List<software.amazon.awssdk.services.s3.model.Bucket>" }, { "option": "operation", "value": "getObjectTagging", "carriers": [ "list" ], "javaType": "java.util.List<software.amazon.awssdk.services.s3.model.Tag>" }, { "option": "operation", "value": "getBucketTagging", "carriers": [ "list" ], "javaType": "java.util.List<software.amazon.awssdk.services.s3.model.Tag>" }, { "option": "operation", "value": "createDownloadLink", "carriers": [ "text" ], "javaType": "java.lang.String" }, { "option": "operation", "value": "createUploadLink", "carriers": [ "text" ], "javaType": "java.lang.String" }, { "option": "operation", "value": "getBucketPolicy", "carriers": [ "text" ], "javaType": "java.lang.String" }, { "option": "operation", "value": "deleteObject", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "headBucket", "carriers": [ "pojo", "unchanged" ] }, { "option": "operation", "value": "headObject", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.HeadObjectResponse" }, { "option": "operation", "value": "deleteObjects", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.DeleteObjectsResponse" }, { "option": "operation", "value": "deleteBucket", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.DeleteBucketResponse" }, { "option": "operation", "value": "createBucket", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.CreateBucketResponse" }, { "option": "operation", "value": "restoreObject", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.RestoreObjectResponse" }, { "option": "operation", "value": "putObjectTagging", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.PutObjectTaggingResponse" }, { "option": "operation", "value": "deleteObjectTagging", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.DeleteObjectTaggingResponse" }, { "option": "operation", "value": "getObjectAcl", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.GetObjectAclResponse" }, { "option": "operation", "value": "putObjectAcl", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.PutObjectAclResponse" }, { "option": "operation", "value": "putBucketTagging", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.PutBucketTaggingResponse" }, { "option": "operation", "value": "deleteBucketTagging", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.DeleteBucketTaggingResponse" }, { "option": "operation", "value": "getBucketVersioning", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.GetBucketVersioningResponse" }, { "option": "operation", "value": "putBucketVersioning", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.PutBucketVersioningResponse" }, { "option": "operation", "value": "putBucketPolicy", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.PutBucketPolicyResponse" }, { "option": "operation", "value": "deleteBucketPolicy", "carriers": [ "pojo" ], "javaType": "software.amazon.awssdk.services.s3.model.DeleteBucketPolicyResponse" } ], "description": "Unchanged after an upload and a copyObject, with the ETag in a header. By the operation: the stream of the object for getObject and getObjectRange, a List for the lists and the tagging gets, the URL as text for the links, the policy JSON for getBucketPolicy, true for deleteObject, and the response of the AWS SDK for the others. getObject with ignoreBody=true, headBucket for a bucket that does not exist and streamingUploadMode keep the body" }
+  },
   "properties": {
     "bucketNameOrArn": { "index": 0, "kind": "path", "displayName": "Bucket Name Or Arn", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Bucket name or ARN" },
     "autoCreateBucket": { "index": 1, "kind": "parameter", "displayName": "Auto Create Bucket", "group": "common", "label": "common", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField": "configuration", "description": "Setting the autocreation of the S3 bucket bucketName. This will apply also in case of moveAfterRead option enabled, and it will create the destinationBucket if it doesn't exist already." },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-files.json

@@ -47,6 +47,11 @@
     "CamelFileLocalWorkPath": { "index": 13, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Path to the local work file, if local work directory is used.", "constantName": "org.apache.camel.component.file.azure.FilesConstants#FILE_LOCAL_WORK_PATH" },
     "CamelFileHost": { "index": 14, "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The remote hostname.", "constantName": "org.apache.camel.component.file.azure.FilesConstants#FILE_HOST" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "file" ], "dependsOn": [ "preMove" ], "byOption": [ { "option": "streamDownload", "value": "true", "carriers": [ "stream" ] }, { "option": "download", "value": "false", "carriers": [ "null" ] } ], "description": "The file as read: a RemoteFile with its content loaded as bytes, which converts to text, bytes or a stream; a stream with streamDownload; with preMove its content, a byte array" },
+    "producerIn": { "carriers": [ "text", "bytes", "stream", "file" ], "byOption": [ { "option": "allowNullBody", "value": "true", "carriers": [ "null", "text", "bytes", "stream", "file" ] } ], "description": "What converts to an InputStream or a byte array: text, bytes, a stream or a file. A Map or a List fails: marshal it first" },
+    "producerOut": { "carriers": [ "unchanged" ] }
+  },
   "properties": {
     "account": { "index": 0, "kind": "path", "displayName": "Account", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.file.azure.FilesConfiguration", "configurationField": "configuration", "description": "The account to use" },
     "share": { "index": 1, "kind": "path", "displayName": "Share", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.file.azure.FilesConfiguration", "configurationField": "configuration", "description": "The share to use" },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/azure-storage-blob.json

@@ -157,6 +157,11 @@
     "CamelAzureStorageBlobImmutabilityPolicyMode": { "index": 77, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "com.azure.storage.blob.models.BlobImmutabilityPolicyMode", "enum": [ "Mutable", "Unlocked", "Locked" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "(setBlobImmutabilityPolicy) The mode of the immutability policy: UNLOCKED (default, can be modified or deleted), LOCKED (cannot be modified or shortened, only extended), or MUTABLE.", "constantName": "org.apache.camel.component.azure.storage.blob.BlobConstants#BLOB_IMMUTABILITY_POLICY_MODE" },
     "CamelAzureStorageBlobRehydratePriority": { "index": 78, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "com.azure.storage.blob.models.RehydratePriority", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "(setBlobTier) The rehydrate priority used when rehydrating a blob from the archive tier: Standard or High. Ignored when changing tier between non-archive tiers.", "constantName": "org.apache.camel.component.azure.storage.blob.BlobConstants#REHYDRATE_PRIORITY" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "stream", "file" ], "description": "The content of the blob, one message per blob: a stream that reads it, or with fileDir the java.io.File it is downloaded to" },
+    "producerIn": { "carriers": [ "any" ], "byOption": [ { "option": "operation", "value": "uploadBlockBlob", "carriers": [ "text", "bytes", "stream", "file" ] }, { "option": "operation", "value": "commitAppendBlob", "carriers": [ "text", "bytes", "stream", "file" ] }, { "option": "operation", "value": "uploadPageBlob", "carriers": [ "text", "bytes", "stream", "file" ] }, { "option": "operation", "value": "stageBlockBlobList", "carriers": [ "list", "pojo" ] }, { "option": "operation", "value": "commitBlobBlockList", "carriers": [ "list", "pojo" ] } ], "description": "The content to upload for uploadBlockBlob, commitAppendBlob and uploadPageBlob: text, bytes, a stream or a file; a Map or a List fails: marshal it first. A List of BlobBlock for stageBlockBlobList, and of Block for commitBlobBlockList. getBlob writes into an OutputStream body. The other operations do not use the body, or take their value from a header first: the file of uploadBlockBlobChunked, the tags, the tag filter, the legal hold, the tier and the policy" },
+    "producerOut": { "carriers": [ "list" ], "byOption": [ { "option": "operation", "value": "getBlob", "carriers": [ "stream" ] }, { "option": "operation", "value": "downloadBlobToFile", "carriers": [ "file" ], "javaType": "java.io.File" }, { "option": "operation", "value": "getBlobTags", "carriers": [ "map" ], "javaType": "java.util.Map<String, String>" }, { "option": "operation", "value": "getPageBlobRanges", "carriers": [ "iterator" ], "javaType": "com.azure.core.http.rest.PagedIterable<com.azure.storage.blob.models.PageRangeItem>" }, { "option": "operation", "value": "getBlobBlockList", "carriers": [ "pojo" ], "javaType": "com.azure.storage.blob.models.BlockList" }, { "option": "operation", "value": "setBlobImmutabilityPolicy", "carriers": [ "pojo" ], "javaType": "com.azure.storage.blob.models.BlobImmutabilityPolicy" }, { "option": "operation", "value": "setBlobTier", "carriers": [ "pojo" ], "javaType": "com.azure.storage.blob.models.AccessTier" }, { "option": "operation", "value": "copyBlob", "carriers": [ "text" ], "javaType": "java.lang.String" }, { "option": "operation", "value": "createBlobSnapshot", "carriers": [ "text" ], "javaType": "java.lang.String" }, { "option": "operation", "value": "setBlobLegalHold", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "createBlobContainer", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "deleteBlobContainer", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "deleteBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "downloadLink", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "uploadBlockBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "uploadBlockBlobChunked", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "stageBlockBlobList", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "commitBlobBlockList", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "createAppendBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "commitAppendBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "createPageBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "uploadPageBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "resizePageBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "clearPageBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "setBlobTags", "carriers": [ "value" ], "javaType": "java.lang.Boolean" }, { "option": "operation", "value": "undeleteBlob", "carriers": [ "value" ], "javaType": "java.lang.Boolean" } ], "description": "A List of the items of the SDK for listBlobContainers, the default, findBlobsByTags, listBlobs, listBlobVersions and getChangeFeed. A stream of the content for getBlob, or the OutputStream body it wrote into; the java.io.File for downloadBlobToFile; true for the operations that create, upload, set or delete, with their results in headers, such as the link of downloadLink" }
+  },
   "properties": {
     "accountName": { "index": 0, "kind": "path", "displayName": "Account Name", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.storage.blob.BlobConfiguration", "configurationField": "configuration", "description": "Azure account name to be used for authentication with azure blob services" },
     "containerName": { "index": 1, "kind": "path", "displayName": "Container Name", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.azure.storage.blob.BlobConfiguration", "configurationField": "configuration", "description": "The blob container name" },

catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/dropbox.json

@@ -43,6 +43,11 @@
     "DELETED_PATH": { "index": 11, "kind": "header", "displayName": "", "group": "del", "label": "del", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Name of the path deleted on dropbox", "constantName": "org.apache.camel.component.dropbox.util.DropboxConstants#DELETED_PATH" },
     "MOVED_PATH": { "index": 12, "kind": "header", "displayName": "", "group": "move", "label": "move", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Name of the path moved on dropbox", "constantName": "org.apache.camel.component.dropbox.util.DropboxConstants#MOVED_PATH" }
   },
+  "bodyTypes": {
+    "consumerOut": { "carriers": [ "unknown" ], "byOption": [ { "option": "operation", "value": "get", "carriers": [ "stream", "bytes", "map" ] }, { "option": "operation", "value": "search", "carriers": [ "list" ], "javaType": "java.util.List<com.dropbox.core.v2.files.SearchMatchV2>" } ], "description": "One message per poll. get: the content of the file in remotePath as a stream cache (a byte array when stream caching is off), or for a folder a Map of the path to the content of each file. search: a List of SearchMatchV2" },
+    "producerIn": { "carriers": [ "any" ], "description": "Only put reads the body, unless localPath or the CamelDropboxLocalPath header names a local file or folder to upload: the content to upload, as text, bytes, a stream or a file. A Map or a List is not uploaded, and the result is KO without an error: marshal it first" },
+    "producerOut": { "carriers": [ "unknown" ], "byOption": [ { "option": "operation", "value": "put", "carriers": [ "value", "map" ] }, { "option": "operation", "value": "get", "carriers": [ "stream", "bytes", "map" ] }, { "option": "operation", "value": "del", "carriers": [ "text" ], "javaType": "java.lang.String" }, { "option": "operation", "value": "move", "carriers": [ "text" ], "javaType": "java.lang.String" }, { "option": "operation", "value": "search", "carriers": [ "list" ], "javaType": "java.util.List<com.dropbox.core.v2.files.SearchMatchV2>" } ], "description": "put: OK or KO, a DropboxResultCode, or for a local folder of several files a Map of each remote path to its result. get: the content of the file as a stream cache (a byte array when stream caching is off), or a Map of the path to the content of each file of a folder. del: the path deleted. move: the new path. search: a List of SearchMatchV2" }
+  },
   "properties": {
     "operation": { "index": 0, "kind": "path", "displayName": "Operation", "group": "common", "label": "", "required": true, "type": "enum", "javaType": "org.apache.camel.component.dropbox.util.DropboxOperation", "enum": [ "put", "del", "search", "get", "move" ], "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.dropbox.DropboxConfiguration", "configurationField": "configuration", "description": "The specific action (typically is a CRUD action) to perform on Dropbox remote folder." },
     "clientIdentifier": { "index": 1, "kind": "parameter", "displayName": "Client Identifier", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.dropbox.DropboxConfiguration", "configurationField": "configuration", "description": "Name of the app registered to make API requests" },