Class StarbaseQuery

src/drivers/database/starbasedb.ts:64–112

}

export class StarbaseQuery implements QueryableBaseDriver {
  protected url: string;
  protected headers: Record<string, string>;

  constructor(
    protected _url: string,
    protected token: string,
    protected type: string = "internal"
  ) {
    this.url = `${_url.replace(/\/$/, "")}/query/raw`;
    this.headers = {
      Authorization: `Bearer ${this.token}`,
      "Content-Type": "application/json",
    };

    if (type !== "internal") {
      this.headers["X-Starbase-Source"] = type;
    }
  }

  async transaction(stmts: string[]): Promise<DatabaseResultSet[]> {
    const r = await fetch(this.url, {
      method: "POST",
      headers: this.headers,
      body: JSON.stringify({
        transaction: stmts.map((s) => ({ sql: s })),
      }),
    });

    const json: StarbaseResponse = await r.json();
    return (Array.isArray(json.result) ? json.result : [json.result]).map(
      transformRawResult
    );
  }

  async query(stmt: string): Promise<DatabaseResultSet> {
    const r = await fetch(this.url, {
      method: "POST",
      headers: this.headers,
      body: JSON.stringify({ sql: stmt }),
    });

    const json: StarbaseResponse = await r.json();

    return transformRawResult(
      Array.isArray(json.result) ? json.result[0] : json.result
    );
  }
}