grassrootseconomics/eth-indexer
7
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add all events handler

Browse Source
This commit is contained in:
Mohamed Sohail 2024-06-03 11:00:28 +08:00
parent ccfc2843b2
commit 0906110ab6
Signed by: kamikazechaser
GPG Key ID: 7DD45520C01CD85D
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/sub/jetstream.go
View File

@ -115,18 +115,30 @@ func (s *JetStreamSub) processEventHandler(ctx context.Context, msgSubject strin
if err := s.store.InsertTokenTransfer(ctx, chainEvent); err != nil {
return err
}
case "TRACKER.TOKEN_MINT":
if err := s.store.InsertTokenMint(ctx, chainEvent); err != nil {
return err
}
case "TRACKER.POOL_SWAP":
if err := s.store.InsertPoolSwap(ctx, chainEvent); err != nil {
return err
}
case "TRACKER.FAUCET_GIVE":
if err := s.store.InsertFaucetGive(ctx, chainEvent); err != nil {
return err
}
case "TRACKER.POOL_DEPOSIT":
if err := s.store.InsertPoolDeposit(ctx, chainEvent); err != nil {
return err
}
case "TRACKER.TOKEN_MINT":
if err := s.store.InsertTokenMint(ctx, chainEvent); err != nil {
return err
}
case "TRACKER.TOKEN_BURN":
if err := s.store.InsertTokenBurn(ctx, chainEvent); err != nil {
return err
}
case "TRACKER.QUOTER_PRICE_INDEX_UPDATED":
if err := s.store.InsertPriceQuoteUpdate(ctx, chainEvent); err != nil {
return err
}
}
return nil