Commit 0e4f1485c87a234b33cad6c197625d414bfd070c | the-knife

apps/server/package.json+6-6

 @@ -17,21 +17,21 @@
     "test": "vitest run"
   },
   "dependencies": {
-    "@effect/platform": "^0.94.5",
+    "@effect/platform-node": "4.0.0-beta.10",
-    "@effect/platform-node": "^0.104.1",
+    "@effect/sql-sqlite-node": "4.0.0-beta.10",
-    "@effect/sql": "^0.49.0",
+    "effect": "4.0.0-beta.10",
-    "@effect/sql-sqlite-node": "^0.50.1",
-    "effect": "^3.19.19",
     "node-pty": "^1.1.0",
     "open": "^10.1.0",
     "ws": "^8.18.0"
   },
   "devDependencies": {
+    "@effect/vitest": "4.0.0-beta.10",
     "@t3tools/contracts": "workspace:*",
     "@t3tools/web": "workspace:*",
     "@types/node": "^22.10.2",
     "@types/ws": "^8.5.13",
     "tsdown": "^0.20.3",
-    "typescript": "^5.7.3"
+    "typescript": "^5.7.3",
+    "vitest": "^4.0.0"
   }
 }

apps/server/src/orchestration/Errors.ts+11-11

apps/server/src/orchestration/Layer.test.ts+10-14

