Function writeWorkspaceStateRecordSync

packages/db/src/workspace-state.ts:58–139

(
  state: AgentSpaceState,
  workspaceId = DEFAULT_WORKSPACE_ID,
  options?: WorkspaceStateWriteOptions,
)

}

export function writeWorkspaceStateRecordSync(
  state: AgentSpaceState,
  workspaceId = DEFAULT_WORKSPACE_ID,
  options?: WorkspaceStateWriteOptions,
): AgentSpaceState {
  const db = getDatabase();
  const now = new Date().toISOString();
  const existing = db
    .prepare("SELECT id, state_version FROM workspace_snapshot WHERE id = ?")
    .get(workspaceId) as { id: string; state_version: number } | undefined;
  const expectedVersion = options?.expectedVersion ?? readWorkspaceStateVersion(state);

  if (!existing) {
    db.prepare(
      `INSERT INTO workspace_snapshot (
        id,
        organization_name,
        pending_handoffs,
        state_json,
        state_version,
        created_at,
        updated_at
      ) VALUES (?, ?, ?, ?, 1, ?, ?)`,
    ).run(
      workspaceId,
      state.organizationName,
      state.pendingHandoffs,
      JSON.stringify(state),
      now,
      now,
    );
    return attachWorkspaceStateVersion(state, 1);
  }

  if (!options?.skipVersionCheck && typeof expectedVersion === "number") {
    const result = db.prepare(
      `UPDATE workspace_snapshot
       SET organization_name = ?,
           pending_handoffs = ?,
           state_json = ?,
           state_version = state_version + 1,
           updated_at = ?
       WHERE id = ? AND state_version = ?`,
    ).run(
      state.organizationName,
      state.pendingHandoffs,
      JSON.stringify(state),
      now,
      workspaceId,
      expectedVersion,
    );

    if (result.changes === 0) {
      const currentVersion = readWorkspaceStateCurrentVersionSync(workspaceId) ?? existing.state_version;
      throw new WorkspaceStateConflictError({
        workspaceId,
        expectedVersion,
        currentVersion,