mirror of
https://ghfast.top/https://github.com/discourse/discourse-ai.git
synced 2026-07-16 11:36:23 +08:00
cf220c530c
* 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 |
||
|---|---|---|
| .. | ||
| digest_rag_upload_spec.rb | ||
| fast_track_topic_gist_spec.rb | ||
| generate_rag_embeddings_spec.rb | ||
| manage_embedding_def_search_index_spec.rb | ||
| stream_composer_helper_spec.rb | ||
| stream_discord_reply_spec.rb | ||
| stream_discover_reply_spec.rb | ||
| stream_post_helper_spec.rb | ||
| stream_topic_ai_summary_spec.rb | ||
