/
distribution.go
75 lines (61 loc) · 3.25 KB
/
distribution.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
package distribution
import (
"github.com/Moonyongjung/xpriv.go/key"
"github.com/Moonyongjung/xpriv.go/types"
"golang.org/x/net/context"
"github.com/Moonyongjung/xpla-private-chain/app/params"
sdk "github.com/cosmos/cosmos-sdk/types"
disttypes "github.com/cosmos/cosmos-sdk/x/distribution/types"
govtypes "github.com/cosmos/cosmos-sdk/x/gov/types"
"github.com/gogo/protobuf/grpc"
)
// (Tx) make msg - fund community pool
func MakeFundCommunityPoolMsg(fundCommunityPoolMsg types.FundCommunityPoolMsg, privKey key.PrivateKey) (disttypes.MsgFundCommunityPool, error) {
return parseFundCommunityPoolArgs(fundCommunityPoolMsg, privKey)
}
// (Tx) make msg - proposal community pool
func MakeProposalCommunityPoolSpendMsg(communityPoolSpendMsg types.CommunityPoolSpendMsg, privKey key.PrivateKey, encodingConfig params.EncodingConfig) (govtypes.MsgSubmitProposal, error) {
return parseProposalCommunityPoolSpendArgs(communityPoolSpendMsg, privKey, encodingConfig)
}
// (Tx) make msg - withdraw rewards
func MakeWithdrawRewardsMsg(withdrawRewardsMsg types.WithdrawRewardsMsg, privKey key.PrivateKey) ([]sdk.Msg, error) {
return parseWithdrawRewardsArgs(withdrawRewardsMsg, privKey)
}
// (Tx) make msg - withdraw all rewards
func MakeWithdrawAllRewardsMsg(privKey key.PrivateKey, lcdUrl, grpcUrl string, grpcConn grpc.ClientConn, ctx context.Context) ([]sdk.Msg, error) {
return parseWithdrawAllRewardsArgs(privKey, lcdUrl, grpcUrl, grpcConn, ctx)
}
// (Tx) make msg - withdraw address
func MakeSetWithdrawAddrMsg(setWithdrawAddrMsg types.SetwithdrawAddrMsg, privKey key.PrivateKey) (disttypes.MsgSetWithdrawAddress, error) {
return parseSetWithdrawAddrArgs(setWithdrawAddrMsg, privKey)
}
// (Query) make msg - distribution params
func MakeQueryDistributionParamsMsg() (disttypes.QueryParamsRequest, error) {
return disttypes.QueryParamsRequest{}, nil
}
// (Query) make msg - validator outstanding rewards
func MakeValidatorOutstandingRewardsMsg(validatorOutstandingRewardsMsg types.ValidatorOutstandingRewardsMsg) (disttypes.QueryValidatorOutstandingRewardsRequest, error) {
return parseValidatorOutstandingRewardsArgs(validatorOutstandingRewardsMsg)
}
// (Query) make msg - commission
func MakeQueryDistCommissionMsg(queryDistCommissionMsg types.QueryDistCommissionMsg) (disttypes.QueryValidatorCommissionRequest, error) {
return parseQueryDistCommissionArgs(queryDistCommissionMsg)
}
// (Query) make msg - distribution slashes
func MakeQueryDistSlashesMsg(queryDistSlashesMsg types.QueryDistSlashesMsg) (disttypes.QueryValidatorSlashesRequest, error) {
return parseDistSlashesArgs(queryDistSlashesMsg)
}
// (Query) make msg - distribution rewards
func MakeyQueryDistRewardsMsg(queryDistRewardsMsg types.QueryDistRewardsMsg) (disttypes.QueryDelegationRewardsRequest, error) {
return parseQueryDistRewardsArgs(queryDistRewardsMsg)
}
// (Query) make msg - distribution all rewards
func MakeyQueryDistTotalRewardsMsg(queryDistRewardsMsg types.QueryDistRewardsMsg) (disttypes.QueryDelegationTotalRewardsRequest, error) {
return disttypes.QueryDelegationTotalRewardsRequest{
DelegatorAddress: queryDistRewardsMsg.DelegatorAddr,
}, nil
}
// (Query) make msg - community pool
func MakeQueryCommunityPoolMsg() (disttypes.QueryCommunityPoolRequest, error) {
return disttypes.QueryCommunityPoolRequest{}, nil
}