feat: slack integration (#34)

Co-authored-by: Evan Gentis <[email protected]>

.env.example

@@ -1,3 +1,6 @@
 EMAIL_USERNAME="[email protected]"
 EMAIL_PASSWORD="secretpassword"
+SLACK_CHANNEL="SlackChannelName"
+SLACK_TOKEN="slack-token"
 STORES="bestbuy,bandh,nvidia"
+NOTIFICATION_METHODS="email"

package.json

@@ -28,6 +28,7 @@
     "winston": "^3.3.3"
   },
   "devDependencies": {
+    "@slack/web-api": "^5.12.0",
     "@types/node": "^14.11.1",
     "@types/nodemailer": "^6.4.0",
     "@types/puppeteer": "^3.0.2",

src/config.ts

@@ -20,10 +20,19 @@ const page = {
 
 const stores = process.env.STORES ?? 'nvidia';
 
+const notificationMethods = process.env.NOTIFICATION_METHODS ?? 'email';
+
+const slack = {
+	channel: process.env.SLACK_CHANNEL,
+	token: process.env.SLACK_TOKEN
+};
+
 export const Config = {
 	email,
 	notifications,
 	page,
 	rateLimitTimeout: 5000,
-	stores
+	stores,
+	slack,
+	notificationMethods
 };

src/notification/index.ts

@@ -1,8 +1,13 @@
 import {Config} from '../config';
 import sendEmail from './email';
+import sendSlaskMessage from './slack';
 
 export default function sendNotification(cartUrl: string) {
-	if (Config.notifications.email) {
+	if (Config.notificationMethods.toLocaleLowerCase().includes('email')) {
 		sendEmail(cartUrl);
 	}
+
+	if (Config.notificationMethods.toLocaleLowerCase().includes('slack')) {
+		sendSlaskMessage(cartUrl);
+	}
 }

src/notification/slack.ts

@@ -0,0 +1,23 @@
+import {WebClient} from '@slack/web-api';
+import {Config} from '../config';
+import {Logger} from '../logger';
+
+const channel = Config.slack.channel ?? '';
+const token = Config.slack.token ?? '';
+const web = new WebClient(token);
+
+export default function sendSlackMessage(text: string) {
+	(async () => {
+		try {
+			const result = await web.chat.postMessage({text, channel});
+			if (!result.ok) {
+				Logger.error(result.error);
+				return;
+			}
+
+			Logger.info(`✔ slack message sent to '${channel}': ${text}`);
+		} catch (error) {
+			Logger.error(error);
+		}
+	})();
+}