feat(cron): add cron module for scheduled execution of wasm contracts

app/ante.go

@@ -12,13 +12,19 @@ import (
 	errorsmod "cosmossdk.io/errors"
 	wasmkeeper "github.com/CosmWasm/wasmd/x/wasm/keeper"
 	wasmtypes "github.com/CosmWasm/wasmd/x/wasm/types"
+	// TODO: revisit
+	// "github.com/dymensionxyz/rollapp-wasm/x/gasless"
+	// gaslesskeeper "github.com/dymensionxyz/rollapp-wasm/x/gasless/keeper"
 )
 
 // HandlerOptions are the options required for constructing a default SDK AnteHandler.
 type HandlerOptions struct {
 	ante.HandlerOptions
 
 	IBCKeeper         *ibckeeper.Keeper
+	// TODO: revisit
+	// GaslessKeeper     gaslesskeeper.Keeper
+	// BankKeeper        gasless.BankKeeper
 	WasmConfig        *wasmtypes.WasmConfig
 	TxCounterStoreKey storetypes.StoreKey
 }
@@ -40,6 +46,8 @@ func GetAnteDecorators(options HandlerOptions) []sdk.AnteDecorator {
 
 		ante.NewValidateMemoDecorator(options.AccountKeeper),
 		ante.NewConsumeGasForTxSizeDecorator(options.AccountKeeper),
+		// TODO: revisit
+		// gasless.NewDeductFeeDecorator(options.AccountKeeper, options.BankKeeper, options.FeegrantKeeper, options.TxFeeChecker, options.GaslessKeeper),
 		ante.NewDeductFeeDecorator(options.AccountKeeper, options.BankKeeper, options.FeegrantKeeper, options.TxFeeChecker),
 		ante.NewSetPubKeyDecorator(options.AccountKeeper), // SetPubKeyDecorator must be called before all signature verification decorators
 		ante.NewValidateSigCountDecorator(options.AccountKeeper),

app/app.go

@@ -126,6 +126,16 @@ import (
 
 	distr "github.com/dymensionxyz/dymension-rdk/x/dist"
 	distrkeeper "github.com/dymensionxyz/dymension-rdk/x/dist/keeper"
+
+	"github.com/dymensionxyz/rollapp-wasm/x/cron"
+	cronkeeper "github.com/dymensionxyz/rollapp-wasm/x/cron/keeper"
+	crontypes "github.com/dymensionxyz/rollapp-wasm/x/cron/types"
+
+	// TODO: revisit
+	// "github.com/dymensionxyz/rollapp-wasm/x/gasless"
+	// gaslessclient "github.com/dymensionxyz/rollapp-wasm/x/gasless/client"
+	// gaslesskeeper "github.com/dymensionxyz/rollapp-wasm/x/gasless/keeper"
+	// gaslesstypes "github.com/dymensionxyz/rollapp-wasm/x/gasless/types"
 )
 
 const (
@@ -145,6 +155,9 @@ var (
 		ibctransfertypes.StoreKey, capabilitytypes.StoreKey,
 		wasmtypes.StoreKey,
 		denommetadatamoduletypes.StoreKey,
+		crontypes.StoreKey,
+		// TODO: revisit
+		// gaslesstypes.StoreKey,
 	}
 )
 
@@ -158,6 +171,8 @@ func getGovProposalHandlers() []govclient.ProposalHandler {
 		ibcclientclient.UpdateClientProposalHandler,
 		ibcclientclient.UpgradeProposalHandler,
 	)
+	// TODO: revisit
+	// govProposalHandlers = append(govProposalHandlers, gaslessclient.GaslessProposalHandler...)
 
 	return govProposalHandlers
 }
@@ -190,6 +205,9 @@ var (
 		hubgenesis.AppModuleBasic{},
 		wasm.AppModuleBasic{},
 		denommetadata.AppModuleBasic{},
+		cron.AppModuleBasic{},
+		// TODO: revisit
+		// gasless.AppModuleBasic{},
 	)
 
 	// module account permissions
@@ -205,6 +223,9 @@ var (
 		wasmtypes.ModuleName:                {authtypes.Burner},
 		hubgentypes.ModuleName:              {authtypes.Burner},
 		denommetadatamoduletypes.ModuleName: nil,
+		crontypes.ModuleName:                nil,
+		// TODO: revisit
+		// gaslesstypes.ModuleName:             nil,
 	}
 )
 
