simulation.py

"""`Simulation` represents an airport simulation of a day on the given
parameters. `ClonedSimulation` is designed to be an immutable delegate of a
simulation that can be used for other objects to observe or predict the
simulation states.
"""
import time
import logging
import traceback
import importlib

from copy import deepcopy, copy
from clock import Clock, ClockException
from airport import Airport
from scenario import Scenario
from routing_expert import RoutingExpert
from analyst import Analyst
from utils import get_seconds_after
from uncertainty import Uncertainty
from config import Config
from state_logger import StateLogger


class Simulation:
    """Simulation, representing a simulation day, holds both static and dynamic
    states of the current airport, and implements `tick()` functions for the
    caller to simulation to the next state.
    """

    def __init__(self):

        params = Config.params

        # Setups the logger
        self.logger = logging.getLogger(__name__)

        # Setups the clock
        self.clock = Clock()

        # Sets up the airport
        airport_name = params["airport"]
        self.airport = Airport.create(airport_name)

        # Sets up the scenario
        self.scenario = Scenario.create(
            airport_name, self.airport.surface)

        # Sets up the routing expert monitoring the airport surface
        self.routing_expert = RoutingExpert(self.airport.surface.links,
                                            self.airport.surface.nodes,
                                            params["simulation"]["cache"])

        # Sets up the uncertainty module
        self.uncertainty = (Uncertainty(params["uncertainty"]["prob_hold"],
                                        params["uncertainty"]["speed_bias_sigma"],
                                        params["uncertainty"]["speed_bias_mu"])
                            if params["uncertainty"]["enabled"] else None)

        # Loads the requested scheduler
        self.scheduler = get_scheduler()

        if not params["simulator"]["test_mode"]:
            # Sets up the analyst
            self.analyst = Analyst(self)

            # Sets up the state logger
            self.state_logger = StateLogger()

        # Initializes the previous schedule time
        self.last_schedule_time = None

        # Initializes the last execution time for rescheduling to None
        self.last_schedule_exec_time = None

        self.__print_stats()

    def tick(self):
        """Moves the states of this simulation to the next state."""

        self.logger.debug("\nCurrent Time: %s", self.now)

        try:

            # # Reschedule happens before the tick. It will resolve conflict here
            # if self.__is_time_to_reschedule():
            #     self.logger.info("Time to reschedule")
            #     start = time.time()
            #     self.__reschedule()  # it will try to resolve conflict
            #     self.last_schedule_exec_time = time.time() - start  # seconds
            #     self.last_schedule_time = self.now
            #     self.logger.info("Last schedule time is updated to %s",
            #                      self.last_schedule_time)

            # Add aircraft
            self.airport.add_aircrafts(self.scenario, self.now,
                                       self.clock.sim_time, self.scheduler)

            start = time.time()
            self.__reschedule()  # it will try to resolve conflict
            self.last_schedule_exec_time = time.time() - start  # seconds
            self.last_schedule_time = self.now
            self.logger.info("Last schedule time is updated to %s",
                                self.last_schedule_time)

            # # Inject uncertainties
            # if self.uncertainty:
            #     self.uncertainty.inject(self)

            # Tick
            self.airport.tick()
            state = None
            aircrafts = self.airport.control_takeoff()
            if not Config.params["simulator"]["test_mode"]:
                state = self.state_logger.log_on_tick(self)
            self.clock.tick()

            # print(len(state["aircrafts"]))
            # if len(state["aircrafts"]) >= 1:
            #     print(state["aircrafts"][0]["callsign"] + " "+state["aircrafts"][0]["state"])

            # Remove aircraft close to the runway
            self.airport.remove_aircrafts(self.scenario)
            self.airport.remove_departure_aircrafts(aircrafts)
            # Abort on conflict
            conflicts, conflicts_dist = self.airport.conflicts
            if conflicts:
                for idx, conflict in enumerate(conflicts):
                    dist = conflicts_dist[idx]
                    print("Found %s", conflict)
                    print("Conflict distance: %d", dist)
                    print(conflict.detailed_description)
                    self.logger.error("Found %s", conflict)
                    self.logger.error("Conflict distance: %d", dist)
                    self.logger.error(conflict.detailed_description)
                    for aircraft in self.airport.aircrafts:
                        self.logger.error(aircraft)
                        print(aircraft.model)
                        aircraft.has_conflict = True
                # for conflict in conflicts:
                #     self.logger.error("Found %s", conflict)
                #     self.logger.error("Conflict distance: ", dist)
                #     self.logger.error(conflict.detailed_description)
                #     for aircraft in self.airport.aircrafts:
                #         self.logger.error(aircraft)

                # change color for crashing airplanes
                # print(pair[0].model, pair[1].model)
                # pair[0].has_conflict = True
                # pair[1].has_conflict = True
                
                # raise SimulationException("Conflict found")

            # Observe
            if not Config.params["simulator"]["test_mode"]:
                self.analyst.observe_on_tick(self)

            # return current state for streaming visualization
            return state

        except ClockException as error:
            # Finishes
            if not Config.params["simulator"]["test_mode"]:
                self.analyst.save()
            raise error
        except SimulationException as error:
            raise error
        except Exception as error:
            self.logger.error(traceback.format_exc())
            raise error

    def __is_time_to_reschedule(self):
        reschedule_cycle = Config.params["simulation"]["reschedule_cycle"]
        last_time = self.last_schedule_time
        next_time = (get_seconds_after(last_time, reschedule_cycle)
                     if last_time is not None else None)
        return last_time is None or next_time <= self.now

    def __reschedule(self):
        schedule, priority = self.scheduler.schedule(self)
        self.airport.apply_schedule(schedule)
        self.airport.apply_priority(priority)
        if not Config.params["simulator"]["test_mode"]:
            self.analyst.observe_on_reschedule(self)

    @property
    def now(self):
        """Return the current time of the simulation."""
        return self.clock.now

    def __print_stats(self):
        self.scenario.print_stats()
        self.airport.print_stats()

    def __getstate__(self):
        __dict = dict(self.__dict__)
        del __dict["logger"]
        __dict["uncertainty"] = None
        __dict["routing_expert"] = None
        return __dict

    def __setstate__(self, new_dict):
        self.__dict__.update(new_dict)

    def set_quiet(self, logger):
        """Sets the simulation and its subclass to quiet mode where the logger
        doesn't print that many stuff.
        """
        self.logger = logger
        self.airport.set_quiet(logger)
        self.scenario.set_quiet(logger)
        self.routing_expert.set_quiet(logger)

    @property
    def copy(self):
        """Obtains a immutable copy of this simulation."""
        # NOTE: If uncertainty is not None, call inject() in tick().
        return ClonedSimulation(self)


