服务启动, 登出所有账号连接

wai-server/core/services/whatsappHandler.js

@@ -2,7 +2,7 @@ const generateId = require('../../utils/generateId.util');
 const { domain } = require('../../config').server;
 const whatsappEvents = require('../emitter');
 const { callWebhook } = require('../webhook');
-const { addConnection, updateConnection, addCurrentConnection } = require('../../services/connections.service');
+const { addConnection, updateConnection, addCurrentConnection, resetConnection } = require('../../services/connections.service');
 const { objectMapper } = require('../../utils/commons.util');
 const { sessionService } = require('..');
 
@@ -100,4 +100,11 @@ function setupWhatsappHandler() {
   setupMessageHandler();
 }
 
-module.exports = { setupWhatsappHandler };
+/**
+ * 登出: 当前服务的所有连接
+ */
+async function resetCurrentConnection() {
+  await resetConnection();
+}
+
+module.exports = { setupWhatsappHandler, resetCurrentConnection };

wai-server/index.js

@@ -5,7 +5,7 @@ const server = require('./server');
 
 const { port } = require('./config').server;
 
-const { setupWhatsappHandler } = require('./core/services/whatsappHandler');
+const { setupWhatsappHandler, resetCurrentConnection } = require('./core/services/whatsappHandler');
 
 async function bootstrap() {
   /**
@@ -15,6 +15,7 @@ async function bootstrap() {
    */
 
   setupWhatsappHandler();
+  await resetCurrentConnection();
 
   return http.createServer(server.callback()).listen(port, '0.0.0.0');
 }