from .util import utf2unicode from .flight import Flight from .common import fixUnpickled from . import const import pickle as pickle import calendar import datetime import time #------------------------------------------------------------------------------ ## @package mlx.pirep # # The PIREP module. # # This module defines only one class, \ref PIREP. It is used to extract and # store the information needed for a PIREP. The saved PIREPs are pickled # instances of this class. #------------------------------------------------------------------------------ class PIREP(object): """A pilot's report of a flight.""" class Message(object): """A message belonging to the PIREP.""" @staticmethod def fromMessageData(messageData): """Construct a message from a JSON message data.""" message = messageData["message"] senderPID = messageData["senderPID"] senderName = messageData["senderName"] return PIREP.Message(message, senderPID, senderName) def __init__(self, message, senderPID, senderName): """Construct the message object.""" self.message = message self.senderPID = senderPID self.senderName = senderName _flightTypes = { const.FLIGHTTYPE_SCHEDULED : "SCHEDULED", const.FLIGHTTYPE_VIP : "VIP", const.FLIGHTTYPE_CHARTER : "CHARTER", const.FLIGHTTYPE_OLDTIMER : "OT" } @staticmethod def _formatLine(timeStr, line): """Format the given time string and line as needed for the ACARS and some other things.""" return "[" + timeStr + "]-[" + line + "]" @staticmethod def formatTimestampForRPC(t): """Format the given timestamp for RPC.""" return time.strftime("%Y-%m-%d %H:%M:%S", time.gmtime(t)) @staticmethod def parseTimestampFromRPC(s): """Format the given timestamp for RPC.""" dt = datetime.datetime.strptime(s, "%Y-%m-%d %H:%M:%S") return calendar.timegm(dt.utctimetuple()) @staticmethod def decodeFlightTypeText(s): """Decode the given flight type text.""" for (flighType, text) in PIREP._flightTypes.items(): if s==text: return flighType return const.FLIGHTTYPE_SCHEDULED @staticmethod def parseLogFromRPC(log): """Parse the given log coming from the RPC.""" index = 0 entries = [] inTimeStr = False inEntry = False timestr = "" entry = "" while index1: self.transition = star[1] self.transition.strip() else: self.transition = "" self.approachType = pirepData["approachType"] self.arrivalRunway = pirepData["arrivalRunway"] self.online = int(pirepData["online"])!=0 self.comments = pirepData["comments"] self.flightDefects = pirepData["flightDefects"] self.delayCodes = pirepData["timeComment"] if self.delayCodes=="UTC": self.delayCodes = [] else: self.delayCodes = self.delayCodes.split(", ") flightDate = pirepData["flightDate"] + " " self.blockTimeStart = \ PIREP.parseTimestampFromRPC(flightDate + pirepData["blockTimeStart"]) self.flightTimeStart = \ PIREP.parseTimestampFromRPC(flightDate + pirepData["flightTimeStart"]) self.flightTimeEnd = \ PIREP.parseTimestampFromRPC(flightDate + pirepData["flightTimeEnd"]) self.blockTimeEnd = \ PIREP.parseTimestampFromRPC(flightDate + pirepData["blockTimeEnd"]) self.flownDistance = float(pirepData["flownDistance"]) self.fuelUsed = float(pirepData["fuelUsed"]) # logger = flight.logger self.rating = float(pirepData["rating"]) log = pirepData["log"] self.logLines = PIREP.parseLogFromRPC(log)[1:] if self.logLines and \ (self.logLines[0][0]=="LOGGER NG LOG" or self.logLines[0][0]=="MAVA LOGGER X"): self.logLines = self.logLines[1:] numLogLines = len(self.logLines) lastFaultLineIndex = 0 self.faultLineIndexes = [] for ratingText in pirepData["ratingText"].splitlines()[:-1]: faultLines = PIREP.parseLogFromRPC(ratingText) for (timeStr, entry) in faultLines: for i in range(lastFaultLineIndex, numLogLines-1): if timeStr>=self.logLines[i][0] and \ timeStr