import * as Effect from "effect/Effect";import * as Layer from "effect/Layer";import * as Stream from "effect/Stream"; import * as ConnectionResolver from "./resolver.ts";import * as ConnectionDriver from "./driver.ts";import * as EnvironmentRegistry from "./registry.ts";import * as ConnectionOnboarding from "./onboarding.ts";import * as PlatformConnectionSource from "../platform/source.ts";import * as RelayEnvironmentDiscovery from "../relay/discovery.ts";import * as RemoteEnvironmentAuthorization from "../authorization/service.ts";import * as RpcSession from "../rpc/session.ts"; export function layerWithOptions(options: RpcSession.RpcSessionOptions) { const driverLayer = ConnectionDriver.layer.pipe( Layer.provide(Layer.mergeAll(ConnectionResolver.layer, RpcSession.layerWithOptions(options))), ); const registryLayer = EnvironmentRegistry.layer.pipe(Layer.provide(driverLayer)); const onboardingLayer = ConnectionOnboarding.layer.pipe(Layer.provide(registryLayer)); const connectionServicesLayer = Layer.mergeAll( registryLayer, RelayEnvironmentDiscovery.layer, onboardingLayer, ); const connectionStartupLayer = Layer.effectDiscard( Effect.gen(function* () { const registry = yield* EnvironmentRegistry.EnvironmentRegistry; const platformSource = yield* PlatformConnectionSource.PlatformConnectionSource; yield* registry.start; yield* platformSource.registrations.pipe( Stream.runForEach(registry.reconcilePlatform), Effect.forkScoped, ); }).pipe(Effect.withSpan("clientRuntime.connection.application.start")), ); return connectionStartupLayer.pipe( Layer.provideMerge(connectionServicesLayer), Layer.provideMerge(RemoteEnvironmentAuthorization.layer), );} export const layer = layerWithOptions({});
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import * as Stream from "effect/Stream";
import * as ConnectionResolver from "./resolver.ts";
import * as ConnectionDriver from "./driver.ts";
import * as EnvironmentRegistry from "./registry.ts";
import * as ConnectionOnboarding from "./onboarding.ts";
import * as PlatformConnectionSource from "../platform/source.ts";
import * as RelayEnvironmentDiscovery from "../relay/discovery.ts";
import * as RemoteEnvironmentAuthorization from "../authorization/service.ts";
import * as RpcSession from "../rpc/session.ts";
export function layerWithOptions(options: RpcSession.RpcSessionOptions) {
const driverLayer = ConnectionDriver.layer.pipe(
Layer.provide(Layer.mergeAll(ConnectionResolver.layer, RpcSession.layerWithOptions(options))),
);
const registryLayer = EnvironmentRegistry.layer.pipe(Layer.provide(driverLayer));
const onboardingLayer = ConnectionOnboarding.layer.pipe(Layer.provide(registryLayer));
const connectionServicesLayer = Layer.mergeAll(
registryLayer,
RelayEnvironmentDiscovery.layer,
onboardingLayer,
);
const connectionStartupLayer = Layer.effectDiscard(
Effect.gen(function* () {
const registry = yield* EnvironmentRegistry.EnvironmentRegistry;
const platformSource = yield* PlatformConnectionSource.PlatformConnectionSource;
yield* registry.start;
yield* platformSource.registrations.pipe(
Stream.runForEach(registry.reconcilePlatform),
Effect.forkScoped,
);
}).pipe(Effect.withSpan("clientRuntime.connection.application.start")),
);
return connectionStartupLayer.pipe(
Layer.provideMerge(connectionServicesLayer),
Layer.provideMerge(RemoteEnvironmentAuthorization.layer),
);
}
export const layer = layerWithOptions({});