Unified · Split
| @@ -29,11 +29,7 @@ import { · 28 unmodified lines | |||
| 29 | layer as effectWorkerLayer, | 29 | layer as effectWorkerLayer, |
| 30 | runDaemon as runEffectWorkerDaemon, | 30 | runDaemon as runEffectWorkerDaemon, |
| 31 | } from "../EffectWorker.ts"; | 31 | } from "../EffectWorker.ts"; |
| 32 | import { | 32 | import { EventSinkV2, layerFromStores as eventSinkLayer } from "../EventSink.ts"; |
| 33 | EventSinkV2, | ||
| 34 | type EventSinkV2Shape, | ||
| 35 | layerFromStores as eventSinkLayer, | ||
| 36 | } from "../EventSink.ts"; | ||
| 37 | import { layer as eventStoreLayer } from "../EventStore.ts"; | 33 | import { layer as eventStoreLayer } from "../EventStore.ts"; |
| 38 | import { layer as idAllocatorLayer } from "../IdAllocator.ts"; | 34 | import { layer as idAllocatorLayer } from "../IdAllocator.ts"; |
| 39 | import { layer as orchestratorLayer } from "../Orchestrator.ts"; | 35 | import { layer as orchestratorLayer } from "../Orchestrator.ts"; |
| @@ -184,7 +180,7 @@ export function runOrchestratorV2ProviderReplayScenario< · 144 unmodified lines | |||
| 184 | >; | 180 | >; |
| 185 | readonly enableLegacyTokenStreaming?: boolean; | 181 | readonly enableLegacyTokenStreaming?: boolean; |
| 186 | readonly runEffectWorker?: boolean; | 182 | readonly runEffectWorker?: boolean; |
| 187 | readonly transformEventSink?: (eventSink: EventSinkV2Shape) => EventSinkV2Shape; | 183 | readonly transformEventSink?: (eventSink: EventSinkV2["Service"]) => EventSinkV2["Service"]; |
| 188 | } = {}, | 184 | } = {}, |
| 189 | ): Effect.Effect< | 185 | ): Effect.Effect< |
| 190 | OrchestratorV2ScenarioResult, | 186 | OrchestratorV2ScenarioResult, |
| @@ -225,7 +221,7 @@ export function makeOrchestratorV2ProviderReplayLayer< · 34 unmodified lines | |||
| 225 | readonly enableLegacyTokenStreaming?: boolean; | 221 | readonly enableLegacyTokenStreaming?: boolean; |
| 226 | readonly runEffectWorker?: boolean; | 222 | readonly runEffectWorker?: boolean; |
| 227 | readonly replayGate?: ProviderReplayGate; | 223 | readonly replayGate?: ProviderReplayGate; |
| 228 | readonly transformEventSink?: (eventSink: EventSinkV2Shape) => EventSinkV2Shape; | 224 | readonly transformEventSink?: (eventSink: EventSinkV2["Service"]) => EventSinkV2["Service"]; |
| 229 | } = {}, | 225 | } = {}, |
| 230 | ): Layer.Layer<OrchestratorV2, Error | MigrationError | PlatformError.PlatformError | SqlError> { | 226 | ): Layer.Layer<OrchestratorV2, Error | MigrationError | PlatformError.PlatformError | SqlError> { |
| 231 | const registryLayer = harness.makeProviderAdapterRegistryLayer( | 227 | const registryLayer = harness.makeProviderAdapterRegistryLayer( |
| @@ -245,7 +241,7 @@ export function makeOrchestratorV2ReplayLayerWithRegistry<Error>( · 13 unmodified lines | |||
| 245 | >; | 241 | >; |
| 246 | readonly enableLegacyTokenStreaming?: boolean; | 242 | readonly enableLegacyTokenStreaming?: boolean; |
| 247 | readonly runEffectWorker?: boolean; | 243 | readonly runEffectWorker?: boolean; |
| 248 | readonly transformEventSink?: (eventSink: EventSinkV2Shape) => EventSinkV2Shape; | 244 | readonly transformEventSink?: (eventSink: EventSinkV2["Service"]) => EventSinkV2["Service"]; |
| 249 | } = {}, | 245 | } = {}, |
| 250 | ): Layer.Layer<OrchestratorV2, Error | MigrationError | PlatformError.PlatformError | SqlError> { | 246 | ): Layer.Layer<OrchestratorV2, Error | MigrationError | PlatformError.PlatformError | SqlError> { |
| 251 | const serverConfigLayer = Layer.effect( | 247 | const serverConfigLayer = Layer.effect( |