From 2abdc6ccafe0c71922dfd66ec8834fb770955f8a Mon Sep 17 00:00:00 2001 From: Lei OT Date: Wed, 25 Dec 2024 11:50:26 +0800 Subject: [PATCH 1/3] =?UTF-8?q?perf:=20=E4=B8=8A=E4=BC=A0=E6=9C=80?= =?UTF-8?q?=E8=BF=91=201=20=E5=B0=8F=E6=97=B6=E7=9A=84=E6=97=A5=E5=BF=97,?= =?UTF-8?q?=20=E7=9B=B4=E6=8E=A5upload=20=E6=89=80=E6=9C=89=E6=97=A5?= =?UTF-8?q?=E5=BF=97:=20413=20Payload=20Too=20Large?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/views/AuthApp.jsx | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) diff --git a/src/views/AuthApp.jsx b/src/views/AuthApp.jsx index ea8e0ff..666892c 100644 --- a/src/views/AuthApp.jsx +++ b/src/views/AuthApp.jsx @@ -89,10 +89,20 @@ function AuthApp() { await readWebsocketLog() if (window.$pageSpy) { // window.$pageSpy.triggerPlugins('onOfflineLog', 'upload') - await window.$harbor.upload() // 上传日志 { clearCache: true, remark: '' } - messageApi.info('Success') - clearWebsocketLog() - sendNotify() + try { + // await window.$harbor.upload() // 上传日志 { clearCache: true, remark: '' } + // 上传最近 1 小时的日志, 直接upload 所有日志: 413 Payload Too Large + const now = Date.now() + await window.$harbor.uploadPeriods({ + startTime: now - 60 * 60000, + endTime: now, + }) + messageApi.info('Success') + clearWebsocketLog() + sendNotify() + } catch (error) { + messageApi.error('Failure') + } } else { messageApi.error('Failure') } From 448693d304ae1442a937fd867cdfbfc267ef2f18 Mon Sep 17 00:00:00 2001 From: Lei OT Date: Wed, 25 Dec 2024 11:56:21 +0800 Subject: [PATCH 2/3] =?UTF-8?q?sendMessage:=20=E4=B8=8D=E7=AD=89=E5=BE=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/config.js | 1 + wai-server/api/messages/message.controller.js | 10 +--------- 2 files changed, 2 insertions(+), 9 deletions(-) diff --git a/src/config.js b/src/config.js index b442a7a..7039fd3 100644 --- a/src/config.js +++ b/src/config.js @@ -12,6 +12,7 @@ export const WAI_HOST = 'http://202.103.68.93:3031/api/v1'; export const EMAIL_ATTA_HOST = 'https://p9axztuwd7x8a7.mycht.cn/attatchment'; // 邮件附件 // prod: +// export const WAI_HOST = 'https://wai-server-qq4qmtq7wc9he4.mycht.cn/api/v1'; export const EMAIL_HOST = 'https://p9axztuwd7x8a7.mycht.cn/mail-server/service-mail'; export const API_HOST = 'https://p9axztuwd7x8a7.mycht.cn/whatsapp_server/v2'; export const WS_URL = 'wss://p9axztuwd7x8a7.mycht.cn/whatsapp_server'; // prod: diff --git a/wai-server/api/messages/message.controller.js b/wai-server/api/messages/message.controller.js index a1e0505..4a60c0a 100644 --- a/wai-server/api/messages/message.controller.js +++ b/wai-server/api/messages/message.controller.js @@ -7,14 +7,6 @@ function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms)); } -exports.sendText111 = async ctx => { - const { type } = ctx.params; - const body = ctx.request.body; - ctx.assert(null, 400, `debug: content: {${type}} {${body.content}}`); - ctx.assert(null, 400, 'The message info is malformed!'); - return body; -}; - exports.sendText = async ctx => { const { from, to, content } = ctx.request.body; if (!from || !content) { @@ -29,7 +21,7 @@ exports.sendText = async ctx => { } // return wsToSend; try { - await wsToSend.sendTextMessage(to, content); + wsToSend.sendTextMessage(to, content); return 'Message sent successfully'; // { wsToSend, ret: 'Message sent successfully' }; } catch (error) { console.error('Error sending message:', error); From 3f4576799ed68ea3359f0729738c72ed97514622 Mon Sep 17 00:00:00 2001 From: Lei OT Date: Wed, 25 Dec 2024 13:52:43 +0800 Subject: [PATCH 3/3] =?UTF-8?q?feat:=20/channels/=20=E6=89=80=E6=9C=89?= =?UTF-8?q?=E8=BF=9E=E6=8E=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wai-server/api/channels/channel.controller.js | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/wai-server/api/channels/channel.controller.js b/wai-server/api/channels/channel.controller.js index f28b472..e8d9f0b 100644 --- a/wai-server/api/channels/channel.controller.js +++ b/wai-server/api/channels/channel.controller.js @@ -34,6 +34,8 @@ exports.newConnect = async ctx => { }; exports.getAll = async () => { - const sessions = sessionService.sessions; - return Array.from(sessions); + const findConnection = await getConnection({}); + return findConnection; + // const sessions = sessionService.sessions; + // return Array.from(sessions); };