Changeset 829:0c8f22f0667a for src/mlx/web.py

Timestamp:

12/30/16 15:37:51 (7 years ago)

Author:

István Váradi <ivaradi@…>

Branch:

default

hg-Phase:

(<MercurialRepository 1 'hg:/home/ivaradi/mlx/hg' '/'>, 'public')

Message:

A PIREP can be queried from the server (re #307)

File:

• src/mlx/web.py (modified) (4 diffs)

src/mlx/web.py

@@ -7 +7 @@
 
 from common import MAVA_BASE_URL
+from pirep import PIREP
 
 import threading
@@ -257 +258 @@
             self.aircraftTypeName = \
                 BookedFlight.TYPE2TYPECODE[self.aircraftType]
+
+    def setupFromPIREPData(self, pirepData):
+        """Setup the booked flight from the given PIREP data."""
+        bookedFlightData = pirepData["bookedFlight"]
+
+        self.callsign = bookedFlightData["callsign"]
+
+        date = bookedFlightData["date"]
+
+        departureTime = bookedFlightData["departureTime"]
+        self.departureTime = BookedFlight.getDateTime(date, departureTime)
+
+        arrivalTime = bookedFlightData["arrivalTime"]
+        self.arrivalTime = BookedFlight.getDateTime(date, arrivalTime)
+        if self.arrivalTime<self.departureTime:
+            self.arrivalTime += datetime.timedelta(days = 1)
+
+        self.departureICAO = bookedFlightData["departureICAO"]
+        self.arrivalICAO = bookedFlightData["arrivalICAO"]
+
+        self.aircraftType = \
+          self._decodeAircraftType(bookedFlightData["aircraftType"])
+        self.tailNumber = bookedFlightData["tailNumber"]
+        self.numPassengers = int(bookedFlightData["numPassengers"])
+        self.numCrew = int(bookedFlightData["numCrew"])
+        self.bagWeight = int(bookedFlightData["bagWeight"])
+        self.cargoWeight = int(bookedFlightData["cargoWeight"])
+        self.mailWeight = int(bookedFlightData["mailWeight"])
+        self.route = bookedFlightData["route"]
 
     def writeIntoFile(self, f):
@@ -1242 +1272 @@
 #------------------------------------------------------------------------------
 
+class GetPIREP(RPCRequest):
+    """A request to retrieve the PIREP of a certain flight."""
+    def __init__(self, client, callback, flightID):
+        """Construct the request."""
+        super(GetPIREP, self).__init__(client, callback)
+        self._flightID = flightID
+
+    def run(self):
+        """Perform the update."""
+        result = Result()
+
+        pirepData = self._client.getPIREP(self._flightID)
+        print "pirepData:", pirepData
+
+        bookedFlight = BookedFlight()
+        bookedFlight.setupFromPIREPData(pirepData)
+
+        result.pirep = PIREP(None)
+        result.pirep.setupFromPIREPData(pirepData, bookedFlight)
+
+        return result
+
+#------------------------------------------------------------------------------
+
 class ReflyFlights(RPCRequest):
     """A request to mark certain flights for reflying."""
@@ -1351 +1405 @@
                                               callback, aircraftType))
 
+    def getPIREP(self, callback, flightID):
+        """Query the PIREP for the given flight."""
+        self._addRequest(GetPIREP(self._rpcClient, callback, flightID))
+
     def reflyFlights(self, callback, flightIDs):
         """Mark the flights with the given IDs for reflying."""