Summary

The DingTalk adapter was written against an older synchronous version of the dingtalk-stream SDK. The SDK has since migrated to a fully async architecture, breaking the adapter in three distinct ways that caused all incoming messages to be silently dropped and all replies to fail.

Bug 1 — _run_stream used asyncio.to_thread() on an async coroutine

DingTalkStreamClient.start() is now an async def. Wrapping it in asyncio.to_thread() (which is meant for blocking sync functions) created a coroutine object that was passed as a callable but never awaited, so the WebSocket connection was never established.

# Before
await asyncio.to_thread(self._stream_client.start)

# After
await self._stream_client.start()

Bug 2 — _IncomingHandler.process was sync and missing message conversion

The SDK now dispatches via await handler.raw_process(callback_message) → await handler.process(callback_message). Two problems:

• process was a plain def, causing object tuple can't be used in 'await' expression
• The argument is a CallbackMessage container; the actual chatbot fields live in .data and must be converted via ChatbotMessage.from_dict(callback_message.data) before use

# Before — sync, wrong type
def process(self, message: ChatbotMessage):
    future = asyncio.run_coroutine_threadsafe(...)
    future.result(timeout=60)

# After — async, correct conversion
async def process(self, callback_message: CallbackMessage):
    chatbot_msg = dingtalk_stream.ChatbotMessage.from_dict(callback_message.data)
    await self._adapter._on_message(chatbot_msg)

Bug 3 — SSRF-guard regex rejected valid sessionWebhook URLs

DingTalk's sessionWebhook URLs use the oapi.dingtalk.com subdomain, but the regex only whitelisted api.dingtalk.com. Every incoming webhook was silently discarded, making replies impossible.

# Before
re.compile(r'^https://api\.dingtalk\.com/')

# After — covers all *.dingtalk.com subdomains
re.compile(r'^https://[a-zA-Z0-9\-]+\.dingtalk\.com/')

Enhancement — immediate acknowledgement message

Sends a ⏳ 思考中... text message to the user as soon as a message arrives, before the agent begins processing. This provides responsive feedback during longer inference calls.

Test plan

• Send a direct message to the DingTalk bot; confirm ⏳ 思考中... appears immediately
• Confirm the agent response is received within a few seconds
• Confirm no coroutine was never awaited or tuple can't be used in await warnings in logs
• Confirm sessionWebhook is stored and used correctly for replies

Environment

Tested with dingtalk-stream 0.x (async SDK), Python 3.12.

Made with Cursor