Real-время мониторинг торгового бота: WebSocket, PnL, уведомления

Вступление

Представьте: бот открыл позицию, рынок резко разворачивается, а вы узнаёте об этом через 5 секунд — когда цена уже ушла на отметку стоп-лосса. Задержка в мобильном мониторинге напрямую конвертируется в потери. Мы разрабатываем мобильные приложения, которые подключаются к вашему торговому боту по WebSocket — задержка менее 200 мс, то есть в 25 раз быстрее, чем REST-полинг каждые 5 секунд. Наш опыт показывает, что правильно реализованный транспорт с exponential backoff и синхронизацией состояния гарантирует актуальность данных даже при нестабильной сети. Команда сертифицированных iOS, Android и Flutter-разработчиков реализует проект под ключ за 5–7 рабочих дней. Более 5 лет мы создаём high-performance решения для финансового сектора, и этот кейс — один из типовых.

Как работает WebSocket-транспорт?

REST-полинг каждые 5 секунд создаёт задержку до 5 секунд и бесполезную нагрузку. WebSocket — постоянное соединение, данные приходят по событию. Бэкенд бота рассылает события: position_opened, position_closed, order_filled, pnl_updated. В официальной документации Apple URLSessionWebSocketTask поддерживается с iOS 13.

Сравним подходы:

На iOS реализация через URLSessionWebSocketTask:

actor BotMonitorConnection {
    private var webSocketTask: URLSessionWebSocketTask?
    private let session = URLSession.shared
    var onEvent: ((BotEvent) -> Void)?

    func connect(botId: String, token: String) {
        let url = URL(string: "wss://api.example.com/bots/\(botId)/stream?token=\(token)")!
        webSocketTask = session.webSocketTask(with: url)
        webSocketTask?.resume()
        startListening()
    }

    private func startListening() {
        webSocketTask?.receive { [weak self] result in
            switch result {
            case .success(let message):
                if case .string(let text) = message,
                   let data = text.data(using: .utf8),
                   let event = try? JSONDecoder().decode(BotEvent.self, from: data) {
                    self?.onEvent?(event)
                }
                self?.startListening()
            case .failure(let error):
                self?.scheduleReconnect()
            }
        }
    }

    private func scheduleReconnect() {
        Task {
            try? await Task.sleep(nanoseconds: 3_000_000_000)
            connect(botId: botId, token: token)
        }
    }
}

Почему exponential backoff критичен для мобильного трейдинга?

Мобильная сеть нестабильна: метро, лифт, переключение вышек. Если просто пытаться переподключаться каждую секунду, вы рискуете разрядить батарею и заблокировать сокет. Exponential backoff — это когда интервал переподключения растёт: 1с, 2с, 4с, 8с... до 30с. После успешного подключения интервал сбрасывается. Дополнительно, после восстановления соединения клиент запрашивает текущее состояние через REST (GET /bots/{id}/state), чтобы восполнить пропущенные события.

На Flutter с Riverpod удобно вынести соединение в StreamProvider:

@riverpod
Stream<BotEvent> botEventStream(BotEventStreamRef ref, String botId) {
  final channel = WebSocketChannel.connect(
    Uri.parse('wss://api.example.com/bots/$botId/stream'),
  );
  ref.onDispose(channel.sink.close);
  return channel.stream
      .map((data) => BotEvent.fromJson(jsonDecode(data as String)))
      .handleError((e) => ref.invalidateSelf());
}

Что делать при обрыве соединения?

Пользователь должен видеть индикатор состояния: зелёная точка (live), серая (reconnecting), красная (offline). Это ключевой элемент доверия. Мы реализуем пошаговый алгоритм:

1. При разрыве: ожидание 1 секунду, затем попытка подключения.
2. При неудаче: удвоение таймаута до максимума 30 секунд.
3. При успешном подключении: запрос текущего состояния через REST.
4. Обновление UI с индикатором.

Какие данные отображаются на экране?

Приложение разделено на три основные зоны:

Открытые позиции. Пара, сторона (Long/Short), размер, цена входа, текущая цена, unrealized PnL в % и USD. PnL обновляется по каждому pnl_updated событию — мы не перерисовываем весь список, только изменившуюся строку. На Android — DiffUtil в RecyclerView, на Flutter — ListView.builder с ключами.

