index.ts

import { NodeRuntime } from '@effect/platform-node'
import { Database } from '@repo/shared/Database'
import { SqsService } from '@repo/shared/SqsService'
import { Config, Effect, Layer, LogLevel, Logger } from 'effect'
import { withMinimumLogLevel } from 'effect/Logger'
import * as DemoMessageConsumer from './Features/Demo/DemoMessageConsumer'

const consumers = [DemoMessageConsumer.consumer]

const dependencies = Layer.mergeAll(
  SqsService.Live,
  Logger.pretty,
  Database.Live,
)

const preRunEffect = Effect.gen(function* () {
  const env = yield* Config.string('NODE_ENV').pipe(
    Config.withDefault('development'),
  )
  yield* Effect.logInfo(`Starting, with NODE_ENV: ${env}`)
})

const program = preRunEffect.pipe(
  Effect.andThen(Effect.all(consumers, { concurrency: 'unbounded' })),
  Effect.andThen(Effect.never),
  withMinimumLogLevel(LogLevel.Debug),
  Effect.provide(dependencies),
  Effect.scoped,
  Effect.catchAllCause(Effect.logError),
)

NodeRuntime.runMain(program)