Merge pull request #61 from blinklabs-io/feat/indexer-bulk-mode

feat: use bulk mode for chainsync

Author: agaffney

internal/indexer/indexer.go

@@ -23,8 +23,9 @@ type Domain struct {
 }
 
 type Indexer struct {
-pipeline *pipeline.Pipeline
-domains map[string]Domain
+pipeline *pipeline.Pipeline
+domains map[string]Domain
+tipReached bool
 }
 
 // Singleton indexer instance
@@ -43,7 +44,12 @@ func (i *Indexer) Start() error {
 if err := state.GetState().UpdateCursor(status.SlotNumber, status.BlockHash); err != nil {
 logger.Errorf("failed to update cursor: %s", err)
 }
+if !i.tipReached && status.TipReached {
+i.tipReached = true
+logger.Infof("caught up to chain tip")
+}
 }),
+input_chainsync.WithBulkMode(true),
 }
 if cfg.Indexer.NetworkMagic > 0 {
 inputOpts = append(