ローカルのAI会話を安全に同期するConnectorを作る

local履歴clientとroot task readerは、app-serverをstdioで起動してinitializeし、完全一致するworkspaceのthread/listとthread/readをread-onlyで再照合する。別processの通知は補助にせず、取得結果を正本として履歴normalizerで許可fieldだけへ正規化する。

• 更新の新しいroot・subagentと親chainを8件の優先batchとして読み、最大4件を並列処理する。
• 残りの履歴は既定30分ごとに32件ずつbackfillし、通常pollを全履歴の待ち時間から分離する。
• 初回は全scanし、checkpointがある再起動では優先batchから再開する。

永続outboxは取得したbatchをSQLiteへ先に永続化し、FIFOで送信する。単調増加sequenceと冪等なbatch identityにより古いretryが新しい状態を上書きしない。4 MiBを超える履歴は分割し、完全なID manifestがある場合だけ欠落したturnとmessageを削除扱いへ揃える。

端末側はbrowser利用可能なpublishable keyと利用者sessionだけを持つ。限定ingestion endpointとheartbeat functionがJWTを検証し、権限を持つtransactional RPCへ渡す。databaseはowner単位の行制御を適用し、端末・project・definition・thread・turn・message・batchを同じowner境界へ置く。

• reasoning、command、tool引数・結果、workspaceやGit remoteの構造化fieldは同期しない。
• 利用者とAIの会話本文は原文を同期し、本文内の秘密情報やpathを自動で消す機能はないことを明記した。
• command入口にlogin、単発同期、常時実行、状態確認、診断、恒久error batchの再試行、service管理を用意した。

負荷境界の検査では、巨大threadの削除整合、長いagent key、definition全体の4 MiB超過、絵文字を途中で切るmetadata正規化が問題になった。ID manifestによる整合、byte長制約、definitionのsize保証、Unicode scalar単位の正規化へ修正し、上限付近の入力を含めて再検査した。

Connectorは取得、正規化、durable outbox、remote ingestを一つのCollectorで順序付けた。browser applicationからlocal sourceを直接読む経路は設けていない。