package shardingconfig import ( "github.com/harmony-one/harmony/internal/ctxerror" "github.com/harmony-one/harmony/internal/genesis" ) type instance struct { numShards uint32 numNodesPerShard int numHarmonyOperatedNodesPerShard int hmyAccounts []genesis.DeployAccount fnAccounts []genesis.DeployAccount } // NewInstance creates and validates a new sharding configuration based // upon given parameters. func NewInstance( numShards uint32, numNodesPerShard, numHarmonyOperatedNodesPerShard int, hmyAccounts []genesis.DeployAccount, fnAccounts []genesis.DeployAccount, ) (Instance, error) { if numShards < 1 { return nil, ctxerror.New("sharding config must have at least one shard", "numShards", numShards) } if numNodesPerShard < 1 { return nil, ctxerror.New("each shard must have at least one node", "numNodesPerShard", numNodesPerShard) } if numHarmonyOperatedNodesPerShard < 0 { return nil, ctxerror.New("Harmony-operated nodes cannot be negative", "numHarmonyOperatedNodesPerShard", numHarmonyOperatedNodesPerShard) } if numHarmonyOperatedNodesPerShard > numNodesPerShard { return nil, ctxerror.New(""+ "number of Harmony-operated nodes cannot exceed "+ "overall number of nodes per shard", "numHarmonyOperatedNodesPerShard", numHarmonyOperatedNodesPerShard, "numNodesPerShard", numNodesPerShard) } return instance{ numShards: numShards, numNodesPerShard: numNodesPerShard, numHarmonyOperatedNodesPerShard: numHarmonyOperatedNodesPerShard, hmyAccounts: hmyAccounts, fnAccounts: fnAccounts, }, nil } // MustNewInstance creates a new sharding configuration based upon // given parameters. It panics if parameter validation fails. // It is intended to be used for static initialization. func MustNewInstance( numShards uint32, numNodesPerShard, numHarmonyOperatedNodesPerShard int, hmyAccounts []genesis.DeployAccount, fnAccounts []genesis.DeployAccount, ) Instance { sc, err := NewInstance( numShards, numNodesPerShard, numHarmonyOperatedNodesPerShard, hmyAccounts, fnAccounts) if err != nil { panic(err) } return sc } // NumShards returns the number of shards in the network. func (sc instance) NumShards() uint32 { return sc.numShards } // NumNodesPerShard returns number of nodes in each shard. func (sc instance) NumNodesPerShard() int { return sc.numNodesPerShard } // NumHarmonyOperatedNodesPerShard returns number of nodes in each shard // that are operated by Harmony. func (sc instance) NumHarmonyOperatedNodesPerShard() int { return sc.numHarmonyOperatedNodesPerShard } // HmyAccounts returns the list of Harmony accounts func (sc instance) HmyAccounts() []genesis.DeployAccount { return sc.hmyAccounts } // FnAccounts returns the list of Foundational Node accounts func (sc instance) FnAccounts() []genesis.DeployAccount { return sc.fnAccounts } // FindAccount returns the deploy account based on the blskey, and if the account is a leader // or not in the bootstrapping process. func (sc instance) FindAccount(blsPubKey string) (bool, *genesis.DeployAccount) { for i, item := range sc.hmyAccounts { if item.BlsPublicKey == blsPubKey { item.ShardID = uint32(i) % sc.numShards return uint32(i) < sc.numShards, &item } } for i, item := range sc.fnAccounts { if item.BlsPublicKey == blsPubKey { item.ShardID = uint32(i) % sc.numShards return false, &item } } return false, nil }