Remove duplication

Refs #1834
PREreview · Sep 4, 2024 · c734567 · c734567
1 parent 004557e
commit c734567
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 19 deletions.
diff --git a/src/Redis.ts b/src/Redis.ts
@@ -1,21 +1,15 @@
-import { SystemClock } from 'clock-ts'
-import { Effect, pipe } from 'effect'
-import * as C from 'fp-ts/lib/Console.js'
+import { Context, Effect } from 'effect'
 import { toError } from 'fp-ts/lib/Either.js'
 import { Redis as IoRedis } from 'ioredis'
 import * as L from 'logger-fp-ts'
 import { DeprecatedEnvVars } from './env.js'
 
+export class DeprecatedLoggerEnv extends Context.Tag('DeprecatedLoggerEnv')<DeprecatedLoggerEnv, L.LoggerEnv>() {}
+
 export const redisLifecycle = Effect.acquireRelease(
   Effect.gen(function* () {
     const env = yield* DeprecatedEnvVars
-    const loggerEnv: L.LoggerEnv = {
-      clock: SystemClock,
-      logger: pipe(
-        C.log,
-        L.withShow(env.LOG_FORMAT === 'json' ? L.JsonShowLogEntry : L.getColoredShow(L.ShowLogEntry)),
-      ),
-    }
+    const loggerEnv = yield* DeprecatedLoggerEnv
     const redis = new IoRedis(env.REDIS_URI.href, { commandTimeout: 2 * 1000, enableAutoPipelining: true })
 
     redis.on('connect', () => L.debug('Redis connected')(loggerEnv)())
@@ -28,14 +22,7 @@ export const redisLifecycle = Effect.acquireRelease(
   }),
   redis =>
     Effect.gen(function* () {
-      const env = yield* DeprecatedEnvVars
-      const loggerEnv: L.LoggerEnv = {
-        clock: SystemClock,
-        logger: pipe(
-          C.log,
-          L.withShow(env.LOG_FORMAT === 'json' ? L.JsonShowLogEntry : L.getColoredShow(L.ShowLogEntry)),
-        ),
-      }
+      const loggerEnv = yield* DeprecatedLoggerEnv
       yield* Effect.promise(() =>
         redis
           .quit()

diff --git a/src/index.ts b/src/index.ts
@@ -11,7 +11,7 @@ import * as L from 'logger-fp-ts'
 import type { app } from './app.js'
 import { decodeEnv, DeprecatedEnvVars } from './env.js'
 import { expressServer, Redis } from './ExpressServer.js'
-import { redisLifecycle } from './Redis.js'
+import { DeprecatedLoggerEnv, redisLifecycle } from './Redis.js'
 
 const env = decodeEnv(process)()
 
@@ -54,6 +54,7 @@ pipe(
   Layer.launch,
   Effect.provideServiceEffect(Express, expressServer),
   Effect.provideServiceEffect(Redis, redisLifecycle),
+  Effect.provideService(DeprecatedLoggerEnv, loggerEnv),
   Effect.provideService(DeprecatedEnvVars, env),
   Effect.scoped,
   NodeRuntime.runMain,