summaryrefslogtreecommitdiff
path: root/Omni/Agent/Telegram/Media.hs
diff options
context:
space:
mode:
authorBen Sima <ben@bensima.com>2025-12-13 14:02:35 -0500
committerBen Sima <ben@bensima.com>2025-12-13 14:02:35 -0500
commit54fba81956d1834a1e17fcfde47614d9ef617ad8 (patch)
treef821b4102ae54fd1af41441f458c9fe950152052 /Omni/Agent/Telegram/Media.hs
parenta14881ddcdd6ce83250c978d9df825c29e8d93c6 (diff)
Add incoming message queue for Telegram bot
Batches incoming messages by chat_id with a 3-second sliding window before processing. This prevents confusion when messages arrive simultaneously from different chats. - New IncomingQueue module with STM-based in-memory queue - Messages enqueued immediately, offset acked on enqueue - 200ms tick loop flushes batches past deadline - Batch formatting: numbered messages, sender attribution for groups, media stubs, reply context - Media from first message in batch still gets full processing
Diffstat (limited to 'Omni/Agent/Telegram/Media.hs')
0 files changed, 0 insertions, 0 deletions