bump effect to 4.0.0-beta.78

apps/server/src/atomicWrite.ts

@@ -1,7 +1,6 @@
 import * as Effect from "effect/Effect";
 import * as FileSystem from "effect/FileSystem";
 import * as Path from "effect/Path";
-import * as Random from "effect/Random";
 
 export const writeFileStringAtomically = (input: {
   readonly filePath: string;
@@ -15,7 +14,6 @@ export const writeFileStringAtomically = (input: {
     Effect.gen(function* () {
       const fs = yield* FileSystem.FileSystem;
       const path = yield* Path.Path;
-      const tempFileId = yield* Random.nextUUIDv4;
       const targetDirectory = path.dirname(input.filePath);
 
       yield* fs.makeDirectory(targetDirectory, { recursive: true });
@@ -26,7 +24,7 @@ export const writeFileStringAtomically = (input: {
         directory: targetDirectory,
         prefix: `${path.basename(input.filePath)}.`,
       });
-      const tempPath = path.join(tempDirectory, `${tempFileId}.tmp`);
+      const tempPath = path.join(tempDirectory, "contents.tmp");
 
       yield* fs.writeFileString(tempPath, input.contents);
       if (input.mode !== undefined) {

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

@@ -69,5 +69,5 @@ export interface AuthControlPlaneShape {
 }
 
 export class AuthControlPlane extends Context.Service<AuthControlPlane, AuthControlPlaneShape>()(
-  "t3/AuthControlPlane",
+  "@ru-code/ru-code/auth/Services/AuthControlPlane",
 ) {}

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

@@ -58,4 +58,4 @@ export interface BootstrapCredentialServiceShape {
 export class BootstrapCredentialService extends Context.Service<
   BootstrapCredentialService,
   BootstrapCredentialServiceShape
->()("t3/auth/Services/BootstrapCredentialService") {}
+>()("@ru-code/ru-code/auth/Services/BootstrapCredentialService") {}

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

@@ -92,5 +92,5 @@ export interface ServerAuthShape {
 }
 
 export class ServerAuth extends Context.Service<ServerAuth, ServerAuthShape>()(
-  "t3/auth/Services/ServerAuth",
+  "@ru-code/ru-code/auth/Services/ServerAuth",
 ) {}

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

@@ -7,5 +7,5 @@ export interface ServerAuthPolicyShape {
 }
 
 export class ServerAuthPolicy extends Context.Service<ServerAuthPolicy, ServerAuthPolicyShape>()(
-  "t3/auth/Services/ServerAuthPolicy",
+  "@ru-code/ru-code/auth/Services/ServerAuthPolicy",
 ) {}

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

@@ -29,5 +29,5 @@ export interface ServerSecretStoreShape {
 }
 
 export class ServerSecretStore extends Context.Service<ServerSecretStore, ServerSecretStoreShape>()(
-  "t3/auth/Services/ServerSecretStore",
+  "@ru-code/ru-code/auth/Services/ServerSecretStore",
 ) {}

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

@@ -88,4 +88,4 @@ export interface SessionCredentialServiceShape {
 export class SessionCredentialService extends Context.Service<
   SessionCredentialService,
   SessionCredentialServiceShape
->()("t3/auth/Services/SessionCredentialService") {}
+>()("@ru-code/ru-code/auth/Services/SessionCredentialService") {}

apps/server/src/checkpointing/Errors.ts

@@ -11,7 +11,7 @@ export class CheckpointUnavailableError extends Schema.TaggedErrorClass<Checkpoi
     threadId: Schema.String,
     turnCount: Schema.Number,
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -27,7 +27,7 @@ export class CheckpointInvariantError extends Schema.TaggedErrorClass<Checkpoint
   {
     operation: Schema.String,
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {

apps/server/src/checkpointing/Services/CheckpointDiffQuery.ts

@@ -46,4 +46,4 @@ export interface CheckpointDiffQueryShape {
 export class CheckpointDiffQuery extends Context.Service<
   CheckpointDiffQuery,
   CheckpointDiffQueryShape
->()("t3/checkpointing/Services/CheckpointDiffQuery") {}
+>()("@ru-code/ru-code/checkpointing/Services/CheckpointDiffQuery") {}

apps/server/src/checkpointing/Services/CheckpointStore.ts

@@ -97,5 +97,5 @@ export interface CheckpointStoreShape {
  * CheckpointStore - Service tag for checkpoint persistence and restore operations.
  */
 export class CheckpointStore extends Context.Service<CheckpointStore, CheckpointStoreShape>()(
-  "t3/checkpointing/Services/CheckpointStore",
+  "@ru-code/ru-code/checkpointing/Services/CheckpointStore",
 ) {}

apps/server/src/config.ts

@@ -283,7 +283,7 @@ export const ensureServerDirectories = Effect.fn(function* (derivedPaths: Server
  * ServerConfig - Service tag for server runtime configuration.
  */
 export class ServerConfig extends Context.Service<ServerConfig, ServerConfigShape>()(
-  "t3/config/ServerConfig",
+  "@ru-code/ru-code/config/ServerConfig",
 ) {
   static readonly layerTest = (cwd: string, baseDirOrPrefix: string | { prefix: string }) =>
     Layer.effect(

apps/server/src/environment/Layers/ServerEnvironment.ts

@@ -1,9 +1,9 @@
 import { EnvironmentId, type ExecutionEnvironmentDescriptor } from "@t3tools/contracts";
+import * as Crypto from "effect/Crypto";
 import * as Effect from "effect/Effect";
 import * as FileSystem from "effect/FileSystem";
 import * as Layer from "effect/Layer";
 import * as Path from "effect/Path";
-import * as Random from "effect/Random";
 
 import * as ProcessRunner from "../../processRunner.ts";
 import { ServerConfig } from "../../config.ts";
@@ -39,6 +39,7 @@ export const makeServerEnvironment = Effect.fn("makeServerEnvironment")(function
   const fileSystem = yield* FileSystem.FileSystem;
   const path = yield* Path.Path;
   const serverConfig = yield* ServerConfig;
+  const crypto = yield* Crypto.Crypto;
 
   const readPersistedEnvironmentId = Effect.gen(function* () {
     const exists = yield* fileSystem
@@ -64,7 +65,7 @@ export const makeServerEnvironment = Effect.fn("makeServerEnvironment")(function
       return persisted;
     }
 
-    const generated = yield* Random.nextUUIDv4;
+    const generated = yield* crypto.randomUUIDv4;
     yield* persistEnvironmentId(generated);
     return generated;
   });

apps/server/src/environment/Services/ServerEnvironment.ts

@@ -8,5 +8,5 @@ export interface ServerEnvironmentShape {
 }
 
 export class ServerEnvironment extends Context.Service<ServerEnvironment, ServerEnvironmentShape>()(
-  "t3/environment/Services/ServerEnvironment",
+  "@ru-code/ru-code/environment/Services/ServerEnvironment",
 ) {}

apps/server/src/git/GitManager.ts

@@ -88,7 +88,7 @@ export interface GitManagerShape {
 }
 
 export class GitManager extends Context.Service<GitManager, GitManagerShape>()(
-  "t3/git/GitManager",
+  "@ru-code/ru-code/git/GitManager",
 ) {}
 
 const MAX_PROGRESS_TEXT_LENGTH = 500;

apps/server/src/git/GitWorkflowService.ts

@@ -77,7 +77,7 @@ export interface GitWorkflowServiceShape {
 export class GitWorkflowService extends Context.Service<
   GitWorkflowService,
   GitWorkflowServiceShape
->()("t3/git/GitWorkflowService") {}
+>()("@ru-code/ru-code/git/GitWorkflowService") {}
 
 const unsupportedGitWorkflow = (operation: string, cwd: string, detail: string) =>
   new GitManagerError({

apps/server/src/keybindings.ts

@@ -287,7 +287,7 @@ export interface KeybindingsShape {
  * Keybindings - Service tag for keybinding configuration operations.
  */
 export class Keybindings extends Context.Service<Keybindings, KeybindingsShape>()(
-  "t3/keybindings",
+  "@ru-code/ru-code/keybindings",
 ) {}
 
 const makeKeybindings = Effect.gen(function* () {

apps/server/src/open.ts

@@ -148,7 +148,7 @@ export interface OpenShape {
 /**
  * Open - Service tag for browser/editor launch operations.
  */
-export class Open extends Context.Service<Open, OpenShape>()("t3/open") {}
+export class Open extends Context.Service<Open, OpenShape>()("@ru-code/ru-code/open") {}
 
 // ==============================
 // Implementations

apps/server/src/orchestration/Errors.ts

@@ -7,7 +7,7 @@ export class OrchestrationCommandJsonParseError extends Schema.TaggedErrorClass<
   "OrchestrationCommandJsonParseError",
   {
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -19,7 +19,7 @@ export class OrchestrationCommandDecodeError extends Schema.TaggedErrorClass<Orc
   "OrchestrationCommandDecodeError",
   {
     issue: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -32,7 +32,7 @@ export class OrchestrationCommandInvariantError extends Schema.TaggedErrorClass<
   {
     commandType: Schema.String,
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -45,7 +45,7 @@ export class OrchestrationCommandPreviouslyRejectedError extends Schema.TaggedEr
   {
     commandId: Schema.String,
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -58,7 +58,7 @@ export class OrchestrationProjectorDecodeError extends Schema.TaggedErrorClass<O
   {
     eventType: Schema.String,
     issue: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -71,7 +71,7 @@ export class OrchestrationListenerCallbackError extends Schema.TaggedErrorClass<
   {
     listener: Schema.Literals(["read-model", "domain-event"]),
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {

apps/server/src/orchestration/Services/CheckpointReactor.ts

@@ -36,5 +36,5 @@ export interface CheckpointReactorShape {
  * CheckpointReactor - Service tag for checkpoint reactor workers.
  */
 export class CheckpointReactor extends Context.Service<CheckpointReactor, CheckpointReactorShape>()(
-  "t3/orchestration/Services/CheckpointReactor",
+  "@ru-code/ru-code/orchestration/Services/CheckpointReactor",
 ) {}

apps/server/src/orchestration/Services/OrchestrationEngine.ts

@@ -67,4 +67,4 @@ export interface OrchestrationEngineShape {
 export class OrchestrationEngineService extends Context.Service<
   OrchestrationEngineService,
   OrchestrationEngineShape
->()("t3/orchestration/Services/OrchestrationEngine/OrchestrationEngineService") {}
+>()("@ru-code/ru-code/orchestration/Services/OrchestrationEngine/OrchestrationEngineService") {}

apps/server/src/orchestration/Services/OrchestrationReactor.ts

@@ -29,4 +29,4 @@ export interface OrchestrationReactorShape {
 export class OrchestrationReactor extends Context.Service<
   OrchestrationReactor,
   OrchestrationReactorShape
->()("t3/orchestration/Services/OrchestrationReactor") {}
+>()("@ru-code/ru-code/orchestration/Services/OrchestrationReactor") {}

apps/server/src/orchestration/Services/ProjectionPipeline.ts

@@ -39,4 +39,4 @@ export interface OrchestrationProjectionPipelineShape {
 export class OrchestrationProjectionPipeline extends Context.Service<
   OrchestrationProjectionPipeline,
   OrchestrationProjectionPipelineShape
->()("t3/orchestration/Services/ProjectionPipeline/OrchestrationProjectionPipeline") {}
+>()("@ru-code/ru-code/orchestration/Services/ProjectionPipeline/OrchestrationProjectionPipeline") {}

apps/server/src/orchestration/Services/ProjectionSnapshotQuery.ts

@@ -146,4 +146,4 @@ export interface ProjectionSnapshotQueryShape {
 export class ProjectionSnapshotQuery extends Context.Service<
   ProjectionSnapshotQuery,
   ProjectionSnapshotQueryShape
->()("t3/orchestration/Services/ProjectionSnapshotQuery") {}
+>()("@ru-code/ru-code/orchestration/Services/ProjectionSnapshotQuery") {}

apps/server/src/orchestration/Services/ProviderCommandReactor.ts

@@ -38,4 +38,4 @@ export interface ProviderCommandReactorShape {
 export class ProviderCommandReactor extends Context.Service<
   ProviderCommandReactor,
   ProviderCommandReactorShape
->()("t3/orchestration/Services/ProviderCommandReactor") {}
+>()("@ru-code/ru-code/orchestration/Services/ProviderCommandReactor") {}

apps/server/src/orchestration/Services/ProviderRuntimeIngestion.ts

@@ -38,4 +38,4 @@ export interface ProviderRuntimeIngestionShape {
 export class ProviderRuntimeIngestionService extends Context.Service<
   ProviderRuntimeIngestionService,
   ProviderRuntimeIngestionShape
->()("t3/orchestration/Services/ProviderRuntimeIngestion/ProviderRuntimeIngestionService") {}
+>()("@ru-code/ru-code/orchestration/Services/ProviderRuntimeIngestion/ProviderRuntimeIngestionService") {}

apps/server/src/orchestration/Services/RuntimeReceiptBus.ts

@@ -62,5 +62,5 @@ export interface RuntimeReceiptBusShape {
 }
 
 export class RuntimeReceiptBus extends Context.Service<RuntimeReceiptBus, RuntimeReceiptBusShape>()(
-  "t3/orchestration/Services/RuntimeReceiptBus",
+  "@ru-code/ru-code/orchestration/Services/RuntimeReceiptBus",
 ) {}

apps/server/src/orchestration/Services/ThreadDeletionReactor.ts

@@ -35,4 +35,4 @@ export interface ThreadDeletionReactorShape {
 export class ThreadDeletionReactor extends Context.Service<
   ThreadDeletionReactor,
   ThreadDeletionReactorShape
->()("t3/orchestration/Services/ThreadDeletionReactor") {}
+>()("@ru-code/ru-code/orchestration/Services/ThreadDeletionReactor") {}

apps/server/src/persistence/Errors.ts

@@ -10,7 +10,7 @@ export class PersistenceSqlError extends Schema.TaggedErrorClass<PersistenceSqlE
   {
     operation: Schema.String,
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -23,7 +23,7 @@ export class PersistenceDecodeError extends Schema.TaggedErrorClass<PersistenceD
   {
     operation: Schema.String,
     issue: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -72,7 +72,7 @@ export class ProviderSessionRepositoryValidationError extends Schema.TaggedError
   {
     operation: Schema.String,
     issue: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {
@@ -85,7 +85,7 @@ export class ProviderSessionRepositoryPersistenceError extends Schema.TaggedErro
   {
     operation: Schema.String,
     detail: Schema.String,
-    cause: Schema.optional(Schema.Defect),
+    cause: Schema.optional(Schema.Defect()),
   },
 ) {
   override get message(): string {

apps/server/src/persistence/Migrations/009_ProviderSessionRuntimeMode.ts

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

apps/server/src/persistence/NodeSqliteClient.ts

@@ -252,14 +252,12 @@ export const layerConfig = (
   config: Config.Wrap<SqliteClientConfig>,
 ): Layer.Layer<Client.SqlClient, Config.ConfigError> =>
   Layer.effectContext(
-    Config.unwrap(config)
-      .asEffect()
-      .pipe(
-        Effect.flatMap(make),
-        Effect.map((client) =>
-          Context.make(SqliteClient, client).pipe(Context.add(Client.SqlClient, client)),
-        ),
+    Config.unwrap(config).pipe(
+      Effect.flatMap(make),
+      Effect.map((client) =>
+        Context.make(SqliteClient, client).pipe(Context.add(Client.SqlClient, client)),
       ),
+    ),
   ).pipe(Layer.provide(Reactivity.layer));
 
 export const layer = (config: SqliteClientConfig): Layer.Layer<Client.SqlClient> =>

apps/server/src/persistence/Services/AuthPairingLinks.ts

@@ -75,4 +75,4 @@ export interface AuthPairingLinkRepositoryShape {
 export class AuthPairingLinkRepository extends Context.Service<
   AuthPairingLinkRepository,
   AuthPairingLinkRepositoryShape
->()("t3/persistence/Services/AuthPairingLinks/AuthPairingLinkRepository") {}
+>()("@ru-code/ru-code/persistence/Services/AuthPairingLinks/AuthPairingLinkRepository") {}

apps/server/src/persistence/Services/AuthSessions.ts

@@ -92,4 +92,4 @@ export interface AuthSessionRepositoryShape {
 export class AuthSessionRepository extends Context.Service<
   AuthSessionRepository,
   AuthSessionRepositoryShape
->()("t3/persistence/Services/AuthSessions/AuthSessionRepository") {}
+>()("@ru-code/ru-code/persistence/Services/AuthSessions/AuthSessionRepository") {}

apps/server/src/persistence/Services/McpBinding.ts

@@ -33,4 +33,4 @@ export interface McpBindingRepositoryShape {
 export class McpBindingRepository extends Context.Service<
   McpBindingRepository,
   McpBindingRepositoryShape
->()("ru-fork/persistence/Services/McpBinding/McpBindingRepository") {}
+>()("@ru-code/ru-code/persistence/Services/McpBinding/McpBindingRepository") {}

apps/server/src/persistence/Services/McpCatalog.ts

@@ -23,4 +23,4 @@ export interface McpCatalogRepositoryShape {
 export class McpCatalogRepository extends Context.Service<
   McpCatalogRepository,
   McpCatalogRepositoryShape
->()("ru-fork/persistence/Services/McpCatalog/McpCatalogRepository") {}
+>()("@ru-code/ru-code/persistence/Services/McpCatalog/McpCatalogRepository") {}

apps/server/src/persistence/Services/McpProbeCache.ts

@@ -30,4 +30,4 @@ export interface McpProbeCacheRepositoryShape {
 export class McpProbeCacheRepository extends Context.Service<
   McpProbeCacheRepository,
   McpProbeCacheRepositoryShape
->()("ru-fork/persistence/Services/McpProbeCache/McpProbeCacheRepository") {}
+>()("@ru-code/ru-code/persistence/Services/McpProbeCache/McpProbeCacheRepository") {}

apps/server/src/persistence/Services/OrchestrationCommandReceipts.ts

@@ -69,4 +69,4 @@ export interface OrchestrationCommandReceiptRepositoryShape {
 export class OrchestrationCommandReceiptRepository extends Context.Service<
   OrchestrationCommandReceiptRepository,
   OrchestrationCommandReceiptRepositoryShape
->()("t3/persistence/Services/OrchestrationCommandReceipts/OrchestrationCommandReceiptRepository") {}
+>()("@ru-code/ru-code/persistence/Services/OrchestrationCommandReceipts/OrchestrationCommandReceiptRepository") {}

apps/server/src/persistence/Services/OrchestrationEventStore.ts

@@ -68,4 +68,4 @@ export interface OrchestrationEventStoreShape {
 export class OrchestrationEventStore extends Context.Service<
   OrchestrationEventStore,
   OrchestrationEventStoreShape
->()("t3/persistence/Services/OrchestrationEventStore") {}
+>()("@ru-code/ru-code/persistence/Services/OrchestrationEventStore") {}

apps/server/src/persistence/Services/ProjectionCheckpoints.ts

@@ -92,4 +92,4 @@ export interface ProjectionCheckpointRepositoryShape {
 export class ProjectionCheckpointRepository extends Context.Service<
   ProjectionCheckpointRepository,
   ProjectionCheckpointRepositoryShape
->()("t3/persistence/Services/ProjectionCheckpoints/ProjectionCheckpointRepository") {}
+>()("@ru-code/ru-code/persistence/Services/ProjectionCheckpoints/ProjectionCheckpointRepository") {}