refactor: explicitly run things in main

src/AutoThreads.ts

@@ -145,10 +145,7 @@ const make = Effect.gen(function* ($) {
 
   const ix = Ix.builder.add(archive).add(edit).add(editModal)
 
-  // Run the message handler
-  yield* $(Effect.forkScoped(handleMessages))
-
-  return { ix } as const
+  return { ix, run: handleMessages } as const
 })
 
 export interface AutoThreads extends Effect.Effect.Success<typeof make> {}

src/ChannelsCache.ts

@@ -7,7 +7,4 @@ interface ChannelsCache
   extends Effect.Effect.Success<typeof makeChannelsCache> {}
 
 export const ChannelsCache = Tag<ChannelsCache>()
-export const ChannelsCacheLive = Layer.scoped(
-  ChannelsCache,
-  Effect.tap(makeChannelsCache, _ => Effect.forkScoped(_.run)),
-)
+export const ChannelsCacheLive = Layer.scoped(ChannelsCache, makeChannelsCache)

src/main.ts

@@ -3,18 +3,20 @@ import { Config, Effect, Layer, pipe } from "bot/_common"
 import { Intents, Ix } from "dfx"
 import { makeLive, runIx } from "dfx/gateway"
 import * as Dotenv from "dotenv"
+import { ChannelsCache, ChannelsCacheLive } from "./ChannelsCache.js"
 
 Dotenv.config()
 
 const program = Effect.gen(function* ($) {
+  const channels = yield* $(ChannelsCache)
   const autoThreads = yield* $(AutoThreads)
 
   const runInteractions = pipe(
     Ix.builder.concat(autoThreads.ix),
     runIx(Effect.catchAllCause(Effect.logErrorCause)),
   )
 
-  yield* $(runInteractions)
+  yield* $(Effect.allParDiscard(channels.run, autoThreads.run, runInteractions))
 })
 
 const BotLive = makeLive({
@@ -24,7 +26,10 @@ const BotLive = makeLive({
   },
 })
 
-const EnvLive = Layer.provideMerge(BotLive, AutoThreadsLive)
+const EnvLive = Layer.provideMerge(
+  BotLive,
+  Layer.merge(AutoThreadsLive, ChannelsCacheLive),
+)
 
 pipe(
   program,