poanetwork
/
tokenbridge-monitor
mirror of https://github.com/poanetwork/tokenbridge-monitor.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix panic in presenter

This commit is contained in:
Kirill Fedoseev 2021-10-24 23:10:44 +03:00
parent a99e5d94a6
commit 2d0e916f26
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ethclient/ethclient.go
View File

@ -52,7 +52,7 @@ func (c *Client) BlockNumber(ctx context.Context) (uint64, error) {
defer cancel()
n, err := c.client.BlockNumber(ctx)
ObserveError(c.ChainID, c.url, "eth_getBlockByNumber", err)
ObserveError(c.ChainID, c.url, "eth_blockNumber", err)
return n, err
}

12
presenter/presenter.go
View File

@ -125,7 +125,7 @@ func (p *Presenter) searchSentMessage(ctx context.Context, log *entity.Log) (*Se
}
msg, err := p.repo.Messages.FindByMsgHash(ctx, sent.BridgeID, sent.MsgHash)
if err != nil {
if err != nil || msg == nil {
return nil, err
}
events, err := p.buildMessageEvents(ctx, msg)
@ -148,7 +148,7 @@ func (p *Presenter) searchSignedMessage(ctx context.Context, log *entity.Log) (*
}
msg, err := p.repo.Messages.FindByMsgHash(ctx, sig.BridgeID, sig.MsgHash)
if err != nil {
if err != nil || msg == nil {
return nil, err
}
events, err := p.buildMessageEvents(ctx, msg)
@ -171,7 +171,7 @@ func (p *Presenter) searchExecutedMessage(ctx context.Context, log *entity.Log)
}
msg, err := p.repo.Messages.FindByMessageID(ctx, executed.BridgeID, executed.MessageID)
if err != nil {
if err != nil || msg == nil {
return nil, err
}
events, err := p.buildMessageEvents(ctx, msg)
@ -194,7 +194,7 @@ func (p *Presenter) searchSentInformationRequest(ctx context.Context, log *entit
}
req, err := p.repo.InformationRequests.FindByMessageID(ctx, sent.BridgeID, sent.MessageID)
if err != nil {
if err != nil || req == nil {
return nil, err
}
events, err := p.buildInformationRequestEvents(ctx, req)
@ -217,7 +217,7 @@ func (p *Presenter) searchSignedInformationRequest(ctx context.Context, log *ent
}
req, err := p.repo.InformationRequests.FindByMessageID(ctx, signed.BridgeID, signed.MessageID)
if err != nil {
if err != nil || req == nil {
return nil, err
}
events, err := p.buildInformationRequestEvents(ctx, req)
@ -240,7 +240,7 @@ func (p *Presenter) searchExecutedInformationRequest(ctx context.Context, log *e
}
req, err := p.repo.InformationRequests.FindByMessageID(ctx, executed.BridgeID, executed.MessageID)
if err != nil {
if err != nil || req == nil {
return nil, err
}
events, err := p.buildInformationRequestEvents(ctx, req)