From cd44226a44e6eb6ae5f5f0a20458dc5740cdd26a Mon Sep 17 00:00:00 2001
From: Julius Marminge <julius0216@outlook.com>
Date: Wed, 1 Apr 2026 00:27:34 -0700
Subject: [PATCH] migrate Effect.fn in
 apps/server/src/provider/Layers/ProviderAdapterRegistry.ts

Co-authored-by: codex <codex@users.noreply.github.com>
---
 .../Layers/ProviderAdapterRegistry.ts         | 43 ++++++++++---------
 1 file changed, 22 insertions(+), 21 deletions(-)

diff --git a/apps/server/src/provider/Layers/ProviderAdapterRegistry.ts b/apps/server/src/provider/Layers/ProviderAdapterRegistry.ts
index 23ef8d1b9b..b6c987c64c 100644
--- a/apps/server/src/provider/Layers/ProviderAdapterRegistry.ts
+++ b/apps/server/src/provider/Layers/ProviderAdapterRegistry.ts
@@ -22,30 +22,31 @@ export interface ProviderAdapterRegistryLiveOptions {
   readonly adapters?: ReadonlyArray<ProviderAdapterShape<ProviderAdapterError>>;
 }
 
-const makeProviderAdapterRegistry = (options?: ProviderAdapterRegistryLiveOptions) =>
-  Effect.gen(function* () {
-    const adapters =
-      options?.adapters !== undefined
-        ? options.adapters
-        : [yield* CodexAdapter, yield* ClaudeAdapter];
-    const byProvider = new Map(adapters.map((adapter) => [adapter.provider, adapter]));
+const makeProviderAdapterRegistry = Effect.fn("makeProviderAdapterRegistry")(function* (
+  options?: ProviderAdapterRegistryLiveOptions,
+) {
+  const adapters =
+    options?.adapters !== undefined
+      ? options.adapters
+      : [yield* CodexAdapter, yield* ClaudeAdapter];
+  const byProvider = new Map(adapters.map((adapter) => [adapter.provider, adapter]));
 
-    const getByProvider: ProviderAdapterRegistryShape["getByProvider"] = (provider) => {
-      const adapter = byProvider.get(provider);
-      if (!adapter) {
-        return Effect.fail(new ProviderUnsupportedError({ provider }));
-      }
-      return Effect.succeed(adapter);
-    };
+  const getByProvider: ProviderAdapterRegistryShape["getByProvider"] = (provider) => {
+    const adapter = byProvider.get(provider);
+    if (!adapter) {
+      return Effect.fail(new ProviderUnsupportedError({ provider }));
+    }
+    return Effect.succeed(adapter);
+  };
 
-    const listProviders: ProviderAdapterRegistryShape["listProviders"] = () =>
-      Effect.sync(() => Array.from(byProvider.keys()));
+  const listProviders: ProviderAdapterRegistryShape["listProviders"] = () =>
+    Effect.sync(() => Array.from(byProvider.keys()));
 
-    return {
-      getByProvider,
-      listProviders,
-    } satisfies ProviderAdapterRegistryShape;
-  });
+  return {
+    getByProvider,
+    listProviders,
+  } satisfies ProviderAdapterRegistryShape;
+});
 
 export const ProviderAdapterRegistryLive = Layer.effect(
   ProviderAdapterRegistry,