From 34d7e060074ee57ce8493d0131b2f4ad4ddd3c00 Mon Sep 17 00:00:00 2001
From: Lei OT <lyt@hainatravel.com>
Date: Tue, 31 Dec 2024 15:28:22 +0800
Subject: [PATCH] =?UTF-8?q?feat(WAI):=20=E6=8E=A8=E9=80=81=E7=99=BB?=
 =?UTF-8?q?=E5=BD=95=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 wai-server/core/handler/whatsappHandler.js | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/wai-server/core/handler/whatsappHandler.js b/wai-server/core/handler/whatsappHandler.js
index 9297c80..47e846c 100644
--- a/wai-server/core/handler/whatsappHandler.js
+++ b/wai-server/core/handler/whatsappHandler.js
@@ -36,6 +36,7 @@ const webhookBodyBuilder = (messageData, messageType) => {
     createTime: new Date(new Date().getTime() + 8 * 60 * 60 * 1000).toISOString(), // GMT +8
     domainName,
     conversationid: messageData?.externalId || '',
+    whatsAppNo: messageData?.whatsAppNo || '',
     waiMessage: {
       ...messageData,
       ...(messageData.updateTime ? { [timeField[messageData.status]]: messageData.updateTime } : {}),
@@ -87,6 +88,8 @@ const setupConnectionHandler = () => {
         },
         { connect_domain: domain, connect_name: domainName },
       );
+      const webhookBody = webhookBodyBuilder({ ...connectionData, connection: 'open' }, 'creds:update');
+      await callWebhook(webhookBody);
     } catch (error) {
       logger.error({ connectionData, error }, 'error add connection');
     }
@@ -104,6 +107,8 @@ const setupConnectionHandler = () => {
         { connect_domain: domain, connect_name: domainName, channel_id: connectionData.channelId },
       );
       // todo: 通知前端: 重新扫码
+      const webhookBody = webhookBodyBuilder({ ...connectionData, connection: 'offline' }, 'creds:update');
+      await callWebhook(webhookBody);
     } catch (error) {
       logger.error({ connectionData, error }, 'error add connection');
     }
@@ -118,7 +123,7 @@ const setupCredsHandler = () => {
   whatsappEvents.on('creds:update', async creds => {
     logger.info('creds:update', creds);
     try {
-      const webhookBody = webhookBodyBuilder({ ...creds }, eventName);
+      const webhookBody = webhookBodyBuilder({ ...creds, connection: '' }, 'creds:update');
       await callWebhook(webhookBody);
     } catch (error) {
       logger.error({ creds, error }, 'error update creds');