From dfcdb65b4527bb5c7dcf0dce0a56359dd2b46af4 Mon Sep 17 00:00:00 2001
From: Aleksandr Malina <ef1rspb@gmail.com>
Date: Thu, 19 Aug 2021 10:58:43 +0300
Subject: [PATCH] Clear cache

---
 src/mappings/StakeChanged.ts | 2 ++
 src/mappings/common.ts       | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/src/mappings/StakeChanged.ts b/src/mappings/StakeChanged.ts
index 81d8c23b..9ee859f2 100644
--- a/src/mappings/StakeChanged.ts
+++ b/src/mappings/StakeChanged.ts
@@ -55,6 +55,7 @@ export async function handleSlashForAnalytics(event: SubstrateEvent): Promise<vo
     await element.save()
 }
 
+// Due to memory consumption optimization `rewardDestinationByAddress` contains only one key
 let rewardDestinationByAddress: {[blockId: string]: {[address: string]: RewardDestination}} = {}
 
 async function cachedRewardDestination(accountAddress: string, event: SubstrateEvent): Promise<RewardDestination> {
@@ -64,6 +65,7 @@ async function cachedRewardDestination(accountAddress: string, event: SubstrateE
     if (cachedBlock !== undefined) {
         return cachedBlock[accountAddress]
     } else {
+        rewardDestinationByAddress = {}
         const allAccountsInBlock = event.block.events
             .filter(event => { 
                 return event.event.method == "Reward" && event.event.section == "staking"
diff --git a/src/mappings/common.ts b/src/mappings/common.ts
index 050ec300..0b1b1bd8 100644
--- a/src/mappings/common.ts
+++ b/src/mappings/common.ts
@@ -99,6 +99,7 @@ export async function cachedCurrentEra(block: SubstrateBlock): Promise<EraIndex>
     }
 }
 
+// Due to memory consumption optimization `eraStakersByEra` contains only one key
 let eraStakersByEra: {[era: number]: [StorageKey<[EraIndex, AccountId]>, Exposure][]} = {}
 
 export async function cachedEraStakers(era: number): Promise<[StorageKey<[EraIndex, AccountId]>, Exposure][]> {
@@ -106,6 +107,7 @@ export async function cachedEraStakers(era: number): Promise<[StorageKey<[EraInd
     if (cachedValue !== undefined) {
         return cachedValue
     } else {
+        eraStakersByEra = {}
         let eraStakers = await api.query.staking.erasStakers.entries(era);
         eraStakersByEra[era] = eraStakers
         return eraStakers