fix(streaming): guard streamer for non-sendable messages, add streaming config

Skip streamer acquisition for heartbeat (NoHistory=true), preventing
HEARTBEAT_OK from leaking to Telegram via streamer.Finalize().

Add streaming.enabled to Telegram defaults and example config.

Author: amirmamaghani

config/config.example.json

@@ -56,7 +56,10 @@
       "allow_from": [
         "YOUR_USER_ID"
       ],
-      "reasoning_channel_id": ""
+      "reasoning_channel_id": "",
+      "streaming": {
+        "enabled": true
+      }
     },
     "discord": {
       "enabled": false,

pkg/agent/loop.go

@@ -740,7 +740,7 @@ func (al *AgentLoop) runLLMIteration(
 	// Check if both the provider and channel support streaming
 	streamProvider, providerCanStream := agent.Provider.(providers.StreamingProvider)
 	var streamer bus.Streamer
-	if providerCanStream && opts.SendResponse && !constants.IsInternalChannel(opts.Channel) {
+	if providerCanStream && !opts.NoHistory && !constants.IsInternalChannel(opts.Channel) {
 		streamer, _ = al.bus.GetStreamer(ctx, opts.Channel, opts.ChatID)
 	}
 

pkg/config/defaults.go

@@ -58,6 +58,7 @@ func DefaultConfig() *Config {
 					Enabled: true,
 					Text:    "Thinking... 💭",
 				},
+				Streaming: StreamingConfig{Enabled: true},
 			},
 			Feishu: FeishuConfig{
 				Enabled:           false,