feat(STX-501): add remote feature flag routing to getAPIRequestURL for sentinel migration

src/SmartTransactionsController.ts

@@ -288,6 +288,14 @@
 
   #trace: TraceCallback;
 
+  #isStxMigrationFlagEnabled(flagName: string): boolean {
+    const flag = this.messenger.call('RemoteFeatureFlagController:getState')
+      ?.remoteFeatureFlags?.[flagName];
+    return Boolean(
+      flag && typeof flag === 'object' && 'value' in flag && flag.value,
+    );
+  }
+
   /**
    * Validates the smart transactions feature flags from the remote feature flag controller
    * and reports any validation errors to Sentry via ErrorReportingService.
@@ -443,9 +451,9 @@
       isSmartTransactionPending,
     );
     if (!this.timeoutHandle && pendingTransactions?.length > 0) {
       this.poll();
     } else if (this.timeoutHandle && pendingTransactions?.length === 0) {
       this.stop();
     }
   }
 
@@ -470,7 +478,7 @@
     }
 
     this.timeoutHandle = setInterval(() => {
       safelyExecute(async () => this.updateSmartTransactions());
     }, this.#interval);
     await safelyExecute(async () => this.updateSmartTransactions());
   }
@@ -537,7 +545,7 @@
       ethQuery = new EthQuery(provider);
     }
 
     this.#createOrUpdateSmartTransaction(smartTransaction, {
       chainId,
       ethQuery,
     });
@@ -818,9 +826,13 @@
     });
 
     // Construct the URL and fetch the data
+    const useSentinelForBatchStatus = this.#isStxMigrationFlagEnabled(
+      'stxMigrationBatchStatus',
+    );
     const url = `${getAPIRequestURL(
       APIType.BATCH_STATUS,
       chainId,
+      useSentinelForBatchStatus,
     )}?${params.toString()}`;
     const data = (await this.#fetch(url)) as Record<
       string,
@@ -912,15 +924,21 @@
       );
     }
     transactions.push(unsignedTradeTransactionWithNonce);
+    const useSentinelForGetFees = this.#isStxMigrationFlagEnabled(
+      'stxMigrationGetFees',
+    );
     const data = await this.#trace(
       { name: SmartTransactionsTraceName.GetFees },
       async () =>
-        await this.#fetch(getAPIRequestURL(APIType.GET_FEES, chainId), {
-          method: 'POST',
-          body: JSON.stringify({
-            txs: transactions,
-          }),
-        }),
+        await this.#fetch(
+          getAPIRequestURL(APIType.GET_FEES, chainId, useSentinelForGetFees),
+          {
+            method: 'POST',
+            body: JSON.stringify({
+              txs: transactions,
+            }),
+          },
+        ),
     );
     let approvalTxFees: IndividualTxFees | null;
     let tradeTxFees: IndividualTxFees | null;
@@ -977,11 +995,18 @@
     const ethQuery = this.#getEthQuery({
       networkClientId: selectedNetworkClientId,
     });
+    const useSentinelForSubmitTransactions = this.#isStxMigrationFlagEnabled(
+      'stxMigrationSubmitTransactions',
+    );
     const data = await this.#trace(
       { name: SmartTransactionsTraceName.SubmitTransactions },
       async () =>
         await this.#fetch(
-          getAPIRequestURL(APIType.SUBMIT_TRANSACTIONS, chainId),
+          getAPIRequestURL(
+            APIType.SUBMIT_TRANSACTIONS,
+            chainId,
+            useSentinelForSubmitTransactions,
+          ),
           {
             method: 'POST',
             body: JSON.stringify({
@@ -1129,13 +1154,18 @@
     } = {},
   ): Promise<void> {
     const chainId = this.#getChainId({ networkClientId });
+    const useSentinelForCancel =
+      this.#isStxMigrationFlagEnabled('stxMigrationCancel');
     await this.#trace(
       { name: SmartTransactionsTraceName.CancelTransaction },
       async () =>
-        await this.#fetch(getAPIRequestURL(APIType.CANCEL, chainId), {
-          method: 'POST',
-          body: JSON.stringify({ uuid }),
-        }),
+        await this.#fetch(
+          getAPIRequestURL(APIType.CANCEL, chainId, useSentinelForCancel),
+          {
+            method: 'POST',
+            body: JSON.stringify({ uuid }),
+          },
+        ),
     );
   }
 

src/utils.test.ts

@@ -118,6 +118,123 @@ describe('src/utils.js', () => {
         `${SENTINEL_API_BASE_URL_MAP[baseChainIdDec]}/network`,
       );
     });
+
+    // Sentinel routing via useSentinel flag
+    describe('GET_FEES sentinel routing', () => {
+      it('returns a sentinel URL when useSentinel is true and chain is in SENTINEL_API_BASE_URL_MAP', () => {
+        expect(
+          utils.getAPIRequestURL(APIType.GET_FEES, ChainId.mainnet, true),
+        ).toBe(
+          `${SENTINEL_API_BASE_URL_MAP[ethereumChainIdDec]}/v1/networks/${ethereumChainIdDec}/getFees`,
+        );
+      });
+
+      it('returns the API_BASE_URL when useSentinel is false', () => {
+        expect(
+          utils.getAPIRequestURL(APIType.GET_FEES, ChainId.mainnet, false),
+        ).toBe(`${API_BASE_URL}/networks/${ethereumChainIdDec}/getFees`);
+      });
+
+      it('returns the API_BASE_URL when useSentinel is true but chain is not in SENTINEL_API_BASE_URL_MAP', () => {
+        const unsupportedChainId = '0x539'; // 1337 — local dev chain, not in map
+        const chainIdDec = parseInt(unsupportedChainId, 16);
+        expect(
+          utils.getAPIRequestURL(APIType.GET_FEES, unsupportedChainId, true),
+        ).toBe(`${API_BASE_URL}/networks/${chainIdDec}/getFees`);
+      });
+    });
+
+    describe('SUBMIT_TRANSACTIONS sentinel routing', () => {
+      it('returns a sentinel URL when useSentinel is true and chain is in SENTINEL_API_BASE_URL_MAP', () => {
+        expect(
+          utils.getAPIRequestURL(
+            APIType.SUBMIT_TRANSACTIONS,
+            ChainId.mainnet,
+            true,
+          ),
+        ).toBe(
+          `${SENTINEL_API_BASE_URL_MAP[ethereumChainIdDec]}/v1/networks/${ethereumChainIdDec}/submitTransactions?stxControllerVersion=${packageJson.version}`,
+        );
+      });
+
+      it('returns the API_BASE_URL when useSentinel is false', () => {
+        expect(
+          utils.getAPIRequestURL(
+            APIType.SUBMIT_TRANSACTIONS,
+            ChainId.mainnet,
+            false,
+          ),
+        ).toBe(
+          `${API_BASE_URL}/networks/${ethereumChainIdDec}/submitTransactions?stxControllerVersion=${packageJson.version}`,
+        );
+      });
+
+      it('returns the API_BASE_URL when useSentinel is true but chain is not in SENTINEL_API_BASE_URL_MAP', () => {
+        const unsupportedChainId = '0x539';
+        const chainIdDec = parseInt(unsupportedChainId, 16);
+        expect(
+          utils.getAPIRequestURL(
+            APIType.SUBMIT_TRANSACTIONS,
+            unsupportedChainId,
+            true,
+          ),
+        ).toBe(
+          `${API_BASE_URL}/networks/${chainIdDec}/submitTransactions?stxControllerVersion=${packageJson.version}`,
+        );
+      });
+    });
+
+    describe('CANCEL sentinel routing', () => {
+      it('returns a sentinel URL when useSentinel is true and chain is in SENTINEL_API_BASE_URL_MAP', () => {
+        expect(
+          utils.getAPIRequestURL(APIType.CANCEL, ChainId.mainnet, true),
+        ).toBe(
+          `${SENTINEL_API_BASE_URL_MAP[ethereumChainIdDec]}/v1/networks/${ethereumChainIdDec}/cancel`,
+        );
+      });
+
+      it('returns the API_BASE_URL when useSentinel is false', () => {
+        expect(
+          utils.getAPIRequestURL(APIType.CANCEL, ChainId.mainnet, false),
+        ).toBe(`${API_BASE_URL}/networks/${ethereumChainIdDec}/cancel`);
+      });
+
+      it('returns the API_BASE_URL when useSentinel is true but chain is not in SENTINEL_API_BASE_URL_MAP', () => {
+        const unsupportedChainId = '0x539';
+        const chainIdDec = parseInt(unsupportedChainId, 16);
+        expect(
+          utils.getAPIRequestURL(APIType.CANCEL, unsupportedChainId, true),
+        ).toBe(`${API_BASE_URL}/networks/${chainIdDec}/cancel`);
+      });
+    });
+
+    describe('BATCH_STATUS sentinel routing', () => {
+      it('returns a sentinel URL when useSentinel is true and chain is in SENTINEL_API_BASE_URL_MAP', () => {
+        expect(
+          utils.getAPIRequestURL(APIType.BATCH_STATUS, ChainId.mainnet, true),
+        ).toBe(
+          `${SENTINEL_API_BASE_URL_MAP[ethereumChainIdDec]}/v1/networks/${ethereumChainIdDec}/batchStatus`,
+        );
+      });
+
+      it('returns the API_BASE_URL when useSentinel is false', () => {
+        expect(
+          utils.getAPIRequestURL(APIType.BATCH_STATUS, ChainId.mainnet, false),
+        ).toBe(`${API_BASE_URL}/networks/${ethereumChainIdDec}/batchStatus`);
+      });
+
+      it('returns the API_BASE_URL when useSentinel is true but chain is not in SENTINEL_API_BASE_URL_MAP', () => {
+        const unsupportedChainId = '0x539';
+        const chainIdDec = parseInt(unsupportedChainId, 16);
+        expect(
+          utils.getAPIRequestURL(
+            APIType.BATCH_STATUS,
+            unsupportedChainId,
+            true,
+          ),
+        ).toBe(`${API_BASE_URL}/networks/${chainIdDec}/batchStatus`);
+      });
+    });
   });
 
   describe('isSmartTransactionStatusResolved', () => {

src/utils.ts

@@ -39,10 +39,17 @@
 ) => stxStatus === 'uuid_not_found';
 
 // TODO use actual url once API is defined
-export function getAPIRequestURL(apiType: APIType, chainId: string): string {
+export function getAPIRequestURL(
+  apiType: APIType,
+  chainId: string,
+  useSentinel = false,
+): string {
   const chainIdDec = parseInt(chainId, 16);
   switch (apiType) {
     case APIType.GET_FEES: {
+      if (useSentinel && SENTINEL_API_BASE_URL_MAP[chainIdDec]) {
+        return `${SENTINEL_API_BASE_URL_MAP[chainIdDec]}/v1/networks/${chainIdDec}/getFees`;
+      }
       return `${API_BASE_URL}/networks/${chainIdDec}/getFees`;
     }
 
@@ -51,14 +58,23 @@
     }
 
     case APIType.SUBMIT_TRANSACTIONS: {
+      if (useSentinel && SENTINEL_API_BASE_URL_MAP[chainIdDec]) {
+        return `${SENTINEL_API_BASE_URL_MAP[chainIdDec]}/v1/networks/${chainIdDec}/submitTransactions?stxControllerVersion=${packageJson.version}`;
+      }
       return `${API_BASE_URL}/networks/${chainIdDec}/submitTransactions?stxControllerVersion=${packageJson.version}`;
     }
 
     case APIType.CANCEL: {
+      if (useSentinel && SENTINEL_API_BASE_URL_MAP[chainIdDec]) {
+        return `${SENTINEL_API_BASE_URL_MAP[chainIdDec]}/v1/networks/${chainIdDec}/cancel`;
+      }
       return `${API_BASE_URL}/networks/${chainIdDec}/cancel`;
     }
 
     case APIType.BATCH_STATUS: {
+      if (useSentinel && SENTINEL_API_BASE_URL_MAP[chainIdDec]) {
+        return `${SENTINEL_API_BASE_URL_MAP[chainIdDec]}/v1/networks/${chainIdDec}/batchStatus`;
+      }
       return `${API_BASE_URL}/networks/${chainIdDec}/batchStatus`;
     }
 
@@ -289,8 +305,8 @@
   }
 
   const errorMessage = originalTransactionStatus
     ? `Smart transaction failed with status: ${status}, originalTransactionStatus: ${originalTransactionStatus}`
     : `Smart transaction failed with status: ${status}`;
 
   for (const tx of transactionsToFail) {
     if (tx.status === TransactionStatus.failed) {
@@ -307,7 +323,7 @@
 
     updateTransaction(
       updatedTransaction,
       `Smart transaction status: ${status}`,
     );
   }
 };