M2K workflow - use K_SINK to produce event instead of rest request to…

… broker

local_build.sh

@@ -0,0 +1,2 @@
+buildah build --format=docker -f  pipeline/workflow-builder.Dockerfile -t quay.io/gfarache/serverless-workflow-move2kube:test --build-arg WF_RESOURCES=move2kube/ --build-arg QUARKUS_ADD_EXTENSIONS_ARGS=org.kie.kogito:kogito-addons-quarkus-jobs-knative-eventing:999-SNAPSHOT --ulimit nofile=4096:4096 . && \
+buildah push quay.io/gfarache/serverless-workflow-move2kube:test

move2kube/m2k.sw.yml

@@ -16,6 +16,10 @@ events:
   - name: transformationSavedEvent
     source: ''
     type: transformation_saved
+  - name: saveTransformationEvent
+    source: ''
+    type: save-transformation
+    dataOnly: false
 functions:
   - name: systemOut
     type: custom
@@ -29,9 +33,6 @@ functions:
   - name: startTransformation
     type: rest
     operation: specs/move2kube.yaml#start-transformation
-  - name: sendCloudEvent
-    type: custom
-    operation: rest:post:http://broker-ingress.knative-eventing.svc.cluster.local/sonataflow-infra/default
   - name: createNotification
     operation: notifications#createNotification
 states:
@@ -103,37 +104,18 @@ states:
             actions:
               - title: "Move2Kube waiting Q&A"
                 url: "$SECRET.move2kube_url + \"/workspaces/\"+ .workspaceId + \"/projects/\" + .projectId + \"/outputs/\"+ .transformId "
-    transition: SaveTransformationOutput
-  - name: SaveTransformationOutput
-    type: operation
-    actions:
-      - functionRef:
-          refName: sendCloudEvent
-          arguments:
-            HEADER_Ce-Id: $WORKFLOW.instanceId
-            HEADER_Ce-Specversion: "1.0"
-            HEADER_Ce-Type: "save-transformation"
-            HEADER_Ce-Source: "m2k_swf"
-            HEADER_Content-Type: "application/json"
-            gitRepo: "(.repositoryURL|sub(\"http(s)?://\";\"ssh://\"))"
-            branch: .targetBranch
-            token: .token
-            workspaceId: .workspaceId
-            projectId: .projectId
-            transformId: .transformId
-            workflowCallerId: $WORKFLOW.instanceId
-    transition: WaitForSaveTransformationCompletion
-  - name: WaitForSaveTransformationCompletion
+    transition:
+      nextState: WaitForSaveTransformationCompletionEvent
+      produceEvents:
+        - eventRef: saveTransformationEvent
+          data: "{ data: {gitRepo:.repositoryURL|sub(\"http(s)?://\";\"ssh://\"), branch: .targetBranch, token: .token, workspaceId: .workspaceId, projectId: .projectId, transformId: .transformId, workflowCallerId: $WORKFLOW.instanceId}, datacontenttype: \"application/json\", id: $WORKFLOW.instanceId, specversion: \"1.0\", type: \"save-transformation\", source: \"m2k_swf\"}"
+  - name: WaitForSaveTransformationCompletionEvent
     type: switch
     eventConditions:
-      - eventRef: transformationSavedEvent
-        transition: TransformationSaved
       - eventRef: errorEvent
         transition: TransformationError
-    defaultCondition:
-      transition: TransformationError
-    timeouts:
-      eventTimeout: PT3M
+      - eventRef: transformationSavedEvent
+        transition: TransformationSaved
   - name: TransformationSaved
     type: inject
     data:

pipeline/workflow-builder.Dockerfile

@@ -1,4 +1,4 @@
-FROM quay.io/kiegroup/kogito-swf-builder-nightly:main-2024-01-24 AS builder
+FROM quay.io/kiegroup/kogito-swf-builder-nightly:main-2024-01-29 AS builder
 
 # variables that can be overridden by the builder
 # To add a Quarkus extension to your application