feat(algebra-integral): add addMasterPool for master/slave sync

Without this method, the master service cannot spin up event pools
on demand when slaves publish pool requests via the new_pools channel.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: Ivan Work

src/dex/algebra-integral/algebra-integral.ts

@@ -15,6 +15,7 @@ import {
 import {
   SwapSide,
   Network,
+  CACHE_PREFIX,
   DEST_TOKEN_DEX_TRANSFERS,
   SRC_TOKEN_DEX_TRANSFERS,
   SUBGRAPH_TIMEOUT,
@@ -60,6 +61,8 @@ import { uint256ToBigInt } from '../../lib/decoders';
 import AlgebraIntegralStateMulticallABI from '../../abi/algebra-integral/AlgebraIntegralStateMulticall.abi.json';
 import { buildFeeCallData } from './utils';
 
+const PoolsRegistryHashKey = `${CACHE_PREFIX}_poolsRegistry`;
+
 export class AlgebraIntegral
   extends SimpleExchange
   implements IDex<AlgebraIntegralData>
@@ -187,6 +190,40 @@ export class AlgebraIntegral
     );
   }
 
+  async addMasterPool(poolKey: string, blockNumber: number): Promise<boolean> {
+    const _pairs = await this.dexHelper.cache.hget(
+      PoolsRegistryHashKey,
+      `${this.cacheStateKey}_${poolKey}`,
+    );
+    if (!_pairs) {
+      this.logger.warn(
+        `did not find poolConfig in for key ${PoolsRegistryHashKey} ${this.cacheStateKey}_${poolKey}`,
+      );
+      return false;
+    }
+
+    const poolInfo: { token0: Address; token1: Address } = JSON.parse(_pairs);
+
+    const pools = this.factory.getAvailablePoolsForPair(
+      poolInfo.token0,
+      poolInfo.token1,
+    );
+
+    if (pools.length === 0) return false;
+
+    try {
+      await this.initializeEventPools(blockNumber, true, pools);
+    } catch (e) {
+      this.logger.error(
+        `${this.dexKey}: failed to initialize master pools for ${poolInfo.token0}/${poolInfo.token1}`,
+        e,
+      );
+      return false;
+    }
+
+    return true;
+  }
+
   protected async updateAllPoolFees(): Promise<void> {
     try {
       const activePools = Object.values(this.eventPools).filter(