Skip to content

Commit

Permalink
linter
Browse files Browse the repository at this point in the history
  • Loading branch information
ARR552 committed Sep 19, 2024
1 parent 86d0938 commit 659f08e
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion cmd/run.go
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,7 @@ func monitorChannel(ctx context.Context, chExitRootEvent chan *etherman.GlobalEx
go func() {
for {
select {
case ger := <- chExitRootEvent:
case ger := <-chExitRootEvent:
log.Debug("New GER received")
s := storage.(claimtxman.StorageInterface)
dbTx, err := s.BeginDBTransaction(ctx)
Expand Down
6 changes: 3 additions & 3 deletions db/pgstorage/pgstorage.go
Original file line number Diff line number Diff line change
Expand Up @@ -680,15 +680,15 @@ func (p *PostgresStorage) GetPendingDepositsToClaim(ctx context.Context, destAdd
desAddrSQL := ""
if destAddress != (common.Address{}) {
str := strings.TrimPrefix(destAddress.String(), "0x")
desAddrSQL = "AND dest_addr = decode('"+str+"','hex')"
desAddrSQL = "AND dest_addr = decode('" + str + "','hex')"
}
getNumberPendingDepositsToClaimSQL := "SELECT count(*) FROM sync.deposit WHERE dest_net = $1 AND ready_for_claim = true AND leaf_type = $2 "+desAddrSQL+" AND deposit_cnt NOT IN (SELECT index FROM sync.claim WHERE sync.claim.network_id = $1)"
getNumberPendingDepositsToClaimSQL := "SELECT count(*) FROM sync.deposit WHERE dest_net = $1 AND ready_for_claim = true AND leaf_type = $2 " + desAddrSQL + " AND deposit_cnt NOT IN (SELECT index FROM sync.claim WHERE sync.claim.network_id = $1)"
var depositCount uint64
err := p.getExecQuerier(dbTx).QueryRow(ctx, getNumberPendingDepositsToClaimSQL, destNetwork, leafType).Scan(&depositCount)
if err != nil {
return nil, 0, err
}
getPendingDepositsToClaimSQL := "SELECT d.id, leaf_type, orig_net, orig_addr, amount, dest_net, dest_addr, deposit_cnt, block_id, b.block_num, d.network_id, tx_hash, metadata, ready_for_claim FROM sync.deposit AS d INNER JOIN sync.block AS b ON d.block_id = b.id WHERE dest_net = $1 AND ready_for_claim = true AND leaf_type = $2 "+desAddrSQL+" AND d.deposit_cnt NOT IN (SELECT index FROM sync.claim WHERE sync.claim.network_id = $1) ORDER BY d.deposit_cnt ASC LIMIT $3 OFFSET $4"
getPendingDepositsToClaimSQL := "SELECT d.id, leaf_type, orig_net, orig_addr, amount, dest_net, dest_addr, deposit_cnt, block_id, b.block_num, d.network_id, tx_hash, metadata, ready_for_claim FROM sync.deposit AS d INNER JOIN sync.block AS b ON d.block_id = b.id WHERE dest_net = $1 AND ready_for_claim = true AND leaf_type = $2 " + desAddrSQL + " AND d.deposit_cnt NOT IN (SELECT index FROM sync.claim WHERE sync.claim.network_id = $1) ORDER BY d.deposit_cnt ASC LIMIT $3 OFFSET $4"
rows, err := p.getExecQuerier(dbTx).Query(ctx, getPendingDepositsToClaimSQL, destNetwork, leafType, limit, offset)
if err != nil {
return nil, 0, err
Expand Down
2 changes: 1 addition & 1 deletion server/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -580,4 +580,4 @@ func (s *bridgeService) GetPendingBridgesToClaim(ctx context.Context, req *pb.Ge
Deposits: pbDeposits,
TotalCnt: totalDeposits,
}, nil
}
}

0 comments on commit 659f08e

Please sign in to comment.