feat(task-service): complete reimplementation of task service (#1839)

* feat(task-service): complete reimplementation of task service

MIGRATION CHANGE:
migration-20230809101404- basic setup of task service db
migration-20230809100541- basic setu of example db
migration-20230808104436- basic setup of task service db

GH-1785

* feat(task-service): resolve sonar issues

MIGRATION CHANGE:
migration-20230808104436- add user task in migrations

GH-1785

* fix(task-service): add filter option for events

GH-1785

* fix(task-service): add adaptfrom in adapter, add user modify repo

MIGRATION CHANGE:
migration-20230808104436- updated migration to incude user modify properties

GH-1785

* feat(task-service): add tests for new code

MIGRATION CHANGE:
migration-20230808104436- basic migrations for setup
migration-20230808104437- http component related migrations

BB-1785

* feat(task-service): rename sub task to user task interface

BB-1785

* fix(task-service): remove redundant code from tests

GH-1785

* fix(task-service): add cascade option for user tasks

BB-1785

sandbox/task-example/README.md

@@ -18,6 +18,13 @@ To only install resolved dependencies in `package-lock.json`:
 npm ci
 ```
 
+## Deploy workflows
+
+- Deploy both workflow files in the `workflows` folder using the POST `/workflows` endpoint and keep note of the `externalIdentifier` in both cases.
+- Send the parent `externalIdentifier` to the event mapping endpoint - `/events/mapping`
+- Send the child `externalIdentifier` to the task mapping endpoint - `/tasks/mapping`
+- Trigger the event you used in second point using Kafka, it should create the tasks according to the parent workflow
+
 ## Run the application
 
 ```sh
@@ -72,4 +79,4 @@ npm test
 Please check out [LoopBack 4 documentation](https://loopback.io/doc/en/lb4/) to
 understand how you can continue to add features to this application.
 
-[![LoopBack](https://github.com/loopbackio/loopback-next/raw/master/docs/site/imgs/branding/Powered-by-LoopBack-Badge-(blue)-@2x.png)](http://loopback.io/)
+[![LoopBack](<https://github.com/loopbackio/loopback-next/raw/master/docs/site/imgs/branding/Powered-by-LoopBack-Badge-(blue)-@2x.png>)](http://loopback.io/)

sandbox/task-example/migrations/20230808104436-init.js

@@ -0,0 +1,53 @@
+'use strict';
+
+var dbm;
+var type;
+var seed;
+var fs = require('fs');
+var path = require('path');
+var Promise;
+
+/**
+  * We receive the dbmigrate dependency from dbmigrate initially.
+  * This enables us to not have to rely on NODE_PATH.
+  */
+exports.setup = function(options, seedLink) {
+  dbm = options.dbmigrate;
+  type = dbm.dataType;
+  seed = seedLink;
+  Promise = options.Promise;
+};
+
+exports.up = function(db) {
+  var filePath = path.join(__dirname, 'sqls', '20230808104436-init-up.sql');
+  return new Promise( function( resolve, reject ) {
+    fs.readFile(filePath, {encoding: 'utf-8'}, function(err,data){
+      if (err) return reject(err);
+      console.log('received data: ' + data);
+
+      resolve(data);
+    });
+  })
+  .then(function(data) {
+    return db.runSql(data);
+  });
+};
+
+exports.down = function(db) {
+  var filePath = path.join(__dirname, 'sqls', '20230808104436-init-down.sql');
+  return new Promise( function( resolve, reject ) {
+    fs.readFile(filePath, {encoding: 'utf-8'}, function(err,data){
+      if (err) return reject(err);
+      console.log('received data: ' + data);
+
+      resolve(data);
+    });
+  })
+  .then(function(data) {
+    return db.runSql(data);
+  });
+};
+
+exports._meta = {
+  "version": 1
+};

sandbox/task-example/migrations/20230809100541-init.js → sandbox/task-example/migrations/20230808104437-http.js

@@ -1,4 +1,3 @@
-/* eslint-disable */
 'use strict';
 
 var dbm;
@@ -20,7 +19,7 @@ exports.setup = function (options, seedLink) {
 };
 
 exports.up = function (db) {
-  var filePath = path.join(__dirname, 'sqls', '20230809100541-init-up.sql');
+  var filePath = path.join(__dirname, 'sqls', '20230808104437-http-up.sql');
   return new Promise(function (resolve, reject) {
     fs.readFile(filePath, {encoding: 'utf-8'}, function (err, data) {
       if (err) return reject(err);
@@ -34,7 +33,7 @@ exports.up = function (db) {
 };
 
 exports.down = function (db) {
-  var filePath = path.join(__dirname, 'sqls', '20230809100541-init-down.sql');
+  var filePath = path.join(__dirname, 'sqls', '20230808104437-http-down.sql');
   return new Promise(function (resolve, reject) {
     fs.readFile(filePath, {encoding: 'utf-8'}, function (err, data) {
       if (err) return reject(err);

sandbox/task-example/migrations/sqls/20230808104436-init-down.sql

@@ -0,0 +1,15 @@
+DROP TABLE "main".tasks CASCADE;
+
+DROP TABLE "main".user_tasks CASCADE;
+
+DROP TABLE "main".task_assignements CASCADE;
+
+DROP TABLE "main".task_workflows CASCADE;
+
+DROP TABLE "main".events CASCADE;
+
+DROP TABLE "main".event_workflows CASCADE;
+
+DROP TABLE "main".workflows CASCADE;
+
+DROP TABLE "main".workflow_versions CASCADE;

sandbox/task-example/migrations/sqls/20230808104436-init-up.sql

@@ -0,0 +1,125 @@
+CREATE SCHEMA IF NOT EXISTS main;
+GRANT ALL ON SCHEMA main TO public;
+
+CREATE TABLE "main".tasks
+(
+    id                  uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    key                 varchar                               NOT NULL,
+    name                varchar,
+    description         varchar,
+    status              varchar,
+    priority            varchar,
+    severity            varchar,
+    type                varchar,
+    start_date          timestamptz,
+    due_date            timestamptz,
+    end_date            timestamptz,
+    created_on          timestamptz DEFAULT current_timestamp NOT NULL,
+    modified_on         timestamptz DEFAULT current_timestamp NOT NULL,
+    deleted_on          timestamptz,
+    created_by          uuid,
+    modified_by         uuid,
+    deleted_by          uuid,
+    deleted             boolean,
+    assignee_id         uuid,
+    metadata            json,
+    external_id         varchar,
+    CONSTRAINT pk_tasks_id PRIMARY KEY (id)
+);
+
+CREATE TABLE "main".user_tasks 
+(
+    id                  uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    task_id             uuid NOT NULL,
+    status              varchar,
+    external_id         varchar,
+    name                varchar,
+    created_on          timestamptz DEFAULT current_timestamp NOT NULL,
+    modified_on         timestamptz DEFAULT current_timestamp NOT NULL,
+    deleted_on          timestamptz,
+    created_by          uuid,
+    modified_by         uuid,
+    deleted_by          uuid,
+    deleted             boolean,
+    CONSTRAINT pk_sub_tasks_id PRIMARY KEY (id),
+    CONSTRAINT fk_sub_tasks_tasks FOREIGN KEY (task_id) REFERENCES "main".tasks (id)
+);
+
+CREATE TABLE "main".task_workflows
+(
+    id                   uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    workflow_key         varchar,
+    task_key             varchar,
+    created_on          timestamptz DEFAULT current_timestamp NOT NULL,
+    modified_on         timestamptz DEFAULT current_timestamp NOT NULL,
+    deleted_on          timestamptz,
+    created_by          uuid,
+    modified_by         uuid,
+    deleted_by          uuid,
+    deleted             boolean,
+    CONSTRAINT pk_task_workflows_id PRIMARY KEY (id)
+);
+
+CREATE TABLE "main".events
+(
+    id                   uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    "key"                varchar,
+    "description"        varchar,
+    source               varchar,
+    payload              json,
+    created_on           timestamptz DEFAULT current_timestamp NOT NULL,
+    CONSTRAINT pk_events_id PRIMARY KEY (id)
+);
+
+CREATE TABLE "main".event_workflows
+(
+    id                   uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    event_key            varchar,
+    workflow_key         varchar,
+    created_on           timestamptz DEFAULT current_timestamp NOT NULL,
+    modified_on         timestamptz DEFAULT current_timestamp NOT NULL,
+    deleted_on          timestamptz,
+    created_by          uuid,
+    modified_by         uuid,
+    deleted_by          uuid,
+    deleted             boolean,
+    CONSTRAINT pk_event_workflows_id PRIMARY KEY (id)
+);
+
+
+CREATE SCHEMA IF NOT EXISTS main;
+GRANT ALL ON SCHEMA main TO public;
+
+CREATE TABLE "main".workflows
+(
+    id                  uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    workflow_version    integer                               NOT NULL,
+    name                varchar,
+    description         varchar,
+    external_identifier varchar,
+    provider            varchar,
+    created_on          timestamptz DEFAULT current_timestamp NOT NULL,
+    modified_on         timestamptz DEFAULT current_timestamp NOT NULL,
+    deleted_on          timestamptz,
+    created_by          uuid,
+    modified_by         uuid,
+    deleted_by          uuid,
+    deleted             boolean,
+    inputschema              json,
+    CONSTRAINT pk_workflows_id PRIMARY KEY (id)
+);
+
+CREATE TABLE "main".workflow_versions
+(
+    id                   uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    "version"            integer NOT NULL,
+    workflow_id          uuid    NOT NULL,
+    bpmn_diagram         xml,
+    external_workflow_id varchar,
+    bpmn_file_name       varchar(100),
+    inputschema               json,
+    CONSTRAINT idx_workflow_versions PRIMARY KEY ("version", workflow_id)
+);
+
+ALTER TABLE "main".workflow_versions
+    ADD CONSTRAINT fk_workflow_versions_workflows FOREIGN KEY (workflow_id) REFERENCES "main".workflows (id);

sandbox/task-example/migrations/sqls/20230808104437-http-down.sql

@@ -0,0 +1,3 @@
+DROP TABLE "main".webhook_subscriptions CASCADE;
+
+DROP TABLE "main".client_apps CASCADE;

sandbox/task-example/migrations/sqls/20230808104437-http-up.sql

@@ -0,0 +1,17 @@
+
+CREATE TABLE "main".webhook_subscriptions
+(
+    id                   uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    "key"              varchar NOT NULL,
+    "url"                varchar NOT NULL,
+    CONSTRAINT pk_webhook_subscriptions_id PRIMARY KEY (id)
+);
+
+CREATE TABLE "main".client_apps
+(
+    id                   uuid DEFAULT md5(random()::text || clock_timestamp()::text)::uuid NOT NULL,
+    "api_key"            varchar NOT NULL,
+    "api_secret"         varchar NOT NULL,
+    name                 varchar NOT NULL,
+    CONSTRAINT pk_api_keys_id PRIMARY KEY (id)
+);