mirrors/hermes-agent
1
0
Fork 0
mirror of https://github.com/NousResearch/hermes-agent.git synced 2026-04-25 00:51:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge 5e413166dc into c599a41b84

Browse source
This commit is contained in:
NickYang 2026-04-24 17:23:01 -05:00 • committed by GitHub
commit 612a88c9fd
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
3 changed files with 17 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
gateway/platforms/feishu.py
View file

@ -1449,6 +1449,7 @@ class FeishuAdapter(BasePlatformAdapter):
)
def _apply_settings(self, settings: FeishuAdapterSettings) -> None:
self._last_inbound_message_ids: dict = {} # chat_id -> message_id
self._app_id = settings.app_id
self._app_secret = settings.app_secret
self._domain_name = settings.domain_name
@ -2715,6 +2716,9 @@ class FeishuAdapter(BasePlatformAdapter):
)
chat_id = getattr(message, "chat_id", "") or ""
# Track last inbound message_id per chat for auto-thread reply
if chat_id and message_id:
self._last_inbound_message_ids[chat_id] = message_id
chat_info = await self.get_chat_info(chat_id)
sender_profile = await self._resolve_sender_profile(sender_id)
source = self.build_source(
@ -3907,7 +3911,11 @@ class FeishuAdapter(BasePlatformAdapter):
reply_to: Optional[str],
metadata: Optional[Dict[str, Any]],
) -> Any:
reply_in_thread = bool((metadata or {}).get("thread_id"))
_auto_thread = os.getenv("FEISHU_AUTO_THREAD", "false").lower() in ("true", "1", "yes")
reply_in_thread = bool((metadata or {}).get("thread_id")) or _auto_thread
# When auto_thread is on and no reply_to, use last inbound message_id
if _auto_thread and not reply_to:
reply_to = self._last_inbound_message_ids.get(chat_id)
if reply_to:
body = self._build_reply_message_body(
content=payload,

6
gateway/run.py
View file

@ -9141,11 +9141,14 @@ class GatewayRunner:
cursor=_effective_cursor,
buffer_only=_buffer_only,
)
_feishu_auto_thread = os.getenv("FEISHU_AUTO_THREAD", "false").lower() in ("true", "1", "yes")
_sc_reply_to = event_message_id if (_feishu_auto_thread and source.platform == Platform.FEISHU) else None
_stream_consumer = GatewayStreamConsumer(
adapter=_adapter,
chat_id=source.chat_id,
config=_consumer_cfg,
metadata=_thread_metadata,
reply_to=_sc_reply_to,
)
except Exception as _sc_err:
logger.debug("Proxy: could not set up stream consumer: %s", _sc_err)
@ -9764,11 +9767,14 @@ class GatewayRunner:
cursor=_effective_cursor,
buffer_only=_buffer_only,
)
_feishu_auto_thread2 = os.getenv("FEISHU_AUTO_THREAD", "false").lower() in ("true", "1", "yes")
_sc_reply_to2 = event_message_id if (_feishu_auto_thread2 and source.platform == Platform.FEISHU) else None
_stream_consumer = GatewayStreamConsumer(
adapter=_adapter,
chat_id=source.chat_id,
config=_consumer_cfg,
metadata={"thread_id": _progress_thread_id} if _progress_thread_id else None,
reply_to=_sc_reply_to2,
)
if _want_stream_deltas:
def _stream_delta_cb(text: str) -> None:

3
gateway/stream_consumer.py
View file

@ -83,6 +83,7 @@ class GatewayStreamConsumer:
chat_id: str,
config: Optional[StreamConsumerConfig] = None,
metadata: Optional[dict] = None,
reply_to: Optional[str] = None,
):
self.adapter = adapter
self.chat_id = chat_id
@ -90,7 +91,7 @@ class GatewayStreamConsumer:
self.metadata = metadata
self._queue: queue.Queue = queue.Queue()
self._accumulated = ""
self._message_id: Optional[str] = None
self._message_id: Optional[str] = reply_to
self._already_sent = False
self._edit_supported = True # Disabled when progressive edits are no longer usable
self._last_edit_time = 0.0