use abstutil::{serialize_btreemap, CmdArgs, Timer};
use geom::{Duration, LonLat, Time};
use hyper::{Body, Request, Response, Server};
use map_model::{CompressedTurnGroupID, ControlTrafficSignal, IntersectionID, Map, TurnGroupID};
use serde::Serialize;
use sim::{
AlertHandler, GetDrawAgents, PersonID, Sim, SimFlags, SimOptions, TripID, TripMode, VehicleType,
};
use std::collections::{BTreeMap, HashMap};
use std::convert::TryFrom;
use std::error::Error;
use std::sync::RwLock;
lazy_static::lazy_static! {
static ref MAP: RwLock<Map> = RwLock::new(Map::blank());
static ref SIM: RwLock<Sim> = RwLock::new(Sim::new(&Map::blank(), SimOptions::new("tmp"), &mut Timer::throwaway()));
static ref FLAGS: RwLock<SimFlags> = RwLock::new(SimFlags::for_test("tmp"));
}
#[tokio::main]
async fn main() {
let mut args = CmdArgs::new();
let mut sim_flags = SimFlags::from_args(&mut args);
let port = args.required("--port").parse::<u16>().unwrap();
args.done();
sim_flags.opts.alerts = AlertHandler::Silence;
let (map, sim, _) = sim_flags.load(&mut Timer::new("setup headless"));
*MAP.write().unwrap() = map;
*SIM.write().unwrap() = sim;
*FLAGS.write().unwrap() = sim_flags;
let addr = std::net::SocketAddr::from(([127, 0, 0, 1], port));
println!("Listening on http://{}", addr);
let serve_future = Server::bind(&addr).serve(hyper::service::make_service_fn(|_| async {
Ok::<_, hyper::Error>(hyper::service::service_fn(serve_req))
}));
if let Err(err) = serve_future.await {
panic!("Server error: {}", err);
}
}
async fn serve_req(req: Request<Body>) -> Result<Response<Body>, hyper::Error> {
let path = req.uri().path().to_string();
let params: HashMap<String, String> =
url::Url::parse(&format!("http://localhost{}", req.uri()))
.unwrap()
.query_pairs()
.map(|(k, v)| (k.to_string(), v.to_string()))
.collect();
let body = hyper::body::to_bytes(req).await?.to_vec();
let resp = match handle_command(
&path,
¶ms,
&body,
&mut SIM.write().unwrap(),
&mut MAP.write().unwrap(),
) {
Ok(resp) => resp,
Err(err) => {
format!("Bad command {} with params {:?}: {}", path, params, err)
}
};
Ok(Response::new(Body::from(resp)))
}
fn handle_command(
path: &str,
params: &HashMap<String, String>,
body: &Vec<u8>,
sim: &mut Sim,
map: &mut Map,
) -> Result<String, Box<dyn Error>> {
match path {
"/sim/reset" => {
let (new_map, new_sim, _) = FLAGS.read().unwrap().load(&mut Timer::new("reset sim"));
*map = new_map;
*sim = new_sim;
Ok(format!("sim reloaded"))
}
"/sim/get-time" => Ok(sim.time().to_string()),
"/sim/goto-time" => {
let t = Time::parse(¶ms["t"])?;
if t <= sim.time() {
Err(format!("{} is in the past. call /sim/reset first?", t).into())
} else {
let dt = t - sim.time();
sim.timed_step(map, dt, &mut None, &mut Timer::new("goto-time"));
Ok(format!("it's now {}", t))
}
}
"/traffic-signals/get" => {
let i = IntersectionID(params["id"].parse::<usize>()?);
if let Some(ts) = map.maybe_get_traffic_signal(i) {
Ok(abstutil::to_json(ts))
} else {
Err(format!("{} isn't a traffic signal", i).into())
}
}
"/traffic-signals/set" => {
let ts: ControlTrafficSignal = abstutil::from_json(body)?;
let id = ts.id;
map.incremental_edit_traffic_signal(ts);
Ok(format!("{} has been updated", id))
}
"/traffic-signals/get-delays" => {
let i = IntersectionID(params["id"].parse::<usize>()?);
let t1 = Time::parse(¶ms["t1"])?;
let t2 = Time::parse(¶ms["t2"])?;
let ts = if let Some(ts) = map.maybe_get_traffic_signal(i) {
ts
} else {
return Err(format!("{} isn't a traffic signal", i).into());
};
let turn_groups: Vec<&TurnGroupID> = ts.turn_groups.keys().collect();
let mut delays = Delays {
per_direction: BTreeMap::new(),
};
for tg in ts.turn_groups.keys() {
delays.per_direction.insert(tg.clone(), Vec::new());
}
if let Some(list) = sim.get_analytics().intersection_delays.get(&i) {
for (idx, t, dt, _) in list {
if *t >= t1 && *t <= t2 {
delays
.per_direction
.get_mut(turn_groups[*idx as usize])
.unwrap()
.push(*dt);
}
}
}
Ok(abstutil::to_json(&delays))
}
"/traffic-signals/get-cumulative-thruput" => {
let i = IntersectionID(params["id"].parse::<usize>()?);
let ts = if let Some(ts) = map.maybe_get_traffic_signal(i) {
ts
} else {
return Err(format!("{} isn't a traffic signal", i).into());
};
let mut thruput = Throughput {
per_direction: BTreeMap::new(),
};
for (idx, tg) in ts.turn_groups.keys().enumerate() {
thruput.per_direction.insert(
tg.clone(),
sim.get_analytics()
.traffic_signal_thruput
.total_for(CompressedTurnGroupID {
i,
idx: u8::try_from(idx).unwrap(),
}),
);
}
Ok(abstutil::to_json(&thruput))
}
"/data/get-finished-trips" => Ok(abstutil::to_json(&FinishedTrips {
trips: sim.get_analytics().finished_trips.clone(),
})),
"/data/get-agent-positions" => Ok(abstutil::to_json(&AgentPositions {
agents: sim
.get_unzoomed_agents(map)
.into_iter()
.map(|a| AgentPosition {
vehicle_type: a.vehicle_type,
pos: a.pos.to_gps(map.get_gps_bounds()),
person: a.person,
})
.collect(),
})),
_ => Err("Unknown command".into()),
}
}
#[derive(Serialize)]
struct FinishedTrips {
trips: Vec<(Time, TripID, Option<TripMode>, Duration)>,
}
#[derive(Serialize)]
struct Delays {
#[serde(serialize_with = "serialize_btreemap")]
per_direction: BTreeMap<TurnGroupID, Vec<Duration>>,
}
#[derive(Serialize)]
struct Throughput {
#[serde(serialize_with = "serialize_btreemap")]
per_direction: BTreeMap<TurnGroupID, usize>,
}
#[derive(Serialize)]
struct AgentPositions {
agents: Vec<AgentPosition>,
}
#[derive(Serialize)]
struct AgentPosition {
vehicle_type: Option<VehicleType>,
pos: LonLat,
person: Option<PersonID>,
}