feat: reward messages event emission

x/reward/keeper/campaign_test.go

@@ -29,7 +29,7 @@ func createNCampaign(keeper *keeper.Keeper, ctx sdk.Context, n int) []types.Camp
 		items[i].StartTS = uint64(time.Now().Unix())
 		items[i].EndTS = uint64(time.Now().Add(5 * time.Minute).Unix())
 		items[i].RewardType = types.RewardType_REWARD_TYPE_REFERRAL
-		items[i].RewardDefs = []types.Definition{{
+		items[i].RewardDefs = types.Definitions{{
 			RecType:    types.ReceiverType_RECEIVER_TYPE_SINGLE,
 			RecAccType: types.ReceiverAccType_RECEIVER_ACC_TYPE_SUB,
 			Amount:     sdkmath.NewInt(100),

x/reward/keeper/msg_server_campaign.go

@@ -71,6 +71,8 @@ func (k msgServer) CreateCampaign(goCtx context.Context, msg *types.MsgCreateCam
 
 	k.SetCampaign(ctx, campaign)
 
+	msg.EmitEvent(&ctx, msg.Uid)
+
 	return &types.MsgCreateCampaignResponse{}, nil
 }
 
@@ -104,5 +106,7 @@ func (k msgServer) UpdateCampaign(goCtx context.Context, msg *types.MsgUpdateCam
 
 	k.SetCampaign(ctx, valFound)
 
+	msg.EmitEvent(&ctx, msg.Uid)
+
 	return &types.MsgUpdateCampaignResponse{}, nil
 }

x/reward/keeper/msg_server_reward.go

@@ -47,5 +47,7 @@ func (k msgServer) ApplyReward(goCtx context.Context, msg *types.MsgApplyReward)
 
 	k.UpdateCampaignPool(ctx, campaign, distribution)
 
+	msg.EmitEvent(&ctx, msg.CampaignUid, distribution)
+
 	return &types.MsgApplyRewardResponse{}, nil
 }

x/reward/types/campaign.go

@@ -9,7 +9,7 @@ func NewCampaign(
 	creator, funderAddres, uID string,
 	startTS, endTS uint64,
 	rewardType RewardType,
-	rewardDefs []Definition,
+	rewardDefs Definitions,
 	pool Pool,
 ) Campaign {
 	return Campaign{
@@ -48,7 +48,7 @@ func (c *Campaign) CheckExpiration(blockTime uint64) error {
 }
 
 // CheckPoolBalance checks if a pool balance of a capaign has enough fund to pay the rewards.
-func (c *Campaign) CheckPoolBalance(distributions []Distribution) error {
+func (c *Campaign) CheckPoolBalance(distributions Distributions) error {
 	totalAmount := sdkmath.ZeroInt()
 	for _, d := range distributions {
 		totalAmount.Add(d.Allocation.Amount)

x/reward/types/events.go

@@ -0,0 +1,8 @@
+package types
+
+const (
+	attributeValueCategory    = ModuleName
+	attributeKeyUID           = "uid"
+	attributeKeyCampaignUID   = "campaign_uid"
+	attributeKeyDistributions = "distributions"
+)

x/reward/types/messages_campaign.go

@@ -64,6 +64,15 @@ func (msg *MsgCreateCampaign) ValidateBasic() error {
 	return nil
 }
 
+// EmitEvent emits the event for the message success.
+func (msg *MsgCreateCampaign) EmitEvent(ctx *sdk.Context, uid string) {
+	emitter := utils.NewEventEmitter(ctx, attributeValueCategory)
+	emitter.AddMsg(TypeMsgCreateCampaign, msg.Creator,
+		sdk.NewAttribute(attributeKeyUID, uid),
+	)
+	emitter.Emit()
+}
+
 var _ sdk.Msg = &MsgUpdateCampaign{}
 
 func NewMsgUpdateCampaign(
@@ -115,3 +124,12 @@ func (msg *MsgUpdateCampaign) ValidateBasic() error {
 
 	return nil
 }
+
+// EmitEvent emits the event for the message success.
+func (msg *MsgUpdateCampaign) EmitEvent(ctx *sdk.Context, uid string) {
+	emitter := utils.NewEventEmitter(ctx, attributeValueCategory)
+	emitter.AddMsg(TypeMsgUpdateCampaign, msg.Creator,
+		sdk.NewAttribute(attributeKeyUID, uid),
+	)
+	emitter.Emit()
+}

x/reward/types/messages_reward.go

@@ -63,3 +63,13 @@ func (msg *MsgApplyReward) ValidateBasic() error {
 
 	return nil
 }
+
+// EmitEvent emits the event for the message success.
+func (msg *MsgApplyReward) EmitEvent(ctx *sdk.Context, campaignUID string, distributions Distributions) {
+	emitter := utils.NewEventEmitter(ctx, attributeValueCategory)
+	emitter.AddMsg(TypeMsgApplyReward, msg.Creator,
+		sdk.NewAttribute(attributeKeyCampaignUID, campaignUID),
+		sdk.NewAttribute(attributeKeyDistributions, distributions.String()),
+	)
+	emitter.Emit()
+}

x/reward/types/reward.go

@@ -6,9 +6,13 @@ import (
 	sdkerrors "cosmossdk.io/errors"
 	sdkmath "cosmossdk.io/math"
 	sdk "github.com/cosmos/cosmos-sdk/types"
+	yaml "gopkg.in/yaml.v2"
 )
 
-type Definitions []Definition
+type (
+	Definitions   []Definition
+	Distributions []Distribution
+)
 
 // RewardFactoryKeepers holds the keeper objectes usable by reward types methods.
 type RewardFactoryKeepers struct {
@@ -20,7 +24,7 @@ type RewardFactoryKeepers struct {
 type IRewardFactory interface {
 	VaidateDefinitions(campaign Campaign) error
 	CalculateDistributions(goCtx context.Context, ctx sdk.Context, keepers RewardFactoryKeepers,
-		definitions Definitions, ticket string) ([]Distribution, error)
+		definitions Definitions, ticket string) (Distributions, error)
 }
 
 // NewDistribution created new distribution object.
@@ -51,3 +55,11 @@ func (d *Definition) ValidateBasic(blockTime uint64) error {
 	}
 	return nil
 }
+
+func (ds Distributions) String() string {
+	out, err := yaml.Marshal(ds)
+	if err != nil {
+		panic(err)
+	}
+	return string(out)
+}

x/reward/types/reward_affiliate.go

@@ -30,7 +30,7 @@ func (afr AffiliationReward) VaidateDefinitions(campaign Campaign) error {
 // CalculateDistributions parses ticket payload and returns the distribution list of affiliation reward.
 func (afr AffiliationReward) CalculateDistributions(goCtx context.Context, ctx sdk.Context, keepers RewardFactoryKeepers,
 	definitions Definitions, ticket string,
-) ([]Distribution, error) {
+) (Distributions, error) {
 	var payload ApplyAffiliationRewardPayload
 	if err := keepers.OVMKeeper.VerifyTicketUnmarshal(goCtx, ticket, &payload); err != nil {
 		return nil, sdkerrors.Wrapf(ErrInTicketVerification, "%s", err)
@@ -42,7 +42,7 @@ func (afr AffiliationReward) CalculateDistributions(goCtx context.Context, ctx s
 		return nil, sdkerrors.Wrapf(ErrAccReceiverTypeNotFound, "%s", payload.Receiver.RecType)
 	}
 
-	return []Distribution{
+	return Distributions{
 		NewDistribution(
 			payload.Receiver.Addr,
 			NewAllocation(

x/reward/types/reward_noloss.go

@@ -32,7 +32,7 @@ func (afr NoLossBetsReward) VaidateDefinitions(campaign Campaign) error {
 // CalculateDistributions parses ticket payload and returns the distribution list of no loss bets reward.
 func (afr NoLossBetsReward) CalculateDistributions(goCtx context.Context, ctx sdk.Context, keepers RewardFactoryKeepers,
 	definitions Definitions, ticket string,
-) ([]Distribution, error) {
+) (Distributions, error) {
 	var payload ApplyNoLossBetsRewardPayload
 	if err := keepers.OVMKeeper.VerifyTicketUnmarshal(goCtx, ticket, &payload); err != nil {
 		return nil, sdkerrors.Wrapf(ErrInTicketVerification, "%s", err)
@@ -59,7 +59,7 @@ func (afr NoLossBetsReward) CalculateDistributions(goCtx context.Context, ctx sd
 		}
 	}
 
-	return []Distribution{
+	return Distributions{
 		NewDistribution(
 			payload.Receiver.Addr,
 			NewAllocation(

x/reward/types/reward_referral.go

@@ -40,13 +40,13 @@ func (rfr ReferralReward) VaidateDefinitions(campaign Campaign) error {
 // CalculateDistributions parses ticket payload and returns the distribution list of referral reward.
 func (rfr ReferralReward) CalculateDistributions(goCtx context.Context, ctx sdk.Context, keepers RewardFactoryKeepers,
 	definitions Definitions, ticket string,
-) ([]Distribution, error) {
+) (Distributions, error) {
 	var payload ApplyRerferralRewardPayload
 	if err := keepers.OVMKeeper.VerifyTicketUnmarshal(goCtx, ticket, &payload); err != nil {
 		return nil, sdkerrors.Wrapf(ErrInTicketVerification, "%s", err)
 	}
 
-	distributions := []Distribution{}
+	distributions := Distributions{}
 	for _, d := range definitions {
 		found := false
 		for _, r := range payload.Receivers {

x/reward/types/reward_signup.go

@@ -30,7 +30,7 @@ func (sur SignUpReward) VaidateDefinitions(campaign Campaign) error {
 // CalculateDistributions parses ticket payload and returns the distribution list of signup reward.
 func (sur SignUpReward) CalculateDistributions(goCtx context.Context, ctx sdk.Context, keepers RewardFactoryKeepers,
 	definitions Definitions, ticket string,
-) ([]Distribution, error) {
+) (Distributions, error) {
 	var payload ApplySignupRewardPayload
 	if err := keepers.OVMKeeper.VerifyTicketUnmarshal(goCtx, ticket, &payload); err != nil {
 		return nil, sdkerrors.Wrapf(ErrInTicketVerification, "%s", err)
@@ -42,7 +42,7 @@ func (sur SignUpReward) CalculateDistributions(goCtx context.Context, ctx sdk.Co
 		return nil, sdkerrors.Wrapf(ErrAccReceiverTypeNotFound, "%s", payload.Receiver.RecType)
 	}
 
-	return []Distribution{
+	return Distributions{
 		NewDistribution(
 			payload.Receiver.Addr,
 			NewAllocation(