forked from cosmos/cosmos-sdk
-
Notifications
You must be signed in to change notification settings - Fork 35
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: add a BeforeSend hook to the bank module (#278)
- Loading branch information
1 parent
529d6f8
commit 985c1c8
Showing
10 changed files
with
417 additions
and
8 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,19 @@ | ||
| package keeper | ||
|
|
||
| import ( | ||
| "context" | ||
|
|
||
| sdk "github.com/cosmos/cosmos-sdk/types" | ||
| "github.com/cosmos/cosmos-sdk/x/bank/types" | ||
| ) | ||
|
|
||
| // Implements StakingHooks interface | ||
| var _ types.BankHooks = BaseSendKeeper{} | ||
|
|
||
| // BeforeSend executes the BeforeSend hook if registered. | ||
| func (k BaseSendKeeper) BeforeSend(ctx context.Context, from, to sdk.AccAddress, amount sdk.Coins) error { | ||
| if k.hooks != nil { | ||
| return k.hooks.BeforeSend(ctx, from, to, amount) | ||
| } | ||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,165 @@ | ||
| package keeper_test | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "testing" | ||
|
|
||
| "cosmossdk.io/depinject" | ||
| "cosmossdk.io/log" | ||
| "cosmossdk.io/math" | ||
| "github.com/cosmos/cosmos-sdk/crypto/keys/secp256k1" | ||
| "github.com/cosmos/cosmos-sdk/runtime" | ||
| "github.com/cosmos/cosmos-sdk/testutil/configurator" | ||
| simtestutil "github.com/cosmos/cosmos-sdk/testutil/sims" | ||
| "github.com/stretchr/testify/require" | ||
|
|
||
| sdk "github.com/cosmos/cosmos-sdk/types" | ||
| authtypes "github.com/cosmos/cosmos-sdk/x/auth/types" | ||
| "github.com/cosmos/cosmos-sdk/x/bank/keeper" | ||
| bankkeeper "github.com/cosmos/cosmos-sdk/x/bank/keeper" | ||
| banktestutil "github.com/cosmos/cosmos-sdk/x/bank/testutil" | ||
| "github.com/cosmos/cosmos-sdk/x/bank/types" | ||
| stakingkeeper "github.com/cosmos/cosmos-sdk/x/staking/keeper" | ||
|
|
||
| stakingtypes "github.com/cosmos/cosmos-sdk/x/staking/types" | ||
| ) | ||
|
|
||
| var _ types.BankHooks = &MockBankHooksReceiver{} | ||
|
|
||
| var ( | ||
| priv1 = secp256k1.GenPrivKey() | ||
| addr1 = sdk.AccAddress(priv1.PubKey().Address()) | ||
| ) | ||
|
|
||
| type testingSuite struct { | ||
| BankKeeper bankkeeper.Keeper | ||
| AccountKeeper types.AccountKeeper | ||
| StakingKeeper stakingkeeper.Keeper | ||
| App *runtime.App | ||
| } | ||
|
|
||
| func createTestSuite(t *testing.T, genesisAccounts []authtypes.GenesisAccount) testingSuite { | ||
| res := testingSuite{} | ||
|
|
||
| var genAccounts []simtestutil.GenesisAccount | ||
| for _, acc := range genesisAccounts { | ||
| genAccounts = append(genAccounts, simtestutil.GenesisAccount{GenesisAccount: acc}) | ||
| } | ||
|
|
||
| startupCfg := simtestutil.DefaultStartUpConfig() | ||
| startupCfg.GenesisAccounts = genAccounts | ||
|
|
||
| app, err := simtestutil.SetupWithConfiguration( | ||
| depinject.Configs( | ||
| configurator.NewAppConfig( | ||
| configurator.ParamsModule(), | ||
| configurator.AuthModule(), | ||
| configurator.StakingModule(), | ||
| configurator.TxModule(), | ||
| configurator.ConsensusModule(), | ||
| configurator.BankModule(), | ||
| configurator.GovModule(), | ||
| configurator.DistributionModule(), | ||
| configurator.AuthModule(), | ||
| ), | ||
| depinject.Supply(log.NewNopLogger()), | ||
| ), | ||
| startupCfg, &res.BankKeeper, &res.AccountKeeper, &res.StakingKeeper) | ||
|
|
||
| res.App = app | ||
|
|
||
| require.NoError(t, err) | ||
| return res | ||
| } | ||
|
|
||
| // BankHooks event hooks for bank (noalias) | ||
| type MockBankHooksReceiver struct{} | ||
|
|
||
| // Mock BeforeSend bank hook that doesn't allow the sending of exactly 100 coins of any denom. | ||
| func (h *MockBankHooksReceiver) BeforeSend(ctx context.Context, from, to sdk.AccAddress, amount sdk.Coins) error { | ||
| for _, coin := range amount { | ||
| if coin.Amount.Equal(math.NewInt(100)) { | ||
| return fmt.Errorf("not allowed; expected %v, got: %v", 100, coin.Amount) | ||
| } | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func TestHooks(t *testing.T) { | ||
| acc := &authtypes.BaseAccount{ | ||
| Address: addr1.String(), | ||
| } | ||
|
|
||
| genAccs := []authtypes.GenesisAccount{acc} | ||
| app := createTestSuite(t, genAccs) | ||
| baseApp := app.App.BaseApp | ||
| ctx := baseApp.NewContext(false) | ||
| bondDenom, err := app.StakingKeeper.BondDenom(ctx) | ||
| require.NoError(t, err) | ||
|
|
||
| addrs := simtestutil.AddTestAddrs(app.BankKeeper, app.StakingKeeper, ctx, 2, math.NewInt(1000)) | ||
| banktestutil.FundModuleAccount(ctx, app.BankKeeper, stakingtypes.BondedPoolName, sdk.NewCoins(sdk.NewCoin(bondDenom, math.NewInt(1000)))) | ||
|
|
||
| // create a valid send amount which is 1 coin, and an invalidSendAmount which is 100 coins | ||
| validSendAmount := sdk.NewCoins(sdk.NewCoin(bondDenom, math.NewInt(1))) | ||
| invalidSendAmount := sdk.NewCoins(sdk.NewCoin(bondDenom, math.NewInt(100))) | ||
|
|
||
| // setup our mock bank hooks receiver that prevents the send of 100 coins | ||
| bankHooksReceiver := MockBankHooksReceiver{} | ||
| baseBankKeeper, ok := app.BankKeeper.(keeper.BaseKeeper) | ||
| require.True(t, ok) | ||
| keeper.UnsafeSetHooks( | ||
| &baseBankKeeper, types.NewMultiBankHooks(&bankHooksReceiver), | ||
| ) | ||
| app.BankKeeper = baseBankKeeper | ||
|
|
||
| // try sending a validSendAmount and it should work | ||
| err = app.BankKeeper.SendCoins(ctx, addrs[0], addrs[1], validSendAmount) | ||
| require.NoError(t, err) | ||
|
|
||
| // try sending an invalidSendAmount and it should not work | ||
| err = app.BankKeeper.SendCoins(ctx, addrs[0], addrs[1], invalidSendAmount) | ||
| require.Error(t, err) | ||
|
|
||
| // try doing SendManyCoins and make sure if even a single subsend is invalid, the entire function fails | ||
| err = app.BankKeeper.SendManyCoins(ctx, addrs[0], []sdk.AccAddress{addrs[0], addrs[1]}, []sdk.Coins{invalidSendAmount, validSendAmount}) | ||
| require.Error(t, err) | ||
|
|
||
| // make sure that account to module doesn't bypass hook | ||
| err = app.BankKeeper.SendCoinsFromAccountToModule(ctx, addrs[0], stakingtypes.BondedPoolName, validSendAmount) | ||
| require.NoError(t, err) | ||
| err = app.BankKeeper.SendCoinsFromAccountToModule(ctx, addrs[0], stakingtypes.BondedPoolName, invalidSendAmount) | ||
| require.Error(t, err) | ||
|
|
||
| // make sure that module to account doesn't bypass hook | ||
| err = app.BankKeeper.SendCoinsFromModuleToAccount(ctx, stakingtypes.BondedPoolName, addrs[0], validSendAmount) | ||
| require.NoError(t, err) | ||
| err = app.BankKeeper.SendCoinsFromModuleToAccount(ctx, stakingtypes.BondedPoolName, addrs[0], invalidSendAmount) | ||
| require.Error(t, err) | ||
|
|
||
| // make sure that module to module doesn't bypass hook | ||
| err = app.BankKeeper.SendCoinsFromModuleToModule(ctx, stakingtypes.BondedPoolName, stakingtypes.NotBondedPoolName, validSendAmount) | ||
| require.NoError(t, err) | ||
| err = app.BankKeeper.SendCoinsFromModuleToModule(ctx, stakingtypes.BondedPoolName, stakingtypes.NotBondedPoolName, invalidSendAmount) | ||
| require.Error(t, err) | ||
|
|
||
| // make sure that module to many accounts doesn't bypass hook | ||
| err = app.BankKeeper.SendCoinsFromModuleToManyAccounts(ctx, stakingtypes.BondedPoolName, []sdk.AccAddress{addrs[0], addrs[1]}, []sdk.Coins{validSendAmount, validSendAmount}) | ||
| require.NoError(t, err) | ||
| err = app.BankKeeper.SendCoinsFromModuleToManyAccounts(ctx, stakingtypes.BondedPoolName, []sdk.AccAddress{addrs[0], addrs[1]}, []sdk.Coins{validSendAmount, invalidSendAmount}) | ||
| require.Error(t, err) | ||
|
|
||
| // make sure that DelegateCoins doesn't bypass the hook | ||
| err = app.BankKeeper.DelegateCoins(ctx, addrs[0], app.AccountKeeper.GetModuleAddress(stakingtypes.BondedPoolName), validSendAmount) | ||
| require.NoError(t, err) | ||
| err = app.BankKeeper.DelegateCoins(ctx, addrs[0], app.AccountKeeper.GetModuleAddress(stakingtypes.BondedPoolName), invalidSendAmount) | ||
| require.Error(t, err) | ||
|
|
||
| // make sure that UndelegateCoins doesn't bypass the hook | ||
| err = app.BankKeeper.UndelegateCoins(ctx, app.AccountKeeper.GetModuleAddress(stakingtypes.BondedPoolName), addrs[0], validSendAmount) | ||
| require.NoError(t, err) | ||
| err = app.BankKeeper.UndelegateCoins(ctx, app.AccountKeeper.GetModuleAddress(stakingtypes.BondedPoolName), addrs[0], invalidSendAmount) | ||
| require.Error(t, err) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,11 @@ | ||
| package keeper | ||
|
|
||
| import "github.com/cosmos/cosmos-sdk/x/bank/types" | ||
|
|
||
| // UnsafeSetHooks updates the x/bank keeper's hooks, overriding any potential | ||
| // pre-existing hooks. | ||
| // | ||
| // WARNING: this function should only be used in tests. | ||
| func UnsafeSetHooks(k *BaseKeeper, h types.BankHooks) { | ||
| k.hooks = h | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.