Function layerFor

packages/infra/test/cluster-cosmos.test.ts:16–25

()

const liveSnowflake = Layer.effect(Snowflake.Generator, TestClock.withLive(Snowflake.makeGenerator))

const layerFor = () =>
  layerCosmos({
    url: Redacted.make(cosmosUrl ?? ""),
    dbName: cosmosDb,
    prefix: "test-cluster-"
  })
    .pipe(
      Layer.provideMerge(liveSnowflake),
      Layer.provide(ShardingConfig.layerDefaults)
    )

describe.skipIf(!cosmosUrl)("ClusterCosmos MessageStorage", () => {
  it.effect("deduplicates keyed requests and returns the last reply", () =>