Skip to content

Commit c43ecd6

Browse files
Merge pull request #360 from icon-project/bugfix/12-icon-bridge-planning-fix-error-message-use-context
use appropriate error message + use context in GetMedianGasPriceForBlock
2 parents b7118b8 + f6448f8 commit c43ecd6

File tree

4 files changed

+11
-11
lines changed

4 files changed

+11
-11
lines changed

cmd/e2etest/chain/bsc/client.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ func NewClients(urls []string, l log.Logger) (cls []*Client, err error) {
1414
for _, url := range urls {
1515
clrpc, err := rpc.Dial(url)
1616
if err != nil {
17-
l.Errorf("failed to create hmny rpc client: url=%v, %v", url, err)
17+
l.Errorf("failed to create bsc rpc client: url=%v, %v", url, err)
1818
return nil, err
1919
}
2020
cleth := ethclient.NewClient(clrpc)

cmd/iconbridge/chain/bsc/client.go

+7-7
Original file line numberDiff line numberDiff line change
@@ -21,13 +21,13 @@ func newClients(urls []string, bmc string, l log.Logger) (cls []*Client, bmcs []
2121
for _, url := range urls {
2222
clrpc, err := rpc.Dial(url)
2323
if err != nil {
24-
l.Errorf("failed to create hmny rpc client: url=%v, %v", url, err)
24+
l.Errorf("failed to create bsc rpc client: url=%v, %v", url, err)
2525
return nil, nil, err
2626
}
2727
cleth := ethclient.NewClient(clrpc)
2828
clbmc, err := NewBMC(common.HexToAddress(bmc), cleth)
2929
if err != nil {
30-
l.Errorf("failed to create bmc binding to hmny ethclient: url=%v, %v", url, err)
30+
l.Errorf("failed to create bmc binding to bsc ethclient: url=%v, %v", url, err)
3131
return nil, nil, err
3232
}
3333
bmcs = append(bmcs, clbmc)
@@ -153,26 +153,26 @@ func (cl *Client) GetBlockReceipts(hash common.Hash) (types.Receipts, error) {
153153
return receipts, nil
154154
}
155155

156-
func (c *Client) GetMedianGasPriceForBlock() (gasPrice *big.Int, gasHeight *big.Int, err error) {
156+
func (c *Client) GetMedianGasPriceForBlock(ctx context.Context) (gasPrice *big.Int, gasHeight *big.Int, err error) {
157157
gasPrice = big.NewInt(0)
158-
header, err := c.eth.HeaderByNumber(context.TODO(), nil)
158+
header, err := c.eth.HeaderByNumber(ctx, nil)
159159
if err != nil {
160160
err = errors.Wrapf(err, "GetHeaderByNumber(height:latest) Err: %v", err)
161161
return
162162
}
163163
height := header.Number
164-
txnCount, err := c.eth.TransactionCount(context.TODO(), header.Hash())
164+
txnCount, err := c.eth.TransactionCount(ctx, header.Hash())
165165
if err != nil {
166166
err = errors.Wrapf(err, "GetTransactionCount(height:%v, headerHash: %v) Err: %v", height, header.Hash(), err)
167167
return
168168
} else if err == nil && txnCount == 0 {
169169
return nil, nil, fmt.Errorf("TransactionCount is zero for height(%v, headerHash %v)", height, header.Hash())
170170
}
171-
// txnF, err := c.eth.TransactionInBlock(context.TODO(), header.Hash(), 0)
171+
// txnF, err := c.eth.TransactionInBlock(ctx, header.Hash(), 0)
172172
// if err != nil {
173173
// return nil, errors.Wrapf(err, "GetTransactionInBlock(headerHash: %v, height: %v Index: %v) Err: %v", header.Hash(), height, 0, err)
174174
// }
175-
txnS, err := c.eth.TransactionInBlock(context.TODO(), header.Hash(), uint(math.Floor(float64(txnCount)/2)))
175+
txnS, err := c.eth.TransactionInBlock(ctx, header.Hash(), uint(math.Floor(float64(txnCount)/2)))
176176
if err != nil {
177177
return nil, nil, errors.Wrapf(err, "GetTransactionInBlock(headerHash: %v, height: %v Index: %v) Err: %v", header.Hash(), height, txnCount-1, err)
178178
}

cmd/iconbridge/chain/bsc/receiver_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ func TestMedianGasPrice(t *testing.T) {
4646
cls, _, err := newClients([]string{url}, BSC_BMC_PERIPHERY, log.New())
4747
require.NoError(t, err)
4848

49-
_, _, err = cls[0].GetMedianGasPriceForBlock()
49+
_, _, err = cls[0].GetMedianGasPriceForBlock(context.Background())
5050
require.NoError(t, err)
5151
}
5252

@@ -61,7 +61,7 @@ func TestFilterLogs(t *testing.T) {
6161
if recv == nil {
6262
t.Fatal(errors.New("Receiver is nil"))
6363
}
64-
exists, err := recv.hasBTPMessage(context.TODO(), big.NewInt(BlockHeight))
64+
exists, err := recv.hasBTPMessage(context.Background(), big.NewInt(BlockHeight))
6565
require.NoError(t, err)
6666
if !exists {
6767
require.NoError(t, errors.New("Expected true"))

cmd/iconbridge/chain/bsc/sender.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -198,7 +198,7 @@ func (s *sender) Segment(
198198
return nil, nil, err
199199
}
200200
cl, _ := s.jointClient()
201-
gasPrice, gasHeight, err := cl.GetMedianGasPriceForBlock()
201+
gasPrice, gasHeight, err := cl.GetMedianGasPriceForBlock(ctx)
202202
if err != nil || gasPrice.Int64() == 0 {
203203
s.log.Infof("GetMedianGasPriceForBlock(%v) Msg: %v. Using default value for gas price \n", gasHeight.String(), err)
204204
gasPrice = s.prevGasPrice

0 commit comments

Comments
 (0)