feat: add static aggregation hook implementation for cosmosnative

.gitignore

@@ -30,6 +30,7 @@ go.work.sum
 # Depinject debug file
 debug_container.dot
 
+.DS_Store
 .idea
 /release/
 **/node_modules

proto/hyperlane/core/post_dispatch/v1/events.proto

@@ -87,6 +87,27 @@ message EventCreateNoopHook {
   string owner = 2;
 }
 
+// EventCreateAggregationHook ...
+message EventCreateAggregationHook {
+
+  // id ...
+  string aggregation_hook_id = 1 [
+    (gogoproto.customtype) =
+        "github.com/bcp-innovations/hyperlane-cosmos/util.HexAddress",
+    (gogoproto.nullable) = false
+  ];
+
+  // owner ...
+  string owner = 2;
+
+  // hooks ...
+  repeated string hooks = 3 [
+    (gogoproto.customtype) =
+        "github.com/bcp-innovations/hyperlane-cosmos/util.HexAddress",
+    (gogoproto.nullable) = false
+  ];
+}
+
 // EventCreateIgp ...
 message EventCreateIgp {
   string igp_id = 1 [

proto/hyperlane/core/post_dispatch/v1/genesis.proto

@@ -14,6 +14,8 @@ message GenesisState {
   repeated MerkleTreeHook merkle_tree_hooks = 3
       [ (gogoproto.nullable) = false ];
   repeated NoopHook noop_hooks = 4 [ (gogoproto.nullable) = false ];
+  repeated AggregationHook aggregation_hooks = 5
+      [ (gogoproto.nullable) = false ];
 }
 
 // GenesisDestinationGasConfigWrapper ...
@@ -32,4 +34,4 @@ message GenesisDestinationGasConfigWrapper {
 
   // igp_id is required for the Genesis handling.
   uint64 igp_id = 4;
-}
+}

proto/hyperlane/core/post_dispatch/v1/query.proto

@@ -58,6 +58,18 @@ service Query {
   rpc NoopHook(QueryNoopHookRequest) returns (QueryNoopHookResponse) {
     option (google.api.http).get = "/hyperlane/v1/noop_hooks/{id}";
   }
+
+  // AggregationHooks ...
+  rpc AggregationHooks(QueryAggregationHooksRequest)
+      returns (QueryAggregationHooksResponse) {
+    option (google.api.http).get = "/hyperlane/v1/aggregation_hooks";
+  }
+
+  // AggregationHook ...
+  rpc AggregationHook(QueryAggregationHookRequest)
+      returns (QueryAggregationHookResponse) {
+    option (google.api.http).get = "/hyperlane/v1/aggregation_hooks/{id}";
+  }
 }
 
 // QueryIgpsRequest ...
@@ -174,3 +186,21 @@ message QueryNoopHooksResponse {
       [ (gogoproto.nullable) = false, (amino.dont_omitempty) = true ];
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
+
+// QueryAggregationHookRequest ...
+message QueryAggregationHookRequest { string id = 1; }
+
+// QueryAggregationHookResponse ...
+message QueryAggregationHookResponse { AggregationHook aggregation_hook = 1; }
+
+// QueryAggregationHooksRequest ...
+message QueryAggregationHooksRequest {
+  cosmos.base.query.v1beta1.PageRequest pagination = 1;
+}
+
+// QueryAggregationHooksResponse ...
+message QueryAggregationHooksResponse {
+  repeated AggregationHook aggregation_hooks = 1
+      [ (gogoproto.nullable) = false, (amino.dont_omitempty) = true ];
+  cosmos.base.query.v1beta1.PageResponse pagination = 2;
+}

proto/hyperlane/core/post_dispatch/v1/tx.proto

@@ -36,6 +36,10 @@ service Msg {
 
   // CreateNoopHook ...
   rpc CreateNoopHook(MsgCreateNoopHook) returns (MsgCreateNoopHookResponse);
+
+  // CreateAggregationHook ...
+  rpc CreateAggregationHook(MsgCreateAggregationHook)
+      returns (MsgCreateAggregationHookResponse);
 }
 
 // MsgCreateIgp ...
@@ -205,3 +209,28 @@ message MsgCreateNoopHookResponse {
     (gogoproto.nullable) = false
   ];
 }
+
+// MsgCreateAggregationHook ...
+message MsgCreateAggregationHook {
+  option (cosmos.msg.v1.signer) = "owner";
+  option (amino.name) = "hyperlane/v1/MsgCreateAggregationHook";
+
+  // owner ...
+  string owner = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // hooks ...
+  repeated string hooks = 2 [
+    (gogoproto.customtype) =
+        "github.com/bcp-innovations/hyperlane-cosmos/util.HexAddress",
+    (gogoproto.nullable) = false
+  ];
+}
+
+// MsgCreateAggregationHookResponse ...
+message MsgCreateAggregationHookResponse {
+  string id = 1 [
+    (gogoproto.customtype) =
+        "github.com/bcp-innovations/hyperlane-cosmos/util.HexAddress",
+    (gogoproto.nullable) = false
+  ];
+}

proto/hyperlane/core/post_dispatch/v1/types.proto

@@ -103,4 +103,24 @@ message NoopHook {
 
   // owner ...
   string owner = 2 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
-}
+}
+
+// AggregationHook ...
+message AggregationHook {
+  // id ...
+  string id = 1 [
+    (gogoproto.customtype) =
+        "github.com/bcp-innovations/hyperlane-cosmos/util.HexAddress",
+    (gogoproto.nullable) = false
+  ];
+
+  // owner ...
+  string owner = 2 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // hooks ...
+  repeated string hooks = 3 [
+    (gogoproto.customtype) =
+        "github.com/bcp-innovations/hyperlane-cosmos/util.HexAddress",
+    (gogoproto.nullable) = false
+  ];
+}

