refactor: update timestamp() to timestamp_ns()

Signed-off-by: Gustavo Inacio <[email protected]>

Author: gusinacio

tap_core/src/manager/adapters/receipt.rs

@@ -113,19 +113,19 @@ pub fn safe_truncate_receipts<T: ReceiptState, R: WithValueAndTimestamp>(
         return;
     }
 
-    receipts.sort_unstable_by_key(|rx_receipt| rx_receipt.signed_receipt().timestamp());
+    receipts.sort_unstable_by_key(|rx_receipt| rx_receipt.signed_receipt().timestamp_ns());
 
     // This one will be the last timestamp in `receipts` after naive truncation
-    let last_timestamp = receipts[limit as usize - 1].signed_receipt().timestamp();
+    let last_timestamp = receipts[limit as usize - 1].signed_receipt().timestamp_ns();
     // This one is the timestamp that comes just after the one above
-    let after_last_timestamp = receipts[limit as usize].signed_receipt().timestamp();
+    let after_last_timestamp = receipts[limit as usize].signed_receipt().timestamp_ns();
 
     receipts.truncate(limit as usize);
 
     if last_timestamp == after_last_timestamp {
         // If the last timestamp is the same as the one that came after it, we need to
         // remove all the receipts with the same timestamp as the last one, because
         // otherwise we would leave behind part of the receipts for that timestamp.
-        receipts.retain(|rx_receipt| rx_receipt.signed_receipt().timestamp() != last_timestamp);
+        receipts.retain(|rx_receipt| rx_receipt.signed_receipt().timestamp_ns() != last_timestamp);
     }
 }

tap_core/src/manager/mod.rs

@@ -92,7 +92,7 @@ pub use tap_manager::Manager;
 
 pub trait WithValueAndTimestamp {
     fn value(&self) -> u128;
-    fn timestamp(&self) -> u64;
+    fn timestamp_ns(&self) -> u64;
 }
 
 pub trait WithUniqueId {

tap_core/src/manager/tap_manager.rs

@@ -202,7 +202,7 @@ where
         let previous_rav = self.get_previous_rav().await?;
         let min_timestamp_ns = previous_rav
             .as_ref()
-            .map(|rav| rav.message.timestamp() + 1)
+            .map(|rav| rav.message.timestamp_ns() + 1)
             .unwrap_or(0);
 
         let (valid_receipts, invalid_receipts) = self
@@ -239,7 +239,7 @@ where
         match self.get_previous_rav().await? {
             Some(last_rav) => {
                 self.context
-                    .remove_receipts_in_timestamp_range(..=last_rav.message.timestamp())
+                    .remove_receipts_in_timestamp_range(..=last_rav.message.timestamp_ns())
                     .await
                     .map_err(|err| Error::AdapterError {
                         source_error: anyhow::Error::new(err),

tap_core/src/rav.rs

@@ -93,7 +93,7 @@ impl WithValueAndTimestamp for ReceiptAggregateVoucher {
         self.valueAggregate
     }
 
-    fn timestamp(&self) -> u64 {
+    fn timestamp_ns(&self) -> u64 {
         self.timestampNs
     }
 }

tap_core/src/receipt/checks.rs

@@ -162,7 +162,7 @@ where
     ) {
         let (mut checking, mut failed) = (vec![], vec![]);
         for receipt in receipts.into_iter() {
-            let receipt_timestamp_ns = receipt.signed_receipt().timestamp();
+            let receipt_timestamp_ns = receipt.signed_receipt().timestamp_ns();
             let min_timestamp_ns = self.0;
             if receipt_timestamp_ns >= min_timestamp_ns {
                 checking.push(receipt);

tap_core/src/receipt/receipt_sol.rs

@@ -35,7 +35,7 @@ impl WithValueAndTimestamp for Receipt {
         self.value
     }
 
-    fn timestamp(&self) -> u64 {
+    fn timestamp_ns(&self) -> u64 {
         self.timestamp_ns
     }
 }

tap_core/src/signed_message.rs

@@ -55,8 +55,8 @@ where
         self.message.value()
     }
 
-    fn timestamp(&self) -> u64 {
-        self.message.timestamp()
+    fn timestamp_ns(&self) -> u64 {
+        self.message.timestamp_ns()
     }
 }