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

aptos/watcher_fix: make it just try again instead of restarting the watcher

This commit is contained in:
Josh Siegel 2022-10-19 01:38:30 +00:00 committed by jumpsiegel
parent 557a32b8f4
commit 80e39a8128
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
node/pkg/watchers/aptos/watcher.go
View File

@ -108,7 +108,7 @@ func (e *Watcher) Run(ctx context.Context) error {
if err != nil {
logger.Error("retrievePayload", zap.Error(err))
p2p.DefaultRegistry.AddErrorCount(vaa.ChainIDAptos, 1)
return err
continue
}
if !gjson.Valid(string(body)) {
@ -156,7 +156,7 @@ func (e *Watcher) Run(ctx context.Context) error {
if err != nil {
logger.Error("retrievePayload", zap.Error(err))
p2p.DefaultRegistry.AddErrorCount(vaa.ChainIDAptos, 1)
return err
continue
}
// data doesn't exist yet. skip, and try again later
@ -169,7 +169,7 @@ func (e *Watcher) Run(ctx context.Context) error {
if !gjson.Valid(string(eventsJson)) {
logger.Error("InvalidJson: " + string(eventsJson))
p2p.DefaultRegistry.AddErrorCount(vaa.ChainIDAptos, 1)
break
continue
}
@ -198,7 +198,7 @@ func (e *Watcher) Run(ctx context.Context) error {
if err != nil {
logger.Error("health", zap.Error(err))
p2p.DefaultRegistry.AddErrorCount(vaa.ChainIDAptos, 1)
return err
continue
}
if !gjson.Valid(string(health)) {