diff --git a/bridge/cmd/guardiand/ethwatch.go b/bridge/cmd/guardiand/ethwatch.go index fc3d9365..b05cc0e3 100644 --- a/bridge/cmd/guardiand/ethwatch.go +++ b/bridge/cmd/guardiand/ethwatch.go @@ -247,7 +247,7 @@ func ethLockupProcessor(lockC chan *common.ChainLock, setC chan *common.Guardian ) if *unsafeDevMode && len(sigs) >= quorum { - _, err := devnet.GetDevnetIndex() + idx, err := devnet.GetDevnetIndex() if err != nil { return err } @@ -263,9 +263,9 @@ func ethLockupProcessor(lockC chan *common.ChainLock, setC chan *common.Guardian zap.Binary("bytes", vaaBytes)) // TODO: actually submit to Solana once the agent works and has a reasonable key - //if idx == 0 { - // vaaC <- state.lockupSignatures[hash].ourVAA - //} + if idx == 0 { + vaaC <- state.lockupSignatures[hash].ourVAA + } } else if !*unsafeDevMode { panic("not implemented") // TODO } else { diff --git a/bridge/pkg/solana/watcher.go b/bridge/pkg/solana/watcher.go index d473a9ff..aedef9b0 100644 --- a/bridge/pkg/solana/watcher.go +++ b/bridge/pkg/solana/watcher.go @@ -93,8 +93,8 @@ func (e *SolanaBridgeWatcher) Run(ctx context.Context) error { timeout, _ := context.WithTimeout(ctx, 15*time.Second) res, err := c.SubmitVAA(timeout, &agentv1.SubmitVAARequest{Vaa: vaaBytes}) if err != nil { - errC <- fmt.Errorf("failed to submit VAA: %w", err) - return + logger.Error("failed to submit VAA", zap.Error(err)) + break } logger.Info("submitted VAA", diff --git a/devnet/bridge.yaml b/devnet/bridge.yaml index 6c139685..05245a93 100644 --- a/devnet/bridge.yaml +++ b/devnet/bridge.yaml @@ -42,7 +42,7 @@ spec: - -ethRPC - ws://eth-devnet:8545 - -agentRPC - - http://localhost:9000 + - localhost:9000 - -ethConfirmations - '1' - -unsafeDevMode