update maestro example

Author: RomanBachaloSigmaSoftware

index.js

@@ -302,6 +302,7 @@ app.get('/nav001', eg001Navigator.getController)
 
 app.get('/mae001', eg001maestro.getController)
   .post('/mae001', eg001maestro.createController)
+  .post('/mae001publish', eg001maestro.publishController)
   .get('/mae002', eg002maestro.getController)
   .post('/mae002', eg002maestro.createController)
   .get('/mae003', eg003maestro.getController)

lib/maestro/controllers/eg001TriggerWorkflow.js

@@ -10,6 +10,7 @@ const { formatString, API_TYPES } = require('../../utils.js');
 const { getExampleByNumber } = require('../../manifestService');
 const dsConfig = require('../../../config/index.js').config;
 const { getMaestroWorkflows, triggerWorkflow } = require('../examples/triggerWorkflow');
+const { createWorkflow, publishWorkflow } = require('../workflowUtils.js');
 
 const eg001TriggerWorkflow = exports;
 const exampleNumber = 1;
@@ -51,39 +52,103 @@ eg001TriggerWorkflow.createController = async (req, res) => {
   };
 
   const example = getExampleByNumber(res.locals.manifest, exampleNumber, api);
+  try {
+    const { instanceUrl, instanceId } = await triggerWorkflow(args, req.session.workflowId);
+    req.session.instanceId = instanceId;
+
+    return res.render('pages/maestro-examples/eg001EmbedWorkflow', {
+      title: example.ExampleName,
+      message: formatString(example.ResultsPageText, JSON.stringify(instanceId)),
+      instanceUrl,
+    });
+  } catch (error) {
+    const errorCode = error?.response?.statusCode;
+    const errorMessage = error?.response?.body?.message;
+    return res.render('pages/error', { err: error, errorCode, errorMessage });
+  }
+};
+
+/**
+ * Form page for this application
+ */
+eg001TriggerWorkflow.getController = async (req, res) => {
+  // Check that the authentication token is ok with a long buffer time.
+  // If needed, now is the best time to ask the user to authenticate
+  // since they have not yet entered any information into the form.
+  const isTokenOK = req.dsAuth.checkToken();
+  if (!isTokenOK) {
+    // Save the current operation so it will be resumed after authentication
+    req.dsAuth.setEg(req, eg);
+    return res.redirect(mustAuthenticate);
+  }
+
+  const args = {
+    accessToken: req.user.accessToken,
+    basePath: dsConfig.maestroApiUrl,
+    accountId: req.session.accountId,
+  };
+
+  const example = getExampleByNumber(res.locals.manifest, exampleNumber, api);
+  const sourceFile =
+    path.basename(__filename)[5].toLowerCase() +
+    path.basename(__filename).substr(6);
+
   try {
     const workflows = await getMaestroWorkflows(args);
+    if (!workflows.data || workflows.data.length === 0 || !workflows.data.find(wf => wf.name === workflowName)) {
+      if (!req.session.templateId) {
+        return res.render('pages/maestro-examples/eg001TriggerWorkflow', {
+          eg: eg,
+          csrfToken: req.csrfToken(),
+          example: example,
+          templateOk: false,
+          sourceFile: sourceFile,
+          sourceUrl: dsConfig.githubExampleUrl + 'maestro/examples/' + sourceFile,
+          documentation: dsConfig.documentation + eg,
+          showDoc: dsConfig.documentation,
+        });
+      }
+
+      const newWorkflow = await createWorkflow(args, req.session.templateId);
+      const consentUrl = await publishWorkflow(args, newWorkflow.workflowDefinitionId);
 
-    if (workflows.data && workflows.data.length > 0) {
-        const workflow = workflows.data.find(wf => wf.status === 'active' && wf.name === workflowName);
-        if (workflow) {
-            const { instanceUrl, instanceId } = await triggerWorkflow(args, workflow.id);
-            req.session.workflowId = workflow.id;
-            req.session.instanceId = instanceId;
-
-            return res.render('pages/maestro-examples/eg001EmbedWorkflow', {
-                title: example.ExampleName,
-                message: formatString(example.ResultsPageText, JSON.stringify(instanceId)),
-                instanceUrl,
-            });
-        }
+      req.session.workflowId = newWorkflow.workflowDefinitionId;
+
+      if (consentUrl) {
+        return res.render('pages/maestro-examples/eg001PublishWorkflow', {
+          eg: eg,
+          csrfToken: req.csrfToken(),
+          example: example,
+          message: example.AdditionalPage[0].ResultsPageText,
+          consentUrl
+        });
+      }
     }
 
-    const errorCode = '404';
-    const errorMessage = 'No active workflow found';
-    const errorInfo = example.CustomErrorTexts[0].ErrorMessage;
-    return res.render('pages/error', { errorCode, errorMessage, errorInfo });
+    const workflow = workflows.data.find(wf => wf.name === workflowName);
+    req.session.workflowId = workflow.id;
   } catch (error) {
     const errorCode = error?.response?.statusCode;
     const errorMessage = error?.response?.body?.message;
     return res.render('pages/error', { err: error, errorCode, errorMessage });
   }
+
+  res.render('pages/maestro-examples/eg001TriggerWorkflow', {
+    eg: eg,
+    csrfToken: req.csrfToken(),
+    example: example,
+    sourceFile: sourceFile,
+    templateOk: true,
+    sourceUrl: dsConfig.githubExampleUrl + 'maestro/examples/' + sourceFile,
+    documentation: dsConfig.documentation + eg,
+    showDoc: dsConfig.documentation,
+  });
 };
 
 /**
- * Form page for this application
+ * Publish workflow
  */
-eg001TriggerWorkflow.getController = async (req, res) => {
+eg001TriggerWorkflow.publishController = async (req, res) => {
   // Check that the authentication token is ok with a long buffer time.
   // If needed, now is the best time to ask the user to authenticate
   // since they have not yet entered any information into the form.
@@ -94,6 +159,29 @@ eg001TriggerWorkflow.getController = async (req, res) => {
     return res.redirect(mustAuthenticate);
   }
 
+  const args = {
+    accessToken: req.user.accessToken,
+    basePath: dsConfig.maestroApiUrl,
+    accountId: req.session.accountId,
+  };
+
+  try {
+    const consentUrl = await publishWorkflow(args, req.session.workflowId);
+
+    if (consentUrl) {
+      return res.render('pages/maestro-examples/eg001PublishWorkflow', {
+        eg: eg,
+        csrfToken: req.csrfToken(),
+        example: example,
+        message: example.AdditionalPage[0].ResultsPageText,
+        consentUrl
+      });
+    }
+  } catch (error) {
+    const errorCode = error?.response?.statusCode;
+    const errorMessage = error?.response?.body?.message;
+    return res.render('pages/error', { err: error, errorCode, errorMessage });
+  }
   const example = getExampleByNumber(res.locals.manifest, exampleNumber, api);
   const sourceFile =
     path.basename(__filename)[5].toLowerCase() +
@@ -104,6 +192,7 @@ eg001TriggerWorkflow.getController = async (req, res) => {
     csrfToken: req.csrfToken(),
     example: example,
     sourceFile: sourceFile,
+    templateOk: true,
     sourceUrl: dsConfig.githubExampleUrl + 'maestro/examples/' + sourceFile,
     documentation: dsConfig.documentation + eg,
     showDoc: dsConfig.documentation,