add sns for transfers

enjin · Oct 12, 2023 · 582c7bb · 582c7bb
1 parent aeb4cf6
commit 582c7bb
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/src/mappings/balances/events/transfer.ts b/src/mappings/balances/events/transfer.ts
@@ -6,6 +6,7 @@ import { BalancesTransferEvent } from '../../../types/generated/events'
 import { BalancesTransfer, Event as EventModel, Extrinsic } from '../../../model'
 import { Event } from '../../../types/generated/support'
 import { CommonContext } from '../../types/contexts'
+import { Sns } from '../../../common/sns'
 
 interface EventData {
     from: Uint8Array
@@ -32,6 +33,19 @@ export async function transfer(
     const eventData = getEventData(ctx, item.event)
     if (!eventData) return undefined
 
+    if (item.event.extrinsic) {
+        await Sns.getInstance().send({
+            id: item.event.id,
+            name: item.event.name,
+            body: {
+                from: u8aToHex(eventData.from),
+                to: u8aToHex(eventData.to),
+                amount: eventData.amount,
+                extrinsic: item.event.extrinsic.id,
+            },
+        })
+    }
+
     return new EventModel({
         id: item.event.id,
         extrinsic: item.event.extrinsic?.id ? new Extrinsic({ id: item.event.extrinsic.id }) : null,