v1.28.22

AutomaApp · Nov 21, 2023 · 2010e7a · 2010e7a
2 parents f3e75ee + e6438b9
commit 2010e7a
Show file tree

Hide file tree

Showing 19 changed files with 60 additions and 29 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "automa",
-  "version": "1.28.21",
+  "version": "1.28.22",
   "description": "An extension for automating your browser by connecting blocks",
   "repository": {
     "type": "git",

diff --git a/src/newtab/pages/workflows/[id].vue b/src/newtab/pages/workflows/[id].vue
@@ -1528,6 +1528,12 @@ function checkWorkflowUpdate() {
 }
 /* eslint-disable consistent-return */
 function onBeforeLeave() {
+  // disselect node before leave
+  const selectedNodes = editor.value.getSelectedNodes.value;
+  selectedNodes?.forEach((node) => {
+    node.selected = false;
+  });
+
   updateHostedWorkflow();
 
   const dataNotChanged = !state.dataChanged || !haveEditAccess.value;

diff --git a/src/params/App.vue b/src/params/App.vue
@@ -48,7 +48,11 @@
         </p>
         <div class="px-4 pb-4">
           <ul class="space-y-4 divide-y">
-            <li v-for="(param, paramIdx) in workflow.params" :key="paramIdx">
+            <li
+              v-for="(param, paramIdx) in workflow.params"
+              :key="paramIdx"
+              class="flex flex-col gap-3"
+            >
               <component
                 :is="paramsList[param.type].valueComp"
                 v-if="paramsList[param.type]"
@@ -74,7 +78,7 @@
               <p
                 v-if="param.description"
                 title="Description"
-                class="ml-1 whitespace-pre text-sm leading-tight"
+                class="ml-1 text-sm leading-tight"
               >
                 {{ param.description }}
               </p>

diff --git a/src/workflowEngine/WorkflowWorker.js b/src/workflowEngine/WorkflowWorker.js
@@ -110,7 +110,7 @@ class WorkflowWorker {
     currentColumn.index += 1;
   }
 
-  setVariable(name, value) {
+  async setVariable(name, value) {
     let variableName = name;
     const vars = this.engine.referenceData.variables;
 
@@ -127,10 +127,15 @@ class WorkflowWorker {
     }
 
     if (variableName.startsWith('$$')) {
-      dbStorage.variables.put({
-        value,
-        name: variableName.slice(2),
+      variableName = variableName.slice(2);
+
+      const findStorageVar = await dbStorage.variables.get({
+        name: variableName,
       });
+
+      if (findStorageVar)
+        await dbStorage.variables.update(findStorageVar.id, { value });
+      else await dbStorage.variables.add({ name: variableName, value });
     }
 
     this.engine.addRefDataSnapshot('variables');
@@ -392,7 +397,7 @@ class WorkflowWorker {
             value = parseJSON(value, value);
 
             if (item.type === 'variable') {
-              this.setVariable(item.name, value);
+              await this.setVariable(item.name, value);
             } else {
               this.addDataToColumn(item.name, value);
             }

diff --git a/src/workflowEngine/blocksHandler/handlerClipboard.js b/src/workflowEngine/blocksHandler/handlerClipboard.js
@@ -46,7 +46,7 @@ export default async function ({ data, id, label }) {
     valueToReturn = copiedText;
 
     if (data.assignVariable) {
-      this.setVariable(data.variableName, copiedText);
+      await this.setVariable(data.variableName, copiedText);
     }
     if (data.saveData) {
       this.addDataToColumn(data.dataColumn, copiedText);

diff --git a/src/workflowEngine/blocksHandler/handlerCookie.js b/src/workflowEngine/blocksHandler/handlerCookie.js
@@ -75,7 +75,7 @@ async function cookie({ data, id }) {
 
   if (data.type === 'get') {
     if (data.assignVariable) {
-      this.setVariable(data.variableName, result);
+      await this.setVariable(data.variableName, result);
     }
     if (data.saveData) {
       this.addDataToColumn(data.dataColumn, result);

diff --git a/src/workflowEngine/blocksHandler/handlerDataMapping.js b/src/workflowEngine/blocksHandler/handlerDataMapping.js
@@ -46,7 +46,7 @@ export async function dataMapping({ id, data }) {
   }
 
   if (data.assignVariable) {
-    this.setVariable(data.variableName, dataToMap);
+    await this.setVariable(data.variableName, dataToMap);
   }
   if (data.saveData) {
     this.addDataToColumn(data.dataColumn, dataToMap);

diff --git a/src/workflowEngine/blocksHandler/handlerGoogleSheets.js b/src/workflowEngine/blocksHandler/handlerGoogleSheets.js
@@ -154,7 +154,7 @@ export default async function ({ data, id }, { refData }) {
       result = await getSpreadsheetRange(data);
 
       if (data.assignVariable) {
-        this.setVariable(data.variableName, result);
+        await this.setVariable(data.variableName, result);
       }
       if (data.saveData) {
         this.addDataToColumn(data.dataColumn, result);
@@ -172,7 +172,7 @@ export default async function ({ data, id }, { refData }) {
       result = spreadsheetId;
 
       if (data.assignVariable) {
-        this.setVariable(data.variableName, result);
+        await this.setVariable(data.variableName, result);
       }
       if (data.saveData) {
         this.addDataToColumn(data.dataColumn, result);

diff --git a/src/workflowEngine/blocksHandler/handlerHandleDownload.js b/src/workflowEngine/blocksHandler/handlerHandleDownload.js
@@ -48,7 +48,7 @@ async function handleDownload({ data, id: blockId }) {
         this.addDataToColumn(data.dataColumn, downloadItem.filename);
       }
       if (data.assignVariable) {
-        this.setVariable(data.variableName, downloadItem.filename);
+        await this.setVariable(data.variableName, downloadItem.filename);
       }
 
       return {

diff --git a/src/workflowEngine/blocksHandler/handlerInsertData.js b/src/workflowEngine/blocksHandler/handlerInsertData.js
@@ -81,7 +81,7 @@ async function insertData({ id, data }, { refData }) {
         this.addDataToColumn(item.name, tableValue);
       });
     } else {
-      this.setVariable(item.name, value);
+      await this.setVariable(item.name, value);
     }
   }
 

diff --git a/src/workflowEngine/blocksHandler/handlerInteractionBlock.js b/src/workflowEngine/blocksHandler/handlerInteractionBlock.js
@@ -69,7 +69,7 @@ async function interactionHandler(block) {
     }
 
     if (block.data.assignVariable) {
-      this.setVariable(block.data.variableName, data);
+      await this.setVariable(block.data.variableName, data);
     }
 
     if (debugMode && isChrome) {

diff --git a/src/workflowEngine/blocksHandler/handlerJavascriptCode.js b/src/workflowEngine/blocksHandler/handlerJavascriptCode.js
@@ -204,9 +204,11 @@ export async function javascriptCode({ outputs, data, ...block }, { refData }) {
     }
 
     if (result.variables) {
-      Object.keys(result.variables).forEach((varName) => {
-        this.setVariable(varName, result.variables[varName]);
-      });
+      await Promise.allSettled(
+        Object.keys(result.variables).map(async (varName) => {
+          await this.setVariable(varName, result.variables[varName]);
+        })
+      );
     }
 
     let insert = true;
@@ -222,10 +224,21 @@ export async function javascriptCode({ outputs, data, ...block }, { refData }) {
       insert = typeof insertData === 'boolean' ? insertData : true;
 
       if (inputNextBlockId) {
-        const customNextBlockId = this.getBlockConnections(inputNextBlockId);
+        let customNextBlockId = this.getBlockConnections(inputNextBlockId);
         if (!customNextBlockId)
           throw new Error(`Can't find block with "${inputNextBlockId}" id`);
 
+        const nextBlock = this.engine.blocks[inputNextBlockId];
+        if (!customNextBlockId && nextBlock) {
+          customNextBlockId = [
+            {
+              id: inputNextBlockId,
+              blockId: inputNextBlockId,
+              connections: new Map([]),
+            },
+          ];
+        }
+
         nextBlockId = customNextBlockId;
       }
     } else {

diff --git a/src/workflowEngine/blocksHandler/handlerLogData.js b/src/workflowEngine/blocksHandler/handlerLogData.js
@@ -22,7 +22,7 @@ export async function logData({ id, data }) {
       logs = getTranslateLog(curWorkflowState, 'json');
 
       if (data.assignVariable) {
-        this.setVariable(data.variableName, logs);
+        await this.setVariable(data.variableName, logs);
       }
       if (data.saveData) {
         this.addDataToColumn(data.dataColumn, logs);

diff --git a/src/workflowEngine/blocksHandler/handlerParameterPrompt.js b/src/workflowEngine/blocksHandler/handlerParameterPrompt.js
@@ -75,9 +75,11 @@ export default async function ({ data, id }) {
 
   const result = await getInputtedParams(promptId, timeout);
 
-  Object.entries(result).forEach(([varName, varValue]) => {
-    this.setVariable(varName, varValue);
-  });
+  await Promise.allSettled(
+    Object.entries(result).map(async ([varName, varValue]) =>
+      this.setVariable(varName, varValue)
+    )
+  );
 
   return {
     data: '',

diff --git a/src/workflowEngine/blocksHandler/handlerSaveAssets.js b/src/workflowEngine/blocksHandler/handlerSaveAssets.js
@@ -60,7 +60,7 @@ export default async function ({ data, id, label }) {
 
   if (data.saveDownloadIds) {
     if (data.assignVariable) {
-      this.setVariable(data.variableName, downloadIds);
+      await this.setVariable(data.variableName, downloadIds);
     }
     if (data.saveData) {
       this.addDataToColumn(data.dataColumn, downloadIds);

diff --git a/src/workflowEngine/blocksHandler/handlerSortData.js b/src/workflowEngine/blocksHandler/handlerSortData.js
@@ -54,7 +54,7 @@ export async function sliceData({ id, data }) {
   });
 
   if (data.assignVariable) {
-    this.setVariable(data.variableName, sortedArray);
+    await this.setVariable(data.variableName, sortedArray);
   }
   if (data.saveData) {
     this.addDataToColumn(data.dataColumn, sortedArray);

diff --git a/src/workflowEngine/blocksHandler/handlerTabUrl.js b/src/workflowEngine/blocksHandler/handlerTabUrl.js
@@ -23,7 +23,7 @@ export async function logData({ id, data }) {
   }
 
   if (data.assignVariable) {
-    this.setVariable(data.variableName, urls);
+    await this.setVariable(data.variableName, urls);
   }
   if (data.saveData) {
     this.addDataToColumn(data.dataColumn, urls);

diff --git a/src/workflowEngine/blocksHandler/handlerTakeScreenshot.js b/src/workflowEngine/blocksHandler/handlerTakeScreenshot.js
@@ -51,7 +51,8 @@ async function takeScreenshot({ data, id, label }) {
           uri: dataUrl,
           ext: data.ext,
         });
-      if (data.assignVariable) this.setVariable(data.variableName, dataUrl);
+      if (data.assignVariable)
+        await this.setVariable(data.variableName, dataUrl);
     };
 
     if (data.captureActiveTab) {

diff --git a/src/workflowEngine/blocksHandler/handlerWebhook.js b/src/workflowEngine/blocksHandler/handlerWebhook.js
@@ -105,7 +105,7 @@ export async function webhook({ data, id }, { refData }) {
     }
 
     if (data.assignVariable) {
-      this.setVariable(data.variableName, returnData);
+      await this.setVariable(data.variableName, returnData);
     }
     if (data.saveData) {
       if (data.dataColumn === '$assignColumns' && Array.isArray(returnData)) {