feat(batch): batch message request (#2121)

This pr introduce a new message type BatchRequest that suppresses execution errors on individual messages, preventing them from causing the entire batch to fail.

app/app.go

@@ -100,6 +100,8 @@ import (
 
 	axelarParams "github.com/axelarnetwork/axelar-core/app/params"
 	"github.com/axelarnetwork/axelar-core/x/ante"
+	"github.com/axelarnetwork/axelar-core/x/auxiliary"
+	auxiliarytypes "github.com/axelarnetwork/axelar-core/x/auxiliary/types"
 	"github.com/axelarnetwork/axelar-core/x/axelarnet"
 	axelarnetclient "github.com/axelarnetwork/axelar-core/x/axelarnet/client"
 	axelarnetKeeper "github.com/axelarnetwork/axelar-core/x/axelarnet/keeper"
@@ -652,6 +654,7 @@ func initAppModules(keepers *KeeperCache, bApp *bam.BaseApp, encodingConfig axel
 			bApp.Router(),
 		),
 		permission.NewAppModule(*GetKeeper[permissionKeeper.Keeper](keepers)),
+		auxiliary.NewAppModule(encodingConfig.Codec, bApp.MsgServiceRouter()),
 	)
 	return appModules
 }
@@ -692,6 +695,10 @@ func InitCustomAnteDecorators(
 	appOpts servertypes.AppOptions,
 ) []sdk.AnteDecorator {
 	var anteDecorators []sdk.AnteDecorator
+
+	// unwrap batch messages, must be done before any other custom  decorators
+	anteDecorators = append(anteDecorators, ante.NewBatchDecorator(encodingConfig.Codec))
+
 	// enforce wasm limits earlier in the ante handler chain
 	if IsWasmEnabled() {
 		wasmConfig := mustReadWasmConfig(appOpts)
@@ -792,6 +799,7 @@ func orderMigrations() []string {
 		permissionTypes.ModuleName,
 		snapTypes.ModuleName,
 		axelarnetTypes.ModuleName,
+		auxiliarytypes.ModuleName,
 	)
 	return migrationOrder
 }
@@ -842,6 +850,7 @@ func orderBeginBlockers() []string {
 		snapTypes.ModuleName,
 		axelarnetTypes.ModuleName,
 		voteTypes.ModuleName,
+		auxiliarytypes.ModuleName,
 	)
 	return beginBlockerOrder
 }
@@ -887,6 +896,7 @@ func orderEndBlockers() []string {
 		axelarnetTypes.ModuleName,
 		permissionTypes.ModuleName,
 		voteTypes.ModuleName,
+		auxiliarytypes.ModuleName,
 	)
 	return endBlockerOrder
 }
@@ -935,6 +945,7 @@ func orderModulesForGenesis() []string {
 		axelarnetTypes.ModuleName,
 		rewardTypes.ModuleName,
 		permissionTypes.ModuleName,
+		auxiliarytypes.ModuleName,
 	)
 	return genesisOrder
 }
@@ -1105,6 +1116,7 @@ func GetModuleBasics() module.BasicManager {
 		axelarnet.AppModuleBasic{},
 		reward.AppModuleBasic{},
 		permission.AppModuleBasic{},
+		auxiliary.AppModuleBasic{},
 	}
 
 	if IsWasmEnabled() {

proto/axelar/auxiliary/v1beta1/events.proto

@@ -0,0 +1,12 @@
+syntax = "proto3";
+package axelar.auxiliary.v1beta1;
+
+option go_package = "github.com/axelarnetwork/axelar-core/x/auxiliary/types";
+option (gogoproto.messagename_all) = true;
+
+import "gogoproto/gogo.proto";
+
+message BatchedMessageFailed {
+    int32 index = 1;
+    string error = 2;
+}

proto/axelar/auxiliary/v1beta1/genesis.proto

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

proto/axelar/auxiliary/v1beta1/service.proto

@@ -0,0 +1,20 @@
+syntax = "proto3";
+package axelar.auxiliary.v1beta1;
+
+option go_package = "github.com/axelarnetwork/axelar-core/x/auxiliary/types";
+
+import "gogoproto/gogo.proto";
+import "google/api/annotations.proto";
+import "axelar/auxiliary/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/auxiliary/batch"
+      body : "*"
+    };
+  }
+}