summaryrefslogtreecommitdiff
path: root/bin
diff options
context:
space:
mode:
Diffstat (limited to 'bin')
-rwxr-xr-xbin/efa-gw75
1 files changed, 75 insertions, 0 deletions
diff --git a/bin/efa-gw b/bin/efa-gw
index 4b28828..ecec5f5 100755
--- a/bin/efa-gw
+++ b/bin/efa-gw
@@ -24,6 +24,80 @@ occupancy_cache = dict()
eva_to_name = dict()
+class EFA:
+ def __init__(self, url):
+ self.dm_url = url + "/XML_DM_REQUEST"
+ self.dm_post_data = {
+ "command": "",
+ "deleteAssignedStops_dm": "1",
+ "help": "Hilfe",
+ "itdLPxx_id_dm": ":dm",
+ "itdLPxx_mapState_dm": "",
+ "itdLPxx_mdvMap2_dm": "",
+ "itdLPxx_mdvMap_dm": "3406199:401077:NAV3",
+ "itdLPxx_transpCompany": "vrr",
+ "itdLPxx_view": "",
+ "language": "de",
+ "mode": "direct",
+ "nameInfo_dm": "invalid",
+ "nameState_dm": "empty",
+ "outputFormat": "JSON",
+ "ptOptionsActive": "1",
+ "requestID": "0",
+ "reset": "neue Anfrage",
+ "sessionID": "0",
+ "submitButton": "anfordern",
+ "typeInfo_dm": "invalid",
+ "type_dm": "stop",
+ "useProxFootSearch": "0",
+ "useRealtime": "1",
+ }
+
+ async def get_departures(self, place, name, ts):
+ self.dm_post_data.update(
+ {
+ "itdDateDay": ts.day,
+ "itdDateMonth": ts.month,
+ "itdDateYear": ts.year,
+ "itdTimeHour": ts.hour,
+ "itdTimeMinute": ts.minute,
+ "name_dm": name,
+ }
+ )
+ if place is None:
+ self.dm_post_data.pop("placeInfo_dm", None)
+ self.dm_post_data.pop("placeState_dm", None)
+ self.dm_post_data.pop("place_dm", None)
+ else:
+ self.dm_post_data.update(
+ {"placeInfo_dm": "invalid", "placeState_dm": "empty", "place_dm": place}
+ )
+ departures = list()
+ async with aiohttp.ClientSession() as session:
+ async with session.post(self.dm_url, data=self.dm_post_data) as response:
+ # EFA may return JSON with a text/html Content-Type, which response.json() does not like.
+ departures = json.loads(await response.text())
+
+ return departures
+
+
+async def get_departures(request):
+ efa_url = request.query.get("url", None)
+ place = request.query.get("place", None)
+ name = request.query.get("name", None)
+
+ if not efa_url:
+ return web.HTTPBadRequest(text="missing url=... parameter")
+ if not name:
+ return web.HTTPBadRequest(text="missing name=... parameter")
+
+ now = datetime.now()
+
+ reply = await EFA(efa_url).get_departures(place, name, now)
+
+ return web.Response(body=json.dumps(reply), headers=headers)
+
+
def get_occupancy(occupancy):
try:
return occupancy_map[occupancy]
@@ -92,6 +166,7 @@ if __name__ == "__main__":
eva_to_name[int(eva)] = name, optid
app = web.Application()
+ app.add_routes([web.get(f"{args.prefix}departures", get_departures)])
app.add_routes(
[web.get(f"{args.prefix}occupancy-by-eva/{{eva}}.json", get_occupancy_by_eva)]
)