Menu
Debug streaming issues (stop not working, content loss, reconnect problems). Use when SSE streaming has bugs.
Instalar com Codex ou Claude Copie este prompt, cole no Codex, Claude ou outro assistente e deixe que ele revise a página da skill e instale para você.
Baseado na classificação ocupacional SOC
| name | debug-stream |
| description | Debug streaming issues (stop not working, content loss, reconnect problems). Use when SSE streaming has bugs. |
| allowed-tools | Bash, Read, Grep |
TOKEN=$(ssh dev "curl -s -X POST http://localhost:8100/auth/login \
-H 'Content-Type: application/json' \
-d '{\"email\":\"Codex-test@fusion.dev\",\"password\":\"test123456\",\"client_id\":\"app_a93ea0569cafafe6299c7f660669a5b7\"}' \
| python3 -c 'import sys,json;print(json.load(sys.stdin)[\"access_token\"])'")
# 最近的 app 日志（过滤噪音）
ssh dev "docker logs fusion-api 2>&1" | grep -E 'app - |POST /api/chat/(send|stop)|stream-status|/stream/' | tail -30
# 特定会话
ssh dev "docker logs fusion-api 2>&1" | grep '{conversation_id}'
# 查看所有活跃流
ssh dev "docker exec middleware-redis redis-cli keys 'stream:*'"
# 查看特定会话的 meta
ssh dev "docker exec middleware-redis redis-cli hgetall 'stream:meta:{conv_id}'"
# 查看 lock
ssh dev "docker exec middleware-redis redis-cli get 'stream:lock:{conv_id}'"
# 查看 Stream 内容（最近 5 条）
ssh dev "docker exec middleware-redis redis-cli xrevrange 'stream:chunks:{conv_id}' + - COUNT 5"
# 发消息
RESPONSE=$(ssh dev "timeout 3 curl -s -N \
-H 'Authorization: Bearer $TOKEN' \
-H 'Content-Type: application/json' \
-X POST http://localhost:8002/api/chat/send \
-d '{\"model_id\":\"qwen3-235b-a22b\",\"message\":\"说一个字\",\"stream\":true}' 2>&1 || true")
# 提取 IDs
CONV_ID=$(echo "$RESPONSE" | python3 -c "import sys,json
for l in sys.stdin:
if 'conversation_id' in l and 'data:' in l:
print(json.loads(l.split('data: ')[1])['conversation_id']); break" 2>/dev/null)
MSG_ID=$(echo "$RESPONSE" | python3 -c "import sys,json
for l in sys.stdin:
if 'data:' in l and '\"id\"' in l:
print(json.loads(l.split('data: ')[1])['id']); break" 2>/dev/null)
echo "conv=$CONV_ID msg=$MSG_ID"
# 检查 stream-status
ssh dev "curl -s -H 'Authorization: Bearer $TOKEN' \
'http://localhost:8002/api/chat/stream-status/$CONV_ID'"
# 发 stop（带 message_id 防误杀）
ssh dev "curl -s -H 'Authorization: Bearer $TOKEN' \
-X POST 'http://localhost:8002/api/chat/stop/$CONV_ID?message_id=$MSG_ID'"
# 验证 stop 后状态
sleep 1
ssh dev "curl -s -H 'Authorization: Bearer $TOKEN' \
'http://localhost:8002/api/chat/stream-status/$CONV_ID'"
stream-status 是否返回 cancelledstreaming，说明 cancel_stream 没执行成功cancel_stream.lua 是否因为 meta 状态或 message_id 不匹配而跳过cancel_stream 是否误杀了新一轮的流（message_id 校验问题）init_stream 是否在 SSE 读取器之前执行（应在 process_message 中同步调用）init_stream 是否正确清除了上一轮的 Stream 数据（redis.delete(stream_chunks_key)）| 文件 | 职责 |
|---|---|
app/services/chat_service.py | 入口：init_stream → create_task → StreamingResponse |
app/services/stream_handler.py | Part A: generate_to_redis / Part B: stream_redis_as_sse |
app/services/stream_state_service.py | Redis 操作：init/append/finalize/cancel/check_lock |
app/services/task_manager.py | 进程内任务注册与取消（注意：跨 worker 不可见） |
app/core/lua/ | Lua 原子脚本：finalize_stream / cancel_stream / release_lock |
app/api/chat.py | stop 端点：cancel_task + cancel_stream 双通道 |
Add a new FastAPI API endpoint. Use when creating new REST API routes for the application.
Add a new LLM provider to fusion-api. Use when integrating a new AI model service.
Fusion API 项目架构、技术栈、核心组件总览。Use when you need to understand how the backend works, its architecture, or tech stack.
Quick reference for all API endpoints. Use when you need to know available endpoints, their methods, and purposes.
查看 dev 服务器 fusion-api 日志。Use when debugging backend issues, checking errors, or tracing request flow.
用 curl 测试 dev 服务器 API 端点。Use to verify API behavior, test streaming, or debug issues end-to-end.