@@ -257,6 +278,9 @@ type App struct {
 	TransferKeeper   ibctransferkeeper.Keeper
 	WasmKeeper       wasmkeeper.Keeper
 	FeeGrantKeeper   feegrantkeeper.Keeper
+	CronKeeper       cronkeeper.Keeper
+	// TODO: revisit
+	// GaslessKeeper    gaslesskeeper.Keeper
 
 	// make scoped keepers public for test purposes
 	ScopedIBCKeeper      capabilitykeeper.ScopedKeeper
@@ -434,6 +458,8 @@ func NewRollapp(
 		AddRoute(distrtypes.RouterKey, distr.NewCommunityPoolSpendProposalHandler(app.DistrKeeper)).
 		AddRoute(upgradetypes.RouterKey, upgrade.NewSoftwareUpgradeProposalHandler(app.UpgradeKeeper)).
 		AddRoute(ibcclienttypes.RouterKey, ibcclient.NewClientProposalHandler(app.IBCKeeper.ClientKeeper))
+		// TODO: revisit
+		// AddRoute(gaslesstypes.RouterKey, gasless.NewGaslessProposalHandler(app.GaslessKeeper))
 
 	govConfig := govtypes.DefaultConfig()
 	/*
@@ -485,6 +511,25 @@ func NewRollapp(
 		app.AccountKeeper,
 	)
 
+	app.CronKeeper = cronkeeper.NewKeeper(
+		appCodec,
+		app.keys[crontypes.StoreKey],
+		app.keys[crontypes.MemStoreKey],
+		app.GetSubspace(crontypes.ModuleName),
+		&app.WasmKeeper,
+	)
+
+	// TODO: revisit
+	// app.GaslessKeeper = gaslesskeeper.NewKeeper(
+	// 	appCodec,
+	// 	app.keys[gaslesstypes.StoreKey],
+	// 	app.GetSubspace(gaslesstypes.ModuleName),
+	// 	app.interfaceRegistry,
+	// 	app.AccountKeeper,
+	// 	app.BankKeeper,
+	// 	&app.WasmKeeper,
+	// )
+
 	wasmDir := filepath.Join(homePath, "wasm")
 	wasmConfig, err := wasm.ReadWasmConfig(appOpts)
 	if err != nil {
@@ -556,6 +601,9 @@ func NewRollapp(
 		upgrade.NewAppModule(app.UpgradeKeeper),
 		hubgenesis.NewAppModule(appCodec, app.HubGenesisKeeper, app.AccountKeeper),
 		denommetadata.NewAppModule(app.DenomMetadataKeeper, app.BankKeeper),
+		cron.NewAppModule(appCodec, app.CronKeeper, app.AccountKeeper, app.BankKeeper, app.WasmKeeper),
+		// TODO: revisit
+		// gasless.NewAppModule(appCodec, app.GaslessKeeper, app.AccountKeeper, app.BankKeeper),
 	}
 
 	app.mm = module.NewManager(modules...)
@@ -586,6 +634,9 @@ func NewRollapp(
 		hubgentypes.ModuleName,
 		denommetadatamoduletypes.ModuleName,
 		wasm.ModuleName,
+		crontypes.ModuleName,
+		// TODO: revisit
+		// gaslesstypes.ModuleName,
 	}
 	app.mm.SetOrderBeginBlockers(beginBlockersList...)
 
@@ -610,6 +661,9 @@ func NewRollapp(
 		hubgentypes.ModuleName,
 		denommetadatamoduletypes.ModuleName,
 		wasm.ModuleName,
+		crontypes.ModuleName,
+		// TODO: revisit
+		// gaslesstypes.ModuleName,
 	}
 	app.mm.SetOrderEndBlockers(endBlockersList...)
 
@@ -640,6 +694,9 @@ func NewRollapp(
 		hubgentypes.ModuleName,
 		denommetadatamoduletypes.ModuleName,
 		wasm.ModuleName,
+		crontypes.ModuleName,
+		// TODO: revisit
+		// gaslesstypes.ModuleName,
 	}
 	app.mm.SetOrderInitGenesis(initGenesisList...)
 
@@ -729,6 +786,9 @@ func (app *App) setAnteHandler(txConfig client.TxConfig, wasmConfig wasmtypes.Wa
 				SigGasConsumer:  ante.DefaultSigVerificationGasConsumer,
 			},
 			IBCKeeper:         app.IBCKeeper,
+			// TODO: revisit
+			// GaslessKeeper:     app.GaslessKeeper,
+			// BankKeeper:        app.BankKeeper,
 			WasmConfig:        &wasmConfig,
 			TxCounterStoreKey: app.keys[wasmtypes.StoreKey],
 		},
@@ -972,5 +1032,8 @@ func initParamsKeeper(appCodec codec.BinaryCodec, legacyAmino *codec.LegacyAmino
 	paramsKeeper.Subspace(denommetadatamoduletypes.ModuleName)
 
 	paramsKeeper.Subspace(wasmtypes.ModuleName)
+	paramsKeeper.Subspace(crontypes.ModuleName)
+	// TODO: revisit
+	// paramsKeeper.Subspace(gaslesstypes.ModuleName)
 	return paramsKeeper
 }

go.mod

@@ -9,20 +9,26 @@ require (
 	github.com/CosmWasm/wasmd v0.33.0
 	github.com/bcdevtools/block-explorer-rpc-cosmos v1.2.3
 	github.com/bcdevtools/wasm-block-explorer-rpc-cosmos v1.1.1
+	github.com/cosmos/cosmos-proto v1.0.0-beta.3
 	github.com/cosmos/cosmos-sdk v0.46.16
+	github.com/cosmos/gogoproto v1.4.11
 	github.com/cosmos/ibc-go/v6 v6.3.0
 	github.com/dymensionxyz/dymension-rdk v1.6.0
 	github.com/dymensionxyz/dymint v1.1.0-rc02
 	github.com/ethereum/go-ethereum v1.12.0
 	github.com/evmos/evmos/v12 v12.1.6
+	github.com/gogo/protobuf v1.3.3
+	github.com/golang/protobuf v1.5.3
 	github.com/gorilla/mux v1.8.1
+	github.com/grpc-ecosystem/grpc-gateway v1.16.0
 	github.com/pkg/errors v0.9.1
 	github.com/prometheus/client_golang v1.18.0
 	github.com/rakyll/statik v0.1.7
 	github.com/spf13/cast v1.5.1
 	github.com/spf13/cobra v1.8.0
 	github.com/tendermint/tendermint v0.34.29
 	github.com/tendermint/tm-db v0.6.8-0.20220506192307-f628bb5dc95b
+	google.golang.org/genproto/googleapis/api v0.0.0-20240125205218-1f4bbc51befe
 	google.golang.org/grpc v1.61.0
 )
 
@@ -79,9 +85,7 @@ require (
 	github.com/containerd/cgroups v1.1.0 // indirect
 	github.com/coreos/go-systemd/v22 v22.5.0 // indirect
 	github.com/cosmos/btcutil v1.0.5 // indirect
-	github.com/cosmos/cosmos-proto v1.0.0-beta.3 // indirect
 	github.com/cosmos/go-bip39 v1.0.0 // indirect
-	github.com/cosmos/gogoproto v1.4.11 // indirect
 	github.com/cosmos/gorocksdb v1.2.0 // indirect
 	github.com/cosmos/iavl v0.19.6 // indirect
 	github.com/cosmos/ledger-cosmos-go v0.12.4 // indirect
@@ -124,10 +128,8 @@ require (
 	github.com/godbus/dbus v0.0.0-20190726142602-4481cbc300e2 // indirect
 	github.com/godbus/dbus/v5 v5.1.0 // indirect
 	github.com/gogo/gateway v1.1.0 // indirect
-	github.com/gogo/protobuf v1.3.3 // indirect
 	github.com/golang/glog v1.1.2 // indirect
 	github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
-	github.com/golang/protobuf v1.5.3 // indirect
 	github.com/golang/snappy v0.0.5-0.20220116011046-fa5810519dcb // indirect
 	github.com/google/btree v1.1.2 // indirect
 	github.com/google/flatbuffers v2.0.8+incompatible // indirect
@@ -144,7 +146,6 @@ require (
 	github.com/gorilla/rpc v1.2.0 // indirect
 	github.com/gorilla/websocket v1.5.1 // indirect
 	github.com/grpc-ecosystem/go-grpc-middleware v1.3.0 // indirect
-	github.com/grpc-ecosystem/grpc-gateway v1.16.0 // indirect
 	github.com/gsterjov/go-libsecret v0.0.0-20161001094733-a6f4afe4910c // indirect
 	github.com/gtank/merlin v0.1.1 // indirect
 	github.com/gtank/ristretto255 v0.1.2 // indirect
@@ -296,7 +297,6 @@ require (
 	google.golang.org/api v0.149.0 // indirect
 	google.golang.org/appengine v1.6.8 // indirect
 	google.golang.org/genproto v0.0.0-20240116215550-a9fa1716bcac // indirect
-	google.golang.org/genproto/googleapis/api v0.0.0-20240125205218-1f4bbc51befe // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20240125205218-1f4bbc51befe // indirect
 	google.golang.org/protobuf v1.32.0 // indirect
 	gopkg.in/ini.v1 v1.67.0 // indirect

proto/aib/cron/v1beta1/cron.proto

@@ -0,0 +1,15 @@
+syntax = "proto3";
+package aib.cron.v1beta1;
+
+import "gogoproto/gogo.proto";
+
+option go_package = "github.com/dymensionxyz/rollapp-wasm/x/cron/types";
+
+message WhitelistedContract {
+    uint64 game_id = 1;
+    string security_address = 2;
+    string contract_admin = 3;
+    string game_name = 4;
+    string contract_address = 5;
+    uint64 game_type = 6;
+}

proto/aib/cron/v1beta1/genesis.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+package aib.cron.v1beta1;
+
+import "gogoproto/gogo.proto";
+import "aib/cron/v1beta1/params.proto";
+import "aib/cron/v1beta1/cron.proto";
+
+option go_package = "github.com/dymensionxyz/rollapp-wasm/x/cron/types";
+
+// GenesisState defines the cron module's genesis state.
+message GenesisState {
+  Params params = 1 [
+    (gogoproto.moretags) = "yaml:\"params\"",
+    (gogoproto.nullable) = false
+  ];
+  repeated WhitelistedContract whitelisted_contracts  = 2  [
+    (gogoproto.moretags) = "yaml:\"whitelisted_contracts\"",
+    (gogoproto.nullable) = false
+  ];
+}

proto/aib/cron/v1beta1/params.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+package aib.cron.v1beta1;
+
+import "gogoproto/gogo.proto";
+
+option go_package = "github.com/dymensionxyz/rollapp-wasm/x/cron/types";
+
+// Params defines the set of module parameters.
+message Params {
+  // Security address that can whitelist/delist contract
+  repeated string security_address = 1 [    
+    (gogoproto.jsontag) = "security_address,omitempty",
+    (gogoproto.moretags) = "yaml:\"security_address\""
+  ];
+
+  uint64 contract_gas_limit = 2 [
+    (gogoproto.jsontag) = "contract_gas_limit,omitempty",
+    (gogoproto.moretags) = "yaml:\"contract_gas_limit\""
+  ];
+}

proto/aib/cron/v1beta1/query.proto

@@ -0,0 +1,42 @@
+syntax = "proto3";
+package aib.cron.v1beta1;
+
+import "gogoproto/gogo.proto";
+import "google/api/annotations.proto";
+import "cosmos/base/query/v1beta1/pagination.proto";
+import "aib/cron/v1beta1/params.proto";
+import "aib/cron/v1beta1/cron.proto";
+
+option go_package = "github.com/dymensionxyz/rollapp-wasm/x/cron/types";
+
+// Query defines the gRPC querier service.
+service Query {
+  // Parameters queries the parameters of the module.
+  rpc Params(QueryParamsRequest) returns (QueryParamsResponse) {
+    option (google.api.http).get = "/aib/cron/v1beta1/params";
+  }
+  rpc QueryWhitelistedContracts(QueryWhitelistedContractsRequest) returns (QueryWhitelistedContractsResponse) {
+    option (google.api.http).get = "/aib/cron/v1beta1/whitelisted_contracts";
+  }
+}
+
+// QueryParamsRequest is request type for the Query/Params RPC method.
+message QueryParamsRequest {}
+
+// QueryParamsResponse is response type for the Query/Params RPC method.
+message QueryParamsResponse {
+  // params holds all the parameters of this module.
+  Params params = 1 [(gogoproto.nullable) = false];
+}
+
+message QueryWhitelistedContractsRequest{
+  cosmos.base.query.v1beta1.PageRequest pagination = 1
+  [(gogoproto.moretags) = "yaml:\"pagination\""];
+}
+
+message QueryWhitelistedContractsResponse {
+  repeated WhitelistedContract whilisted_contracts = 1 [(gogoproto.nullable) = false];
+  cosmos.base.query.v1beta1.PageResponse pagination = 2
+  [(gogoproto.moretags) = "yaml:\"pagination\""];
+}
+

proto/aib/cron/v1beta1/tx.proto

@@ -0,0 +1,32 @@
+syntax = "proto3";
+package aib.cron.v1beta1;
+import "gogoproto/gogo.proto";
+
+import "cosmos/msg/v1/msg.proto";
+import "cosmos_proto/cosmos.proto";
+import "aib/cron/v1beta1/params.proto";
+
+
+option go_package = "github.com/dymensionxyz/rollapp-wasm/x/cron/types";
+
+// Msg defines the Msg service.
+service Msg {
+    rpc RegisterContract(MsgRegisterContract) returns(MsgRegisterContractResponse);
+    rpc DeRegisterContract(MsgDeRegisterContract) returns(MsgDeRegisterContractResponse);
+}
+
+message MsgRegisterContract {
+    string security_address = 1;
+    string game_name = 2;
+    string contract_address = 3;
+    uint64 game_type = 4; // 1 -> single, 2 -> multi, 3 -> both
+  }
+
+message MsgRegisterContractResponse {}
+
+message MsgDeRegisterContract {
+  string security_address = 1;
+  uint64 game_id = 2;
+}
+
+message MsgDeRegisterContractResponse {}