mirror of
https://github.com/dcs-retribution/dcs-retribution.git
synced 2025-11-10 15:41:24 +00:00
6a5097659b
Also recreates all other flight-plans in the package to ensure JOIN, INGRESS & SPLIT are updated
110 lines
3.5 KiB
Python
110 lines
3.5 KiB
Python
from uuid import UUID
|
|
|
|
from dcs.mapping import LatLng, Point
|
|
from fastapi import APIRouter, Depends, HTTPException, status
|
|
from starlette.responses import Response
|
|
|
|
from game import Game
|
|
from game.ato import Flight
|
|
from game.ato.flightwaypoint import FlightWaypoint
|
|
from game.ato.flightwaypointtype import FlightWaypointType
|
|
from game.server import GameContext
|
|
from game.server.leaflet import LeafletPoint
|
|
from game.server.waypoints.models import FlightWaypointJs
|
|
from game.sim import GameUpdateEvents
|
|
from game.utils import meters
|
|
|
|
router: APIRouter = APIRouter(prefix="/waypoints")
|
|
|
|
|
|
def waypoints_for_flight(flight: Flight) -> list[FlightWaypointJs]:
|
|
departure = FlightWaypointJs.for_waypoint(
|
|
FlightWaypoint(
|
|
"TAKEOFF",
|
|
FlightWaypointType.TAKEOFF,
|
|
flight.departure.position,
|
|
meters(0),
|
|
"RADIO",
|
|
),
|
|
flight,
|
|
0,
|
|
)
|
|
return [departure] + [
|
|
FlightWaypointJs.for_waypoint(w, flight, i)
|
|
for i, w in enumerate(flight.flight_plan.waypoints, 1)
|
|
]
|
|
|
|
|
|
@router.get(
|
|
"/{flight_id}",
|
|
operation_id="list_all_waypoints_for_flight",
|
|
response_model=list[FlightWaypointJs],
|
|
)
|
|
def all_waypoints_for_flight(
|
|
flight_id: UUID, game: Game = Depends(GameContext.require)
|
|
) -> list[FlightWaypointJs]:
|
|
return waypoints_for_flight(game.db.flights.get(flight_id))
|
|
|
|
|
|
@router.post(
|
|
"/{flight_id}/{waypoint_idx}/position",
|
|
operation_id="set_waypoint_position",
|
|
status_code=status.HTTP_204_NO_CONTENT,
|
|
response_class=Response,
|
|
)
|
|
def set_position(
|
|
flight_id: UUID,
|
|
waypoint_idx: int,
|
|
position: LeafletPoint,
|
|
game: Game = Depends(GameContext.require),
|
|
) -> None:
|
|
from game.server import EventStream
|
|
|
|
flight = game.db.flights.get(flight_id)
|
|
if waypoint_idx == 0:
|
|
raise HTTPException(status_code=status.HTTP_403_FORBIDDEN)
|
|
|
|
waypoint = flight.flight_plan.waypoints[waypoint_idx - 1]
|
|
waypoint.position = Point.from_latlng(
|
|
LatLng(position.lat, position.lng), game.theater.terrain
|
|
)
|
|
package_model = (
|
|
GameContext.get_model()
|
|
.ato_model_for(flight.blue)
|
|
.find_matching_package_model(flight.package)
|
|
)
|
|
if package_model is None:
|
|
raise HTTPException(
|
|
status_code=status.HTTP_404_NOT_FOUND,
|
|
detail=f"Could not find PackageModel owning {flight}",
|
|
)
|
|
events = GameUpdateEvents()
|
|
update_package_waypoints_if_primary_flight(waypoint, flight, events)
|
|
package_model.update_tot()
|
|
EventStream.put_nowait(events.update_flight(flight))
|
|
|
|
|
|
def update_package_waypoints_if_primary_flight(
|
|
waypoint: FlightWaypoint,
|
|
flight: Flight,
|
|
events: GameUpdateEvents,
|
|
) -> None:
|
|
wpts = flight.package.waypoints
|
|
if flight is flight.package.primary_flight and wpts:
|
|
if waypoint.waypoint_type is FlightWaypointType.JOIN:
|
|
wpts.join = waypoint.position
|
|
elif waypoint.waypoint_type is FlightWaypointType.SPLIT:
|
|
wpts.split = waypoint.position
|
|
elif waypoint.waypoint_type is FlightWaypointType.REFUEL:
|
|
wpts.refuel = waypoint.position
|
|
elif "INGRESS" in waypoint.waypoint_type.name:
|
|
wpts.ingress = waypoint.position
|
|
wpts.initial = wpts.get_initial_point(
|
|
waypoint.position, flight.package.target.position
|
|
)
|
|
for f in flight.package.flights:
|
|
if f is flight:
|
|
continue
|
|
f.recreate_flight_plan()
|
|
events.update_flight(f)
|