feat: fake the rwaData returned from backend to make sure it work for stock label.

Author: dawnseeker8

packages/assets-controllers/src/token-service.ts

@@ -8,7 +8,9 @@ import type { CaipChainId, Hex } from '@metamask/utils';
 
 import { isTokenListSupportedForNetwork } from './assetsUtil';
 
-export const TOKEN_END_POINT_API = 'https://token.api.cx.metamask.io';
+// export const TOKEN_END_POINT_API = 'https://token.api.cx.metamask.io';
+// TODO change it back after development is done
+export const TOKEN_END_POINT_API = 'https://token.dev-api.cx.metamask.io';
 export const TOKEN_METADATA_NO_SUPPORT_ERROR =
   'TokenService Error: Network does not support fetchTokenMetadata';
 
@@ -18,7 +20,7 @@ export const TOKEN_METADATA_NO_SUPPORT_ERROR =
  * @param chainId - The chain ID of the network the tokens requested are on.
  * @returns The tokens URL.
  */
-function getTokensURL(chainId: Hex) {
+function getTokensURL(chainId: Hex): string {
   const occurrenceFloor = chainId === ChainId['linea-mainnet'] ? 1 : 3;
 
   return `${TOKEN_END_POINT_API}/tokens/${convertHexToDecimal(
@@ -33,7 +35,7 @@ function getTokensURL(chainId: Hex) {
  * @param tokenAddress - The token address.
  * @returns The token metadata URL.
  */
-function getTokenMetadataURL(chainId: Hex, tokenAddress: string) {
+function getTokenMetadataURL(chainId: Hex, tokenAddress: string): string {
   return `${TOKEN_END_POINT_API}/token/${convertHexToDecimal(
     chainId,
   )}?address=${tokenAddress}`;
@@ -62,12 +64,12 @@ function getTokenSearchURL(
   query: string,
   limit = 10,
   includeMarketData = false,
-) {
+): string {
   const encodedQuery = encodeURIComponent(query);
   const encodedChainIds = chainIds
     .map((id) => encodeURIComponent(id))
     .join(',');
-  return `${TOKEN_END_POINT_API}/tokens/search?networks=${encodedChainIds}&query=${encodedQuery}&limit=${limit}&includeMarketData=${includeMarketData}`;
+  return `${TOKEN_END_POINT_API}/tokens/search?networks=${encodedChainIds}&query=${encodedQuery}&limit=${limit}&includeMarketData=${includeMarketData}&includeRwaData=true`;
 }
 
 /**
@@ -142,16 +144,42 @@ export async function fetchTokenListByChainId(
   if (response) {
     const result = await parseJsonResponse(response);
     if (Array.isArray(result) && chainId === ChainId['linea-mainnet']) {
-      return result.filter(
+      const filteredResult = result.filter(
         (elm) =>
-          elm.aggregators.includes('lineaTeam') || elm.aggregators.length >= 3,
+          elm.aggregators.includes('lineaTeam') ?? elm.aggregators.length >= 3,
       );
+      // TODO: remove this after development is done
+      // if the filteredResult has an aggregator that includes 'Ondo' then append rwaData as metadata.
+      const filteredResultWithRwaData = filteredResult.map((elm) => {
+        const metadata = {
+          rwaData: {
+            instrumentType: 'stock',
+            ticker: elm.name?.split(' ')[0] ?? '',
+            market: {
+              nextOpen: new Date(new Date().setHours(9, 0, 0, 0)).toISOString(),
+              nextClose: new Date(new Date().setHours(16, 0, 0, 0)).toISOString(),
+            },
+            nextPause: {
+              start: new Date(new Date().setHours(16, 0, 0, 0)).toISOString(),
+              end: new Date(new Date().setHours(17, 0, 0, 0)).toISOString(),
+            },
+          },
+        };
+        if (elm.aggregators.includes('Ondo')) {
+          return { ...elm, ...metadata };
+        }
+        return elm;
+      });
+
+      console.log('filteredResult', filteredResult);
+      return filteredResultWithRwaData;
     }
     return result;
   }
   return undefined;
 }
 
+// TODO This end point already contain RwaData, so we don't need to append it here.
 /**
  * Search for tokens across one or more networks by query string using CAIP format chain IDs.
  *
@@ -180,7 +208,7 @@ export async function searchTokens(
     // The API returns an object with structure: { count: number, data: array, pageInfo: object }
     if (result && typeof result === 'object' && Array.isArray(result.data)) {
       return {
-        count: result.count || result.data.length,
+        count: result.count ?? result.data.length,
         data: result.data,
       };
     }
@@ -271,7 +299,21 @@ export async function getTrendingTokens({
 
     // Validate that the API returned an array
     if (Array.isArray(result)) {
-      return result;
+      // TODO hack the results to include RwaData
+      const filteredResultWithRwaData = result.map((elm) => {
+        const metadata = {
+          rwaData: {
+            instrumentType: 'stock',
+            ticker: elm.name?.split(' ')[0] ?? '',
+            market: {
+              nextOpen: new Date(new Date().setHours(9, 0, 0, 0)).toISOString(),
+              nextClose: new Date(new Date().setHours(16, 0, 0, 0)).toISOString(),
+            },
+          },
+        };
+        return { ...elm, ...metadata };
+      });
+      return filteredResultWithRwaData;
     }
 
     // Handle non-expected responses
@@ -306,7 +348,31 @@ export async function fetchTokenMetadata<T>(
   const tokenMetadataURL = getTokenMetadataURL(chainId, tokenAddress);
   const response = await queryApi(tokenMetadataURL, abortSignal, timeout);
   if (response) {
-    return parseJsonResponse(response) as Promise<T>;
+    const result = await parseJsonResponse(response);
+    if (Array.isArray(result)) {
+      const filteredResultWithRwaData = result.map((elm) => {
+        const metadata = {
+          rwaData: {
+            instrumentType: 'stock',
+            ticker: elm.name?.split(' ')[0] ?? '',
+            market: {
+              nextOpen: new Date(new Date().setHours(9, 0, 0, 0)).toISOString(),
+              nextClose: new Date(new Date().setHours(16, 0, 0, 0)).toISOString(),
+            },
+            nextPause: {
+              start: new Date(new Date().setHours(16, 0, 0, 0)).toISOString(),
+              end: new Date(new Date().setHours(17, 0, 0, 0)).toISOString(),
+            },
+          },
+        };
+        if (elm.aggregators.includes('Ondo')) {
+          return { ...elm, ...metadata };
+        }
+        return elm;
+      });
+      return filteredResultWithRwaData as unknown as T;
+    }
+    return result as T;
   }
   return undefined;
 }

packages/bridge-controller/src/utils/fetch.ts

@@ -53,7 +53,22 @@ export async function fetchBridgeTokens(
   const transformedTokens: Record<string, BridgeAsset> = {};
   tokens.forEach((token: unknown) => {
     if (validateSwapsTokenObject(token)) {
-      transformedTokens[token.address] = token;
+      // TODO hack the results to include RwaData
+      const metadata = {
+        rwaData: {
+          instrumentType: 'stock',
+          ticker: token.name?.split(' ')[0] ?? '',
+          market: {
+            nextOpen: new Date(new Date().setHours(9, 0, 0, 0)).toISOString(),
+            nextClose: new Date(new Date().setHours(16, 0, 0, 0)).toISOString(),
+          },
+          nextPause: {
+            start: new Date(new Date().setHours(16, 0, 0, 0)).toISOString(),
+            end: new Date(new Date().setHours(17, 0, 0, 0)).toISOString(),
+          },
+        },
+      };
+      transformedTokens[token.address] = { ...token, ...metadata };
     }
   });
   return transformedTokens;

packages/bridge-controller/src/utils/validators.ts

@@ -16,6 +16,7 @@ import {
   assert,
   pattern,
   intersection,
+  date,
 } from '@metamask/superstruct';
 import { CaipAssetTypeStruct, isStrictHexString } from '@metamask/utils';
 
@@ -86,6 +87,21 @@ export const BridgeAssetSchema = type({
    * URL for token icon
    */
   iconUrl: optional(nullable(string())),
+
+  rwaData: optional(
+    type({
+      instrumentType: string(),
+      ticker: string(),
+      market: type({
+        nextOpen: string(),
+        nextClose: string(),
+      }),
+      nextPause: type({
+        start: string(),
+        end: string(),
+      }),
+    }),
+  ),
 });
 
 const DefaultPairSchema = type({