[oracle] i64 -> [u8;8]

Author: canonbrother

lib/ain-ocean/src/api/prices.rs

@@ -195,12 +195,12 @@ async fn get_feed(
             let median_time = &q[..16];
             let height = &q[16..];
 
-            let median_time = median_time.parse::<i64>()?;
+            let median_time = median_time.parse::<i64>()?.to_be_bytes();
             let height = height.parse::<u32>()?.to_be_bytes();
-            Ok::<(i64, [u8; 4]), Error>((median_time, height))
+            Ok::<([u8; 8], [u8; 4]), Error>((median_time, height))
         })
         .transpose()?
-        .unwrap_or((i64::MAX, [0xffu8; 4]));
+        .unwrap_or(([0xffu8; 8], [0xffu8; 4]));
 
 
     let repo = &ctx.services.oracle_price_aggregated;
@@ -216,7 +216,7 @@ async fn get_feed(
         .map(|item| {
             let (k, v) = item?;
             let res = OraclePriceAggregatedResponse {
-                id: format!("{}-{}-{}", k.0, k.1, k.2),
+                id: format!("{}-{}-{}", k.0, k.1, i64::from_be_bytes(k.2)),
                 key: format!("{}-{}", k.0, k.1),
                 sort: format!(
                     "{}{}",

lib/ain-ocean/src/indexer/loan_token.rs

@@ -159,7 +159,7 @@ pub fn perform_active_price_tick(
     ticker_id: (Token, Currency),
     block: &BlockContext,
 ) -> Result<()> {
-    let id = (ticker_id.0.clone(), ticker_id.1.clone(), i64::MAX, [0xffu8; 4]);
+    let id = (ticker_id.0.clone(), ticker_id.1.clone(), [0xffu8; 8], [0xffu8; 4]);
 
     let prev = services
         .oracle_price_aggregated

lib/ain-ocean/src/indexer/oracle.rs

@@ -375,7 +375,7 @@ fn index_set_oracle_data(
         let id = (
             token.clone(),
             currency.clone(),
-            price_aggregated.block.median_time,
+            price_aggregated.block.median_time.to_be_bytes(),
             price_aggregated.block.height.to_be_bytes(),
         );
         oracle_repo.by_id.put(&id, &price_aggregated)?;
@@ -406,7 +406,7 @@ fn index_set_oracle_data_interval(
         let aggregated = services.oracle_price_aggregated.by_id.get(&(
             token.clone(),
             currency.clone(),
-            context.block.median_time,
+            context.block.median_time.to_be_bytes(),
             context.block.height.to_be_bytes(),
         ))?;
 
@@ -456,7 +456,7 @@ impl Index for SetOracleData {
             let id = (
                 token.clone(),
                 currency.clone(),
-                context.block.median_time,
+                context.block.median_time.to_be_bytes(),
                 context.block.height.to_be_bytes(),
             );
 

lib/ain-ocean/src/model/oracle_price_aggregated.rs

@@ -2,7 +2,7 @@ use serde::{Deserialize, Serialize};
 
 use super::{BlockContext, OraclePriceActiveNext};
 
-pub type OraclePriceAggregatedId = (String, String, i64, [u8; 4]); //token-currency-mediantime-height
+pub type OraclePriceAggregatedId = (String, String, [u8; 8], [u8; 4]); //token-currency-mediantime-height
 
 #[derive(Serialize, Deserialize, Debug, Clone)]
 #[serde(rename_all = "camelCase")]