use std::collections::HashSet; use abstutil::{wraparound_get, MapName, Parallelism, Tags, Timer}; use geom::{Distance, Polygon, Pt2D, Ring}; use map_model::{osm, ControlTrafficSignal, LaneID, NORMAL_LANE_THICKNESS}; use sim::{AgentID, Sim}; use widgetry::{ lctrl, Btn, Checkbox, Choice, Color, DrawBaselayer, Drawable, EventCtx, GeomBatch, GfxCtx, HorizontalAlignment, Key, Line, Outcome, Panel, State, Text, UpdateType, VerticalAlignment, Widget, }; use crate::app::{App, ShowLayers, ShowObject}; use crate::common::{tool_panel, CommonState, ContextualActions}; use crate::game::{ChooseSomething, PopupMsg, PromptInput, Transition}; use crate::helpers::ID; use crate::load::MapLoader; use crate::options::OptionsPanel; use crate::render::{calculate_corners, DrawOptions}; use crate::sandbox::GameplayMode; mod floodfill; mod objects; pub mod path_counter; mod polygons; pub mod shared_row; pub mod streetmix; pub struct DebugMode { panel: Panel, common: CommonState, tool_panel: Panel, objects: objects::ObjectDebugger, hidden: HashSet, layers: ShowLayers, search_results: Option, all_routes: Option<(usize, Drawable)>, highlighted_agents: Option<(ID, Drawable)>, } impl DebugMode { pub fn new(ctx: &mut EventCtx) -> Box> { Box::new(DebugMode { panel: Panel::new(Widget::col(vec![ Widget::row(vec![ Line("Debug Mode").small_heading().draw(ctx), Btn::close(ctx), ]), Text::new().draw(ctx).named("current info"), Checkbox::switch(ctx, "show buildings", Key::Num1, true), Checkbox::switch(ctx, "show intersections", Key::Num2, true), Checkbox::switch(ctx, "show lanes", Key::Num3, true), Checkbox::switch(ctx, "show areas", Key::Num4, true), Checkbox::switch(ctx, "show labels", Key::Num5, false), Checkbox::switch(ctx, "show route for all agents", Key::R, false), Widget::col(vec![ Btn::text_fg("unhide everything").build_def(ctx, lctrl(Key::H)), Btn::text_fg("screenshot everything").build_def(ctx, None), Btn::text_fg("screenshot all of the everything").build_def(ctx, None), Btn::text_fg("search OSM metadata").build_def(ctx, Key::Slash), Btn::text_fg("clear OSM search results").build_def(ctx, lctrl(Key::Slash)), Btn::text_fg("save sim state").build_def(ctx, Key::O), Btn::text_fg("load previous sim state").build_def(ctx, Key::Y), Btn::text_fg("load next sim state").build_def(ctx, Key::U), Btn::text_fg("pick a savestate to load").build_def(ctx, None), Btn::text_fg("find bad traffic signals").build_def(ctx, None), Btn::text_fg("find degenerate roads").build_def(ctx, None), Btn::text_fg("find large intersections").build_def(ctx, None), ]), Text::from_all(vec![ Line("Hold "), Key::LeftControl.txt(ctx), Line(" to show position"), ]) .draw(ctx), ])) .aligned(HorizontalAlignment::Right, VerticalAlignment::Top) .build(ctx), common: CommonState::new(), tool_panel: tool_panel(ctx), objects: objects::ObjectDebugger::new(), hidden: HashSet::new(), layers: ShowLayers::new(), search_results: None, all_routes: None, highlighted_agents: None, }) } fn reset_info(&mut self, ctx: &mut EventCtx) { let mut txt = Text::new(); if !self.hidden.is_empty() { txt.add(Line(format!("Hiding {} things", self.hidden.len()))); } if let Some(ref results) = self.search_results { txt.add(Line(format!( "Search for {} has {} results", results.query, results.num_matches ))); } if let Some((n, _)) = self.all_routes { txt.add(Line(format!( "Showing {} routes", abstutil::prettyprint_usize(n) ))); } self.panel.replace(ctx, "current info", txt.draw(ctx)); } } impl State for DebugMode { fn event(&mut self, ctx: &mut EventCtx, app: &mut App) -> Transition { ctx.canvas_movement(); if ctx.redo_mouseover() { app.primary.current_selection = app.mouseover_debug_mode(ctx, self); } match self.panel.event(ctx) { Outcome::Clicked(x) => match x.as_ref() { "close" => { return Transition::Pop; } "save sim state" => { ctx.loading_screen("savestate", |_, timer| { timer.start("save sim state"); app.primary.sim.save(); timer.stop("save sim state"); }); } "load previous sim state" => { if let Some(t) = ctx.loading_screen("load previous savestate", |ctx, mut timer| { let prev_state = app .primary .sim .find_previous_savestate(app.primary.sim.time()); match prev_state.clone().and_then(|path| { Sim::load_savestate(path, &app.primary.map, &mut timer).ok() }) { Some(new_sim) => { app.primary.sim = new_sim; app.recalculate_current_selection(ctx); None } None => Some(Transition::Push(PopupMsg::new( ctx, "Error", vec![format!( "Couldn't load previous savestate {:?}", prev_state )], ))), } }) { return t; } } "load next sim state" => { if let Some(t) = ctx.loading_screen("load next savestate", |ctx, mut timer| { let next_state = app.primary.sim.find_next_savestate(app.primary.sim.time()); match next_state.clone().and_then(|path| { Sim::load_savestate(path, &app.primary.map, &mut timer).ok() }) { Some(new_sim) => { app.primary.sim = new_sim; app.recalculate_current_selection(ctx); None } None => Some(Transition::Push(PopupMsg::new( ctx, "Error", vec![format!("Couldn't load next savestate {:?}", next_state)], ))), } }) { return t; } } "pick a savestate to load" => { return Transition::Push(ChooseSomething::new( ctx, "Load which savestate?", Choice::strings(abstutil::list_all_objects(app.primary.sim.save_dir())), Box::new(|ss, ctx, app| { // TODO Oh no, we have to do path construction here :( let ss_path = format!("{}/{}.bin", app.primary.sim.save_dir(), ss); ctx.loading_screen("load savestate", |ctx, mut timer| { app.primary.sim = Sim::load_savestate(ss_path, &app.primary.map, &mut timer) .expect("Can't load savestate"); app.recalculate_current_selection(ctx); }); Transition::Pop }), )); } "unhide everything" => { self.hidden.clear(); app.primary.current_selection = app.mouseover_debug_mode(ctx, self); self.reset_info(ctx); } "search OSM metadata" => { return Transition::Push(PromptInput::new( ctx, "Search for what?", Box::new(search_osm), )); } "clear OSM search results" => { self.search_results = None; self.reset_info(ctx); } "screenshot everything" => { screenshot_everything(ctx, app); return Transition::Keep; } "screenshot all of the everything" => { return Transition::Push(ScreenshotTest::new( ctx, app, vec![ MapName::seattle("downtown"), MapName::new("krakow", "center"), MapName::seattle("lakeslice"), MapName::seattle("montlake"), MapName::new("london", "southbank"), MapName::seattle("udistrict"), ], )); } "find bad traffic signals" => { find_bad_signals(app); } "find degenerate roads" => { find_degenerate_roads(app); } "find large intersections" => { find_large_intersections(app); } _ => unreachable!(), }, Outcome::Changed => { // TODO We should really recalculate current_selection when these change. Meh. self.layers.show_buildings = self.panel.is_checked("show buildings"); self.layers.show_intersections = self.panel.is_checked("show intersections"); self.layers.show_lanes = self.panel.is_checked("show lanes"); self.layers.show_areas = self.panel.is_checked("show areas"); self.layers.show_labels = self.panel.is_checked("show labels"); if self.panel.is_checked("show route for all agents") { if self.all_routes.is_none() { self.all_routes = Some(calc_all_routes(ctx, app)); self.reset_info(ctx); } } else { if self.all_routes.is_some() { self.all_routes = None; self.reset_info(ctx); } } } _ => {} } match app.primary.current_selection { Some(ID::Intersection(_)) | Some(ID::Car(_)) => { let id = app.primary.current_selection.clone().unwrap(); if self .highlighted_agents .as_ref() .map(|(x, _)| *x != id) .unwrap_or(true) { let mut batch = GeomBatch::new(); let agents = match id { ID::Intersection(i) => app .primary .sim .get_accepted_agents(i) .into_iter() .map(|(a, _)| a) .collect(), ID::Car(c) => app.primary.sim.get_blocked_by(AgentID::Car(c)), _ => unreachable!(), }; for a in agents { if let Some(obj) = app.primary.draw_map.get_obj( ctx, ID::from_agent(a), app, &mut app.primary.draw_map.agents.borrow_mut(), ) { batch.push(Color::PURPLE, obj.get_outline(&app.primary.map)); } else { return Transition::Push(PopupMsg::new( ctx, "Wat", vec![format!( "{} is accepted at or blocked by by {:?}, but no longer exists", a, id )], )); } } self.highlighted_agents = Some((id, ctx.upload(batch))); } } _ => { self.highlighted_agents = None; } } self.objects.event(ctx); if let Some(t) = self.common.event(ctx, app, &mut Actions {}) { return t; } match self.tool_panel.event(ctx) { Outcome::Clicked(x) => match x.as_ref() { "back" => Transition::Pop, "settings" => Transition::Push(OptionsPanel::new(ctx, app)), _ => unreachable!(), }, _ => Transition::Keep, } } fn draw_baselayer(&self) -> DrawBaselayer { DrawBaselayer::Custom } fn draw(&self, g: &mut GfxCtx, app: &App) { let mut opts = DrawOptions::new(); opts.label_buildings = self.layers.show_labels; app.draw(g, opts, self); if let Some(ref results) = self.search_results { g.redraw(&results.draw); } if let Some((_, ref draw)) = self.highlighted_agents { g.redraw(draw); } self.objects.draw(g, app); if let Some((_, ref draw)) = self.all_routes { g.redraw(draw); } if !g.is_screencap() { self.panel.draw(g); self.common.draw(g, app); self.tool_panel.draw(g); } } } impl ShowObject for DebugMode { fn show(&self, obj: &ID) -> bool { if self.hidden.contains(obj) { return false; } match obj { ID::Road(_) | ID::Lane(_) => self.layers.show_lanes, ID::Building(_) => self.layers.show_buildings, ID::Intersection(_) => self.layers.show_intersections, ID::Area(_) => self.layers.show_areas, _ => true, } } fn layers(&self) -> &ShowLayers { &self.layers } } fn search_osm(filter: String, ctx: &mut EventCtx, app: &mut App) -> Transition { let mut num_matches = 0; let mut batch = GeomBatch::new(); // TODO Case insensitive let map = &app.primary.map; let color = Color::RED.alpha(0.8); for r in map.all_roads() { if r.osm_tags .inner() .iter() .any(|(k, v)| format!("{} = {}", k, v).contains(&filter)) { num_matches += 1; batch.push(color, r.get_thick_polygon(map)); } } for a in map.all_areas() { if a.osm_tags .inner() .iter() .any(|(k, v)| format!("{} = {}", k, v).contains(&filter)) { num_matches += 1; batch.push(color, a.polygon.clone()); } } let results = SearchResults { query: filter, num_matches, draw: batch.upload(ctx), }; Transition::Multi(vec![ Transition::Pop, Transition::ModifyState(Box::new(|state, ctx, _| { let mut mode = state.downcast_mut::().unwrap(); mode.search_results = Some(results); mode.reset_info(ctx); })), ]) } struct SearchResults { query: String, num_matches: usize, draw: Drawable, } fn calc_all_routes(ctx: &EventCtx, app: &mut App) -> (usize, Drawable) { let agents = app.primary.sim.active_agents(); let mut batch = GeomBatch::new(); let mut cnt = 0; let sim = &app.primary.sim; let map = &app.primary.map; for maybe_trace in Timer::new("calculate all routes").parallelize( "route to geometry", Parallelism::Fastest, agents, |id| { sim.trace_route(id, map, None) .map(|trace| trace.make_polygons(NORMAL_LANE_THICKNESS)) }, ) { if let Some(t) = maybe_trace { cnt += 1; batch.push(app.cs.route, t); } } (cnt, ctx.upload(batch)) } struct Actions; impl ContextualActions for Actions { fn actions(&self, app: &App, id: ID) -> Vec<(Key, String)> { let mut actions = vec![(Key::D, "debug".to_string())]; match id { ID::Lane(l) => { actions.push((Key::H, "hide this".to_string())); if app.primary.map.get_l(l).lane_type.supports_any_movement() { actions.push((Key::F, "floodfill from this lane".to_string())); actions.push((Key::S, "show strongly-connected components".to_string())); } actions.push((Key::X, "debug lane geometry".to_string())); actions.push((Key::F2, "debug lane triangles geometry".to_string())); actions.push(( Key::B, "trace the block to the left of this road".to_string(), )); } ID::Intersection(i) => { actions.push((Key::H, "hide this".to_string())); actions.push((Key::X, "debug intersection geometry".to_string())); actions.push((Key::F2, "debug sidewalk corners".to_string())); if app.primary.map.get_i(i).roads.len() == 2 { actions.push((Key::C, "collapse degenerate road?".to_string())); } } ID::Car(_) => { actions.push((Key::Backspace, "forcibly delete this car".to_string())); actions.push((Key::G, "find front of blockage".to_string())); } ID::Area(_) => { actions.push((Key::X, "debug area geometry".to_string())); actions.push((Key::F2, "debug area triangles".to_string())); } ID::ParkingLot(_) => { actions.push((Key::H, "hide this".to_string())); } ID::BusStop(_) => { actions.push((Key::H, "hide this".to_string())); } _ => {} } actions } fn execute( &mut self, ctx: &mut EventCtx, app: &mut App, id: ID, action: String, close_info: &mut bool, ) -> Transition { match (id, action.as_ref()) { (id, "hide this") => Transition::ModifyState(Box::new(|state, ctx, app| { let mode = state.downcast_mut::().unwrap(); println!("Hiding {:?}", id); app.primary.current_selection = None; mode.hidden.insert(id); mode.reset_info(ctx); })), (id, "debug") => { *close_info = false; objects::ObjectDebugger::dump_debug(id, &app.primary.map, &app.primary.sim); Transition::Keep } (ID::Car(c), "forcibly delete this car") => { app.primary.sim.delete_car(c, &app.primary.map); app.primary .sim .tiny_step(&app.primary.map, &mut app.primary.sim_cb); app.primary.current_selection = None; Transition::Keep } (ID::Car(c), "find front of blockage") => Transition::Push(PopupMsg::new( ctx, "Blockage results", vec![format!( "{} is ultimately blocked by {}", c, app.primary.sim.find_blockage_front(c, &app.primary.map) )], )), (ID::Lane(l), "floodfill from this lane") => { Transition::Push(floodfill::Floodfiller::floodfill(ctx, app, l)) } (ID::Lane(l), "show strongly-connected components") => { Transition::Push(floodfill::Floodfiller::scc(ctx, app, l)) } (ID::Intersection(i), "debug intersection geometry") => { let pts = app.primary.map.get_i(i).polygon.points(); let mut pts_without_last = pts.clone(); pts_without_last.pop(); Transition::Push(polygons::PolygonDebugger::new( ctx, "point", pts.iter().map(|pt| polygons::Item::Point(*pt)).collect(), Some(Pt2D::center(&pts_without_last)), )) } (ID::Intersection(i), "debug sidewalk corners") => { Transition::Push(polygons::PolygonDebugger::new( ctx, "corner", calculate_corners(app.primary.map.get_i(i), &app.primary.map) .into_iter() .map(|poly| polygons::Item::Polygon(poly)) .collect(), None, )) } (ID::Intersection(i), "collapse degenerate road?") => { let i = app.primary.map.get_i(i); let (r1, r2) = { let mut iter = i.roads.iter(); (*iter.next().unwrap(), *iter.next().unwrap()) }; diff_tags( &app.primary.map.get_r(r1).osm_tags, &app.primary.map.get_r(r2).osm_tags, ); Transition::Keep } (ID::Lane(l), "debug lane geometry") => { Transition::Push(polygons::PolygonDebugger::new( ctx, "point", app.primary .map .get_l(l) .lane_center_pts .points() .iter() .map(|pt| polygons::Item::Point(*pt)) .collect(), None, )) } (ID::Lane(l), "debug lane triangles geometry") => { Transition::Push(polygons::PolygonDebugger::new( ctx, "triangle", app.primary .draw_map .get_l(l) .polygon .triangles() .into_iter() .map(|tri| polygons::Item::Triangle(tri)) .collect(), None, )) } (ID::Lane(l), "trace the block to the left of this road") => { Transition::ModifyState(Box::new(move |state, ctx, app| { let mut mode = state.downcast_mut::().unwrap(); // Just abuse this to display the results mode.search_results = trace_block(app, l).map(|poly| SearchResults { query: format!("block around {}", l), num_matches: 0, draw: ctx.upload(GeomBatch::from(vec![(Color::RED, poly)])), }); mode.reset_info(ctx); })) } (ID::Area(a), "debug area geometry") => { let pts = &app.primary.map.get_a(a).polygon.points(); let center = if pts[0] == *pts.last().unwrap() { // TODO The center looks really wrong for Volunteer Park and others, but I // think it's because they have many points along some edges. Pt2D::center(&pts.iter().skip(1).cloned().collect()) } else { Pt2D::center(pts) }; Transition::Push(polygons::PolygonDebugger::new( ctx, "point", pts.iter().map(|pt| polygons::Item::Point(*pt)).collect(), Some(center), )) } (ID::Area(a), "debug area triangles") => { Transition::Push(polygons::PolygonDebugger::new( ctx, "triangle", app.primary .map .get_a(a) .polygon .triangles() .into_iter() .map(|tri| polygons::Item::Triangle(tri)) .collect(), None, )) } _ => unreachable!(), } } fn is_paused(&self) -> bool { true } fn gameplay_mode(&self) -> GameplayMode { // Hack so info panels can be opened in DebugMode GameplayMode::FixTrafficSignals } } fn find_bad_signals(app: &App) { println!("Bad traffic signals:"); for i in app.primary.map.all_intersections() { if i.is_traffic_signal() { let first = &ControlTrafficSignal::get_possible_policies( &app.primary.map, i.id, &mut Timer::throwaway(), )[0] .0; if first == "phase per road" || first == "arbitrary assignment" { println!("- {}", i.id); ControlTrafficSignal::brute_force(&app.primary.map, i.id); } } } } fn find_degenerate_roads(app: &App) { let map = &app.primary.map; for i in map.all_intersections() { if i.roads.len() != 2 { continue; } if i.turns.iter().any(|t| map.get_t(*t).between_sidewalks()) { continue; } let (r1, r2) = { let mut iter = i.roads.iter(); (*iter.next().unwrap(), *iter.next().unwrap()) }; let r1 = map.get_r(r1); let r2 = map.get_r(r2); if r1.zorder != r2.zorder { continue; } if r1 .lanes_ltr() .into_iter() .map(|(_, dir, lt)| (dir, lt)) .collect::>() != r2 .lanes_ltr() .into_iter() .map(|(_, dir, lt)| (dir, lt)) .collect::>() { continue; } println!("Maybe merge {}", i.id); diff_tags(&r1.osm_tags, &r2.osm_tags); } } fn diff_tags(t1: &Tags, t2: &Tags) { for (k, v1) in t1.inner() { if k == osm::OSM_WAY_ID { continue; } let v2 = t2.get(k).cloned().unwrap_or_else(String::new); if v1 != &v2 { println!("- {} = \"{}\" vs \"{}\"", k, v1, v2); } } for (k, v2) in t2.inner() { if !t1.contains_key(k) { println!("- {} = \"\" vs \"{}\"", k, v2); } } } fn find_large_intersections(app: &App) { let mut seen = HashSet::new(); for t in app.primary.map.all_turns().values() { if !seen.contains(&t.id.parent) && t.geom.length() > Distance::meters(50.0) { println!("{} has a long turn", t.id.parent); seen.insert(t.id.parent); } } } // Because of the slightly odd control flow needed to ask widgetry to ScreenCaptureEverything, a // separate state is the easiest way to automatically screenshot multiple maps. struct ScreenshotTest { todo_maps: Vec, screenshot_done: bool, } impl ScreenshotTest { fn new(ctx: &mut EventCtx, app: &App, mut todo_maps: Vec) -> Box> { MapLoader::new( ctx, app, todo_maps.pop().unwrap(), Box::new(move |_, _| { Transition::Replace(Box::new(ScreenshotTest { todo_maps, screenshot_done: false, })) }), ) } } impl State for ScreenshotTest { fn event(&mut self, ctx: &mut EventCtx, app: &mut App) -> Transition { if self.screenshot_done { if self.todo_maps.is_empty() { Transition::Pop } else { Transition::Replace(ScreenshotTest::new( ctx, app, self.todo_maps.drain(..).collect(), )) } } else { self.screenshot_done = true; screenshot_everything(ctx, app); // TODO Sometimes this still gets stuck and needs a mouse wiggle for input event? Transition::Keep } } fn draw(&self, _: &mut GfxCtx, _: &App) {} } fn screenshot_everything(ctx: &mut EventCtx, app: &App) { let bounds = app.primary.map.get_bounds(); assert!(bounds.min_x == 0.0 && bounds.min_y == 0.0); let name = app.primary.map.get_name(); ctx.request_update(UpdateType::ScreenCaptureEverything { dir: format!("screenshots/{}/{}", name.city, name.map), zoom: 3.0, max_x: bounds.max_x, max_y: bounds.max_y, }); } fn trace_block(app: &App, start: LaneID) -> Option { let map = &app.primary.map; let mut pts = Vec::new(); let mut current = start; let mut fwd = app.primary.map.get_parent(start).lanes_ltr()[0].0 == start; let mut visited = HashSet::new(); loop { let l = map.get_l(current); let lane_pts = if fwd { l.lane_center_pts.shift_left(l.width / 2.0) } else { l.lane_center_pts.reversed().shift_left(l.width / 2.0) } .unwrap() .into_points(); if let Some(last_pt) = pts.last().cloned() { if last_pt != lane_pts[0] { let last_i = if fwd { l.src_i } else { l.dst_i }; if let Some(pl) = map .get_i(last_i) .polygon .clone() .into_ring() .get_shorter_slice_btwn(last_pt, lane_pts[0]) { pts.extend(pl.into_points()); } } } pts.extend(lane_pts); // Imagine pointing down this lane to the intersection. Rotate left -- which road is next? let i = if fwd { l.dst_i } else { l.src_i }; println!("{}, fwd={}, pointing to {}", current, fwd, i); let roads = map .get_i(i) .get_roads_sorted_by_incoming_angle(map.all_roads()); let idx = roads.iter().position(|r| *r == l.parent).unwrap(); // Get the next road counter-clockwise let next_road = map.get_r(*wraparound_get(&roads, (idx as isize) + 1)); // Depending on if this road points to or from the intersection, get the left- or // right-most lane. let next_lane = if next_road.src_i == i { next_road.lanes_ltr()[0].0 } else { next_road.lanes_ltr().last().unwrap().0 }; if next_lane == start { break; } if visited.contains(¤t) { println!("Loop, something's broken"); return None; } visited.insert(current); current = next_lane; fwd = map.get_l(current).src_i == i; } pts.push(pts[0]); pts.dedup(); Some(Ring::new(pts).ok()?.to_polygon()) }