certusone
/
wormhole-explorer
mirror of https://github.com/certusone/wormhole-explorer.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Avoid process pyth message in analytic (#235)

This commit is contained in:
walker-16 2023-04-14 12:11:47 -03:00 committed by GitHub
parent abf4a690da
commit 2028277b30
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
analytic/cmd/main.go
View File

@ -63,7 +63,7 @@ func main() {
// create and start a consumer.
vaaConsumeFunc := newVAAConsume(rootCtx, config, logger)
consumer := consumer.New(vaaConsumeFunc, metric.Push, logger)
consumer := consumer.New(vaaConsumeFunc, metric.Push, logger, config.P2pNetwork)
consumer.Start(rootCtx)
// create and start server.

14
analytic/consumer/consumer.go
View File

@ -5,7 +5,9 @@ import (
"github.com/wormhole-foundation/wormhole-explorer/analytic/metric"
"github.com/wormhole-foundation/wormhole-explorer/analytic/queue"
"github.com/wormhole-foundation/wormhole-explorer/common/domain"
"github.com/wormhole-foundation/wormhole/sdk/vaa"
vaa_sdk "github.com/wormhole-foundation/wormhole/sdk/vaa"
"go.uber.org/zap"
)
@ -14,11 +16,12 @@ type Consumer struct {
consume queue.VAAConsumeFunc
pushMetric metric.MetricPushFunc
logger *zap.Logger
p2pNetwork string
}
// New creates a new vaa consumer.
func New(consume queue.VAAConsumeFunc, pushMetric metric.MetricPushFunc, logger *zap.Logger) *Consumer {
return &Consumer{consume: consume, pushMetric: pushMetric, logger: logger}
func New(consume queue.VAAConsumeFunc, pushMetric metric.MetricPushFunc, logger *zap.Logger, p2pNetwork string) *Consumer {
return &Consumer{consume: consume, pushMetric: pushMetric, logger: logger, p2pNetwork: p2pNetwork}
}
// Start consumes messages from VAA queue, parse and store those messages in a repository.
@ -42,6 +45,13 @@ func (c *Consumer) Start(ctx context.Context) {
continue
}
// filter vaa from pythnet.
if c.p2pNetwork == domain.P2pMainNet && vaa_sdk.ChainIDPythNet == vaa.EmitterChain {
c.logger.Debug("Skip vaa from pythnet", zap.String("id", event.ID))
msg.Done()
continue
}
// push vaa metrics.
err = c.pushMetric(ctx, vaa)
if err != nil {