game/sandbox/

time_warp.rs

use anyhow::Result;
use instant::Instant;

use crate::ID;
use abstutil::prettyprint_usize;
use geom::{Duration, Polygon, Pt2D, Ring, Time};
use map_gui::render::DrawOptions;
use map_gui::tools::grey_out_map;
use widgetry::tools::PopupMsg;
use widgetry::{
    Choice, DrawBaselayer, EventCtx, GeomBatch, GfxCtx, Key, Line, Outcome, Panel, PanelDims,
    Slider, State, TabController, Text, Toggle, UpdateType, Widget,
};

use crate::app::{App, FindDelayedIntersections, ShowEverything, Transition};
use crate::common::Warping;
use crate::sandbox::{GameplayMode, SandboxMode};

// TODO Text entry would be great
pub struct JumpToTime {
    panel: Panel,
    target: Time,
    maybe_mode: Option<GameplayMode>,
    tabs: TabController,
}

impl JumpToTime {
    pub fn new_state(
        ctx: &mut EventCtx,
        app: &App,
        maybe_mode: Option<GameplayMode>,
    ) -> Box<dyn State<App>> {
        let target = app.primary.sim.time();
        let end_of_day = app.primary.sim.get_end_of_day();

        let jump_to_time_btn = ctx
            .style()
            .btn_tab
            .text("Jump to time")
            .hotkey(Key::T)
            .tooltip("Jump to time");
        let jump_to_time_content = {
            // TODO Auto-fill width?
            let slider_width = 500.0;

            Widget::col(vec![
                Line("Jump to what time?").small_heading().into_widget(ctx),
                if app.has_prebaked().is_some() {
                    match area_under_curve(
                        app.prebaked().active_agents(end_of_day),
                        slider_width,
                        50.0,
                    ) {
                        Ok(polygon) => {
                            GeomBatch::from(vec![(ctx.style().icon_fg.alpha(0.7), polygon)])
                                .into_widget(ctx)
                        }

                        Err(err) => {
                            warn!("Not drawing area under curve: {err}");
                            Widget::nothing()
                        }
                    }
                } else {
                    Widget::nothing()
                },
                Slider::area(
                    ctx,
                    slider_width,
                    target.to_percent(end_of_day).min(1.0),
                    "time slider",
                ),
                build_jump_to_time_btn(ctx, target),
            ])
        };

        let jump_to_delay_btn = ctx
            .style()
            .btn_tab
            .text("Jump to delay")
            .hotkey(Key::D)
            .tooltip("Jump to delay");
        let jump_to_delay_content = Widget::col(vec![
            Widget::row(vec![
                Line("Jump to next").small_heading().into_widget(ctx),
                Widget::dropdown(
                    ctx,
                    "delay",
                    app.opts.jump_to_delay,
                    vec![
                        Choice::new("1", Duration::minutes(1)),
                        Choice::new("2", Duration::minutes(2)),
                        Choice::new("5", Duration::minutes(5)),
                        Choice::new("10", Duration::minutes(10)),
                    ],
                ),
                Line("minute delay").small_heading().into_widget(ctx),
            ]),
            build_jump_to_delay_button(ctx, app.opts.jump_to_delay),
        ]);

        let mut tabs = TabController::new("jump_to_time_tabs");
        tabs.push_tab(jump_to_time_btn, jump_to_time_content);
        tabs.push_tab(jump_to_delay_btn, jump_to_delay_content);

        Box::new(JumpToTime {
            target,
            maybe_mode,
            panel: Panel::new_builder(Widget::col(vec![
                ctx.style().btn_close_widget(ctx),
                tabs.build_widget(ctx),
            ]))
            .dims_width(PanelDims::ExactPixels(640.0))
            .dims_height(PanelDims::ExactPixels(360.0))
            .build(ctx),
            tabs,
        })
    }
}

