Function readWantedRowAt

packages/wl-sdk/src/ops/state.ts:57–85

(opts: {
  auth: DoltHubAuth;
  owner: string;
  db: string;
  ref?: string;
  wantedId: string;
  fetch?: typeof fetch;
  hooks?: DoltFetchHooks;
})

/** Read the full wanted row at a ref. Returns `null` when the row isn't present. */
export async function readWantedRowAt(opts: {
  auth: DoltHubAuth;
  owner: string;
  db: string;
  ref?: string;
  wantedId: string;
  fetch?: typeof fetch;
  hooks?: DoltFetchHooks;
}): Promise<WantedRow | null> {
  const sql = `SELECT * 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 = WantedRowSchema.safeParse(res.rows[0]);
    if (!parsed.success) return null;
    return parsed.data;
  } catch (err) {
    if (err instanceof WlDoltHubError && err.status === 404) return null;
    throw new WlError(`Read wanted row at ${opts.ref ?? 'main'} failed`, 'upstream', err);
  }
}

/**
 * Compare two wanted rows for "represents the same state on the wanted-board".