D1ProxyClient.ts

export class D1ProxyClient {
  private workerUrl: string;
  private apiKey: string;
  constructor(workerUrl: string, apiKey: string) {
    this.workerUrl = workerUrl;
    this.apiKey = apiKey;
  }
  async query(sql: string, params: any[] = []) {
    const response = await fetch(this.workerUrl, {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
      },
      body: JSON.stringify({
        params,
        sql,
        apiKey: this.apiKey,
      }),
    });

    const data = await response.json();

    return data as { error?: any; results: any };
  }
}