impl State<App> for JumpToTime {
    fn event(&mut self, ctx: &mut EventCtx, app: &mut App) -> Transition {
        match self.panel.event(ctx) {
            Outcome::Clicked(x) => match x.as_ref() {
                "close" => {
                    return Transition::Pop;
                }
                "jump to time" => {
                    if self.target < app.primary.sim.time() {
                        if let Some(mode) = self.maybe_mode.take() {
                            let target_time = self.target;
                            return Transition::Replace(SandboxMode::async_new(
                                app,
                                mode,
                                Box::new(move |ctx, app| {
                                    vec![Transition::Push(TimeWarpScreen::new_state(
                                        ctx,
                                        app,
                                        target_time,
                                        None,
                                    ))]
                                }),
                            ));
                        } else {
                            return Transition::Replace(PopupMsg::new_state(
                                ctx,
                                "Error",
                                vec!["Sorry, you can't go rewind time from this mode."],
                            ));
                        }
                    }
                    return Transition::Replace(TimeWarpScreen::new_state(
                        ctx,
                        app,
                        self.target,
                        None,
                    ));
                }
                "jump to delay" => {
                    let delay = self.panel.dropdown_value("delay");
                    app.opts.jump_to_delay = delay;
                    return Transition::Replace(TimeWarpScreen::new_state(
                        ctx,
                        app,
                        app.primary.sim.get_end_of_day(),
                        Some(delay),
                    ));
                }
                action => {
                    if self.tabs.handle_action(ctx, action, &mut self.panel) {
                        // if true, tabs has handled the action
                    } else {
                        unreachable!("unhandled action: {}", action)
                    }
                }
            },
            // TODO check what changed...
            Outcome::Changed(_) => {
                if self.tabs.active_tab_idx() == 1 {
                    self.panel.replace(
                        ctx,
                        "jump to delay",
                        build_jump_to_delay_button(ctx, self.panel.dropdown_value("delay")),
                    );
                }
            }
            _ => {}
        }

        if self.tabs.active_tab_idx() == 0 {
            let target = app
                .primary
                .sim
                .get_end_of_day()
                .percent_of(self.panel.slider("time slider").get_percent())
                .round_seconds(600.0);
            if target != self.target {
                self.target = target;
                self.panel
                    .replace(ctx, "jump to time", build_jump_to_time_btn(ctx, target));
            }
        }

        if self.panel.clicked_outside(ctx) {
            return Transition::Pop;
        }

        Transition::Keep
    }

    fn draw(&self, g: &mut GfxCtx, app: &App) {
        grey_out_map(g, app);
        self.panel.draw(g);
    }
}

// Display a nicer screen for jumping forwards in time, allowing cancellation.
pub struct TimeWarpScreen {
    target: Time,
    wall_time_started: Instant,
    sim_time_started: geom::Time,
    halt_upon_delay: Option<Duration>,
    panel: Panel,
}

impl TimeWarpScreen {
    pub fn new_state(
        ctx: &mut EventCtx,
        app: &mut App,
        target: Time,
        mut halt_upon_delay: Option<Duration>,
    ) -> Box<dyn State<App>> {
        if let Some(halt_limit) = halt_upon_delay {
            if app.primary.sim_cb.is_none() {
                app.primary.sim_cb = Some(Box::new(FindDelayedIntersections {
                    halt_limit,
                    report_limit: halt_limit,
                    currently_delayed: Vec::new(),
                }));
                // TODO Can we get away with less frequently? Not sure about all the edge cases
                app.primary.sim.set_periodic_callback(Duration::minutes(1));
            } else {
                halt_upon_delay = None;
            }
        }

        Box::new(TimeWarpScreen {
            target,
            wall_time_started: Instant::now(),
            sim_time_started: app.primary.sim.time(),
            halt_upon_delay,
            panel: Panel::new_builder(
                Widget::col(vec![
                    Widget::placeholder(ctx, "text"),
                    Toggle::checkbox(
                        ctx,
                        "skip drawing (for faster simulations)",
                        Key::Space,
                        app.opts.dont_draw_time_warp,
                    )
                    .named("don't draw"),
                    ctx.style()
                        .btn_outline
                        .text("stop now")
                        .hotkey(Key::Escape)
                        .build_def(ctx)
                        .centered_horiz(),
                ])
                // hardcoded width avoids jiggle due to text updates
                .force_width(700.0),
            )
            .build(ctx),
        })
    }
}

