Expose multiple roles by giving it a name

Refs #1834
PREreview · Sep 4, 2024 · a1f6c1a · a1f6c1a
1 parent c214a84
commit a1f6c1a
Showing 1 changed file with 21 additions and 19 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -133,27 +133,29 @@ if (env.VERIFY_CACHE) {
 
 class Express extends Context.Tag('Express')<Express, ReturnType<typeof app>>() {}
 
-pipe(
-  Effect.acquireRelease(
-    Effect.gen(function* () {
-      const app = yield* Express
-      const listeningHttpServer = app.listen(3000)
-      L.debug('Server listening')(loggerEnv)()
-      return listeningHttpServer
+const expressServerLifecycle = Effect.acquireRelease(
+  Effect.gen(function* () {
+    const app = yield* Express
+    const listeningHttpServer = app.listen(3000)
+    L.debug('Server listening')(loggerEnv)()
+    return listeningHttpServer
+  }),
+  server =>
+    Effect.promise(async () => {
+      L.debug('Shutting server down')(loggerEnv)()
+      server.close()
+
+      await redis
+        .quit()
+        .then(() => L.debug('Redis disconnected')(loggerEnv)())
+        .catch((error: unknown) =>
+          L.warnP('Redis unable to disconnect')({ error: E.toError(error).message })(loggerEnv)(),
+        )
     }),
-    server =>
-      Effect.promise(async () => {
-        L.debug('Shutting server down')(loggerEnv)()
-        server.close()
+)
 
-        await redis
-          .quit()
-          .then(() => L.debug('Redis disconnected')(loggerEnv)())
-          .catch((error: unknown) =>
-            L.warnP('Redis unable to disconnect')({ error: E.toError(error).message })(loggerEnv)(),
-          )
-      }),
-  ),
+pipe(
+  expressServerLifecycle,
   Layer.scopedDiscard,
   Layer.launch,
   Effect.provideServiceEffect(Express, expressServer),