Function insertBrowserSession

apps/api/src/lib/browser-sessions.ts:38–77

(
  row: Omit<BrowserSessionRow, "created_at" | "updated_at">,
)

// ---------------------------------------------------------------------------

export async function insertBrowserSession(
  row: Omit<BrowserSessionRow, "created_at" | "updated_at">,
): Promise<BrowserSessionRow> {
  const now = new Date().toISOString();
  const full: BrowserSessionRow = {
    ...row,
    created_at: now,
    updated_at: now,
  };

  const MAX_ATTEMPTS = 10;
  let lastError: any = null;
  for (let attempt = 1; attempt <= MAX_ATTEMPTS; attempt++) {
    try {
      const [data] = await db
        .insert(schema.browser_sessions)
        .values(full)
        .returning();

      return data as BrowserSessionRow;
    } catch (error) {
      lastError = error;
      logger.error("Error inserting browser session, trying again", {
        error,
        id: row.id,
        attempt,
      });
      await new Promise(resolve => setTimeout(resolve, 75));
    }
  }

  logger.error("Failed to insert browser session after all retries", {
    error: lastError,
    id: row.id,
    attempts: MAX_ATTEMPTS,
  });
  throw new Error(
    `Failed to insert browser session: ${lastError?.message ?? "unknown error"}`,
  );
}

export async function getBrowserSession(
  id: string,