t3-code-android-nightly/.repos/alchemy-effect/packages/better-auth/test/Cloudflare/Hyperdrive.test.ts

import * as Alchemy from "alchemy";
import * as Cloudflare from "alchemy/Cloudflare";
import * as Neon from "alchemy/Neon";
import * as Test from "alchemy/Test/Alchemy";
import { expect } from "alchemy-test";
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import HyperdriveAuthWorker from "./fixtures/hyperdrive-worker.ts";
import {
  AuthHttpError,
  edgeRetry,
  getJson,
  postJson,
  toCookieHeader,
} from "../http.ts";

const providers = Layer.mergeAll(Cloudflare.providers(), Neon.providers());
const { test, beforeAll, afterAll, deploy, destroy } = Test.make({
  providers,
});

const Stack = Alchemy.Stack(
  "BetterAuthHdTestStack",
  { providers, state: Cloudflare.state() },
  Effect.gen(function* () {
    const worker = yield* HyperdriveAuthWorker;
    return { url: worker.url.as<string>() };
  }),
);

const stack = beforeAll(deploy(Stack));
afterAll.skipIf(!!process.env.NO_DESTROY)(destroy(Stack));

test(
  "Worker -> Postgres through Hyperdrive (pg on workerd, origin-URL migrations)",
  Effect.gen(function* () {
    const { url } = yield* stack;
    const email = "hyperdrive@example.com";
    const password = "password1234";

    yield* postJson(`${url}/auth/sign-up/email`, {
      email,
      password,
      name: "Hyperdrive User",
    }).pipe(
      Effect.filterOrFail(
        (response) =>
          response.status === 200 ||
          response.body.includes("USER_ALREADY_EXISTS"),
        (response) => new AuthHttpError({ url, ...response }),
      ),
      edgeRetry,
    );

    const signIn = yield* postJson(`${url}/auth/sign-in/email`, {
      email,
      password,
    }).pipe(
      Effect.filterOrFail(
        (response) => response.status === 200,
        (response) => new AuthHttpError({ url, ...response }),
      ),
    );
    expect(signIn.setCookies.length).toBeGreaterThan(0);

    const me = yield* getJson<{ email: string | null }>(`${url}/me`, {
      cookie: toCookieHeader(signIn.setCookies),
    });
    expect(me.email).toBe(email);
  }),
  {
    tags: [
      "provider:cloudflare",
      "provider:cloudflare:hyperdrive",
      "provider:cloudflare:worker",
      "provider:neon",
      "provider:neon:project",
      "live",
    ],
    timeout: 120_000,
  },
);