add more events to PriceAggregator

multiversx · Oct 4, 2024 · 8a11626 · 8a11626
1 parent 190f26f
commit 8a11626
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 1 deletion.
diff --git a/contracts/core/price-aggregator/src/events.rs b/contracts/core/price-aggregator/src/events.rs
@@ -43,4 +43,20 @@ pub trait EventsModule {
         #[indexed] epoch: u64,
         new_round_event: &NewRoundEvent<Self::Api>,
     );
+
+    #[event("discard_round")]
+    fn discard_round_event(
+        &self,
+        #[indexed] from: &ManagedBuffer,
+        #[indexed] to: &ManagedBuffer,
+        #[indexed] epoch: u64,
+    );
+
+    #[event("add_submission")]
+    fn add_submission_event(
+        &self,
+        #[indexed] caller: &ManagedAddress,
+        #[indexed] price: &BigUint,
+        #[indexed] epoch: u64,
+    );
 }
diff --git a/contracts/core/price-aggregator/src/lib.rs b/contracts/core/price-aggregator/src/lib.rs
@@ -183,10 +183,12 @@ pub trait PriceAggregator:
         let accepted = !submissions.contains_key(&caller)
             && (is_first_submission || submission_timestamp >= first_submission_timestamp);
         if accepted {
-            submissions.insert(caller, price);
+            submissions.insert(caller.clone(), price.clone());
             last_sub_time_mapper.set(current_timestamp);
 
             self.create_new_round(token_pair, submissions, decimals);
+            let epoch = self.blockchain().get_block_epoch();
+            self.add_submission_event(&caller, &price, epoch);
         }
 
         self.oracle_status()
@@ -282,6 +284,9 @@ pub trait PriceAggregator:
                 .get()
                 .push(&price_feed);
             self.emit_new_round_event(&token_pair, &price_feed);
+        } else {
+            let epoch = self.blockchain().get_block_epoch();
+            self.discard_round_event(&token_pair.from.clone(), &token_pair.to.clone(), epoch);
         }
     }