chore: add message.sender event

QuokkaStake · Feb 24, 2024 · 3b1aaf0 · 3b1aaf0
1 parent cb66d8a
commit 3b1aaf0
Show file tree

Hide file tree

Showing 16 changed files with 16 additions and 0 deletions.
diff --git a/pkg/messages/msg_acknowledgement.go b/pkg/messages/msg_acknowledgement.go
@@ -61,6 +61,7 @@ func (m *MsgAcknowledgement) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgAcknowledgement) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Signer.Value),
 	}
 }
 

diff --git a/pkg/messages/msg_begin_redelegate.go b/pkg/messages/msg_begin_redelegate.go
@@ -59,6 +59,7 @@ func (m *MsgBeginRedelegate) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgBeginRedelegate) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.DelegatorAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeRedelegate, cosmosStakingTypes.AttributeKeySrcValidator, m.ValidatorSrcAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeRedelegate, cosmosStakingTypes.AttributeKeyDstValidator, m.ValidatorDstAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeRedelegate, cosmosStakingTypes.AttributeKeyDelegator, m.DelegatorAddress.Value),

diff --git a/pkg/messages/msg_delegate.go b/pkg/messages/msg_delegate.go
@@ -55,6 +55,7 @@ func (m *MsgDelegate) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgDelegate) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.DelegatorAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeDelegate, cosmosStakingTypes.AttributeKeyValidator, m.ValidatorAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeDelegate, cosmosStakingTypes.AttributeKeyDelegator, m.DelegatorAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeDelegate, cosmosTypes.AttributeKeyAmount, m.Amount.String()),

diff --git a/pkg/messages/msg_exec.go b/pkg/messages/msg_exec.go
@@ -54,6 +54,7 @@ func (m *MsgExec) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgExec) GetValues() event.EventValues {
 	values := []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Grantee.Value),
 	}
 
 	return values

diff --git a/pkg/messages/msg_grant.go b/pkg/messages/msg_grant.go
@@ -111,6 +111,7 @@ func (m *MsgGrant) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgGrant) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Grantee.Value),
 	}
 }
 

diff --git a/pkg/messages/msg_recv_packet.go b/pkg/messages/msg_recv_packet.go
@@ -55,6 +55,7 @@ func (m *MsgRecvPacket) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgRecvPacket) GetValues() event.EventValues {
 	values := []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Signer.Value),
 	}
 
 	values = append(values, m.Packet.GetValues()...)

diff --git a/pkg/messages/msg_revoke.go b/pkg/messages/msg_revoke.go
@@ -52,6 +52,7 @@ func (m *MsgRevoke) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgRevoke) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Grantee.Value),
 	}
 }
 

diff --git a/pkg/messages/msg_send.go b/pkg/messages/msg_send.go
@@ -55,6 +55,7 @@ func (m *MsgSend) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgSend) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.From.Value),
 		event.From(cosmosBankTypes.EventTypeTransfer, cosmosTypes.AttributeKeySender, m.From.Value),
 		event.From(cosmosBankTypes.EventTypeTransfer, cosmosBankTypes.AttributeKeyRecipient, m.To.Value),
 		event.From(cosmosBankTypes.EventTypeCoinSpent, cosmosBankTypes.AttributeKeySpender, m.From.Value),

diff --git a/pkg/messages/msg_set_withdraw_address.go b/pkg/messages/msg_set_withdraw_address.go
@@ -49,6 +49,7 @@ func (m *MsgSetWithdrawAddress) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgSetWithdrawAddress) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.DelegatorAddress.Value),
 	}
 }
 

diff --git a/pkg/messages/msg_timeout.go b/pkg/messages/msg_timeout.go
@@ -55,6 +55,7 @@ func (m *MsgTimeout) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgTimeout) GetValues() event.EventValues {
 	values := []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Signer.Value),
 	}
 
 	values = append(values, m.Packet.GetValues()...)

diff --git a/pkg/messages/msg_transfer.go b/pkg/messages/msg_transfer.go
@@ -108,6 +108,7 @@ func (m *MsgTransfer) FetchRemoteChainData(fetcher types.DataFetcher) {
 func (m *MsgTransfer) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Sender.Value),
 		event.From(ibcTypes.EventTypeTransfer, ibcTypes.AttributeKeyReceiver, m.Receiver.Value),
 		event.From(ibcTypes.EventTypeTransfer, cosmosTypes.AttributeKeySender, m.Sender.Value),
 		event.From(ibcTypes.EventTypeTransfer, cosmosTypes.AttributeKeyAmount, m.Token.String()),

diff --git a/pkg/messages/msg_undelegate.go b/pkg/messages/msg_undelegate.go
@@ -61,6 +61,7 @@ func (m *MsgUndelegate) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgUndelegate) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.DelegatorAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeUnbond, cosmosStakingTypes.AttributeKeyValidator, m.ValidatorAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeUnbond, cosmosStakingTypes.AttributeKeyDelegator, m.DelegatorAddress.Value),
 		event.From(cosmosStakingTypes.EventTypeUnbond, cosmosTypes.AttributeKeyAmount, m.Amount.String()),

diff --git a/pkg/messages/msg_update_client.go b/pkg/messages/msg_update_client.go
@@ -45,6 +45,7 @@ func (m *MsgUpdateClient) GetAdditionalData(fetcher types.DataFetcher) {
 func (m *MsgUpdateClient) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Signer.Value),
 		event.From(ibcClientTypes.EventTypeUpdateClient, ibcClientTypes.AttributeKeyClientID, m.ClientID),
 	}
 }

diff --git a/pkg/messages/msg_vote.go b/pkg/messages/msg_vote.go
@@ -78,6 +78,7 @@ func (m *MsgVote) GetVote() string {
 func (m *MsgVote) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.Voter.Value),
 		event.From(cosmosGovEvents.EventTypeProposalVote, cosmosGovEvents.AttributeKeyProposalID, m.ProposalID.Value),
 		event.From(cosmosGovEvents.EventTypeProposalVote, cosmosGovEvents.AttributeKeyOption, m.Option.String()),
 	}

diff --git a/pkg/messages/msg_withdraw_delegator_reward.go b/pkg/messages/msg_withdraw_delegator_reward.go
@@ -69,6 +69,7 @@ func (m *MsgWithdrawDelegatorReward) GetAdditionalData(fetcher types.DataFetcher
 func (m *MsgWithdrawDelegatorReward) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeyAction, m.Type()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, m.DelegatorAddress.Value),
 		event.From(cosmosDistributionTypes.EventTypeWithdrawRewards, cosmosDistributionTypes.AttributeKeyValidator, m.ValidatorAddress.Value),
 		event.From(cosmosDistributionTypes.EventTypeWithdrawRewards, cosmosDistributionTypes.AttributeKeyDelegator, m.DelegatorAddress.Value),
 	}

diff --git a/pkg/messages/packet/fungible_token_packet.go b/pkg/messages/packet/fungible_token_packet.go
@@ -89,6 +89,7 @@ func (p *FungibleTokenPacket) GetValues() event.EventValues {
 	return []event.EventValue{
 		event.From(ibcTypes.EventTypePacket, cosmosBankTypes.AttributeKeyReceiver, p.Receiver.Value),
 		event.From(ibcTypes.EventTypePacket, cosmosTypes.AttributeKeyAmount, p.Token.Value.String()),
+		event.From(cosmosTypes.EventTypeMessage, cosmosTypes.AttributeKeySender, p.Sender.Value),
 	}
 }