feat(memo): added memo handler to contributions

schema.graphql

@@ -104,6 +104,7 @@ type Bid @entity {
 type Contribution @entity {
   id: ID!
   account: String! @index
+  memo: String @index
   parachain: Parachain!
   fund: Crowdloan!
   amount: BigInt! @index

src/handlers/parachain-handler.ts

@@ -3,6 +3,7 @@ import * as Storage from '../services/storage';
 import { Crowdloan } from '../types/models/Crowdloan';
 import { parseNumber } from '../utils';
 import { CrowdloanStatus } from '../types';
+import { Contribution } from '../types/index';
 
 interface ParaInfo {
   manager: string;
@@ -65,6 +66,24 @@ export const handleCrowdloanContributed = async (substrateEvent: SubstrateEvent)
   await Storage.save('Contribution', contribution);
 };
 
+export const handleCrowdloanMemo = async (substrateEvent: SubstrateEvent) => {
+  const { event, block } = substrateEvent;
+  const { block: rawBlock } = block;
+
+  const blockNum = rawBlock.header.number.toNumber();
+  const [contributor, fundIdx, memo] = event.data.toJSON() as [string, number, string];
+  await Storage.ensureParachain(fundIdx);
+  await Storage.ensureFund(fundIdx);
+
+  const contributions = await Contribution.getByAccount(contributor);
+  const latestContributionBeforeMemo = contributions.filter((contrib) => contrib.blockNum <= blockNum).sort((a, b) => a.blockNum - b.blockNum).pop();
+
+  if (!latestContributionBeforeMemo) return;
+  latestContributionBeforeMemo.memo = memo;
+  logger.info(`Adding memo ${memo} for contributor ${contributor} at block ${blockNum}`);
+  await Storage.save('Contribution', latestContributionBeforeMemo);
+};
+
 export const updateCrowdloanStatus = async (block: SubstrateBlock) => {
   const blockNum = block.block.header.number.toNumber();
   const funds = (await Crowdloan.getByIsFinished(false)) || [];

src/mappings/mappingHandlers.ts

@@ -1,11 +1,11 @@
-import { SignedBlock } from '@polkadot/types/interfaces';
-import { SubstrateExtrinsic, SubstrateEvent } from '@subql/types';
+import { SubstrateEvent } from '@subql/types';
 import { SubstrateBlock } from '@subql/types';
 
 import {
   handleCrowdloanContributed,
   handleCrowdloanCreated,
   handleCrowdloanDissolved,
+  handleCrowdloanMemo,
   handleParachainRegistered,
   updateCrowdloanStatus
 } from '../handlers/parachain-handler';
@@ -36,6 +36,7 @@ const eventsMapping = {
   'slots/Leased': handleSlotsLeased,
   'slots/NewLeasePeriod': handleNewLeasePeriod,
   'crowdloan/Contributed': handleCrowdloanContributed,
+  'crowdloan/MemoUpdated': handleCrowdloanMemo,
   'crowdloan/Dissolved': handleCrowdloanDissolved
 };
 

src/types/models/Contribution.ts

@@ -14,6 +14,8 @@ export class Contribution implements Entity {
 
     public account: string;
 
+    public memo?: string;
+
     public parachainId: string;
 
     public fundId: string;
@@ -53,6 +55,13 @@ export class Contribution implements Entity {
 
     }
 
+    static async getByMemo(memo: string): Promise<Contribution[] | undefined>{
+
+      const records = await store.getByField('Contribution', 'memo', memo);
+      return records.map(record => Contribution.create(record));
+
+    }
+
     static async getByAmount(amount: bigint): Promise<Contribution[] | undefined>{
 
       const records = await store.getByField('Contribution', 'amount', amount);