t3-code-android-nightly/.repos/alchemy-effect/packages/alchemy/test/SQL/fixtures/d1-worker.ts

import * as Cloudflare from "@/Cloudflare/index.ts";
import * as SQL from "@/SQL/D1.ts";
import * as Effect from "effect/Effect";
import * as HttpServerRequest from "effect/http/HttpServerRequest";
import * as HttpServerResponse from "effect/http/HttpServerResponse";
import { makeLayerUsers, makeSqlRoutes } from "./routes.ts";

export const Database = Cloudflare.D1.Database("SqlD1Database");

const TABLE = "alchemy_sql_users";

const DDL = `CREATE TABLE IF NOT EXISTS ${TABLE} (
  id INTEGER PRIMARY KEY,
  name TEXT NOT NULL,
  email TEXT NOT NULL
)`;

/**
 * Init effect for the whole route surface: binds the D1 database, builds the
 * `SQL.D1` client and the `SQL.D1Layer`-backed users service, and returns
 * the handler interface. Resources/bindings yielded here dedupe with any
 * other usage in the Worker, so nothing needs to be threaded through `fetch`.
 */
const D1Routes = Effect.gen(function* () {
  const d1 = yield* Cloudflare.D1.QueryDatabase(Database);
  const sql = yield* SQL.D1(d1);
  const layerUsers = yield* makeLayerUsers(TABLE).pipe(
    Effect.provide(SQL.D1Layer(d1)),
  );
  return makeSqlRoutes({ sql, layerUsers, ddl: DDL, table: TABLE });
});

/**
 * Effect-native Worker driving `SQL.D1` (the raw `@effect/sql-d1` client)
 * over a bound D1 database. All routes come from the shared dialect-agnostic
 * table in `routes.ts` — D1 has no dialect extras (`@effect/sql-d1` supports
 * neither transactions nor `updateValues`).
 */
export default class SqlD1Worker extends Cloudflare.Worker<SqlD1Worker>()(
  "SqlD1Worker",
  {
    main: import.meta.url,
  },
  Effect.gen(function* () {
    const routes = yield* D1Routes;

    return {
      fetch: Effect.gen(function* () {
        const request = yield* HttpServerRequest.HttpServerRequest;
        const response = yield* routes.handle(request);
        if (response !== undefined) {
          return response;
        }
        return yield* HttpServerResponse.json(
          { error: "not found" },
          { status: 404 },
        );
      }).pipe(
        Effect.catchCause((cause) =>
          HttpServerResponse.json({ error: String(cause) }, { status: 500 }),
        ),
      ),
    };
  }).pipe(Effect.provide(Cloudflare.D1.QueryDatabaseBinding)),
) {}