refactor(add-flow): add perma link on tree view

src/server/views/api/addFlow.js

@@ -1,3 +1,5 @@
+const flowHelpers = require('../helpers/flowHelpers');
+
 async function handler(req, res) {
   const {connectionName, flowHost} = req.params;
   const {data} = req.body;
@@ -8,9 +10,10 @@ async function handler(req, res) {
   if (!flow) return res.status(404).json({error: 'flow not found'});
 
   try {
-    const result = await Flows.set(flow, data);
+    const flowTree = await Flows.set(flow, data);
+    const processedFlow = flowHelpers.processFlow(flowTree);
 
-    return res.status(200).json(result);
+    return res.status(200).json(processedFlow);
   } catch (err) {
     return res.status(500).json({error: err.message});
   }

src/server/views/api/getFlow.js

@@ -1,18 +1,4 @@
-function processFlow(flow) {
-  const {job, children} = flow;
-  const queueName = job.queueName;
-
-  if (children && children.length > 0) {
-    return {
-      job: {...job, queueName},
-      children: children.map((child) => processFlow(child)),
-    };
-  } else {
-    return {
-      job: {...job, queueName},
-    };
-  }
-}
+const flowHelpers = require('../helpers/flowHelpers');
 
 async function handler(req, res) {
   const {connectionName, flowHost} = req.params;
@@ -27,8 +13,8 @@ async function handler(req, res) {
       depth: Number(depth),
       maxChildren: Number(maxChildren),
     });
-    const processedFlow = processFlow(flowTree);
-    const {job} = flowTree;
+    const processedFlow = flowHelpers.processFlow(flowTree);
+
     return res.status(200).json(processedFlow);
   } catch (err) {
     return res.status(500).json({error: err.message});

src/server/views/helpers/flowHelpers.js

@@ -0,0 +1,19 @@
+const Helpers = {
+  processFlow: function (flow) {
+    const {job, children} = flow;
+    const queueName = job.queueName;
+
+    if (children && children.length > 0) {
+      return {
+        job: {...job, queueName},
+        children: children.map((child) => this.processFlow(child)),
+      };
+    } else {
+      return {
+        job: {...job, queueName},
+      };
+    }
+  },
+};
+
+module.exports = Helpers;