Do not store pythnet observations (#49)

2022-12-26 19:30:58 -03:00 · 2022-12-26 19:30:58 -03:00 · 43c529e5d3
parent 9f035b40bd
commit 43c529e5d3
1 changed files with 5 additions and 0 deletions
--- a/fly/storage/repository.go
+++ b/fly/storage/repository.go
@ -95,6 +95,11 @@ func (s *Repository) UpsertObservation(o *gossipv1.SignedObservation) error {
 	now := time.Now()
 	//TODO error handling
 	chainId, err := strconv.ParseUint(chainIdStr, 10, 16)
+
+	// TODO should we notify the caller that pyth observations are not stored?
+	if vaa.ChainID(chainId) == vaa.ChainIDPythNet {
+		return nil
+	}
 	sequence, err := strconv.ParseUint(sequenceStr, 10, 64)
 	addr := eth_common.BytesToAddress(o.GetAddr())
 	obs := ObservationUpdate{