fix(chatwoot): corrige reabertura de conversas e loop de conexão

Este commit aborda duas questões críticas na integração com o Chatwoot para melhorar a estabilidade e a experiência do agente.

Primeiro, as conversas que já estavam marcadas como "resolvidas" no Chatwoot não eram reabertas automaticamente quando o cliente enviava uma nova mensagem. Isso foi corrigido para que o sistema verifique o status da conversa e a reabra, garantindo que nenhuma nova interação seja perdida.

Segundo, um bug no tratamento do evento de conexão fazia com que a mensagem de status "Conexão estabelecida com sucesso" fosse enviada repetidamente, poluindo o histórico da conversa. A lógica foi ajustada para garantir que esta notificação seja enviada apenas uma vez por evento de conexão.

Author: Vitordotpy

src/api/integrations/chatbot/chatwoot/services/chatwoot.service.ts

@@ -747,34 +747,49 @@ export class ChatwootService {
           return null;
         }
 
-        let inboxConversation = contactConversations.payload.find(
-          (conversation) => conversation.inbox_id == filterInbox.id,
-        );
-        if (inboxConversation) {
-          if (this.provider.reopenConversation) {
-            this.logger.verbose(`Found conversation in reopenConversation mode: ${JSON.stringify(inboxConversation)}`);
-            if (inboxConversation && this.provider.conversationPending && inboxConversation.status !== 'open') {
-              await client.conversations.toggleStatus({
-                accountId: this.provider.accountId,
-                conversationId: inboxConversation.id,
-                data: {
-                  status: 'pending',
-                },
-              });
-            }
+        let inboxConversation = null;
+
+        if (this.provider.reopenConversation) {
+          inboxConversation = contactConversations.payload.find(
+            (conversation) =>
+              conversation && conversation.status !== 'resolved' && conversation.inbox_id == filterInbox.id,
+          );
+
+          if (inboxConversation) {
+            this.logger.verbose(
+              `Found open conversation in reopenConversation mode: ${JSON.stringify(inboxConversation)}`,
+            );
           } else {
             inboxConversation = contactConversations.payload.find(
-              (conversation) =>
-                conversation && conversation.status !== 'resolved' && conversation.inbox_id == filterInbox.id,
+              (conversation) => conversation.inbox_id == filterInbox.id,
             );
-            this.logger.verbose(`Found conversation: ${JSON.stringify(inboxConversation)}`);
-          }
 
-          if (inboxConversation) {
-            this.logger.verbose(`Returning existing conversation ID: ${inboxConversation.id}`);
-            this.cache.set(cacheKey, inboxConversation.id);
-            return inboxConversation.id;
+            if (inboxConversation) {
+              this.logger.verbose(`Found resolved conversation to reopen: ${JSON.stringify(inboxConversation)}`);
+              if (this.provider.conversationPending && inboxConversation.status !== 'open') {
+                await client.conversations.toggleStatus({
+                  accountId: this.provider.accountId,
+                  conversationId: inboxConversation.id,
+                  data: {
+                    status: 'pending',
+                  },
+                });
+                this.logger.verbose(`Reopened resolved conversation ID: ${inboxConversation.id}`);
+              }
+            }
           }
+        } else {
+          inboxConversation = contactConversations.payload.find(
+            (conversation) =>
+              conversation && conversation.status !== 'resolved' && conversation.inbox_id == filterInbox.id,
+          );
+          this.logger.verbose(`Found conversation: ${JSON.stringify(inboxConversation)}`);
+        }
+
+        if (inboxConversation) {
+          this.logger.verbose(`Returning existing conversation ID: ${inboxConversation.id}`);
+          this.cache.set(cacheKey, inboxConversation.id);
+          return inboxConversation.id;
         }
 
         const data = {
@@ -2407,12 +2422,25 @@ export class ChatwootService {
 
       if (event === 'connection.update') {
         if (body.status === 'open') {
+          const waInstance = this.waMonitor.waInstances[instance.instanceName];
           // if we have qrcode count then we understand that a new connection was established
-          if (this.waMonitor.waInstances[instance.instanceName].qrCode.count > 0) {
+          if (waInstance && waInstance.qrCode.count > 0) {
             const msgConnection = i18next.t('cw.inbox.connected');
             await this.createBotMessage(instance, msgConnection, 'incoming');
-            this.waMonitor.waInstances[instance.instanceName].qrCode.count = 0;
+            waInstance.qrCode.count = 0;
+
+            waInstance.lastConnectionNotification = Date.now();
+
             chatwootImport.clearAll(instance);
+          } else if (waInstance) {
+            const timeSinceLastNotification = Date.now() - (waInstance.lastConnectionNotification || 0);
+            const minIntervalMs = 30000; // 30 seconds
+
+            if (timeSinceLastNotification < minIntervalMs) {
+              this.logger.warn(
+                `Connection notification skipped for ${instance.instanceName} - too frequent (${timeSinceLastNotification}ms since last)`,
+              );
+            }
           }
         }
       }