Class WlClient

packages/wl-sdk/src/client.ts:157–396

}

export class WlClient {
  readonly #config: WlClientConfig;
  readonly #upstream: { owner: string; db: string };
  readonly #fork: { forkOwner: string; forkDb: string };
  readonly #auth: DoltHubAuth;
  readonly #hooks: DoltFetchHooks;

  constructor(config: WlClientConfig) {
    if (!config.upstream) throw new WlError('WlClient: upstream is required', 'internal');
    if (!config.forkOrg) throw new WlError('WlClient: forkOrg is required', 'internal');
    if (!config.rigHandle) throw new WlError('WlClient: rigHandle is required', 'internal');
    if (!config.token) throw new WlError('WlClient: token is required', 'internal');

    this.#config = config;
    this.#upstream = parseUpstreamRef(config.upstream);
    this.#fork = { forkOwner: config.forkOrg, forkDb: this.#upstream.db };
    this.#auth = { token: config.token };
    this.#hooks = {
      onRequest: config.onRequest,
      onError: info => config.onError?.(info),
    };
  }

  /** The parsed `{ owner, db }` of the upstream wasteland. */
  get upstream(): { owner: string; db: string } {
    return this.#upstream;
  }

  /** The parsed `{ forkOwner, forkDb }` for the caller's fork. */
  get fork(): { forkOwner: string; forkDb: string } {
    return this.#fork;
  }

  /** The configured rig handle. */
  get rigHandle(): string {
    return this.#config.rigHandle;
  }

  #ctx(): MutationContext {
    return {
      auth: this.#auth,
      upstream: this.#upstream,
      fork: this.#fork,
      rigHandle: this.#config.rigHandle,
      fetch: this.#config.fetch,
      now: this.#config.now,
      hooks: this.#hooks,
    };
  }

  // ── Lifecycle ──────────────────────────────────────────────────

  async join(input: JoinInput): Promise<JoinResult> {
    return unwrap(
      await join({
        auth: this.#auth,
        upstream: this.#upstream,
        dolthubOrg: this.#config.forkOrg,