Backend Architecture

POST /agent/streaming
  │
  ├─ agentRegistry.register(threadId, abortController, promise)   ← 进程内
  ├─ redis HSET agent:task:{threadId} { status, userId, startedAt }
  │      TTL: 运行期 600s，完成后降到 120s
  │
  ├─ ChunkWriter (75ms 批量 flush)
  │      └─ redis XADD agent:stream:{threadId} { chunk }
  │
  ├─ createKiraAgent({ model, tools })
  │      └─ SSE → ChunkWriter.write(chunk)
  │
  └─ onFinish:
      ├─ 保存 message + thread_version (images/videos/audios)
      ├─ 派发 video/music Inngest events
      └─ ChunkWriter.close() → XADD sentinel { type: "done" }

GET /agent/stream/:threadId  ← 断线重连
  └─ createBlockingRedis() [独立连接]
      └─ XREAD BLOCK 3s STREAMS agent:stream:{threadId} {lastId}
         → 重放未消费 chunks + sentinel

rewind / stop
  ├─ inngest.send("video/task.cancelled" | "music/task.cancelled", { taskId })
  └─ redis.set("cancel:{taskId}", "1", "EX", 3600)
     └─ Worker 每个 step.run 检查 → 命中抛 NonRetriableError
        └─ Inngest cleanup function 退款 + 通知

const userId = c.get("jwtPayload")?.sub;

POST /support/delete-account
  ├─ 记录原因
  ├─ pgmq.send(account_deletion, {userId}, sleep=30d)
  ├─ pgmq.send(account_deletion_reminder, {userId}, sleep=27d)
  └─ 立即发 scheduled 邮件

[27 天后] kira-queue → reminder 邮件
[30 天后] kira-queue → DELETE /user → deleted 邮件 → archive

const updatedFlag = [...new Set([...(thread.flag ?? []), "nsfw"])];
await supabase.from("threads").update({ flag: updatedFlag }).eq("id", threadId);

index.ts
  ├─ Hono app
  ├─ CORS 白名单：*.kira.art / op.kira.art / （dev=allow-all）
  ├─ HTTP logger + OTEL instrumentation
  └─ SIGINT/SIGTERM:
     ├─ agentRegistry.abortAll()
     ├─ agentRegistry.waitForAll(Infinity)
     ├─ posthog.shutdown()
     ├─ telemetry.shutdown()
     ├─ Sentry.close()
     └─ process.exit(0)