Лента событий. Последние N событий: «Открыта позиция BTC/USDT long 0.01 BTC @ 67,430», «Ордер исполнен», «Стоп-лосс сработал». Все с временными метками.

Метрики сессии. Количество сделок, суммарный реализованный PnL, win rate. Обновляется при каждом position_closed.

Типы событий подробно:

Push-уведомления для критичных событий

WebSocket — основной канал для активного экрана. Но когда приложение свёрнуто, события доставляются через FCM/APNs: стоп-лосс сработал, ошибка бота, значительное изменение PnL. Push-уведомления не заменяют real-time, а дополняют его. Мы настраиваем фильтрацию, чтобы не спамить: только события, помеченные бэкендом как critical.

Trust и опыт

Наши инженеры имеют сертификаты Apple (iOS) и Google (Android). За 5+ лет мы реализовали более 20 проектов для финансовой сферы, включая торговые терминалы, мониторинг портфелей и ботов. Каждое приложение проходит код-ревью, нагрузочное тестирование и проверку на безопасность.

Что входит в работу

• WebSocket-клиент с exponential backoff переподключением
• Индикатор состояния соединения (live/reconnecting/offline)
• Список открытых позиций с live PnL (эффективное обновление)
• Лента событий с автоскроллом
• REST-синхронизация состояния при переподключении
• Push через FCM/APNs для фоновых алертов
• Документация и инструкция по интеграции

Сроки и стоимость

Срок разработки — 5–7 рабочих дней. Если бэкенд уже рассылает WebSocket-события, хватит 4–5 дней на мобильную часть. Стоимость рассчитывается индивидуально после анализа требований и архитектуры.

Свяжитесь с нами, чтобы обсудить ваш проект. Наши специалисты бесплатно оценят логику бота, предложат оптимальную архитектуру и дадут точную смету. Получите консультацию уже сегодня.

Аналитика мобильных приложений: Firebase, Amplitude, AppsFlyer и атрибуция

Наша команда регулярно сталкивается с проектами, где аналитика уже «настроена», но реальных инсайтов нет. Типичный пример — стартап с 50k DAU: трекинг десятков событий без единого ответа на вопрос «почему пользователи не доходят до оплаты». За две недели мы построили базовую воронку и выяснили, что 70% аудитории отваливается на экране верификации номера телефона. После локализации бага retention вырос на 12%. Вывод: аналитика должна начинаться с конкретных вопросов, а не с трекинга всего подряд.

Почему таксономия событий — основа аналитики мобильных приложений?

Firebase Analytics, Amplitude, Mixpanel — технически похожи. Разница в том, что вы в них кладёте. Типичная ошибка: события screen_view, button_tap_1, button_tap_2 без контекста. Через месяц никто не помнит, что такое button_tap_2.

Правильная таксономия: объект + действие + контекст. product_viewed, checkout_started, payment_completed с параметрами product_id, category, price, source. Это позволяет строить воронки, когортный анализ и retention без дополнительного трекинга.

Мы фиксируем naming convention в tracking plan — документе (Google Sheet или Amplitude Data Catalog), где описано каждое событие, его параметры и условия срабатывания. Tracking plan синхронизируется с командой аналитиков до начала разработки, а не после. Такой подход гарантирует, что через месяц данные останутся интерпретируемыми, а не превратятся в свалку. Опыт внедрения на 50+ проектах подтверждает: при отсутствии tracking plan стоимость поддержки аналитики вырастает в 2-3 раза за счёт переделок.

Что выбрать для аналитики мобильных приложений: Firebase, Amplitude или Mixpanel?

Таблица ниже показывает ключевые различия трёх популярных платформ. Выбор зависит от бюджета, трафика и задач.

Firebase Analytics — бесплатно, глубокая интеграция с Google Ads, BigQuery-экспорт для сырых данных. Ограничения: задержка данных до 24 часов, ограниченные воронки. Для стартапов с Google Ads трафиком — первый выбор.