impl State<App> for TimeWarpScreen {
    fn event(&mut self, ctx: &mut EventCtx, app: &mut App) -> Transition {
        if ctx.input.nonblocking_is_update_event().is_some() {
            ctx.input.use_update_event();
            app.primary.sim.time_limited_step(
                &app.primary.map,
                self.target - app.primary.sim.time(),
                Duration::seconds(0.033),
                &mut app.primary.sim_cb,
            );
            #[allow(clippy::never_loop)]
            for (t, maybe_i, alert) in app.primary.sim.clear_alerts() {
                // TODO Just the first :(
                return Transition::Replace(PopupMsg::new_state(
                    ctx,
                    "Alert",
                    vec![format!("At {}, near {:?}, {}", t, maybe_i, alert)],
                ));
            }
            if let Some(ref mut cb) = app.primary.sim_cb {
                let di = cb.downcast_mut::<FindDelayedIntersections>().unwrap();
                if let Some((i, t)) = di.currently_delayed.get(0) {
                    if app.primary.sim.time() - *t > di.halt_limit {
                        let id = ID::Intersection(*i);
                        app.primary.layer =
                            Some(Box::new(crate::layer::traffic::TrafficJams::new(ctx, app)));
                        return Transition::Replace(Warping::new_state(
                            ctx,
                            app.primary.canonical_point(id.clone()).unwrap(),
                            Some(10.0),
                            Some(id),
                            &mut app.primary,
                        ));
                    }
                }
            }

            let now = app.primary.sim.time();
            let (finished_after, _) = app.primary.sim.num_trips();
            let finished_before = if app.has_prebaked().is_some() {
                let mut cnt = 0;
                for (t, _, _, _) in &app.prebaked().finished_trips {
                    if *t > now {
                        break;
                    }
                    cnt += 1;
                }
                Some(cnt)
            } else {
                None
            };

            let elapsed_sim_time = now - self.sim_time_started;
            let elapsed_wall_time = Duration::realtime_elapsed(self.wall_time_started);
            let txt = Text::from_multiline(vec![
                // I'm covered in shame for not doing this from the start.
                Line("Let's do the time warp again!").small_heading(),
                Line(format!(
                    "{} / {}",
                    now.ampm_tostring(),
                    self.target.ampm_tostring()
                )),
                Line(format!(
                    "Speed: {}x",
                    prettyprint_usize((elapsed_sim_time / elapsed_wall_time) as usize)
                )),
                if let Some(n) = finished_before {
                    // TODO Underline
                    Line(format!(
                        "Finished trips: {} ({} compared to before \"{}\")",
                        prettyprint_usize(finished_after),
                        compare_count(finished_after, n),
                        app.primary.map.get_edits().edits_name,
                    ))
                } else {
                    Line(format!(
                        "Finished trips: {}",
                        prettyprint_usize(finished_after)
                    ))
                },
            ]);

            self.panel.replace(ctx, "text", txt.into_widget(ctx));
        }
        // >= because of the case of resetting to midnight. GameplayMode::initialize takes a tiny
        // step past midnight after spawning things, so that agents initially appear on the map.
        if app.primary.sim.time() >= self.target {
            return Transition::Pop;
        }

        match self.panel.event(ctx) {
            Outcome::Changed(_) => {
                app.opts.dont_draw_time_warp = self.panel.is_checked("don't draw");
            }
            Outcome::Clicked(x) => match x.as_ref() {
                "stop now" => {
                    return Transition::Pop;
                }
                _ => unreachable!(),
            },
            _ => {}
        }
        if self.panel.clicked_outside(ctx) {
            return Transition::Pop;
        }

        ctx.request_update(UpdateType::Game);
        Transition::Keep
    }

    fn draw_baselayer(&self) -> DrawBaselayer {
        DrawBaselayer::Custom
    }

    fn draw(&self, g: &mut GfxCtx, app: &App) {
        if app.opts.dont_draw_time_warp {
            g.clear(app.cs.inner_panel_bg);
        } else {
            app.draw(g, DrawOptions::new(), &ShowEverything::new());
            grey_out_map(g, app);
        }

        self.panel.draw(g);
    }

    fn on_destroy(&mut self, _: &mut EventCtx, app: &mut App) {
        if self.halt_upon_delay.is_some() {
            assert!(app.primary.sim_cb.is_some());
            app.primary.sim_cb = None;
            app.primary.sim.unset_periodic_callback();
        }
    }
}

fn area_under_curve(raw: Vec<(Time, usize)>, width: f64, height: f64) -> Result<Polygon> {
    assert!(!raw.is_empty());
    let min_x = Time::START_OF_DAY;
    let min_y = 0;
    let max_x = raw.last().unwrap().0;
    let max_y = raw.iter().max_by_key(|(_, cnt)| *cnt).unwrap().1;

    let mut pts = Vec::new();
    for (t, cnt) in raw {
        pts.push(lttb::DataPoint::new(
            width * (t - min_x) / (max_x - min_x),
            height * (1.0 - (((cnt - min_y) as f64) / ((max_y - min_y) as f64))),
        ));
    }
    let mut downsampled = Vec::new();
    for pt in lttb::lttb(pts, 100) {
        downsampled.push(Pt2D::new(pt.x, pt.y));
    }
    downsampled.push(Pt2D::new(width, height));
    downsampled.push(downsampled[0]);

    Ring::deduping_new(downsampled).map(|ring| ring.into_polygon())
}

// TODO Maybe color, put in helpers
fn compare_count(after: usize, before: usize) -> String {
    match after.cmp(&before) {
        std::cmp::Ordering::Equal => "+0".to_string(),
        std::cmp::Ordering::Greater => {
            format!("+{}", prettyprint_usize(after - before))
        }
        std::cmp::Ordering::Less => {
            format!("-{}", prettyprint_usize(before - after))
        }
    }
}

fn build_jump_to_time_btn(ctx: &EventCtx, target: Time) -> Widget {
    ctx.style()
        .btn_solid_primary
        .text(format!("Jump to {}", target.ampm_tostring()))
        .hotkey(Key::Enter)
        .build_widget(ctx, "jump to time")
        .centered_horiz()
        .margin_above(16)
}

fn build_jump_to_delay_button(ctx: &EventCtx, delay: Duration) -> Widget {
    ctx.style()
        .btn_solid_primary
        .text(format!("Jump to next {} delay", delay))
        .hotkey(Key::Enter)
        .build_widget(ctx, "jump to delay")
        .centered_horiz()
        .margin_above(16)
}