feat: add session message monitoring tab to bot detail dialog

Add a new "Sessions" tab in the bot detail dialog that displays
sent & received messages grouped by sessions. Users can select
any session to view its messages in a chat-bubble style layout.

Backend changes:
- Add sessionId filter to monitoring messages endpoint
- Add role column to MonitoringMessage (user/assistant)
- Record bot responses in monitoring via record_query_response()
- Add DB migration (dbm019) for the new role column

Frontend changes:
- New BotSessionMonitor component with session list + message viewer
- Add Sessions sidebar tab to BotDetailDialog
- Add getBotSessions/getSessionMessages API methods to BackendClient
- Add i18n translations (en-US, zh-Hans, zh-Hant, ja-JP)

Generated with [Claude Code](https://claude.ai/code)
via [Happy](https://happy.engineering)

Co-Authored-By: Claude <noreply@anthropic.com>
Co-Authored-By: Happy <yesreply@happy.engineering>

Author: 3 people

src/langbot/pkg/api/http/controller/groups/monitoring.py

@@ -52,6 +52,7 @@ async def get_messages() -> str:
             # Parse query parameters
             bot_ids = quart.request.args.getlist('botId')
             pipeline_ids = quart.request.args.getlist('pipelineId')
+            session_ids = quart.request.args.getlist('sessionId')
             start_time_str = quart.request.args.get('startTime')
             end_time_str = quart.request.args.get('endTime')
             limit = int(quart.request.args.get('limit', 100))
@@ -64,6 +65,7 @@ async def get_messages() -> str:
             messages, total = await self.ap.monitoring_service.get_messages(
                 bot_ids=bot_ids if bot_ids else None,
                 pipeline_ids=pipeline_ids if pipeline_ids else None,
+                session_ids=session_ids if session_ids else None,
                 start_time=start_time,
                 end_time=end_time,
                 limit=limit,

src/langbot/pkg/api/http/service/monitoring.py

@@ -32,6 +32,7 @@ async def record_message(
         user_id: str | None = None,
         runner_name: str | None = None,
         variables: str | None = None,
+        role: str = 'user',
     ) -> str:
         """Record a message"""
         message_id = str(uuid.uuid4())
@@ -50,6 +51,7 @@ async def record_message(
             'user_id': user_id,
             'runner_name': runner_name,
             'variables': variables,
+            'role': role,
         }
 
         await self.ap.persistence_mgr.execute_async(
@@ -355,6 +357,7 @@ async def get_messages(
         self,
         bot_ids: list[str] | None = None,
         pipeline_ids: list[str] | None = None,
+        session_ids: list[str] | None = None,
         start_time: datetime.datetime | None = None,
         end_time: datetime.datetime | None = None,
         limit: int = 100,
@@ -367,6 +370,8 @@ async def get_messages(
             conditions.append(persistence_monitoring.MonitoringMessage.bot_id.in_(bot_ids))
         if pipeline_ids:
             conditions.append(persistence_monitoring.MonitoringMessage.pipeline_id.in_(pipeline_ids))
+        if session_ids:
+            conditions.append(persistence_monitoring.MonitoringMessage.session_id.in_(session_ids))
         if start_time:
             conditions.append(persistence_monitoring.MonitoringMessage.timestamp >= start_time)
         if end_time:

src/langbot/pkg/entity/persistence/monitoring.py

@@ -22,6 +22,7 @@ class MonitoringMessage(Base):
     user_id = sqlalchemy.Column(sqlalchemy.String(255), nullable=True)
     runner_name = sqlalchemy.Column(sqlalchemy.String(255), nullable=True)  # Runner name for this query
     variables = sqlalchemy.Column(sqlalchemy.Text, nullable=True)  # Query variables as JSON string
+    role = sqlalchemy.Column(sqlalchemy.String(50), nullable=True, default='user')  # user, assistant
 
 
 class MonitoringLLMCall(Base):

src/langbot/pkg/persistence/migrations/dbm019_monitoring_message_role.py

@@ -0,0 +1,26 @@
+import sqlalchemy
+from .. import migration
+
+
+@migration.migration_class(19)
+class DBMigrateMonitoringMessageRole(migration.DBMigration):
+    """Add role column to monitoring_messages table"""
+
+    async def upgrade(self):
+        """Upgrade"""
+        try:
+            sql_text = sqlalchemy.text(
+                "ALTER TABLE monitoring_messages ADD COLUMN role VARCHAR(50) DEFAULT 'user'"
+            )
+            await self.ap.persistence_mgr.execute_async(sql_text)
+        except Exception:
+            # Column may already exist
+            pass
+
+    async def downgrade(self):
+        """Downgrade"""
+        try:
+            sql_text = sqlalchemy.text('ALTER TABLE monitoring_messages DROP COLUMN role')
+            await self.ap.persistence_mgr.execute_async(sql_text)
+        except Exception:
+            pass

src/langbot/pkg/pipeline/monitoring_helper.py

@@ -114,6 +114,60 @@ async def record_query_success(
         except Exception as e:
             ap.logger.error(f'Failed to record query success: {e}')
 
+    @staticmethod
+    async def record_query_response(
+        ap: app.Application,
+        query: pipeline_query.Query,
+        bot_id: str,
+        bot_name: str,
+        pipeline_id: str,
+        pipeline_name: str,
+        runner_name: str | None = None,
+    ):
+        """Record bot response message to monitoring"""
+        try:
+            session_id = f'{query.launcher_type}_{query.launcher_id}'
+
+            # Extract response content from resp_message_chain
+            if hasattr(query, 'resp_message_chain') and query.resp_message_chain:
+                # Serialize the last response message chain
+                last_resp = query.resp_message_chain[-1]
+                if hasattr(last_resp, 'model_dump'):
+                    message_content = json.dumps(last_resp.model_dump(), ensure_ascii=False)
+                else:
+                    message_content = str(last_resp)
+            elif hasattr(query, 'resp_messages') and query.resp_messages:
+                last_resp = query.resp_messages[-1]
+                if hasattr(last_resp, 'get_content_platform_message_chain'):
+                    chain = last_resp.get_content_platform_message_chain()
+                    if hasattr(chain, 'model_dump'):
+                        message_content = json.dumps(chain.model_dump(), ensure_ascii=False)
+                    else:
+                        message_content = str(chain)
+                else:
+                    message_content = str(last_resp)
+            else:
+                return  # No response to record
+
+            await ap.monitoring_service.record_message(
+                bot_id=bot_id,
+                bot_name=bot_name,
+                pipeline_id=pipeline_id,
+                pipeline_name=pipeline_name,
+                message_content=message_content,
+                session_id=session_id,
+                status='success',
+                level='info',
+                platform=query.launcher_type.value
+                if hasattr(query.launcher_type, 'value')
+                else str(query.launcher_type),
+                user_id=query.sender_id,
+                runner_name=runner_name,
+                role='assistant',
+            )
+        except Exception as e:
+            ap.logger.error(f'Failed to record query response: {e}')
+
     @staticmethod
     async def record_query_error(
         ap: app.Application,

src/langbot/pkg/pipeline/pipelinemgr.py

@@ -339,6 +339,20 @@ async def process_query(self, query: pipeline_query.Query):
                 except Exception as e:
                     self.ap.logger.error(f'Failed to record query success: {e}')
 
+                # Record bot response message
+                try:
+                    await monitoring_helper.MonitoringHelper.record_query_response(
+                        ap=self.ap,
+                        query=query,
+                        bot_id=query.bot_uuid or 'unknown',
+                        bot_name=bot_name,
+                        pipeline_id=self.pipeline_entity.uuid,
+                        pipeline_name=pipeline_name,
+                        runner_name=runner_name,
+                    )
+                except Exception as e:
+                    self.ap.logger.error(f'Failed to record query response: {e}')
+
         except Exception as e:
             inst_name = query.current_stage_name if query.current_stage_name else 'unknown'
             self.ap.logger.error(f'Error processing query {query.query_id} stage={inst_name} : {e}')

web/src/app/home/bots/BotDetailDialog.tsx

@@ -21,6 +21,7 @@ import {
 import { Button } from '@/components/ui/button';
 import BotForm from '@/app/home/bots/components/bot-form/BotForm';
 import { BotLogListComponent } from '@/app/home/bots/components/bot-log/view/BotLogListComponent';
+import BotSessionMonitor from '@/app/home/bots/components/bot-session/BotSessionMonitor';
 import { useTranslation } from 'react-i18next';
 import { z } from 'zod';
 import { httpClient } from '@/app/infra/http/HttpClient';
@@ -82,6 +83,19 @@ export default function BotDetailDialog({
         </svg>
       ),
     },
+    {
+      key: 'sessions',
+      label: t('bots.sessionMonitor.title'),
+      icon: (
+        <svg
+          xmlns="http://www.w3.org/2000/svg"
+          viewBox="0 0 24 24"
+          fill="currentColor"
+        >
+          <path d="M2 22C2 17.5817 5.58172 14 10 14C14.4183 14 18 17.5817 18 22H16C16 18.6863 13.3137 16 10 16C6.68629 16 4 18.6863 4 22H2ZM10 13C6.685 13 4 10.315 4 7C4 3.685 6.685 1 10 1C13.315 1 16 3.685 16 7C16 10.315 13.315 13 10 13ZM10 11C12.21 11 14 9.21 14 7C14 4.79 12.21 3 10 3C7.79 3 6 4.79 6 7C6 9.21 7.79 11 10 11ZM18.2837 14.7028C21.0644 15.9561 23 18.752 23 22H21C21 19.564 19.5483 17.4671 17.4628 16.5271L18.2837 14.7028ZM17.5962 3.41321C19.5944 4.23703 21 6.20361 21 8.5C21 11.3702 18.8042 13.7252 16 13.9776V11.9646C17.6967 11.7222 19 10.264 19 8.5C19 7.11935 18.2016 5.92603 17.041 5.35635L17.5962 3.41321Z"></path>
+        </svg>
+      ),
+    },
   ];
 
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
@@ -155,7 +169,7 @@ export default function BotDetailDialog({
   return (
     <>
       <Dialog open={open} onOpenChange={onOpenChange}>
-        <DialogContent className="overflow-hidden p-0 !max-w-[50rem] max-h-[75vh] flex">
+        <DialogContent className="overflow-hidden p-0 !max-w-[70rem] max-h-[75vh] flex">
           <SidebarProvider className="items-start w-full flex">
             <Sidebar
               collapsible="none"
@@ -189,10 +203,12 @@ export default function BotDetailDialog({
                 <DialogTitle>
                   {activeMenu === 'config'
                     ? t('bots.editBot')
-                    : t('bots.botLogTitle')}
+                    : activeMenu === 'logs'
+                      ? t('bots.botLogTitle')
+                      : t('bots.sessionMonitor.title')}
                 </DialogTitle>
               </DialogHeader>
-              <div className="flex-1 overflow-y-auto px-6 pb-6">
+              <div className={activeMenu === 'sessions' ? 'flex-1 min-h-0' : 'flex-1 overflow-y-auto px-6 pb-6'}>
                 {activeMenu === 'config' && (
                   <BotForm
                     initBotId={botId}
@@ -204,6 +220,9 @@ export default function BotDetailDialog({
                 {activeMenu === 'logs' && botId && (
                   <BotLogListComponent botId={botId} />
                 )}
+                {activeMenu === 'sessions' && botId && (
+                  <BotSessionMonitor botId={botId} />
+                )}
               </div>
               {activeMenu === 'config' && (
                 <DialogFooter className="px-6 py-4 border-t shrink-0">