From f96cf3f8cc2792bc2f8b55c231ae00304f821b98 Mon Sep 17 00:00:00 2001
From: Avisek <biisal.int@gmail.com>
Date: Thu, 26 Feb 2026 11:33:01 +0530
Subject: [PATCH] feat: Add `reasoning_channel_id` to communication platform
 configurations and improve message bus context cancellation handling.

---
 config/config.example.json | 38 +++++++++++++++++++++++++-------------
 pkg/bus/bus.go             |  9 +++++++++
 2 files changed, 34 insertions(+), 13 deletions(-)

diff --git a/config/config.example.json b/config/config.example.json
index 9575039f8..a5bb96774 100644
--- a/config/config.example.json
+++ b/config/config.example.json
@@ -52,30 +52,35 @@
       "proxy": "",
       "allow_from": [
         "YOUR_USER_ID"
-      ]
+      ],
+      "reasoning_channel_id": ""
     },
     "discord": {
       "enabled": false,
       "token": "YOUR_DISCORD_BOT_TOKEN",
       "allow_from": [],
-      "mention_only": false
+      "mention_only": false,
+      "reasoning_channel_id": ""
     },
     "qq": {
       "enabled": false,
       "app_id": "YOUR_QQ_APP_ID",
       "app_secret": "YOUR_QQ_APP_SECRET",
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "maixcam": {
       "enabled": false,
       "host": "0.0.0.0",
       "port": 18790,
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "whatsapp": {
       "enabled": false,
       "bridge_url": "ws://localhost:3001",
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "feishu": {
       "enabled": false,
@@ -83,19 +88,22 @@
       "app_secret": "",
       "encrypt_key": "",
       "verification_token": "",
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "dingtalk": {
       "enabled": false,
       "client_id": "YOUR_CLIENT_ID",
       "client_secret": "YOUR_CLIENT_SECRET",
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "slack": {
       "enabled": false,
       "bot_token": "xoxb-YOUR-BOT-TOKEN",
       "app_token": "xapp-YOUR-APP-TOKEN",
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "line": {
       "enabled": false,
@@ -104,7 +112,8 @@
       "webhook_host": "0.0.0.0",
       "webhook_port": 18791,
       "webhook_path": "/webhook/line",
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "onebot": {
       "enabled": false,
@@ -112,7 +121,8 @@
       "access_token": "",
       "reconnect_interval": 5,
       "group_trigger_prefix": [],
-      "allow_from": []
+      "allow_from": [],
+      "reasoning_channel_id": ""
     },
     "wecom": {
       "_comment": "WeCom Bot (智能机器人) - Easier setup, supports group chats",
@@ -124,7 +134,8 @@
       "webhook_port": 18793,
       "webhook_path": "/webhook/wecom",
       "allow_from": [],
-      "reply_timeout": 5
+      "reply_timeout": 5,
+      "reasoning_channel_id": ""
     },
     "wecom_app": {
       "_comment": "WeCom App (自建应用) - More features, proactive messaging, private chat only. See docs/wecom-app-configuration.md",
@@ -138,7 +149,8 @@
       "webhook_port": 18792,
       "webhook_path": "/webhook/wecom-app",
       "allow_from": [],
-      "reply_timeout": 5
+      "reply_timeout": 5,
+      "reasoning_channel_id": ""
     }
   },
   "providers": {
@@ -251,4 +263,4 @@
     "host": "127.0.0.1",
     "port": 18790
   }
-}
+}
\ No newline at end of file
diff --git a/pkg/bus/bus.go b/pkg/bus/bus.go
index f2bf0c379..f5ff9587d 100644
--- a/pkg/bus/bus.go
+++ b/pkg/bus/bus.go
@@ -34,6 +34,9 @@ func (mb *MessageBus) PublishInbound(ctx context.Context, msg InboundMessage) er
 	if mb.closed.Load() {
 		return ErrBusClosed
 	}
+	if err := ctx.Err(); err != nil {
+		return err
+	}
 	select {
 	case mb.inbound <- msg:
 		return nil
@@ -59,6 +62,9 @@ func (mb *MessageBus) PublishOutbound(ctx context.Context, msg OutboundMessage)
 	if mb.closed.Load() {
 		return ErrBusClosed
 	}
+	if err := ctx.Err(); err != nil {
+		return err
+	}
 	select {
 	case mb.outbound <- msg:
 		return nil
@@ -84,6 +90,9 @@ func (mb *MessageBus) PublishOutboundMedia(ctx context.Context, msg OutboundMedi
 	if mb.closed.Load() {
 		return ErrBusClosed
 	}
+	if err := ctx.Err(); err != nil {
+		return err
+	}
 	select {
 	case mb.outboundMedia <- msg:
 		return nil