main: connect jabber after loading data
This commit is contained in:
parent
ce25726600
commit
61bf30b4dd
|
@ -19,6 +19,10 @@ impl std::error::Error for UsageError {}
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
|
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
|
||||||
tokio::task::LocalSet::new().run_until(async move {
|
tokio::task::LocalSet::new().run_until(async move {
|
||||||
|
let aircrafts = aircrafts::Aircrafts::load("aircraftDatabase.csv");
|
||||||
|
let locations = location::Locations::load("locations.json");
|
||||||
|
let mut events = adsb::run("http://radiobert.serv.zentralwerk.org:8080/data.json", locations);
|
||||||
|
|
||||||
let args: Vec<String> = args().collect();
|
let args: Vec<String> = args().collect();
|
||||||
if args.len() != 4 {
|
if args.len() != 4 {
|
||||||
println!("Usage: {} <jid> <password> <muc>", args[0]);
|
println!("Usage: {} <jid> <password> <muc>", args[0]);
|
||||||
|
@ -29,10 +33,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
|
||||||
let muc = args[3].to_owned();
|
let muc = args[3].to_owned();
|
||||||
let jabber = jabber::run(jid, password, muc).await;
|
let jabber = jabber::run(jid, password, muc).await;
|
||||||
|
|
||||||
let aircrafts = aircrafts::Aircrafts::load("aircraftDatabase.csv");
|
|
||||||
let locations = location::Locations::load("locations.json");
|
|
||||||
let mut events = adsb::run("http://radiobert.serv.zentralwerk.org:8080/data.json", locations);
|
|
||||||
|
|
||||||
while let Some(event) = events.recv().await {
|
while let Some(event) = events.recv().await {
|
||||||
println!("event: {:?}", event);
|
println!("event: {:?}", event);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue