From 6bf4b90c90f15f4ab60833bddf5b5756d1a6b1f6 Mon Sep 17 00:00:00 2001 From: Elizabeth Alexander Hunt Date: Thu, 2 Jul 2026 11:55:17 -0700 Subject: Init --- .../processors/SQSWidgetRequestProcessor.ts | 31 ++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 Homework/cs5260/widgetrequesthandler/processors/SQSWidgetRequestProcessor.ts (limited to 'Homework/cs5260/widgetrequesthandler/processors/SQSWidgetRequestProcessor.ts') diff --git a/Homework/cs5260/widgetrequesthandler/processors/SQSWidgetRequestProcessor.ts b/Homework/cs5260/widgetrequesthandler/processors/SQSWidgetRequestProcessor.ts new file mode 100644 index 0000000..cf4f4c5 --- /dev/null +++ b/Homework/cs5260/widgetrequesthandler/processors/SQSWidgetRequestProcessor.ts @@ -0,0 +1,31 @@ +import { TracingLogger } from "@/shared/log"; +import { WidgetRequestT } from "@/shared/schema"; +import { SQSClient, SendMessageCommand } from "@aws-sdk/client-sqs"; +import { ProcessorResponse, WidgetRequestProcessor } from "."; + +export class SQSWidgetRequestProcessor implements WidgetRequestProcessor { + private sqsClient: SQSClient; + private queueUrl: string; + private logger: TracingLogger; + + constructor(sqsClient: SQSClient, queueUrl: string, logger: TracingLogger) { + this.sqsClient = sqsClient; + this.queueUrl = queueUrl; + this.logger = logger; + } + + public async handle( + widgetRequest: WidgetRequestT, + ): Promise { + const MessageBody = JSON.stringify(widgetRequest); + this.logger.info(`Handling WidgetRequest=(${MessageBody})`); + + const sendMessage = new SendMessageCommand({ + QueueUrl: this.queueUrl, + MessageBody, + }); + await this.sqsClient.send(sendMessage); + + return { success: true, message: "added to queue" }; + } +} -- cgit v1.3