bump effect to latest beta (#1866)

Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Co-authored-by: Julius Marminge <julius@macmini.local>
Co-authored-by: codex <codex@users.noreply.github.com>

Author: 4 people

apps/desktop/src/clientPersistence.test.ts

@@ -58,7 +58,7 @@ const clientSettings: ClientSettings = {
 };
 
 const savedRegistryRecord: PersistedSavedEnvironmentRecord = {
-  environmentId: EnvironmentId.makeUnsafe("environment-1"),
+  environmentId: EnvironmentId.make("environment-1"),
   label: "Remote environment",
   httpBaseUrl: "https://remote.example.com/",
   wsBaseUrl: "wss://remote.example.com/",

apps/server/integration/OrchestrationEngineHarness.integration.ts

@@ -438,7 +438,7 @@ export const makeOrchestrationIntegrationHarness = (
     ) =>
       waitFor(
         pendingApprovalRepository
-          .getByRequestId({ requestId: ApprovalRequestId.makeUnsafe(requestId) })
+          .getByRequestId({ requestId: ApprovalRequestId.make(requestId) })
           .pipe(
             Effect.map((row) =>
               Option.match(row, {

apps/server/integration/TestProviderAdapter.integration.ts

@@ -289,7 +289,7 @@ export const makeTestProviderAdapterHarness = (options?: MakeTestProviderAdapter
 
         state.turnCount += 1;
         const turnCount = state.turnCount;
-        const turnId = TurnId.makeUnsafe(`turn-${turnCount}`);
+        const turnId = TurnId.make(`turn-${turnCount}`);
 
         const response = state.queuedResponses.shift();
         if (!response) {
@@ -307,7 +307,7 @@ export const makeTestProviderAdapterHarness = (options?: MakeTestProviderAdapter
             ...(fixtureEvent as Record<string, unknown>),
             eventId: randomUUID(),
             provider,
-            sessionId: RuntimeSessionId.makeUnsafe(String(input.threadId)),
+            sessionId: RuntimeSessionId.make(String(input.threadId)),
             createdAt: nowIso(),
           };
           rawEvent.threadId = state.snapshot.threadId;
@@ -363,7 +363,7 @@ export const makeTestProviderAdapterHarness = (options?: MakeTestProviderAdapter
         if (deferredTurnCompletedEvents.length === 0) {
           yield* emit({
             type: "turn.completed",
-            eventId: EventId.makeUnsafe(randomUUID()),
+            eventId: EventId.make(randomUUID()),
             provider,
             createdAt: nowIso(),
             threadId: state.snapshot.threadId,

apps/server/integration/fixtures/providerRuntime.ts

@@ -5,14 +5,14 @@ const PROVIDER = "codex" as const;
 const SESSION_ID = "fixture-session";
 const THREAD_ID = "fixture-thread";
 const TURN_ID = "fixture-turn";
-const REQUEST_ID = RuntimeRequestId.makeUnsafe("req-1");
+const REQUEST_ID = RuntimeRequestId.make("req-1");
 
 function baseEvent(
   eventId: string,
   createdAt: string,
 ): Pick<LegacyProviderRuntimeEvent, "eventId" | "provider" | "sessionId" | "createdAt"> {
   return {
-    eventId: EventId.makeUnsafe(eventId),
+    eventId: EventId.make(eventId),
     provider: PROVIDER,
     sessionId: SESSION_ID,
     createdAt,

apps/server/integration/orchestrationEngine.integration.test.ts

@@ -30,14 +30,13 @@ import type {
 } from "../src/orchestration/Services/RuntimeReceiptBus.ts";
 import * as NodeServices from "@effect/platform-node/NodeServices";
 
-const asMessageId = (value: string): MessageId => MessageId.makeUnsafe(value);
-const asProjectId = (value: string): ProjectId => ProjectId.makeUnsafe(value);
-const asEventId = (value: string): EventId => EventId.makeUnsafe(value);
-const asApprovalRequestId = (value: string): ApprovalRequestId =>
-  ApprovalRequestId.makeUnsafe(value);
+const asMessageId = (value: string): MessageId => MessageId.make(value);
+const asProjectId = (value: string): ProjectId => ProjectId.make(value);
+const asEventId = (value: string): EventId => EventId.make(value);
+const asApprovalRequestId = (value: string): ApprovalRequestId => ApprovalRequestId.make(value);
 
 const PROJECT_ID = asProjectId("project-1");
-const THREAD_ID = ThreadId.makeUnsafe("thread-1");
+const THREAD_ID = ThreadId.make("thread-1");
 const FIXTURE_TURN_ID = "fixture-turn";
 const APPROVAL_REQUEST_ID = asApprovalRequestId("req-approval-1");
 type IntegrationProvider = ProviderKind;
@@ -112,7 +111,7 @@ const seedProjectAndThread = (harness: OrchestrationIntegrationHarness) =>
 
     yield* harness.engine.dispatch({
       type: "project.create",
-      commandId: CommandId.makeUnsafe("cmd-project-create"),
+      commandId: CommandId.make("cmd-project-create"),
       projectId: PROJECT_ID,
       title: "Integration Project",
       workspaceRoot: harness.workspaceDir,
@@ -125,7 +124,7 @@ const seedProjectAndThread = (harness: OrchestrationIntegrationHarness) =>
 
     yield* harness.engine.dispatch({
       type: "thread.create",
-      commandId: CommandId.makeUnsafe("cmd-thread-create"),
+      commandId: CommandId.make("cmd-thread-create"),
       threadId: THREAD_ID,
       projectId: PROJECT_ID,
       title: "Integration Thread",
@@ -150,7 +149,7 @@ const startTurn = (input: {
 }) =>
   input.harness.engine.dispatch({
     type: "thread.turn.start",
-    commandId: CommandId.makeUnsafe(input.commandId),
+    commandId: CommandId.make(input.commandId),
     threadId: THREAD_ID,
     message: {
       messageId: asMessageId(input.messageId),
@@ -261,7 +260,7 @@ it.live.skipIf(!process.env.CODEX_BINARY_PATH)(
 
         yield* harness.engine.dispatch({
           type: "project.create",
-          commandId: CommandId.makeUnsafe("cmd-project-create-real-codex"),
+          commandId: CommandId.make("cmd-project-create-real-codex"),
           projectId: PROJECT_ID,
           title: "Integration Project",
           workspaceRoot: harness.workspaceDir,
@@ -274,7 +273,7 @@ it.live.skipIf(!process.env.CODEX_BINARY_PATH)(
 
         yield* harness.engine.dispatch({
           type: "thread.create",
-          commandId: CommandId.makeUnsafe("cmd-thread-create-real-codex"),
+          commandId: CommandId.make("cmd-thread-create-real-codex"),
           threadId: THREAD_ID,
           projectId: PROJECT_ID,
           title: "Integration Thread",
@@ -291,7 +290,7 @@ it.live.skipIf(!process.env.CODEX_BINARY_PATH)(
 
         yield* harness.engine.dispatch({
           type: "thread.turn.start",
-          commandId: CommandId.makeUnsafe("cmd-turn-start-real-codex-1"),
+          commandId: CommandId.make("cmd-turn-start-real-codex-1"),
           threadId: THREAD_ID,
           message: {
             messageId: asMessageId("msg-real-codex-1"),
@@ -318,7 +317,7 @@ it.live.skipIf(!process.env.CODEX_BINARY_PATH)(
 
         yield* harness.engine.dispatch({
           type: "thread.turn.start",
-          commandId: CommandId.makeUnsafe("cmd-turn-start-real-codex-2"),
+          commandId: CommandId.make("cmd-turn-start-real-codex-2"),
           threadId: THREAD_ID,
           message: {
             messageId: asMessageId("msg-real-codex-2"),
@@ -583,7 +582,7 @@ it.live("tracks approval requests and resolves pending approvals on user respons
 
       yield* harness.engine.dispatch({
         type: "thread.approval.respond",
-        commandId: CommandId.makeUnsafe("cmd-approval-respond"),
+        commandId: CommandId.make("cmd-approval-respond"),
         threadId: THREAD_ID,
         requestId: APPROVAL_REQUEST_ID,
         decision: "accept",
@@ -815,7 +814,7 @@ it.live("reverts to an earlier checkpoint and trims checkpoint projections + git
 
       yield* harness.engine.dispatch({
         type: "thread.checkpoint.revert",
-        commandId: CommandId.makeUnsafe("cmd-checkpoint-revert"),
+        commandId: CommandId.make("cmd-checkpoint-revert"),
         threadId: THREAD_ID,
         turnCount: 1,
         createdAt: nowIso(),
@@ -875,7 +874,7 @@ it.live(
 
         yield* harness.engine.dispatch({
           type: "thread.checkpoint.revert",
-          commandId: CommandId.makeUnsafe("cmd-checkpoint-revert-no-session"),
+          commandId: CommandId.make("cmd-checkpoint-revert-no-session"),
           threadId: THREAD_ID,
           turnCount: 0,
           createdAt: nowIso(),
@@ -1119,7 +1118,7 @@ it.live("forwards claudeAgent approval responses to the provider session", () =>
 
         yield* harness.engine.dispatch({
           type: "thread.approval.respond",
-          commandId: CommandId.makeUnsafe("cmd-claude-approval-respond"),
+          commandId: CommandId.make("cmd-claude-approval-respond"),
           threadId: THREAD_ID,
           requestId: APPROVAL_REQUEST_ID,
           decision: "accept",
@@ -1192,7 +1191,7 @@ it.live("forwards thread.turn.interrupt to claudeAgent provider sessions", () =>
 
         yield* harness.engine.dispatch({
           type: "thread.turn.interrupt",
-          commandId: CommandId.makeUnsafe("cmd-turn-interrupt-claude"),
+          commandId: CommandId.make("cmd-turn-interrupt-claude"),
           threadId: THREAD_ID,
           createdAt: nowIso(),
         });
@@ -1309,7 +1308,7 @@ it.live("reverts claudeAgent turns and rolls back provider conversation state",
 
         yield* harness.engine.dispatch({
           type: "thread.checkpoint.revert",
-          commandId: CommandId.makeUnsafe("cmd-checkpoint-revert-claude"),
+          commandId: CommandId.make("cmd-checkpoint-revert-claude"),
           threadId: THREAD_ID,
           turnCount: 1,
           createdAt: nowIso(),

apps/server/integration/providerService.integration.test.ts

@@ -122,15 +122,12 @@ it.live("replays typed runtime fixture events", () =>
 
     yield* Effect.gen(function* () {
       const provider = yield* ProviderService;
-      const session = yield* provider.startSession(
-        ThreadId.makeUnsafe("thread-integration-typed"),
-        {
-          threadId: ThreadId.makeUnsafe("thread-integration-typed"),
-          provider: "codex",
-          cwd: fixture.cwd,
-          runtimeMode: "full-access",
-        },
-      );
+      const session = yield* provider.startSession(ThreadId.make("thread-integration-typed"), {
+        threadId: ThreadId.make("thread-integration-typed"),
+        provider: "codex",
+        cwd: fixture.cwd,
+        runtimeMode: "full-access",
+      });
       assert.equal((session.threadId ?? "").length > 0, true);
 
       const observedEvents = yield* runTurn({
@@ -157,15 +154,12 @@ it.live("replays file-changing fixture turn events", () =>
 
     yield* Effect.gen(function* () {
       const provider = yield* ProviderService;
-      const session = yield* provider.startSession(
-        ThreadId.makeUnsafe("thread-integration-tools"),
-        {
-          threadId: ThreadId.makeUnsafe("thread-integration-tools"),
-          provider: "codex",
-          cwd: fixture.cwd,
-          runtimeMode: "full-access",
-        },
-      );
+      const session = yield* provider.startSession(ThreadId.make("thread-integration-tools"), {
+        threadId: ThreadId.make("thread-integration-tools"),
+        provider: "codex",
+        cwd: fixture.cwd,
+        runtimeMode: "full-access",
+      });
       assert.equal((session.threadId ?? "").length > 0, true);
 
       const observedEvents = yield* runTurn({
@@ -196,15 +190,12 @@ it.live("runs multi-turn tool/approval flow", () =>
 
     yield* Effect.gen(function* () {
       const provider = yield* ProviderService;
-      const session = yield* provider.startSession(
-        ThreadId.makeUnsafe("thread-integration-multi"),
-        {
-          threadId: ThreadId.makeUnsafe("thread-integration-multi"),
-          provider: "codex",
-          cwd: fixture.cwd,
-          runtimeMode: "full-access",
-        },
-      );
+      const session = yield* provider.startSession(ThreadId.make("thread-integration-multi"), {
+        threadId: ThreadId.make("thread-integration-multi"),
+        provider: "codex",
+        cwd: fixture.cwd,
+        runtimeMode: "full-access",
+      });
       assert.equal((session.threadId ?? "").length > 0, true);
 
       const firstTurnEvents = yield* runTurn({
@@ -250,15 +241,12 @@ it.live("rolls back provider conversation state only", () =>
 
     yield* Effect.gen(function* () {
       const provider = yield* ProviderService;
-      const session = yield* provider.startSession(
-        ThreadId.makeUnsafe("thread-integration-rollback"),
-        {
-          threadId: ThreadId.makeUnsafe("thread-integration-rollback"),
-          provider: "codex",
-          cwd: fixture.cwd,
-          runtimeMode: "full-access",
-        },
-      );
+      const session = yield* provider.startSession(ThreadId.make("thread-integration-rollback"), {
+        threadId: ThreadId.make("thread-integration-rollback"),
+        provider: "codex",
+        cwd: fixture.cwd,
+        runtimeMode: "full-access",
+      });
       assert.equal((session.threadId ?? "").length > 0, true);
 
       yield* runTurn({

apps/server/src/auth/Layers/SessionCredentialService.ts

@@ -188,7 +188,7 @@ export const makeSessionCredentialService = Effect.gen(function* () {
 
   const issue: SessionCredentialServiceShape["issue"] = (input) =>
     Effect.gen(function* () {
-      const sessionId = AuthSessionId.makeUnsafe(crypto.randomUUID());
+      const sessionId = AuthSessionId.make(crypto.randomUUID());
       const issuedAt = yield* DateTime.now;
       const expiresAt = DateTime.add(issuedAt, {
         milliseconds: Duration.toMillis(input?.ttl ?? DEFAULT_SESSION_TTL),

apps/server/src/auth/Services/AuthControlPlane.ts

@@ -4,7 +4,7 @@ import type {
   AuthPairingLink,
   AuthSessionId,
 } from "@t3tools/contracts";
-import { Data, DateTime, Duration, Effect, ServiceMap } from "effect";
+import { Data, DateTime, Duration, Effect, Context } from "effect";
 import { SessionRole } from "./SessionCredentialService";
 
 export const DEFAULT_SESSION_SUBJECT = "cli-issued-session";
@@ -64,6 +64,6 @@ export interface AuthControlPlaneShape {
   ) => Effect.Effect<number, AuthControlPlaneError>;
 }
 
-export class AuthControlPlane extends ServiceMap.Service<AuthControlPlane, AuthControlPlaneShape>()(
+export class AuthControlPlane extends Context.Service<AuthControlPlane, AuthControlPlaneShape>()(
   "t3/AuthControlPlane",
 ) {}

apps/server/src/auth/Services/BootstrapCredentialService.ts

@@ -1,5 +1,5 @@
 import type { AuthPairingLink, ServerAuthBootstrapMethod } from "@t3tools/contracts";
-import { Data, DateTime, Duration, ServiceMap } from "effect";
+import { Data, DateTime, Duration, Context } from "effect";
 import type { Effect, Stream } from "effect";
 
 export type BootstrapCredentialRole = "owner" | "client";
@@ -51,7 +51,7 @@ export interface BootstrapCredentialServiceShape {
   readonly consume: (credential: string) => Effect.Effect<BootstrapGrant, BootstrapCredentialError>;
 }
 
-export class BootstrapCredentialService extends ServiceMap.Service<
+export class BootstrapCredentialService extends Context.Service<
   BootstrapCredentialService,
   BootstrapCredentialServiceShape
 >()("t3/auth/Services/BootstrapCredentialService") {}

apps/server/src/auth/Services/ServerAuth.ts

@@ -12,7 +12,7 @@ import type {
   ServerAuthSessionMethod,
   AuthWebSocketTokenResult,
 } from "@t3tools/contracts";
-import { Data, DateTime, ServiceMap } from "effect";
+import { Data, DateTime, Context } from "effect";
 import type { Effect } from "effect";
 import type * as HttpServerRequest from "effect/unstable/http/HttpServerRequest";
 import type { SessionRole } from "./SessionCredentialService.ts";
@@ -79,6 +79,6 @@ export interface ServerAuthShape {
   readonly issueStartupPairingUrl: (baseUrl: string) => Effect.Effect<string, AuthError>;
 }
 
-export class ServerAuth extends ServiceMap.Service<ServerAuth, ServerAuthShape>()(
+export class ServerAuth extends Context.Service<ServerAuth, ServerAuthShape>()(
   "t3/auth/Services/ServerAuth",
 ) {}