|
|
@ -21,6 +21,7 @@ async fn fetch_candles_until_now( |
|
|
|
let mut result = vec![]; |
|
|
|
let mut result = vec![]; |
|
|
|
|
|
|
|
|
|
|
|
loop { |
|
|
|
loop { |
|
|
|
|
|
|
|
println!("pulling candles from {start_time}"); |
|
|
|
let candles = poloniex_client |
|
|
|
let candles = poloniex_client |
|
|
|
.get_historical_candles(pair, interval, start_time, Utc::now().naive_utc()) |
|
|
|
.get_historical_candles(pair, interval, start_time, Utc::now().naive_utc()) |
|
|
|
.await?; |
|
|
|
.await?; |
|
|
@ -33,7 +34,6 @@ async fn fetch_candles_until_now( |
|
|
|
let last_candle_ts = last_candle.ts.and_utc().timestamp(); |
|
|
|
let last_candle_ts = last_candle.ts.and_utc().timestamp(); |
|
|
|
let now = Utc::now().timestamp(); |
|
|
|
let now = Utc::now().timestamp(); |
|
|
|
|
|
|
|
|
|
|
|
dbg!(last_candle_ts, now); |
|
|
|
|
|
|
|
if last_candle_ts < now { |
|
|
|
if last_candle_ts < now { |
|
|
|
// если какие-то свечки недополучили из-за лимитов,
|
|
|
|
// если какие-то свечки недополучили из-за лимитов,
|
|
|
|
// смещаем запрашиваемый временной отрезок вправо
|
|
|
|
// смещаем запрашиваемый временной отрезок вправо
|
|
|
|