Skip to content

Commit

Permalink
fixup: integrate bg router
Browse files Browse the repository at this point in the history
  • Loading branch information
bryanchriswhite committed Jun 22, 2023
1 parent bf6a85d commit ca0b962
Showing 1 changed file with 10 additions and 1 deletion.
11 changes: 10 additions & 1 deletion p2p/module.go
Original file line number Diff line number Diff line change
Expand Up @@ -245,7 +245,16 @@ func (m *p2pModule) Send(addr cryptoPocket.Address, msg *anypb.Any) error {
}

unstakedSendErr := m.unstakedActorRouter.Send(poktEnvelopeBz, addr)
stakedSendErr := m.stakedActorRouter.Send(poktEnvelopeBz, addr)

isStaked, err := m.isStakedActor()
if err != nil {
return err
}

var stakedSendErr error
if isStaked {
stakedSendErr = m.stakedActorRouter.Send(poktEnvelopeBz, addr)
}

if errors.Is(unstakedSendErr, typesP2P.ErrUnknownPeer) &&
errors.Is(stakedSendErr, typesP2P.ErrUnknownPeer) {
Expand Down

0 comments on commit ca0b962

Please sign in to comment.