Function clusterWorkflowLayer

packages/infra/test/cluster-sqlite.test.ts:105–139

()

  return `${step1}:${step2}:${step3}`
}))

const clusterWorkflowLayer = () => {
  const prefix = "test_cluster_sqlite"
  const config = ShardingConfig.layer({
    runnerAddress: Option.some(testRunnerAddress(20)),
    shardsPerGroup: 1,
    availableShardGroups: [testShardGroup("workflow")],
    assignedShardGroups: [testShardGroup("workflow")],
    entityTerminationTimeout: 0,
    entityMessagePollInterval: 50,
    entityReplyPollInterval: 50,
    refreshAssignmentsInterval: 0,
    sendRetryInterval: 50
  })
  const storage = Layer
    .merge(
      SqlMessageStorage.layerWith({ prefix }),
      Layer.orDie(SqlRunnerStorage.layerWith({ prefix }))
    )
    .pipe(Layer.provide(SqliteClient.layer({ filename: ":memory:" })))

  return Layer
    .merge(SqliteDeferredWorkflowLayer, SequentialDeferredWorkflowLayer)
    .pipe(
      Layer.provideMerge(StepLog.layer),
      Layer.provideMerge(
        ClusterWorkflowEngine.layer.pipe(
          Layer.provideMerge(Sharding.layer),
          Layer.provide(Runners.layerNoop),
          Layer.provide(RunnerHealth.layerNoop),
          Layer.provide(storage),
          Layer.provide(config),
          Layer.provide(NodeCrypto.layer)
        )
      )
    )
}