feat: added external task script worker mock support

group_vars/stage_dev/plain.yml

@@ -103,6 +103,8 @@ smardigo_management_oidc_client_id: "management-smardigo"
 smardigo_management_url: "{{ http_s }}://{{ management_service_connect_hostname }}/api/v1/scopes/{{ scope_id }}/processes/{{ process_instance_id }}/messages"
 smardigo_management_token: "eyJlbmMiOiJBMTI4Q0JDLUhTMjU2IiwiYWxnIjoiZGlyIn0..rCRO1cVFgkyZ45D5cJNK5g.fc6JVOo5ja5sqe-0PQTfJGOivJ6tyiD-rwgY6rXJ3-U.tOgqgJ2zTjB3_M9BGtvVjQ"
 
+connect_external_task_script_worker_enabled: true
+
 #awx_admin_username: "< see vault >"
 #awx_admin_password: "< see vault >"
 

roles/connect/vars/main.yml

@@ -71,7 +71,9 @@ connect_environment: [
   "ELASTIC_SEARCH_INDEX: \"{{ connect_elastic_search_index | default('search') }}\"",
   "ELASTIC_MESSAGE_INDEX: \"{{ connect_elastic_message_index | default('message') }}\"",
   "ELASTIC_ANALYSIS_INDEX: \"{{ connect_elastic_analysis_index | default('analysis') }}\"",
-  
+
+  "EXTERNAL_TASK_SCRIPT_WORKER_ENABLED: \"{{ connect_external_task_script_worker_enabled | default('false') }}\"",
+
   "SMA_ENABLE_WEBDAV_DOC_EDITING: \"true\"",
   "SMA_WEBDAV_BASE_PATH: \"{{ http_s }}://{{ stage_server_domain }}\"",
   "SMA_WEBDAV_HOST_URL: \"{{ http_s }}://{{ shared_service_webdav_hostname }}/\"",

smardigo/.gitignore

@@ -0,0 +1,2 @@
+/provisioning.zip
+/template.zip

smardigo/package.sh

@@ -0,0 +1,4 @@
+rm -f provisioning.zip
+zip -r provisioning.zip provisioning/
+rm -f template.zip
+zip -r template.zip template/

smardigo/template/script-worker/external-task-mock.json

@@ -0,0 +1,9 @@
+{
+  "configKey": "external-task-mock",
+  "topicName": "external-task-mock",
+  "maxTasks": 10,
+  "lockDuration": 1000,
+  "variableNames": [
+  ],
+  "script": "external-task-mock.groovy"
+}

smardigo/template/script/external-task-mock.groovy

@@ -0,0 +1,24 @@
+/****************************************
+  insert process variable values start
+*****************************************/
+def processVariables = [:]
+processVariables.result = creation_user_id + " is not a cat"
+
+/****************************************
+  insert process variable values end
+*****************************************/
+/****************************************
+  insert local variable values start
+*****************************************/
+def localVariables = [:]
+
+/****************************************
+  insert local variable values end
+*****************************************/
+
+def result = [
+  processVariables:processVariables,
+  localVariables:localVariables
+]
+
+return result;