mirror of
https://github.com/dcs-liberation/dcs_liberation.git
synced 2025-11-10 14:22:26 +00:00
0f34946127
This is the first step toward bundling all assets related to a save game into a single item. That makes it easier to avoid clobbering "temporary" assets from other games like the state.json, but also makes it easier for players to file bug reports, since there's only a single asset to upload. This is only the first step because so far it only includes the various save files: start of turn, end of last turn before results processing, and "latest" (the game saved explicitly by the player).
81 lines
2.7 KiB
Python
81 lines
2.7 KiB
Python
from __future__ import annotations
|
|
|
|
import json
|
|
from datetime import timedelta
|
|
from pathlib import Path
|
|
from typing import Optional, TYPE_CHECKING
|
|
|
|
from game.debriefing import Debriefing
|
|
from game.missiongenerator import MissionGenerator
|
|
from game.unitmap import UnitMap
|
|
from .aircraftsimulation import AircraftSimulation
|
|
from .missionresultsprocessor import MissionResultsProcessor
|
|
from ..profiling import logged_duration
|
|
|
|
if TYPE_CHECKING:
|
|
from game import Game
|
|
from .gameupdateevents import GameUpdateEvents
|
|
|
|
|
|
TICK = timedelta(seconds=1)
|
|
|
|
|
|
class SimulationAlreadyCompletedError(RuntimeError):
|
|
def __init__(self) -> None:
|
|
super().__init__("Simulation already completed")
|
|
|
|
|
|
class MissionSimulation:
|
|
def __init__(self, game: Game) -> None:
|
|
self.game = game
|
|
self.unit_map: Optional[UnitMap] = None
|
|
self.aircraft_simulation = AircraftSimulation(self.game)
|
|
self.completed = False
|
|
self.time = self.game.conditions.start_time
|
|
|
|
def begin_simulation(self) -> None:
|
|
self.time = self.game.conditions.start_time
|
|
self.aircraft_simulation.begin_simulation()
|
|
|
|
def tick(self, events: GameUpdateEvents) -> GameUpdateEvents:
|
|
self.time += TICK
|
|
if self.completed:
|
|
raise RuntimeError("Simulation already completed")
|
|
self.aircraft_simulation.on_game_tick(events, self.time, TICK)
|
|
self.completed = events.simulation_complete
|
|
return events
|
|
|
|
def generate_miz(self, output: Path) -> None:
|
|
with logged_duration("Mission generation"):
|
|
self.unit_map = MissionGenerator(self.game, self.time).generate_miz(output)
|
|
|
|
def debrief_current_state(
|
|
self, state_path: Path, force_end: bool = False
|
|
) -> Debriefing:
|
|
if self.unit_map is None:
|
|
raise RuntimeError(
|
|
"Simulation has no unit map. Results processing began before a mission "
|
|
"was generated."
|
|
)
|
|
|
|
with state_path.open("r", encoding="utf-8") as state_file:
|
|
data = json.load(state_file)
|
|
if force_end:
|
|
data["mission_ended"] = True
|
|
debriefing = Debriefing(data, self.game, self.unit_map)
|
|
debriefing.merge_simulation_results(self.aircraft_simulation.results)
|
|
return debriefing
|
|
|
|
def process_results(self, debriefing: Debriefing, events: GameUpdateEvents) -> None:
|
|
if self.unit_map is None:
|
|
raise RuntimeError(
|
|
"Simulation has no unit map. Results processing began before a mission "
|
|
"was generated."
|
|
)
|
|
|
|
self.game.save_last_turn_state()
|
|
MissionResultsProcessor(self.game).commit(debriefing, events)
|
|
|
|
def finish(self) -> None:
|
|
self.unit_map = None
|