…draft+edit), already_sent

Implements Layer 2 of the unified streaming architecture described in NousResearch#922,
which explicitly lists the async gateway stream consumer as awaiting implementation.

GatewayStreamConsumer bridges the sync stream_delta_callback from the agent
thread to the async Telegram transport methods using an asyncio.Queue.

Key design decisions:
- Thread bridge via queue.Queue + finish() sentinel — matches the existing
  tool_progress_callback pattern in gateway/run.py, no new threading primitives
- Draft transport (sendMessageDraft, Bot API 9.5+) for private DMs only;
  groups/channels return Textdraft_peer_invalid by design — short-circuited
  at the consumer level before any API call
- Edit transport: send_raw() for first message, edit_message_raw() on interval
- Auto mode: draft-first with seamless mid-stream fallback to edit
- already_sent flag: set on first confirmed delivery; callers skip send()
- Short/instant responses (< buffer_threshold): still delivered via the
  same transport negotiation path, never silently dropped
- Finalization: sendMessageDraft previews are ephemeral — finalize_draft()
  commits a permanent sendMessage() so the response is never lost
- run_with_timeout(): 300 s safety timeout wraps run()

…nt wiring

StreamingConfig (gateway/config.py):
- Typed dataclass with live-benchmarked defaults (edit_interval=0.15s,
  buffer_threshold=20 chars) — 42% smoother than placeholder values in NousResearch#922
- Loaded once at startup from config.yaml streaming: block via from_dict()
- _hermes_home module-level variable makes config paths monkeypatchable in tests
- to_dict() / from_dict() for clean serialization roundtrip

_run_agent wiring (gateway/run.py):
- Reads self.config.streaming — no duplicate config.yaml file reads per message
- Checks adapter.supports_streaming before creating consumer — other platforms
  fall through unchanged
- Consumer task started alongside progress_task; awaited before reading already_sent
- already_sent propagated into handler_result dict so base adapter skips re-send
- Quick-commands lookup fixed: self.config.get() -> getattr() (config is dataclass)
- Stream consumer cleaned up in finally block alongside existing task cleanup

… providers

Stage 1 of streaming support. Adds:

- stream_delta_callback parameter on AIAgent.__init__ for real-time token delivery
- _interruptible_streaming_api_call() handling chat_completions + anthropic_messages
- Enhanced _run_codex_stream() to fire delta callbacks during Codex streaming
- _fire_stream_delta() fires both display and TTS callbacks
- _fire_reasoning_delta() for reasoning content streaming
- Tool-call suppression: callbacks only fire on text-only responses
- on_first_delta callback for spinner control on first token
- Provider fallback: graceful degradation to non-streaming
- _has_stream_consumers() unifies stream_delta_callback and _stream_callback checks
- Anthropic streaming returns native Message for downstream compatibility

Drawing from PRs #922 (unified streaming), #1312 (gateway consumer),
#774 (Telegram streaming), #798 (CLI streaming), #1214 (reasoning modes).
Credit: jobless0x, OutThisLife, clicksingh, raulvidis.

… providers

Stage 1 of streaming support. Adds:

- stream_delta_callback parameter on AIAgent.__init__ for real-time token delivery
- _interruptible_streaming_api_call() handling chat_completions + anthropic_messages
- Enhanced _run_codex_stream() to fire delta callbacks during Codex streaming
- _fire_stream_delta() fires both display and TTS callbacks
- _fire_reasoning_delta() for reasoning content streaming
- Tool-call suppression: callbacks only fire on text-only responses
- on_first_delta callback for spinner control on first token
- Provider fallback: graceful degradation to non-streaming
- _has_stream_consumers() unifies stream_delta_callback and _stream_callback checks
- Anthropic streaming returns native Message for downstream compatibility

Drawing from PRs NousResearch#922 (unified streaming), NousResearch#1312 (gateway consumer),
NousResearch#774 (Telegram streaming), NousResearch#798 (CLI streaming), NousResearch#1214 (reasoning modes).
Credit: jobless0x, OutThisLife, clicksingh, raulvidis.

… providers

Stage 1 of streaming support. Adds:

- stream_delta_callback parameter on AIAgent.__init__ for real-time token delivery
- _interruptible_streaming_api_call() handling chat_completions + anthropic_messages
- Enhanced _run_codex_stream() to fire delta callbacks during Codex streaming
- _fire_stream_delta() fires both display and TTS callbacks
- _fire_reasoning_delta() for reasoning content streaming
- Tool-call suppression: callbacks only fire on text-only responses
- on_first_delta callback for spinner control on first token
- Provider fallback: graceful degradation to non-streaming
- _has_stream_consumers() unifies stream_delta_callback and _stream_callback checks
- Anthropic streaming returns native Message for downstream compatibility

Drawing from PRs NousResearch#922 (unified streaming), NousResearch#1312 (gateway consumer),
NousResearch#774 (Telegram streaming), NousResearch#798 (CLI streaming), NousResearch#1214 (reasoning modes).
Credit: jobless0x, OutThisLife, clicksingh, raulvidis.

… providers

Stage 1 of streaming support. Adds:

- stream_delta_callback parameter on AIAgent.__init__ for real-time token delivery
- _interruptible_streaming_api_call() handling chat_completions + anthropic_messages
- Enhanced _run_codex_stream() to fire delta callbacks during Codex streaming
- _fire_stream_delta() fires both display and TTS callbacks
- _fire_reasoning_delta() for reasoning content streaming
- Tool-call suppression: callbacks only fire on text-only responses
- on_first_delta callback for spinner control on first token
- Provider fallback: graceful degradation to non-streaming
- _has_stream_consumers() unifies stream_delta_callback and _stream_callback checks
- Anthropic streaming returns native Message for downstream compatibility

Drawing from PRs NousResearch#922 (unified streaming), NousResearch#1312 (gateway consumer),
NousResearch#774 (Telegram streaming), NousResearch#798 (CLI streaming), NousResearch#1214 (reasoning modes).
Credit: jobless0x, OutThisLife, clicksingh, raulvidis.

… providers

Stage 1 of streaming support. Adds:

- stream_delta_callback parameter on AIAgent.__init__ for real-time token delivery
- _interruptible_streaming_api_call() handling chat_completions + anthropic_messages
- Enhanced _run_codex_stream() to fire delta callbacks during Codex streaming
- _fire_stream_delta() fires both display and TTS callbacks
- _fire_reasoning_delta() for reasoning content streaming
- Tool-call suppression: callbacks only fire on text-only responses
- on_first_delta callback for spinner control on first token
- Provider fallback: graceful degradation to non-streaming
- _has_stream_consumers() unifies stream_delta_callback and _stream_callback checks
- Anthropic streaming returns native Message for downstream compatibility

Drawing from PRs NousResearch#922 (unified streaming), NousResearch#1312 (gateway consumer),
NousResearch#774 (Telegram streaming), NousResearch#798 (CLI streaming), NousResearch#1214 (reasoning modes).
Credit: jobless0x, OutThisLife, clicksingh, raulvidis.