import { Effect, Exit, Layer, ManagedRuntime, Scope } from "effect";import { afterEach, describe, expect, it } from "vitest"; import { CheckpointReactor } from "../Services/CheckpointReactor.ts";import { ProviderCommandReactor } from "../Services/ProviderCommandReactor.ts";import { ProviderRuntimeIngestionService } from "../Services/ProviderRuntimeIngestion.ts";import { OrchestrationReactor } from "../Services/OrchestrationReactor.ts";import { makeOrchestrationReactor } from "./OrchestrationReactor.ts"; describe("OrchestrationReactor", () => { let runtime: ManagedRuntime.ManagedRuntime<OrchestrationReactor, never> | null = null; afterEach(async () => { if (runtime) { await runtime.dispose(); } runtime = null; }); it("starts provider ingestion, provider command, and checkpoint reactors", async () => { const started: string[] = []; runtime = ManagedRuntime.make( Layer.effect(OrchestrationReactor, makeOrchestrationReactor).pipe( Layer.provideMerge( Layer.succeed(ProviderRuntimeIngestionService, { start: () => { started.push("provider-runtime-ingestion"); return Effect.void; }, drain: Effect.void, }), ), Layer.provideMerge( Layer.succeed(ProviderCommandReactor, { start: () => { started.push("provider-command-reactor"); return Effect.void; }, drain: Effect.void, }), ), Layer.provideMerge( Layer.succeed(CheckpointReactor, { start: () => { started.push("checkpoint-reactor"); return Effect.void; }, drain: Effect.void, }), ), ), ); const reactor = await runtime.runPromise(Effect.service(OrchestrationReactor)); const scope = await Effect.runPromise(Scope.make("sequential")); await Effect.runPromise(reactor.start().pipe(Scope.provide(scope))); expect(started).toEqual([ "provider-runtime-ingestion", "provider-command-reactor", "checkpoint-reactor", ]); await Effect.runPromise(Scope.close(scope, Exit.void)); });});
import { Effect, Exit, Layer, ManagedRuntime, Scope } from "effect";
import { afterEach, describe, expect, it } from "vitest";
import { CheckpointReactor } from "../Services/CheckpointReactor.ts";
import { ProviderCommandReactor } from "../Services/ProviderCommandReactor.ts";
import { ProviderRuntimeIngestionService } from "../Services/ProviderRuntimeIngestion.ts";
import { OrchestrationReactor } from "../Services/OrchestrationReactor.ts";
import { makeOrchestrationReactor } from "./OrchestrationReactor.ts";
describe("OrchestrationReactor", () => {
let runtime: ManagedRuntime.ManagedRuntime<OrchestrationReactor, never> | null = null;
afterEach(async () => {
if (runtime) {
await runtime.dispose();
}
runtime = null;
});
it("starts provider ingestion, provider command, and checkpoint reactors", async () => {
const started: string[] = [];
runtime = ManagedRuntime.make(
Layer.effect(OrchestrationReactor, makeOrchestrationReactor).pipe(
Layer.provideMerge(
Layer.succeed(ProviderRuntimeIngestionService, {
start: () => {
started.push("provider-runtime-ingestion");
return Effect.void;
},
drain: Effect.void,
}),
),
Layer.provideMerge(
Layer.succeed(ProviderCommandReactor, {
start: () => {
started.push("provider-command-reactor");
return Effect.void;
},
drain: Effect.void,
}),
),
Layer.provideMerge(
Layer.succeed(CheckpointReactor, {
start: () => {
started.push("checkpoint-reactor");
return Effect.void;
},
drain: Effect.void,
}),
),
),
);
const reactor = await runtime.runPromise(Effect.service(OrchestrationReactor));
const scope = await Effect.runPromise(Scope.make("sequential"));
await Effect.runPromise(reactor.start().pipe(Scope.provide(scope)));
expect(started).toEqual([
"provider-runtime-ingestion",
"provider-command-reactor",
"checkpoint-reactor",
]);
await Effect.runPromise(Scope.close(scope, Exit.void));
});
});