return early if indexer is null

2026-01-12 07:42:48 +00:00 · 2021-12-14 12:33:13 +01:00
1 changed files with 3 additions and 0 deletions
--- a/internal/state/indexer/indexer_service.go
+++ b/internal/state/indexer/indexer_service.go
@@ -83,6 +83,9 @@ func (is *Service) publish(msg pubsub.Message) error {
 	if curr.Pending == 0 {
 		// INDEX: We have all the transactions we expect for the current block.
 		for _, sink := range is.eventSinks {
+			if sink.Type() == NULL {
+				return nil // if indexer is set to null return early
+			}
 			start := time.Now()
 			if err := sink.IndexBlockEvents(is.currentBlock.header); err != nil {
 				is.logger.Error("failed to index block header",