Puneet/epochevents (#2515)

* add events from cachectx to main ctx events * add tests for events from hooks. * add entry to CHANGELOG.md (cherry picked from commit 1b5e970) # Conflicts: # CHANGELOG.md
osmosis-labs · Aug 26, 2022 · 49a2b8e · 49a2b8e
1 parent 280c895
commit 49a2b8e
Show file tree

Hide file tree

Showing 3 changed files with 40 additions and 1 deletion.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -121,6 +121,19 @@ This release contains minor CLI bug fixes.
 * [1759](https://github.com/osmosis-labs/osmosis/pull/1759) Fix pagination filter in incentives query.
 * [1698](https://github.com/osmosis-labs/osmosis/pull/1698) Register wasm snapshotter extension.
 * [1931](https://github.com/osmosis-labs/osmosis/pull/1931) Add explicit check for input denoms to `CalcJoinPoolShares`
+<<<<<<< HEAD
+=======
+* [2011](https://github.com/osmosis-labs/osmosis/pull/2011) Fix bug in TokenFactory initGenesis, relating to denom creation fee param.
+* [2186](https://github.com/osmosis-labs/osmosis/pull/2186) Remove liquidity event that was emitted twice per message.
+
+### Improvements
+* [#2214](https://github.com/osmosis-labs/osmosis/pull/2214) Speedup epoch distribution, superfluid component
+* [#2515](https://github.com/osmosis-labs/osmosis/pull/2515) Emit events from functions implementing epoch hooks' `panicCatchingEpochHook` cacheCtx
+
+### SDK Upgrades
+* [#2245](https://github.com/osmosis-labs/osmosis/pull/2244) Upgrade SDK with the following major changes:
+   * Minimum deposit on proposer at submission time: https://github.com/osmosis-labs/cosmos-sdk/pull/296
+>>>>>>> 1b5e970c (Puneet/epochevents (#2515))
 
 ## [v9.0.0 - Nitrogen](https://github.com/osmosis-labs/osmosis/releases/tag/v9.0.0)
 

diff --git a/x/epochs/types/hooks.go b/x/epochs/types/hooks.go
@@ -50,4 +50,5 @@ func panicCatchingEpochHook(
 	cacheCtx, write := ctx.CacheContext()
 	hookFn(cacheCtx, epochIdentifier, epochNumber)
 	write()
+	ctx.EventManager().EmitEvents(cacheCtx.EventManager().Events())
 }
diff --git a/x/epochs/types/hooks_test.go b/x/epochs/types/hooks_test.go
@@ -1,6 +1,7 @@
 package types_test
 
 import (
+	"strconv"
 	"testing"
 
 	sdk "github.com/cosmos/cosmos-sdk/types"
@@ -26,6 +27,22 @@ func (suite *KeeperTestSuite) SetupTest() {
 	suite.queryClient = types.NewQueryClient(suite.QueryHelper)
 }
 
+func dummyAfterEpochEndEvent(epochIdentifier string, epochNumber int64) sdk.Event {
+	return sdk.NewEvent(
+		"afterEpochEnd",
+		sdk.NewAttribute("epochIdentifier", epochIdentifier),
+		sdk.NewAttribute("epochNumber", strconv.FormatInt(epochNumber, 10)),
+	)
+}
+
+func dummyBeforeEpochStartEvent(epochIdentifier string, epochNumber int64) sdk.Event {
+	return sdk.NewEvent(
+		"beforeEpochStart",
+		sdk.NewAttribute("epochIdentifier", epochIdentifier),
+		sdk.NewAttribute("epochNumber", strconv.FormatInt(epochNumber, 10)),
+	)
+}
+
 // dummyEpochHook is a struct satisfying the epoch hook interface,
 // that maintains a counter for how many times its been succesfully called,
 // and a boolean for whether it should panic during its execution.
@@ -39,13 +56,16 @@ func (hook *dummyEpochHook) AfterEpochEnd(ctx sdk.Context, epochIdentifier strin
 		panic("dummyEpochHook is panicking")
 	}
 	hook.successCounter += 1
+	ctx.EventManager().EmitEvent(dummyAfterEpochEndEvent(epochIdentifier, epochNumber))
 }
 
 func (hook *dummyEpochHook) BeforeEpochStart(ctx sdk.Context, epochIdentifier string, epochNumber int64) {
 	if hook.shouldPanic {
 		panic("dummyEpochHook is panicking")
 	}
 	hook.successCounter += 1
+	ctx.EventManager().EmitEvent(dummyBeforeEpochStartEvent(epochIdentifier, epochNumber))
+
 }
 
 func (hook *dummyEpochHook) Clone() *dummyEpochHook {
@@ -55,7 +75,7 @@ func (hook *dummyEpochHook) Clone() *dummyEpochHook {
 
 var _ types.EpochHooks = &dummyEpochHook{}
 
-func (suite *KeeperTestSuite) TestHooksPanicRecovery() {
+func (suite *KeeperTestSuite) TestHooksPanicRecoveryAndEvents() {
 	panicHook := dummyEpochHook{shouldPanic: true}
 	noPanicHook := dummyEpochHook{shouldPanic: false}
 	simpleHooks := []dummyEpochHook{panicHook, noPanicHook}
@@ -81,8 +101,13 @@ func (suite *KeeperTestSuite) TestHooksPanicRecovery() {
 			suite.NotPanics(func() {
 				if epochActionSelector == 0 {
 					hooks.BeforeEpochStart(suite.Ctx, "id", 0)
+					suite.Require().Equal(suite.Ctx.EventManager().Events(), sdk.Events{dummyBeforeEpochStartEvent("id", 0)},
+						"test case index %d, before epoch event check", tcIndex)
 				} else if epochActionSelector == 1 {
 					hooks.AfterEpochEnd(suite.Ctx, "id", 0)
+					suite.Require().Equal(suite.Ctx.EventManager().Events(), sdk.Events{dummyAfterEpochEndEvent("id", 0)},
+						"test case index %d, after epoch event check", tcIndex)
+
 				}
 			})