feat: send errors to targets (#233)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "testbeats",
-  "version": "2.0.8",
+  "version": "2.0.9",
   "description": "Publish test results to Microsoft Teams, Google Chat, Slack and InfluxDB",
   "main": "src/index.js",
   "types": "./src/index.d.ts",

src/commands/publish.command.js

@@ -18,6 +18,7 @@ class PublishCommand {
    */
   constructor(opts) {
     this.opts = opts;
+    this.errors = [];
   }
 
   async publish() {
@@ -31,7 +32,7 @@ class PublishCommand {
     this.#validateConfig();
     this.#processResults();
     await this.#publishResults();
-    logger.info('✅ Results published successfully!');
+    await this.#publishErrors();
   }
 
   #validateEnvDetails() {
@@ -184,13 +185,24 @@ class PublishCommand {
         } else if (result_options.type === 'jmeter') {
           this.results.push(prp.parse(result_options));
         } else {
-          this.results.push(trp.parse(result_options));
+          const { result, errors } = trp.parseV2(result_options);
+          if (result) {
+            this.results.push(result);
+          }
+          if (errors) {
+            this.errors = this.errors.concat(errors);
+          }
         }
       }
     }
   }
 
   async #publishResults() {
+    if (!this.results.length) {
+      logger.warn('⚠️ No results to publish');
+      return;
+    }
+
     for (const config of this.configs) {
       for (let i = 0; i < this.results.length; i++) {
         const result = this.results[i];
@@ -207,6 +219,23 @@ class PublishCommand {
         }
       }
     }
+    logger.info('✅ Results published successfully!');
+  }
+
+  async #publishErrors() {
+    if (!this.errors.length) {
+      logger.debug('⚠️ No errors to publish');
+      return;
+    }
+    logger.info('🛑 Publishing errors...');
+    for (const config of this.configs) {
+      if (config.targets) {
+        for (const target of config.targets) {
+          await target_manager.handleErrors({ target, errors: this.errors });
+        }
+      }
+    }
+    throw new Error(this.errors.join('\n'));
   }
 
 }

src/targets/chat.js

@@ -238,7 +238,31 @@ const default_inputs = {
   ]
 };
 
+async function handleErrors({ target, errors }) {
+  let title = 'Error: Reporting Test Results';
+  title = target.inputs.title ? title + ' - ' + target.inputs.title : title;
+
+  const root_payload = getRootPayload();
+  const payload = root_payload.cards[0];
+
+  payload.sections.push({
+    "widgets": [
+      {
+        "textParagraph": {
+          text: `<b>${title}</b><br><br><b>Errors</b>: <br>${errors.join('<br>')}`
+        }
+      }
+    ]
+  });
+
+  return request.post({
+    url: target.inputs.url,
+    body: root_payload
+  });
+}
+
 module.exports = {
   run,
+  handleErrors,
   default_options
 }

src/targets/index.js

@@ -34,6 +34,14 @@ async function run(target, result) {
   }
 }
 
+async function handleErrors({ target, errors }) {
+  const target_runner = getTargetRunner(target);
+  if (target_runner.handleErrors) {
+    await target_runner.handleErrors({ target, errors });
+  }
+}
+
 module.exports = {
-  run
+  run,
+  handleErrors
 }

src/targets/slack.js

@@ -264,7 +264,45 @@ const default_inputs = {
   ]
 }
 
+async function handleErrors({ target, errors }) {
+  let title = 'Error: Reporting Test Results';
+  title = target.inputs.title ? title + ' - ' + target.inputs.title : title;
+
+  const blocks = [];
+
+  blocks.push({
+    "type": "section",
+    "text": {
+      "type": "mrkdwn",
+      "text": title
+    }
+  });
+  blocks.push({
+    "type": "section",
+    "text": {
+      "type": "mrkdwn",
+      "text": errors.join('\n\n')
+    }
+  });
+
+  const payload = {
+    "attachments": [
+      {
+        "color": COLORS.DANGER,
+        "blocks": blocks,
+        "fallback": title,
+      }
+    ]
+  };
+
+  return request.post({
+    url: target.inputs.url,
+    body: payload
+  });
+}
+
 module.exports = {
   run,
+  handleErrors,
   default_options
 }

src/targets/teams.js

@@ -300,7 +300,40 @@ const default_inputs = {
   ]
 }
 
+async function handleErrors({ target, errors }) {
+  let title = 'Error: Reporting Test Results';
+  title = target.inputs.title ? title + ' - ' + target.inputs.title : title;
+
+  const root_payload = getRootPayload();
+  const payload = getMainPayload(target);
+
+  payload.body.push({
+    "type": "TextBlock",
+    "text": title,
+    "size": "medium",
+    "weight": "bolder",
+    "wrap": true
+  });
+
+  payload.body.push({
+    "type": "TextBlock",
+    "text": errors.join('\n'),
+    "size": "medium",
+    "weight": "bolder",
+    "wrap": true
+  });
+
+  setRootPayload(root_payload, payload);
+
+
+  return request.post({
+    url: target.inputs.url,
+    body: root_payload
+  });
+}
+
 module.exports = {
   run,
+  handleErrors,
   default_options
 }