Wrap the newParticipant in an object

gh-250
douglasnaphas · Mar 28, 2022 · 4a5238e · 4a5238e
1 parent c554963
commit 4a5238e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/backend/stream.js b/backend/stream.js
@@ -69,7 +69,9 @@ const handleJoin = async (record) => {
   for (let i = 0; i < connectionIds.length; i++) {
     const postToConnectionParams = {
       ConnectionId: connectionIds[i],
-      Data: Buffer.from(record.dynamodb.NewImage.game_name.S),
+      Data: Buffer.from(
+        JSON.stringify({ newParticipant: record.dynamodb.NewImage.game_name.S })
+      ),
     };
     try {
       await api.postToConnection(postToConnectionParams).promise();

diff --git a/backend/stream.test.js b/backend/stream.test.js
@@ -178,7 +178,7 @@ describe("stream", () => {
         },
         expectedPostToConnectionParams: {
           ConnectionId: "PktBLdr_IAMCJxA=",
-          Data: Buffer.from("Le"),
+          Data: Buffer.from(JSON.stringify({ newParticipant: "Le" })),
         },
         postToConnectionData: {},
         expectedStatusCode: 200,
@@ -227,11 +227,13 @@ describe("stream", () => {
           return MockApiGatewayManagementApi;
         });
         process.env.TABLE_NAME = TABLE_NAME;
-        process.env.WS_ENDPOINT = WS_ENDPOINT
+        process.env.WS_ENDPOINT = WS_ENDPOINT;
         const handler = require("./stream").handler;
         const result = await handler(event);
         expect(result.statusCode).toEqual(expectedStatusCode);
-        expect(MockApiGatewayManagementApi).toHaveBeenCalledWith({endpoint: WS_ENDPOINT})
+        expect(MockApiGatewayManagementApi).toHaveBeenCalledWith({
+          endpoint: WS_ENDPOINT,
+        });
         if (expectedDbQueryParams) {
           expect(mockQuery).toHaveBeenCalledWith(expectedDbQueryParams);
         }