class ClonedSimulation:
    """ClonedSimulation is a copy of a `Simulation` object; however, it shares
    objects with the source `Simulation` object on immutable data objects in
    order to avoid the overhead in copying.
    The `tick()` function is divided into `pre_tick`, `tick`, and `post_tick`
    to allow the called (mainly the scheduler) to inject operations in between.
    """

    def __init__(self, simulation):

        self.clock = deepcopy(simulation.clock)
        self.airport = deepcopy(simulation.airport)
        self.scenario = copy(simulation.scenario)

        # Sets up the logger in quiet mode
        self.logger = logging.getLogger("QUIET_MODE")
        self.airport.set_quiet(self.logger)
        self.scenario.set_quiet(self.logger)

    def pre_tick(self, scheduler):
        """Adds aircraft before a tick."""
        self.airport.add_aircrafts(self.scenario, self.now,
                                   self.clock.sim_time, scheduler)

    def tick(self):
        """Turn off the logger, reschedule, and analyst."""
        self.logger.debug("\nPredicted Time: %s", self.now)
        self.airport.tick(True)
        try:
            self.clock.tick()
        except ClockException as error:
            raise error

    def post_tick(self):
        """Removes aircraft after a tick."""
        self.airport.remove_aircrafts(self.scenario)

    @property
    def now(self):
        """Returns simulated time of now."""
        return self.clock.now


def get_scheduler():
    """Loads the requested scheduler."""
    scheduler_name = Config.params["scheduler"]["name"]
    return importlib.import_module("scheduler." + scheduler_name).Scheduler()


class SimulationException(Exception):
    """Extends `Exception` for the simulation errors."""
    pass