fix: corrige estrutura de if/else e bloco try/catch em chatwoot-import-helper.ts

[oriondesign2015]

Esta PR corrige problemas de sintaxe no arquivo chatwoot-import-helper.ts, especificamente:

• Ajusta a estrutura do bloco if/else no método getExistingSourceIds, evitando erro de compilação do TypeScript.
• Garante que o bloco catch esteja corretamente posicionado dentro do método, retornando null em caso de erro.
• Mantém a lógica original do método, apenas corrigindo a sintaxe para permitir a compilação e execução correta do projeto.
  Essas correções eliminam o erro de build relacionado ao TypeScript e melhoram a robustez do código ao tratar exceções de forma adequada.

Summary by Sourcery

Refactor and extend core chatbot and event infrastructure, add new integrations, enhance media processing and message handling, and resolve critical build and runtime bugs

New Features:

• Introduce NATS support in the event system alongside RabbitMQ, SQS, WebSocket and Pusher
• Add EvoAI and N8n chatbot integrations and expose catalog/collection endpoints
• Extend Webhook controller with configurable timeouts, exponential‐backoff retries, and JWT authentication
• Support message location, sticker and enhanced media types in BusinessStartupService

Bug Fixes:

• Fix chatwoot-import-helper logic to correctly query existing source IDs by conversation
• Prevent duplicate audio messages and improper conversation reopen in Chatwoot
• Retain animation in GIF/WebP stickers and enforce libopus 48 kHz mono audio conversion
• Eliminate deadlock and duplicate delivery in Baileys message processing and caching
• Correct SEND_MESSAGE_UPDATE event handling across RabbitMQ, Pusher and Webhook schemas

Enhancements:

• Refactor OpenAI, Typebot, Flowise, EvolutionBot and Dify to share BaseChatbotService and BaseChatbotController logic
• Unify message sending, session lifecycle and speech-to-text flows across chatbot services
• Add S3_SKIP_POLICY environment variable to opt out of automatic bucket policy
• Improve Websocket authentication to validate API keys and support Engine.IO clients

Documentation:

• Update CHANGELOG to document new features, fixes and security improvements

[sourcery-ai]

Reviewer's Guide

This PR refactors getExistingSourceIds in chatwoot-import-helper.ts by updating its signature to accept an optional conversationId, conditionally adding a WHERE filter when conversationId is provided, and replacing the process exit in the catch block with a safe return of an empty set.

Sequence Diagram for OpenAI Audio Transcription

sequenceDiagram
    actor User
    participant OS as OpenaiService
    participant OAI as OpenAI API

    User->>OS: process(audio message, ...)
    OS->>OS: speechToText(msgOrBuffer, ...)
    OS->>OS: getAudioBufferFromMsg(msg, ...)
    activate OS
    OS-->>OS: audioBuffer
    deactivate OS
    OS->>OS: processAudioTranscription(audioBuffer)
    activate OS
    OS->>OAI: Transcribe audio (POST /v1/audio/transcriptions)
    OAI-->>OS: transcription text
    OS-->>OS: transcription
    deactivate OS
    OS-->>OS: transcription
    OS-->>User: (Sends message with transcribed text or uses it in bot logic)

Loading

Sequence Diagram for Typebot Audio Message Handling

sequenceDiagram
    actor User
    participant TC as TypebotController
    participant TS as TypebotService
    participant BCS as BaseChatbotService
    participant OS as OpenaiService
    participant TAPI as Typebot API
    participant WA as WhatsApp API

    User->>TC: emit(audio message, ...)
    TC->>TS: processTypebot(...)
    TS->>BCS: process(bot, audio content, ...)
    BCS->>TS: sendMessageToBot(audio content, ...)
    activate TS
    TS->>TS: isAudioMessage(content)
    alt Audio Message
        TS->>OS: speechToText(msg)
        OS-->>TS: transcription
        TS->>TAPI: continueChat/sendMessage (with transcription)
    else Not Audio Message
        TS->>TAPI: continueChat/sendMessage (original content)
    end
    TAPI-->>TS: Bot Response (messages, input, actions)
    deactivate TS
    TS->>TS: sendWAMessage(..., response.messages, ...)
    activate TS
    TS->>WA: Send Formatted Messages (text, media, buttons, list)
    deactivate TS
    WA-->>User: Bot Messages

Loading

Entity Relationship Diagram for EventDto NATS Integration

