refactor: chain specific cached strategy registry

apps/processing/src/services/processing.service.ts

@@ -46,12 +46,9 @@ export class ProcessingService {
         const { eventRegistryRepository, strategyRegistryRepository } = registriesRepositories;
         const orchestrators: Map<ChainId, Orchestrator> = new Map();
 
-        const strategyRegistry = await InMemoryCachedStrategyRegistry.initialize(
-            new Logger({ className: "InMemoryCachedStrategyRegistry" }),
-            new DatabaseStrategyRegistry(
-                new Logger({ className: "DatabaseStrategyRegistry" }),
-                strategyRegistryRepository,
-            ),
+        const strategyRegistry = new DatabaseStrategyRegistry(
+            new Logger({ className: "DatabaseStrategyRegistry" }),
+            strategyRegistryRepository,
         );
         const eventsRegistry = new DatabaseEventRegistry(
             new Logger({ className: "DatabaseEventRegistry" }),
@@ -69,6 +66,11 @@ export class ProcessingService {
                 eventsRegistry,
                 [chain.id as ChainId],
             );
+            const cachedStrategyRegistry = await InMemoryCachedStrategyRegistry.initialize(
+                new Logger({ className: "InMemoryCachedStrategyRegistry" }),
+                strategyRegistry,
+                chain.id as ChainId,
+            );
 
             orchestrators.set(
                 chain.id as ChainId,
@@ -78,7 +80,7 @@ export class ProcessingService {
                     indexerClient,
                     {
                         eventsRegistry: cachedEventsRegistry,
-                        strategyRegistry,
+                        strategyRegistry: cachedStrategyRegistry,
                     },
                     chain.fetchLimit,
                     chain.fetchDelayMs,

apps/processing/test/unit/processing.service.spec.ts

@@ -101,10 +101,10 @@ describe("ProcessingService", () => {
     });
 
     it("initializes multiple orchestrators correctly", () => {
-        expect(InMemoryCachedStrategyRegistry.initialize).toHaveBeenCalledTimes(1);
         expect(DatabaseStrategyRegistry).toHaveBeenCalledTimes(1);
         expect(DatabaseEventRegistry).toHaveBeenCalledTimes(1);
         expect(EvmProvider).toHaveBeenCalledTimes(2);
+        expect(InMemoryCachedStrategyRegistry.initialize).toHaveBeenCalledTimes(2);
         expect(InMemoryCachedEventRegistry.initialize).toHaveBeenCalledTimes(2);
 
         // Verify orchestrators were created with correct parameters

packages/data-flow/src/registries/strategy/cachedStrategyRegistry.ts

@@ -28,16 +28,19 @@ export class InMemoryCachedStrategyRegistry implements IStrategyRegistry {
      *
      * @param logger - The logger instance
      * @param strategyRegistry - The strategy registry instance
+     * @param chainId - The chain ID to load strategies for
      * @returns The initialized cached strategy registry
      */
     static async initialize(
         logger: ILogger,
         strategyRegistry: IStrategyRegistry,
+        chainId: ChainId,
     ): Promise<InMemoryCachedStrategyRegistry> {
-        const strategies = await strategyRegistry.getStrategies();
         const cache = new Map<ChainId, Map<Address, Strategy>>();
 
-        logger.debug(`Loading strategies into memory...`);
+        logger.debug(`Loading strategies into memory for chain ID: ${chainId}...`);
+
+        const strategies = await strategyRegistry.getStrategies({ chainId });
 
         for (const strategy of strategies) {
             if (!cache.has(strategy.chainId)) {

packages/data-flow/test/registries/cachedStrategyRegistry.spec.ts

@@ -44,6 +44,7 @@ describe("InMemoryCachedStrategyRegistry", () => {
         const registry = await InMemoryCachedStrategyRegistry.initialize(
             logger,
             mockStrategyRegistry,
+            chainId,
         );
         const cached = await registry.getStrategyId(chainId, strategyAddress);
 
@@ -65,6 +66,7 @@ describe("InMemoryCachedStrategyRegistry", () => {
         const registry = await InMemoryCachedStrategyRegistry.initialize(
             logger,
             mockStrategyRegistry,
+            chainId,
         );
         const result = await registry.getStrategyId(chainId, strategyAddress);
 
@@ -78,6 +80,7 @@ describe("InMemoryCachedStrategyRegistry", () => {
         const registry = await InMemoryCachedStrategyRegistry.initialize(
             logger,
             mockStrategyRegistry,
+            chainId,
         );
         await registry.saveStrategyId(chainId, strategyAddress, strategyId, true);
 
@@ -109,6 +112,7 @@ describe("InMemoryCachedStrategyRegistry", () => {
         const registry = await InMemoryCachedStrategyRegistry.initialize(
             logger,
             mockStrategyRegistry,
+            chainId,
         );
         await registry.saveStrategyId(chainId, strategyAddress, strategyId, true);
 
@@ -130,6 +134,7 @@ describe("InMemoryCachedStrategyRegistry", () => {
         const registry = await InMemoryCachedStrategyRegistry.initialize(
             logger,
             mockStrategyRegistry,
+            chainId,
         );
         const params = { handled: true, chainId };
         const result = await registry.getStrategies(params);