Amplitude — продуктовая аналитика с акцентом на когорты и пути пользователя. Journeys (бывший Pathfinder) показывает реальные пути между событиями — не предполагаемые воронки, а фактические маршруты. Session Replay — запись сессий для UX-анализа. Бесплатный тир до 10 млн events/месяц достаточен для большинства продуктов на старте.

Mixpanel — ближе к Amplitude, сильнее в сегментации в реальном времени. Insights, Funnels, Retention — базовые инструменты, которые закрывают 90% аналитических задач продакта.

Более формальные определения этих платформ можно найти в Wikipedia и Wikipedia.

Как решить проблему мультиканальной атрибуции с AppsFlyer?

Знать откуда пришёл пользователь — отдельная задача. Firebase Attribution работает только внутри Google-экосистемы. Для мультиканальной атрибуции (Facebook Ads, TikTok, Apple Search Ads, programmatic) нужен MMP — Mobile Measurement Partner.

AppsFlyer — лидер рынка. OneLink — universal deep link, который работает на iOS и Android и корректно атрибутирует установку из любого канала. Protect360 — встроенная защита от fraud (фейковые установки, click injection на Android). Adjust и Branch — конкуренты с похожим функционалом. Branch силён в deep linking; Adjust популярен в gaming.

Согласно Apple, с iOS 14.5 приложения должны получать разрешение пользователя через ATT перед сбором IDFA для отслеживания. AppsFlyer использует probabilistic matching (IP + user agent + timing) для этих пользователей — точность ниже, но лучше чем ничего. SKAdNetwork и Privacy Preserving Attribution дают агрегированные данные от Apple с задержкой 24-72 часа.

Как настроить crash-аналитику, чтобы не пропускать баги?

Firebase Crashlytics — стандарт для crash reporting. Автоматически группирует крэши по стектрейсу, показывает affected users %, velocity alerts при росте crash rate более чем на 10% за час.

Важно: символикация. На iOS .dSYM файлы должны автоматически загружаться при каждой сборке — через Fastlane upload_symbols_to_crashlytics или Xcode Cloud built-in. Без символов крэш в Crashlytics выглядит как набор адресов памяти. Это происходит чаще чем кажется при переходе на новый CI — в одном проекте с аудиторией 500k пользователей мы обнаружили, что 40% крэшей оставались несимволизированными из-за пропущенного этапа в CI/CD. После автоматизации время реакции на баги сократилось с 3 часов до 15 минут.

Для React Native и Flutter — @sentry/react-native и sentry_flutter дают дополнительный контекст: breadcrumbs, сетевые запросы перед крэшем, состояние Redux/Provider.

Ниже — сравнение популярных инструментов crash-аналитики для выбора под свои задачи.

Настройка окружения

Три окружения с отдельными Firebase проектами: dev, staging, production. Смешивать аналитику из тестовых сессий и production — распространённая ошибка, которая искажает все метрики. На iOS через GoogleService-Info.plist для каждой схемы, на Android через google-services.json в папке каждого flavor.

Сроки: базовая аналитика с Firebase + Crashlytics — 3-5 дней. Полноценный tracking plan + Amplitude/Mixpanel с воронками и когортами — 2-3 недели. Атрибуция через AppsFlyer с deep linking и fraud protection — 1-2 недели. Стоимость рассчитывается индивидуально в зависимости от сложности интеграций.

Что входит в нашу работу

В рамках внедрения аналитики мы предоставляем:

• Разработку и согласование tracking plan с командами продукта и маркетинга.
• Интеграцию SDK (Firebase, Amplitude, Mixpanel, AppsFlyer) с учётом вашего стека (Swift/Kotlin/Flutter/React Native).
• Настройку воронок, когорт, дашбордов и алертов.
• Автоматизацию символикации и загрузки .dSYM через Fastlane.
• Документацию по событиям и параметрам.
• Обучение команды работе с аналитической платформой.
• Две недели пост-релизной поддержки и корректировки трекинга.

Наш опыт — 7 лет внедрения аналитики и более 80 успешных проектов в сфере мобильной разработки. Мы гарантируем корректность данных и прозрачность каждого этапа.

Свяжитесь с нами, чтобы получить консультацию по настройке аналитики вашего приложения. Закажите аудит текущей аналитики — и мы покажем, какие метрики вы теряете.