x/core/02_post_dispatch/client/cli/query.go

@@ -29,6 +29,8 @@ func GetQueryCmd() *cobra.Command {
 		CmdMerkleTreeHook(),
 		CmdNoopHooks(),
 		CmdNoopHook(),
+		CmdAggregationHooks(),
+		CmdAggregationHook(),
 	)
 	return cmd
 }
@@ -303,3 +305,70 @@ func CmdNoopHook() *cobra.Command {
 
 	return cmd
 }
+
+func CmdAggregationHooks() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "aggregation-hooks",
+		Short: "List all aggregation hooks",
+		Args:  cobra.ExactArgs(0),
+		RunE: func(cmd *cobra.Command, args []string) (err error) {
+			clientCtx, err := client.GetClientQueryContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			queryClient := types.NewQueryClient(clientCtx)
+			pageReq, err := client.ReadPageRequest(cmd.Flags())
+			if err != nil {
+				return err
+			}
+
+			params := &types.QueryAggregationHooksRequest{
+				Pagination: pageReq,
+			}
+
+			res, err := queryClient.AggregationHooks(cmd.Context(), params)
+			if err != nil {
+				return err
+			}
+
+			return clientCtx.PrintProto(res)
+		},
+	}
+
+	flags.AddQueryFlagsToCmd(cmd)
+	flags.AddPaginationFlagsToCmd(cmd, "aggregation-hooks")
+
+	return cmd
+}
+
+func CmdAggregationHook() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "aggregation-hook [id]",
+		Short: "Get details for a specific aggregation hook",
+		Args:  cobra.ExactArgs(1),
+		RunE: func(cmd *cobra.Command, args []string) (err error) {
+			clientCtx, err := client.GetClientQueryContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			queryClient := types.NewQueryClient(clientCtx)
+
+			params := &types.QueryAggregationHookRequest{
+				Id: args[0],
+			}
+
+			res, err := queryClient.AggregationHook(cmd.Context(), params)
+			if err != nil {
+				return err
+			}
+
+			return clientCtx.PrintProto(res)
+		},
+	}
+
+	flags.AddQueryFlagsToCmd(cmd)
+
+	return cmd
+}

