use std::collections::{BTreeSet, VecDeque};
use serde::{Deserialize, Serialize};
use geom::{Distance, Duration, PolyLine, Time, EPSILON_DIST};
use map_model::{Direction, Map, Traversable};
use crate::{
CarID, CarStatus, DistanceInterval, DrawCarInput, ParkingSpot, PersonID, Router, TimeInterval,
TransitSimState, TripID, Vehicle, VehicleType,
};
#[derive(Debug, Serialize, Deserialize, Clone)]
pub(crate) struct Car {
pub vehicle: Vehicle,
pub state: CarState,
pub router: Router,
pub trip_and_person: Option<(TripID, PersonID)>,
pub started_at: Time,
pub total_blocked_time: Duration,
pub last_steps: VecDeque<Traversable>,
pub wants_to_overtake: BTreeSet<CarID>,
}
impl Car {
pub fn crossing_state(&self, start_dist: Distance, start_time: Time, map: &Map) -> CarState {
let dist_int = DistanceInterval::new_driving(
start_dist,
if self.router.last_step() {
self.router.get_end_dist()
} else {
self.router.head().get_polyline(map).length()
},
);
self.crossing_state_with_end_dist(dist_int, start_time, map)
}
pub fn crossing_state_with_end_dist(
&self,
dist_int: DistanceInterval,
start_time: Time,
map: &Map,
) -> CarState {
let speed = self.router.head().max_speed_along(
self.vehicle.max_speed,
self.vehicle.vehicle_type.to_constraints(),
map,
);
let dt = (dist_int.end - dist_int.start) / speed;
CarState::Crossing(TimeInterval::new(start_time, start_time + dt), dist_int)
}
pub fn get_draw_car(
&self,
front: Distance,
now: Time,
map: &Map,
transit: &TransitSimState,
) -> DrawCarInput {
assert!(front >= Distance::ZERO);
let mut partly_on = Vec::new();
let raw_body = if front >= self.vehicle.length {
self.router
.head()
.get_polyline(map)
.exact_slice(front - self.vehicle.length, front)
} else {
let mut result = self
.router
.head()
.get_polyline(map)
.slice(Distance::ZERO, front)
.map(|(pl, _)| pl.into_points())
.ok()
.unwrap_or_else(Vec::new);
let mut leftover = self.vehicle.length - front;
let mut i = 0;
while leftover > Distance::ZERO {
if i == self.last_steps.len() {
break;
}
partly_on.push(self.last_steps[i]);
let len = self.last_steps[i].get_polyline(map).length();
let start = (len - leftover).max(Distance::ZERO);
let piece = self.last_steps[i]
.get_polyline(map)
.slice(start, len)
.map(|(pl, _)| pl.into_points())
.ok()
.unwrap_or_else(Vec::new);
result = match PolyLine::append(piece, result) {
Ok(pl) => pl,
Err(err) => panic!(
"{} at {} has weird geom along {:?}: {}",
self.vehicle.id, now, self.last_steps, err
),
};
leftover -= len;
i += 1;
}
if result.len() < 2 {
if let Ok((pl, _)) = self
.router
.head()
.get_polyline(map)
.slice(Distance::ZERO, 2.0 * EPSILON_DIST)
{
result = pl.into_points();
}
}
match PolyLine::new(result) {
Ok(pl) => pl,
Err(err) => panic!("Weird body for {} at {}: {}", self.vehicle.id, now, err),
}
};
let body = match self.state {
CarState::Unparking(_, ref spot, ref time_int)
| CarState::Parking(_, ref spot, ref time_int) => {
let (percent_time, is_parking) = match self.state {
CarState::Unparking(_, _, _) => (1.0 - time_int.percent(now), false),
CarState::Parking(_, _, _) => (time_int.percent(now), true),
_ => unreachable!(),
};
match spot {
ParkingSpot::Onstreet(parking_l, _) => {
let r = map.get_parent(*parking_l);
let driving_offset = r.offset(self.router.head().as_lane());
let parking_offset = r.offset(*parking_l);
let mut diff = (parking_offset as isize) - (driving_offset as isize);
if map.get_l(self.router.head().as_lane()).dir == Direction::Back {
diff *= -1;
}
let width = map.get_l(*parking_l).width * (diff as f64) * percent_time;
match raw_body.shift_right(width) {
Ok(pl) => pl,
Err(err) => {
println!(
"Body for onstreet {} at {} broken: {}",
self.vehicle.id, now, err
);
raw_body
}
}
}
_ => {
let driveway = match spot {
ParkingSpot::Offstreet(b, _) => {
map.get_b(*b).driving_connection(map).unwrap().1
}
ParkingSpot::Lot(pl, _) => map.get_pl(*pl).driveway_line.clone(),
_ => unreachable!(),
};
let maybe_full_piece = if is_parking {
raw_body.clone().extend(driveway.reversed())
} else {
driveway
.clone()
.extend(raw_body.clone())
.map(|pl| pl.reversed())
};
let full_piece = match maybe_full_piece {
Ok(pl) => pl,
Err(err) => {
println!(
"Body and driveway for {} at {} broken: {}",
self.vehicle.id, now, err
);
raw_body
}
};
let creep_along = driveway.length() * percent_time;
let sliced =
full_piece.exact_slice(creep_along, creep_along + self.vehicle.length);
if is_parking {
sliced
} else {
sliced.reversed()
}
}
}
}
_ => raw_body,
};
DrawCarInput {
id: self.vehicle.id,
waiting_for_turn: match self.state {
CarState::WaitingToAdvance { .. } | CarState::Queued { .. } => {
match self.router.maybe_next() {
Some(Traversable::Turn(t)) => Some(t),
_ => None,
}
}
_ => None,
},
status: match self.state {
CarState::Queued { .. } => CarStatus::Moving,
CarState::WaitingToAdvance { .. } => CarStatus::Moving,
CarState::Crossing(_, _) => CarStatus::Moving,
CarState::Unparking(_, _, _) => CarStatus::Moving,
CarState::Parking(_, _, _) => CarStatus::Moving,
CarState::IdlingAtStop(_, _) => CarStatus::Parked,
},
show_parking_intent: matches!(
(self.is_parking(), &self.state),
(true, _) | (_, CarState::Unparking(_, _, _))
),
on: self.router.head(),
partly_on,
label: if self.vehicle.vehicle_type == VehicleType::Bus
|| self.vehicle.vehicle_type == VehicleType::Train
{
Some(
map.get_br(transit.bus_route(self.vehicle.id))
.short_name
.clone(),
)
} else {
None
},
body,
person: self.trip_and_person.map(|(_, p)| p),
}
}
pub fn is_parking(&self) -> bool {
if let CarState::Parking(_, _, _) = self.state {
return true;
}
self.router.is_parking()
}
}
#[derive(Debug, Serialize, Deserialize, Clone)]
pub(crate) enum CarState {
Crossing(TimeInterval, DistanceInterval),
Queued {
blocked_since: Time,
},
WaitingToAdvance {
blocked_since: Time,
},
Unparking(Distance, ParkingSpot, TimeInterval),
Parking(Distance, ParkingSpot, TimeInterval),
IdlingAtStop(Distance, TimeInterval),
}
impl CarState {
pub fn get_end_time(&self) -> Time {
match self {
CarState::Crossing(ref time_int, _) => time_int.end,
CarState::Queued { .. } => unreachable!(),
CarState::WaitingToAdvance { .. } => unreachable!(),
CarState::Unparking(_, _, ref time_int) => time_int.end,
CarState::Parking(_, _, ref time_int) => time_int.end,
CarState::IdlingAtStop(_, ref time_int) => time_int.end,
}
}
pub fn time_spent_waiting(&self, now: Time) -> Duration {
match self {
CarState::Queued { blocked_since } | CarState::WaitingToAdvance { blocked_since } => {
now - *blocked_since
}
_ => Duration::ZERO,
}
}
}