Send notification of feedback

nulib · Jun 28, 2024 · 2b0df30 · 2b0df30
1 parent 1b5e2bf
commit 2b0df30
Show file tree

Hide file tree

Showing 8 changed files with 1,949 additions and 20 deletions.
diff --git a/layers/api_dependencies/package-lock.json b/layers/api_dependencies/package-lock.json
diff --git a/layers/api_dependencies/package.json b/layers/api_dependencies/package.json
@@ -8,6 +8,7 @@
   "dependencies": {
     "@aws-crypto/sha256-browser": "^2.0.1",
     "@aws-sdk/client-sfn": "^3.563.0",
+    "@aws-sdk/client-sns": "^3.606.0",
     "@aws-sdk/credential-provider-node": "^3.563.0",
     "@honeybadger-io/js": "^4.9.3",
     "@smithy/node-http-handler": "^2.5.0",

diff --git a/node/src/handlers/post-chat-feedback.js b/node/src/handlers/post-chat-feedback.js
@@ -1,5 +1,7 @@
 const { wrap } = require("./middleware");
 const { PutObjectCommand, S3Client } = require("@aws-sdk/client-s3");
+const { SNSClient, PublishCommand } = require("@aws-sdk/client-sns");
+
 const Validator = require("jsonschema").Validator;
 
 const feedbackSchema = {
@@ -56,6 +58,11 @@ const handler = wrap(async (event) => {
     }
     await uploadToS3(`${content.sentiment}/${content.context.ref}`, content);
 
+    await sendNotification(
+      `Chat feedback: ${content.sentiment} response`,
+      JSON.stringify(content, null, 2)
+    );
+
     return {
       statusCode: 200,
       headers: { "content-type": "text/plain" },
@@ -76,7 +83,7 @@ const handler = wrap(async (event) => {
 const uploadToS3 = async (key, body) => {
   const client = new S3Client({});
   const command = new PutObjectCommand({
-    Bucket: process.env.MEDIA_CONVERT_DESTINATION_BUCKET,
+    Bucket: process.env.CHAT_FEEDBACK_BUCKET,
     Key: key,
     Body: JSON.stringify(body, null, 2),
     ContentType: "application/json",
@@ -85,4 +92,16 @@ const uploadToS3 = async (key, body) => {
   return await client.send(command);
 };
 
-module.exports = { handler };
+const sendNotification = async (subject, message) => {
+  const snsClient = new SNSClient({});
+  const command = new PublishCommand({
+    TopicArn: process.env.CHAT_FEEDBACK_TOPIC_ARN,
+    Subject: subject,
+    Message: message,
+  });
+  const response = await snsClient.send(command);
+  console.log(response);
+  return response;
+};
+
+module.exports = { handler, uploadToS3 };