|
@@ -1,5 +1,6 @@
|
|
|
#[macro_use]
|
|
#[macro_use]
|
|
|
extern crate serde_derive;
|
|
extern crate serde_derive;
|
|
|
|
|
+use core::cmp::Ordering::Equal;
|
|
|
use reqwest;
|
|
use reqwest;
|
|
|
use chrono::{Utc, Duration, Local, DateTime};
|
|
use chrono::{Utc, Duration, Local, DateTime};
|
|
|
use select::document::Document;
|
|
use select::document::Document;
|
|
@@ -221,7 +222,7 @@ fn parse_url(url: &str) -> Vec<Auction> {
|
|
|
fn daemon(queries: Vec<Query>) {
|
|
fn daemon(queries: Vec<Query>) {
|
|
|
|
|
|
|
|
|
|
|
|
|
- println!("Starting daemon with {}", queries.len());
|
|
|
|
|
|
|
+ println!("Starting daemon with {} active queries", queries.len());
|
|
|
loop {
|
|
loop {
|
|
|
let mut auctions = vec![];
|
|
let mut auctions = vec![];
|
|
|
for mut query in queries.clone() {
|
|
for mut query in queries.clone() {
|
|
@@ -230,6 +231,9 @@ fn daemon(queries: Vec<Query>) {
|
|
|
}
|
|
}
|
|
|
println!("{} auctions found", auctions.len());
|
|
println!("{} auctions found", auctions.len());
|
|
|
let writer = BufWriter::new(File::create("db.json").unwrap());
|
|
let writer = BufWriter::new(File::create("db.json").unwrap());
|
|
|
|
|
+
|
|
|
|
|
+ auctions.sort_by_key(|k| k.remaining);
|
|
|
|
|
+
|
|
|
serde_json::to_writer_pretty(writer, &auctions).unwrap();
|
|
serde_json::to_writer_pretty(writer, &auctions).unwrap();
|
|
|
let pause = time::Duration::from_secs(300);
|
|
let pause = time::Duration::from_secs(300);
|
|
|
thread::sleep(pause);
|
|
thread::sleep(pause);
|