Merge pull request #1473 from mars-protocol/develop

getPrices

Author: linkielink

package.json

@@ -22,10 +22,10 @@
   "dependencies": {
     "@cosmjs/cosmwasm-stargate": "^0.33.1",
     "@delphi-labs/shuttle-react": "^4.2.0",
-    "@keplr-wallet/cosmos": "^0.12.223",
+    "@keplr-wallet/cosmos": "^0.12.230",
     "@next/eslint-plugin-next": "^15.3.1",
     "@skip-go/client": "^0.16.30",
-    "@solana/web3.js": "^1.98.1",
+    "@solana/web3.js": "^1.98.2",
     "@tanstack/react-query": "^5.74.4",
     "@tanstack/react-table": "^8.21.3",
     "@tippyjs/react": "^4.2.6",
@@ -48,7 +48,7 @@
     "react-draggable": "^4.4.6",
     "react-helmet-async": "^2.0.5",
     "react-qr-code": "^2.0.15",
-    "react-router-dom": "^7.5.1",
+    "react-router-dom": "^7.5.3",
     "react-spring": "^9.7.5",
     "react-toastify": "^11.0.5",
     "react-use-clipboard": "^1.0.9",
@@ -57,7 +57,7 @@
     "starknet": "^6.24.1",
     "swr": "^2.3.3",
     "viem": "^2.28.0",
-    "wagmi": "^2.14.16",
+    "wagmi": "^2.15.2",
     "zustand": "5.0.3"
   },
   "devDependencies": {

src/api/prices/getOraclePrices.ts

@@ -13,17 +13,47 @@ function getAssetPrice(asset: Asset, priceResult: PriceResponse): BNCoin {
   return BNCoin.fromDenomAndBigNumber(asset.denom, price.shiftedBy(decimalDiff))
 }
 
+function chunkArray<T>(array: T[], chunkSize: number): T[][] {
+  const chunks: T[][] = []
+  for (let i = 0; i < array.length; i += chunkSize) {
+    chunks.push(array.slice(i, i + chunkSize))
+  }
+  return chunks
+}
+
 export default async function getOraclePrices(
   chainConfig: ChainConfig,
   assets: Asset[],
 ): Promise<BNCoin[]> {
-  const oracleQueryClient = chainConfig.isOsmosis
-    ? await getOracleQueryClientOsmosis(chainConfig)
-    : await getOracleQueryClientNeutron(chainConfig)
+  if (!assets.length) return []
   try {
-    if (!assets.length) return []
+    let priceResults: PriceResponse[] = []
+    if (chainConfig.isOsmosis) {
+      const osmosisOracleQueryClient = await getOracleQueryClientOsmosis(chainConfig)
+      priceResults = await iterateContractQuery(osmosisOracleQueryClient.prices)
+    } else {
+      const neutronOracleQueryClient = await getOracleQueryClientNeutron(chainConfig)
+      const denoms = assets.map((asset) => asset.denom)
+
+      const denomChunks = chunkArray(denoms, 3)
 
-    const priceResults = await iterateContractQuery(oracleQueryClient.prices)
+      const chunkResults = await Promise.all(
+        denomChunks.map(async (chunk) => {
+          return await neutronOracleQueryClient.pricesByDenoms({ denoms: chunk, kind: 'default' })
+        }),
+      )
+
+      priceResults = chunkResults.reduce((acc: PriceResponse[], result) => {
+        if (result && typeof result === 'object') {
+          const priceEntries = Object.entries(result).map(([denom, price]) => ({
+            denom,
+            price: String(price),
+          })) as PriceResponse[]
+          return [...acc, ...priceEntries]
+        }
+        return acc
+      }, [])
+    }
 
     return assets.map((asset) => {
       const priceResponse = priceResults.find(byDenom(asset.denom)) as PriceResponse
@@ -32,9 +62,12 @@ export default async function getOraclePrices(
   } catch (error) {
     console.error(error)
     try {
+      const queryClient = chainConfig.isOsmosis
+        ? await getOracleQueryClientOsmosis(chainConfig)
+        : await getOracleQueryClientNeutron(chainConfig)
       return Promise.all(
         assets.map(async (asset) => {
-          const priceResponse = await oracleQueryClient.price({ denom: asset.denom })
+          const priceResponse = await queryClient.price({ denom: asset.denom })
           return getAssetPrice(asset, priceResponse)
         }),
       )