feat: automatically track core vault xrp transactions

Author: kuco23

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

@@ -10,6 +10,7 @@ import type { XrpContext } from "../context"
 
 export class XrpIndexer {
   private tracked = new Set<string>()
+  private coreVaultLoaded: boolean = false
 
   constructor(
     public readonly context: XrpContext,
@@ -26,14 +27,6 @@ export class XrpIndexer {
     return this.runHistoric(startBlock)
   }
 
-  async updateTrackedAddresses(): Promise<void> {
-    const agents = await this.context.orm.em.fork().findAll(
-      Entities.AgentVault, { populate: [ 'underlyingAddress' ] })
-    for (const agent of agents) {
-      this.tracked.add(agent.underlyingAddress.text)
-    }
-  }
-
   async runHistoric(startBlock?: number, endBlock?: number): Promise<void> {
     const firstUnhandledBlock = await this.firstUnhandledBlock(startBlock)
     if (startBlock === undefined || firstUnhandledBlock > startBlock) {
@@ -78,6 +71,12 @@ export class XrpIndexer {
     await setVar(em, this.firstUnhandledBlockDbKey, block.toString())
   }
 
+  protected async updateTrackedAddresses(): Promise<void> {
+    const em = this.context.orm.em.fork()
+    await this.updateCoreVaultTracking(em)
+    await this.updateAgentVaultTracking(em)
+  }
+
   protected async processBlock(block: IXrpBlock): Promise<void> {
     await this.context.orm.em.transactional(async em => {
     let blockEnt = await em.findOne(Entities.UnderlyingBlock, { hash: block.ledger_hash })
@@ -136,6 +135,25 @@ export class XrpIndexer {
     })
   }
 
+  private async updateCoreVaultTracking(em: EntityManager): Promise<void> {
+    if (this.coreVaultLoaded) return
+    const settings = await em.findOne(Entities.CoreVaultManagerSettings,
+      { fasset: FAssetType.FXRP }, { populate: ['coreVault'] }
+    )
+    if (settings != null && settings.coreVault != null) {
+      this.tracked.add(settings.coreVault.text)
+      this.coreVaultLoaded = true
+    }
+  }
+
+  private async updateAgentVaultTracking(em: EntityManager): Promise<void> {
+    const agents = await em.findAll(
+      Entities.AgentVault, { populate: [ 'underlyingAddress' ] })
+    for (const agent of agents) {
+      this.tracked.add(agent.underlyingAddress.text)
+    }
+  }
+
   private async storeXrpBlock(em: EntityManager, xrpBlock: IXrpBlock): Promise<Entities.UnderlyingBlock> {
     return em.create(Entities.UnderlyingBlock, {
       hash: xrpBlock.ledger_hash, height: xrpBlock.ledger_index,