Send notification of feedback

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 };

node/src/package.json

@@ -15,6 +15,7 @@
     "@smithy/node-http-handler": "^2.5.0",
     "@smithy/protocol-http": "^3.3.0",
     "@smithy/signature-v4": "^2.3.0",
+    "aws-sdk-client-mock": "^4.0.1",
     "axios": ">=0.21.1",
     "cookie": "^0.5.0",
     "debug": "^4.3.4",

node/test/integration/post-chat-feedback.test.js

@@ -2,8 +2,8 @@ const chai = require("chai");
 const expect = chai.expect;
 chai.use(require("chai-http"));
 const ApiToken = requireSource("api/api-token");
-const { mockClient } = require("aws-sdk-client-mock");
 const { S3Client, PutObjectCommand } = require("@aws-sdk/client-s3");
+const { mockClient } = require("aws-sdk-client-mock");
 
 const { handler } = requireSource("handlers/post-chat-feedback");
 

node/test/test-helpers/index.js

@@ -14,7 +14,7 @@ const TestEnvironment = {
   NUSSO_BASE_URL: "https://nusso-base.com/",
   NUSSO_API_KEY: "abc123",
   WEBSOCKET_URI: "wss://thisisafakewebsocketapiurl",
-  MEDIA_CONVERT_DESTINATION_BUCKET: "test-mediaconvert-destination-bucket",
+  CHAT_FEEDBACK_BUCKET: "test-mediaconvert-destination-bucket",
 };
 
 for (const v in TestEnvironment) delete process.env[v];

template.yaml

@@ -705,22 +705,37 @@ Resources:
       #*   - !Ref apiDependencies
       Environment:
         Variables:
-          MEDIA_CONVERT_DESTINATION_BUCKET: !Ref MediaConvertDestinationBucket
+          CHAT_FEEDBACK_BUCKET: !Ref chatFeedbackBucket
+          CHAT_FEEDBACK_TOPIC_ARN: !Ref chatFeedbackTopic
       Policies:
         Version: 2012-10-17
         Statement:
           - Sid: BucketAccess
             Effect: Allow
             Action:
               - s3:PutObject
-            Resource: !Sub "arn:aws:s3:::${MediaConvertDestinationBucket}/*"
+            Resource: !Sub "arn:aws:s3:::${chatFeedbackBucket}/*"
+          - Sid: TopicAccess
+            Effect: Allow
+            Action:
+              - sns:Publish
+            Resource: !Ref chatFeedbackTopic
       Events:
         PostApi:
           Type: HttpApi
           Properties:
             ApiId: !Ref dcApi
             Path: /chat-feedback
             Method: POST
+  chatFeedbackBucket:
+    Type: 'AWS::S3::Bucket'
+    Properties:
+      BucketName: !Sub "${AWS::StackName}-chat-feedback"
+  chatFeedbackTopic:
+    Type: AWS::SNS::Topic
+    Properties:
+      DisplayName: DC Chat Feedback
+      TopicName: !Sub "${AWS::StackName}-chat-feedback"
   defaultFunction:
     Type: AWS::Serverless::Function
     Properties: