/
proposal_handler.go
50 lines (41 loc) · 1.27 KB
/
proposal_handler.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
package params
import (
"fmt"
govtypes "github.com/netcloth/netcloth-chain/modules/gov/types"
sdk "github.com/netcloth/netcloth-chain/types"
)
func NewParamChangeProposalHandler(k Keeper) govtypes.Handler {
return func(ctx sdk.Context, content govtypes.Content) sdk.Error {
switch c := content.(type) {
case ParameterChangeProposal:
return handleParameterChangeProposal(ctx, k, c)
default:
errMsg := fmt.Sprintf("unrecognized param proposal content type: %T", c)
return sdk.ErrUnknownRequest(errMsg)
}
}
}
func handleParameterChangeProposal(ctx sdk.Context, k Keeper, p ParameterChangeProposal) sdk.Error {
for _, c := range p.Changes {
ss, ok := k.GetSubspace(c.Subspace)
if !ok {
return ErrUnknownSubspace(k.codespace, c.Subspace)
}
var err error
if len(c.Subkey) == 0 {
k.Logger(ctx).Info(
fmt.Sprintf("setting new parameter; key: %s, value: %s", c.Key, c.Value),
)
err = ss.Update(ctx, []byte(c.Key), []byte(c.Value))
} else {
k.Logger(ctx).Info(
fmt.Sprintf("setting new parameter; key: %s, subkey: %s, value: %s", c.Key, c.Subspace, c.Value),
)
err = ss.Update(ctx, []byte(c.Key), []byte(c.Value))
}
if err != nil {
return ErrSettingParameter(k.codespace, c.Key, c.Subkey, c.Value, err.Error())
}
}
return nil
}