Function adapterLayer

packages/infra/test/workflow-engine-cosmos.test.ts:238–256

(prefix: string)

  const prefixFor = (label: string) => `test-${Date.now()}-${label}-`

  const adapterLayer = (prefix: string) =>
    Layer
      .mergeAll(
        IncrementHandler,
        AwaitOnlyHandler,
        CounterRef.layer,
        CosmosClientLayer(cosmosUrl ?? "", cosmosDb)
      )
      .pipe(
        Layer.provideMerge(
          layerCosmos({
            url: Redacted.make(cosmosUrl ?? ""),
            dbName: cosmosDb,
            prefix,
            recoveryInterval: Duration.millis(500),
            clockPollInterval: Duration.millis(500)
          })
        )
      )

  it.live("recovery poller drives execs with stale leases", () => {
    const prefix = prefixFor("recovery")