Merge pull request #528 from limxiy/feat/utilities-time-formatters-conversion

Add timestamp helpers, fee formatting, conversion functions, and recommendation types (#379, #377, #376, #296)

Author: Tinna23

packages/core/src/recommendation/types.rs

@@ -70,3 +70,6 @@ pub struct RecommendHistoryResponse {
     pub entries: Vec<RecommendHistoryEntry>,
 }
 
+pub type RecommendationRequest = RecommendRequest;
+pub type RecommendationResponse = RecommendResponse;
+

packages/devkit/Cargo.toml

@@ -18,9 +18,11 @@ tokio = { version = "1", features = ["rt-multi-thread", "macros"] }
 
 [dev-dependencies]
 criterion = { version = "0.5", features = ["html_reports"] }
+tempfile = "3"
 tokio-test = "0.4"
 tracing = "0.1"
 tracing-subscriber = "0.3"
+uuid = { version = "1", features = ["v4"] }
 
 [[bench]]
 name = "fee_model_bench"

packages/devkit/src/utilities/converters.rs

@@ -29,3 +29,11 @@ impl std::fmt::Display for ConversionError {
 }
 
 impl std::error::Error for ConversionError {}
+
+pub fn stroops_to_xlm(stroops: u64) -> f64 {
+    stroop_to_xlm(stroops)
+}
+
+pub fn xlm_to_stroops(xlm: f64) -> Result<u64, ConversionError> {
+    xlm_to_stroop(xlm)
+}

packages/devkit/src/utilities/formatters.rs

@@ -0,0 +1,53 @@
+/// Format fee value in stroops with comma separators
+pub fn format_stroops(n: u64) -> String {
+    let s = n.to_string();
+    let mut result = String::new();
+    for (i, c) in s.chars().rev().enumerate() {
+        if i > 0 && i % 3 == 0 {
+            result.push(',');
+        }
+        result.push(c);
+    }
+    result.chars().rev().collect::<String>() + " str"
+}
+
+/// Format fee value as XLM (1 XLM = 10,000,000 stroops)
+pub fn format_xlm(n: u64) -> String {
+    let xlm = n as f64 / 10_000_000.0;
+    format!("{:.7} XLM", xlm)
+}
+
+/// Auto-format: show stroops below 1M, XLM above
+pub fn format_fee_short(n: u64) -> String {
+    if n < 1_000_000 {
+        format_stroops(n)
+    } else {
+        format_xlm(n)
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_format_stroops() {
+        assert_eq!(format_stroops(0), "0 str");
+        assert_eq!(format_stroops(100), "100 str");
+        assert_eq!(format_stroops(3849), "3,849 str");
+        assert_eq!(format_stroops(1000000), "1,000,000 str");
+    }
+
+    #[test]
+    fn test_format_xlm() {
+        assert_eq!(format_xlm(0), "0.0000000 XLM");
+        assert_eq!(format_xlm(10_000_000), "1.0000000 XLM");
+        assert_eq!(format_xlm(3849), "0.0003849 XLM");
+    }
+
+    #[test]
+    fn test_format_fee_short() {
+        assert_eq!(format_fee_short(3849), "3,849 str");
+        assert_eq!(format_fee_short(10_000_000), "1.0000000 XLM");
+    }
+}

packages/devkit/src/utilities/mod.rs

@@ -1,6 +1,7 @@
 pub mod csv_reader;
 pub mod json_reader;
-//! Shared utility helpers used by CLI subcommands.
-
+/// Shared utility helpers used by CLI subcommands.
 pub mod comparator;
+pub mod formatters;
 pub mod percentile_table;
+pub mod time;

packages/devkit/src/utilities/time.rs

@@ -1,5 +1,7 @@
 use std::time::Duration;
 
+use chrono::{DateTime, Utc};
+
 #[derive(Debug, Clone, PartialEq, Eq)]
 pub struct ParseError(pub String);
 
@@ -32,6 +34,25 @@ pub fn parse_window(s: &str) -> Result<Duration, ParseError> {
     }
 }
 
+pub fn now_unix_ms() -> u64 {
+    std::time::SystemTime::now()
+        .duration_since(std::time::UNIX_EPOCH)
+        .unwrap()
+        .as_millis() as u64
+}
+
+pub fn unix_ms_to_datetime(ms: u64) -> DateTime<Utc> {
+    DateTime::from_timestamp_millis(ms as i64).unwrap_or_default()
+}
+
+pub fn datetime_to_unix_ms(dt: &DateTime<Utc>) -> u64 {
+    dt.timestamp_millis() as u64
+}
+
+pub fn ledger_close_time_to_unix_ms(close_time: u64) -> u64 {
+    close_time * 1000
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;