feat(x/emissions): emit req/cancel stake removal events

Author: amimart

x/emissions/api/emissions/v9/events.pulsar.go

@@ -127,6 +127,8 @@ func (ms msgServer) RemoveStake(ctx context.Context, msg *types.RemoveStakeReque
 		return nil, errorsmod.Wrap(err, "failed to set stake removal")
 	}
 
+	types.EmitNewRequestStakeRemovalEvent(ctx, msg.TopicId, msg.Sender, msg.Sender, msg.Amount, stakeToRemove.BlockRemovalCompleted)
+
 	return &types.RemoveStakeResponse{}, nil
 }
 
@@ -161,6 +163,8 @@ func (ms msgServer) CancelRemoveStake(ctx context.Context, msg *types.CancelRemo
 		return nil, errorsmod.Wrap(err, "failed to delete previous stake removal")
 	}
 
+	types.EmitNewCancelStakeRemovalEvent(ctx, msg.TopicId, msg.Sender, msg.Sender, removal.Amount)
+
 	return &types.CancelRemoveStakeResponse{}, nil
 }
 
@@ -282,6 +286,8 @@ func (ms msgServer) RemoveDelegateStake(ctx context.Context, msg *types.RemoveDe
 		return nil, errorsmod.Wrap(err, "failed to set delegate stake removal")
 	}
 
+	types.EmitNewRequestStakeRemovalEvent(ctx, msg.TopicId, msg.Reputer, msg.Sender, msg.Amount, stakeToRemove.BlockRemovalCompleted)
+
 	return &types.RemoveDelegateStakeResponse{}, nil
 }
 
@@ -324,6 +330,8 @@ func (ms msgServer) CancelRemoveDelegateStake(ctx context.Context, msg *types.Ca
 		return nil, errorsmod.Wrap(err, "failed to delete previous delegate stake removal")
 	}
 
+	types.EmitNewCancelStakeRemovalEvent(ctx, msg.TopicId, msg.Reputer, msg.Sender, removal.Amount)
+
 	return &types.CancelRemoveDelegateStakeResponse{}, err
 }
 

x/emissions/keeper/msgserver/msg_server_stake.go

@@ -76,4 +76,6 @@ const (
 	PRUNE_RECORDS_EVENT                                     = "prune_records_event"
 	REPUTER_STAKE_REMOVAL_EVENT                             = "reputer_stake_removal_event"
 	DELEGATE_STAKE_REMOVAL_EVENT                            = "delegate_stake_removal_event"
+	REQUEST_STAKE_REMOVAL_EVENT                             = "request_stake_removal_event"
+	CANCEL_STAKE_REMOVAL_EVENT                              = "cancel_stake_removal_event"
 )

x/emissions/metrics/labels.go

@@ -171,6 +171,31 @@ message EventRemoveStake {
   ];
 }
 
+message EventRequestStakeRemoval {
+  uint64 topic_id = 1;
+  string reputer = 2;
+  string delegator = 3;
+  string amount = 4 [
+    (cosmos_proto.scalar) = "cosmos.Int",
+    (gogoproto.customtype) = "cosmossdk.io/math.Int",
+    (gogoproto.nullable) = false,
+    (amino.dont_omitempty) = true
+  ];
+  int64 completion_height = 5;
+}
+
+message EventCancelStakeRemoval {
+  uint64 topic_id = 1;
+  string reputer = 2;
+  string delegator = 3;
+  string amount = 4 [
+    (cosmos_proto.scalar) = "cosmos.Int",
+    (gogoproto.customtype) = "cosmossdk.io/math.Int",
+    (gogoproto.nullable) = false,
+    (amino.dont_omitempty) = true
+  ];
+}
+
 // EventReputerStakeUpdated is an event derived from the primitive ones EventAddStake and EventRemoveStake.
 // It only expresses a change in the total stake of a reputer for a topic.
 //