fix: extract all event topics from event and the interfaces

Author: kuco23

packages/fasset-indexer-core/src/context/events.ts

@@ -65,22 +65,28 @@ export class EventInterface {
       const iface = this.contractToIface(contractname)
       for (const event of Object.values(EVENTS[cname])) {
         if (eventNames?.includes(event) !== false) {
-          const topic = this.getEventTopic(event, iface)
-          mp.set(topic, cname)
+          const topics = this.getEventTopics(event, iface)
+          for (const topic of topics) {
+            mp.set(topic, cname)
+          }
         }
       }
     }
     return mp
   }
 
-  getEventTopic(eventName: string, ifaces: Interface[]): string {
+  getEventTopics(eventName: string, ifaces: Interface[]): string[] {
+    const topics = new Set<string>()
     for (const iface of ifaces) {
       const parsed = iface.getEvent(eventName)
       if (parsed != null) {
-        return parsed.topicHash
+        topics.add(parsed.topicHash)
       }
     }
-    throw new Error(`Event ${eventName} not found in interface`)
+    if (topics.size == 0) {
+       new Error(`Event ${eventName} not found in interface`)
+    }
+    return Array.from(topics)
   }
 
   contractToIface(name: string): Interface[] {

packages/fasset-indexer-core/src/indexer/eventlib/event-storer.ts

@@ -22,8 +22,8 @@ export class EventStorer {
 
   constructor(readonly orm: ORM, public readonly lookup: ContractLookup) {
     const oldIface = this.lookup.interfaces.assetManagerInterface[0]
-    this.oldCollateralTypeAddedTopic = this.lookup.getEventTopic(EVENTS.ASSET_MANAGER.COLLATERAL_TYPE_ADDED, [oldIface])
-    this.oldAgentVaultCreatedTopic = this.lookup.getEventTopic(EVENTS.ASSET_MANAGER.AGENT_VAULT_CREATED, [oldIface])
+    this.oldCollateralTypeAddedTopic = this.lookup.getEventTopics(EVENTS.ASSET_MANAGER.COLLATERAL_TYPE_ADDED, [oldIface])[0]
+    this.oldAgentVaultCreatedTopic = this.lookup.getEventTopics(EVENTS.ASSET_MANAGER.AGENT_VAULT_CREATED, [oldIface])[0]
   }
 
   async processEvent(log: Event): Promise<void> {

packages/fasset-indexer-core/src/indexer/indexer.ts

@@ -63,8 +63,10 @@ export class EventIndexer {
 
   protected async storeLogs(logs: Log[]): Promise<void> {
     for (const log of logs) {
+      if (log.index > 0) break
+      console.log(log)
       const fullLog = await this.eventParser.logToEvent(log)
-      if (fullLog !== null) {
+      if (fullLog != null) {
         logger.info(`event indexer is processing event ${fullLog.name} (block: ${fullLog.blockNumber}, index: ${fullLog.logIndex})`)
         await this.stateUpdater.processEvent(fullLog)
       }

packages/fasset-indexer-core/src/scripts/find-event-changed-topics.ts

@@ -11,8 +11,8 @@ async function am(context: Context) {
   for (const iface of Object.keys(EVENTS)) {
     if (iface != 'ASSET_MANAGER') continue
     for (const event of Object.values(EVENTS[iface as keyof typeof EVENTS])) {
-      const resp1 = context.getEventTopic(event, [iface1])
-      const resp2 = context.getEventTopic(event, [iface2])
+      const resp1 = context.getEventTopics(event, [iface1])[0]
+      const resp2 = context.getEventTopics(event, [iface2])[0]
       if (resp1 != resp2) console.log(event)
     }
   }