dus-flughafen-foo/server.py
2023-10-15 23:08:14 +00:00

60 lines
1.9 KiB
Python

from seleniumwire import webdriver # Import from seleniumwire
from seleniumwire.utils import decode
from time import sleep
from collections import deque
import json
import re
options = webdriver.ChromeOptions()
options.add_argument('--headless')
options.add_argument("--incognito")
options.add_argument("--nogpu")
options.add_argument("--disable-gpu")
options.add_argument("--window-size=1280,1280")
options.add_argument("--no-sandbox")
options.add_argument("--enable-javascript")
options.add_argument('--disable-dev-shm-usage')
# Create a new instance of the Chrome driver
driver = webdriver.Chrome(options=options)
q = deque()
def interceptor(request, response): # A response interceptor takes two args
if 'ws-travis.dus.com/socket.io/?EIO=3&transport=polling' in request.url :
body = decode(response.body, response.headers.get('Content-Encoding', 'identity'))
x = re.split("\d\d\d:\d\d\/dus,", body.decode("utf-8"))
for i in [i for i in x if i]:
try:
j = json.loads(i)
handleJson(j)
except ValueError:
print ("\nErr: ", i, "\n")
if i.find("online-level") > 0:
j = json.loads(i[:i.rfind(']') + 1])
handleJson(j)
def handleJson(jsonObj):
if isinstance(jsonObj, list):
if 'online-level' in jsonObj:
typ = jsonObj[1]["LevelValues"][0]["Type"]
value = jsonObj[1]["LevelValues"][0]["Values"]
NmtId = jsonObj[1]["NmtId"]
time = jsonObj[1]["Time"]
q.append([typ, value, NmtId, time])
driver.response_interceptor = interceptor
driver.get('https://dus-travis.dus.com/')
while True:
sleep(1)
for i in range(1, len(q)):
a = q.popleft()
print ("[", a[3], "]: ", "NmtId: ", a[2] , " Typ: ", a[0], " Wert: ", a[1])