+ This function listens to incoming webhooks from Vonage regarding + WhatsApp messages, and responds to them. To use the function, send + message to the WhatsApp user provided by Vonage. +
+
Date: Sun, 30 Jul 2023 21:30:04 +0100
Subject: [PATCH 09/11] chore: new utils
---
node/whatsapp-with-vonage/src/main.js | 54 +++++++++++---------------
node/whatsapp-with-vonage/src/utils.js | 34 ++++++++++++++++
2 files changed, 57 insertions(+), 31 deletions(-)
create mode 100644 node/whatsapp-with-vonage/src/utils.js
diff --git a/node/whatsapp-with-vonage/src/main.js b/node/whatsapp-with-vonage/src/main.js
index 703bad59..918a3923 100644
--- a/node/whatsapp-with-vonage/src/main.js
+++ b/node/whatsapp-with-vonage/src/main.js
@@ -1,49 +1,41 @@
import jwt from 'jsonwebtoken';
import sha256 from 'sha256';
import { fetch } from 'undici';
-import fs from 'fs';
-import path from 'path';
-import { fileURLToPath } from 'url';
-
-const __filename = fileURLToPath(import.meta.url);
-const __dirname = path.dirname(__filename);
-const staticFolder = path.join(__dirname, '../static');
+import { getStaticFile, throwIfMissing } from './utils.js';
export default async ({ req, res }) => {
- if (
- !process.env.VONAGE_API_KEY ||
- !process.env.VONAGE_API_SECRET ||
- !process.env.VONAGE_API_SIGNATURE_SECRET ||
- !process.env.VONAGE_WHATSAPP_NUMBER
- ) {
- throw new Error('Missing environment variables.');
- }
+ throwIfMissing(process.env, [
+ 'VONAGE_API_KEY',
+ 'VONAGE_API_SECRET',
+ 'VONAGE_API_SIGNATURE_SECRET',
+ 'VONAGE_WHATSAPP_NUMBER',
+ ]);
if (req.method === 'GET') {
- const html = fs
- .readFileSync(path.join(staticFolder, 'index.html'))
- .toString();
- return res.send(html, 200, { 'Content-Type': 'text/html; charset=utf-8' });
+ return res.send(getStaticFile('index.html'), 200, {
+ 'Content-Type': 'text/html; charset=utf-8',
+ });
}
const token = (req.headers.authorization ?? '').split(' ')[1];
- var decoded = jwt.verify(token, process.env.VONAGE_API_SIGNATURE_SECRET, {
- algorithms: ['HS256'],
- });
+ var decoded = jwt.verify(
+ token,
+ process.env.VONAGE_API_SIGNATURE_SECRET ?? '',
+ {
+ algorithms: ['HS256'],
+ }
+ );
- if (sha256(req.bodyString) != decoded['payload_hash']) {
+ if (sha256(req.bodyRaw) != decoded['payload_hash']) {
return res.json({ ok: false, error: 'Payload hash mismatch.' }, 401);
}
- if (!req.body.from) {
- return res.json(
- { ok: false, error: 'Missing required parameter: from.' },
- 400
- );
+ try {
+ throwIfMissing(req.body, ['from', 'text']);
+ } catch (err) {
+ return res.json({ ok: false, error: err.message }, 400);
}
- const text = req.body.text ?? 'I only accept text messages.';
-
const basicAuthToken = btoa(
`${process.env.VONAGE_API_KEY}:${process.env.VONAGE_API_SECRET}`
);
@@ -53,7 +45,7 @@ export default async ({ req, res }) => {
from: process.env.VONAGE_WHATSAPP_NUMBER,
to: req.body.from,
message_type: 'text',
- text: `Hi there! You sent me: ${text}`,
+ text: `Hi there! You sent me: ${req.body.text}`,
channel: 'whatsapp',
}),
headers: {
diff --git a/node/whatsapp-with-vonage/src/utils.js b/node/whatsapp-with-vonage/src/utils.js
new file mode 100644
index 00000000..5b93ba58
--- /dev/null
+++ b/node/whatsapp-with-vonage/src/utils.js
@@ -0,0 +1,34 @@
+import path from 'path';
+import { fileURLToPath } from 'url';
+import fs from 'fs';
+
+/**
+ * Throws an error if any of the keys are missing from the object
+ * @param {*} obj
+ * @param {string[]} keys
+ * @throws {Error}
+ */
+export function throwIfMissing(obj, keys) {
+ const missing = [];
+ for (let key of keys) {
+ if (!(key in obj) || !obj[key]) {
+ missing.push(key);
+ }
+ }
+ if (missing.length > 0) {
+ throw new Error(`Missing required fields: ${missing.join(', ')}`);
+ }
+}
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = path.dirname(__filename);
+const staticFolder = path.join(__dirname, '../static');
+
+/**
+ * Returns the contents of a file in the static folder
+ * @param {string} fileName
+ * @returns {string} Contents of static/{fileName}
+ */
+export function getStaticFile(fileName) {
+ return fs.readFileSync(path.join(staticFolder, fileName)).toString();
+}
From c2f503201bbdec15be18517a50d03bf9403c0034 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Matej=20Ba=C4=8Do?=