t3-code-android-nightly/.repos/alchemy-effect/packages/alchemy/test/Local/fixtures/rpc-spawner-parent.ts

// Test fixture: boots an RpcSpawner, POSTs once with the child entry given by
// the first CLI arg, and prints `PARENT_PID=<n>` and `CHILD_PID=<n>` lines to
// stdout so the test harness can observe them. Then idles until killed.
// Relative imports (not `@/` alias) so this file runs under both Bun and
// Node without a paths-aware loader. This fixture is excluded from the test
// project's typecheck (see tsconfig.test.json) because the relative path
// crosses composite-project boundaries.
import * as Deferred from "effect/Deferred";
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as FetchHttpClient from "effect/http/FetchHttpClient";
import * as HttpBody from "effect/http/HttpBody";
import * as HttpClient from "effect/http/HttpClient";
import { layerServer, RpcSpawner } from "../../../src/Local/RpcSpawner.ts";
import { PlatformServices } from "../../../src/Util/PlatformServices.ts";

const childEntry = process.argv[2];
if (!childEntry) {
  console.error("usage: rpc-spawner-parent.ts <child-entry-url>");
  process.exit(2);
}

const program = Effect.gen(function* () {
  const sp = yield* RpcSpawner;
  const http = yield* HttpClient.HttpClient;
  const res = yield* http
    .post(sp.url, {
      body: yield* HttpBody.json({
        serverEntryUrl: childEntry,
        alchemyContext: {
          dotAlchemy: "/tmp/.alchemy",
          updateStateStore: false,
          dev: true,
          adopt: false,
        },
        stack: { name: "test", stage: "dev" },
      }),
    })
    .pipe(Effect.flatMap((res) => res.text));

  // The child's pid is whatever owns the listening port returned in res.
  // We surface it for the test harness via stdout.
  console.log(`PARENT_PID=${process.pid}\n`);
  console.log(`CHILD_URL=${res}\n`);

  const stop = yield* Deferred.make<void>();
  yield* Deferred.await(stop);
});

program
  .pipe(
    Effect.provide([
      Layer.provide(
        layerServer({ profile: undefined, envFile: undefined }),
        PlatformServices,
      ),
      FetchHttpClient.layer,
    ]),
    Effect.scoped,
    Effect.runPromise,
  )
  .catch((e) => {
    console.error(e);
    process.exit(1);
  });