x/core/02_post_dispatch/client/cli/tx.go

@@ -23,6 +23,7 @@ func GetTxCmd() *cobra.Command {
 		NewIgpCmd(),
 		NewMerkleCmd(),
 		NewNoopHookCmd(),
+		NewAggregationHookCmd(),
 	)
 
 	return txCmd

x/core/02_post_dispatch/client/cli/tx_aggregation.go

@@ -0,0 +1,65 @@
+package cli
+
+import (
+	"fmt"
+
+	"github.com/bcp-innovations/hyperlane-cosmos/util"
+	"github.com/bcp-innovations/hyperlane-cosmos/x/core/02_post_dispatch/types"
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/cosmos/cosmos-sdk/client/flags"
+	"github.com/cosmos/cosmos-sdk/client/tx"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/spf13/cobra"
+)
+
+func NewAggregationHookCmd() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "aggregation",
+		Short: "Hyperlane Aggregation Hook commands",
+	}
+
+	cmd.AddCommand(
+		CmdCreateAggregationHook(),
+	)
+
+	return cmd
+}
+
+func CmdCreateAggregationHook() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "create [hook-id...]",
+		Short: "Create a new aggregation hook with the given ordered child hook ids",
+		Args:  cobra.MinimumNArgs(1),
+		RunE: func(cmd *cobra.Command, args []string) (err error) {
+			clientCtx, err := client.GetClientTxContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			hooks := make([]util.HexAddress, len(args))
+			for i, arg := range args {
+				hookId, err := util.DecodeHexAddress(arg)
+				if err != nil {
+					return err
+				}
+				hooks[i] = hookId
+			}
+
+			msg := types.MsgCreateAggregationHook{
+				Owner: clientCtx.GetFromAddress().String(),
+				Hooks: hooks,
+			}
+
+			_, err = sdk.AccAddressFromBech32(msg.Owner)
+			if err != nil {
+				panic(fmt.Errorf("invalid sender address (%s)", msg.Owner))
+			}
+
+			return tx.GenerateOrBroadcastTxCLI(clientCtx, cmd.Flags(), &msg)
+		},
+	}
+
+	flags.AddTxFlagsToCmd(cmd)
+
+	return cmd
+}

x/core/02_post_dispatch/keeper/genesis.go

@@ -41,6 +41,15 @@ func InitGenesis(ctx sdk.Context, k Keeper, data *types.GenesisState) {
 			panic(err)
 		}
 	}
+
+	for _, aggregationHook := range data.AggregationHooks {
+		if err := k.validateAggregationHooks(ctx, aggregationHook.Hooks); err != nil {
+			panic(err)
+		}
+		if err := k.aggregationHooks.Set(ctx, aggregationHook.Id.GetInternalId(), aggregationHook); err != nil {
+			panic(err)
+		}
+	}
 }
 
 func ExportGenesis(ctx sdk.Context, k Keeper) *types.GenesisState {
@@ -95,10 +104,21 @@ func ExportGenesis(ctx sdk.Context, k Keeper) *types.GenesisState {
 		panic(err)
 	}
 
+	iterAggregationHooks, err := k.aggregationHooks.Iterate(ctx, nil)
+	if err != nil {
+		panic(err)
+	}
+
+	aggregationHooks, err := iterAggregationHooks.Values()
+	if err != nil {
+		panic(err)
+	}
+
 	return &types.GenesisState{
-		Igps:            igps,
-		IgpGasConfigs:   gasConfigs,
-		MerkleTreeHooks: merkleTreeHooks,
-		NoopHooks:       noopHooks,
+		Igps:             igps,
+		IgpGasConfigs:    gasConfigs,
+		MerkleTreeHooks:  merkleTreeHooks,
+		NoopHooks:        noopHooks,
+		AggregationHooks: aggregationHooks,
 	}
 }