Messenger Hub

1 Архитектура: один бандл, не четыре

MessengerHub — единый домен "коммуникации менеджера", а не набор отдельных мессенджер-интеграций

2 Четыре канала: сравнение и интеграция

Нажмите на канал для деталей подключения

3 UI: Unified Inbox и Thread View

Интерфейс мобильного приложения менеджера

4 5 типов LLM-подсказок через qwen3:4b

Нажмите на тип для просмотра примера API-ответа

Request:  { "type": "quick_reply" }

Response: {
  "type": "quick_reply",
  "suggestions": [
    "Курс сейчас 92.5 за USDT, могу зафиксировать на 30 минут",
    "Минимальная сумма обмена 1000 USDT",
    "Могу предложить 92.3 при объёме от 10,000 USDT"
  ],
  "confidence": 0.85
}

Response: {
  "type": "summary",
  "text": "Клиент Ivan Petrov (VIP, Москва) хочет обменять
           5000 USDT на рубли. Предыдущие 3 сделки:
           суммы 2000-8000 USDT, средний курс 91.8.
           Клиент лоялен, но чувствителен к курсу."
}

Response: {
  "type": "risk_alert",
  "alerts": [{
    "level": "medium",
    "text": "Клиент упоминает третье лицо как получателя
             — возможный structuring (дробление операций)"
  }]
}

Response: {
  "type": "deal_suggest",
  "suggestion": {
    "instrument": "USDT-TRC20",
    "amount": 50000,
    "rate": 92.5,
    "reason": "Клиент регулярный (3 сделки/мес),
               объём растёт. Рекомендуемая скидка 0.3%"
  }
}

Response: {
  "type": "sentiment",
  "sentiment": "neutral_to_positive",
  "signals": ["вежливый тон", "конкретные суммы",
               "не торгуется агрессивно"],
  "recommendation": "Клиент настроен на сделку,
                     не затягивайте с ответом"
}

5 Путь входящего сообщения

От клиента в Telegram до подсказки на экране менеджера

6 Flutter: архитектура мобильного приложения

Flutter + Riverpod + SQLCipher. Offline-First: локальная БД = источник правды для UI

// Riverpod: стрим сообщений чата
@riverpod
Stream<List<Message>> chatMessages(Ref ref, String chatId) async* {
  // 1. Сначала из локальной БД — мгновенно
  yield await ref.read(localDbProvider).getMessages(chatId, limit: 50);
  // 2. Затем подписка на WebSocket дельты
  yield* ref.read(wsProvider).messageStream(chatId);
}

// Offline-First алгоритм отправки:
// 1. Сохранить в SQLCipher со статусом PENDING
// 2. UI показывает с индикатором "отправляется"
// 3. Отправить в очередь (dart:isolate)
// 4. Успех → статус SENT / Ошибка → статус ERROR + кнопка "повтор"

7 Интеграция с существующим кодом

Какие бандлы переиспользуем и что расширяем

8 Безопасность: что исправить до запуска

Найденные уязвимости в существующем коде, влияющие на Messenger Hub

9 Фазы реализации Messenger Hub

Параллельный поток разработки, не блокирует основную архитектуру

10 Полная структура бандла MessengerHub

Всё в одном месте: Entity, Adapter, Service, LLM, Api, Queue

src/Bundles/MessengerHub/
  MessengerHubComponent.php
  Routes.php
  adminMenu.php

  Entity/
    ConversationEntity.php         // Чат (channel + contact + status)
    MessageEntity.php              // Сообщение (encrypted content)
    ChannelAccountEntity.php       // Подключённый канал брокера
    MessageAttachmentEntity.php    // Медиа-файлы

  Enum/
    ChannelType.php                // Telegram | WhatsApp | Signal | Matrix
    MessageDirection.php           // Inbound | Outbound
    MessageStatus.php              // Sent | Delivered | Read | Failed
    ConversationStatus.php         // Active | Archived | Blocked

  Adapter/
    ChannelAdapterInterface.php    // connect, disconnect, sendMessage, handleWebhook
    ChannelAdapterManager.php      // Роутинг по ChannelType
    Telegram/TelegramChannelAdapter.php
    WhatsApp/WhatsAppChannelAdapter.php
    Signal/SignalChannelAdapter.php
    Matrix/MatrixChannelAdapter.php

  Service/
    ConversationService.php        // handleInbound, создание/архивация чатов
    MessageService.php             // отправка через адаптер
    EncryptedMessageStore.php      // AES-256-GCM at rest
    WebSocketBroadcastService.php  // push к менеджеру
    PushNotificationService.php    // FCM / APNs

  LLM/
    LLMPipelineService.php         // Оркестратор 5 типов подсказок
    ContextBuilder.php             // Сборка контекста: messages + CRM data
    PromptTemplates.php            // System prompts для каждого типа

  Api/
    ConversationsEndpoint.php      // GET /api/v2/messenger/conversations
    MessagesEndpoint.php           // GET/POST /api/v2/messenger/messages
    AssistEndpoint.php             // POST /api/v2/messenger/.../assist
    ChannelsEndpoint.php           // CRUD каналов
    SyncEndpoint.php               // Delta sync для мобильного

  Queue/Handler/
    InboundMessageHandler.php      // Обработка входящих
    OutboundMessageHandler.php     // Очередь исходящих
    LLMAnalysisHandler.php         // Async LLM inference

  DTO/
    UnifiedMessage.php             // Универсальный формат
    SendMessageRequest.php
    ConversationListItem.php
    LLMAssistResponse.php

  WebSocket/
    MessengerHubWsHandler.php      // RoadRunner WS plugin