use std::collections::BTreeMap;
use std::fmt;
use crate::anyhow::Context;
use anyhow::Result;
use petgraph::graphmap::DiGraphMap;
use serde::{Deserialize, Serialize};
use abstio::MapName;
use abstutil::{deserialize_btreemap, serialize_btreemap, Tags};
use geom::{Circle, Distance, GPSBounds, PolyLine, Polygon, Pt2D};
use crate::make::initial::lane_specs::get_lane_specs_ltr;
use crate::{
osm, Amenity, AreaType, Direction, DrivingSide, IntersectionType, LaneType, MapConfig,
};
#[derive(Debug, Serialize, Deserialize)]
pub struct RawMap {
pub name: MapName,
#[serde(
serialize_with = "serialize_btreemap",
deserialize_with = "deserialize_btreemap"
)]
pub roads: BTreeMap<OriginalRoad, RawRoad>,
#[serde(
serialize_with = "serialize_btreemap",
deserialize_with = "deserialize_btreemap"
)]
pub intersections: BTreeMap<osm::NodeID, RawIntersection>,
#[serde(
serialize_with = "serialize_btreemap",
deserialize_with = "deserialize_btreemap"
)]
pub buildings: BTreeMap<osm::OsmID, RawBuilding>,
pub bus_routes: Vec<RawBusRoute>,
pub areas: Vec<RawArea>,
pub parking_lots: Vec<RawParkingLot>,
pub parking_aisles: Vec<(osm::WayID, Vec<Pt2D>)>,
pub boundary_polygon: Polygon,
pub gps_bounds: GPSBounds,
pub config: MapConfig,
}
#[derive(Serialize, Deserialize, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub struct OriginalRoad {
pub osm_way_id: osm::WayID,
pub i1: osm::NodeID,
pub i2: osm::NodeID,
}
impl fmt::Display for OriginalRoad {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(
f,
"OriginalRoad({} from {} to {}",
self.osm_way_id, self.i1, self.i2
)
}
}
impl fmt::Debug for OriginalRoad {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
write!(f, "{}", self)
}
}
impl OriginalRoad {
pub fn new(way: i64, (i1, i2): (i64, i64)) -> OriginalRoad {
OriginalRoad {
osm_way_id: osm::WayID(way),
i1: osm::NodeID(i1),
i2: osm::NodeID(i2),
}
}
pub fn to_string_code(&self) -> String {
format!(
"OriginalRoad::new({}, ({}, {}))",
self.osm_way_id.0, self.i1.0, self.i2.0
)
}
}
impl RawMap {
pub fn blank(name: MapName) -> RawMap {
RawMap {
name,
roads: BTreeMap::new(),
intersections: BTreeMap::new(),
buildings: BTreeMap::new(),
bus_routes: Vec::new(),
areas: Vec::new(),
parking_lots: Vec::new(),
parking_aisles: Vec::new(),
boundary_polygon: Polygon::rectangle(1.0, 1.0),
gps_bounds: GPSBounds::new(),
config: MapConfig {
driving_side: DrivingSide::Right,
bikes_can_use_bus_lanes: true,
inferred_sidewalks: true,
separate_cycleways: false,
},
}
}
pub fn roads_per_intersection(&self, i: osm::NodeID) -> Vec<OriginalRoad> {
let mut results = Vec::new();
for id in self.roads.keys() {
if id.i1 == i || id.i2 == i {
results.push(*id);
}
}
results
}
pub fn new_osm_node_id(&self, start: i64) -> osm::NodeID {
assert!(start < 0);
let mut osm_node_id = start;
loop {
if self.intersections.keys().any(|i| i.0 == osm_node_id) {
osm_node_id -= 1;
} else {
return osm::NodeID(osm_node_id);
}
}
}
pub fn new_osm_way_id(&self, start: i64) -> osm::WayID {
assert!(start < 0);
let mut osm_way_id = start;
loop {
if self.roads.keys().any(|r| r.osm_way_id.0 == osm_way_id) {
osm_way_id -= 1;
} else {
return osm::WayID(osm_way_id);
}
}
}
pub fn preview_intersection(
&self,
id: osm::NodeID,
) -> (Polygon, Vec<Polygon>, Vec<(String, Polygon)>) {
use crate::make::initial;
let i = initial::Intersection {
id,
polygon: Circle::new(Pt2D::new(0.0, 0.0), Distance::meters(1.0)).to_polygon(),
roads: self.roads_per_intersection(id).into_iter().collect(),
intersection_type: self.intersections[&id].intersection_type,
elevation: self.intersections[&id].elevation,
};
let mut roads = BTreeMap::new();
for r in &i.roads {
roads.insert(
*r,
initial::Road::new(*r, &self.roads[r], &self.config).unwrap(),
);
}
let (poly, debug) = initial::intersection_polygon(&i, &mut roads).unwrap();
(
poly,
roads
.values()
.map(|r| r.trimmed_center_pts.make_polygons(2.0 * r.half_width))
.collect(),
debug,
)
}
pub fn trimmed_road_geometry(&self, road: OriginalRoad) -> Option<PolyLine> {
use crate::make::initial;
let mut roads = BTreeMap::new();
for id in vec![road.i1, road.i2] {
for r in self.roads_per_intersection(id) {
roads.insert(
r,
initial::Road::new(r, &self.roads[&r], &self.config).ok()?,
);
}
}
for id in vec![road.i1, road.i2] {
let i = initial::Intersection {
id,
polygon: Circle::new(Pt2D::new(0.0, 0.0), Distance::meters(1.0)).to_polygon(),
roads: self.roads_per_intersection(id).into_iter().collect(),
intersection_type: self.intersections[&id].intersection_type,
elevation: self.intersections[&id].elevation,
};
initial::intersection_polygon(&i, &mut roads).unwrap();
}
Some(roads.remove(&road).unwrap().trimmed_center_pts)
}
pub fn save(&self) {
abstio::write_binary(abstio::path_raw_map(&self.name), self)
}
}
impl RawMap {
pub fn can_delete_intersection(&self, i: osm::NodeID) -> bool {
self.roads_per_intersection(i).is_empty()
}
pub fn delete_intersection(&mut self, id: osm::NodeID) {
if !self.can_delete_intersection(id) {
panic!(
"Can't delete_intersection {}, must have roads connected",
id
);
}
self.intersections.remove(&id).unwrap();
}
pub fn move_intersection(&mut self, id: osm::NodeID, point: Pt2D) -> Option<Vec<OriginalRoad>> {
self.intersections.get_mut(&id).unwrap().point = point;
let mut fixed = Vec::new();
for r in self.roads_per_intersection(id) {
fixed.push(r);
let road = self.roads.get_mut(&r).unwrap();
if r.i1 == id {
road.center_points[0] = point;
} else {
assert_eq!(r.i2, id);
*road.center_points.last_mut().unwrap() = point;
}
}
Some(fixed)
}
pub fn closest_intersection(&self, pt: Pt2D) -> osm::NodeID {
self.intersections
.iter()
.min_by_key(|(_, i)| i.point.dist_to(pt))
.map(|(id, _)| *id)
.unwrap()
}
pub fn path_dist_to(&self, from: osm::NodeID, to: osm::NodeID) -> Option<Distance> {
let mut graph = DiGraphMap::new();
for (id, r) in &self.roads {
graph.add_edge(id.i1, id.i2, id);
if !r.osm_tags.contains_key("oneway") {
graph.add_edge(id.i2, id.i1, id);
}
}
petgraph::algo::dijkstra(&graph, from, Some(to), |(_, _, r)| {
PolyLine::unchecked_new(self.roads[r].center_points.clone()).length()
})
.get(&to)
.cloned()
}
pub fn merge_short_road(
&mut self,
short: OriginalRoad,
) -> Result<(
osm::NodeID,
osm::NodeID,
Vec<OriginalRoad>,
Vec<OriginalRoad>,
)> {
{
let i1 = &self.intersections[&short.i1];
let i2 = &self.intersections[&short.i2];
if i1.intersection_type == IntersectionType::Border
|| i2.intersection_type == IntersectionType::Border
{
bail!("{} touches a border", short);
}
}
let (i1, i2) = (short.i1, short.i2);
if i1 == i2 {
bail!("Can't merge {} -- it's a loop on {}", short, i1);
}
let i1_pt = self.intersections[&i1].point;
self.roads.remove(&short).unwrap();
{
let i = self.intersections.remove(&i2).unwrap();
if i.intersection_type == IntersectionType::TrafficSignal {
self.intersections.get_mut(&i1).unwrap().intersection_type =
IntersectionType::TrafficSignal;
}
}
let mut deleted = vec![short];
let mut created = Vec::new();
let mut remapped_road_ids = BTreeMap::new();
for r in self.roads_per_intersection(i2) {
deleted.push(r);
let mut road = self.roads.remove(&r).unwrap();
let mut new_id = r;
if r.i1 == i2 {
new_id.i1 = i1;
if false {
road.center_points[0] = i1_pt;
} else {
road.center_points.insert(0, i1_pt);
}
} else {
assert_eq!(r.i2, i2);
new_id.i2 = i1;
if false {
*road.center_points.last_mut().unwrap() = i1_pt;
} else {
road.center_points.push(i1_pt);
}
}
remapped_road_ids.insert(r, new_id);
self.roads.insert(new_id, road);
created.push(new_id);
}
for road in self.roads.values_mut() {
let mut fix_trs = Vec::new();
for (rt, to) in road.turn_restrictions.drain(..) {
if to == short && rt == RestrictionType::BanTurns {
for x in &created {
fix_trs.push((rt, *x));
}
} else {
fix_trs.push((rt, to));
}
}
road.turn_restrictions = fix_trs;
}
for road in self.roads.values_mut() {
let mut add = Vec::new();
road.complicated_turn_restrictions.retain(|(via, to)| {
if *via == short {
let to_id = remapped_road_ids.get(to).cloned().unwrap_or(*to);
add.push((RestrictionType::BanTurns, to_id));
false
} else {
true
}
});
road.turn_restrictions.extend(add);
}
Ok((i1, i2, deleted, created))
}
}
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct RawRoad {
pub center_points: Vec<Pt2D>,
pub osm_tags: Tags,
pub turn_restrictions: Vec<(RestrictionType, OriginalRoad)>,
pub complicated_turn_restrictions: Vec<(OriginalRoad, OriginalRoad)>,
}
impl RawRoad {
pub fn get_geometry(&self, id: OriginalRoad, cfg: &MapConfig) -> Result<(PolyLine, Distance)> {
let lane_specs = get_lane_specs_ltr(&self.osm_tags, cfg);
let mut total_width = Distance::ZERO;
let mut sidewalk_right = None;
let mut sidewalk_left = None;
for l in &lane_specs {
total_width += l.width;
if l.lt == LaneType::Sidewalk || l.lt == LaneType::Shoulder {
if l.dir == Direction::Back {
sidewalk_left = Some(l.width);
} else {
sidewalk_right = Some(l.width);
}
}
}
let mut true_center =
PolyLine::new(self.center_points.clone()).with_context(|| id.to_string())?;
match (sidewalk_right, sidewalk_left) {
(Some(w), None) => {
true_center = true_center.must_shift_right(w / 2.0);
}
(None, Some(w)) => {
true_center = true_center.must_shift_right(w / 2.0);
}
_ => {}
}
Ok((true_center, total_width))
}
pub fn is_light_rail(&self) -> bool {
self.osm_tags.is_any("railway", vec!["light_rail", "rail"])
}
pub fn is_footway(&self) -> bool {
self.osm_tags.is_any(
osm::HIGHWAY,
vec!["cycleway", "footway", "path", "pedestrian", "steps"],
)
}
pub fn is_service(&self) -> bool {
self.osm_tags.is(osm::HIGHWAY, "service")
}
}
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct RawIntersection {
pub point: Pt2D,
pub intersection_type: IntersectionType,
pub elevation: Distance,
}
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct RawBuilding {
pub polygon: Polygon,
pub osm_tags: Tags,
pub public_garage_name: Option<String>,
pub num_parking_spots: usize,
pub amenities: Vec<Amenity>,
}
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct RawArea {
pub area_type: AreaType,
pub polygon: Polygon,
pub osm_tags: Tags,
pub osm_id: osm::OsmID,
}
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct RawParkingLot {
pub osm_id: osm::OsmID,
pub polygon: Polygon,
pub osm_tags: Tags,
}
#[derive(Serialize, Deserialize, Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub enum RestrictionType {
BanTurns,
OnlyAllowTurns,
}
#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
pub struct TurnRestriction(pub OriginalRoad, pub RestrictionType, pub OriginalRoad);
impl RestrictionType {
pub fn new(restriction: &str) -> Option<RestrictionType> {
if restriction.contains("no_") || restriction == "psv" {
Some(RestrictionType::BanTurns)
} else if restriction.contains("only_") {
Some(RestrictionType::OnlyAllowTurns)
} else {
None
}
}
}
#[derive(Debug, Serialize, Deserialize)]
pub struct RawBusRoute {
pub full_name: String,
pub short_name: String,
pub osm_rel_id: osm::RelationID,
pub gtfs_trip_marker: Option<String>,
pub is_bus: bool,
pub stops: Vec<RawBusStop>,
pub border_start: Option<osm::NodeID>,
pub border_end: Option<osm::NodeID>,
pub all_pts: Vec<(osm::NodeID, Pt2D)>,
}
#[derive(Debug, Serialize, Deserialize)]
pub struct RawBusStop {
pub name: String,
pub vehicle_pos: (osm::NodeID, Pt2D),
pub matched_road: Option<(OriginalRoad, Direction)>,
pub ped_pos: Option<Pt2D>,
}