additional @pushto operation in json transformer

Author: devhelpr

archive/json-map-language.json

@@ -11,6 +11,11 @@
       }
     }
   },
+  "@pushTo:messages": {
+    "@comment": "this pushes a new message to messages",
+    "role": "system",
+    "@set:content": "input"
+  },
   "@comment": "this sets the name property to the value of payload['input-property-name']",
   "@set:name": "input-property-name",
   "@operation:object": {

libs/web-flow-executor/src/nodes/json-utils/transform-json.test.ts

@@ -82,16 +82,23 @@ describe('transformJSON', () => {
           },
         },
       },
+      '@pushTo:messages': {
+        '@comment': 'this pushes a new message to messages',
+        role: 'system',
+        '@set:content': 'input',
+      },
     };
     const result = transformJSON(input, undefined, 'root', {
       ['payload-messages']: [
         { role: 'admin', message: 'hello', a: 5, b: 8 },
         { role: 'user', message: 'world', a: 303, b: 606 },
       ],
+      ['input']: 'hello test',
     });
     expect((result as any)['messages']).toEqual([
       { role: 'admin', content: 'hello', calc: 13 },
       { role: 'user', content: 'world', calc: 909 },
+      { role: 'system', content: 'hello test' },
     ]);
   });
 

libs/web-flow-executor/src/nodes/json-utils/transform-json.ts

@@ -11,9 +11,37 @@ const evaluateAtProperty = (
   newJson: any,
   key: string,
   value: any,
-  payload: any
+  payload: any,
+  initialPayload?: any
 ) => {
-  if (key.startsWith('@expression:')) {
+  if (key.startsWith('@pushTo:')) {
+    const setProperty = key.replace('@pushTo:', '');
+    if (!newJson[setProperty]) {
+      newJson[setProperty] = [];
+    }
+    const newItem: any = {};
+    Object.keys(value).forEach((mapKey) => {
+      if (mapKey.startsWith('@') && !mapKey.startsWith('@@')) {
+        const mapValue = value[mapKey];
+        evaluateAtProperty(
+          newItem,
+          mapKey,
+          mapValue,
+          initialPayload,
+          initialPayload
+        );
+      } else {
+        const mapValue = value[mapKey];
+        if (isArrayOrObject(mapValue)) {
+          transformJSON(mapValue, mapKey, '', initialPayload);
+        } else {
+          newItem[mapKey] = mapValue;
+        }
+      }
+    });
+
+    newJson[setProperty].push(newItem);
+  } else if (key.startsWith('@expression:')) {
     const setProperty = key.replace('@expression:', '');
     const compiledExpression = compileExpressionAsInfo(value);
     const expressionFunction = (
@@ -55,7 +83,7 @@ const evaluateAtProperty = (
           const newItem: any = {};
           Object.keys(value.map.properties).forEach((mapKey) => {
             const mapValue = value.map.properties[mapKey];
-            evaluateAtProperty(newItem, mapKey, mapValue, item);
+            evaluateAtProperty(newItem, mapKey, mapValue, item, initialPayload);
           });
           return newItem;
         });
@@ -98,7 +126,7 @@ export const transformJSON = (
       console.log(`${path ? path + '.' : ''}${key}`);
 
       if (key.startsWith('@') && !key.startsWith('@@')) {
-        evaluateAtProperty(newJson, key, value, payload);
+        evaluateAtProperty(newJson, key, value, payload, payload);
       } else if (isArrayOrObject(value)) {
         const result = transformJSON(
           value,
@@ -115,7 +143,7 @@ export const transformJSON = (
     });
     return newJson;
   } else {
-    console.log(path, json);
-    return json;
+    console.error(path, json);
+    throw new Error('Unexpected JSON');
   }
 };

libs/web-flow-executor/src/nodes/raw-json.tsx

@@ -172,9 +172,9 @@ export const getRawJsonNode: NodeTaskFactory<NodeInfo> = (
       ];
     },
     (nodeInstance) => {
-      if (nodeInstance.node.nodeInfo) {
-        nodeInstance.node.nodeInfo.isRunOnStart = true;
-      }
+      // if (nodeInstance.node.nodeInfo) {
+      //   nodeInstance.node.nodeInfo.isRunOnStart = true;
+      // }
       canvasAppInstance = nodeInstance.contextInstance;
       rect = nodeInstance.rect;
       node = nodeInstance.node as IRectNodeComponent<NodeInfo>;

libs/web-flow-executor/src/nodes/user-text-input.tsx

@@ -52,7 +52,7 @@ export const getUserTextInput =
           followPath: undefined,
         };
       } else {
-        if (typeof input !== 'string') {
+        if (typeof input === 'string') {
           currentValue = input;
           if (inputElement) {
             inputElement.value = currentValue;