Merge pull request #219 from wizelineacademy/sqs-integration-with-lalo

implements rulersurvey sqs for lalo
wizelineacademy · Jun 13, 2024 · 930a802 · 930a802
2 parents 156cd9e + 709c994
commit 930a802
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 5 deletions.
diff --git a/handlers/subscriber.ts b/handlers/subscriber.ts
@@ -1,6 +1,10 @@
 import db from "@/db/drizzle";
 import { finalSurvey, sprintSurvey } from "@/db/schema";
-import { feedbackAnalysis, projectAnalysis } from "@/services/rag";
+import {
+  feedbackAnalysis,
+  projectAnalysis,
+  rulerAnalysis,
+} from "@/services/rag";
 import { DeleteMessageCommand, SQSClient } from "@aws-sdk/client-sqs";
 import { eq } from "drizzle-orm";
 import { Resource } from "sst";
@@ -14,8 +18,7 @@ export const handler: SQSHandler = async (event) => {
   switch (messageBody.type) {
     case "RULER":
       try {
-        console.log("ruler msg bdy", messageBody);
-        //TODO: lalo implements this
+        await rulerAnalysis(messageBody.id);
       } catch (error) {
         console.log("ERROR:", error);
       }

diff --git a/services/project.ts b/services/project.ts
@@ -242,7 +242,8 @@ export async function getUpdateFeedbackHistory({
 }
 
 export interface SQSMessageBody {
-  id: number;
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  id: any;
   type: "RULER" | "SPRINT" | "FINAL";
 }
 

diff --git a/services/rulerSurvey.ts b/services/rulerSurvey.ts
@@ -38,7 +38,7 @@ export async function submitRulerSurveyAnswer(surveyAnswer: RulerSurveyAnswer) {
       MessageGroupId: messageGroupId,
       MessageDeduplicationId: crypto.randomUUID(),
       MessageBody: JSON.stringify({
-        id: 1,
+        id: surveyAnswer.userId,
         type: "RULER",
       } as SQSMessageBody),
     }),