feat: add typed event for oracle post pices

CHANGELOG.md

@@ -58,6 +58,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 * [#1223](https://github.com/NibiruChain/nibiru/pull/1223) - chore(deps): bump github.com/golang/protobuf from 1.5.2 to 1.5.3
 * [#1205](https://github.com/NibiruChain/nibiru/pull/1205) - test: first testing framework skeleton and example
 * [#1228](https://github.com/NibiruChain/nibiru/pull/1228) - feat: update github.com/CosmWasm/wasmd 0.29.2
+* [#1244](https://github.com/NibiruChain/nibiru/pull/1244) - feat: add typed event for oracle post price
 * [#1237](https://github.com/NibiruChain/nibiru/pull/1237) - feat: reduce gas on openposition
 
 ### Bug Fixes

proto/oracle/v1beta1/event.proto

@@ -0,0 +1,18 @@
+syntax = "proto3";
+
+package nibiru.oracle.v1beta1;
+
+import "gogoproto/gogo.proto";
+import "google/api/annotations.proto";
+
+option go_package = "github.com/NibiruChain/nibiru/x/oracle/types";
+
+// Emitted when a price is posted
+message OraclePriceUpdate {
+  string pair = 1;
+  string price = 2 [
+      (gogoproto.customtype) = "github.com/cosmos/cosmos-sdk/types.Dec",
+      (gogoproto.nullable) = false
+  ];    
+  int64 timestamp_ms = 3;
+}

x/oracle/keeper/keeper.go

@@ -199,9 +199,17 @@ func (k Keeper) SetPrice(ctx sdk.Context, pair asset.Pair, price sdk.Dec) {
 	k.ExchangeRates.Insert(ctx, pair, price)
 
 	key := collections.Join(pair, ctx.BlockTime())
+	timestampMs := ctx.BlockTime().UnixMilli()
 	k.PriceSnapshots.Insert(ctx, key, types.PriceSnapshot{
 		Pair:        pair,
 		Price:       price,
-		TimestampMs: ctx.BlockTime().UnixMilli(),
+		TimestampMs: timestampMs,
 	})
+	if err := ctx.EventManager().EmitTypedEvent(&types.OraclePriceUpdate{
+		Pair:        pair.String(),
+		Price:       price,
+		TimestampMs: timestampMs,
+	}); err != nil {
+		ctx.Logger().Error("failed to emit OraclePriceUpdate", "pair", pair, "error", err)
+	}
 }

x/oracle/keeper/querier_test.go

@@ -9,6 +9,8 @@ import (
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	"github.com/stretchr/testify/require"
 
+	testutilevents "github.com/NibiruChain/nibiru/x/common/testutil"
+
 	"github.com/NibiruChain/nibiru/x/common/asset"
 	"github.com/NibiruChain/nibiru/x/common/denoms"
 	"github.com/NibiruChain/nibiru/x/oracle/types"
@@ -90,6 +92,14 @@ func TestQueryExchangeRateTwap(t *testing.T) {
 
 	rate := sdk.NewDec(1700)
 	input.OracleKeeper.SetPrice(input.Ctx, asset.Registry.Pair(denoms.BTC, denoms.NUSD), rate)
+	testutilevents.RequireContainsTypedEvent(
+		t,
+		input.Ctx,
+		&types.OraclePriceUpdate{
+			Pair:        asset.Registry.Pair(denoms.BTC, denoms.NUSD).String(),
+			Price:       rate,
+			TimestampMs: input.Ctx.BlockTime().UnixMilli()},
+	)
 
 	_, err := querier.ExchangeRateTwap(ctx, &types.QueryExchangeRateRequest{Pair: asset.Registry.Pair(denoms.ETH, denoms.NUSD)})
 	require.Error(t, err)