Add metricsClient to processor

wormhole-foundation · Jul 4, 2023 · befed2a · befed2a
1 parent 9600ed7
commit befed2a
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 7 deletions.
diff --git a/parser/cmd/backfiller/run.go b/parser/cmd/backfiller/run.go
@@ -4,6 +4,7 @@ import (
  "context"
  "time"
 
+ "github.com/wormhole-foundation/wormhole-explorer/common/client/alert"
  "github.com/wormhole-foundation/wormhole-explorer/common/logger"
  "github.com/wormhole-foundation/wormhole-explorer/parser/config"
  "github.com/wormhole-foundation/wormhole-explorer/parser/http/vaa"
@@ -55,7 +56,7 @@ func Run(config *config.BackfillerConfiguration) {
  vaaRepository := vaa.NewRepository(db.Database, logger)
 
  //create a processor
- processor := processor.New(parserVAAAPIClient, parserRepository, metrics.NewDummyMetrics(), logger)
+ processor := processor.New(parserVAAAPIClient, parserRepository, alert.NewDummyClient(), metrics.NewDummyMetrics(), logger)
 
  logger.Info("Started wormhole-explorer-parser as backfiller")
 

diff --git a/parser/cmd/service/run.go b/parser/cmd/service/run.go
@@ -58,10 +58,10 @@ func Run() {
  }
 
  // get alert client.
- // alertClient, err := newAlertClient(config)
- // if err != nil {
- //  logger.Fatal("failed to create alert client", zap.Error(err))
- // }
+ alertClient, err := newAlertClient(config)
+ if err != nil {
+ logger.Fatal("failed to create alert client", zap.Error(err))
+ }
 
  // create a metrics
  metrics := newMetrics(config)
@@ -78,7 +78,7 @@ func Run() {
  repository := parser.NewRepository(db.Database, logger)
 
  //create a processor
- processor := processor.New(parserVAAAPIClient, repository, metrics, logger)
+ processor := processor.New(parserVAAAPIClient, repository, alertClient, metrics, logger)
 
  // create and start a consumer
  consumer := consumer.New(vaaConsumeFunc, processor.Process, metrics, logger)

diff --git a/parser/processor/processor.go b/parser/processor/processor.go
@@ -6,6 +6,7 @@ import (
  "fmt"
  "time"
 
+ "github.com/wormhole-foundation/wormhole-explorer/common/client/alert"
  "github.com/wormhole-foundation/wormhole-explorer/parser/internal/metrics"
  "github.com/wormhole-foundation/wormhole-explorer/parser/parser"
  "github.com/wormhole-foundation/wormhole/sdk/vaa"
@@ -15,11 +16,12 @@ import (
 type Processor struct {
  parser parser.ParserVAAAPIClient
  repository *parser.Repository
+ alert alert.AlertClient
  metrics metrics.Metrics
  logger *zap.Logger
 }
 
-func New(parser parser.ParserVAAAPIClient, repository *parser.Repository, metrics metrics.Metrics, logger *zap.Logger) *Processor {
+func New(parser parser.ParserVAAAPIClient, repository *parser.Repository, alert alert.AlertClient, metrics metrics.Metrics, logger *zap.Logger) *Processor {
  return &Processor{
  parser: parser,
  repository: repository,