feat(nexus): gmp events metadata

axelarnetwork · Sep 26, 2024 · 359710c · 359710c
1 parent 2c52c94
commit 359710c
Show file tree

Hide file tree

Showing 4 changed files with 407 additions and 58 deletions.
diff --git a/docs/proto/proto-docs.md b/docs/proto/proto-docs.md
diff --git a/proto/axelar/nexus/v1beta1/events.proto b/proto/axelar/nexus/v1beta1/events.proto
@@ -53,13 +53,37 @@ message MessageReceived {
       [ (gogoproto.nullable) = false ];
   exported.v1beta1.CrossChainAddress recipient = 4
       [ (gogoproto.nullable) = false ];
+  string source_chain = 5
+  [ (gogoproto.casttype) =
+      "github.com/axelarnetwork/axelar-core/x/nexus/exported.ChainName" ];
+  string destination_chain = 6
+  [ (gogoproto.casttype) =
+      "github.com/axelarnetwork/axelar-core/x/nexus/exported.ChainName" ];
 }
 
-message MessageProcessing { string id = 1 [ (gogoproto.customname) = "ID" ]; }
+message MessageProcessing {
+  string id = 1 [ (gogoproto.customname) = "ID" ];
+}
 
-message MessageExecuted { string id = 1 [ (gogoproto.customname) = "ID" ]; }
+message MessageExecuted {
+  string id = 1 [ (gogoproto.customname) = "ID" ];
+  string source_chain = 2
+  [ (gogoproto.casttype) =
+      "github.com/axelarnetwork/axelar-core/x/nexus/exported.ChainName" ];
+  string destination_chain = 3
+  [ (gogoproto.casttype) =
+      "github.com/axelarnetwork/axelar-core/x/nexus/exported.ChainName" ];
+}
 
-message MessageFailed { string id = 1 [ (gogoproto.customname) = "ID" ]; }
+message MessageFailed {
+  string id = 1 [ (gogoproto.customname) = "ID" ];
+  string source_chain = 2
+  [ (gogoproto.casttype) =
+      "github.com/axelarnetwork/axelar-core/x/nexus/exported.ChainName" ];
+  string destination_chain = 3
+  [ (gogoproto.casttype) =
+      "github.com/axelarnetwork/axelar-core/x/nexus/exported.ChainName" ];
+}
 
 message WasmMessageRouted {
   exported.v1beta1.WasmMessage message = 1 [ (gogoproto.nullable) = false ];

diff --git a/x/nexus/keeper/general_message.go b/x/nexus/keeper/general_message.go
@@ -51,7 +51,11 @@ func (k Keeper) SetMessageExecuted(ctx sdk.Context, id string) error {
 
 	m.Status = exported.Executed
 
-	funcs.MustNoErr(ctx.EventManager().EmitTypedEvent(&types.MessageExecuted{ID: m.ID}))
+	funcs.MustNoErr(ctx.EventManager().EmitTypedEvent(&types.MessageExecuted{
+		ID:               m.ID,
+		SourceChain:      m.GetSourceChain(),
+		DestinationChain: m.GetDestinationChain(),
+	}))
 
 	return k.setMessage(ctx, m)
 }
@@ -71,7 +75,11 @@ func (k Keeper) SetMessageFailed(ctx sdk.Context, id string) error {
 
 	m.Status = exported.Failed
 
-	funcs.MustNoErr(ctx.EventManager().EmitTypedEvent(&types.MessageFailed{ID: m.ID}))
+	funcs.MustNoErr(ctx.EventManager().EmitTypedEvent(&types.MessageFailed{
+		ID:               m.ID,
+		SourceChain:      m.GetSourceChain(),
+		DestinationChain: m.GetDestinationChain(),
+	}))
 
 	return k.setMessage(ctx, m)
 }
@@ -149,10 +157,12 @@ func (k Keeper) SetNewMessage(ctx sdk.Context, msg exported.GeneralMessage) erro
 	}
 
 	funcs.MustNoErr(ctx.EventManager().EmitTypedEvent(&types.MessageReceived{
-		ID:          msg.ID,
-		PayloadHash: msg.PayloadHash,
-		Sender:      msg.Sender,
-		Recipient:   msg.Recipient,
+		ID:               msg.ID,
+		PayloadHash:      msg.PayloadHash,
+		Sender:           msg.Sender,
+		Recipient:        msg.Recipient,
+		SourceChain:      msg.GetSourceChain(),
+		DestinationChain: msg.GetDestinationChain(),
 	}))
 
 	return k.setMessage(ctx, msg)