797 Add support for datastream component - WIP

cli/commands/component/init/openapi/src/main/java/com/bytechef/cli/command/component/init/openapi/ComponentInitOpenApiGenerator.java

@@ -225,9 +225,9 @@ private CodeBlock addDynamicProperty(
             builder.add("dynamicProperties($S)", propertyName);
 
             builder.add(
-                ".properties(($T.ActionPropertiesFunction)$T::get" + buildOptionsFunctionsName(propertyName) +
+                ".properties(($T.PropertiesFunction)$T::get" + buildOptionsFunctionsName(propertyName) +
                     "Properties)",
-                ClassName.get("com.bytechef.component.definition", "PropertiesDataSource"),
+                ClassName.get("com.bytechef.component.definition", "ActionDefinition"),
                 ClassName.get(
                     "com.bytechef.component." + componentName + ".util",
                     getComponentClassName(componentName) + "Utils"));
@@ -2153,9 +2153,9 @@ private void handleDynamicOptions(
             dynamicOptionsMap.put(buildOptionsFunctionsName(propertyName), type);
 
             builder.add(
-                ".options(($T.ActionOptionsFunction<" + optionType + ">)$T::get"
+                ".options(($T.OptionsFunction<" + optionType + ">)$T::get"
                     + buildOptionsFunctionsName(propertyName) + "Options)",
-                ClassName.get("com.bytechef.component.definition", "OptionsDataSource"),
+                ClassName.get("com.bytechef.component.definition", "ActionDefinition"),
                 ClassName.get("com.bytechef.component." + componentName + ".util",
                     getComponentClassName(componentName) + "Utils"));
 

client/src/ee/shared/middleware/automation/api-platform/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/automation/configuration/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/embedded/configuration/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/embedded/configuration/models/IntegrationInstanceConfigurationWorkflow.ts

@@ -155,7 +155,7 @@ export function IntegrationInstanceConfigurationWorkflowToJSONTyped(value?: Omit
         'connections': value['connections'] == null ? undefined : ((value['connections'] as Array<any>).map(IntegrationInstanceConfigurationWorkflowConnectionToJSON)),
         'enabled': value['enabled'],
         'integrationInstanceConfigurationId': value['integrationInstanceConfigurationId'],
-        'lastExecutionDate': value['lastExecutionDate'] == null ? undefined : ((value['lastExecutionDate']).toISOString()),
+        'lastExecutionDate': value['lastExecutionDate'] == null ? value['lastExecutionDate'] : value['lastExecutionDate'].toISOString(),
         'workflowId': value['workflowId'],
         '__version': value['version'],
     };

client/src/ee/shared/middleware/embedded/configuration/models/IntegrationVersion.ts

@@ -91,7 +91,7 @@ export function IntegrationVersionToJSONTyped(value?: Omit<IntegrationVersion, '
     return {
 
         'description': value['description'],
-        'publishedDate': value['publishedDate'] == null ? undefined : ((value['publishedDate']).toISOString()),
+        'publishedDate': value['publishedDate'] == null ? value['publishedDate'] : value['publishedDate'].toISOString(),
         'status': IntegrationStatusToJSON(value['status']),
     };
 }

client/src/ee/shared/middleware/embedded/connected-user/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/embedded/security/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/embedded/workflow/execution/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/embedded/workflow/execution/models/IntegrationInstanceConfigurationWorkflow.ts

@@ -155,7 +155,7 @@ export function IntegrationInstanceConfigurationWorkflowToJSONTyped(value?: Omit
         'connections': value['connections'] == null ? undefined : ((value['connections'] as Array<any>).map(IntegrationInstanceConfigurationWorkflowConnectionToJSON)),
         'enabled': value['enabled'],
         'integrationInstanceConfigurationId': value['integrationInstanceConfigurationId'],
-        'lastExecutionDate': value['lastExecutionDate'] == null ? undefined : ((value['lastExecutionDate']).toISOString()),
+        'lastExecutionDate': value['lastExecutionDate'] == null ? value['lastExecutionDate'] : value['lastExecutionDate'].toISOString(),
         'workflowId': value['workflowId'],
         '__version': value['version'],
     };

client/src/ee/shared/middleware/embedded/workflow/execution/models/Job.ts

@@ -224,7 +224,7 @@ export function JobToJSONTyped(value?: Omit<Job, 'createdBy'|'createdDate'|'curr
 
     return {
 
-        'endDate': value['endDate'] == null ? undefined : ((value['endDate']).toISOString()),
+        'endDate': value['endDate'] == null ? value['endDate'] : value['endDate'].toISOString(),
         'error': ExecutionErrorToJSON(value['error']),
         'taskExecutions': value['taskExecutions'] == null ? undefined : ((value['taskExecutions'] as Array<any>).map(TaskExecutionToJSON)),
     };

client/src/ee/shared/middleware/embedded/workflow/execution/models/JobBasic.ts

@@ -153,7 +153,7 @@ export function JobBasicToJSONTyped(value?: Omit<JobBasic, 'createdBy'|'createdD
 
     return {
 
-        'endDate': value['endDate'] == null ? undefined : ((value['endDate']).toISOString()),
+        'endDate': value['endDate'] == null ? value['endDate'] : value['endDate'].toISOString(),
     };
 }
 

client/src/ee/shared/middleware/platform/api-connector/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/platform/configuration/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/ee/shared/middleware/platform/custom-component/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/automation/configuration/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/automation/configuration/models/ProjectDeploymentWorkflow.ts

@@ -161,7 +161,7 @@ export function ProjectDeploymentWorkflowToJSONTyped(value?: Omit<ProjectDeploym
         'inputs': value['inputs'],
         'connections': value['connections'] == null ? undefined : ((value['connections'] as Array<any>).map(ProjectDeploymentWorkflowConnectionToJSON)),
         'enabled': value['enabled'],
-        'lastExecutionDate': value['lastExecutionDate'] == null ? undefined : ((value['lastExecutionDate']).toISOString()),
+        'lastExecutionDate': value['lastExecutionDate'] == null ? value['lastExecutionDate'] : value['lastExecutionDate'].toISOString(),
         'projectDeploymentId': value['projectDeploymentId'],
         'staticWebhookUrl': value['staticWebhookUrl'],
         'workflowId': value['workflowId'],

client/src/shared/middleware/automation/configuration/models/ProjectVersion.ts

@@ -91,7 +91,7 @@ export function ProjectVersionToJSONTyped(value?: Omit<ProjectVersion, 'version'
     return {
 
         'description': value['description'],
-        'publishedDate': value['publishedDate'] == null ? undefined : ((value['publishedDate']).toISOString()),
+        'publishedDate': value['publishedDate'] == null ? value['publishedDate'] : value['publishedDate'].toISOString(),
         'status': ProjectStatusToJSON(value['status']),
     };
 }

client/src/shared/middleware/automation/workflow/execution/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/automation/workflow/execution/models/Job.ts

@@ -224,7 +224,7 @@ export function JobToJSONTyped(value?: Omit<Job, 'createdBy'|'createdDate'|'curr
 
     return {
 
-        'endDate': value['endDate'] == null ? undefined : ((value['endDate']).toISOString()),
+        'endDate': value['endDate'] == null ? value['endDate'] : value['endDate'].toISOString(),
         'error': ExecutionErrorToJSON(value['error']),
         'taskExecutions': value['taskExecutions'] == null ? undefined : ((value['taskExecutions'] as Array<any>).map(TaskExecutionToJSON)),
     };

client/src/shared/middleware/automation/workflow/execution/models/JobBasic.ts

@@ -153,7 +153,7 @@ export function JobBasicToJSONTyped(value?: Omit<JobBasic, 'createdBy'|'createdD
 
     return {
 
-        'endDate': value['endDate'] == null ? undefined : ((value['endDate']).toISOString()),
+        'endDate': value['endDate'] == null ? value['endDate'] : value['endDate'].toISOString(),
     };
 }
 

client/src/shared/middleware/platform/configuration/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/platform/configuration/apis/WorkflowNodeDescriptionApi.ts

@@ -22,6 +22,13 @@ import {
     GetWorkflowNodeDescription200ResponseToJSON,
 } from '../models/index';
 
+export interface GetClusterElementWorkflowNodeDescriptionRequest {
+    id: string;
+    workflowNodeName: string;
+    clusterElementName: string;
+    environmentId: number;
+}
+
 export interface GetWorkflowNodeDescriptionRequest {
     id: string;
     workflowNodeName: string;
@@ -33,6 +40,72 @@ export interface GetWorkflowNodeDescriptionRequest {
  */
 export class WorkflowNodeDescriptionApi extends runtime.BaseAPI {
 
+    /**
+     * Get an action description shown in the editor.
+     * Get an action description shown in the editor
+     */
+    async getClusterElementWorkflowNodeDescriptionRaw(requestParameters: GetClusterElementWorkflowNodeDescriptionRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<runtime.ApiResponse<GetWorkflowNodeDescription200Response>> {
+        if (requestParameters['id'] == null) {
+            throw new runtime.RequiredError(
+                'id',
+                'Required parameter "id" was null or undefined when calling getClusterElementWorkflowNodeDescription().'
+            );
+        }
+
+        if (requestParameters['workflowNodeName'] == null) {
+            throw new runtime.RequiredError(
+                'workflowNodeName',
+                'Required parameter "workflowNodeName" was null or undefined when calling getClusterElementWorkflowNodeDescription().'
+            );
+        }
+
+        if (requestParameters['clusterElementName'] == null) {
+            throw new runtime.RequiredError(
+                'clusterElementName',
+                'Required parameter "clusterElementName" was null or undefined when calling getClusterElementWorkflowNodeDescription().'
+            );
+        }
+
+        if (requestParameters['environmentId'] == null) {
+            throw new runtime.RequiredError(
+                'environmentId',
+                'Required parameter "environmentId" was null or undefined when calling getClusterElementWorkflowNodeDescription().'
+            );
+        }
+
+        const queryParameters: any = {};
+
+        if (requestParameters['environmentId'] != null) {
+            queryParameters['environmentId'] = requestParameters['environmentId'];
+        }
+
+        const headerParameters: runtime.HTTPHeaders = {};
+
+
+        let urlPath = `/workflows/{id}/workflow-nodes/{workflowNodeName}/cluster-element-definition/{clusterElementName}/descriptions`;
+        urlPath = urlPath.replace(`{${"id"}}`, encodeURIComponent(String(requestParameters['id'])));
+        urlPath = urlPath.replace(`{${"workflowNodeName"}}`, encodeURIComponent(String(requestParameters['workflowNodeName'])));
+        urlPath = urlPath.replace(`{${"clusterElementName"}}`, encodeURIComponent(String(requestParameters['clusterElementName'])));
+
+        const response = await this.request({
+            path: urlPath,
+            method: 'GET',
+            headers: headerParameters,
+            query: queryParameters,
+        }, initOverrides);
+
+        return new runtime.JSONApiResponse(response, (jsonValue) => GetWorkflowNodeDescription200ResponseFromJSON(jsonValue));
+    }
+
+    /**
+     * Get an action description shown in the editor.
+     * Get an action description shown in the editor
+     */
+    async getClusterElementWorkflowNodeDescription(requestParameters: GetClusterElementWorkflowNodeDescriptionRequest, initOverrides?: RequestInit | runtime.InitOverrideFunction): Promise<GetWorkflowNodeDescription200Response> {
+        const response = await this.getClusterElementWorkflowNodeDescriptionRaw(requestParameters, initOverrides);
+        return await response.value();
+    }
+
     /**
      * Get an action description shown in the editor.
      * Get an action description shown in the editor

client/src/shared/middleware/platform/configuration/models/DateProperty.ts

@@ -118,8 +118,8 @@ export function DatePropertyToJSONTyped(value?: DateProperty | null, ignoreDiscr
 
     return {
         ...ValuePropertyToJSONTyped(value, true),
-        'defaultValue': value['defaultValue'] == null ? undefined : ((value['defaultValue']).toISOString().substring(0,10)),
-        'exampleValue': value['exampleValue'] == null ? undefined : ((value['exampleValue']).toISOString().substring(0,10)),
+        'defaultValue': value['defaultValue'] == null ? value['defaultValue'] : value['defaultValue'].toISOString().substring(0,10),
+        'exampleValue': value['exampleValue'] == null ? value['exampleValue'] : value['exampleValue'].toISOString().substring(0,10),
         'options': value['options'] == null ? undefined : ((value['options'] as Array<any>).map(OptionToJSON)),
         'optionsDataSource': OptionsDataSourceToJSON(value['optionsDataSource']),
     };

client/src/shared/middleware/platform/configuration/models/DateTimeProperty.ts

@@ -118,8 +118,8 @@ export function DateTimePropertyToJSONTyped(value?: DateTimeProperty | null, ign
 
     return {
         ...ValuePropertyToJSONTyped(value, true),
-        'defaultValue': value['defaultValue'] == null ? undefined : ((value['defaultValue']).toISOString()),
-        'exampleValue': value['exampleValue'] == null ? undefined : ((value['exampleValue']).toISOString()),
+        'defaultValue': value['defaultValue'] == null ? value['defaultValue'] : value['defaultValue'].toISOString(),
+        'exampleValue': value['exampleValue'] == null ? value['exampleValue'] : value['exampleValue'].toISOString(),
         'options': value['options'] == null ? undefined : ((value['options'] as Array<any>).map(OptionToJSON)),
         'optionsDataSource': OptionsDataSourceToJSON(value['optionsDataSource']),
     };

client/src/shared/middleware/platform/notification/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/platform/security/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/platform/security/models/ApiKey.ts

@@ -123,12 +123,12 @@ export function ApiKeyToJSONTyped(value?: ApiKey | null, ignoreDiscriminator: bo
     return {
 
         'createdBy': value['createdBy'],
-        'createdDate': value['createdDate'] == null ? undefined : ((value['createdDate']).toISOString()),
+        'createdDate': value['createdDate'] == null ? value['createdDate'] : value['createdDate'].toISOString(),
         'environmentId': value['environmentId'],
         'id': value['id'],
         'lastModifiedBy': value['lastModifiedBy'],
-        'lastModifiedDate': value['lastModifiedDate'] == null ? undefined : ((value['lastModifiedDate']).toISOString()),
-        'lastUsedDate': value['lastUsedDate'] == null ? undefined : ((value['lastUsedDate']).toISOString()),
+        'lastModifiedDate': value['lastModifiedDate'] == null ? value['lastModifiedDate'] : value['lastModifiedDate'].toISOString(),
+        'lastUsedDate': value['lastUsedDate'] == null ? value['lastUsedDate'] : value['lastUsedDate'].toISOString(),
         'name': value['name'],
         'secretKey': value['secretKey'],
         'type': value['type'],

client/src/shared/middleware/platform/user/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/platform/workflow/execution/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/platform/workflow/execution/models/Job.ts

@@ -224,7 +224,7 @@ export function JobToJSONTyped(value?: Omit<Job, 'createdBy'|'createdDate'|'curr
 
     return {
 
-        'endDate': value['endDate'] == null ? undefined : ((value['endDate']).toISOString()),
+        'endDate': value['endDate'] == null ? value['endDate'] : value['endDate'].toISOString(),
         'error': ExecutionErrorToJSON(value['error']),
         'taskExecutions': value['taskExecutions'] == null ? undefined : ((value['taskExecutions'] as Array<any>).map(TaskExecutionToJSON)),
     };

client/src/shared/middleware/platform/workflow/execution/models/JobBasic.ts

@@ -153,7 +153,7 @@ export function JobBasicToJSONTyped(value?: Omit<JobBasic, 'createdBy'|'createdD
 
     return {
 
-        'endDate': value['endDate'] == null ? undefined : ((value['endDate']).toISOString()),
+        'endDate': value['endDate'] == null ? value['endDate'] : value['endDate'].toISOString(),
     };
 }
 

client/src/shared/middleware/platform/workflow/test/.openapi-generator/VERSION

@@ -1 +1 @@
-7.15.0
+7.16.0

client/src/shared/middleware/platform/workflow/test/models/Job.ts

@@ -224,7 +224,7 @@ export function JobToJSONTyped(value?: Omit<Job, 'createdBy'|'createdDate'|'curr
 
     return {
 
-        'endDate': value['endDate'] == null ? undefined : ((value['endDate']).toISOString()),
+        'endDate': value['endDate'] == null ? value['endDate'] : value['endDate'].toISOString(),
         'error': ExecutionErrorToJSON(value['error']),
         'taskExecutions': value['taskExecutions'] == null ? undefined : ((value['taskExecutions'] as Array<any>).map(TaskExecutionToJSON)),
     };

config/pmd/pmd-ruleset.xml

@@ -50,7 +50,6 @@
     <rule ref="category/java/errorprone.xml/UnconditionalIfStatement" />
     <rule ref="category/java/errorprone.xml/UnnecessaryConversionTemporary" />
     <rule ref="category/java/errorprone.xml/UnusedNullCheckInEquals" />
-    <rule ref="category/java/errorprone.xml/UselessOperationOnImmutable" />
 
     <rule ref="category/java/multithreading.xml/AvoidThreadGroup" />
     <rule ref="category/java/multithreading.xml/DontCallThreadRun" />

gradle/libs.versions.toml

@@ -1,5 +1,5 @@
 [versions]
-checkstyle = "11.0.0"
+checkstyle = "11.1.0"
 com-google-auto-service = "1.1.1"
 graalvm = "24.2.2"
 jackson = "2.19.2"
@@ -8,13 +8,13 @@ java = "21"
 org-mapstruct = "1.6.3"
 org-mapstruct-extensions-spring = "1.1.3"
 org-springdoc = "2.8.13"
-pmd = "7.16.0"
+pmd = "7.17.0"
 spotbugs = "4.8.6"
 spring-ai = "1.0.3"
 spring-boot = "3.5.6"
 spring-cloud-aws = "3.4.0"
 spring-cloud-dependencies = "2025.0.0"
-spring-shell = "3.4.0"
+spring-shell = "3.4.1"
 
 [libraries]
 com-github-miachm-sods-sods = "com.github.miachm.sods:SODS:1.7.0"
@@ -24,7 +24,7 @@ com-google-auto-service-auto-service = { module = "com.google.auto.service:auto-
 com-google-auto-service-auto-service-annotations = { module = "com.google.auto.service:auto-service-annotations", version.ref = "com-google-auto-service" }
 com-squareup-javapoet = "com.squareup:javapoet:1.13.0"
 commons-validator = "commons-validator:commons-validator:1.10.0"
-io-swagger-core-v3-swagger-annotations = "io.swagger.core.v3:swagger-annotations:2.2.37"
+io-swagger-core-v3-swagger-annotations = "io.swagger.core.v3:swagger-annotations:2.2.38"
 io-swagger-parser-v3-swagger-parser = "io.swagger.parser.v3:swagger-parser:2.1.34"
 loki-logback-appender = "com.github.loki4j:loki-logback-appender:2.0.0"
 org-apache-activemq-artemis-jakarta-server = "org.apache.activemq:artemis-jakarta-server:2.42.0"
@@ -47,12 +47,12 @@ org-wiremock-wiremock = "org.wiremock:wiremock-standalone:3.13.1"
 org-zeroturnaround-zt-exec = "org.zeroturnaround:zt-exec:1.12"
 
 [plugins]
-com-github-ben-manes-versions = "com.github.ben-manes.versions:0.52.0"
+com-github-ben-manes-versions = "com.github.ben-manes.versions:0.53.0"
 gradle-git-properties = "com.gorylenko.gradle-git-properties:2.5.2"
 jib = "com.google.cloud.tools.jib:3.4.5"
-nl-littlerobots-version-catalog-update = "nl.littlerobots.version-catalog-update:1.0.0"
-org-graalvm-buildtools-native = "org.graalvm.buildtools.native:0.11.0"
-org-openapi-generator = "org.openapi.generator:7.15.0"
+nl-littlerobots-version-catalog-update = "nl.littlerobots.version-catalog-update:1.0.1"
+org-graalvm-buildtools-native = "org.graalvm.buildtools.native:0.11.1"
+org-openapi-generator = "org.openapi.generator:7.16.0"
 org-sonarqube = "org.sonarqube:6.3.1.5724"
 spotbugs = "com.github.spotbugs:6.2.5"
-spotless = "com.diffplug.gradle.spotless:7.2.1"
+spotless = "com.diffplug.gradle.spotless:8.0.0"