F/rewards generation e2e (#63)

babylon-contract v0.11 integration

demo/app/app.go

@@ -12,6 +12,7 @@ import (
 	wasmkeeper "github.com/CosmWasm/wasmd/x/wasm/keeper"
 	wasmtypes "github.com/CosmWasm/wasmd/x/wasm/types"
 	appparams "github.com/babylonlabs-io/babylon-sdk/demo/app/params"
+	appwasm "github.com/babylonlabs-io/babylon-sdk/demo/app/wasm"
 	abci "github.com/cometbft/cometbft/abci/types"
 	tmos "github.com/cometbft/cometbft/libs/os"
 	cmtproto "github.com/cometbft/cometbft/proto/tendermint/types"
@@ -492,6 +493,9 @@ func NewConsumerApp(
 		// add support for the custom queries
 		wasmkeeper.WithQueryHandlerDecorator(bbnkeeper.NewQueryDecorator(app.BabylonKeeper)),
 	)
+	// Add grpc query support for the whitelisted grpc queries
+	wasmOpts = append(wasmOpts, appwasm.RegisterGrpcQueries(bApp, appCodec)...)
+
 	// The last arguments can contain custom message handlers, and custom query handlers,
 	// if we want to allow any custom callbacks
 	availableCapabilities := AllCapabilities()

demo/app/test_helpers.go

@@ -66,6 +66,7 @@ func setup(t testing.TB, chainID string, withGenesis bool, invCheckPeriod uint,
 
 	appOptions := make(simsutils.AppOptionsMap, 0)
 	appOptions[flags.FlagHome] = nodeHome // ensure unique folder
+	appOptions[server.FlagTrace] = true
 	appOptions[server.FlagInvCheckPeriod] = invCheckPeriod
 	app := NewConsumerApp(log.NewNopLogger(), db, nil, true, appOptions, opts, bam.SetChainID(chainID), bam.SetSnapshot(snapshotStore, snapshottypes.SnapshotOptions{KeepRecent: 2}))
 	if withGenesis {

demo/app/wasm/grpc_whitelist.go

@@ -0,0 +1,29 @@
+package wasm
+
+import (
+	wasmkeeper "github.com/CosmWasm/wasmd/x/wasm/keeper"
+	"github.com/cosmos/cosmos-sdk/baseapp"
+	"github.com/cosmos/cosmos-sdk/codec"
+	minttypes "github.com/cosmos/cosmos-sdk/x/mint/types"
+)
+
+func RegisterGrpcQueries(bApp *baseapp.BaseApp, appCodec codec.Codec) []wasmkeeper.Option {
+	queryRouter := bApp.GRPCQueryRouter()
+	queryPluginOpt := wasmkeeper.WithQueryPlugins(
+		&wasmkeeper.QueryPlugins{
+			Stargate: wasmkeeper.AcceptListStargateQuerier(WhitelistedGrpcQuery(), queryRouter, appCodec),
+			Grpc:     wasmkeeper.AcceptListGrpcQuerier(WhitelistedGrpcQuery(), queryRouter, appCodec),
+		})
+
+	return []wasmkeeper.Option{
+		queryPluginOpt,
+	}
+}
+
+// WhitelistedGrpcQuery returns the whitelisted Grpc queries
+func WhitelistedGrpcQuery() wasmkeeper.AcceptedQueries {
+	return wasmkeeper.AcceptedQueries{
+		// mint
+		"/cosmos.mint.v1beta1.Query/Params": &minttypes.QueryParamsResponse{},
+	}
+}

tests/scripts/copy_local_wasm.sh

@@ -2,7 +2,7 @@
 set -o errexit -o nounset -o pipefail
 command -v shellcheck >/dev/null && shellcheck "$0"
 
-CONTRACTS="babylon_contract btc_staking"
+CONTRACTS="babylon_contract btc_staking btc_finality"
 OUTPUT_FOLDER="$(dirname "$0")/../testdata"
 
 echo "DEV-only: copy from local built instead of downloading"

tests/testdata/version.txt

@@ -1 +1 @@
-v0.10.0-rc.0
+v0.11.0-rc.1

x/babylon/keeper/wasm.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"encoding/hex"
 	"encoding/json"
+	"fmt"
 
 	errorsmod "cosmossdk.io/errors"
 	"github.com/babylonlabs-io/babylon-sdk/x/babylon/contract"
@@ -113,6 +114,6 @@ func (k Keeper) doSudoCall(ctx sdk.Context, contractAddr sdk.AccAddress, msg con
 		return errorsmod.Wrap(err, "marshal sudo msg")
 	}
 	resp, err := k.wasm.Sudo(ctx, contractAddr, bz)
-	k.Logger(ctx).Debug("response of sudo call %v to contract %s: %v", bz, contractAddr.String(), resp)
+	k.Logger(ctx).Debug(fmt.Sprintf("response of sudo call %v to contract %s: %v", bz, contractAddr.String(), resp))
 	return err
 }