Skip to content

Commit

Permalink
lint fix
Browse files Browse the repository at this point in the history
  • Loading branch information
goran-ethernal committed Sep 10, 2024
1 parent 2e7d3c3 commit 6aee0ee
Show file tree
Hide file tree
Showing 6 changed files with 43 additions and 36 deletions.
14 changes: 10 additions & 4 deletions command/bridge/deploy/deploy.go
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,8 @@ func runCommand(cmd *cobra.Command, _ []string) {
defer outputter.WriteOutput()

outputter.WriteCommandResult(&helper.MessageResult{
Message: fmt.Sprintf("%s started... External Chain JSON RPC address %s.", contractsDeploymentTitle, params.externalRPCAddress),
Message: fmt.Sprintf("%s started... External Chain JSON RPC address %s.",
contractsDeploymentTitle, params.externalRPCAddress),
})

chainConfig, err := chain.ImportFromFile(params.genesisPath)
Expand All @@ -145,11 +146,13 @@ func runCommand(cmd *cobra.Command, _ []string) {

externalChainID, err := externalChainClient.ChainID()
if err != nil {
outputter.SetError(fmt.Errorf("failed to get chainID for provided IP address: %s: %w", params.externalRPCAddress, err))
outputter.SetError(fmt.Errorf("failed to get chainID for provided IP address: %s: %w",
params.externalRPCAddress, err))
}

if consensusCfg.Bridge[externalChainID.Uint64()] != nil {
code, err := externalChainClient.GetCode(consensusCfg.Bridge[externalChainID.Uint64()].ExternalGatewayAddr, jsonrpc.LatestBlockNumberOrHash)
code, err := externalChainClient.GetCode(consensusCfg.Bridge[externalChainID.Uint64()].ExternalGatewayAddr,
jsonrpc.LatestBlockNumberOrHash)
if err != nil {
outputter.SetError(fmt.Errorf("failed to check if rootchain contracts are deployed: %w", err))

Expand Down Expand Up @@ -213,7 +216,10 @@ func deployContracts(outputter command.OutputFormatter,
initialValidators []*validator.GenesisValidator,
cmdCtx context.Context) (deploymentResultInfo, error) {
var internalTxRelayer txrelayer.TxRelayer
externalTxRelayer, err := txrelayer.NewTxRelayer(txrelayer.WithClient(externalChainClient), txrelayer.WithWriter(outputter),

externalTxRelayer, err := txrelayer.NewTxRelayer(
txrelayer.WithClient(externalChainClient),
txrelayer.WithWriter(outputter),
txrelayer.WithReceiptsTimeout(params.txTimeout))
if err != nil {
return deploymentResultInfo{BridgeCfg: nil, CommandResults: nil},
Expand Down
18 changes: 8 additions & 10 deletions command/bridge/deploy/internal_contracts.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
//nolint:dupl
package deploy

import (
Expand All @@ -23,7 +24,8 @@ var (

// initInternalContracts initializes the internal contracts
func initInternalContracts(o command.OutputFormatter, chainCfg *chain.Chain) {
useBridgeAllowList, useBridgeBlockList := chainCfg.Params.DoesItUseBridgeAllowList(), chainCfg.Params.DoesItUseBridgeBlockList()
useBridgeAllowList, useBridgeBlockList := chainCfg.Params.DoesItUseBridgeAllowList(),
chainCfg.Params.DoesItUseBridgeBlockList()

internalContracts = make([]*contract, 0)

Expand Down Expand Up @@ -86,7 +88,6 @@ func initInternalContracts(o command.OutputFormatter, chainCfg *chain.Chain) {
NewUseBlockList: useBridgeBlockList,
NewOwner: chainCfg.Params.GetBridgeOwner(),
}

} else {
input = &contractsapi.InitializeChildERC20PredicateFn{
NewGateway: config.InternalGatewayAddr,
Expand Down Expand Up @@ -131,7 +132,6 @@ func initInternalContracts(o command.OutputFormatter, chainCfg *chain.Chain) {
NewUseBlockList: useBridgeBlockList,
NewOwner: chainCfg.Params.GetBridgeOwner(),
}

} else {
input = &contractsapi.InitializeChildERC721PredicateFn{
NewGateway: config.InternalGatewayAddr,
Expand Down Expand Up @@ -175,7 +175,6 @@ func initInternalContracts(o command.OutputFormatter, chainCfg *chain.Chain) {
NewUseBlockList: useBridgeBlockList,
NewOwner: chainCfg.Params.GetBridgeOwner(),
}

} else {
input = &contractsapi.InitializeChildERC1155PredicateFn{
NewGateway: config.InternalGatewayAddr,
Expand Down Expand Up @@ -320,13 +319,12 @@ func initInternalContracts(o command.OutputFormatter, chainCfg *chain.Chain) {
})
}

// preAllocateInternalPredicates pre-allocates internal predicates in genesis if the command is run in bootstrap mode
func preAllocateInternalPredicates(o command.OutputFormatter, chainCfg *chain.Chain, bridgeCfg *polybft.BridgeConfig) error {
if _, err := o.Write([]byte("[BRIDGE - DEPLOY] Pre-allocating internal predicates in bootstrap mode\n")); err != nil {
return err
}

// preAllocateInternalPredicates pre-allocates internal predicates in genesis
// if the command is run in bootstrap mode
func preAllocateInternalPredicates(o command.OutputFormatter,
chainCfg *chain.Chain, bridgeCfg *polybft.BridgeConfig) error {
predicateBaseProxyAddress := contracts.ChildBridgeContractsBaseAddress

if consensusCfg.Bridge != nil {
for _, bridgeCfg := range consensusCfg.Bridge {
heighestAddr := bridgeCfg.GetHeighestInternalAddress()
Expand Down
4 changes: 1 addition & 3 deletions consensus/polybft/bridge_event_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -324,7 +324,6 @@ func (b *bridgeEventManager) getAggSignatureForBridgeBatchMessage(blockNumber ui

var signatures bls.Signatures

publicKeys := make([][]byte, 0)
bmap := bitmap.Bitmap{}
signers := make(map[types.Address]struct{}, 0)

Expand All @@ -339,10 +338,9 @@ func (b *bridgeEventManager) getAggSignatureForBridgeBatchMessage(blockNumber ui
return Signature{}, err
}

bmap.Set(uint64(index))
bmap.Set(uint64(index)) //nolint:gosec

signatures = append(signatures, signature)
publicKeys = append(publicKeys, validatorsMetadata[index].BlsKey.Marshal())
signers[types.StringToAddress(vote.From)] = struct{}{}
}

Expand Down
9 changes: 6 additions & 3 deletions consensus/polybft/contracts_initializer.go
Original file line number Diff line number Diff line change
Expand Up @@ -420,7 +420,8 @@ func initERC20ACLPredicateContract(
return nil
}

input, err := getInitERC20PredicateACLInput(bcfg, owner, useBridgeAllowList, useBridgeBlockList, childMintable, chainID)
input, err := getInitERC20PredicateACLInput(bcfg, owner,
useBridgeAllowList, useBridgeBlockList, childMintable, chainID)
if err != nil {
return err
}
Expand Down Expand Up @@ -453,7 +454,8 @@ func initERC721ACLPredicateContract(
return nil
}

input, err := getInitERC721PredicateACLInput(bcfg, owner, useBridgeAllowList, useBridgeBlockList, childMintable, chainID)
input, err := getInitERC721PredicateACLInput(bcfg, owner,
useBridgeAllowList, useBridgeBlockList, childMintable, chainID)
if err != nil {
return err
}
Expand Down Expand Up @@ -486,7 +488,8 @@ func initERC1155ACLPredicateContract(
return nil
}

input, err := getInitERC1155PredicateACLInput(bcfg, owner, useBridgeAllowList, useBridgeBlockList, childMintable, chainID)
input, err := getInitERC1155PredicateACLInput(bcfg, owner,
useBridgeAllowList, useBridgeBlockList, childMintable, chainID)
if err != nil {
return err
}
Expand Down
28 changes: 14 additions & 14 deletions consensus/polybft/polybft_config.go
Original file line number Diff line number Diff line change
Expand Up @@ -166,32 +166,32 @@ type BridgeConfig struct {

// GetHeighestInternalAddress returns the highest address among all internal bridge contracts
func (b *BridgeConfig) GetHeighestInternalAddress() types.Address {
heighest := b.InternalGatewayAddr
if b.InternalERC20PredicateAddr.Compare(heighest) > 0 {
heighest = b.InternalERC20PredicateAddr
result := b.InternalGatewayAddr
if b.InternalERC20PredicateAddr.Compare(result) > 0 {
result = b.InternalERC20PredicateAddr
}

if b.InternalERC721PredicateAddr.Compare(heighest) > 0 {
heighest = b.InternalERC721PredicateAddr
if b.InternalERC721PredicateAddr.Compare(result) > 0 {
result = b.InternalERC721PredicateAddr
}

if b.InternalERC1155PredicateAddr.Compare(heighest) > 0 {
heighest = b.InternalERC1155PredicateAddr
if b.InternalERC1155PredicateAddr.Compare(result) > 0 {
result = b.InternalERC1155PredicateAddr
}

if b.InternalMintableERC20PredicateAddr.Compare(heighest) > 0 {
heighest = b.InternalMintableERC20PredicateAddr
if b.InternalMintableERC20PredicateAddr.Compare(result) > 0 {
result = b.InternalMintableERC20PredicateAddr
}

if b.InternalMintableERC721PredicateAddr.Compare(heighest) > 0 {
heighest = b.InternalMintableERC721PredicateAddr
if b.InternalMintableERC721PredicateAddr.Compare(result) > 0 {
result = b.InternalMintableERC721PredicateAddr
}

if b.InternalMintableERC1155PredicateAddr.Compare(heighest) > 0 {
heighest = b.InternalMintableERC1155PredicateAddr
if b.InternalMintableERC1155PredicateAddr.Compare(result) > 0 {
result = b.InternalMintableERC1155PredicateAddr
}

return heighest
return result
}

func (p *PolyBFTConfig) IsBridgeEnabled() bool {
Expand Down
6 changes: 4 additions & 2 deletions types/types.go
Original file line number Diff line number Diff line change
Expand Up @@ -201,8 +201,10 @@ func IncrementAddressBy(addr Address, increment uint64) Address {
addrBigInt.Add(addrBigInt, big.NewInt(0).SetUint64(increment))

// Convert back to Address
var newAddr Address
addrBytes := addrBigInt.Bytes()
var (
newAddr Address
addrBytes = addrBigInt.Bytes()
)

// Handle overflow by truncating to 20 bytes
if len(addrBytes) > 20 {
Expand Down

0 comments on commit 6aee0ee

Please sign in to comment.