add event

zeta-chain · Feb 2, 2024 · 7c2084b · 7c2084b
1 parent 14acf5d
commit 7c2084b
Show file tree

Hide file tree

Showing 4 changed files with 366 additions and 43 deletions.
diff --git a/proto/crosschain/events.proto b/proto/crosschain/events.proto
@@ -58,3 +58,9 @@ message EventOutboundSuccess {
   string new_status = 4;
   string value_received = 5;
 }
+
+message EventCCTXGasPriceIncreased {
+  string cctx_index = 1;
+  string gas_price_increase = 2;
+  string additional_fees = 3;
+}
diff --git a/typescript/crosschain/events_pb.d.ts b/typescript/crosschain/events_pb.d.ts
@@ -291,3 +291,37 @@ export declare class EventOutboundSuccess extends Message<EventOutboundSuccess>
   static equals(a: EventOutboundSuccess | PlainMessage<EventOutboundSuccess> | undefined, b: EventOutboundSuccess | PlainMessage<EventOutboundSuccess> | undefined): boolean;
 }
 
+/**
+ * @generated from message zetachain.zetacore.crosschain.EventCCTXGasPriceIncreased
+ */
+export declare class EventCCTXGasPriceIncreased extends Message<EventCCTXGasPriceIncreased> {
+  /**
+   * @generated from field: string cctx_index = 1;
+   */
+  cctxIndex: string;
+
+  /**
+   * @generated from field: string gas_price_increase = 2;
+   */
+  gasPriceIncrease: string;
+
+  /**
+   * @generated from field: string additional_fees = 3;
+   */
+  additionalFees: string;
+
+  constructor(data?: PartialMessage<EventCCTXGasPriceIncreased>);
+
+  static readonly runtime: typeof proto3;
+  static readonly typeName = "zetachain.zetacore.crosschain.EventCCTXGasPriceIncreased";
+  static readonly fields: FieldList;
+
+  static fromBinary(bytes: Uint8Array, options?: Partial<BinaryReadOptions>): EventCCTXGasPriceIncreased;
+
+  static fromJson(jsonValue: JsonValue, options?: Partial<JsonReadOptions>): EventCCTXGasPriceIncreased;
+
+  static fromJsonString(jsonString: string, options?: Partial<JsonReadOptions>): EventCCTXGasPriceIncreased;
+
+  static equals(a: EventCCTXGasPriceIncreased | PlainMessage<EventCCTXGasPriceIncreased> | undefined, b: EventCCTXGasPriceIncreased | PlainMessage<EventCCTXGasPriceIncreased> | undefined): boolean;
+}
+
diff --git a/x/crosschain/keeper/abci.go b/x/crosschain/keeper/abci.go
@@ -75,11 +75,18 @@ IterateChains:
 						continue IterateChains
 					}
 					if !gasPriceIncrease.IsNil() && !gasPriceIncrease.IsZero() {
-						ctx.Logger().Info("GasStabilityPool: updated gas price for pending cctx",
-							"cctxIndex", pendingCctx.Index,
-							"gasPriceIncrease", gasPriceIncrease.String(),
-							"additionalFees", additionalFees.String(),
-						)
+						// Emit typed event for gas price increase
+						if err := ctx.EventManager().EmitTypedEvent(
+							&types.EventCCTXGasPriceIncreased{
+								CctxIndex:        pendingCctx.Index,
+								GasPriceIncrease: gasPriceIncrease.String(),
+								AdditionalFees:   additionalFees.String(),
+							}); err != nil {
+							ctx.Logger().Error(
+								"GasStabilityPool: failed to emit EventCCTXGasPriceIncreased",
+								"err", err.Error(),
+							)
+						}
 						cctxCount++
 					}
 				}