feat: kas bridge

app/keepers.go

@@ -111,6 +111,8 @@ import (
 	hypercoretypes "github.com/bcp-innovations/hyperlane-cosmos/x/core/types"
 	hyperwarpkeeper "github.com/bcp-innovations/hyperlane-cosmos/x/warp/keeper"
 	hyperwarptypes "github.com/bcp-innovations/hyperlane-cosmos/x/warp/types"
+	kaskeeper "github.com/dymensionxyz/dymension/v3/x/kas/keeper"
+	kastypes "github.com/dymensionxyz/dymension/v3/x/kas/types"
 
 	forward "github.com/dymensionxyz/dymension/v3/x/forward"
 	forwardtypes "github.com/dymensionxyz/dymension/v3/x/forward/types"
@@ -173,6 +175,7 @@ type AppKeepers struct {
 
 	HyperCoreKeeper hypercorekeeper.Keeper
 	HyperWarpKeeper hyperwarpkeeper.Keeper
+	KasKeeper       *kaskeeper.Keeper
 
 	Forward *forward.Forward
 
@@ -191,7 +194,6 @@ func (a *AppKeepers) InitKeepers(
 	moduleAccountAddrs map[string]bool,
 	appOpts servertypes.AppOptions,
 ) {
-
 	govModuleAddress := authtypes.NewModuleAddress(govtypes.ModuleName).String()
 
 	// get skipUpgradeHeights from the app options
@@ -539,6 +541,13 @@ func (a *AppKeepers) InitKeepers(
 		hyperwarpkeeper.NewMsgServerImpl(a.HyperWarpKeeper),
 	)
 
+	a.KasKeeper = kaskeeper.NewKeeper(
+		appCodec,
+		runtime.NewKVStoreService(a.keys[kastypes.ModuleName]),
+		govModuleAddress,
+		&a.HyperCoreKeeper,
+	)
+
 	a.HyperWarpKeeper.SetHook(a.Forward)
 
 	a.DelayedAckKeeper.SetCompletionHooks(map[string]delayedackkeeper.CompletionHookInstance{

app/keys.go

@@ -32,6 +32,7 @@ import (
 	txfeestypes "github.com/osmosis-labs/osmosis/v15/x/txfees/types"
 
 	irotypes "github.com/dymensionxyz/dymension/v3/x/iro/types"
+	kastypes "github.com/dymensionxyz/dymension/v3/x/kas/types"
 
 	dymnstypes "github.com/dymensionxyz/dymension/v3/x/dymns/types"
 
@@ -129,18 +130,21 @@ var KVStoreKeys = storetypes.NewKVStoreKeys(
 	delayedacktypes.StoreKey,
 	eibcmoduletypes.StoreKey,
 	dymnstypes.StoreKey,
+	lightcliendmoduletypes.StoreKey,
+	grouptypes.StoreKey,
+	hypercoretypes.ModuleName,
+	hyperwarptypes.ModuleName,
+	kastypes.ModuleName,
+
 	// ethermint keys
 	evmtypes.StoreKey,
 	feemarkettypes.StoreKey,
+
 	// osmosis keys
 	lockuptypes.StoreKey,
 	epochstypes.StoreKey,
 	gammtypes.StoreKey,
 	poolmanagertypes.StoreKey,
 	incentivestypes.StoreKey,
 	txfeestypes.StoreKey,
-	lightcliendmoduletypes.StoreKey,
-	grouptypes.StoreKey,
-	hypercoretypes.ModuleName,
-	hyperwarptypes.ModuleName,
 )

app/modules.go

@@ -64,6 +64,8 @@ import (
 
 	dymnsmodule "github.com/dymensionxyz/dymension/v3/x/dymns"
 	dymnstypes "github.com/dymensionxyz/dymension/v3/x/dymns/types"
+	"github.com/dymensionxyz/dymension/v3/x/kas"
+	kastypes "github.com/dymensionxyz/dymension/v3/x/kas/types"
 
 	delayedackmodule "github.com/dymensionxyz/dymension/v3/x/delayedack"
 	denommetadatamodule "github.com/dymensionxyz/dymension/v3/x/denommetadata"
@@ -154,6 +156,7 @@ func (app *App) SetupModules(
 		// Hyperlane modules
 		hypercore.NewAppModule(appCodec, &app.HyperCoreKeeper),
 		hyperwarp.NewAppModule(appCodec, app.HyperWarpKeeper),
+		kas.NewAppModule(appCodec, app.KasKeeper),
 	}
 }
 
@@ -197,6 +200,7 @@ var maccPerms = map[string][]string{
 	irotypes.ModuleName:                                {authtypes.Minter, authtypes.Burner},
 	hypertypes.ModuleName:                              nil,
 	hyperwarptypes.ModuleName:                          {authtypes.Minter, authtypes.Burner},
+	kastypes.ModuleName:                                nil,
 }
 
 var PreBlockers = []string{
@@ -245,6 +249,7 @@ var BeginBlockers = []string{
 	grouptypes.ModuleName,
 	hypertypes.ModuleName,
 	hyperwarptypes.ModuleName,
+	kastypes.ModuleName,
 }
 
 var EndBlockers = []string{
@@ -289,6 +294,7 @@ var EndBlockers = []string{
 	grouptypes.ModuleName,
 	hypertypes.ModuleName,
 	hyperwarptypes.ModuleName,
+	kastypes.ModuleName,
 }
 
 var InitGenesis = []string{
@@ -334,4 +340,5 @@ var InitGenesis = []string{
 	hypertypes.ModuleName,
 	hyperwarptypes.ModuleName,
 	circuittypes.ModuleName,
+	kastypes.ModuleName,
 }

app/upgrades/v5/constants.go

@@ -7,6 +7,7 @@ import (
 	hypercoretypes "github.com/bcp-innovations/hyperlane-cosmos/x/core/types"
 	hyperwarptypes "github.com/bcp-innovations/hyperlane-cosmos/x/warp/types"
 	"github.com/dymensionxyz/dymension/v3/app/upgrades"
+	kastypes "github.com/dymensionxyz/dymension/v3/x/kas/types"
 )
 
 const (
@@ -20,6 +21,7 @@ var Upgrade = upgrades.Upgrade{
 		Added: []string{
 			hypercoretypes.ModuleName,
 			hyperwarptypes.ModuleName,
+			kastypes.ModuleName,
 			circuittypes.ModuleName,
 		},
 	},

go.mod

@@ -247,7 +247,7 @@ require (
 )
 
 replace (
-	github.com/bcp-innovations/hyperlane-cosmos => github.com/dymensionxyz/hyperlane-cosmos v0.0.0-20250520112012-e15f3cfebc7b
+	github.com/bcp-innovations/hyperlane-cosmos => github.com/dymensionxyz/hyperlane-cosmos v0.0.0-20250604142341-c9b00acb9947
 	github.com/evmos/ethermint => github.com/dymensionxyz/ethermint v0.22.0-dymension-v1.1.0-rc01.0.20250515141645-7f16f1928018
 	// use dymension forks
 	github.com/gogo/protobuf => github.com/regen-network/protobuf v1.3.3-alpha.regen.1

go.sum

@@ -460,8 +460,8 @@ github.com/dymensionxyz/ethermint v0.22.0-dymension-v1.1.0-rc01.0.20250515141645
 github.com/dymensionxyz/ethermint v0.22.0-dymension-v1.1.0-rc01.0.20250515141645-7f16f1928018/go.mod h1:eA60HVW0vtGMLV3Xp3FHLw7/d2w8MTtBv1YyGmlyulg=
 github.com/dymensionxyz/gerr-cosmos v1.1.0 h1:IW/P7HCB/iP9kgk3VXaWUoMoyx3vD76YO6p1fnubHVc=
 github.com/dymensionxyz/gerr-cosmos v1.1.0/go.mod h1:n+0olxPogzWqFKba45mCpvrHLGmeS8W9UZjggHnWk6c=
-github.com/dymensionxyz/hyperlane-cosmos v0.0.0-20250520112012-e15f3cfebc7b h1:swhhKl97Kw/xP3XK5s9yE7wJcHK20onXwohZn9UcwLE=
-github.com/dymensionxyz/hyperlane-cosmos v0.0.0-20250520112012-e15f3cfebc7b/go.mod h1:Fu7YLwOAUGpSsTxBH/KgGwoNlbGHwAUc3gg1jZ5Fnao=
+github.com/dymensionxyz/hyperlane-cosmos v0.0.0-20250604142341-c9b00acb9947 h1:ijADSaQvSIzMIv8msBb6lFps8cv/Ji1spDTY4wqB1s8=
+github.com/dymensionxyz/hyperlane-cosmos v0.0.0-20250604142341-c9b00acb9947/go.mod h1:A/rrrIGIEq8qfybJIvpcH31GdXBLdTLp5Ww5koc7PCw=
 github.com/dymensionxyz/osmosis/osmomath v0.0.6-dymension-v0.1.0.20250212133615-20c3718ed2f2 h1:/hXBQnPaH7gNvT37/br73OyaF55iq5TK8fcsvYcGcNg=
 github.com/dymensionxyz/osmosis/osmomath v0.0.6-dymension-v0.1.0.20250212133615-20c3718ed2f2/go.mod h1:uCJk9ysBsOONgfPmQVDCp5altrjTnFtPtPwpRP9AQeI=
 github.com/dymensionxyz/osmosis/v15 v15.2.1-0.20250518125211-85359101c419 h1:wMtODf2AcTxJiv4DRUMUGvU52ApPLX7c4eIJBqGVCUI=

proto/dymensionxyz/dymension/kas/d.proto

@@ -0,0 +1,43 @@
+syntax = "proto3";
+
+package dymensionxyz.dymension.kas;
+
+import "cosmos_proto/cosmos.proto";
+import "gogoproto/gogo.proto";
+
+option go_package = "github.com/dymensionxyz/dymension/v3/x/kas/types";
+
+// Kaspa transaction outpoint
+// https://github.com/kaspanet/rusty-kaspa/blob/1adeae8e5e2bdf7b65265420d294a356edc6d9e6/consensus/client/src/outpoint.rs#L91
+message TransactionOutpoint {
+  // 32 byte hash
+  bytes transaction_id = 1;
+  // pointer to the output in the transaction
+  uint32 index = 2;
+}
+
+// an index into a set of a dispatched Hyperlane withdrawal messages
+// see
+// https://github.com/dymensionxyz/hyperlane-cosmos/blob/5b73e596185ce009f7d9d412e26294c52e3108a8/x/core/keeper/query_server.go#L39
+// and
+// https://github.com/dymensionxyz/hyperlane-cosmos/blob/5b73e596185ce009f7d9d412e26294c52e3108a8/proto/hyperlane/core/v1/query.proto#L88-L92
+message WithdrawalID {
+  // in stringified hex address format
+  string message_id = 2;
+}
+
+enum WithdrawalStatus {
+  WITHDRAWAL_STATUS_UNSPECIFIED = 0;
+  WITHDRAWAL_STATUS_UNPROCESSED = 1;
+  WITHDRAWAL_STATUS_PROCESSED = 2;
+}
+
+// signed by validators to attest to successfully relayed withdrawals
+message ProgressIndication {
+  // current/'old' outpoint the validator sees on the hub
+  TransactionOutpoint old_outpoint = 1;
+  // new outpoint after processing withdrawals
+  TransactionOutpoint new_outpoint = 2;
+  // the processed withdrawals
+  repeated WithdrawalID processed_withdrawals = 3;
+}

proto/dymensionxyz/dymension/kas/events.proto

@@ -0,0 +1,13 @@
+syntax = "proto3";
+
+package dymensionxyz.dymension.kas;
+
+import "cosmos_proto/cosmos.proto";
+import "gogoproto/gogo.proto";
+import "dymensionxyz/dymension/kas/d.proto";
+
+option go_package = "github.com/dymensionxyz/dymension/v3/x/kas/types";
+
+message EventBootstrap {}
+
+message EventUpdate { ProgressIndication update = 1; }

proto/dymensionxyz/dymension/kas/genesis.proto

@@ -0,0 +1,14 @@
+syntax = "proto3";
+package dymensionxyz.dymension.kas;
+
+import "gogoproto/gogo.proto";
+import "dymensionxyz/dymension/kas/d.proto";
+option go_package = "github.com/dymensionxyz/dymension/v3/x/kas/types";
+
+message GenesisState {
+  bool bootstrapped = 1;
+  string mailbox = 2;
+  string ism = 3;
+  TransactionOutpoint outpoint = 4;
+  repeated WithdrawalID processed_withdrawals = 5;
+}

proto/dymensionxyz/dymension/kas/query.proto

@@ -0,0 +1,35 @@
+syntax = "proto3";
+package dymensionxyz.dymension.kas;
+
+import "gogoproto/gogo.proto";
+import "google/api/annotations.proto";
+import "cosmos/base/query/v1beta1/pagination.proto";
+import "dymensionxyz/dymension/kas/d.proto";
+
+option go_package = "github.com/dymensionxyz/dymension/v3/x/kas/types";
+
+service Query {
+
+  rpc WithdrawalStatus(QueryWithdrawalStatusRequest)
+      returns (QueryWithdrawalStatusResponse) {
+    option (google.api.http).get =
+        "/dymensionxyz/dymension/kas/withdrawal_status";
+  }
+
+  rpc Outpoint(QueryOutpointRequest) returns (QueryOutpointResponse) {
+    option (google.api.http).get = "/dymensionxyz/dymension/kas/outpoint";
+  }
+}
+
+message QueryWithdrawalStatusRequest {
+  repeated WithdrawalID withdrawal_id = 1;
+}
+
+message QueryWithdrawalStatusResponse {
+  repeated WithdrawalStatus status = 1;
+  TransactionOutpoint outpoint = 2;
+}
+
+message QueryOutpointRequest {}
+
+message QueryOutpointResponse { TransactionOutpoint outpoint = 1; }

proto/dymensionxyz/dymension/kas/tx.proto

@@ -0,0 +1,53 @@
+syntax = "proto3";
+package dymensionxyz.dymension.kas;
+
+option go_package = "github.com/dymensionxyz/dymension/v3/x/kas/types";
+
+import "google/protobuf/any.proto";
+import "cosmos_proto/cosmos.proto";
+import "gogoproto/gogo.proto";
+import "google/protobuf/timestamp.proto";
+import "cosmos/msg/v1/msg.proto";
+import "dymensionxyz/dymension/kas/d.proto";
+
+service Msg {
+  option (cosmos.msg.v1.service) = true;
+
+  rpc Bootstrap(MsgBootstrap) returns (MsgBootstrapResponse);
+
+  rpc IndicateProgress(MsgIndicateProgress)
+      returns (MsgIndicateProgressResponse);
+}
+
+message MsgBootstrap {
+  option (cosmos.msg.v1.signer) = "authority";
+
+  // Authority is the address that controls the module (defaults to x/gov unless
+  // overwritten).
+  string authority = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // the kaspa escrow mailbox
+  string mailbox = 2;
+
+  // the kaspa escrow ism
+  string ism = 3;
+
+  // the seed kaspa escrow outpoint
+  TransactionOutpoint outpoint = 4;
+}
+
+message MsgBootstrapResponse {}
+
+message MsgIndicateProgress {
+  option (cosmos.msg.v1.signer) = "signer";
+  string signer = 1 [ (cosmos_proto.scalar) = "cosmos.AddressString" ];
+
+  // sig verification info
+  // https://github.com/dymensionxyz/hyperlane-cosmos/blob/89bed40d16e362c92c12166aa0f86f3db42b3db7/x/core/01_interchain_security/types/message_id_multisig_raw.go#L48
+  bytes metadata = 2;
+
+  // what is signed by validators
+  ProgressIndication payload = 3;
+}
+
+message MsgIndicateProgressResponse {}

x/kas/client/cli/query.go

@@ -0,0 +1,22 @@
+package cli
+
+import (
+	"fmt"
+
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/spf13/cobra"
+
+	"github.com/dymensionxyz/dymension/v3/x/kas/types"
+)
+
+func GetQueryCmd() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:                        types.ModuleName,
+		Short:                      fmt.Sprintf("Querying commands for the %s module", types.ModuleName),
+		DisableFlagParsing:         true,
+		SuggestionsMinimumDistance: 2,
+		RunE:                       client.ValidateCmd,
+	}
+
+	return cmd
+}

x/kas/client/cli/tx.go

@@ -0,0 +1,22 @@
+package cli
+
+import (
+	"fmt"
+
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/spf13/cobra"
+
+	"github.com/dymensionxyz/dymension/v3/x/kas/types"
+)
+
+func GetTxCmd() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:                        types.ModuleName,
+		Short:                      fmt.Sprintf("%s transactions subcommands", types.ModuleName),
+		DisableFlagParsing:         true,
+		SuggestionsMinimumDistance: 2,
+		RunE:                       client.ValidateCmd,
+	}
+
+	return cmd
+}

x/kas/doc.go

@@ -0,0 +1,3 @@
+// Package kas does bookkeeping for the Kaspa<->Dymension Hyperlane-esque bridge.
+// https://www.notion.so/dymension/ADR-Kaspa-Bridge-Implementation-206a4a51f86a803980aec7099c826fb4
+package kas

x/kas/genesis_test.go

@@ -0,0 +1,8 @@
+package kas_test
+
+import (
+	"testing"
+)
+
+func TestInitGenesis(t *testing.T) {
+}