the hawk.nodejs catcher added

Author: robonetphy

.env.example

@@ -3,6 +3,9 @@
 # - "admin:org - read:org"
 TOKEN=
 
+#HAWK Catcher TOKEN
+HAWK_TOKEN=
+
 # Node id
 COLUMN_NODE_ID_TO_DO=
 COLUMN_NODE_ID_PR=

package.json

@@ -11,6 +11,7 @@
     "get-projects": "node bin/get-projects.js"
   },
   "dependencies": {
+    "@hawk.so/nodejs": "^2.2.0",
     "@octokit/core": "^3.1.2",
     "axios": "^0.19.2",
     "cron": "^1.8.2",

src/index.js

@@ -1,6 +1,7 @@
 require('dotenv').config();
 
 const Utils = require('./utils');
+const HawkCatcher = require('@hawk.so/nodejs').default;
 
 const { Octokit } = require('@octokit/core');
 const parseGithubUrl = require('parse-github-url');
@@ -9,6 +10,8 @@ const axios = require('axios').default;
 const CronJob = require('cron').CronJob;
 
 const TOKEN = process.env.TOKEN;
+const HAWK_TOKEN = process.env.HAWK_TOKEN;
+
 const COLUMN_NODE_ID_TO_DO = process.env.COLUMN_NODE_ID_TO_DO;
 const COLUMN_NODE_ID_PR = process.env.COLUMN_NODE_ID_PR;
 const NOTIFIER_URL = process.env.NOTIFIER_URL;
@@ -40,6 +43,16 @@ const CARDS_QUERY = require('./queries/cards');
 const ISSUE_QUERY = require('./queries/issue');
 const PR_QUERY = require('./queries/pr');
 
+/**
+ * Initialize HawkCatcher.
+ */
+HawkCatcher.init({
+  token: HAWK_TOKEN,
+  context: {
+    myOwnDebugInfo: '1234',
+  },
+});
+
 /**
  * Sends POST request to telegram bot
  *
@@ -76,7 +89,7 @@ function checkForParsableGithubLink(message) {
     return [true, owner, name, type, id];
   }
 
-  return [ false ];
+  return [false];
 }
 
 /**
@@ -355,7 +368,7 @@ async function parseQuery(members, response) {
     })
   );
 
-  let cardDataWithoutMembers = [ ...parsedCardData ];
+  let cardDataWithoutMembers = [...parsedCardData];
 
   for (let i = 0; i < members.length; i++) {
     cardDataWithoutMembers = cardDataWithoutMembers.map((x) =>
@@ -482,56 +495,60 @@ function parseMeetingMessage(mentionList) {
  * Call the Github GraphQL API, parse its response to message and add that message as cron job.
  */
 async function main() {
-  const toDoJob = new CronJob(
-    TO_DO_TIME,
-    async () => {
-      notify(
-        await notifyMessage("📌 Sprint's backlog", COLUMN_NODE_ID_TO_DO, true)
-      )
-        .then(() => console.log('Tasks Job Completed.'))
-        .catch(console.error);
-    },
-    null,
-    true,
-    'Europe/Moscow'
-  );
+  try {
+    const toDoJob = new CronJob(
+      TO_DO_TIME,
+      async () => {
+        notify(
+          await notifyMessage("📌 Sprint's backlog", COLUMN_NODE_ID_TO_DO, true)
+        )
+          .then(() => console.log('Tasks Job Completed.'))
+          .catch(HawkCatcher.send);
+      },
+      null,
+      true,
+      'Europe/Moscow'
+    );
 
-  const prJob = new CronJob(
-    PR_TIME,
-    async () => {
-      notify(
-        await notifyMessage('👀 Pull requests for review', COLUMN_NODE_ID_PR)
-      )
-        .then(() => console.log('PR Job Completed.'))
-        .catch(console.error);
-    },
-    null,
-    true,
-    'Europe/Moscow'
-  );
-  const meetingJob = new CronJob(
-    MEETING_TIME,
-    () => {
-      notify(parseMeetingMessage(MEETING_MENTION))
-        .then(() => console.log('Meeting Job Completed.'))
-        .catch(console.error);
-    },
-    null,
-    true,
-    'Europe/Moscow'
-  );
+    const prJob = new CronJob(
+      PR_TIME,
+      async () => {
+        notify(
+          await notifyMessage('👀 Pull requests for review', COLUMN_NODE_ID_PR)
+        )
+          .then(() => console.log('PR Job Completed.'))
+          .catch(HawkCatcher.send);
+      },
+      null,
+      true,
+      'Europe/Moscow'
+    );
+    const meetingJob = new CronJob(
+      MEETING_TIME,
+      () => {
+        notify(parseMeetingMessage(MEETING_MENTION))
+          .then(() => console.log('Meeting Job Completed.'))
+          .catch(HawkCatcher.send);
+      },
+      null,
+      true,
+      'Europe/Moscow'
+    );
 
-  toDoJob.start();
-  console.log('To do list Notifier started');
-  console.log('Will notify at:' + TO_DO_TIME);
+    toDoJob.start();
+    console.log('To do list Notifier started');
+    console.log('Will notify at:' + TO_DO_TIME);
 
-  prJob.start();
-  console.log('PR review list Notifier started');
-  console.log('Will notify at:' + PR_TIME);
+    prJob.start();
+    console.log('PR review list Notifier started');
+    console.log('Will notify at:' + PR_TIME);
 
-  meetingJob.start();
-  console.log('Meeting notifier started');
-  console.log('Will notify at:' + MEETING_TIME);
+    meetingJob.start();
+    console.log('Meeting notifier started');
+    console.log('Will notify at:' + MEETING_TIME);
+  } catch (e) {
+    HawkCatcher.send(e);
+  }
 }
 
 main();

yarn.lock

@@ -39,6 +39,14 @@
     minimatch "^3.0.4"
     strip-json-comments "^3.1.1"
 
+"@hawk.so/nodejs@^2.2.0":
+  version "2.2.0"
+  resolved "https://registry.yarnpkg.com/@hawk.so/nodejs/-/nodejs-2.2.0.tgz#d72f028b2b39eaf6ac1a8b5f711ab9faa7649cb3"
+  integrity sha512-6QdzhfNfzEEmkHzW3ApfGAbl4Ri8P68ezHqHgzToGVN/42SeC/wWX21hR69BrXSfMloK/33AH+Be/luNY388Ug==
+  dependencies:
+    axios "^0.19.2"
+    stack-trace "^0.0.10"
+
 "@nodelib/fs.scandir@2.1.4":
   version "2.1.4"
   resolved "https://registry.yarnpkg.com/@nodelib/fs.scandir/-/fs.scandir-2.1.4.tgz#d4b3549a5db5de2683e0c1071ab4f140904bbf69"
@@ -1958,6 +1966,11 @@ sprintf-js@~1.0.2:
   resolved "https://registry.yarnpkg.com/sprintf-js/-/sprintf-js-1.0.3.tgz#04e6926f662895354f3dd015203633b857297e2c"
   integrity sha1-BOaSb2YolTVPPdAVIDYzuFcpfiw=
 
+stack-trace@^0.0.10:
+  version "0.0.10"
+  resolved "https://registry.yarnpkg.com/stack-trace/-/stack-trace-0.0.10.tgz#547c70b347e8d32b4e108ea1a2a159e5fdde19c0"
+  integrity sha1-VHxws0fo0ytOEI6hoqFZ5f3eGcA=
+
 string-width@^3.0.0:
   version "3.1.0"
   resolved "https://registry.yarnpkg.com/string-width/-/string-width-3.1.0.tgz#22767be21b62af1081574306f69ac51b62203961"