diff --git a/internal/sub/jetstream.go b/internal/sub/jetstream.go index 8bbaca6..c37d982 100644 --- a/internal/sub/jetstream.go +++ b/internal/sub/jetstream.go @@ -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