Function readWantedStatusAt

packages/wl-sdk/src/ops/state.ts:23–54

(opts: {
  auth: DoltHubAuth;
  /** The repo to read from — fork for branch reads, upstream for main. */
  owner: string;
  db: string;
  ref?: string;
  wantedId: string;
  fetch?: typeof fetch;
  hooks?: DoltFetchHooks;
})

/** Read just the `status` field for a wanted row at a ref. */
export async function readWantedStatusAt(opts: {
  auth: DoltHubAuth;
  /** The repo to read from — fork for branch reads, upstream for main. */
  owner: string;
  db: string;
  ref?: string;
  wantedId: string;
  fetch?: typeof fetch;
  hooks?: DoltFetchHooks;
}): Promise<string | null> {
  const sql = `SELECT status FROM wanted WHERE id = '${escapeSqlString(opts.wantedId)}' LIMIT 1`;
  try {
    const res = await doltRead({
      auth: opts.auth,
      owner: opts.owner,
      db: opts.db,
      ref: opts.ref,
      query: sql,
      fetch: opts.fetch,
      hooks: opts.hooks,
    });
    if (res.rows.length === 0) return null;
    const parsed = StatusRow.safeParse(res.rows[0]);
    if (!parsed.success) return null;
    return parsed.data.status ?? null;
  } catch (err) {
    // Treat 404s on a not-yet-created branch as "no row": the branch
    // simply doesn't exist on the fork yet. Other errors propagate.
    if (err instanceof WlDoltHubError && err.status === 404) return null;
    throw new WlError(`Read wanted status at ${opts.ref ?? 'main'} failed`, 'upstream', err);
  }
}

/** Read the full wanted row at a ref. Returns `null` when the row isn't present. */
export async function readWantedRowAt(opts: {