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

Remove persistence remainders from the guardian 

Change-Id: I1c4c02820c2e5c0aca0c07402b854ffebd5cff0b
This commit is contained in:
Hendrik Hofstadt 2021-07-20 23:50:38 +02:00
parent c0228415f8
commit 9fbb8d76c9
4 changed files with 35 additions and 73 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
bridge/pkg/common/chainlock.go
View File

@ -17,5 +17,4 @@ type MessagePublication struct {
EmitterChain vaa.ChainID EmitterChain vaa.ChainID
EmitterAddress vaa.Address EmitterAddress vaa.Address
Payload []byte Payload []byte
Persist bool
} }

99
bridge/pkg/ethereum/abi/abi.go
View File

File diff suppressed because one or more lines are too long

3
bridge/pkg/ethereum/watcher.go
View File

@ -186,8 +186,7 @@ func (e *EthBridgeWatcher) Run(ctx context.Context) error {
EmitterChain: vaa.ChainIDEthereum, EmitterChain: vaa.ChainIDEthereum,
EmitterAddress: PadAddress(ev.Sender), EmitterAddress: PadAddress(ev.Sender),
Payload: ev.Payload, Payload: ev.Payload,
Persist: ev.PersistMessage, ConsistencyLevel: ev.ConsistencyLevel,
ConsistencyLevel: ev.Commitment,
} }
logger.Info("found new lockup transaction", zap.Stringer("tx", ev.Raw.TxHash), logger.Info("found new lockup transaction", zap.Stringer("tx", ev.Raw.TxHash),

5
bridge/pkg/terra/watcher.go
View File

@ -178,11 +178,10 @@ func (e *BridgeWatcher) Run(ctx context.Context) error {
nonce := gjson.Get(json, "result.events.from_contract\\.message\\.nonce.0") nonce := gjson.Get(json, "result.events.from_contract\\.message\\.nonce.0")
sequence := gjson.Get(json, "result.events.from_contract\\.message\\.sequence.0") sequence := gjson.Get(json, "result.events.from_contract\\.message\\.sequence.0")
blockTime := gjson.Get(json, "result.events.from_contract\\.message\\.block_time.0") blockTime := gjson.Get(json, "result.events.from_contract\\.message\\.block_time.0")
persist := gjson.Get(json, "result.events.from_contract\\.message\\.persist.0")
txHash := gjson.Get(json, "result.events.tx\\.hash.0") txHash := gjson.Get(json, "result.events.tx\\.hash.0")
if payload.Exists() && sender.Exists() && chainId.Exists() && nonce.Exists() && sequence.Exists() && if payload.Exists() && sender.Exists() && chainId.Exists() && nonce.Exists() && sequence.Exists() &&
blockTime.Exists() && txHash.Exists() && persist.Exists() { blockTime.Exists() && txHash.Exists() {
logger.Info("new message detected on terra", logger.Info("new message detected on terra",
zap.String("chainId", chainId.String()), zap.String("chainId", chainId.String()),
@ -191,7 +190,6 @@ func (e *BridgeWatcher) Run(ctx context.Context) error {
zap.String("nonce", nonce.String()), zap.String("nonce", nonce.String()),
zap.String("sequence", sequence.String()), zap.String("sequence", sequence.String()),
zap.String("blockTime", blockTime.String()), zap.String("blockTime", blockTime.String()),
zap.String("persist", persist.String()),
) )
senderAddress, err := StringToAddress(sender.String()) senderAddress, err := StringToAddress(sender.String())
@ -218,7 +216,6 @@ func (e *BridgeWatcher) Run(ctx context.Context) error {
EmitterChain: vaa.ChainIDTerra, EmitterChain: vaa.ChainIDTerra,
EmitterAddress: senderAddress, EmitterAddress: senderAddress,
Payload: payloadValue, Payload: payloadValue,
Persist: persist.Bool(),
ConsistencyLevel: 0, // Instant finality ConsistencyLevel: 0, // Instant finality
} }
e.msgChan <- messagePublication e.msgChan <- messagePublication