From 46142b8a4bf3bb5af319f291dc061114155b3889 Mon Sep 17 00:00:00 2001
From: LiaoYijun <lyj@hainatravel.com>
Date: Wed, 25 Dec 2024 14:02:58 +0800
Subject: [PATCH] =?UTF-8?q?perf:=20=E5=A2=9E=E5=8A=A0=E5=8F=91=E9=80=81?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=94=99=E8=AF=AF=E6=8D=95=E8=8E=B7=EF=BC=9B?=
 =?UTF-8?q?webhook=20=E9=87=8D=E8=AF=95=E4=B8=80=E6=AC=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 wai-server/core/baileys/index.js | 12 +++++++++---
 wai-server/core/webhook/index.js |  2 +-
 2 files changed, 10 insertions(+), 4 deletions(-)

diff --git a/wai-server/core/baileys/index.js b/wai-server/core/baileys/index.js
index f70b2e2..5df3e50 100644
--- a/wai-server/core/baileys/index.js
+++ b/wai-server/core/baileys/index.js
@@ -54,7 +54,10 @@ const createWhatsApp = async phone => {
   const sendTextMessage = (whatsAppNo, content) => {
     const number = formatPhoneNumber(whatsAppNo);
     try {
-      waSocket.sendMessage(number, { text: content });
+      waSocket.sendMessage(number, { text: content })
+        .catch(ex => {
+          console.info('发送文本消息出错', ex)
+        });
     } catch (ex) {
       waEmitter.emit('message.error', {
         messge: '发送文本消息出错',
@@ -69,6 +72,9 @@ const createWhatsApp = async phone => {
     try {
       waSocket.sendMessage(number, {
         image: { url: imageUrl },
+      })
+      .catch(ex => {
+        console.info('发送图片消息出错', ex)
       });
     } catch (ex) {
       waEmitter.emit('message.error', {
@@ -253,8 +259,8 @@ const createWhatsApp = async phone => {
             console.log('正在重连：');
             start();
           } else {
-            waSocket.end(error => console.error('end.error: ', error));
-            waSocket.logout(msg => console.error('logout.msg: ', msg));
+            // waSocket.end(error => console.error('end.error: ', error));
+            // waSocket.logout(msg => console.error('logout.msg: ', msg));
             console.log('Connection closed. You are logged out.');
 
             waEmitter.emit('connection:close', {
diff --git a/wai-server/core/webhook/index.js b/wai-server/core/webhook/index.js
index 7bdf295..0b1a39d 100644
--- a/wai-server/core/webhook/index.js
+++ b/wai-server/core/webhook/index.js
@@ -6,7 +6,7 @@ const webhookUrl = require('../../config').webhook;
 // 5s, 10s, 20s, 30s, 1m, 15m, 30m, 1h
 const retryDelays = [5000, 10000, 20000, 30000, 300000, 900000, 1800000, 3600000];
 axiosRetry(axios, {
-  retries: 8, // Number of retries
+  retries: 1, // Number of retries
   retryDelay: retryCount => {
     const delayIndex = Math.min(retryCount - 1, retryDelays.length - 1);
     const delay = retryDelays[delayIndex];