From ac5d6b015ab0c103ace909abe2d9c43a540d283b Mon Sep 17 00:00:00 2001
From: Methapon2001 <61303214+Methapon2001@users.noreply.github.com>
Date: Tue, 1 Apr 2025 11:34:22 +0700
Subject: [PATCH] feat: add message type to websocket

---
 src/services/rabbitmq.ts | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/src/services/rabbitmq.ts b/src/services/rabbitmq.ts
index 3bb45ef6..79f9ef7f 100644
--- a/src/services/rabbitmq.ts
+++ b/src/services/rabbitmq.ts
@@ -126,6 +126,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
   sendWebSocket(
     "send-command-notification",
     {
+      success: true,
       message: `ระบบทำการออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543}`,
       payload: command,
     },
@@ -169,6 +170,7 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
       sendWebSocket(
         "send-command-notification",
         {
+          success: true,
           message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} เสร็จสิ้น`,
           payload: command,
         },
@@ -179,6 +181,15 @@ async function handler(msg: amqp.ConsumeMessage): Promise<boolean> {
     })
     .catch((e) => {
       console.error(e);
+      sendWebSocket(
+        "send-command-notification",
+        {
+          success: false,
+          message: `ระบบออกคำสั่งเลขที่ ${command.commandNo}/${command.commandYear + 543} ผิดพลาด`,
+          payload: command,
+        },
+        { userId: user.sub },
+      ).catch(console.error);
       return false;
     });
 }