wf work

back/workflows.json

@@ -51,31 +51,5 @@
         }
       }
     ]
-  },
-  {
-    "name": "Sample Plugin Object Workflow",
-    "trigger": {
-      "object_type": "Plugins_Objects",
-      "event_type": "create"
-    },
-    "conditions": [
-      {
-        "logic": "AND",
-        "conditions": [
-          {
-            "field": "Plugin",
-            "operator": "equals",
-            "value": "ARPSCAN"
-          },
-          {
-            "field": "Status",
-            "operator": "equals",
-            "value": "missing-in-last-scan"
-          }
-        ]
-      }
-    ],
-    "actions": [     
-    ]
   }
 ]

front/css/app.css

@@ -1891,13 +1891,18 @@ input[readonly] {
     padding: 10px;
 }
 
-.workflow-card, .condition-list, .actions-list 
+.workflow-card, .actions-list 
 {
-    display: grid;
+    display: contents;
     padding: 5px;
     padding-left: 10px;
 }
 
+.condition-list
+{
+    z-index:1;
+}
+
 .condition 
 {
     padding: 5px;

front/workflowsCore.php

@@ -38,7 +38,7 @@ let fieldOptions = [
       ];
       
 let triggerTypes = [
-  "Devices", "Plugins_Objects"
+  "Devices"
 ];
 
 let operatorTypes = [
@@ -52,6 +52,7 @@ let actionTypes = [
 // --------------------------------------
 // Retrieve and process the data
 function getData() {
+
   showSpinner();
 
   getSetting()
@@ -60,9 +61,7 @@ function getData() {
     workflows = res;
     console.log(workflows);
 
-    // Store the updated workflows object back into cache
-    setCache('workflows', JSON.stringify(workflows));
-
+    updateWorkflowsJson(workflows);
     renderWorkflows();
     hideSpinner();
   });
@@ -75,6 +74,11 @@ function renderWorkflows() {
   let $container = $("#workflowContainer");
   $container.empty(); // Clear previous UI
 
+  workflows = getWorkflowsJson();
+
+  console.log("renderWorkflows");
+  console.log(workflows);
+
   $.each(workflows, function (index, wf) {
     let $wfElement = generateWorkflowUI(wf, index);
     $container.append($wfElement);
@@ -87,14 +91,14 @@ function renderWorkflows() {
 function generateWorkflowUI(wf, wfIndex) {
 
   let $wfContainer = $("<div>", { 
-    class: "workflow-card box box-solid box-primary panel panel-default", 
+    class: "workflow-card col-sm-12 col-sx-12", 
     id: `wf-${wfIndex}-container` 
   });
 
   // Workflow Name
   let $wfLinkWrap = $("<div>",
     {
-      class: " ",
+      class: "box box-solid box-primary  ",
       id: `wf-${wfIndex}-header` 
     }
   )
@@ -150,7 +154,7 @@ function generateWorkflowUI(wf, wfIndex) {
   // Trigger Section with dropdowns
   let $triggerSection = $("<div>",
     {
-      class: "condition-list box  box-secondary"
+      class: "box  box-secondary col-sm-12 col-sx-12"
     }
   ).append($triggerTitle);
 
@@ -203,7 +207,11 @@ function generateWorkflowUI(wf, wfIndex) {
   lastActionIndex = 0
   $.each(wf.actions, function (actionIndex, action) {
     let $actionEl = $("<div>", {
-      class: "panel"
+      class: "col-sm-11 col-sx-12"
+    });
+
+    let $actionElWrap = $("<div>", {
+      class: "panel col-sm-12 col-sx-12"
     });
 
     // Dropdown for action.field
@@ -241,10 +249,10 @@ function generateWorkflowUI(wf, wfIndex) {
 
     // Actions
 
-    let $actionRemoveButtonWrap = $("<div>", { class: "button-container col-sm-12 col-sx-12" });
+    let $actionRemoveButtonWrap = $("<div>", { class: "button-container col-sm-1 col-sx-12" });
 
     let $actionRemoveIcon = $("<i>", { 
-      class: "fa-solid fa-minus"
+      class: "fa-solid fa-trash"
     });
 
     let $actionRemoveButton = $("<button>", {
@@ -252,13 +260,14 @@ function generateWorkflowUI(wf, wfIndex) {
       actionIndex: actionIndex,
       wfIndex: wfIndex
     })
-    .append($actionRemoveIcon) // Add icon
-    .append("Remove Action"); // Add text
+    .append($actionRemoveIcon)
 
     $actionRemoveButtonWrap.append($actionRemoveButton);
-    $actionEl.append($actionRemoveButtonWrap);
 
-    $actionsContainer.append($actionEl);
+    $actionElWrap.append($actionEl)
+    $actionElWrap.append($actionRemoveButtonWrap)
+
+    $actionsContainer.append($actionElWrap);
 
     lastActionIndex = actionIndex
   });
@@ -303,7 +312,7 @@ function generateWorkflowUI(wf, wfIndex) {
 // Render conditions recursively
 function renderConditions(wfIndex, parentIndexPath, conditionGroupsIndex, conditions) {
   let $conditionList = $("<div>", { 
-    class: "condition-list  ",
+    class: "condition-list panel panel-secondary col-sm-12 col-sx-12",
     parentIndexPath: parentIndexPath 
   });
 
@@ -316,7 +325,7 @@ function renderConditions(wfIndex, parentIndexPath, conditionGroupsIndex, condit
     if (condition.logic) {
       let $nestedCondition = $("<div>",
         {
-          class : "condition box  box-secondary"
+          class : "condition box  box-secondary col-sm-12 col-sx-12"
         }
       );
 
@@ -340,11 +349,16 @@ function renderConditions(wfIndex, parentIndexPath, conditionGroupsIndex, condit
       // INDIVIDUAL CONDITIONS
       let $conditionItem = $("<div>",
       {
-        class: "panel",
+        class: "panel col-sm-12 col-sx-12",
         conditionIndex: conditionIndex,
         wfIndex: wfIndex
       });
 
+      let $conditionItemsWrap = $("<div>",
+      {
+        class: "conditionItemsWrap col-sm-11 col-sx-12"
+      });
+
       // Create dropdown for condition field
       let $fieldDropdown = createEditableDropdown(
         `${currentPath}.field`,"Field", 
@@ -371,22 +385,23 @@ function renderConditions(wfIndex, parentIndexPath, conditionGroupsIndex, condit
           "condition-value-input"
        );
 
-      $conditionItem.append($fieldDropdown); // Append field dropdown
-      $conditionItem.append($operatorDropdown); // Append operator dropdown
-      $conditionItem.append($editableInput); // Append editable input for condition value
+      $conditionItemsWrap.append($fieldDropdown); // Append field dropdown
+      $conditionItemsWrap.append($operatorDropdown); // Append operator dropdown
+      $conditionItemsWrap.append($editableInput); // Append editable input for condition value
 
-      let $conditionRemoveButtonWrap = $("<div>", { class: "button-container col-sm-12 col-sx-12" });
+      let $conditionRemoveButtonWrap = $("<div>", { class: "button-container col-sm-1 col-sx-12" });
       let $conditionRemoveButtonIcon = $("<i>", { 
-        class: "fa-solid fa-minus"
+        class: "fa-solid fa-trash"
       });
       let $conditionRemoveButton = $("<button>", {
-        class : "btn btn-secondary remove-condition",
-        lastConditionIndex : lastConditionIndex,
+        class : "btn btn-secondary remove-condition col-sm-12 col-sx-12",
+        conditionIndex : conditionIndex,
         wfIndex: wfIndex,
         parentIndexPath: parentIndexPath
-      }).append($conditionRemoveButtonIcon).append("Remove Condition")
+      }).append($conditionRemoveButtonIcon)
 
       $conditionRemoveButtonWrap .append($conditionRemoveButton);
+      $conditionItem.append($conditionItemsWrap);
       $conditionItem.append($conditionRemoveButtonWrap);
 
       $conditionList.append($conditionItem);      
@@ -401,20 +416,19 @@ function renderConditions(wfIndex, parentIndexPath, conditionGroupsIndex, condit
 
   if (conditionGroupsIndex != 0) {
     // Add Condition button
-    let $conditionAddWrap = $("<div>", { class: "button-container col-sm-6 col-sx-12" });
+    let $conditionAddWrap = $("<div>", { class: "button-container col-sx-12" });
     let $conditionAddIcon = $("<i>", { 
       class: "fa-solid fa-plus"
     });
     let $conditionAddButton = $("<button>", {
       class: "btn btn-secondary add-condition col-sx-12",
-      lastConditionIndex: lastConditionIndex,
       wfIndex: wfIndex,
       parentIndexPath: parentIndexPath
     }).append($conditionAddIcon).append("Add Condition");
     $conditionAddWrap.append($conditionAddButton);
 
     // Remove Condition Group button
-    let $conditionGroupRemoveWrap = $("<div>", { class: "button-container col-sm-6 col-sx-12" });
+    let $conditionGroupRemoveWrap = $("<div>", { class: "button-container col-sx-12" });
     let $conditionGroupRemoveIcon = $("<i>", { 
       class: "fa-solid fa-trash"
     });
@@ -455,7 +469,7 @@ function renderConditions(wfIndex, parentIndexPath, conditionGroupsIndex, condit
 function createEditableDropdown(jsonPath, labelText, options, selectedValue, id) {
 
   let $wrapper = $("<div>", {
-    class: "form-group col-xs-12"
+    class: "form-group col-sm-12 col-sx-12"
   });
 
   let $label = $("<label>", {   
@@ -474,6 +488,7 @@ function createEditableDropdown(jsonPath, labelText, options, selectedValue, id)
     jsonPath: jsonPath,
     class: "form-control col-sm-8 col-xs-12"
   });
+ 
 
   // Add options to the select dropdown
   $.each(options, function (_, option) {
@@ -505,7 +520,7 @@ function createEditableInput(jsonPath, labelText, value, id, className = "") {
 
   // prepare wrapper
   $wrapper = $("<div>", {
-    class: "form-group col-xs-12"
+    class: "form-group col-sm-12 col-xs-12"
   });
 
   let $label = $("<label>", {   
@@ -553,7 +568,7 @@ function createEditableInput(jsonPath, labelText, value, id, className = "") {
 // Updating the in-memory workflow object
 function updateWorkflowObject(newValue, jsonPath) {
   // Load workflows from cache if available
-  let workflows = JSON.parse(getCache('workflows')) || []; // Initialize as an array
+  let workflows = getWorkflowsJson()
 
   console.log("Initial workflows:", workflows);
 
@@ -561,8 +576,7 @@ function updateWorkflowObject(newValue, jsonPath) {
 
   console.log("Updated workflows:", workflows);
 
-  // Store the updated workflows object back into cache
-  setCache('workflows', JSON.stringify(workflows)); // Store as a string in localStorage
+  updateWorkflowsJson(workflows)
 }
 
 
@@ -634,25 +648,10 @@ function parsePath(path) {
 
 // ---------------------------------------------------
 // Function to add a new Workflow
-function addWorkflow() {
-  workflows.push({
-      "name": "New Workflow",
-      "trigger": {
-        "object_type": "Devices",
-        "event_type": "create"
-      },
-      "conditions": [
-      ],
-      "actions": [     
-      ]
-    }
-  );
+function addWorkflow(workflows) {
+  workflows.push(getEmptyWorkflowJson());
 
-  // // Ensure the workflows object is updated in memory
-  // workflows =  workflows;
-
-  // Update the cache with the modified workflows object
-  setCache("workflows", JSON.stringify(workflows));
+  updateWorkflowsJson(workflows)
 
   // Re-render the UI
   renderWorkflows();
@@ -660,15 +659,11 @@ function addWorkflow() {
 
 // ---------------------------------------------------
 // Function to remove a Workflow
-function removeWorkflow(wfIndex) {
+function removeWorkflow(workflows, wfIndex) {
   
   workflows.splice(wfIndex, 1);
 
-  // // Ensure the workflows object is updated in memory
-  // workflows =  workflows;
-
-  // Update the cache with the modified workflows object
-  setCache("workflows", JSON.stringify(workflows));
+  updateWorkflowsJson(workflows)
 
   // Re-render the UI
   renderWorkflows();
@@ -676,9 +671,11 @@ function removeWorkflow(wfIndex) {
 
 // ---------------------------------------------------
 // Function to add a new condition
-function addCondition(wfIndex, parentIndexPath) {
+function addCondition(workflows, wfIndex, parentIndexPath) {
     if (!parentIndexPath) return;
 
+    workflows = getWorkflowsJson()
+
     // Navigate to the target nested object
     let target = getNestedObject(workflows, parentIndexPath);
 
@@ -699,8 +696,7 @@ function addCondition(wfIndex, parentIndexPath) {
     // Ensure the workflows object is updated in memory
     workflows[wfIndex] = { ...workflows[wfIndex] };
 
-    // Update the cache with the modified workflows object
-    setCache("workflows", JSON.stringify(workflows));
+    updateWorkflowsJson(workflows)
 
     // Re-render the UI
     renderWorkflows();
@@ -708,7 +704,7 @@ function addCondition(wfIndex, parentIndexPath) {
 
 // ---------------------------------------------------
 // Function to add a new condition group
-function addConditionGroup(wfIndex, parentIndexPath) {
+function addConditionGroup(workflows, wfIndex, parentIndexPath) {
     if (!parentIndexPath) return;
 
     // Navigate to the target nested object
@@ -730,8 +726,7 @@ function addConditionGroup(wfIndex, parentIndexPath) {
     // Ensure the workflows object is updated in memory
     workflows[wfIndex] = { ...workflows[wfIndex] };
 
-    // Update the cache with the modified workflows object
-    setCache("workflows", JSON.stringify(workflows));
+    updateWorkflowsJson(workflows)
 
     // Re-render the UI
     renderWorkflows();
@@ -739,18 +734,21 @@ function addConditionGroup(wfIndex, parentIndexPath) {
 
 // ---------------------------------------------------
 // Function to add a new action
-function addAction(wfIndex) {
+function addAction(workflows, wfIndex) {
     let newAction = {
         type: actionTypes[0],
         field: fieldOptions[0],
         value: ""
     };
     workflows[wfIndex].actions.push(newAction);
+
+    updateWorkflowsJson(workflows)
+
     renderWorkflows();
 }
 
-function removeCondition(wfIndex, parentIndexPath, lastConditionIndex) {
-    if (!parentIndexPath || lastConditionIndex === undefined) return;
+function removeCondition(workflows, wfIndex, parentIndexPath, conditionIndex) {
+    if (!parentIndexPath || conditionIndex === undefined) return;
 
     // Navigate to the target nested object
     let target = getNestedObject(workflows, parentIndexPath);
@@ -763,19 +761,18 @@ function removeCondition(wfIndex, parentIndexPath, lastConditionIndex) {
     }
 
     // Remove the specified condition
-    target.conditions.splice(lastConditionIndex, 1);
+    target.conditions.splice(conditionIndex, 1);
 
     // Ensure the workflows object is updated in memory
     workflows[wfIndex] = { ...workflows[wfIndex] };
 
-    // Update the cache with the modified workflows object
-    setCache("workflows", JSON.stringify(workflows));
+    updateWorkflowsJson(workflows)
 
     // Re-render the UI
     renderWorkflows();
 }
 
-function removeAction(wfIndex, actionIndex) {
+function removeAction(workflows, wfIndex, actionIndex) {
     if (!actionIndex || actionIndex === undefined) return;
 
     // Navigate to the target nested object
@@ -788,20 +785,21 @@ function removeAction(wfIndex, actionIndex) {
         return;
     }
 
+    console.log(actionIndex);
+    
     // Remove the specified condition
     target.actions.splice(actionIndex, 1);
 
     // Ensure the workflows object is updated in memory
     workflows[wfIndex] = { ...workflows[wfIndex] };
 
-    // Update the cache with the modified workflows object
-    setCache("workflows", JSON.stringify(workflows));
+    updateWorkflowsJson(workflows)
 
     // Re-render the UI
     renderWorkflows();
 }
 
-function removeConditionGroup(wfIndex, parentIndexPath) {
+function removeConditionGroup(workflows, wfIndex, parentIndexPath) {
     if (!parentIndexPath) return;
 
     // Split the path by dots
@@ -832,8 +830,7 @@ function removeConditionGroup(wfIndex, parentIndexPath) {
     // Ensure the workflows object is updated in memory
     workflows[wfIndex] = { ...workflows[wfIndex] };
 
-    // Update the cache with the modified workflows object
-    setCache("workflows", JSON.stringify(workflows));
+    updateWorkflowsJson(workflows)
 
     // Re-render the UI
     renderWorkflows();
@@ -860,41 +857,73 @@ function getNestedObject(obj, path) {
     }, obj);
 }
 
+// ---------------------------------------------------
+// Get workflows JSON
+function getWorkflowsJson()
+{
+  return workflows = JSON.parse(getCache('workflows')) || getEmptyWorkflowJson();
+} 
+
+// ---------------------------------------------------
+// Get workflows JSON
+function updateWorkflowsJson(workflows)
+{  
+    // Store the updated workflows object back into cache
+    setCache('workflows', JSON.stringify(workflows));
+} 
+
+// ---------------------------------------------------
+// Get empty workflow JSON
+function getEmptyWorkflowJson()
+{
+  return {
+      "name": "New Workflow",
+      "trigger": {
+        "object_type": "Devices",
+        "event_type": "create"
+      },
+      "conditions": [
+      ],
+      "actions": [     
+      ]
+    }
+} 
+
 // ---------------------------------------------------
 // Event listeners
 $(document).on("click", ".add-workflow-btn", function () {
-  addWorkflow();
+  addWorkflow(getWorkflowsJson());
 });
 
 $(document).on("click", ".remove-wf", function () {
   let wfIndex = $(this).attr("wfindex");
-  removeWorkflow(wfIndex);
+  removeWorkflow(getWorkflowsJson(), wfIndex);
 });
 
 $(document).on("click", ".add-condition", function () {
     let wfIndex = $(this).attr("wfindex");
     let parentIndexPath = $(this).attr("parentIndexPath");
-    addCondition(wfIndex, parentIndexPath);
+    addCondition(getWorkflowsJson(), wfIndex, parentIndexPath);
 });
 
 $(document).on("click", ".add-condition-group", function () {
     let wfIndex = $(this).attr("wfindex");
     let parentIndexPath = $(this).attr("parentIndexPath");
-    addConditionGroup(wfIndex, parentIndexPath);
+    addConditionGroup(getWorkflowsJson(), wfIndex, parentIndexPath);
 });
 
 $(document).on("click", ".add-action", function () {
     let wfIndex = $(this).attr("wfIndex");
-    addAction(wfIndex);
+    addAction(getWorkflowsJson(), wfIndex);
 });
 
 // Event Listeners for Removing Conditions
 $(document).on("click", ".remove-condition", function () {
     let wfIndex = $(this).attr("wfindex");
     let parentIndexPath = $(this).attr("parentIndexPath");
-    let lastConditionIndex = parseInt($(this).attr("lastConditionIndex"), 10);
+    let conditionIndex = parseInt($(this).attr("conditionIndex"), 10);
     
-    removeCondition(wfIndex, parentIndexPath, lastConditionIndex);
+    removeCondition(getWorkflowsJson(), wfIndex, parentIndexPath, conditionIndex);
 });
 
 // Event Listeners for Removing Actions
@@ -902,16 +931,14 @@ $(document).on("click", ".remove-action", function () {
     let wfIndex = $(this).attr("wfindex");
     let actionIndex = $(this).attr("actionIndex");
     
-    removeAction(wfIndex, actionIndex);
+    removeAction(getWorkflowsJson(), wfIndex, actionIndex);
 });
 
 // Event Listeners for Removing Condition Groups
 $(document).on("click", ".remove-condition-group", function () {
     let wfIndex = $(this).attr("wfindex");
     let parentIndexPath = $(this).attr("parentIndexPath");
-    let lastConditionIndex = parseInt($(this).attr("lastConditionIndex"), 10);
-    
-    removeConditionGroup(wfIndex, parentIndexPath);
+    removeConditionGroup(getWorkflowsJson(), wfIndex, parentIndexPath);
 });
 
 // ---------------------------------------------------

server/workflows/app_events.py

@@ -122,7 +122,6 @@ class AppEvent_obj:
         """Generic function to create triggers dynamically."""
         trigger_name = f"trg_{event}_{table_name.lower()}"
 
-
         query = f"""
          CREATE TRIGGER IF NOT EXISTS "{trigger_name}"
             AFTER {event.upper()} ON "{table_name}"
@@ -130,8 +129,8 @@ class AppEvent_obj:
                 SELECT 1 FROM AppEvents 
                 WHERE AppEventProcessed = 0 
                 AND ObjectType = '{table_name}'
-                AND ObjectGUID = {config['fields']['ObjectGUID']}
-                AND ObjectStatus = {config['fields']['ObjectStatus']} 
+                AND ObjectGUID = {manage_prefix(config['fields']['ObjectGUID'], event)}
+                AND ObjectStatus = {manage_prefix(config['fields']['ObjectStatus'], event)} 
                 AND AppEventType = '{event.lower()}'
             )
             BEGIN
@@ -156,15 +155,15 @@ class AppEvent_obj:
                     DATETIME('now'), 
                     FALSE, 
                     '{table_name}', 
-                    {config['fields']['ObjectGUID']},  -- ObjectGUID
-                    {config['fields']['ObjectPrimaryID']},  -- ObjectPrimaryID
-                    {config['fields']['ObjectSecondaryID']},  -- ObjectSecondaryID
-                    {config['fields']['ObjectStatus']},  -- ObjectStatus
-                    {config['fields']['ObjectStatusColumn']},  -- ObjectStatusColumn
-                    {config['fields']['ObjectIsNew']},  -- ObjectIsNew
-                    {config['fields']['ObjectIsArchived']},  -- ObjectIsArchived
-                    {config['fields']['ObjectForeignKey']},  -- ObjectForeignKey
-                    {config['fields']['ObjectPlugin']},  -- ObjectForeignKey
+                    {manage_prefix(config['fields']['ObjectGUID'], event)},  -- ObjectGUID
+                    {manage_prefix(config['fields']['ObjectPrimaryID'], event)},  -- ObjectPrimaryID
+                    {manage_prefix(config['fields']['ObjectSecondaryID'], event)},  -- ObjectSecondaryID
+                    {manage_prefix(config['fields']['ObjectStatus'], event)},  -- ObjectStatus
+                    {manage_prefix(config['fields']['ObjectStatusColumn'], event)},  -- ObjectStatusColumn
+                    {manage_prefix(config['fields']['ObjectIsNew'], event)},  -- ObjectIsNew
+                    {manage_prefix(config['fields']['ObjectIsArchived'], event)},  -- ObjectIsArchived
+                    {manage_prefix(config['fields']['ObjectForeignKey'], event)},  -- ObjectForeignKey
+                    {manage_prefix(config['fields']['ObjectPlugin'], event)},  -- ObjectForeignKey
                     '{event.lower()}'
                 );
             END;
@@ -177,3 +176,10 @@ class AppEvent_obj:
     def save(self):
         # Commit changes
         self.db.commitDB()
+
+# Manage prefixes of column names
+def manage_prefix(field, event):
+    if event == "delete":
+        return field.replace("NEW.", "OLD.")
+    return field 
+

test/workflows.json

@@ -1,17 +1,4 @@
 [
-  {
-    "name": "Empty Workflow",
-    "trigger": {
-      "object_type": "",
-      "event_type": ""
-    },
-    "conditions": [
-     
-    ],
-    "actions": [
-      
-    ]
-  },
   {
     "name": "Sample Device Update Workflow",
     "trigger": {
@@ -36,14 +23,14 @@
             "logic": "OR",
             "conditions": [
               {
-                "field": "devSite",
+                "field": "devIsNew",
                 "operator": "equals",
-                "value": "Home"
+                "value": "1"
               },
               {
                 "field": "devName",
                 "operator": "contains",
-                "value": "Motorola"
+                "value": "Google"
               }
             ]
           }
@@ -55,33 +42,14 @@
         "type": "update_field",
         "field": "devIsNew",
         "value": "0"
-      }
-    ]
-  },
-  {
-    "name": "Sample Plugin Object Workflow",
-    "trigger": {
-      "object_type": "Plugins_Objects",
-      "event_type": "create"
-    },
-    "conditions": [
+      },
       {
-        "logic": "AND",
-        "conditions": [
-          {
-            "field": "Plugin",
-            "operator": "equals",
-            "value": "ARPSCAN"
-          },
-          {
-            "field": "Status",
-            "operator": "equals",
-            "value": "missing-in-last-scan"
-          }
-        ]
+        "type": "run_plugin",
+        "plugin": "SMTP",
+        "params": {
+          "message": "New device from Google detected."
+        }
       }
-    ],
-    "actions": [     
     ]
   }
 ]