t3-code-android-nightly/.repos/alchemy-effect/examples/fly-microservices/test/integ.test.ts

import * as Alchemy from "alchemy";
import * as Fly from "alchemy/Fly";
import * as Test from "alchemy/Test/Bun";
import { expect } from "bun:test";
import * as Effect from "effect/Effect";
import * as Schedule from "effect/Schedule";
import * as HttpClient from "effect/http/HttpClient";
import Stack from "../alchemy.run.ts";
import { USERS } from "../src/users.ts";

const { test, beforeAll, afterAll, deploy, destroy } = Test.make({
  providers: Fly.providers(),
  state: Alchemy.localState(),
  profile: process.env.ALCHEMY_PROFILE,
});

const getJson = (url: string) =>
  HttpClient.get(url).pipe(
    Effect.flatMap((res) =>
      res.status === 200
        ? res.json
        : Effect.fail(new Error(`HTTP ${res.status}`)),
    ),
    Effect.retry({ schedule: Schedule.exponential("500 millis"), times: 20 }),
  );

const stack = beforeAll(deploy(Stack), { timeout: 400_000 });

afterAll.skipIf(!!process.env.NO_DESTROY)(destroy(Stack), {
  timeout: 240_000,
});

test(
  "the public gateway reaches private Services over the stack network",
  Effect.gen(function* () {
    const out = yield* stack;
    expect(out.url).toMatch(/^https:\/\/.+\.fly\.dev$/);
    expect(out.usersUrl).toBeUndefined();
    expect(out.usersPrivateUrl).toMatch(/^http:\/\/.+\.flycast$/);
    expect(out.ordersPrivateUrl).toMatch(/^http:\/\/.+\.flycast$/);
    expect(out.network).toBeString();

    expect((yield* getJson(`${out.url}/users`)) as unknown).toEqual(USERS);
    const orders = (yield* getJson(`${out.url}/orders`)) as Array<{
      user: { name: string };
    }>;
    expect(orders.map((order) => order.user.name)).toEqual(["Ada", "Grace"]);
  }),
  { timeout: 240_000 },
);