你可能以为 app_server 会用 WebSocket/SSE 把事件实时推给前端。但实际上：event/ 和 status/ 目录里没有任何 SSE / WebSocket / event-stream 代码。app_server 侧的事件只有两件事：

event_router.py，前缀 /conversation/{conversation_id}/events，三个只读端点：

# event_router.py
GET  .../events/search    # 搜事件（按 kind/时间过滤 + 分页）
GET  .../events/count     # 数事件总数
GET  .../events           # 批量取事件

event_service_base.py 是存储基类，用模板方法模式：基类写好 search/count/save 的编排逻辑，把三个"怎么读写一条"的原语留给子类实现：

# 基类实现编排，子类填原语（概念）
class EventServiceBase(EventService):
    async def search_events(self, ...):   # 编排：并发读所有文件→内存过滤→排序→分页
        paths = self._search_paths(...)                  # ← 子类实现
        events = await self._load_events_from_paths(paths)  # 并发+信号量限流
        return 过滤排序分页(events)
    # 三个留给子类的原语：
    async def _load_event(self, path): ...    # 子类：怎么读一条
    async def _store_event(self, event): ...  # 子类：怎么写一条
    def _search_paths(self, ...): ...         # 子类：去哪找

FilesystemEventService（filesystem_event_service.py:17）：一个事件存一个 JSON 文件，用 Pydantic 的 model_validate_json/model_dump_json 读写。路径设计是关键（event_service_base.py:66）：

def get_conversation_path(self, ...):
    # 路径 = {prefix}/{user_id}/{V1_CONVERSATIONS_DIR}/{conversation_id.hex}
    return f'{prefix}/{user_id}/conversations/{conversation_id.hex}'

事件从哪写入？webhook_router.py（前缀 /webhooks）。沙箱里的 agent-server 每产生事件就回调这里。鉴权靠 valid_sandbox（:250）校验 X-Session-API-Key 头：

# webhook_router.py
@router.post('/webhooks/events/{conversation_id}')
async def on_event(conversation_id, events, sandbox=Depends(valid_sandbox), ...):
    # valid_sandbox：校验 X-Session-API-Key → 反查 sandbox → 切换成沙箱属主用户上下文
    ...

on_event（webhook_router.py:468）收到一批事件后：

1. 并发落库：把所有事件 save_event 存下来。
2. 处理特殊事件：stats 事件、执行状态变化、Agent 主动切模型（SwitchLLMObservation）等 → 更新会话记录。
3. 终态打点：任务结束时 _track_conversation_terminal 做分析埋点。
4. 后台跑回调：background_tasks.add_task(_run_callbacks_in_bg_and_close, ...)。

_run_callbacks_in_bg_and_close（:583）的注释解释了一个精妙的性能考量：回调处理器运行时不持有 DB 连接。

✋ 动手

grep -n 'search\|count\|save_event' openhands/app_server/event/event_service.py
grep -n 'get_conversation_path\|user_id\|_load_event\|_store_event' openhands/app_server/event/event_service_base.py
grep -n 'def on_event\|valid_sandbox\|_run_callbacks_in_bg\|_import_all_tools' openhands/app_server/event_callback/webhook_router.py