Added events in subscription and session endblock

sentinel-official · Jun 23, 2021 · ec4642b · ec4642b
1 parent b28d534
commit ec4642b
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/x/session/abci.go b/x/session/abci.go
@@ -29,6 +29,13 @@ func EndBlock(ctx sdk.Context, k keeper.Keeper) []abcitypes.ValidatorUpdate {
 			k.SetSession(ctx, item)
 			k.SetInactiveSessionForAddress(ctx, itemAddress, item.Id)
 			k.SetInactiveSessionAt(ctx, item.StatusAt.Add(inactiveDuration), item.Id)
+			ctx.EventManager().EmitTypedEvent(
+				&types.EventEndSession{
+					Id:           item.Id,
+					Subscription: item.Subscription,
+					Node:         item.Node,
+				},
+			)
 
 			return false
 		}

diff --git a/x/subscription/abci.go b/x/subscription/abci.go
@@ -33,6 +33,11 @@ func EndBlock(ctx sdk.Context, k keeper.Keeper) []abcitypes.ValidatorUpdate {
 
 			k.SetSubscription(ctx, item)
 			k.SetInactiveSubscriptionAt(ctx, item.StatusAt.Add(inactiveDuration), item.Id)
+			ctx.EventManager().EmitTypedEvent(
+				&types.EventCancelSubscription{
+					Id: item.Id,
+				},
+			)
 
 			return false
 		}