feat(platform): add Forward message support for aiocqhttp adapter (#2003)

* feat(platform): add Forward message support for aiocqhttp adapter

- Add _send_forward_message method to send merged forward cards via OneBot API
- Support NapCat's send_forward_msg API with fallback to send_group_forward_msg
- Fix MessageChain deserialization for Forward messages in handler.py
- Properly deserialize nested ForwardMessageNode.message_chain to preserve data

This enables plugins to send QQ merged forward cards through the standard
LangBot send_message API using the Forward message component.

* style: fix ruff lint and format issues

- Remove f-string prefix from log message without placeholders
- Apply ruff format to aiocqhttp.py and handler.py

* refactor: remove custom deserializer, rely on SDK for Forward deserialization

- Remove _deserialize_message_chain from handler.py; use standard
  MessageChain.model_validate() (Forward handling fixed in SDK via
  langbot-app/langbot-plugin-sdk#38)
- Fix group_id type: use int instead of str for OneBot compatibility
- Add warning log when Forward message is used with non-group target

* chore: bump langbot-plugin to 0.2.7 (Forward deserialization fix)

---------

Co-authored-by: RockChinQ <rockchinq@gmail.com>

pyproject.toml

@@ -64,7 +64,7 @@ dependencies = [
     "chromadb>=0.4.24",
     "qdrant-client (>=1.15.1,<2.0.0)",
     "pyseekdb==1.0.0b7",
-    "langbot-plugin==0.2.6",
+    "langbot-plugin==0.2.7",
     "asyncpg>=0.30.0",
     "line-bot-sdk>=3.19.0",
     "tboxsdk>=0.0.10",

src/langbot/pkg/platform/sources/aiocqhttp.py

@@ -375,6 +375,18 @@ class AiocqhttpAdapter(abstract_platform_adapter.AbstractMessagePlatformAdapter)
             self.bot = aiocqhttp.CQHttp()
 
     async def send_message(self, target_type: str, target_id: str, message: platform_message.MessageChain):
+        # Check if message contains a Forward component
+        forward_msg = message.get_first(platform_message.Forward)
+        if forward_msg:
+            if target_type == 'group':
+                # Send as merged forward message via OneBot API
+                await self._send_forward_message(int(target_id), forward_msg)
+                return
+            else:
+                await self.logger.warning(
+                    f'Forward message is only supported for group targets, got target_type={target_type}. Falling through to normal send.'
+                )
+
         aiocq_msg = (await AiocqhttpMessageConverter.yiri2target(message))[0]
 
         if target_type == 'group':
@@ -382,6 +394,90 @@ class AiocqhttpAdapter(abstract_platform_adapter.AbstractMessagePlatformAdapter)
         elif target_type == 'person':
             await self.bot.send_private_msg(user_id=int(target_id), message=aiocq_msg)
 
+    async def _send_forward_message(self, group_id: int, forward: platform_message.Forward):
+        """Send a merged forward message to a group using NapCat extended API."""
+        messages = []
+
+        for node in forward.node_list:
+            # Build content for each node
+            content = []
+            if node.message_chain:
+                for component in node.message_chain:
+                    if isinstance(component, platform_message.Plain):
+                        if component.text:
+                            content.append({'type': 'text', 'data': {'text': component.text}})
+                    elif isinstance(component, platform_message.Image):
+                        img_data = {}
+                        if component.base64:
+                            b64 = component.base64
+                            if b64.startswith('data:'):
+                                b64 = b64.split(',', 1)[-1] if ',' in b64 else b64
+                            img_data['file'] = f'base64://{b64}'
+                        elif component.url:
+                            img_data['file'] = component.url
+                        elif component.path:
+                            img_data['file'] = str(component.path)
+
+                        if img_data:
+                            content.append({'type': 'image', 'data': img_data})
+
+            if not content:
+                continue
+
+            # Build node data - use user_id and nickname format for NapCat
+            user_id = str(node.sender_id) if node.sender_id else str(self.bot_account_id or '10000')
+            node_data = {
+                'type': 'node',
+                'data': {
+                    'user_id': user_id,
+                    'nickname': node.sender_name or '未知',
+                    'content': content,
+                },
+            }
+
+            messages.append(node_data)
+
+        if not messages:
+            return
+
+        # Build the full message payload for NapCat's send_forward_msg API
+        # This matches the format used by GiveMeSetuPlugin
+        bot_id = str(self.bot_account_id) if self.bot_account_id else '10000'
+        payload = {
+            'group_id': group_id,
+            'user_id': bot_id,  # Required by NapCat for display
+            'messages': messages,
+        }
+
+        # Add display settings if available
+        if forward.display:
+            if forward.display.title:
+                payload['news'] = [{'text': forward.display.title}]
+            if forward.display.brief:
+                payload['prompt'] = forward.display.brief
+            if forward.display.summary:
+                payload['summary'] = forward.display.summary
+            if forward.display.source:
+                payload['source'] = forward.display.source
+
+        try:
+            # Use send_forward_msg (NapCat extended API) instead of send_group_forward_msg
+            await self.logger.info(
+                f'Sending forward message to group {group_id} with {len(messages)} nodes, payload keys: {list(payload.keys())}'
+            )
+            result = await self.bot.call_action('send_forward_msg', **payload)
+            await self.logger.info(f'Forward message sent to group {group_id}, result: {result}')
+        except Exception as e:
+            await self.logger.error(f'Failed to send forward message to group {group_id}: {e}')
+            # Fallback: try standard OneBot API with integer group_id
+            try:
+                await self.logger.info('Trying fallback API send_group_forward_msg')
+                await self.bot.call_action('send_group_forward_msg', group_id=group_id, messages=messages)
+                await self.logger.info(f'Forward message sent via fallback API to group {group_id}')
+            except Exception as e2:
+                await self.logger.error(f'Fallback also failed: {e2}')
+                raise
+
     async def reply_message(
         self,
         message_source: platform_events.MessageEvent,

src/langbot/pkg/plugin/handler.py

@@ -279,6 +279,7 @@ class RuntimeConnectionHandler(handler.Handler):
             target_id = data['target_id']
             message_chain = data['message_chain']
 
+            # Use custom deserializer that properly handles Forward messages
             message_chain_obj = platform_message.MessageChain.model_validate(message_chain)
 
             bot = await self.ap.platform_mgr.get_bot_by_uuid(bot_uuid)