Оновлення буфера онлайн-сесій
src/golden/workers/bull/queue/update-temp-online.worker.ts
Кожні 10 хвилин (cron */10 * * * *). Ephemeral: без ретраю.
Що відбувається
Послідовно виконує:
- Чистить вчорашні рядки з
golden_online_time_temp— там тримається тільки поточний день - Бере історію chat-sender invites (
golden_history_sending_messages) за необчислений період — інкрементально через in-memory cursor останнього перерахунку - Онлайн TU по сендеру — для кожної TU цього оператора рахує скільки часу TU була “активна” за sender-сигналами + лічильники
amountContact/amountAgencyза типом invite. Це основний результат воркера. - Онлайн оператора (агрегат) — той самий розрахунок але по всіх invites оператора. 🗑️ Можна прибрати — це не реальний heartbeat і не login/logout, а онлайн виведений зі sender-активності; не консумиться у нормальному UI.
TODO: перевірити чи десь зчитується і прибрати. - Записує усе в
golden_online_time_tempчерез upsert (один документ наoperator+date)
Архівація завершених тасків раніше була фазою цього воркера — тепер це окремий archive-tasks.
Моніторинг
Лише logger.error() через Winston. ТГ-моніторинг не ввімкнений.