Skip to content

Commit

Permalink
refactor: modify the key prefix
Browse files Browse the repository at this point in the history
  • Loading branch information
any0Ne1010 committed Feb 4, 2024
1 parent a4e4128 commit c364bff
Show file tree
Hide file tree
Showing 3 changed files with 28 additions and 31 deletions.
28 changes: 10 additions & 18 deletions x/committer/keeper/keeper.go
Original file line number Diff line number Diff line change
Expand Up @@ -48,12 +48,12 @@ func (k Keeper) Logger(ctx sdk.Context) log.Logger {
func (k Keeper) SetLastProposal(ctx sdk.Context, proposal types.Proposal) {
store := ctx.KVStore(k.storeKey)
b := k.cdc.MustMarshal(&proposal)
store.Set(types.KeyPrefix(types.LastProposalID), b)
store.Set(types.KeyPrefixLastProposalID, b)
}

func (k Keeper) GetLastProposal(ctx sdk.Context) types.Proposal {
store := ctx.KVStore(k.storeKey)
b := store.Get(types.KeyPrefix(types.LastProposalID))
b := store.Get(types.KeyPrefixLastProposalID)
if b == nil {
return types.Proposal{Id: 0, EndIndex: 0}
}
Expand All @@ -63,16 +63,14 @@ func (k Keeper) GetLastProposal(ctx sdk.Context) types.Proposal {
}

func (k Keeper) SetProposal(ctx sdk.Context, proposal types.Proposal) {
p := types.KeyPrefix(types.ProposalKeyPrefix)
store := prefix.NewStore(ctx.KVStore(k.storeKey), p)
store := ctx.KVStore(k.storeKey)
b := k.cdc.MustMarshal(&proposal)
store.Set(types.KeyPrefix(fmt.Sprintf("%d", proposal.Id)), b)
store.Set(types.KeyPrefix(types.KeyPrefixProposal, fmt.Sprintf("%d", proposal.Id)), b)
}

func (k Keeper) GetProposal(ctx sdk.Context, id uint64) (types.Proposal, bool) {
p := types.KeyPrefix(types.ProposalKeyPrefix)
store := prefix.NewStore(ctx.KVStore(k.storeKey), p)
b := store.Get(types.KeyPrefix(fmt.Sprintf("%d", id)))
store := ctx.KVStore(k.storeKey)
b := store.Get(types.KeyPrefix(types.KeyPrefixProposal, fmt.Sprintf("%d", id)))
if b == nil {
return types.Proposal{}, false
}
Expand All @@ -82,23 +80,17 @@ func (k Keeper) GetProposal(ctx sdk.Context, id uint64) (types.Proposal, bool) {
return proposal, true
}

// func (k Keeper) AddCommitter(ctx sdk.Context, committer string) {
// committers := k.GetAllCommitters(ctx)
// committers.CommitterList = append(committers.CommitterList, committer)
// k.SetCommitter(ctx, committers)
// }

func (k Keeper) SetCommitter(ctx sdk.Context, committer types.Committer) {
p := types.KeyPrefix(types.CommitterKeyPrefix)
p := types.KeyPrefixCommitter
store := prefix.NewStore(ctx.KVStore(k.storeKey), p)
b := k.cdc.MustMarshal(&committer)
store.Set(types.KeyPrefix(types.CommitterKeyPrefix), b)
store.Set(p, b)
}

func (k Keeper) GetAllCommitters(ctx sdk.Context) types.Committer {
p := types.KeyPrefix(types.CommitterKeyPrefix)
p := types.KeyPrefixCommitter
store := prefix.NewStore(ctx.KVStore(k.storeKey), p)
b := store.Get(types.KeyPrefix(types.CommitterKeyPrefix))
b := store.Get(p)
if b == nil {
return types.Committer{}
}
Expand Down
4 changes: 2 additions & 2 deletions x/committer/keeper/params.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (
func (k Keeper) GetParams(ctx sdk.Context) types.Params {
store := ctx.KVStore(k.storeKey)
var params types.Params
k.cdc.MustUnmarshal(store.Get(types.KeyPrefix(types.KeyPrefixParams)), &params)
k.cdc.MustUnmarshal(store.Get(types.KeyPrefixParams), &params)
return params
}

Expand All @@ -18,5 +18,5 @@ func (k Keeper) SetParams(ctx sdk.Context, params types.Params) {
store := ctx.KVStore(k.storeKey)
bz := k.cdc.MustMarshal(&params)

store.Set(types.KeyPrefix(types.KeyPrefixParams), bz)
store.Set(types.KeyPrefixParams, bz)
}
27 changes: 16 additions & 11 deletions x/committer/types/keys.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,19 +12,24 @@ const (

// MemStoreKey defines the in-memory store key
MemStoreKey = "mem_committer"
)

// ProposalKeyPrefix is the prefix to retrieve all Proposal
ProposalKeyPrefix = "proposal/"

// LastProposalIdKey defines the key to store the last proposal id
LastProposalID = "last_proposal_id"

// CommitterKeyPrefix is the prefix to retrieve all Committer
CommitterKeyPrefix = "committer/"
// prefix bytes for the committer store
const (
prefixLastProposalID = iota + 1
prefixCommitter
prefixProposal
prefixParams
)

KeyPrefixParams = "params/"
// KVStore key prefixes
var (
KeyPrefixLastProposalID = []byte{prefixLastProposalID}
KeyPrefixCommitter = []byte{prefixCommitter}
KeyPrefixProposal = []byte{prefixProposal}
KeyPrefixParams = []byte{prefixParams}
)

func KeyPrefix(p string) []byte {
return []byte(p)
func KeyPrefix(prefix []byte, p string) []byte {
return append(prefix, []byte(p)...)
}

0 comments on commit c364bff

Please sign in to comment.