erDiagram
    EventDto {
        object webhook
        object sqs
        object rabbitmq
        object nats
        object pusher
        object websocket
    }
    EventDto ||--o{ nats : contains
    nats {
        boolean enabled "Optional"
        string events "Optional, Array of strings"
    }

Loading

Class Diagram for TypebotService Refactoring

classDiagram
    class BaseChatbotService {
        +process(...)
    }
    class OpenaiService {
        +speechToText(...)
    }
    class TypebotService {
        +TypebotService(waMonitor, configService, prismaRepository, openaiService: OpenaiService)
        +sendWAMessage(instance, session, settings, remoteJid, messages, input, clientSideActions)
        +processTypebot(instance, remoteJid, msg, session, bot, ...)
        #getBotType(): string
        #sendMessageToBot(instance, session, settings, bot, remoteJid, pushName, content, msg?)
        -openaiService: OpenaiService
        -initTypebotSession(instance, session, bot, remoteJid, pushName, prefilledVariables?)
        -processTypebotMessages(instance, session, settings, remoteJid, messages, input, clientSideActions)
        -parseListFormat(text: string)
        -parseButtonFormat(text: string)
    }
    BaseChatbotService <|-- TypebotService
    TypebotService o-- OpenaiService : uses for audio transcription

Loading

Class Diagram for WebhookController Enhancements

classDiagram
    class EventController
    class WebhookController {
        +set(instanceName, data)
        +sendData(instanceName, event, webhookData)
        #retryWebhookRequest(httpService, webhookData, origin, baseURL, serverUrl, maxRetries?, delaySeconds?)
        -generateJwtToken(authToken: string): string
    }
    EventController <|-- WebhookController

Loading

File-Level Changes

Change	Details	Files
Extended getExistingSourceIds signature with optional conversationId	Add conversationId parameter Update return type to include optional param	src/api/integrations/chatbot/chatwoot/utils/chatwoot-import-helper.ts
Conditional SQL query based on conversationId	Introduce query variable assignment Branch query to include conversation_id filter when provided Fallback to original query otherwise	src/api/integrations/chatbot/chatwoot/utils/chatwoot-import-helper.ts
Adjust database call parameters	Pass formattedSourceIds and conversationId to pgClient.query Wrap parameters in array matching query signature	src/api/integrations/chatbot/chatwoot/utils/chatwoot-import-helper.ts
Improve error handling in catch block	Replace process.exit with returning new Set() Log error without terminating process	src/api/integrations/chatbot/chatwoot/utils/chatwoot-import-helper.ts

Possibly linked issues

• Adicionar dentro do manager informações da versão da baileys #645: PR fixes media message import issue in Chatwoot by modifying sourceId check in chatwoot-import-helper.ts to filter by conversationId.

---

Tips and commands

Interacting with Sourcery

• Trigger a new review: Comment @sourcery-ai review on the pull request.
• Continue discussions: Reply directly to Sourcery's review comments.
• Generate a GitHub issue from a review comment: Ask Sourcery to create an
  issue from a review comment by replying to it. You can also reply to a
  review comment with @sourcery-ai issue to create an issue from it.
• Generate a pull request title: Write @sourcery-ai anywhere in the pull
  request title to generate a title at any time. You can also comment
  @sourcery-ai title on the pull request to (re-)generate the title at any time.
• Generate a pull request summary: Write @sourcery-ai summary anywhere in
  the pull request body to generate a PR summary at any time exactly where you
  want it. You can also comment @sourcery-ai summary on the pull request to
  (re-)generate the summary at any time.
• Generate reviewer's guide: Comment @sourcery-ai guide on the pull
  request to (re-)generate the reviewer's guide at any time.
• Resolve all Sourcery comments: Comment @sourcery-ai resolve on the
  pull request to resolve all Sourcery comments. Useful if you've already
  addressed all the comments and don't want to see them anymore.
• Dismiss all Sourcery reviews: Comment @sourcery-ai dismiss on the pull
  request to dismiss all existing Sourcery reviews. Especially useful if you
  want to start fresh with a new review - don't forget to comment
  @sourcery-ai review to trigger a new review!

Customizing Your Experience

Access your dashboard to:

• Enable or disable review features such as the Sourcery-generated pull request
  summary, the reviewer's guide, and others.
• Change the review language.
• Add, remove or edit custom review instructions.
• Adjust other review settings.

Getting Help

• Contact our support team for questions or feedback.
• Visit our documentation for detailed guides and information.
• Keep in touch with the Sourcery team by following us on X/Twitter, LinkedIn or GitHub.