| ... | ... | @@ -7,8 +7,8 @@ import * as Deferred from "effect/Deferred"; |
| 7 | 7 | import * as Effect from "effect/Effect"; |
| 8 | 8 | import * as Layer from "effect/Layer"; |
| 9 | 9 | import * as Path from "effect/Path"; |
| 10 | | import { HttpServer } from "effect/unstable/http"; |
| 11 | | import * as NetAddress from "effect/unstable/net/NetAddress"; |
| 10 | import { HttpServer } from "effect/http"; |
| 11 | import * as NetAddress from "effect/net/NetAddress"; |
| 12 | 12 | |
| 13 | 13 | import * as EnvironmentAuth from "./auth/EnvironmentAuth.ts"; |
| 14 | 14 | import * as ServiceLauncherClient from "./cloud/serviceLauncherClient.ts"; |
| ... | ... | @@ -17,6 +17,7 @@ import * as ServerEnvironment from "./environment/ServerEnvironment.ts"; |
| 17 | 17 | import * as Keybindings from "./keybindings.ts"; |
| 18 | 18 | import * as EffectWorker from "./orchestration-v2/EffectWorker.ts"; |
| 19 | 19 | import * as LegacyV1ThreadImporter from "./orchestration-v2/legacy/LegacyV1ThreadImporter.ts"; |
| 20 | import * as Orchestrator from "./orchestration-v2/Orchestrator.ts"; |
| 20 | 21 | import * as ProjectStore from "./orchestration-v2/ProjectStore.ts"; |
| 21 | 22 | import * as ProviderRuntimeRecovery from "./orchestration-v2/ProviderRuntimeRecoveryService.ts"; |
| 22 | 23 | import * as ProviderSessionManager from "./orchestration-v2/ProviderSessionManager.ts"; |
| ... | ... | @@ -113,6 +114,7 @@ it.effect("parks automatic pull until activation without delaying command readin |
| 113 | 114 | prepareForShutdown: Effect.void, |
| 114 | 115 | reconcile: () => Effect.succeed(recovery), |
| 115 | 116 | }), |
| 117 | Layer.mock(Orchestrator.OrchestratorV2)({ recoverDelegatedTasks: Effect.void }), |
| 116 | 118 | Layer.mock(ProviderSessionManager.ProviderSessionManagerV2)({ shutdown: Effect.void }), |
| 117 | 119 | Layer.mock(AgentAwarenessRelay.AgentAwarenessRelay)({ start: () => Effect.void }), |
| 118 | 120 | Layer.mock(EffectWorker.OrchestrationEffectWorkerV2)({ runOnce: Effect.never }), |