...	@@ -3,22 +3,18 @@ import os from "node:os";	...	@@ -3,22 +3,18 @@ import os from "node:os";
3	import path from "node:path";	3	import path from "node:path";
4		4
5	import type { OrchestrationEvent } from "@t3tools/contracts";	5	import type { OrchestrationEvent } from "@t3tools/contracts";
6	import { Effect } from "effect";	6	import { Effect, Layer, ManagedRuntime } from "effect";
7	import { afterEach, describe, expect, it } from "vitest";	7	import { afterEach, describe, expect, it } from "vitest";
8		8
9	import {	9	import {
10	OrchestrationEventRepository,	10	OrchestrationEventRepository,
11	type OrchestrationEventRepositoryShape,	11	type OrchestrationEventRepositoryShape,
12	} from "../persistence/Services/OrchestrationEvents";	12	} from "../persistence/Services/OrchestrationEvents.ts";
13	import { PersistenceSqlError } from "../persistence/Errors";	13	import { PersistenceSqlError } from "../persistence/Errors.ts";
14		14	import { makeSqlitePersistenceLive } from "../persistence/Layers/Sqlite.ts";
15	import { Layer, ManagedRuntime } from "effect";	15	import { OrchestrationEngineLive } from "./Layer.ts";
16		16	import { OrchestrationEngineService } from "./Service.ts";
17	import { makeSqlitePersistenceLive } from "../persistence/Layers/Sqlite";	17	import { OrchestrationEventRepositoryLive } from "../persistence/Layers/OrchestrationEvents.ts";
18
19	import { OrchestrationEngineLive } from "./Layer";
20	import { OrchestrationEngineService } from "./Service";
21	import { OrchestrationEventRepositoryLive } from "../persistence/Layers/OrchestrationEvents";
22		18
23	const tempDirs: string[] = [];	19	const tempDirs: string[] = [];
24		20
...	@@ -41,7 +37,7 @@ export async function createOrchestrationSystem(stateDir: string) {	...	@@ -41,7 +37,7 @@ export async function createOrchestrationSystem(stateDir: string) {
41	Layer.provide(makeSqlitePersistenceLive(dbPath)),	37	Layer.provide(makeSqlitePersistenceLive(dbPath)),
42	);	38	);
43	const runtime = ManagedRuntime.make(orchestrationLayer);	39	const runtime = ManagedRuntime.make(orchestrationLayer);
44	const engine = await runtime.runPromise(OrchestrationEngineService);	40	const engine = await runtime.runPromise(Effect.service(OrchestrationEngineService));
45	return {	41	return {
46	engine,	42	engine,
47	run: <A, E>(effect: Effect.Effect<A, E>) => runtime.runPromise(effect),	43	run: <A, E>(effect: Effect.Effect<A, E>) => runtime.runPromise(effect),
...	@@ -362,7 +358,7 @@ describe("OrchestrationEngine", () => {	...	@@ -362,7 +358,7 @@ describe("OrchestrationEngine", () => {
362	Layer.provide(Layer.succeed(OrchestrationEventRepository, inMemoryStore)),	358	Layer.provide(Layer.succeed(OrchestrationEventRepository, inMemoryStore)),
363	),	359	),
364	);	360	);
365	await runtime.runPromise(OrchestrationEngineService);	361	await runtime.runPromise(Effect.service(OrchestrationEngineService));
366	await runtime.dispose();	362	await runtime.dispose();
367	await expect(runtime.dispose()).resolves.toBeUndefined();	363	await expect(runtime.dispose()).resolves.toBeUndefined();
368	});	364	});
...	@@ -404,7 +400,7 @@ describe("OrchestrationEngine", () => {	...	@@ -404,7 +400,7 @@ describe("OrchestrationEngine", () => {
404	Layer.provide(Layer.succeed(OrchestrationEventRepository, flakyStore)),	400	Layer.provide(Layer.succeed(OrchestrationEventRepository, flakyStore)),
405	),	401	),
406	);	402	);
407	const engine = await runtime.runPromise(OrchestrationEngineService);	403	const engine = await runtime.runPromise(Effect.service(OrchestrationEngineService));
408	const createdAt = new Date().toISOString();	404	const createdAt = new Date().toISOString();
409		405
410	await expect(	406	await expect(

apps/server/src/orchestration/Layer.ts+10-10

apps/server/src/orchestration/Service.ts+5-5

...	@@ -11,11 +11,11 @@ import type {	...	@@ -11,11 +11,11 @@ import type {
11	OrchestrationEvent,	11	OrchestrationEvent,
12	OrchestrationReadModel,	12	OrchestrationReadModel,
13	} from "@t3tools/contracts";	13	} from "@t3tools/contracts";
14	import { Context } from "effect";	14	import { ServiceMap } from "effect";
15	import type { Effect } from "effect";	15	import type { Effect } from "effect";
16		16
17	import type { OrchestrationDispatchError, OrchestrationEngineError } from "./Errors";	17	import type { OrchestrationDispatchError, OrchestrationEngineError } from "./Errors.ts";
18	import type { OrchestrationEventRepositoryError } from "../persistence/Errors";	18	import type { OrchestrationEventRepositoryError } from "../persistence/Errors.ts";
19		19
20	export interface OrchestrationEngineShape {	20	export interface OrchestrationEngineShape {
21	/**	21	/**
...	@@ -89,7 +89,7 @@ export interface OrchestrationEngineShape {	...	@@ -89,7 +89,7 @@ export interface OrchestrationEngineShape {
89	* })	89	* })
90	* ```	90	* ```
91	*/	91	*/
92	export class OrchestrationEngineService extends Context.Tag("orchestration/Engine")<	92	export class OrchestrationEngineService extends ServiceMap.Service<
93	OrchestrationEngineService,	93	OrchestrationEngineService,
94	OrchestrationEngineShape	94	OrchestrationEngineShape
95	>() {}	95	>()("orchestration/Engine") {}

apps/server/src/orchestration/reducer.test.ts+1-1

...	@@ -2,7 +2,7 @@ import type { OrchestrationEvent } from "@t3tools/contracts";	...	@@ -2,7 +2,7 @@ import type { OrchestrationEvent } from "@t3tools/contracts";
2	import { Effect } from "effect";	2	import { Effect } from "effect";
3	import { describe, expect, it } from "vitest";	3	import { describe, expect, it } from "vitest";
4		4
5	import { createEmptyReadModel, reduceEvent } from "./reducer";	5	import { createEmptyReadModel, reduceEvent } from "./reducer.ts";
6		6
7	describe("orchestration reducer", () => {	7	describe("orchestration reducer", () => {
8	it("applies thread.created events using runtime schema decoding", async () => {	8	it("applies thread.created events using runtime schema decoding", async () => {

apps/server/src/orchestration/reducer.ts+4-4

...	@@ -16,7 +16,7 @@ import {	...	@@ -16,7 +16,7 @@ import {
16	} from "@t3tools/contracts";	16	} from "@t3tools/contracts";
17	import { Effect, Schema } from "effect";	17	import { Effect, Schema } from "effect";
18		18
19	import { toReducerDecodeError, type OrchestrationReducerDecodeError } from "./Errors";	19	import { toReducerDecodeError, type OrchestrationReducerDecodeError } from "./Errors.ts";
20		20
21	type ThreadPatch = Partial<Omit<OrchestrationThread, "id" \| "projectId">>;	21	type ThreadPatch = Partial<Omit<OrchestrationThread, "id" \| "projectId">>;
22		22
...	@@ -34,9 +34,9 @@ function decodeForEvent<A>(	...	@@ -34,9 +34,9 @@ function decodeForEvent<A>(
34	eventType: string,	34	eventType: string,
35	field: string,	35	field: string,
36	): Effect.Effect<A, OrchestrationReducerDecodeError> {	36	): Effect.Effect<A, OrchestrationReducerDecodeError> {
37	return Schema.decodeUnknown(schema)(value).pipe(	37	return Schema.decodeUnknownEffect(schema)(value).pipe(
38	Effect.mapError(toReducerDecodeError(`${eventType}:${field}`)),	38	Effect.mapError(toReducerDecodeError(`${eventType}:${field}`)),
39	);	39	) as Effect.Effect<A, OrchestrationReducerDecodeError>
40	}	40	}
41		41
42	const ThreadCreatedPayloadSchema = Schema.Struct({	42	const ThreadCreatedPayloadSchema = Schema.Struct({
...	@@ -61,7 +61,7 @@ const ThreadMetaUpdatedPayloadSchema = Schema.Struct({	...	@@ -61,7 +61,7 @@ const ThreadMetaUpdatedPayloadSchema = Schema.Struct({
61		61
62	const MessageSentPayloadSchema = Schema.Struct({	62	const MessageSentPayloadSchema = Schema.Struct({
63	id: Schema.String,	63	id: Schema.String,
64	role: Schema.Literal("user", "assistant"),	64	role: Schema.Literals(["user", "assistant"]),
65	text: Schema.String,	65	text: Schema.String,
66	threadId: Schema.String,	66	threadId: Schema.String,
67	createdAt: Schema.String,	67	createdAt: Schema.String,

apps/server/src/persistence/Errors.ts+9-9

...	@@ -1,6 +1,6 @@	...	@@ -1,6 +1,6 @@
1	import { ParseResult, Schema } from "effect";	1	import { Schema, SchemaIssue } from "effect";
2		2
3	export class PersistenceSqlError extends Schema.TaggedError<PersistenceSqlError>()(	3	export class PersistenceSqlError extends Schema.TaggedErrorClass<PersistenceSqlError>()(
4	"PersistenceSqlError",	4	"PersistenceSqlError",
5	{	5	{
6	operation: Schema.String,	6	operation: Schema.String,
...	@@ -13,7 +13,7 @@ export class PersistenceSqlError extends Schema.TaggedError<PersistenceSqlError>	...	@@ -13,7 +13,7 @@ export class PersistenceSqlError extends Schema.TaggedError<PersistenceSqlError>
13	}	13	}
14	}	14	}
15		15
16	export class PersistenceDecodeError extends Schema.TaggedError<PersistenceDecodeError>()(	16	export class PersistenceDecodeError extends Schema.TaggedErrorClass<PersistenceDecodeError>()(
17	"PersistenceDecodeError",	17	"PersistenceDecodeError",
18	{	18	{
19	operation: Schema.String,	19	operation: Schema.String,
...	@@ -26,7 +26,7 @@ export class PersistenceDecodeError extends Schema.TaggedError<PersistenceDecode	...	@@ -26,7 +26,7 @@ export class PersistenceDecodeError extends Schema.TaggedError<PersistenceDecode
26	}	26	}
27	}	27	}
28		28
29	export class PersistenceSerializationError extends Schema.TaggedError<PersistenceSerializationError>()(	29	export class PersistenceSerializationError extends Schema.TaggedErrorClass<PersistenceSerializationError>()(
30	"PersistenceSerializationError",	30	"PersistenceSerializationError",
31	{	31	{
32	operation: Schema.String,	32	operation: Schema.String,
...	@@ -39,7 +39,7 @@ export class PersistenceSerializationError extends Schema.TaggedError<Persistenc	...	@@ -39,7 +39,7 @@ export class PersistenceSerializationError extends Schema.TaggedError<Persistenc
39	}	39	}
40	}	40	}
41		41
42	export class ProjectValidationError extends Schema.TaggedError<ProjectValidationError>()(	42	export class ProjectValidationError extends Schema.TaggedErrorClass<ProjectValidationError>()(
43	"ProjectValidationError",	43	"ProjectValidationError",
44	{	44	{
45	operation: Schema.String,	45	operation: Schema.String,
...	@@ -52,7 +52,7 @@ export class ProjectValidationError extends Schema.TaggedError<ProjectValidation	...	@@ -52,7 +52,7 @@ export class ProjectValidationError extends Schema.TaggedError<ProjectValidation
52	}	52	}
53	}	53	}
54		54
55	export class ProjectPathMissingError extends Schema.TaggedError<ProjectPathMissingError>()(	55	export class ProjectPathMissingError extends Schema.TaggedErrorClass<ProjectPathMissingError>()(
56	"ProjectPathMissingError",	56	"ProjectPathMissingError",
57	{	57	{
58	cwd: Schema.String,	58	cwd: Schema.String,
...	@@ -64,7 +64,7 @@ export class ProjectPathMissingError extends Schema.TaggedError<ProjectPathMissi	...	@@ -64,7 +64,7 @@ export class ProjectPathMissingError extends Schema.TaggedError<ProjectPathMissi
64	}	64	}
65	}	65	}
66		66
67	export class ProjectNotFoundError extends Schema.TaggedError<ProjectNotFoundError>()(	67	export class ProjectNotFoundError extends Schema.TaggedErrorClass<ProjectNotFoundError>()(
68	"ProjectNotFoundError",	68	"ProjectNotFoundError",
69	{	69	{
70	projectId: Schema.String,	70	projectId: Schema.String,
...	@@ -99,10 +99,10 @@ export function toPersistenceSqlError(operation: string) {	...	@@ -99,10 +99,10 @@ export function toPersistenceSqlError(operation: string) {
99	}	99	}
100		100
101	export function toPersistenceDecodeError(operation: string) {	101	export function toPersistenceDecodeError(operation: string) {
102	return (error: ParseResult.ParseError): PersistenceDecodeError =>	102	return (error: Schema.SchemaError): PersistenceDecodeError =>
103	new PersistenceDecodeError({	103	new PersistenceDecodeError({
104	operation,	104	operation,
105	issue: ParseResult.TreeFormatter.formatErrorSync(error),	105	issue: SchemaIssue.makeFormatterDefault()(error.issue),
106	cause: error,	106	cause: error,
107	});	107	});
108	}	108	}

apps/server/src/persistence/Layers/OrchestrationEvents.test.ts+13-13

apps/server/src/persistence/Layers/OrchestrationEvents.ts+7-7

...	@@ -1,7 +1,7 @@	...	@@ -1,7 +1,7 @@
1	import type { OrchestrationEvent } from "@t3tools/contracts";	1	import type { OrchestrationEvent } from "@t3tools/contracts";
2	import { OrchestrationEventSchema } from "@t3tools/contracts";	2	import { OrchestrationEventSchema } from "@t3tools/contracts";
3	import * as SqlClient from "@effect/sql/SqlClient";	3	import * as SqlClient from "effect/unstable/sql/SqlClient";
4	import * as SqlSchema from "@effect/sql/SqlSchema";	4	import * as SqlSchema from "effect/unstable/sql/SqlSchema";
5	import { Effect, Layer, Schema } from "effect";	5	import { Effect, Layer, Schema } from "effect";
6		6
7	import {	7	import {
...	@@ -10,14 +10,14 @@ import {	...	@@ -10,14 +10,14 @@ import {
10	toPersistenceSerializationError,	10	toPersistenceSerializationError,
11	toPersistenceSqlError,	11	toPersistenceSqlError,
12	type OrchestrationEventRepositoryError,	12	type OrchestrationEventRepositoryError,
13	} from "../Errors";	13	} from "../Errors.ts";
14	import { makeSqlitePersistenceLive } from "./Sqlite";	14	import { makeSqlitePersistenceLive } from "./Sqlite.ts";
15	import {	15	import {
16	OrchestrationEventRepository,	16	OrchestrationEventRepository,
17	type OrchestrationEventRepositoryShape,	17	type OrchestrationEventRepositoryShape,
18	} from "../Services/OrchestrationEvents";	18	} from "../Services/OrchestrationEvents.ts";
19		19
20	const decodeEvent = Schema.decodeUnknown(OrchestrationEventSchema);	20	const decodeEvent = Schema.decodeUnknownEffect(OrchestrationEventSchema);
21		21
22	const EventRowSchema = Schema.Struct({	22	const EventRowSchema = Schema.Struct({
23	sequence: Schema.Number,	23	sequence: Schema.Number,
...	@@ -73,7 +73,7 @@ function eventRowToOrchestrationEvent(	...	@@ -73,7 +73,7 @@ function eventRowToOrchestrationEvent(
73	const makeRepository = Effect.gen(function* () {	73	const makeRepository = Effect.gen(function* () {
74	const sql = yield* SqlClient.SqlClient;	74	const sql = yield* SqlClient.SqlClient;
75		75
76	const appendEventRow = SqlSchema.single({	76	const appendEventRow = SqlSchema.findOne({
77	Request: AppendEventRequestSchema,	77	Request: AppendEventRequestSchema,
78	Result: EventRowSchema,	78	Result: EventRowSchema,
79	execute: (request) =>	79	execute: (request) =>

apps/server/src/persistence/Layers/Projects.test.ts+7-7

apps/server/src/persistence/Layers/Projects.ts+10-10

...	@@ -19,8 +19,8 @@ import {	...	@@ -19,8 +19,8 @@ import {
19	projectScriptsSchema,	19	projectScriptsSchema,
20	projectUpdateScriptsInputSchema,	20	projectUpdateScriptsInputSchema,
21	} from "@t3tools/contracts";	21	} from "@t3tools/contracts";
22	import * as SqlClient from "@effect/sql/SqlClient";	22	import * as SqlClient from "effect/unstable/sql/SqlClient";
23	import * as SqlSchema from "@effect/sql/SqlSchema";	23	import * as SqlSchema from "effect/unstable/sql/SqlSchema";
24	import { Effect, Layer, Option, Schema } from "effect";	24	import { Effect, Layer, Option, Schema } from "effect";
25		25
26	import {	26	import {
...	@@ -32,8 +32,8 @@ import {	...	@@ -32,8 +32,8 @@ import {
32	toPersistenceSerializationError,	32	toPersistenceSerializationError,
33	toPersistenceSqlError,	33	toPersistenceSqlError,
34	type ProjectRepositoryError,	34	type ProjectRepositoryError,
35	} from "../Errors";	35	} from "../Errors.ts";
36	import { ProjectRepository, type ProjectRepositoryShape } from "../Services/Projects";	36	import { ProjectRepository, type ProjectRepositoryShape } from "../Services/Projects.ts";
37		37
38	const ProjectRowSchema = Schema.Struct({	38	const ProjectRowSchema = Schema.Struct({
39	id: Schema.String,	39	id: Schema.String,
...	@@ -226,7 +226,7 @@ const makeRepository = Effect.gen(function* () {	...	@@ -226,7 +226,7 @@ const makeRepository = Effect.gen(function* () {
226	`,	226	`,
227	});	227	});
228		228
229	const findProjectById = SqlSchema.findOne({	229	const findProjectById = SqlSchema.findOneOption({
230	Request: FindByIdRequestSchema,	230	Request: FindByIdRequestSchema,
231	Result: ProjectRowSchema,	231	Result: ProjectRowSchema,
232	execute: ({ id }) =>	232	execute: ({ id }) =>
...	@@ -243,7 +243,7 @@ const makeRepository = Effect.gen(function* () {	...	@@ -243,7 +243,7 @@ const makeRepository = Effect.gen(function* () {
243	`,	243	`,
244	});	244	});
245		245
246	const findProjectByCwd = SqlSchema.findOne({	246	const findProjectByCwd = SqlSchema.findOneOption({
247	Request: FindByCwdRequestSchema,	247	Request: FindByCwdRequestSchema,
248	Result: ProjectRowSchema,	248	Result: ProjectRowSchema,
249	execute: ({ cwd }) =>	249	execute: ({ cwd }) =>
...	@@ -260,7 +260,7 @@ const makeRepository = Effect.gen(function* () {	...	@@ -260,7 +260,7 @@ const makeRepository = Effect.gen(function* () {
260	`,	260	`,
261	});	261	});
262		262
263	const insertProject = SqlSchema.single({	263	const insertProject = SqlSchema.findOne({
264	Request: InsertProjectRequestSchema,	264	Request: InsertProjectRequestSchema,
265	Result: ProjectRowSchema,	265	Result: ProjectRowSchema,
266	execute: (request) =>	266	execute: (request) =>
...	@@ -291,7 +291,7 @@ const makeRepository = Effect.gen(function* () {	...	@@ -291,7 +291,7 @@ const makeRepository = Effect.gen(function* () {
291	`,	291	`,
292	});	292	});
293		293
294	const updateProjectScripts = SqlSchema.single({	294	const updateProjectScripts = SqlSchema.findOne({
295	Request: UpdateScriptsRequestSchema,	295	Request: UpdateScriptsRequestSchema,
296	Result: ProjectRowSchema,	296	Result: ProjectRowSchema,
297	execute: (request) =>	297	execute: (request) =>
...	@@ -381,7 +381,7 @@ const makeRepository = Effect.gen(function* () {	...	@@ -381,7 +381,7 @@ const makeRepository = Effect.gen(function* () {
381	Effect.mapError(toPersistenceSqlError("ProjectRepository.remove:findById")),	381	Effect.mapError(toPersistenceSqlError("ProjectRepository.remove:findById")),
382	);	382	);
383	if (Option.isNone(existing)) {	383	if (Option.isNone(existing)) {
384	return yield* Effect.fail(new ProjectNotFoundError({ projectId: input.id }));	384	return yield* (new ProjectNotFoundError({ projectId: input.id }));
385	}	385	}
386		386
387	yield* deleteProject({ id: input.id }).pipe(	387	yield* deleteProject({ id: input.id }).pipe(
...	@@ -396,7 +396,7 @@ const makeRepository = Effect.gen(function* () {	...	@@ -396,7 +396,7 @@ const makeRepository = Effect.gen(function* () {
396	Effect.mapError(toPersistenceSqlError("ProjectRepository.updateScripts:findById")),	396	Effect.mapError(toPersistenceSqlError("ProjectRepository.updateScripts:findById")),
397	);	397	);
398	if (Option.isNone(existing)) {	398	if (Option.isNone(existing)) {
399	return yield* Effect.fail(new ProjectNotFoundError({ projectId: input.id }));	399	return yield* (new ProjectNotFoundError({ projectId: input.id }));
400	}	400	}
401		401
402	const nextScripts = yield* parseProjectScripts(	402	const nextScripts = yield* parseProjectScripts(

apps/server/src/persistence/Layers/Sqlite.ts+12-9

...	@@ -1,30 +1,32 @@	...	@@ -1,30 +1,32 @@
1	import fs from "node:fs";	1	import fs from "node:fs";
2	import path from "node:path";	2	import path from "node:path";
3		3
4	import * as SqlClient from "@effect/sql/SqlClient";	4	import * as SqlClient from "effect/unstable/sql/SqlClient";
5	import * as SqliteClient from "@effect/sql-sqlite-node/SqliteClient";	5	import * as SqliteClient from "@effect/sql-sqlite-node/SqliteClient";
6	import { Context, Effect, Layer } from "effect";	6	import { Effect, Layer, ServiceMap } from "effect";
7		7
8	import { runMigrations } from "../Migrations";	8
		9
		10	import { runMigrations } from "../Migrations.ts";
9		11
10	export interface PersistenceConfigShape {	12	export interface PersistenceConfigShape {
11	readonly dbPath: string;	13	readonly dbPath: string;
12	}	14	}
13		15
14	export class PersistenceConfig extends Context.Tag("persistence/Config")<	16	export class PersistenceConfig extends ServiceMap.Service<
15	PersistenceConfig,	17	PersistenceConfig,
16	PersistenceConfigShape	18	PersistenceConfigShape
17	>() {}	19	>()("persistence/Config") {}
18		20
19	export function makeSqlitePersistenceLive(dbPath: string) {	21	export function makeSqlitePersistenceLive(dbPath: string) {
20	const SqliteClientLive = Layer.unwrapEffect(	22	const SqliteClientLive = Layer.unwrap(
21	Effect.sync(() => {	23	Effect.sync(() => {
22	fs.mkdirSync(path.dirname(dbPath), { recursive: true });	24	fs.mkdirSync(path.dirname(dbPath), { recursive: true });
23	return SqliteClient.layer({ filename: dbPath });	25	return SqliteClient.layer({ filename: dbPath });
24	}),	26	}),
25	);	27	);
26		28
27	return Layer.scoped(	29	return Layer.effect(
28	SqlClient.SqlClient,	30	SqlClient.SqlClient,
29	Effect.gen(function* () {	31	Effect.gen(function* () {
30	const sql = yield* SqliteClient.SqliteClient;	32	const sql = yield* SqliteClient.SqliteClient;
...	@@ -36,6 +38,7 @@ export function makeSqlitePersistenceLive(dbPath: string) {	...	@@ -36,6 +38,7 @@ export function makeSqlitePersistenceLive(dbPath: string) {
36	).pipe(Layer.provide(SqliteClientLive));	38	).pipe(Layer.provide(SqliteClientLive));
37	}	39	}
38		40
39	export const SqlitePersistenceLive = Layer.unwrapEffect(	41
40	Effect.map(PersistenceConfig, ({ dbPath }) => makeSqlitePersistenceLive(dbPath)),	42	export const SqlitePersistenceLive = Layer.unwrap(
		43	Effect.map(Effect.service(PersistenceConfig), ({ dbPath }) => makeSqlitePersistenceLive(dbPath)),
41	);	44	);

apps/server/src/persistence/Migrations.ts+4-4

...	@@ -8,7 +8,7 @@	...	@@ -8,7 +8,7 @@
8	* ensuring the database schema is always up-to-date before the application starts.	8	* ensuring the database schema is always up-to-date before the application starts.
9	*/	9	*/
10		10
11	import * as Migrator from "@effect/sql/Migrator";	11	import * as Migrator from "effect/unstable/sql/Migrator";
12	import * as Layer from "effect/Layer";	12	import * as Layer from "effect/Layer";
13		13
14	// Import all migrations statically	14	// Import all migrations statically
...	@@ -57,11 +57,11 @@ export const runMigrations = run({ loader });	...	@@ -57,11 +57,11 @@ export const runMigrations = run({ loader });
57	* @example	57	* @example
58	* ```typescript	58	* ```typescript
59	* import { MigrationsLive } from "@acme/db/Migrations"	59	* import { MigrationsLive } from "@acme/db/Migrations"
60	* import { PgClient } from "@effect/sql-pg"	60	* import { SqliteClient } from "@effect/sql-sqlite-node"
61	*	61	*
62	* // Migrations run automatically when PgClient is provided	62	* // Migrations run automatically when SqliteClient is provided
63	* const AppLayer = MigrationsLive.pipe(	63	* const AppLayer = MigrationsLive.pipe(
64	* Layer.provideMerge(PgClient.layer({ url: Redacted.make("postgresql://...") }))	64	* Layer.provideMerge(SqliteClient.layer({ filename: "database.sqlite" }))
65	* )	65	* )
66	* ```	66	* ```
67	*/	67	*/

apps/server/src/persistence/Migrations/001_OrchestrationEvents.ts+1-1

...	@@ -1,4 +1,4 @@	...	@@ -1,4 +1,4 @@
1	import { SqlClient } from "@effect/sql";	1	import * as SqlClient from "effect/unstable/sql/SqlClient";
2	import * as Effect from "effect/Effect";	2	import * as Effect from "effect/Effect";
3		3
4	export default Effect.gen(function* () {	4	export default Effect.gen(function* () {

apps/server/src/persistence/Migrations/002_Projects.ts+1-1

...	@@ -1,4 +1,4 @@	...	@@ -1,4 +1,4 @@
1	import { SqlClient } from "@effect/sql";	1	import * as SqlClient from "effect/unstable/sql/SqlClient";
2	import * as Effect from "effect/Effect";	2	import * as Effect from "effect/Effect";
3		3
4	export default Effect.gen(function* () {	4	export default Effect.gen(function* () {

apps/server/src/persistence/Services/OrchestrationEvents.ts+4-4

...	@@ -7,10 +7,10 @@	...	@@ -7,10 +7,10 @@
7	* @module OrchestrationEventRepository	7	* @module OrchestrationEventRepository
8	*/	8	*/
9	import type { OrchestrationEvent } from "@t3tools/contracts";	9	import type { OrchestrationEvent } from "@t3tools/contracts";
10	import { Context } from "effect";	10	import { ServiceMap } from "effect";
11	import type { Effect } from "effect";	11	import type { Effect } from "effect";
12		12
13	import type { OrchestrationEventRepositoryError } from "../Errors";	13	import type { OrchestrationEventRepositoryError } from "../Errors.ts";
14		14
15	export interface OrchestrationEventRepositoryShape {	15	export interface OrchestrationEventRepositoryShape {
16	/**	16	/**
...	@@ -54,7 +54,7 @@ export interface OrchestrationEventRepositoryShape {	...	@@ -54,7 +54,7 @@ export interface OrchestrationEventRepositoryShape {
54	* })	54	* })
55	* ```	55	* ```
56	*/	56	*/
57	export class OrchestrationEventRepository extends Context.Tag("orchestration/EventRepository")<	57	export class OrchestrationEventRepository extends ServiceMap.Service<
58	OrchestrationEventRepository,	58	OrchestrationEventRepository,
59	OrchestrationEventRepositoryShape	59	OrchestrationEventRepositoryShape
60	>() {}	60	>()("orchestration/EventRepository") {}

apps/server/src/persistence/Services/Projects.ts+4-4

...	@@ -14,10 +14,10 @@ import type {	...	@@ -14,10 +14,10 @@ import type {
14	ProjectUpdateScriptsInput,	14	ProjectUpdateScriptsInput,
15	ProjectUpdateScriptsResult,	15	ProjectUpdateScriptsResult,
16	} from "@t3tools/contracts";	16	} from "@t3tools/contracts";
17	import { Context } from "effect";	17	import { ServiceMap } from "effect";
18	import type { Effect } from "effect";	18	import type { Effect } from "effect";
19		19
20	import type { ProjectRepositoryError } from "../Errors";	20	import type { ProjectRepositoryError } from "../Errors.ts";
21		21
22	export interface ProjectRepositoryShape {	22	export interface ProjectRepositoryShape {
23	/**	23	/**
...	@@ -72,7 +72,7 @@ export interface ProjectRepositoryShape {	...	@@ -72,7 +72,7 @@ export interface ProjectRepositoryShape {
72	* })	72	* })
73	* ```	73	* ```
74	*/	74	*/
75	export class ProjectRepository extends Context.Tag("persistence/ProjectRepository")<	75	export class ProjectRepository extends ServiceMap.Service<
76	ProjectRepository,	76	ProjectRepository,
77	ProjectRepositoryShape	77	ProjectRepositoryShape
78	>() {}	78	>()("persistence/ProjectRepository") {}

apps/server/src/wsServer.test.ts+2-2

...	@@ -3,7 +3,7 @@ import os from "node:os";	...	@@ -3,7 +3,7 @@ import os from "node:os";
3	import path from "node:path";	3	import path from "node:path";
4	import { EventEmitter } from "node:events";	4	import { EventEmitter } from "node:events";
5		5
6	import { Layer, ManagedRuntime } from "effect";	6	import { Effect, Layer, ManagedRuntime } from "effect";
7	import { describe, expect, it, afterEach, vi } from "vitest";	7	import { describe, expect, it, afterEach, vi } from "vitest";
8	import { createServer } from "./wsServer";	8	import { createServer } from "./wsServer";
9	import WebSocket from "ws";	9	import WebSocket from "ws";
...	@@ -1039,7 +1039,7 @@ describe("WebSocket Server", () => {	...	@@ -1039,7 +1039,7 @@ describe("WebSocket Server", () => {
1039	Layer.provide(makeSqlitePersistenceLive(path.join(stateDir, "orchestration.sqlite"))),	1039	Layer.provide(makeSqlitePersistenceLive(path.join(stateDir, "orchestration.sqlite"))),
1040	),	1040	),
1041	);	1041	);
1042	const projectRepository = await projectRuntime.runPromise(ProjectRepository);	1042	const projectRepository = await projectRuntime.runPromise(Effect.service(ProjectRepository));
1043	await projectRuntime.runPromise(projectRepository.add({ cwd: existing }));	1043	await projectRuntime.runPromise(projectRepository.add({ cwd: existing }));
1044	await projectRuntime.runPromise(projectRepository.add({ cwd: missing }));	1044	await projectRuntime.runPromise(projectRepository.add({ cwd: missing }));
1045	await projectRuntime.dispose();	1045	await projectRuntime.dispose();

apps/server/src/wsServer.ts+3-3

...	@@ -18,7 +18,7 @@ import {	...	@@ -18,7 +18,7 @@ import {
18	type WsResponse,	18	type WsResponse,
19	wsRequestSchema,	19	wsRequestSchema,
20	} from "@t3tools/contracts";	20	} from "@t3tools/contracts";
21	import { Layer, ManagedRuntime } from "effect";	21	import { Effect, Layer, ManagedRuntime } from "effect";
22	import { WebSocketServer, type WebSocket } from "ws";	22	import { WebSocketServer, type WebSocket } from "ws";
23		23
24	import { createLogger } from "./logger";	24	import { createLogger } from "./logger";
...	@@ -747,8 +747,8 @@ export function createServer(options: ServerOptions) {	...	@@ -747,8 +747,8 @@ export function createServer(options: ServerOptions) {
747		747
748	try {	748	try {
749	const [nextOrchestrationEngine, repository] = await Promise.all([	749	const [nextOrchestrationEngine, repository] = await Promise.all([
750	runtime.runPromise(OrchestrationEngineService),	750	runtime.runPromise(Effect.service(OrchestrationEngineService)),
751	runtime.runPromise(ProjectRepository),	751	runtime.runPromise(Effect.service(ProjectRepository)),
752	]);	752	]);
753	orchestrationEngine = nextOrchestrationEngine;	753	orchestrationEngine = nextOrchestrationEngine;
754	projectRepository = repository;	754	projectRepository = repository;

bun.lock+40-54

 @@ -34,22 +34,22 @@
         "t3": "./dist/index.mjs",
       },
       "dependencies": {
-        "@effect/platform": "^0.94.5",
+        "@effect/platform-node": "4.0.0-beta.10",
-        "@effect/platform-node": "^0.104.1",
+        "@effect/sql-sqlite-node": "4.0.0-beta.10",
-        "@effect/sql": "^0.49.0",
+        "effect": "4.0.0-beta.10",
-        "@effect/sql-sqlite-node": "^0.50.1",
-        "effect": "^3.19.19",
         "node-pty": "^1.1.0",
         "open": "^10.1.0",
         "ws": "^8.18.0",
       },
       "devDependencies": {
+        "@effect/vitest": "4.0.0-beta.10",
         "@t3tools/contracts": "workspace:*",
         "@t3tools/web": "workspace:*",
         "@types/node": "^22.10.2",
         "@types/ws": "^8.5.13",
         "tsdown": "^0.20.3",
         "typescript": "^5.7.3",
+        "vitest": "^4.0.0",
       },
     },
     "apps/web": {
 @@ -92,7 +92,7 @@
       "name": "@t3tools/contracts",
       "version": "0.0.0",
       "dependencies": {
-        "effect": "^3.19.19",
+        "effect": "4.0.0-beta.10",
         "zod": "^3.24.1",
       },
       "devDependencies": {
 @@ -150,23 +150,13 @@
     "@base-ui/utils": ["@base-ui/utils@0.2.5", "", { "dependencies": { "@babel/runtime": "^7.28.6", "@floating-ui/utils": "^0.2.10", "reselect": "^5.1.1", "use-sync-external-store": "^1.6.0" }, "peerDependencies": { "@types/react": "^17 || ^18 || ^19", "react": "^17 || ^18 || ^19", "react-dom": "^17 || ^18 || ^19" }, "optionalPeers": ["@types/react"] }, "sha512-oYC7w0gp76RI5MxprlGLV0wze0SErZaRl3AAkeP3OnNB/UBMb6RqNf6ZSIlxOc9Qp68Ab3C2VOcJQyRs7Xc7Vw=="],
-    "@effect/cluster": ["@effect/cluster@0.56.4", "", { "dependencies": { "kubernetes-types": "^1.30.0" }, "peerDependencies": { "@effect/platform": "^0.94.5", "@effect/rpc": "^0.73.1", "@effect/sql": "^0.49.0", "@effect/workflow": "^0.16.0", "effect": "^3.19.17" } }, "sha512-7Je5/JlbZOlsSxsbKjr97dJed2cNGWsb+TLNgMcr5mRDbcWlFOTUGvsrisEJV6waosYLIg+2omPdvnvRoYKdhA=="],
+    "@effect/platform-node": ["@effect/platform-node@4.0.0-beta.10", "", { "dependencies": { "@effect/platform-node-shared": "^4.0.0-beta.10", "mime": "^4.1.0", "undici": "^7.20.0" }, "peerDependencies": { "effect": "^4.0.0-beta.10", "ioredis": "^5.7.0" } }, "sha512-ikZ/uyos5okYAHE+wWOwZkHgriFUTY3aY8Kdqbj/ro8xw0z9YXWN4fbyQAZUWkBcieDKS36N+QfHRMPG4fEWRA=="],
-    "@effect/experimental": ["@effect/experimental@0.58.0", "", { "dependencies": { "uuid": "^11.0.3" }, "peerDependencies": { "@effect/platform": "^0.94.0", "effect": "^3.19.13", "ioredis": "^5", "lmdb": "^3" }, "optionalPeers": ["ioredis", "lmdb"] }, "sha512-IEP9sapjF6rFy5TkoqDPc86st/fnqUfjT7Xa3pWJrFGr1hzaMXHo+mWsYOZS9LAOVKnpHuVziDK97EP5qsCHVA=="],
-    "@effect/platform": ["@effect/platform@0.94.5", "", { "dependencies": { "find-my-way-ts": "^0.1.6", "msgpackr": "^1.11.4", "multipasta": "^0.2.7" }, "peerDependencies": { "effect": "^3.19.17" } }, "sha512-z05APUiDDPbodhTkH/RJqOLoCU11bU2IZLfcwLFrld03+ob1VeqRnELQlmueLIYm6NZifHAtjl32V+GRt34y4A=="],
-    "@effect/platform-node": ["@effect/platform-node@0.104.1", "", { "dependencies": { "@effect/platform-node-shared": "^0.57.1", "mime": "^3.0.0", "undici": "^7.10.0", "ws": "^8.18.2" }, "peerDependencies": { "@effect/cluster": "^0.56.1", "@effect/platform": "^0.94.2", "@effect/rpc": "^0.73.0", "@effect/sql": "^0.49.0", "effect": "^3.19.15" } }, "sha512-jT1a/z98niK6fnEU8pWHPPCdJMVDRCIdB65lolcOjse5rsTwVbczMjvKkhVQpF63mNWoOnol7OTRNkw5L54llg=="],
-    "@effect/platform-node-shared": ["@effect/platform-node-shared@0.57.1", "", { "dependencies": { "@parcel/watcher": "^2.5.1", "multipasta": "^0.2.7", "ws": "^8.18.2" }, "peerDependencies": { "@effect/cluster": "^0.56.1", "@effect/platform": "^0.94.2", "@effect/rpc": "^0.73.0", "@effect/sql": "^0.49.0", "effect": "^3.19.15" } }, "sha512-oX/bApMdoKsyrDiNdJxo7U9Rz1RXsjRv+ecfAPp1qGlSdGIo32wVRvJ2XCHqYj0sqaYJS0pU0/GCulRfVGuJag=="],
+    "@effect/platform-node-shared": ["@effect/platform-node-shared@4.0.0-beta.10", "", { "dependencies": { "@types/ws": "^8.18.1", "ws": "^8.19.0" }, "peerDependencies": { "effect": "^4.0.0-beta.10" } }, "sha512-gBSeOG2bfchXFdgdi5oipHKynOzSd7BlzTy5QcjFOoCUTtLP9igqohPB9hTkV3a6seWE2JJqsgsQ79VuLb7fAg=="],
-    "@effect/rpc": ["@effect/rpc@0.73.2", "", { "dependencies": { "msgpackr": "^1.11.4" }, "peerDependencies": { "@effect/platform": "^0.94.5", "effect": "^3.19.18" } }, "sha512-td7LHDgBOYKg+VgGWEelD8rSAmvjXz7am17vfxZROX5qIYuvH7drL/z4p5xQFadhHZ7DYdlFpqdO9ggc77OCIw=="],
+    "@effect/sql-sqlite-node": ["@effect/sql-sqlite-node@4.0.0-beta.10", "", { "dependencies": { "better-sqlite3": "^12.6.2" }, "peerDependencies": { "effect": "^4.0.0-beta.10" } }, "sha512-oQl+gF31HaVM9R8YEpf96CIJypP1Roa5z1VPj8s7ZP+3aCtRVor1K+eMxYNAb8ph7R68Tz0LpmVkefq0mEI3CA=="],
-    "@effect/sql": ["@effect/sql@0.49.0", "", { "dependencies": { "uuid": "^11.0.3" }, "peerDependencies": { "@effect/experimental": "^0.58.0", "@effect/platform": "^0.94.0", "effect": "^3.19.13" } }, "sha512-9UEKR+z+MrI/qMAmSvb/RiD9KlgIazjZUCDSpwNgm0lEK9/Q6ExEyfziiYFVCPiptp52cBw8uBHRic8hHnwqXA=="],
+    "@effect/vitest": ["@effect/vitest@4.0.0-beta.10", "", { "peerDependencies": { "effect": "^4.0.0-beta.10", "vitest": "^3.0.0" } }, "sha512-WmE8vCNw+eDoAq9CwwymrAdIBw1f+8hDP3AUF7jyC7/Cj/kyAYOFwkbtKmDXIFaTlf7G/2fmulEXeCO5W8j0kQ=="],
-    "@effect/sql-sqlite-node": ["@effect/sql-sqlite-node@0.50.1", "", { "dependencies": { "better-sqlite3": "^12.6.2" }, "peerDependencies": { "@effect/experimental": "^0.58.0", "@effect/platform": "^0.94.4", "@effect/sql": "^0.49.0", "effect": "^3.19.16" } }, "sha512-L7DlHcOVl9/9V5stttFyv9wjvA9PBbaXwsp9pU+KN8KqokWgAVBNBEDf/dVfboUrynbDpDWwMU9SJmRJ1LXASQ=="],
-    "@effect/workflow": ["@effect/workflow@0.16.0", "", { "peerDependencies": { "@effect/experimental": "^0.58.0", "@effect/platform": "^0.94.0", "@effect/rpc": "^0.73.0", "effect": "^3.19.13" } }, "sha512-MiAdlxx3TixkgHdbw+Yf1Z3tHAAE0rOQga12kIydJqj05Fnod+W/I+kQGRMY/XWRg+QUsVxhmh1qTr7Ype6lrw=="],
     "@electron/get": ["@electron/get@2.0.3", "", { "dependencies": { "debug": "^4.1.1", "env-paths": "^2.2.0", "fs-extra": "^8.1.0", "got": "^11.8.5", "progress": "^2.0.3", "semver": "^6.2.0", "sumchecker": "^3.0.1" }, "optionalDependencies": { "global-agent": "^3.0.0" } }, "sha512-Qkzpg2s9GnVV2I2BjRksUi43U5e6+zaQMcjoJy0C+C5oxaKl+fmckGDQFtRpZpZV0NQekuZZ+tGz7EA9TVnQtQ=="],
 @@ -258,6 +248,8 @@
     "@inquirer/type": ["@inquirer/type@3.0.10", "", { "peerDependencies": { "@types/node": ">=18" }, "optionalPeers": ["@types/node"] }, "sha512-BvziSRxfz5Ov8ch0z/n3oijRSEcEsHnhggm4xFZe93DHcUCTlutlq9Ox4SVENAfcRD22UQq7T/atg9Wr3k09eA=="],
+    "@ioredis/commands": ["@ioredis/commands@1.5.0", "", {}, "sha512-eUgLqrMf8nJkZxT24JvVRrQya1vZkQh8BBeYNwGDqa5I0VUi8ACx7uFvAaLxintokpTenkK6DASvo/bvNbBGow=="],
     "@jridgewell/gen-mapping": ["@jridgewell/gen-mapping@0.3.13", "", { "dependencies": { "@jridgewell/sourcemap-codec": "^1.5.0", "@jridgewell/trace-mapping": "^0.3.24" } }, "sha512-2kkt/7niJ6MgEPxF0bYdQ6etZaA+fQvDcLKckhy1yIQOzaoKjBBjSj63/aLVjYE3qhRt5dvM+uUyfCg6UKCBbA=="],
     "@jridgewell/remapping": ["@jridgewell/remapping@2.3.5", "", { "dependencies": { "@jridgewell/gen-mapping": "^0.3.5", "@jridgewell/trace-mapping": "^0.3.24" } }, "sha512-LI9u/+laYG4Ds1TDKSJW2YPrIlcVYOwi2fUC6xB43lueCjgxV4lffOCZCtYFiH6TNOX+tQKXx97T4IKHbhyHEQ=="],
 @@ -348,34 +340,6 @@
     "@oxlint/binding-win32-x64-msvc": ["@oxlint/binding-win32-x64-msvc@1.46.0", "", { "os": "win32", "cpu": "x64" }, "sha512-DJbQsSJUr4KSi9uU0QqOgI7PX2C+fKGZX+YDprt3vM2sC0dWZsgVTLoN2vtkNyEWJSY2mnvRFUshWXT3bmo0Ug=="],
-    "@parcel/watcher": ["@parcel/watcher@2.5.6", "", { "dependencies": { "detect-libc": "^2.0.3", "is-glob": "^4.0.3", "node-addon-api": "^7.0.0", "picomatch": "^4.0.3" }, "optionalDependencies": { "@parcel/watcher-android-arm64": "2.5.6", "@parcel/watcher-darwin-arm64": "2.5.6", "@parcel/watcher-darwin-x64": "2.5.6", "@parcel/watcher-freebsd-x64": "2.5.6", "@parcel/watcher-linux-arm-glibc": "2.5.6", "@parcel/watcher-linux-arm-musl": "2.5.6", "@parcel/watcher-linux-arm64-glibc": "2.5.6", "@parcel/watcher-linux-arm64-musl": "2.5.6", "@parcel/watcher-linux-x64-glibc": "2.5.6", "@parcel/watcher-linux-x64-musl": "2.5.6", "@parcel/watcher-win32-arm64": "2.5.6", "@parcel/watcher-win32-ia32": "2.5.6", "@parcel/watcher-win32-x64": "2.5.6" } }, "sha512-tmmZ3lQxAe/k/+rNnXQRawJ4NjxO2hqiOLTHvWchtGZULp4RyFeh6aU4XdOYBFe2KE1oShQTv4AblOs2iOrNnQ=="],
-    "@parcel/watcher-android-arm64": ["@parcel/watcher-android-arm64@2.5.6", "", { "os": "android", "cpu": "arm64" }, "sha512-YQxSS34tPF/6ZG7r/Ih9xy+kP/WwediEUsqmtf0cuCV5TPPKw/PQHRhueUo6JdeFJaqV3pyjm0GdYjZotbRt/A=="],
-    "@parcel/watcher-darwin-arm64": ["@parcel/watcher-darwin-arm64@2.5.6", "", { "os": "darwin", "cpu": "arm64" }, "sha512-Z2ZdrnwyXvvvdtRHLmM4knydIdU9adO3D4n/0cVipF3rRiwP+3/sfzpAwA/qKFL6i1ModaabkU7IbpeMBgiVEA=="],
-    "@parcel/watcher-darwin-x64": ["@parcel/watcher-darwin-x64@2.5.6", "", { "os": "darwin", "cpu": "x64" }, "sha512-HgvOf3W9dhithcwOWX9uDZyn1lW9R+7tPZ4sug+NGrGIo4Rk1hAXLEbcH1TQSqxts0NYXXlOWqVpvS1SFS4fRg=="],
-    "@parcel/watcher-freebsd-x64": ["@parcel/watcher-freebsd-x64@2.5.6", "", { "os": "freebsd", "cpu": "x64" }, "sha512-vJVi8yd/qzJxEKHkeemh7w3YAn6RJCtYlE4HPMoVnCpIXEzSrxErBW5SJBgKLbXU3WdIpkjBTeUNtyBVn8TRng=="],
-    "@parcel/watcher-linux-arm-glibc": ["@parcel/watcher-linux-arm-glibc@2.5.6", "", { "os": "linux", "cpu": "arm" }, "sha512-9JiYfB6h6BgV50CCfasfLf/uvOcJskMSwcdH1PHH9rvS1IrNy8zad6IUVPVUfmXr+u+Km9IxcfMLzgdOudz9EQ=="],
-    "@parcel/watcher-linux-arm-musl": ["@parcel/watcher-linux-arm-musl@2.5.6", "", { "os": "linux", "cpu": "arm" }, "sha512-Ve3gUCG57nuUUSyjBq/MAM0CzArtuIOxsBdQ+ftz6ho8n7s1i9E1Nmk/xmP323r2YL0SONs1EuwqBp2u1k5fxg=="],
-    "@parcel/watcher-linux-arm64-glibc": ["@parcel/watcher-linux-arm64-glibc@2.5.6", "", { "os": "linux", "cpu": "arm64" }, "sha512-f2g/DT3NhGPdBmMWYoxixqYr3v/UXcmLOYy16Bx0TM20Tchduwr4EaCbmxh1321TABqPGDpS8D/ggOTaljijOA=="],
-    "@parcel/watcher-linux-arm64-musl": ["@parcel/watcher-linux-arm64-musl@2.5.6", "", { "os": "linux", "cpu": "arm64" }, "sha512-qb6naMDGlbCwdhLj6hgoVKJl2odL34z2sqkC7Z6kzir8b5W65WYDpLB6R06KabvZdgoHI/zxke4b3zR0wAbDTA=="],
-    "@parcel/watcher-linux-x64-glibc": ["@parcel/watcher-linux-x64-glibc@2.5.6", "", { "os": "linux", "cpu": "x64" }, "sha512-kbT5wvNQlx7NaGjzPFu8nVIW1rWqV780O7ZtkjuWaPUgpv2NMFpjYERVi0UYj1msZNyCzGlaCWEtzc+exjMGbQ=="],
-    "@parcel/watcher-linux-x64-musl": ["@parcel/watcher-linux-x64-musl@2.5.6", "", { "os": "linux", "cpu": "x64" }, "sha512-1JRFeC+h7RdXwldHzTsmdtYR/Ku8SylLgTU/reMuqdVD7CtLwf0VR1FqeprZ0eHQkO0vqsbvFLXUmYm/uNKJBg=="],
-    "@parcel/watcher-win32-arm64": ["@parcel/watcher-win32-arm64@2.5.6", "", { "os": "win32", "cpu": "arm64" }, "sha512-3ukyebjc6eGlw9yRt678DxVF7rjXatWiHvTXqphZLvo7aC5NdEgFufVwjFfY51ijYEWpXbqF5jtrK275z52D4Q=="],
-    "@parcel/watcher-win32-ia32": ["@parcel/watcher-win32-ia32@2.5.6", "", { "os": "win32", "cpu": "ia32" }, "sha512-k35yLp1ZMwwee3Ez/pxBi5cf4AoBKYXj00CZ80jUz5h8prpiaQsiRPKQMxoLstNuqe2vR4RNPEAEcjEFzhEz/g=="],
-    "@parcel/watcher-win32-x64": ["@parcel/watcher-win32-x64@2.5.6", "", { "os": "win32", "cpu": "x64" }, "sha512-hbQlYcCq5dlAX9Qx+kFb0FHue6vbjlf0FrNzSKdYK2APUf7tGfGxQCk2ihEREmbR6ZMc0MVAD5RIX/41gpUzTw=="],
     "@pierre/diffs": ["@pierre/diffs@1.1.0-beta.16", "", { "dependencies": { "@shikijs/transformers": "^3.0.0", "diff": "8.0.3", "hast-util-to-html": "9.0.5", "lru_map": "0.4.1", "shiki": "^3.0.0" }, "peerDependencies": { "react": "^18.3.1 || ^19.0.0", "react-dom": "^18.3.1 || ^19.0.0" } }, "sha512-McjTuEPuacSIcXdoI2O9W6VSHIOs9ApEHnEUwONKZnKqIo2GGv1vNg9Pr8tgBOL7lgBWNEHX5ROJ5z1X74sENQ=="],
     "@quansync/fs": ["@quansync/fs@1.0.0", "", { "dependencies": { "quansync": "^1.0.0" } }, "sha512-4TJ3DFtlf1L5LDMaM6CanJ/0lckGNtJcMjQ1NAV6zDmA0tEHKZtxNKin8EgPaVX1YzljbxckyT2tJrpQKAtngQ=="],
 @@ -710,6 +674,8 @@
     "clsx": ["clsx@2.1.1", "", {}, "sha512-eYm0QWBtUrBWZWG0d386OGAw16Z995PiOVo2B7bjWSbHedGl5e0ZWaq65kOGgUSNesEIDkB9ISbTg/JK9dhCZA=="],
+    "cluster-key-slot": ["cluster-key-slot@1.1.2", "", {}, "sha512-RMr0FhtfXemyinomL4hrWcYJxmX6deFdCxpJzhDttxgO1+bcCnkk+9drydLVDmAMG7NE6aN/fl4F7ucU/90gAA=="],
     "color-convert": ["color-convert@2.0.1", "", { "dependencies": { "color-name": "~1.1.4" } }, "sha512-RRECPsj7iu/xb5oKYcsFHSppFNnsj/52OVTRKb4zP5onXwVF3zVmmToNcOfGC+CRDpfK/U584fMg38ZHCaElKQ=="],
     "color-name": ["color-name@1.1.4", "", {}, "sha512-dOy+3AuW3a2wNbZHIuMZpTcgjGuLU/uBL/ubcZF9OXbDo8ff4O8yVp5Bf0efS8uEoYo5q4Fx7dY9OgQGXgAsQA=="],
 @@ -750,6 +716,8 @@
     "delayed-stream": ["delayed-stream@1.0.0", "", {}, "sha512-ZySD7Nf91aLB0RxL4KGrKHBXl7Eds1DAmEdcoVawXnLD7SDhpNgtuII2aAkg7a7QS41jxPSZ17p4VdGnMHk3MQ=="],
+    "denque": ["denque@2.1.0", "", {}, "sha512-HVQE3AAb/pxF8fQAoiqpvg9i3evqug3hoiwakOyZAwJm+6vZehbkYXZ0l4JxS+I3QxM97v5aaRNhj8v5oBhekw=="],
     "dequal": ["dequal@2.0.3", "", {}, "sha512-0je+qPKHEMohvfRTCEo3CrPG6cAzAYgmzKyxRiYSSDkS6eGJdyVJm7WaYA5ECaAD9wLB2T4EEeymA5aFVcYXCA=="],
     "detect-libc": ["detect-libc@2.1.2", "", {}, "sha512-Btj2BOOO83o3WyH59e8MgXsxEQVcarkUOpEYrubB0urwnN10yQ364rsiByU11nZlqWYZm05i/of7io4mzihBtQ=="],
 @@ -764,7 +732,7 @@
     "dunder-proto": ["dunder-proto@1.0.1", "", { "dependencies": { "call-bind-apply-helpers": "^1.0.1", "es-errors": "^1.3.0", "gopd": "^1.2.0" } }, "sha512-KIN/nDJBQRcXw0MLVhZE9iQHmG68qAVIBg9CqmUYjmQIhgij9U5MFvrqkUL5FbtyyzZuOeOt0zdeRe4UY7ct+A=="],
-    "effect": ["effect@3.19.19", "", { "dependencies": { "@standard-schema/spec": "^1.0.0", "fast-check": "^3.23.1" } }, "sha512-Yc8U/SVXo2dHnaP7zNBlAo83h/nzSJpi7vph6Hzyl4ulgMBIgPmz3UzOjb9sBgpFE00gC0iETR244sfXDNLHRg=="],
+    "effect": ["effect@4.0.0-beta.10", "", { "dependencies": { "@standard-schema/spec": "^1.1.0", "fast-check": "^4.5.3", "find-my-way-ts": "^0.1.6", "ini": "^6.0.0", "kubernetes-types": "^1.30.0", "msgpackr": "^1.11.8", "multipasta": "^0.2.7", "toml": "^3.0.0", "uuid": "^13.0.0", "yaml": "^2.8.2" } }, "sha512-UvxWmT0uzWZqNmQODfW7y1zb0LMlH3xtSn/UESpck2Wvv6SogxibYPWKKNcUsRMm5wwprOoW2IwItYLQyZpe8Q=="],
     "electron": ["electron@40.6.0", "", { "dependencies": { "@electron/get": "^2.0.0", "@types/node": "^24.9.0", "extract-zip": "^2.0.1" }, "bin": { "electron": "cli.js" } }, "sha512-ett8W+yOFGDuM0vhJMamYSkrbV3LoaffzJd9GfjI96zRAxyrNqUSKqBpf/WGbQCweDxX2pkUCUfrv4wwKpsFZA=="],
 @@ -814,7 +782,7 @@
     "extract-zip": ["extract-zip@2.0.1", "", { "dependencies": { "debug": "^4.1.1", "get-stream": "^5.1.0", "yauzl": "^2.10.0" }, "optionalDependencies": { "@types/yauzl": "^2.9.1" }, "bin": { "extract-zip": "cli.js" } }, "sha512-GDhU9ntwuKyGXdZBUgTIe+vXnWj0fppUEtMDL0+idd5Sta8TGpHssn/eusA9mrPr9qNDym6SxAYZjNvCn/9RBg=="],
-    "fast-check": ["fast-check@3.23.2", "", { "dependencies": { "pure-rand": "^6.1.0" } }, "sha512-h5+1OzzfCC3Ef7VbtKdcv7zsstUQwUDlYpUTvjeUsJAssPgLn7QzbboPtL5ro04Mq0rPOsMzl7q5hIbRs2wD1A=="],
+    "fast-check": ["fast-check@4.5.3", "", { "dependencies": { "pure-rand": "^7.0.0" } }, "sha512-IE9csY7lnhxBnA8g/WI5eg/hygA6MGWJMSNfFRrBlXUciADEhS1EDB0SIsMSvzubzIlOBbVITSsypCsW717poA=="],
     "fd-slicer": ["fd-slicer@1.1.0", "", { "dependencies": { "pend": "~1.2.0" } }, "sha512-cE1qsB/VwyQozZ+q1dGxR8LBYNZeofhEdUNGSMbQD3Gw2lAzX9Zb3uIU6Ebc/Fmyjo9AWWfnn0AUCHqtevs/8g=="],
 @@ -908,10 +876,12 @@
     "inherits": ["inherits@2.0.4", "", {}, "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ=="],
-    "ini": ["ini@1.3.8", "", {}, "sha512-JV/yugV2uzW5iMRSiZAyDtQd+nxtUnjeLt0acNdw98kKLrvuRVyB80tsREOE7yvGVgalhZ6RNXCmEHkUKBKxew=="],
+    "ini": ["ini@6.0.0", "", {}, "sha512-IBTdIkzZNOpqm7q3dRqJvMaldXjDHWkEDfrwGEQTs5eaQMWV+djAhR+wahyNNMAa+qpbDUhBMVt4ZKNwpPm7xQ=="],
     "inline-style-parser": ["inline-style-parser@0.2.7", "", {}, "sha512-Nb2ctOyNR8DqQoR0OwRG95uNWIC0C1lCgf5Naz5H6Ji72KZ8OcFZLz2P5sNgwlyoJ8Yif11oMuYs5pBQa86csA=="],
+    "ioredis": ["ioredis@5.9.3", "", { "dependencies": { "@ioredis/commands": "1.5.0", "cluster-key-slot": "^1.1.0", "debug": "^4.3.4", "denque": "^2.1.0", "lodash.defaults": "^4.2.0", "lodash.isarguments": "^3.1.0", "redis-errors": "^1.2.0", "redis-parser": "^3.0.0", "standard-as-callback": "^2.1.0" } }, "sha512-VI5tMCdeoxZWU5vjHWsiE/Su76JGhBvWF1MJnV9ZtGltHk9BmD48oDq8Tj8haZ85aceXZMxLNDQZRVo5QKNgXA=="],
     "is-alphabetical": ["is-alphabetical@2.0.1", "", {}, "sha512-FWyyY60MeTNyeSRpkM2Iry0G9hpr7/9kD40mD/cGQEuilcZYS4okz8SN2Q6rLCJ8gbCt6fN+rC+6tMGS99LaxQ=="],
     "is-alphanumerical": ["is-alphanumerical@2.0.1", "", { "dependencies": { "is-alphabetical": "^2.0.0", "is-decimal": "^2.0.0" } }, "sha512-hmbYhX/9MUMF5uh7tOXyK/n0ZvWpad5caBA17GsC6vyuCqaWliRG5K1qS9inmUhEMaOBIW7/whAnSwveW/LtZw=="],
 @@ -988,8 +958,12 @@
     "lodash": ["lodash@4.17.23", "", {}, "sha512-LgVTMpQtIopCi79SJeDiP0TfWi5CNEc/L/aRdTh3yIvmZXTnheWpKjSZhnvMl8iXbC1tFg9gdHHDMLoV7CnG+w=="],
+    "lodash.defaults": ["lodash.defaults@4.2.0", "", {}, "sha512-qjxPLHd3r5DnsdGacqOMU6pb/avJzdh9tFX2ymgoZE27BmjXrNy/y4LoaiTeAb+O3gL8AfpJGtqfX/ae2leYYQ=="],
     "lodash.difference": ["lodash.difference@4.5.0", "", {}, "sha512-dS2j+W26TQ7taQBGN8Lbbq04ssV3emRw4NY58WErlTO29pIqS0HmoT5aJ9+TUQ1N3G+JOZSji4eugsWwGp9yPA=="],
+    "lodash.isarguments": ["lodash.isarguments@3.1.0", "", {}, "sha512-chi4NHZlZqZD18a0imDHnZPrDeBbTtVN7GXMwuGdRH9qotxAjYs3aVLKc7zNOG9eddR5Ksd8rvFEBc9SsggPpg=="],
     "longest-streak": ["longest-streak@3.1.0", "", {}, "sha512-9Ri+o0JYgehTaVBBDoMqIl8GXtbWg711O3srftcHhZ0dqnETqLaoIK0x17fUw9rFSlK/0NlsKe0Ahhyl5pXE2g=="],
     "lowercase-keys": ["lowercase-keys@2.0.0", "", {}, "sha512-tqNXrS78oMOE73NMxK4EMLQsQowWf8jKooH9g7xPavRT706R6bkQJ6DY2Te7QukaZsulxa30wQ7bk0pm4XiHmA=="],
 @@ -1098,7 +1072,7 @@
     "micromatch": ["micromatch@4.0.8", "", { "dependencies": { "braces": "^3.0.3", "picomatch": "^2.3.1" } }, "sha512-PXwfBhYu0hBCPw8Dn0E+WDYb7af3dSLVWKi3HGv84IdF4TyFoC0ysxFd0Goxw7nSv4T/PzEJQxsYsEiFCKo2BA=="],
-    "mime": ["mime@3.0.0", "", { "bin": { "mime": "cli.js" } }, "sha512-jSCU7/VB1loIWBZe14aEYHU/+1UMEHoaO7qxCOVJOw9GgH72VAWppxNcjU+x9a2k3GSIBXNKxXQFqRvvZ7vr3A=="],
+    "mime": ["mime@4.1.0", "", { "bin": { "mime": "bin/cli.js" } }, "sha512-X5ju04+cAzsojXKes0B/S4tcYtFAJ6tTMuSPBEn9CPGlrWr8Fiw7qYeLT0XyH80HSoAoqWCaz+MWKh22P7G1cw=="],
     "mime-db": ["mime-db@1.52.0", "", {}, "sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg=="],
 @@ -1188,7 +1162,7 @@
     "pump": ["pump@3.0.3", "", { "dependencies": { "end-of-stream": "^1.1.0", "once": "^1.3.1" } }, "sha512-todwxLMY7/heScKmntwQG8CXVkWUOdYxIvY2s0VWAAMh/nd8SoYiRaKjlr7+iCs984f2P8zvrfWcDDYVb73NfA=="],
-    "pure-rand": ["pure-rand@6.1.0", "", {}, "sha512-bVWawvoZoBYpp6yIoQtQXHZjmz35RSVHnUOTefl8Vcjr8snTPY1wnpSPMWekcFwbxI6gtmT7rSYPFvz71ldiOA=="],
+    "pure-rand": ["pure-rand@7.0.1", "", {}, "sha512-oTUZM/NAZS8p7ANR3SHh30kXB+zK2r2BPcEn/awJIbOvq82WoMN4p62AWWp3Hhw50G0xMsw1mhIBLqHw64EcNQ=="],
     "quansync": ["quansync@1.0.0", "", {}, "sha512-5xZacEEufv3HSTPQuchrvV6soaiACMFnq1H8wkVioctoH3TRha9Sz66lOxRwPK/qZj7HPiSveih9yAyh98gvqA=="],
 @@ -1210,6 +1184,10 @@
     "recast": ["recast@0.23.11", "", { "dependencies": { "ast-types": "^0.16.1", "esprima": "~4.0.0", "source-map": "~0.6.1", "tiny-invariant": "^1.3.3", "tslib": "^2.0.1" } }, "sha512-YTUo+Flmw4ZXiWfQKGcwwc11KnoRAYgzAE2E7mXKCjSviTKShtxBsN6YUUBB2gtaBzKzeKunxhUwNHQuRryhWA=="],
+    "redis-errors": ["redis-errors@1.2.0", "", {}, "sha512-1qny3OExCf0UvUV/5wpYKf2YwPcOqXzkwKKSmKHiE6ZMQs5heeE/c8eXK+PNllPvmjgAbfnsbpkGZWy8cBpn9w=="],
+    "redis-parser": ["redis-parser@3.0.0", "", { "dependencies": { "redis-errors": "^1.0.0" } }, "sha512-DJnGAeenTdpMEH6uAJRK/uiyEIH9WVsUmoLwzudwGJUwZPp80PDBWPHXSAGNPwNvIXAbe7MSUB1zQFugFml66A=="],
     "regex": ["regex@6.1.0", "", { "dependencies": { "regex-utilities": "^2.3.0" } }, "sha512-6VwtthbV4o/7+OaAF9I5L5V3llLEsoPyq9P1JVXkedTP33c7MfCG0/5NOPcSJn0TzXcG9YUrR0gQSWioew3LDg=="],
     "regex-recursion": ["regex-recursion@6.0.2", "", { "dependencies": { "regex-utilities": "^2.3.0" } }, "sha512-0YCaSCq2VRIebiaUviZNs0cBz1kg5kVS2UKUfNIx8YVs1cN3AV7NTctO5FOKBA+UT2BPJIWZauYHPqJODG50cg=="],
 @@ -1290,6 +1268,8 @@
     "stackback": ["stackback@0.0.2", "", {}, "sha512-1XMJE5fQo1jGH6Y/7ebnwPOBEkIEnT4QF32d5R1+VXdXveM0IBMJt8zfaxX1P3QhVwrYe+576+jkANtSS2mBbw=="],
+    "standard-as-callback": ["standard-as-callback@2.1.0", "", {}, "sha512-qoRRSyROncaz1z0mvYqIE4lCd9p2R90i6GxW3uZv5ucSu8tU7B5HXUP1gG8pVZsYNVaXjk8ClXHPttLyxAL48A=="],
     "statuses": ["statuses@2.0.2", "", {}, "sha512-DvEy55V3DB7uknRo+4iOGT5fP1slR8wQohVdknigZPMpMstaKJQWhwiYBACJE3Ul2pTnATihhBYnRhZQHGBiRw=="],
     "std-env": ["std-env@3.10.0", "", {}, "sha512-5GS12FdOZNliM5mAOxFRg7Ir0pWz8MdpYm6AY6VPkGpbA7ZzmbzNcBJQ0GPvvyWgcY7QAhCgf9Uy89I03faLkg=="],
 @@ -1350,6 +1330,8 @@
     "to-regex-range": ["to-regex-range@5.0.1", "", { "dependencies": { "is-number": "^7.0.0" } }, "sha512-65P7iz6X5yEr1cwcgvQxbbIw7Uk3gOy5dIdtZ4rDveLqhrdJP+Li/Hx6tyK0NEb+2GCyneCMJiGqrADCSNk8sQ=="],
+    "toml": ["toml@3.0.0", "", {}, "sha512-y/mWCZinnvxjTKYhJ+pYxwD0mRLVvOtdS2Awbgxln6iEnt4rk0yBxeSBHkGJcPucRiG0e55mwWp+g/05rsrd6w=="],
     "tough-cookie": ["tough-cookie@6.0.0", "", { "dependencies": { "tldts": "^7.0.5" } }, "sha512-kXuRi1mtaKMrsLUxz3sQYvVl37B0Ns6MzfrtV5DvJceE9bPyspOqk9xxv7XbZWcfLWbFmm997vl83qUWVJA64w=="],
     "tree-kill": ["tree-kill@1.2.2", "", { "bin": { "tree-kill": "cli.js" } }, "sha512-L0Orpi8qGpRG//Nd+H90vFB+3iHnue1zSSGmNOOCh1GLJ7rUKVwV2HvijphGQS2UmhUZewS9VgvxYIdgr+fG1A=="],
 @@ -1420,7 +1402,7 @@
     "util-deprecate": ["util-deprecate@1.0.2", "", {}, "sha512-EPD5q1uXyFxJpCrLnCc1nHnq3gOa6DZBocAIiI2TaSCA7VCJ1UJDMagCzIkXNsUYfD1daK//LTEQ8xiIbrHtcw=="],
-    "uuid": ["uuid@11.1.0", "", { "bin": { "uuid": "dist/esm/bin/uuid" } }, "sha512-0/A9rDy9P7cJ+8w1c9WD9V//9Wj15Ce2MPz8Ri6032usz+NfePxx5AcN3bN+r6ZL6jEo066/yNYB3tn4pQEx+A=="],
+    "uuid": ["uuid@13.0.0", "", { "bin": { "uuid": "dist-node/bin/uuid" } }, "sha512-XQegIaBTVUjSHliKqcnFqYypAd4S+WCYt5NIeRs6w/UAry7z8Y9j5ZwRRL4kzq9U3sD6v+85er9FvkEaBpji2w=="],
     "vfile": ["vfile@6.0.3", "", { "dependencies": { "@types/unist": "^3.0.0", "vfile-message": "^4.0.0" } }, "sha512-KzIbH/9tXat2u30jf+smMwFCsno4wHVdNmzFyL+T/L3UGqqk6JKfVqOFOZEpZSHADH1k40ab6NUIXZq422ov3Q=="],
 @@ -1450,6 +1432,8 @@
     "yallist": ["yallist@3.1.1", "", {}, "sha512-a4UGQaWPH59mOXUYnAG2ewncQS4i4F43Tv3JoAM+s2VDAmS9NsK8GpDMLrCHPksFT7h3K6TOoUNn2pb7RoXx4g=="],
+    "yaml": ["yaml@2.8.2", "", { "bin": { "yaml": "bin.mjs" } }, "sha512-mplynKqc1C2hTVYxd0PU2xQAc22TI1vShAYGksCCfxbn/dFwnHTNi1bvYsBTkhdUNtGIf5xNOg938rrSSYvS9A=="],
     "yargs": ["yargs@17.7.2", "", { "dependencies": { "cliui": "^8.0.1", "escalade": "^3.1.1", "get-caller-file": "^2.0.5", "require-directory": "^2.1.1", "string-width": "^4.2.3", "y18n": "^5.0.5", "yargs-parser": "^21.1.1" } }, "sha512-7dSzzRQ++CKnNI/krKnYRV7JKKPUXMEh61soaHKg9mrWEhzFWhFnxPxGl+69cD1Ou63C13NUPCnmIcrvqCuM6w=="],
     "yargs-parser": ["yargs-parser@21.1.1", "", {}, "sha512-tVpsJW7DdjecAiFpbIB1e3qxIQsE6NoPc5/eTdrbbIC4h0LVsWhnoa3g+m2HclBIujHzsxZ4VJVA+GUuc2/LBw=="],
 @@ -1530,6 +1514,8 @@
     "parse-entities/@types/unist": ["@types/unist@2.0.11", "", {}, "sha512-CmBKiL6NNo/OqgmMn95Fk9Whlp2mtvIv+KNpQKN2F4SjvrEesubTRWGYSg+BnWZOnlCaSTU1sMpsBOzgbYhnsA=="],
+    "rc/ini": ["ini@1.3.8", "", {}, "sha512-JV/yugV2uzW5iMRSiZAyDtQd+nxtUnjeLt0acNdw98kKLrvuRVyB80tsREOE7yvGVgalhZ6RNXCmEHkUKBKxew=="],
     "readdirp/picomatch": ["picomatch@2.3.1", "", {}, "sha512-JU3teHTNjmE2VCGFzuY8EXzCDVwEqB2a8fsIvwaStHhAWJEeVd1o1QD80CU6+ZdEXXSLbSsuLwJjkCBWqRQUVA=="],
     "recast/source-map": ["source-map@0.6.1", "", {}, "sha512-UjgapumWlbMhkBgzT7Ykc5YXUT46F0iKu8SGXq0bcwP5dz/h0Plj6enJqjz1Zbq2l5WaqYnrVbwWOWMyF3F47g=="],

packages/contracts/package.json+1-1

...	@@ -23,7 +23,7 @@	...	@@ -23,7 +23,7 @@
23	"test": "vitest run"	23	"test": "vitest run"
24	},	24	},
25	"dependencies": {	25	"dependencies": {
26	"effect": "^3.19.19",	26	"effect": "4.0.0-beta.10",
27	"zod": "^3.24.1"	27	"zod": "^3.24.1"
28	},	28	},
29	"devDependencies": {	29	"devDependencies": {

packages/contracts/src/orchestration.ts+7-7

...	@@ -16,7 +16,7 @@ const IdSchema = Schema.String;	...	@@ -16,7 +16,7 @@ const IdSchema = Schema.String;
16		16
17	export const OrchestrationMessageSchema = Schema.Struct({	17	export const OrchestrationMessageSchema = Schema.Struct({
18	id: IdSchema,	18	id: IdSchema,
19	role: Schema.Literal("user", "assistant"),	19	role: Schema.Literals(["user", "assistant"]),
20	text: Schema.String,	20	text: Schema.String,
21	createdAt: IsoDateTimeSchema,	21	createdAt: IsoDateTimeSchema,
22	streaming: Schema.Boolean,	22	streaming: Schema.Boolean,
...	@@ -26,8 +26,8 @@ export type OrchestrationMessage = Schema.Schema.Type<typeof OrchestrationMessag	...	@@ -26,8 +26,8 @@ export type OrchestrationMessage = Schema.Schema.Type<typeof OrchestrationMessag
26		26
27	export const OrchestrationSessionSchema = Schema.Struct({	27	export const OrchestrationSessionSchema = Schema.Struct({
28	sessionId: IdSchema,	28	sessionId: IdSchema,
29	status: Schema.Literal("connecting", "ready", "running", "error", "closed"),	29	status: Schema.Literals(["connecting", "ready", "running", "error", "closed"]),
30	provider: Schema.Literal("codex", "claudeCode"),	30	provider: Schema.Literals(["codex", "claudeCode"]),
31	threadId: IdSchema,	31	threadId: IdSchema,
32	activeTurnId: Schema.NullOr(Schema.String),	32	activeTurnId: Schema.NullOr(Schema.String),
33	createdAt: IsoDateTimeSchema,	33	createdAt: IsoDateTimeSchema,
...	@@ -94,7 +94,7 @@ export type OrchestrationGitReadModel = Schema.Schema.Type<typeof OrchestrationG	...	@@ -94,7 +94,7 @@ export type OrchestrationGitReadModel = Schema.Schema.Type<typeof OrchestrationG
94	export const OrchestrationReadModelSchema = Schema.Struct({	94	export const OrchestrationReadModelSchema = Schema.Struct({
95	sequence: Schema.Number,	95	sequence: Schema.Number,
96	threads: Schema.Array(OrchestrationThreadSchema),	96	threads: Schema.Array(OrchestrationThreadSchema),
97	gitByProjectId: Schema.Record({ key: Schema.String, value: OrchestrationGitReadModelSchema }),	97	gitByProjectId: Schema.Record( Schema.String, OrchestrationGitReadModelSchema),
98	updatedAt: IsoDateTimeSchema,	98	updatedAt: IsoDateTimeSchema,
99	});	99	});
100		100
...	@@ -135,7 +135,7 @@ export const SendMessageCommandSchema = Schema.Struct({	...	@@ -135,7 +135,7 @@ export const SendMessageCommandSchema = Schema.Struct({
135	commandId: IdSchema,	135	commandId: IdSchema,
136	threadId: IdSchema,	136	threadId: IdSchema,
137	messageId: IdSchema,	137	messageId: IdSchema,
138	role: Schema.Literal("user", "assistant"),	138	role: Schema.Literals(["user", "assistant"]),
139	text: Schema.String,	139	text: Schema.String,
140	streaming: Schema.optional(Schema.Boolean),	140	streaming: Schema.optional(Schema.Boolean),
141	createdAt: IsoDateTimeSchema,	141	createdAt: IsoDateTimeSchema,
...	@@ -182,7 +182,7 @@ export const RevertThreadCommandSchema = Schema.Struct({	...	@@ -182,7 +182,7 @@ export const RevertThreadCommandSchema = Schema.Struct({
182	createdAt: IsoDateTimeSchema,	182	createdAt: IsoDateTimeSchema,
183	});	183	});
184		184
185	export const OrchestrationCommandSchema = Schema.Union(	185	export const OrchestrationCommandSchema = Schema.Union([
186	CreateThreadCommandSchema,	186	CreateThreadCommandSchema,
187	DeleteThreadCommandSchema,	187	DeleteThreadCommandSchema,
188	UpdateThreadMetaCommandSchema,	188	UpdateThreadMetaCommandSchema,
...	@@ -190,7 +190,7 @@ export const OrchestrationCommandSchema = Schema.Union(	...	@@ -190,7 +190,7 @@ export const OrchestrationCommandSchema = Schema.Union(
190	SetThreadSessionSchema,	190	SetThreadSessionSchema,
191	UpsertGitReadModelCommandSchema,	191	UpsertGitReadModelCommandSchema,
192	CompleteThreadTurnDiffCommandSchema,	192	CompleteThreadTurnDiffCommandSchema,
193	RevertThreadCommandSchema,	193	RevertThreadCommandSchema,]
194	);	194	);
195		195
196	export type OrchestrationCommand = Schema.Schema.Type<typeof OrchestrationCommandSchema>;	196	export type OrchestrationCommand = Schema.Schema.Type<typeof OrchestrationCommandSchema>;

author	Julius Marminge <julius0216@outlook.com> 2026-02-22 11:07:16-08:00
committer	Julius Marminge <jmarminge@gmail.com> 2026-02-26 13:20:36-08:00
log	0e4f1485c87a234b33cad6c197625d414bfd070c
tree	18289275142aafeca690c7072258ffcc0755fc8d
parent	b152462b2cd5f26f40ae174765ede2c62381d282

...	@@ -1,8 +1,8 @@	...	@@ -1,8 +1,8 @@
1	import { ParseResult, Schema } from "effect";	1	import { SchemaIssue, Schema } from "effect";
2		2
3	import type { OrchestrationEventRepositoryError } from "../persistence/Errors";	3	import type { OrchestrationEventRepositoryError } from "../persistence/Errors.ts";
4		4
5	export class OrchestrationCommandJsonParseError extends Schema.TaggedError<OrchestrationCommandJsonParseError>()(	5	export class OrchestrationCommandJsonParseError extends Schema.TaggedErrorClass<OrchestrationCommandJsonParseError>()(
6	"OrchestrationCommandJsonParseError",	6	"OrchestrationCommandJsonParseError",
7	{	7	{
8	detail: Schema.String,	8	detail: Schema.String,
...	@@ -14,7 +14,7 @@ export class OrchestrationCommandJsonParseError extends Schema.TaggedError<Orche	...	@@ -14,7 +14,7 @@ export class OrchestrationCommandJsonParseError extends Schema.TaggedError<Orche
14	}	14	}
15	}	15	}
16		16
17	export class OrchestrationCommandDecodeError extends Schema.TaggedError<OrchestrationCommandDecodeError>()(	17	export class OrchestrationCommandDecodeError extends Schema.TaggedErrorClass<OrchestrationCommandDecodeError>()(
18	"OrchestrationCommandDecodeError",	18	"OrchestrationCommandDecodeError",
19	{	19	{
20	issue: Schema.String,	20	issue: Schema.String,
...	@@ -26,7 +26,7 @@ export class OrchestrationCommandDecodeError extends Schema.TaggedError<Orchestr	...	@@ -26,7 +26,7 @@ export class OrchestrationCommandDecodeError extends Schema.TaggedError<Orchestr
26	}	26	}
27	}	27	}
28		28
29	export class OrchestrationReducerDecodeError extends Schema.TaggedError<OrchestrationReducerDecodeError>()(	29	export class OrchestrationReducerDecodeError extends Schema.TaggedErrorClass<OrchestrationReducerDecodeError>()(
30	"OrchestrationReducerDecodeError",	30	"OrchestrationReducerDecodeError",
31	{	31	{
32	eventType: Schema.String,	32	eventType: Schema.String,
...	@@ -39,10 +39,10 @@ export class OrchestrationReducerDecodeError extends Schema.TaggedError<Orchestr	...	@@ -39,10 +39,10 @@ export class OrchestrationReducerDecodeError extends Schema.TaggedError<Orchestr
39	}	39	}
40	}	40	}
41		41
42	export class OrchestrationListenerCallbackError extends Schema.TaggedError<OrchestrationListenerCallbackError>()(	42	export class OrchestrationListenerCallbackError extends Schema.TaggedErrorClass<OrchestrationListenerCallbackError>()(
43	"OrchestrationListenerCallbackError",	43	"OrchestrationListenerCallbackError",
44	{	44	{
45	listener: Schema.Literal("read-model", "domain-event"),	45	listener: Schema.Literals(["read-model", "domain-event"]),
46	detail: Schema.String,	46	detail: Schema.String,
47	cause: Schema.optional(Schema.Defect),	47	cause: Schema.optional(Schema.Defect),
48	},	48	},
...	@@ -62,18 +62,18 @@ export type OrchestrationEngineError =	...	@@ -62,18 +62,18 @@ export type OrchestrationEngineError =
62	\| OrchestrationCommandJsonParseError	62	\| OrchestrationCommandJsonParseError
63	\| OrchestrationCommandDecodeError;	63	\| OrchestrationCommandDecodeError;
64		64
65	export function toOrchestrationCommandDecodeError(error: ParseResult.ParseError) {	65	export function toOrchestrationCommandDecodeError(error: Schema.SchemaError) {
66	return new OrchestrationCommandDecodeError({	66	return new OrchestrationCommandDecodeError({
67	issue: ParseResult.TreeFormatter.formatErrorSync(error),	67	issue: SchemaIssue.makeFormatterDefault()(error.issue),
68	cause: error,	68	cause: error,
69	});	69	});
70	}	70	}
71		71
72	export function toReducerDecodeError(eventType: string) {	72	export function toReducerDecodeError(eventType: string) {
73	return (error: ParseResult.ParseError): OrchestrationReducerDecodeError =>	73	return (error: Schema.SchemaError): OrchestrationReducerDecodeError =>
74	new OrchestrationReducerDecodeError({	74	new OrchestrationReducerDecodeError({
75	eventType,	75	eventType,
76	issue: ParseResult.TreeFormatter.formatErrorSync(error),	76	issue: SchemaIssue.makeFormatterDefault()(error.issue),
77	cause: error,	77	cause: error,
78	});	78	});
79	}	79	}

...	@@ -6,16 +6,16 @@ import type {	...	@@ -6,16 +6,16 @@ import type {
6	import { OrchestrationCommandSchema } from "@t3tools/contracts";	6	import { OrchestrationCommandSchema } from "@t3tools/contracts";
7	import { Deferred, Effect, Layer, PubSub, Queue, Schema } from "effect";	7	import { Deferred, Effect, Layer, PubSub, Queue, Schema } from "effect";
8		8
9	import { createLogger } from "../logger";	9	import { createLogger } from "../logger.ts";
10	import { OrchestrationEventRepository } from "../persistence/Services/OrchestrationEvents";	10	import { OrchestrationEventRepository } from "../persistence/Services/OrchestrationEvents.ts";
11	import {	11	import {
12	toListenerCallbackError,	12	toListenerCallbackError,
13	toOrchestrationCommandDecodeError,	13	toOrchestrationCommandDecodeError,
14	toOrchestrationJsonParseError,	14	toOrchestrationJsonParseError,
15	type OrchestrationDispatchError,	15	type OrchestrationDispatchError,
16	} from "./Errors";	16	} from "./Errors.ts";
17	import { createEmptyReadModel, reduceEvent } from "./reducer";	17	import { createEmptyReadModel, reduceEvent } from "./reducer.ts";
18	import { OrchestrationEngineService, type OrchestrationEngineShape } from "./Service";	18	import { OrchestrationEngineService, type OrchestrationEngineShape } from "./Service.ts";
19		19
20	type CommandEnvelope = {	20	type CommandEnvelope = {
21	command: OrchestrationCommand;	21	command: OrchestrationCommand;
...	@@ -160,9 +160,9 @@ function mapCommandToEvent(command: OrchestrationCommand): Omit<OrchestrationEve	...	@@ -160,9 +160,9 @@ function mapCommandToEvent(command: OrchestrationCommand): Omit<OrchestrationEve
160	}	160	}
161	}	161	}
162		162
163	const decodeUnknownCommand = Schema.decodeUnknown(OrchestrationCommandSchema);	163	const decodeUnknownCommand = Schema.decodeUnknownEffect(OrchestrationCommandSchema);
164		164
165	const makeOrchestrationEngine = () =>	165	const makeOrchestrationEngine =
166	Effect.gen(function* () {	166	Effect.gen(function* () {
167	const logger = createLogger("orchestration");	167	const logger = createLogger("orchestration");
168	const eventStore = yield* OrchestrationEventRepository;	168	const eventStore = yield* OrchestrationEventRepository;
...	@@ -209,7 +209,7 @@ const makeOrchestrationEngine = () =>	...	@@ -209,7 +209,7 @@ const makeOrchestrationEngine = () =>
209		209
210	yield* Deferred.succeed(envelope.result, { sequence: savedEvent.sequence });	210	yield* Deferred.succeed(envelope.result, { sequence: savedEvent.sequence });
211	}).pipe(	211	}).pipe(
212	Effect.catchAll((error) => Deferred.fail(envelope.result, error).pipe(Effect.asVoid)),	212	Effect.catch((error) => Deferred.fail(envelope.result, error).pipe(Effect.asVoid)),
213	);	213	);
214		214
215	const bootstrapReadModel: Effect.Effect<void, OrchestrationDispatchError> = Effect.gen(	215	const bootstrapReadModel: Effect.Effect<void, OrchestrationDispatchError> = Effect.gen(
...	@@ -287,7 +287,7 @@ const makeOrchestrationEngine = () =>	...	@@ -287,7 +287,7 @@ const makeOrchestrationEngine = () =>
287	} satisfies OrchestrationEngineShape;	287	} satisfies OrchestrationEngineShape;
288	});	288	});
289		289
290	export const OrchestrationEngineLive = Layer.scoped(	290	export const OrchestrationEngineLive = Layer.effect(
291	OrchestrationEngineService,	291	OrchestrationEngineService,
292	makeOrchestrationEngine(),	292	makeOrchestrationEngine,
293	);	293	);

...	@@ -3,11 +3,11 @@ import os from "node:os";	...	@@ -3,11 +3,11 @@ import os from "node:os";
3	import path from "node:path";	3	import path from "node:path";
4	import { DatabaseSync } from "node:sqlite";	4	import { DatabaseSync } from "node:sqlite";
5		5
6	import { Runtime, ManagedRuntime } from "effect";	6	import { ManagedRuntime, Effect } from "effect";
7	import { afterEach, describe, expect, it } from "vitest";	7	import { afterEach, describe, expect, it } from "vitest";
8		8
9	import { OrchestrationEventRepository } from "../Services/OrchestrationEvents";	9	import { OrchestrationEventRepository } from "../Services/OrchestrationEvents.ts";
10	import { makeSqliteOrchestrationEventRepositoryLive } from "./OrchestrationEvents";	10	import { makeSqliteOrchestrationEventRepositoryLive } from "./OrchestrationEvents.ts";
11		11
12	const tempDirs: string[] = [];	12	const tempDirs: string[] = [];
13		13
...	@@ -27,12 +27,12 @@ describe("OrchestrationEventRepository", () => {	...	@@ -27,12 +27,12 @@ describe("OrchestrationEventRepository", () => {
27	it("persists and replays events across restarts", async () => {	27	it("persists and replays events across restarts", async () => {
28	const stateDir = makeTempDir("t3code-event-store-");	28	const stateDir = makeTempDir("t3code-event-store-");
29	const dbPath = path.join(stateDir, "orchestration.sqlite");	29	const dbPath = path.join(stateDir, "orchestration.sqlite");
30	const runtime = Runtime.defaultRuntime;	30
31	const createdAt = new Date().toISOString();	31	const createdAt = new Date().toISOString();
32		32
33	const firstRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));	33	const firstRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));
34	const first = await firstRuntime.runPromise(OrchestrationEventRepository);	34	const first = await firstRuntime.runPromise(Effect.service(OrchestrationEventRepository));
35	const saved = await Runtime.runPromise(runtime)(	35	const saved = await firstRuntime.runPromise(
36	first.append({	36	first.append({
37	eventId: "event-1",	37	eventId: "event-1",
38	type: "thread.created",	38	type: "thread.created",
...	@@ -47,8 +47,8 @@ describe("OrchestrationEventRepository", () => {	...	@@ -47,8 +47,8 @@ describe("OrchestrationEventRepository", () => {
47	await firstRuntime.dispose();	47	await firstRuntime.dispose();
48		48
49	const secondRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));	49	const secondRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));
50	const second = await secondRuntime.runPromise(OrchestrationEventRepository);	50	const second = await secondRuntime.runPromise(Effect.service(OrchestrationEventRepository));
51	const replayed = await Runtime.runPromise(runtime)(second.readFromSequence(0));	51	const replayed = await secondRuntime.runPromise(second.readFromSequence(0));
52	expect(replayed).toEqual([saved]);	52	expect(replayed).toEqual([saved]);
53	await secondRuntime.dispose();	53	await secondRuntime.dispose();
54	});	54	});
...	@@ -56,16 +56,16 @@ describe("OrchestrationEventRepository", () => {	...	@@ -56,16 +56,16 @@ describe("OrchestrationEventRepository", () => {
56	it("creates and reuses the migrator tracking table", async () => {	56	it("creates and reuses the migrator tracking table", async () => {
57	const stateDir = makeTempDir("t3code-event-store-migrations-");	57	const stateDir = makeTempDir("t3code-event-store-migrations-");
58	const dbPath = path.join(stateDir, "orchestration.sqlite");	58	const dbPath = path.join(stateDir, "orchestration.sqlite");
59	const runtime = Runtime.defaultRuntime;	59
60		60
61	const firstRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));	61	const firstRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));
62	const first = await firstRuntime.runPromise(OrchestrationEventRepository);	62	const first = await firstRuntime.runPromise(Effect.service(OrchestrationEventRepository));
63	await Runtime.runPromise(runtime)(first.readAll());	63	await firstRuntime.runPromise(first.readAll());
64	await firstRuntime.dispose();	64	await firstRuntime.dispose();
65		65
66	const secondRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));	66	const secondRuntime = ManagedRuntime.make(makeSqliteOrchestrationEventRepositoryLive(dbPath));
67	const second = await secondRuntime.runPromise(OrchestrationEventRepository);	67	const second = await secondRuntime.runPromise(Effect.service(OrchestrationEventRepository));
68	await Runtime.runPromise(runtime)(second.readAll());	68	await secondRuntime.runPromise(second.readAll());
69	await secondRuntime.dispose();	69	await secondRuntime.dispose();
70		70
71	const db = new DatabaseSync(dbPath, { readOnly: true });	71	const db = new DatabaseSync(dbPath, { readOnly: true });

...	@@ -2,12 +2,12 @@ import fs from "node:fs";	...	@@ -2,12 +2,12 @@ import fs from "node:fs";
2	import os from "node:os";	2	import os from "node:os";
3	import path from "node:path";	3	import path from "node:path";
4		4
5	import { Layer, ManagedRuntime } from "effect";	5	import { Effect, Layer, ManagedRuntime } from "effect";
6	import { afterEach, describe, expect, it } from "vitest";	6	import { afterEach, describe, expect, it } from "vitest";
7		7
8	import { ProjectRepository } from "../Services/Projects";	8	import { ProjectRepository } from "../Services/Projects.ts";
9	import { ProjectRepositoryLive } from "./Projects";	9	import { ProjectRepositoryLive } from "./Projects.ts";
10	import { makeSqlitePersistenceLive } from "./Sqlite";	10	import { makeSqlitePersistenceLive } from "./Sqlite.ts";
11		11
12	function makeProjectRepositoryTest(dbPath: string) {	12	function makeProjectRepositoryTest(dbPath: string) {
13	return ProjectRepositoryLive.pipe(Layer.provide(makeSqlitePersistenceLive(dbPath)));	13	return ProjectRepositoryLive.pipe(Layer.provide(makeSqlitePersistenceLive(dbPath)));
...	@@ -34,7 +34,7 @@ describe("ProjectRepository", () => {	...	@@ -34,7 +34,7 @@ describe("ProjectRepository", () => {
34	const dbPath = path.join(stateDir, "orchestration.sqlite");	34	const dbPath = path.join(stateDir, "orchestration.sqlite");
35		35
36	const firstRuntime = ManagedRuntime.make(makeProjectRepositoryTest(dbPath));	36	const firstRuntime = ManagedRuntime.make(makeProjectRepositoryTest(dbPath));
37	const first = await firstRuntime.runPromise(ProjectRepository);	37	const first = await firstRuntime.runPromise(Effect.service(ProjectRepository));
38		38
39	const created = await firstRuntime.runPromise(first.add({ cwd: projectDir }));	39	const created = await firstRuntime.runPromise(first.add({ cwd: projectDir }));
40	expect(created.created).toBe(true);	40	expect(created.created).toBe(true);
...	@@ -46,7 +46,7 @@ describe("ProjectRepository", () => {	...	@@ -46,7 +46,7 @@ describe("ProjectRepository", () => {
46	await firstRuntime.dispose();	46	await firstRuntime.dispose();
47		47
48	const secondRuntime = ManagedRuntime.make(makeProjectRepositoryTest(dbPath));	48	const secondRuntime = ManagedRuntime.make(makeProjectRepositoryTest(dbPath));
49	const second = await secondRuntime.runPromise(ProjectRepository);	49	const second = await secondRuntime.runPromise(Effect.service(ProjectRepository));
50	const listed = await secondRuntime.runPromise(second.list());	50	const listed = await secondRuntime.runPromise(second.list());
51		51
52	expect(listed).toHaveLength(1);	52	expect(listed).toHaveLength(1);
...	@@ -62,7 +62,7 @@ describe("ProjectRepository", () => {	...	@@ -62,7 +62,7 @@ describe("ProjectRepository", () => {
62	const dbPath = path.join(stateDir, "orchestration.sqlite");	62	const dbPath = path.join(stateDir, "orchestration.sqlite");
63		63
64	const runtime = ManagedRuntime.make(makeProjectRepositoryTest(dbPath));	64	const runtime = ManagedRuntime.make(makeProjectRepositoryTest(dbPath));
65	const repository = await runtime.runPromise(ProjectRepository);	65	const repository = await runtime.runPromise(Effect.service(ProjectRepository));
66		66
67	const existingProject = await runtime.runPromise(repository.add({ cwd: existing }));	67	const existingProject = await runtime.runPromise(repository.add({ cwd: existing }));
68	const missingProject = await runtime.runPromise(repository.add({ cwd: missing }));	68	const missingProject = await runtime.runPromise(repository.add({ cwd: missing }));

effect v4