Skip to content

Commit

Permalink
feat: update slashAck
Browse files Browse the repository at this point in the history
  • Loading branch information
Yaru Wang committed Jul 21, 2023
1 parent 8160aad commit 52ac17a
Showing 1 changed file with 23 additions and 8 deletions.
31 changes: 23 additions & 8 deletions x/ccv/provider/keeper/keeper.go
Original file line number Diff line number Diff line change
Expand Up @@ -765,12 +765,9 @@ func (k Keeper) ConsumeSlashAcks(ctx sdk.Context, chainID string) (acks []types.
return
}

for _, address := range addresses {
consAddr, err := sdk.ConsAddressFromBech32(address)
if err != nil {
// todo
}
acks = append(acks, types.NewConsumerConsAddress(consAddr))
acks, err := StrToConsumerConsAddress(addresses)
if err != nil {
// todo
}

store := ctx.KVStore(k.storeKey)
Expand All @@ -790,8 +787,12 @@ func (k Keeper) AppendSlashAck(ctx sdk.Context, chainID string,
ack types.ConsumerConsAddress,
) {
acks := k.GetSlashAcks(ctx, chainID)

k.SetSlashAcks(ctx, chainID, acks)
consAddresses, err := StrToConsumerConsAddress(acks)
if err != nil {
// todo
}
consAddresses = append(consAddresses, ack)
k.SetSlashAcks(ctx, chainID, consAddresses)
}

// SetInitChainHeight sets the provider block height when the given consumer chain was initiated
Expand Down Expand Up @@ -1074,3 +1075,17 @@ func (k Keeper) GetSlashLog(
func (k Keeper) BondDenom(ctx sdk.Context) string {
return k.stakingKeeper.BondDenom(ctx)
}

// helper func
func StrToConsumerConsAddress(addresses []string) ([]types.ConsumerConsAddress, error) {
consAddresses := []types.ConsumerConsAddress{}
for _, address := range addresses {
// reverse of ConsumerConsAddress.String()
consAddr, err := sdk.ConsAddressFromBech32(address)
if err != nil {
return []types.ConsumerConsAddress{}, err
}
consAddresses = append(consAddresses, types.NewConsumerConsAddress(consAddr))
}
return consAddresses, nil
}

0 comments on commit 52ac17a

Please sign in to comment.