Changeset 1074:638d4c261307

Timestamp:

02/14/23 14:27:21 (15 months ago)

Author:

István Váradi <ivaradi@…>

Branch:

python3

hg-Phase:

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

Message:

New RPC call to query the SimBrief results (re #362)

Location:

src/mlx

Files:

• rpc.py (modified) (2 diffs)
• web.py (modified) (3 diffs)

src/mlx/rpc.py

@@ -752 +752 @@
                      for typeCode in reply.value["typeCodes"]]
 
-            return (reply.value["name"], reply.value["rank"], types)
+            return (reply.value["name"], reply.value["rank"], types,
+                    self._sessionID)
         else:
             return None
@@ -869 +870 @@
                                                             tailNumber))
         return [BookedFlight(value) for value in values]
+
+    def getSimBriefResult(self, timestamp):
+        """Get the SimBrief results for the given timestamp."""
+        return self._performCall(lambda sessionID:
+                                 self._server.getSimBriefResult(sessionID,
+                                                                timestamp))
 
     def _performCall(self, callFn, acceptResults = []):

src/mlx/web.py

@@ -473 +473 @@
             result.rank = loginResult[1]
             result.types = loginResult[2]
+            result.sessionID = loginResult[3]
             result.password = password
             result.fleet = client.getFleet()
@@ -876 +877 @@
 #------------------------------------------------------------------------------
 
+class GetSimBriefResult(RPCRequest):
+    """Request the SimBrief result."""
+    def __init__(self, client, callback, timestamp):
+        """Construct the request with the given client and callback function."""
+        super(GetSimBriefResult, self).__init__(client, callback)
+        self._timestamp = timestamp
+
+    def run(self):
+        """Perform the request."""
+        result = Result()
+
+        result.result = self._client.getSimBriefResult(self._timestamp)
+
+        return result
+
+#------------------------------------------------------------------------------
+
 class Handler(threading.Thread):
     """The handler for the web services.
@@ -970 +988 @@
         self._addRequest(BookFlights(self._rpcClient, callback,
                                      flightIDs, date, tailNumber))
+
+    def getSimBriefResult(self, callback, timestamp):
+        """Enqueue a request to get the SimBrief result."""
+        self._addRequest(GetSimBriefResult(self._rpcClient, callback,
+                                           timestamp))
 
     def run(self):