wip: rate fetching

Author: hyphenized

background/services/indexing/db.ts

@@ -121,6 +121,13 @@ function numberArrayCompare(arr1: number[], arr2: number[]) {
   return 0
 }
 
+type FeedRate = {
+  id: string
+  value: bigint
+  decimals: bigint
+  time: number
+}
+
 export class IndexingDatabase extends Dexie {
   private prices!: Dexie.Table<PriceMeasurement, number>
 
@@ -139,6 +146,11 @@ export class IndexingDatabase extends Dexie {
    */
   private customAssets!: Dexie.Table<CustomAsset, number>
 
+  /**
+   * Currency exchange rates
+   */
+  private currencyRates!: Dexie.Table<FeedRate, "id">
+
   /*
    * Tokens whose balances should be checked periodically. It might make sense
    * for this to be tracked against particular accounts in the future.
@@ -256,6 +268,8 @@ export class IndexingDatabase extends Dexie {
           delete customAsset.metadata?.discoveryTxHash
         }),
     )
+
+    this.version(7).stores({ currencyRates: "&id" })
   }
 
   async savePriceMeasurement(
@@ -429,6 +443,14 @@ export class IndexingDatabase extends Dexie {
       tokenList: v as TokenList,
     }))
   }
+
+  async getCurrencyRates(): Promise<FeedRate[]> {
+    return this.currencyRates.toArray()
+  }
+
+  async saveCurrencyRates(rates: FeedRate[]): Promise<void> {
+    await this.currencyRates.bulkPut(rates)
+  }
 }
 
 export async function getOrCreateDb(

background/services/indexing/index.ts

@@ -57,6 +57,7 @@ import {
   isSameAsset,
 } from "../../redux-slices/utils/asset-utils"
 import { wrapIfEnabled } from "../../features"
+import fetchRatesFromPriceFeeds from "./price-feeds"
 
 // Transactions seen within this many blocks of the chain tip will schedule a
 // token refresh sooner than the standard rate.
@@ -1108,11 +1109,19 @@ export default class IndexingService extends BaseService<Events> {
   private async handleCurrencyRatesAlarm(): Promise<void> {
     logger.info("Syncing currency rates...")
 
-    const rate = {
-      code: "EUR",
-      rate: { amount: BigInt("0x06f9d7c8"), decimals: 8n },
-    }
+    const rates = await fetchRatesFromPriceFeeds(this.chainService)
+
+    this.db.saveCurrencyRates(Object.values(rates))
+
+    const currencies = Object.keys(rates).map((id) => {
+      const currencyCode = id.split("/")[0]
+
+      return {
+        code: currencyCode,
+        rate: { amount: rates[id].value, decimals: rates[id].decimals },
+      }
+    })
 
-    this.emitter.emit("updatedCurrencyRates", [rate])
+    this.emitter.emit("updatedCurrencyRates", currencies)
   }
 }

background/services/indexing/price-feeds.ts

@@ -22,6 +22,7 @@ type FeedRate = {
   id: string
   value: bigint
   decimals: bigint
+  time: number
 }
 
 export default async function fetchRatesFromPriceFeeds(
@@ -44,6 +45,7 @@ export default async function fetchRatesFromPriceFeeds(
         id,
         value: (await contract.callStatic.latestRoundData()) as BigNumber,
         decimals: (await contract.callStatic.decimals()) as number,
+        time: Date.now(),
       }
     }),
   )
@@ -55,6 +57,7 @@ export default async function fetchRatesFromPriceFeeds(
         id: feed.id,
         value: feed.value.toBigInt(),
         decimals: BigInt(feed.decimals),
+        time: feed.time,
       },
     ]),
   )

background/services/redux/index.ts

@@ -947,16 +947,27 @@ export default class ReduxService extends BaseService<never> {
       this.store.dispatch(
         setDisplayCurrency({
           code: "USD",
-          rate: { amount: 1000000n, decimals: 6n },
+          rate: { amount: 1000000n, decimals: 10n },
         }),
       )
     }
 
-    this.indexingService.emitter.on("updatedCurrencyRates", async (rates) => {
-      // const currency = await this.preferenceService.getCurrency()
+    this.indexingService.emitter.on(
+      "updatedCurrencyRates",
+      async (currencies) => {
+        const currency = await this.preferenceService.getCurrency()
 
-      this.store.dispatch(setDisplayCurrency(rates[0]))
-    })
+        const fallback = {
+          code: currency.code,
+          rate: { amount: 1000000n, decimals: 10n },
+        }
+
+        const update =
+          currencies.find((rate) => rate.code === currency.code) ?? fallback
+
+        this.store.dispatch(setDisplayCurrency(update))
+      },
+    )
 
     this.indexingService.emitter.on("refreshAsset", (asset) => {
       this.store.dispatch(