feat(batcher): batch message request

app/app.go

@@ -105,6 +105,8 @@ import (
 	axelarnetKeeper "github.com/axelarnetwork/axelar-core/x/axelarnet/keeper"
 	axelarnetTypes "github.com/axelarnetwork/axelar-core/x/axelarnet/types"
 	axelarbankkeeper "github.com/axelarnetwork/axelar-core/x/bank/keeper"
+	"github.com/axelarnetwork/axelar-core/x/batcher"
+	batchertypes "github.com/axelarnetwork/axelar-core/x/batcher/types"
 	"github.com/axelarnetwork/axelar-core/x/evm"
 	evmKeeper "github.com/axelarnetwork/axelar-core/x/evm/keeper"
 	evmTypes "github.com/axelarnetwork/axelar-core/x/evm/types"
@@ -657,7 +659,9 @@ func initAppModules(keepers *KeeperCache, bApp *bam.BaseApp, encodingConfig axel
 			bApp.Router(),
 		),
 		permission.NewAppModule(*getKeeper[permissionKeeper.Keeper](keepers)),
+		batcher.NewAppModule(encodingConfig.Codec, bApp.MsgServiceRouter(), initMessageAnteDecorators(encodingConfig, keepers)),
 	)
+
 	return appModules
 }
 
@@ -789,6 +793,7 @@ func orderMigrations() []string {
 		permissionTypes.ModuleName,
 		snapTypes.ModuleName,
 		axelarnetTypes.ModuleName,
+		batchertypes.ModuleName,
 	)
 	return migrationOrder
 }
@@ -839,6 +844,7 @@ func orderBeginBlockers() []string {
 		snapTypes.ModuleName,
 		axelarnetTypes.ModuleName,
 		voteTypes.ModuleName,
+		batchertypes.ModuleName,
 	)
 	return beginBlockerOrder
 }
@@ -884,6 +890,7 @@ func orderEndBlockers() []string {
 		axelarnetTypes.ModuleName,
 		permissionTypes.ModuleName,
 		voteTypes.ModuleName,
+		batchertypes.ModuleName,
 	)
 	return endBlockerOrder
 }
@@ -932,6 +939,7 @@ func orderModulesForGenesis() []string {
 		axelarnetTypes.ModuleName,
 		rewardTypes.ModuleName,
 		permissionTypes.ModuleName,
+		batchertypes.ModuleName,
 	)
 	return genesisOrder
 }
@@ -1102,6 +1110,7 @@ func GetModuleBasics() module.BasicManager {
 		axelarnet.AppModuleBasic{},
 		reward.AppModuleBasic{},
 		permission.AppModuleBasic{},
+		batcher.AppModuleBasic{},
 	}
 
 	if IsWasmEnabled() {

proto/axelar/batcher/v1beta1/events.proto

@@ -0,0 +1,15 @@
+syntax = "proto3";
+package axelar.batcher.v1beta1;
+
+option go_package = "github.com/axelarnetwork/axelar-core/x/batcher/types";
+option (gogoproto.messagename_all) = true;
+
+import "gogoproto/gogo.proto";
+
+message FailedMessages {
+  message FailedMessage {
+    int32 index = 1;
+    string error = 2;
+  }
+  repeated FailedMessage messages = 1 [ (gogoproto.nullable) = false,   (gogoproto.jsontag) = "messages,omitempty" ];
+}

proto/axelar/batcher/v1beta1/genesis.proto

@@ -0,0 +1,11 @@
+syntax = "proto3";
+package axelar.batcher.v1beta1;
+
+option go_package = "github.com/axelarnetwork/axelar-core/x/batcher/types";
+
+import "gogoproto/gogo.proto";
+
+option (gogoproto.goproto_getters_all) = false;
+
+// GenesisState represents the genesis state
+message GenesisState {}

proto/axelar/batcher/v1beta1/service.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+package axelar.batcher.v1beta1;
+
+option go_package = "github.com/axelarnetwork/axelar-core/x/batcher/types";
+
+import "gogoproto/gogo.proto";
+import "google/api/annotations.proto";
+import "axelar/batcher/v1beta1/tx.proto";
+
+option (gogoproto.goproto_registration) = true;
+
+// Msg defines the nexus Msg service.
+service MsgService {
+  rpc Batch(BatchRequest) returns (BatchResponse) {
+    option (google.api.http) = {
+      post : "/axelar/batcher/batch"
+      body : "*"
+    };
+  }
+}

proto/axelar/batcher/v1beta1/tx.proto

@@ -0,0 +1,22 @@
+syntax = "proto3";
+package axelar.batcher.v1beta1;
+
+import "google/protobuf/any.proto";
+import "gogoproto/gogo.proto";
+
+import "axelar/permission/exported/v1beta1/types.proto";
+
+option go_package = "github.com/axelarnetwork/axelar-core/x/batcher/types";
+
+message BatchRequest {
+  option (permission.exported.v1beta1.permission_role) = ROLE_UNRESTRICTED;
+
+  bytes sender = 1 [ (gogoproto.casttype) =
+                         "github.com/cosmos/cosmos-sdk/types.AccAddress" ];
+  repeated google.protobuf.Any must_succeed_messages = 2
+      [ (gogoproto.nullable) = false ];
+  repeated google.protobuf.Any can_fail_messages = 3
+      [ (gogoproto.nullable) = false ];
+}
+
+message BatchResponse {}

third_party/proto/ibc/applications/transfer/v1/query.proto

@@ -11,24 +11,24 @@ option go_package = "github.com/cosmos/ibc-go/v4/modules/apps/transfer/types";
 
 // Query provides defines the gRPC querier service.
 service Query {
-  // DenomTrace queries a denomination trace information.
-  rpc DenomTrace(QueryDenomTraceRequest) returns (QueryDenomTraceResponse) {
-    option (google.api.http).get = "/ibc/apps/transfer/v1/denom_traces/{hash}";
-  }
-
   // DenomTraces queries all denomination traces.
   rpc DenomTraces(QueryDenomTracesRequest) returns (QueryDenomTracesResponse) {
     option (google.api.http).get = "/ibc/apps/transfer/v1/denom_traces";
   }
 
+  // DenomTrace queries a denomination trace information.
+  rpc DenomTrace(QueryDenomTraceRequest) returns (QueryDenomTraceResponse) {
+    option (google.api.http).get = "/ibc/apps/transfer/v1/denom_traces/{hash=**}";
+  }
+
   // Params queries all parameters of the ibc-transfer module.
   rpc Params(QueryParamsRequest) returns (QueryParamsResponse) {
     option (google.api.http).get = "/ibc/apps/transfer/v1/params";
   }
 
   // DenomHash queries a denomination hash information.
   rpc DenomHash(QueryDenomHashRequest) returns (QueryDenomHashResponse) {
-    option (google.api.http).get = "/ibc/apps/transfer/v1/denom_hashes/{trace}";
+    option (google.api.http).get = "/ibc/apps/transfer/v1/denom_hashes/{trace=**}";
   }
 
   // EscrowAddress returns the escrow address for a particular port and channel id.

utils/events/event_imports_test.go

@@ -4,6 +4,7 @@ package events_test
 import (
 	_ "github.com/axelarnetwork/axelar-core/x/ante/types"
 	_ "github.com/axelarnetwork/axelar-core/x/axelarnet/types"
+	_ "github.com/axelarnetwork/axelar-core/x/batcher/types"
 	_ "github.com/axelarnetwork/axelar-core/x/evm/types"
 	_ "github.com/axelarnetwork/axelar-core/x/multisig/types"
 	_ "github.com/axelarnetwork/axelar-core/x/nexus/types"