blockworks-foundation
/
pyth-crosschain
mirror of https://github.com/blockworks-foundation/pyth-crosschain.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

bridge: bypass p2p for our own signatures 

ghstack-source-id: ce2bbc780fdc6db13b3594c01aedd8ccd57d0abf
Pull Request resolved: https://github.com/certusone/wormhole/pull/60
This commit is contained in:
Leo 2020-10-28 22:41:34 +01:00
parent 45d10618ce
commit bdd9d96559
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
bridge/cmd/guardiand/p2p.go
View File

@ -223,12 +223,11 @@ func p2p(obsvC chan *gossipv1.LockupObservation, sendC chan []byte) func(ctx con
continue continue
} }
// TODO: better way to handle our own sigs? if envl.GetFrom() == h.ID() {
//if envl.GetFrom() == h.ID() { logger.Debug("received message from ourselves, ignoring",
// logger.Debug("received message from ourselves, ignoring", zap.Any("payload", msg.Message))
// zap.Any("payload", msg.Message)) continue
// continue }
//}
logger.Debug("received message", logger.Debug("received message",
zap.Any("payload", msg.Message), zap.Any("payload", msg.Message),

3
bridge/cmd/guardiand/processor.go
View File

@ -151,6 +151,9 @@ func vaaConsensusProcessor(lockC chan *common.ChainLock, setC chan *common.Guard
} }
state.vaaSignatures[hash].ourVAA = v state.vaaSignatures[hash].ourVAA = v
// Fast path for our own signature
go func() { obsvC <- &obsv }()
case m := <-obsvC: case m := <-obsvC:
// SECURITY: at this point, observations received from the p2p network are fully untrusted (all fields!) // SECURITY: at this point, observations received from the p2p network are fully untrusted (all fields!)
// //