Class WAEQueryable

src/drivers/database/cloudflare-wae.ts:71–123

];

class WAEQueryable implements QueryableBaseDriver {
  constructor(
    protected accountId: string,
    protected token: string
  ) {}

  async query(stmt: string): Promise<DatabaseResultSet> {
    const r = await fetch("/proxy/wae", {
      method: "POST",
      headers: {
        "Content-Type": "text/plain",
        Authorization: "Bearer " + this.token,
        "x-account-id": this.accountId,
      },
      body: stmt,
    });

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

    if (json.error) {
      throw new Error(json.error);
    }

    return {
      rows: json.data,
      headers: json.meta.map(
        (m) =>
          ({
            name: m.name,
            displayName: m.name,
            originalType: m.type,
            type:
              {
                UInt32: ColumnType.INTEGER,
                String: ColumnType.TEXT,
                Float64: ColumnType.REAL,
                DateTime: ColumnType.TEXT,
              }[m.type] ?? ColumnType.TEXT,
          }) as ColumnHeader
      ),
      stat: {
        rowsAffected: 0,
        rowsRead: 0,
        rowsWritten: 0,
        queryDurationMs: 0,
      },
    };
  }

  async transaction(stmt: string[]): Promise<DatabaseResultSet[]> {
    return Promise.all(stmt.map((s) => this.query(s)));
  }
}

export default class CloudflareWAEDriver extends PostgresLikeDriver {
  getFlags(): DriverFlags {