mirror of
https://ghfast.top/https://github.com/discourse/discourse-ai.git
synced 2026-07-15 11:27:11 +08:00
* FIX: Improve MessageBus efficiency and correctly stop streaming This commit enhances the message bus implementation for AI helper streaming by: - Adding client_id targeting for message bus publications to ensure only the requesting client receives streaming updates - Limiting MessageBus backlog size (2) and age (60 seconds) to prevent Redis bloat - Replacing clearTimeout with Ember's cancel method for proper runloop management, we were leaking a stop - Adding tests for client-specific message delivery These changes improve memory usage and make streaming more reliable by ensuring messages are properly directed to the requesting client. * composer suggestion needed a fix as well. * backlog size of 2 is risky here cause same channel name is reused between clients |
||
|---|---|---|
| .. | ||
| ai_spam_scan.rb | ||
| create_ai_chat_reply.rb | ||
| create_ai_reply.rb | ||
| digest_rag_upload.rb | ||
| fast_track_topic_gist.rb | ||
| generate_chat_thread_title.rb | ||
| generate_embeddings.rb | ||
| generate_rag_embeddings.rb | ||
| manage_embedding_def_search_index.rb | ||
| post_sentiment_analysis.rb | ||
| shared_conversation_adjust_upload_security.rb | ||
| stream_composer_helper.rb | ||
| stream_discord_reply.rb | ||
| stream_discover_reply.rb | ||
| stream_post_helper.rb | ||
| stream_topic_ai_summary.rb | ||