fix dependencies and patch version for cli

Author: jsajal

packages/flowtest-cli/bin/index.js

@@ -4,7 +4,7 @@ const yargs = require('yargs/yargs');
 const { hideBin } = require('yargs/helpers');
 const chalk = require('chalk');
 const readFile = require('../utils/readfile');
-const { serialize } = require('../utils/parser');
+const { serialize } = require('../utils/flowparser/parser');
 const { Graph } = require('../graph/Graph');
 const { cloneDeep } = require('lodash');
 const dotenv = require('dotenv');

packages/flowtest-cli/graph/Graph.js

@@ -10,7 +10,7 @@ const path = require('path');
 const Node = require('./compute/node');
 const { LogLevel } = require('./GraphLogger');
 const readFile = require('../utils/readfile');
-const { serialize } = require('../utils/parser');
+const { serialize } = require('../utils/flowparser/parser');
 
 class nestedFlowNode extends Node {
   constructor(nodes, edges, startTime, timeout, initialEnvVars, logger) {

packages/flowtest-cli/package.json

@@ -1,6 +1,6 @@
 {
   "name": "flowtestai",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "CLI to run flow from command line",
   "main": "bin/index.js",
   "scripts": {

packages/flowtest-cli/utils/flowparser/AssertNode.js

@@ -0,0 +1,34 @@
+const { Node } = require('./Node');
+
+class AssertNode extends Node {
+  constructor() {
+    super('assertNode');
+  }
+
+  serialize(id, data, metadata) {
+    return {
+      id,
+      type: this.type,
+      data,
+      ...metadata,
+    };
+  }
+
+  deserialize(node) {
+    const id = node.id;
+    const data = node.data;
+    delete node.id;
+    delete node.data;
+    const metadata = node;
+
+    return {
+      id,
+      data,
+      metadata,
+    };
+  }
+}
+
+module.exports = {
+  AssertNode,
+};

packages/flowtest-cli/utils/flowparser/AuthNode.js

@@ -0,0 +1,34 @@
+const { Node } = require('./Node');
+
+class AuthNode extends Node {
+  constructor() {
+    super('authNode');
+  }
+
+  serialize(id, data, metadata) {
+    return {
+      id,
+      type: this.type,
+      data,
+      ...metadata,
+    };
+  }
+
+  deserialize(node) {
+    const id = node.id;
+    const data = node.data;
+    delete node.id;
+    delete node.data;
+    const metadata = node;
+
+    return {
+      id,
+      data,
+      metadata,
+    };
+  }
+}
+
+module.exports = {
+  AuthNode,
+};

packages/flowtest-cli/utils/flowparser/DelayNode.js

@@ -0,0 +1,34 @@
+const { Node } = require('./Node');
+
+class DelayNode extends Node {
+  constructor() {
+    super('delayNode');
+  }
+
+  serialize(id, data, metadata) {
+    return {
+      id,
+      type: this.type,
+      data,
+      ...metadata,
+    };
+  }
+
+  deserialize(node) {
+    const id = node.id;
+    const data = node.data;
+    delete node.id;
+    delete node.data;
+    const metadata = node;
+
+    return {
+      id,
+      data,
+      metadata,
+    };
+  }
+}
+
+module.exports = {
+  DelayNode,
+};

packages/flowtest-cli/utils/flowparser/NestedFlowNode.js

@@ -0,0 +1,34 @@
+const { Node } = require('./Node');
+
+class NestedFlowNode extends Node {
+  constructor() {
+    super('flowNode');
+  }
+
+  serialize(id, data, metadata) {
+    return {
+      id,
+      type: this.type,
+      data,
+      ...metadata,
+    };
+  }
+
+  deserialize(node) {
+    const id = node.id;
+    const data = node.data;
+    delete node.id;
+    delete node.data;
+    const metadata = node;
+
+    return {
+      id,
+      data,
+      metadata,
+    };
+  }
+}
+
+module.exports = {
+  NestedFlowNode,
+};

packages/flowtest-cli/utils/flowparser/Node.js

@@ -0,0 +1,17 @@
+class Node {
+  constructor(type) {
+    this.type = type;
+  }
+
+  serialize(id, data, metadata) {
+    throw new Error('Serialize method must be implemented by subclasses');
+  }
+
+  deserialize(node) {
+    throw new Error('Deserialize method must be implemented by subclasses');
+  }
+}
+
+module.exports = {
+  Node,
+};

packages/flowtest-cli/utils/flowparser/OutputNode.js

@@ -0,0 +1,34 @@
+const { Node } = require('./Node');
+
+class OutputNode extends Node {
+  constructor() {
+    super('outputNode');
+  }
+
+  serialize(id, data, metadata) {
+    return {
+      id,
+      type: this.type,
+      data,
+      ...metadata,
+    };
+  }
+
+  deserialize(node) {
+    const id = node.id;
+    const { ['output']: _, ...data } = node.data;
+    delete node.id;
+    delete node.data;
+    const metadata = node;
+
+    return {
+      id,
+      data,
+      metadata,
+    };
+  }
+}
+
+module.exports = {
+  OutputNode,
+};

packages/flowtest-cli/utils/flowparser/RequestNode.js

@@ -0,0 +1,34 @@
+const { Node } = require('./Node');
+
+class RequestNode extends Node {
+  constructor() {
+    super('requestNode');
+  }
+
+  serialize(id, data, metadata) {
+    return {
+      id,
+      type: this.type,
+      data,
+      ...metadata,
+    };
+  }
+
+  deserialize(node) {
+    const id = node.id;
+    const data = node.data;
+    delete node.id;
+    delete node.data;
+    const metadata = node;
+
+    return {
+      id,
+      data,
+      metadata,
+    };
+  }
+}
+
+module.exports = {
+  RequestNode,
+};