diff --git a/src/agents/agent-presence.service.ts b/src/agents/agent-presence.service.ts index 70f1ab3..221a198 100644 --- a/src/agents/agent-presence.service.ts +++ b/src/agents/agent-presence.service.ts @@ -39,15 +39,23 @@ export class AgentPresenceService { * Upsert a user's presence. Source is a free-text tag for debugging * (e.g. "hf-plugin", "manual", "test"). PUT /agents/:id/presence * calls this; the plugin pushes only on diff so writes are sparse. + * + * Implementation note: the older findOne+save split was a read-modify- + * write race — two concurrent first-time writes for the same userId + * would both read no row, both INSERT, second hits unique-key dup + * (`agent_presences.PRIMARY`) and 500s. Fabric.OpenclawPlugin's + * presence-sync occasionally fires two PUTs for the same agent within + * ~10 ms (tick overlap on its side — separate fix in the plugin), + * which surfaced this race in prod. + * + * `repo.upsert(values, conflictPaths)` compiles to MySQL + * `INSERT … ON DUPLICATE KEY UPDATE` and is atomic at the storage + * engine level — no read needed, no race window. We synthesize the + * returned entity from what we just wrote rather than round-tripping + * a SELECT — the controller only reads {userId, status} off it. */ async setStatus(userId: string, status: PresenceStatus, source: string): Promise { - const existing = await this.repo.findOne({ where: { userId } }); - if (existing) { - existing.status = status; - existing.source = source; - return this.repo.save(existing); - } - const row = this.repo.create({ userId, status, source }); - return this.repo.save(row); + await this.repo.upsert({ userId, status, source }, ['userId']); + return this.repo.create({ userId, status, source }); } }