|
1 | 1 | use chrono::{Duration, Utc}; |
2 | 2 | use hyperliquid_backtest::prelude::*; |
3 | | -use rs_backtester::prelude::*; |
4 | 3 | use std::fs::File; |
5 | 4 | use std::io::Write; |
6 | 5 | use std::collections::HashMap; |
@@ -48,18 +47,23 @@ async fn main() -> Result<()> { |
48 | 47 | let mut asset_data = HashMap::new(); |
49 | 48 |
|
50 | 49 | // Fetch historical data for all assets |
51 | | - let end_time = Utc::now().timestamp() as u64; |
52 | | - let start_time = end_time - (120 * 24 * 3600); // 120 days of data |
| 50 | + let end_time = Utc::now(); |
| 51 | + let start_time = end_time - Duration::days(30); |
| 52 | + let start_timestamp = start_time.timestamp_millis() as u64; |
| 53 | + let end_timestamp = end_time.timestamp_millis() as u64; |
| 54 | + |
| 55 | + println!("Time range debug:"); |
| 56 | + println!(" Current time: {}", end_time); |
| 57 | + println!(" Start time: {}", start_time); |
| 58 | + println!(" Start timestamp: {}", start_timestamp); |
| 59 | + println!(" End timestamp: {}", end_timestamp); |
| 60 | + println!(); |
53 | 61 |
|
54 | 62 | println!("Fetching historical data for {} assets...", assets.len()); |
55 | 63 |
|
56 | 64 | for asset in &assets { |
57 | 65 | println!("Fetching {} data...", asset); |
58 | | - let data = match asset { |
59 | | - &"BTC" => HyperliquidData::fetch_btc("1h", start_time, end_time).await?, |
60 | | - &"ETH" => HyperliquidData::fetch_eth("1h", start_time, end_time).await?, |
61 | | - _ => HyperliquidData::fetch(asset, "1h", start_time, end_time).await?, |
62 | | - }; |
| 66 | + let data = HyperliquidData::fetch(asset, "1h", start_timestamp, end_timestamp).await?; |
63 | 67 |
|
64 | 68 | println!(" {} data points fetched", data.len()); |
65 | 69 | asset_data.insert(asset.to_string(), data); |
|
0 commit comments