update oracle invalidate function

DeFiCh · Jul 16, 2024 · df2a711 · df2a711
1 parent 051b569
commit df2a711
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/ain-ocean/src/indexer/oracle.rs b/lib/ain-ocean/src/indexer/oracle.rs
@@ -106,6 +106,7 @@ impl Index for AppointOracle {
             context.block.height,
             context.tx.txid,
         ))?;
+        services.oracle_history.by_key.delete(&(oracle_id))?;
         for currency_pair in self.price_feeds.as_ref().iter() {
             let token_currency_id = (
                 currency_pair.token.to_owned(),
@@ -204,6 +205,11 @@ impl Index for RemoveOracle {
                             .oracle_token_currency
                             .by_id
                             .put(&oracle_token_currency.id, &oracle_token_currency)?;
+
+                        services
+                            .oracle_token_currency
+                            .by_key
+                            .put(&oracle_token_currency.key, &oracle_token_currency.id)?;
                     }
                 }
             }