chore(blockchain-link): cache solana epoch

Author: martykan

packages/blockchain-link/src/workers/solana/index.ts

@@ -50,7 +50,7 @@ import type * as MessageTypes from '@trezor/blockchain-link-types/src/messages';
 import { CustomError } from '@trezor/blockchain-link-types/src/constants/errors';
 import { MESSAGES, RESPONSES } from '@trezor/blockchain-link-types/src/constants';
 import { solanaUtils } from '@trezor/blockchain-link-utils';
-import { BigNumber, createLazy } from '@trezor/utils';
+import { BigNumber, createDeferred, createLazy } from '@trezor/utils';
 import {
     transformTokenInfo,
     tokenProgramsInfo,
@@ -298,6 +298,23 @@ const getAccountInfo = async (
             )
             .send();
 
+    const getEpoch = async (): Promise<number> => {
+        const cachedEpoch = await request.state.cache.get('epoch');
+
+        if (cachedEpoch) {
+            return cachedEpoch;
+        }
+
+        // for parallel requests we store the promise in the cache immediately
+        const deferred = createDeferred<number>();
+        request.state.cache.set('epoch', deferred.promise, 3_600_000);
+
+        const { epoch } = await api.rpc.getEpochInfo().send();
+        deferred.resolve(Number(epoch));
+
+        return deferred.promise;
+    };
+
     const tokenAccounts = (
         await Promise.all(
             Object.values(tokenProgramsInfo).map(programInfo =>
@@ -355,7 +372,7 @@ const getAccountInfo = async (
                 owner: accountInfo?.owner,
                 rent: Number(rent),
                 solStakingAccounts: stakingData?.stakingAccounts,
-                solEpoch: stakingData?.epoch,
+                solEpoch: await getEpoch(),
             };
         }
     }

packages/blockchain-link/src/workers/state.ts

@@ -1,14 +1,18 @@
 import { CustomError } from '@trezor/blockchain-link-types/src/constants/errors';
 import type { SubscriptionAccountInfo } from '@trezor/blockchain-link-types';
+import { Cache } from '@trezor/utils';
 
 export class WorkerState {
     addresses: string[];
     accounts: SubscriptionAccountInfo[];
     subscription: { [key: string]: unknown };
+    cache: Cache;
+
     constructor() {
         this.addresses = [];
         this.accounts = [];
         this.subscription = {};
+        this.cache = new Cache();
     }
 
     private validateAddresses(addr: string[]) {

packages/blockchain-link/src/workers/utils.ts

@@ -43,11 +43,5 @@ export const getSolanaStakingData = async (descriptor: string, isTestnet: boolea
     }
     const { result: stakingAccounts } = delegations;
 
-    const epochInfo = await solanaClient.getEpochInfo();
-    if (!epochInfo || !epochInfo.result) {
-        throw new Error('Failed to fetch epoch info');
-    }
-    const { epoch } = epochInfo.result;
-
-    return { stakingAccounts, epoch };
+    return { stakingAccounts };
 };