summaryrefslogtreecommitdiff
path: root/main.py
diff options
context:
space:
mode:
authorAndré Glüpker <git@wgmd.de>2022-10-08 20:40:02 +0200
committerAndré Glüpker <git@wgmd.de>2022-10-08 20:42:27 +0200
commit75d015d3389c7a7f105c77a68291f293b5cdd4a0 (patch)
treea90f1ca1055fce340a88220bc7a76c73c3dec6d8 /main.py
parent12b10b204c59ef16ca7dd793ee7724f93e8136d3 (diff)
downloadsteam-75d015d3389c7a7f105c77a68291f293b5cdd4a0.tar.gz
steam-75d015d3389c7a7f105c77a68291f293b5cdd4a0.tar.bz2
steam-75d015d3389c7a7f105c77a68291f293b5cdd4a0.zip
Format with black
Diffstat (limited to 'main.py')
-rwxr-xr-xmain.py202
1 files changed, 126 insertions, 76 deletions
diff --git a/main.py b/main.py
index e39eb5f..5fd96a1 100755
--- a/main.py
+++ b/main.py
@@ -11,6 +11,7 @@ import os
import re
import sys
import time, datetime
+
# import traceback
import logging
@@ -19,13 +20,13 @@ from QueryServer import QueryServer
# Set some directories
THIS_DIR = os.path.dirname(os.path.abspath(__file__))
-TEMPLATES = os.path.join(THIS_DIR, 'templates')
-ASSETS = os.path.join(THIS_DIR, 'assets')
-CONFIG = os.path.join(THIS_DIR, 'config')
+TEMPLATES = os.path.join(THIS_DIR, "templates")
+ASSETS = os.path.join(THIS_DIR, "assets")
+CONFIG = os.path.join(THIS_DIR, "config")
app = Flask(__name__)
steam = None
-with open(os.path.join(CONFIG, 'secrets.json'), 'rt') as secretjson:
+with open(os.path.join(CONFIG, "secrets.json"), "rt") as secretjson:
secrets = json.load(secretjson)
app.secret_key = secrets["flask_secret"]
steam = SteamAPI(secrets["steam_token"])
@@ -35,16 +36,18 @@ with open(os.path.join(CONFIG, 'secrets.json'), 'rt') as secretjson:
##################################################
intervals = (
- ('w', 604800), # 60 * 60 * 24 * 7
- ('d', 86400), # 60 * 60 * 24
- ('h', 3600), # 60 * 60
- ('m', 60),
- ('s', 1),
- )
+ ("w", 604800), # 60 * 60 * 24 * 7
+ ("d", 86400), # 60 * 60 * 24
+ ("h", 3600), # 60 * 60
+ ("m", 60),
+ ("s", 1),
+)
+
def display_time(timestamp, format="%d.%m.%Y"):
return datetime.datetime.fromtimestamp(timestamp).strftime(format)
+
def display_age(seconds, granularity=2):
result = []
for name, count in intervals:
@@ -52,50 +55,58 @@ def display_age(seconds, granularity=2):
if value:
seconds -= value * count
if value == 1:
- name = name.rstrip('s')
+ name = name.rstrip("s")
result.append("{}{}".format(int(value), name))
- return ' '.join(result[:granularity])
+ return " ".join(result[:granularity])
+
+
+app.jinja_env.filters["display_time"] = display_time
+app.jinja_env.filters["display_age"] = display_age
-app.jinja_env.filters['display_time'] = display_time
-app.jinja_env.filters['display_age'] = display_age
def grepSteamids(text):
steamids = []
- SteamIDfromText = re.findall(r'STEAM_\d:(\d):(\d+)', text)
+ SteamIDfromText = re.findall(r"STEAM_\d:(\d):(\d+)", text)
for steamid in SteamIDfromText:
steam64id = 76561197960265728 + int(steamid[0]) + (int(steamid[1]) * 2)
steamids.append(steam64id)
return steamids
+
##################################################
## Functions for different pages
##################################################
+
@app.route("/")
def main():
- return redirect(url_for('lobby'))
+ return redirect(url_for("lobby"))
+
@app.errorhandler(404)
def not_found(e):
- return render_template('error.jinja', error = 'Die angeforderte Seite konnte nicht gefunden werden.')
+ return render_template(
+ "error.jinja", error="Die angeforderte Seite konnte nicht gefunden werden."
+ )
+
@app.route("/lobby")
def lobby():
steamids = dict()
- friends = request.args.get('friends')
+ friends = request.args.get("friends")
if friends:
- friendList = friends.split(',')
+ friendList = friends.split(",")
profiles = steam.getMultipleFriends(friendList)
for steamid, profile in profiles.items():
- for friendid in profile['friends']:
+ for friendid in profile["friends"]:
if friendid in steamids:
- steamids[friendid]['main'] += ', ' + profile['personaname']
+ steamids[friendid]["main"] += ", " + profile["personaname"]
else:
- steamids[friendid] = {'main': profile['personaname']}
+ steamids[friendid] = {"main": profile["personaname"]}
else:
# Load config (steamids, names)
- with open(os.path.join(CONFIG, 'lobby.json'), 'rt') as config:
+ with open(os.path.join(CONFIG, "lobby.json"), "rt") as config:
steamids = json.load(config)
gamelist = steam.getGames()
@@ -110,16 +121,15 @@ def lobby():
serverinfo = dict()
for steamid, playerdata in steamids.items():
- if 'gameid' not in playerdata \
- or 'gameserverip' not in playerdata:
- continue
- if ':' not in playerdata['gameserverip']:
+ if "gameid" not in playerdata or "gameserverip" not in playerdata:
continue
- gameserver = playerdata['gameserverip']
+ if ":" not in playerdata["gameserverip"]:
+ continue
+ gameserver = playerdata["gameserverip"]
if gameserver not in serverinfo:
- ip, port = gameserver.split(':')
+ ip, port = gameserver.split(":")
port = int(port)
- gameid = playerdata['gameid']
+ gameid = playerdata["gameid"]
# print('Query Server:', ip, port, gameid)
server = QueryServer.QueryServer(ip, port, gameid)
# print('Response:', server)
@@ -127,33 +137,63 @@ def lobby():
serverinfo[gameserver] = server
# Sort steamids to be more appealing
- steamids = OrderedDict(sorted(steamids.items(), key = lambda player: player[1]['personaname'].lower()))
- steamids = OrderedDict(sorted(steamids.items(), reverse=True, key = lambda player: int(player[1]['lastlogoff'])))
- steamids = OrderedDict(sorted(steamids.items(), key = lambda player: (player[1]['personastate'] > 0) and player[1]['personastate'] or 10))
- steamids = OrderedDict(sorted(steamids.items(), key = lambda player: ('gameid' in player[1] and player[1]['gameid'] or "zzz")))
-
- return render_template('lobby_html.jinja',
- steamids = steamids,
- serverinfo = serverinfo,
- gamelist = gamelist,
- states = ['Offline', 'Online', 'Busy', 'Away', 'Snooze', 'Looking to trade', 'Looking to play'],
- current_time = time.time())
-
-@app.route("/premadefinder", methods=['GET', 'POST'])
+ steamids = OrderedDict(
+ sorted(steamids.items(), key=lambda player: player[1]["personaname"].lower())
+ )
+ steamids = OrderedDict(
+ sorted(
+ steamids.items(),
+ reverse=True,
+ key=lambda player: int(player[1]["lastlogoff"]),
+ )
+ )
+ steamids = OrderedDict(
+ sorted(
+ steamids.items(),
+ key=lambda player: (player[1]["personastate"] > 0)
+ and player[1]["personastate"]
+ or 10,
+ )
+ )
+ steamids = OrderedDict(
+ sorted(
+ steamids.items(),
+ key=lambda player: ("gameid" in player[1] and player[1]["gameid"] or "zzz"),
+ )
+ )
+
+ return render_template(
+ "lobby_html.jinja",
+ steamids=steamids,
+ serverinfo=serverinfo,
+ gamelist=gamelist,
+ states=[
+ "Offline",
+ "Online",
+ "Busy",
+ "Away",
+ "Snooze",
+ "Looking to trade",
+ "Looking to play",
+ ],
+ current_time=time.time(),
+ )
+
+
+@app.route("/premadefinder", methods=["GET", "POST"])
def premades():
- steamids = []
+ steamids = []
premadedata = dict()
connections = set()
- if request.method == 'POST':
- postdata = request.form['statustext']
+ if request.method == "POST":
+ postdata = request.form["statustext"]
steamids = grepSteamids(postdata)
steamids = [str(x) for x in steamids]
if len(steamids) > 50:
return render_template(
- 'error.jinja',
- error='Es sind maximal 50 Steamids erlaubt.'
+ "error.jinja", error="Es sind maximal 50 Steamids erlaubt."
)
# Ask steam about profiles
@@ -162,60 +202,70 @@ def premades():
# Add connection between friends.
# Friends are always bidirectional, so we use set and min/max to avoid duplicates
for steamid in steamids:
- for friend in premadedata[steamid]['_friends']:
+ for friend in premadedata[steamid]["_friends"]:
if friend in steamids:
friend_a = min(steamid, friend)
friend_b = max(steamid, friend)
connections.add((friend_a, friend_b))
- return render_template('premades_html.jinja',
- steamids=steamids,
- profiles=premadedata,
- current_time = time.time(),
- connections=connections
- )
+ return render_template(
+ "premades_html.jinja",
+ steamids=steamids,
+ profiles=premadedata,
+ current_time=time.time(),
+ connections=connections,
+ )
+
-@app.route("/server", methods=['GET'])
+@app.route("/server", methods=["GET"])
def server():
- with open(os.path.join(CONFIG, 'server.json'), 'rt') as config:
+ with open(os.path.join(CONFIG, "server.json"), "rt") as config:
servers = json.load(config)
executor = ThreadPoolExecutor(max_workers=10)
serverdata_ = dict()
for _, serverdata in servers.items():
- name = "{0}{1:d}{2:d}".format(serverdata['ip'], serverdata['port'], serverdata['gameid'])
+ name = "{0}{1:d}{2:d}".format(
+ serverdata["ip"], serverdata["port"], serverdata["gameid"]
+ )
serverdata_[name] = executor.submit(
QueryServer.QueryServer,
- serverdata['ip'],
- serverdata['port'],
- serverdata['gameid']
+ serverdata["ip"],
+ serverdata["port"],
+ serverdata["gameid"],
)
for _, serverdata in servers.items():
- name = "{0}{1:d}{2:d}".format(serverdata['ip'], serverdata['port'], serverdata['gameid'])
- serverdata['data'] = serverdata_[name].result()
- if serverdata['data']:
- serverdata_['u' + name] = executor.submit(
+ name = "{0}{1:d}{2:d}".format(
+ serverdata["ip"], serverdata["port"], serverdata["gameid"]
+ )
+ serverdata["data"] = serverdata_[name].result()
+ if serverdata["data"]:
+ serverdata_["u" + name] = executor.submit(
steam.getGameUpdateState,
- serverdata['data']['gameid'],
- serverdata['data']['gameversion'],
+ serverdata["data"]["gameid"],
+ serverdata["data"]["gameversion"],
)
for _, serverdata in servers.items():
- name = "{0}{1:d}{2:d}".format(serverdata['ip'], serverdata['port'], serverdata['gameid'])
- if 'u' + name in serverdata_:
- serverdata['update'] = serverdata_['u' + name].result()
+ name = "{0}{1:d}{2:d}".format(
+ serverdata["ip"], serverdata["port"], serverdata["gameid"]
+ )
+ if "u" + name in serverdata_:
+ serverdata["update"] = serverdata_["u" + name].result()
+
+ return render_template(
+ "server_html.jinja",
+ servers=servers,
+ )
- return render_template('server_html.jinja',
- servers=servers,
- )
-if __name__ == '__main__':
+if __name__ == "__main__":
# print(steam.getFriends("76561197963063991"))
# print(steam.getFriends("76561197963882989"))
- logging.basicConfig(filename='./main.log', level=logging.INFO)
+ logging.basicConfig(filename="./main.log", level=logging.INFO)
- app.config['TEMPLATES_AUTO_RELOAD'] = True
+ app.config["TEMPLATES_AUTO_RELOAD"] = True
app.run(threaded=True)
# Changelog