Message Flow

WA gateway :5002
    │ POST /v1/callback_message
    ▼
CallbackMessage (chat_callback.go:89)
    │
    ├─ 1. Parse body → Payload
    ├─ 2. Resolve device via InstanceID (GetDevice)
    ├─ 3. Branch: Result==true && Report==false (inbound, bukan status)
    │     └─ Extract pesan, split number@server
    │        ├─ s.whatsapp.net → private chat
    │        └─ g.us          → group chat
    ├─ 4. Categorize (private/group) + auto-create group doc
    ├─ 5. Auto-create customer (GetCustomer → CreateCustomer)
    ├─ 6. First-chat / new-chat detection
    │     └─ isonnew = true jika chatList nil/new/close/pending
    ├─ 7. CS rotator dispatch (chat_callback.go:305)
    │     └─ h.svc.GetRotator(ctx, device.StoreId, instance) → returnid_cs
    ├─ 8. Update chat_history dengan CS terpilih
    ├─ 9. Build & save ChatList (create atau update)
    ├─ 10. Save inbound ke chat_inbox (chat_callback.go:529)
    │      └─ CreateChatInbox(newChatInbox)
    └─ 11. Bot dispatch (goroutine, chat_callback.go:549-561)
          └─ if HandleByBot && !is_start && !fromMe:
               go submitBot(newChatInbox) → createOutboxBot

Handler (mis. SubmitMessage)
    │
    ├─ saveMessageMongo (chat_submit.go:425)
    │   ├─ Loop per phone number:
    │   │   ├─ CreateChatInbox (chat_submit.go:815) — simpan ke chat_inbox dulu
    │   │   └─ CreateChatOutbox (chat_submit.go:856) — simpan ke chat_outbox
    │   └─ Return resultChatData, chatInboxList
    │
    ▼
chat_outbox collection (MongoDB)
    │
    ▼
Node engine (terpisah, PM2)
    ├─ cron_message/dispatcher.js  — watch change stream (beta devices)
    │   └─ Enqueue ke Redis BullMQ queue (per-device)
    └─ cron_mdv2.js                — poll chat_outbox (legacy devices)
    │
    ▼
worker_message.js (BullMQ consumer)
    ├─ get_result_data.js — enrich payload
    └─ POST :5002 (WA gateway)
    │
    ▼
On success:
    ├─ chat_inbox.status_ack = "sent"
    └─ delete chat_outbox row