|
| 1 | +using System.Collections.Generic; |
| 2 | +using System.Collections.Immutable; |
| 3 | +using Libplanet.Action; |
| 4 | +using Libplanet.Assets; |
| 5 | +using Libplanet.Consensus; |
| 6 | +using Libplanet.Crypto; |
| 7 | +using Libplanet.PoS; |
| 8 | +using Libplanet.PoS.Control; |
| 9 | +using Libplanet.PoS.Model; |
| 10 | +using Xunit; |
| 11 | + |
| 12 | +namespace Libplanet.Tests.PoS |
| 13 | +{ |
| 14 | + public class DistributeTest : PoSTest |
| 15 | + { |
| 16 | + private readonly ImmutableHashSet<Currency> _nativeTokens; |
| 17 | + private IAccountStateDelta _states; |
| 18 | + |
| 19 | + public DistributeTest() |
| 20 | + : base() |
| 21 | + { |
| 22 | + _nativeTokens = ImmutableHashSet.Create( |
| 23 | + Asset.GovernanceToken, Asset.ConsensusToken, Asset.Share); |
| 24 | + _states = InitializeStates(); |
| 25 | + OperatorPrivateKeys = new List<PrivateKey>(); |
| 26 | + OperatorPublicKeys = new List<PublicKey>(); |
| 27 | + OperatorAddresses = new List<Address>(); |
| 28 | + ValidatorAddresses = new List<Address>(); |
| 29 | + DelegatorAddress = CreateAddress(); |
| 30 | + _states = _states.MintAsset(DelegatorAddress, Asset.GovernanceToken * 100000); |
| 31 | + for (int i = 0; i < 200; i++) |
| 32 | + { |
| 33 | + PrivateKey operatorPrivateKey = new PrivateKey(); |
| 34 | + PublicKey operatorPublicKey = operatorPrivateKey.PublicKey; |
| 35 | + Address operatorAddress = operatorPublicKey.ToAddress(); |
| 36 | + _states = _states.MintAsset(operatorAddress, Asset.GovernanceToken * 1000); |
| 37 | + |
| 38 | + OperatorPrivateKeys.Add(operatorPrivateKey); |
| 39 | + OperatorPublicKeys.Add(operatorPublicKey); |
| 40 | + OperatorAddresses.Add(operatorAddress); |
| 41 | + _states = ValidatorCtrl.Create( |
| 42 | + _states, |
| 43 | + operatorAddress, |
| 44 | + operatorPublicKey, |
| 45 | + Asset.GovernanceToken * 1, |
| 46 | + _nativeTokens, |
| 47 | + 1); |
| 48 | + ValidatorAddresses.Add(Validator.DeriveAddress(operatorAddress)); |
| 49 | + } |
| 50 | + } |
| 51 | + |
| 52 | + private List<PrivateKey> OperatorPrivateKeys { get; set; } |
| 53 | + |
| 54 | + private List<PublicKey> OperatorPublicKeys { get; set; } |
| 55 | + |
| 56 | + private List<Address> OperatorAddresses { get; set; } |
| 57 | + |
| 58 | + private List<Address> ValidatorAddresses { get; set; } |
| 59 | + |
| 60 | + private Address DelegatorAddress { get; set; } |
| 61 | + |
| 62 | + [Fact] |
| 63 | + public void ValidatorSetTest() |
| 64 | + { |
| 65 | + for (int i = 0; i < 200; i++) |
| 66 | + { |
| 67 | + _states = DelegateCtrl.Execute( |
| 68 | + _states, |
| 69 | + DelegatorAddress, |
| 70 | + ValidatorAddresses[i], |
| 71 | + Asset.GovernanceToken * (i + 1), |
| 72 | + _nativeTokens, |
| 73 | + 1); |
| 74 | + } |
| 75 | + |
| 76 | + Address validatorAddressA = ValidatorAddresses[3]; |
| 77 | + Address validatorAddressB = ValidatorAddresses[5]; |
| 78 | + |
| 79 | + _states = DelegateCtrl.Execute( |
| 80 | + _states, |
| 81 | + DelegatorAddress, |
| 82 | + validatorAddressA, |
| 83 | + Asset.GovernanceToken * 200, |
| 84 | + _nativeTokens, |
| 85 | + 1); |
| 86 | + |
| 87 | + _states = DelegateCtrl.Execute( |
| 88 | + _states, |
| 89 | + DelegatorAddress, |
| 90 | + validatorAddressB, |
| 91 | + Asset.GovernanceToken * 300, |
| 92 | + _nativeTokens, |
| 93 | + 1); |
| 94 | + |
| 95 | + _states = ValidatorSetCtrl.Update(_states, 1); |
| 96 | + |
| 97 | + (_states, _) = ValidatorSetCtrl.FetchBondedValidatorSet(_states); |
| 98 | + |
| 99 | + List<Vote> votes = new List<Vote>() |
| 100 | + { |
| 101 | + new Vote( |
| 102 | + default, |
| 103 | + default, |
| 104 | + default, |
| 105 | + default, |
| 106 | + OperatorPrivateKeys[3].PublicKey, |
| 107 | + VoteFlag.Commit, |
| 108 | + null).Sign(OperatorPrivateKeys[3]), |
| 109 | + new Vote( |
| 110 | + default, |
| 111 | + default, |
| 112 | + default, |
| 113 | + default, |
| 114 | + OperatorPrivateKeys[5].PublicKey, |
| 115 | + VoteFlag.Commit, |
| 116 | + null).Sign(OperatorPrivateKeys[5]), |
| 117 | + }; |
| 118 | + FungibleAssetValue blockReward = Asset.ConsensusToken * 50; |
| 119 | + _states = _states.MintAsset(ReservedAddress.RewardPool, blockReward); |
| 120 | + _states = AllocateReward.Execute( |
| 121 | + _states, _nativeTokens, votes, OperatorAddresses[3], 1); |
| 122 | + |
| 123 | + var (baseProposerReward, _) |
| 124 | + = (blockReward * AllocateReward.BaseProposerRewardNumer) |
| 125 | + .DivRem(AllocateReward.BaseProposerRewardDenom); |
| 126 | + var (bonusProposerReward, _) |
| 127 | + = (blockReward * (205 + 307) |
| 128 | + * AllocateReward.BonusProposerRewardNumer) |
| 129 | + .DivRem((100 + (101 + 200) * 50 - 101 - 102 + 204 + 306) |
| 130 | + * AllocateReward.BonusProposerRewardDenom); |
| 131 | + FungibleAssetValue proposerReward = baseProposerReward + bonusProposerReward; |
| 132 | + FungibleAssetValue validatorRewardSum = blockReward - proposerReward; |
| 133 | + |
| 134 | + var (validatorRewardA, _) |
| 135 | + = (validatorRewardSum * 205) |
| 136 | + .DivRem(100 + (101 + 200) * 50 - 101 - 102 + 204 + 306); |
| 137 | + var (commissionA, _) |
| 138 | + = (validatorRewardA * Validator.CommissionNumer) |
| 139 | + .DivRem(Validator.CommissionDenom); |
| 140 | + var (validatorRewardB, _) |
| 141 | + = (validatorRewardSum * 307) |
| 142 | + .DivRem(100 + (101 + 200) * 50 - 101 - 102 + 204 + 306); |
| 143 | + var (commissionB, _) |
| 144 | + = (validatorRewardB * Validator.CommissionNumer) |
| 145 | + .DivRem(Validator.CommissionDenom); |
| 146 | + |
| 147 | + Assert.Equal( |
| 148 | + Asset.ConsensusToken * 0, |
| 149 | + _states.GetBalance(ReservedAddress.RewardPool, Asset.ConsensusToken)); |
| 150 | + |
| 151 | + Assert.Equal( |
| 152 | + Asset.GovernanceToken * (100 + (101 + 200) * 50 - 101 - 102 + 204 + 306), |
| 153 | + _states.GetBalance(ReservedAddress.BondedPool, Asset.GovernanceToken)); |
| 154 | + |
| 155 | + Assert.Equal( |
| 156 | + Asset.ConsensusToken * 205, |
| 157 | + _states.GetBalance(validatorAddressA, Asset.ConsensusToken)); |
| 158 | + |
| 159 | + Assert.Equal( |
| 160 | + Asset.ConsensusToken * 307, |
| 161 | + _states.GetBalance(validatorAddressB, Asset.ConsensusToken)); |
| 162 | + |
| 163 | + Assert.Equal( |
| 164 | + proposerReward + commissionA, |
| 165 | + _states.GetBalance( |
| 166 | + AllocateReward.RewardAddress(OperatorAddresses[3]), Asset.ConsensusToken)); |
| 167 | + |
| 168 | + Assert.Equal( |
| 169 | + commissionB, |
| 170 | + _states.GetBalance( |
| 171 | + AllocateReward.RewardAddress(OperatorAddresses[5]), Asset.ConsensusToken)); |
| 172 | + |
| 173 | + Address delegationAddressA |
| 174 | + = Delegation.DeriveAddress(DelegatorAddress, validatorAddressA); |
| 175 | + |
| 176 | + Assert.Equal( |
| 177 | + Asset.ConsensusToken * 0, |
| 178 | + _states.GetBalance( |
| 179 | + AllocateReward.RewardAddress(DelegatorAddress), Asset.ConsensusToken)); |
| 180 | + |
| 181 | + var (delegatorToken, _) |
| 182 | + = (_states.GetBalance( |
| 183 | + ValidatorRewards.DeriveAddress(validatorAddressA, Asset.ConsensusToken), |
| 184 | + Asset.ConsensusToken) |
| 185 | + * _states.GetBalance( |
| 186 | + Delegation.DeriveAddress(DelegatorAddress, validatorAddressA), |
| 187 | + Asset.Share) |
| 188 | + .RawValue) |
| 189 | + .DivRem(ValidatorCtrl.GetValidator(_states, validatorAddressA) |
| 190 | + .DelegatorShares.RawValue); |
| 191 | + |
| 192 | + _states = DelegateCtrl.Distribute(_states, _nativeTokens, delegationAddressA, 5); |
| 193 | + |
| 194 | + Assert.Equal( |
| 195 | + delegatorToken, |
| 196 | + _states.GetBalance( |
| 197 | + AllocateReward.RewardAddress(DelegatorAddress), Asset.ConsensusToken)); |
| 198 | + } |
| 199 | + } |
| 200 | +} |
0 commit comments