Add Steam info
This commit is contained in:
@@ -2,6 +2,7 @@ import os
|
|||||||
import magic
|
import magic
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
from htmlmin import minify
|
from htmlmin import minify
|
||||||
|
from time import time
|
||||||
from datetime import datetime, timedelta
|
from datetime import datetime, timedelta
|
||||||
from musicbrainzngs import get_image_front
|
from musicbrainzngs import get_image_front
|
||||||
from flask import (
|
from flask import (
|
||||||
@@ -14,6 +15,25 @@ from flask import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
from .modules.api.lb import listens, listening
|
from .modules.api.lb import listens, listening
|
||||||
|
from .modules.api.steam import recent, owned
|
||||||
|
|
||||||
|
def tmsmp(sec: int) -> str:
|
||||||
|
if sec < 60:
|
||||||
|
return f"{sec} s"
|
||||||
|
elif sec < 60*60:
|
||||||
|
return f"{sec/60:.1f} m"
|
||||||
|
elif sec < 60*60*24:
|
||||||
|
return f"{sec/60/60:.1f} h"
|
||||||
|
else:
|
||||||
|
return f"{sec/60/60/24:.1f} d"
|
||||||
|
|
||||||
|
def utmsmp(unix: int) -> str:
|
||||||
|
return datetime \
|
||||||
|
.utcfromtimestamp(unix) \
|
||||||
|
.strftime('%Y-%m-%d %H:%M:%S')
|
||||||
|
|
||||||
|
def rtmsmp(unix: int) -> str:
|
||||||
|
return tmsmp(int(time() - unix))
|
||||||
|
|
||||||
bp = Blueprint(
|
bp = Blueprint(
|
||||||
"risdeveau",
|
"risdeveau",
|
||||||
@@ -47,6 +67,16 @@ def mb_cover(mbid):
|
|||||||
.strftime('%a, %d %b %Y %H:%M:%S GMT')
|
.strftime('%a, %d %b %Y %H:%M:%S GMT')
|
||||||
return r
|
return r
|
||||||
|
|
||||||
|
args = {
|
||||||
|
"lb": listens,
|
||||||
|
"lb_now": listening,
|
||||||
|
"recent": recent,
|
||||||
|
"owned": owned,
|
||||||
|
"tmsmp": tmsmp,
|
||||||
|
"utmsmp": utmsmp,
|
||||||
|
"rtmsmp": rtmsmp
|
||||||
|
}
|
||||||
|
|
||||||
@bp.route("/")
|
@bp.route("/")
|
||||||
def index():
|
def index():
|
||||||
return render_tmpl('index.html', lb=listens, lb_now=listening)
|
return render_tmpl('index.html', **args)
|
||||||
|
|||||||
@@ -0,0 +1,71 @@
|
|||||||
|
from os import environ
|
||||||
|
from flask import Flask, jsonify
|
||||||
|
from apscheduler.schedulers.background import BackgroundScheduler
|
||||||
|
from apscheduler.triggers.interval import IntervalTrigger
|
||||||
|
import requests
|
||||||
|
from time import time
|
||||||
|
import atexit
|
||||||
|
import re
|
||||||
|
from urllib.parse import urlparse, parse_qs
|
||||||
|
|
||||||
|
TOKEN = environ.get("STEAM_TOKEN")
|
||||||
|
MY_ID = 76561198826355942
|
||||||
|
|
||||||
|
recent = {}
|
||||||
|
owned = {}
|
||||||
|
|
||||||
|
def modify_game_list(json: dict) -> dict:
|
||||||
|
if 'games' in json.keys():
|
||||||
|
apps = (3301060, 404790, 1281930, 1920960, 1325960, 431960)
|
||||||
|
new_games = []
|
||||||
|
for i, g in enumerate(json['games']):
|
||||||
|
if g['appid'] not in apps:
|
||||||
|
json['games'][i]['h_cover'] = f"https://shared.fastly.steamstatic.com/store_item_assets//steam/apps/{g['appid']}/header.jpg"
|
||||||
|
json['games'][i]['v_cover'] = f"https://shared.fastly.steamstatic.com/store_item_assets//steam/apps/{g['appid']}/library_600x900.jpg"
|
||||||
|
new_games.append(json['games'][i])
|
||||||
|
json['games'] = new_games
|
||||||
|
return json
|
||||||
|
|
||||||
|
def steam_request(interface: str, method: str, v: int = 1, **kwargs) -> requests.Response:
|
||||||
|
return requests.get(
|
||||||
|
f"https://api.steampowered.com/{interface}/{method}/v{v:04}/",
|
||||||
|
params=dict({"key": TOKEN}, **kwargs),
|
||||||
|
timeout=10
|
||||||
|
)
|
||||||
|
|
||||||
|
def api_request(cache, *args, **kwargs):
|
||||||
|
try:
|
||||||
|
response = steam_request(*args, **kwargs)
|
||||||
|
if response.status_code == 200:
|
||||||
|
cache.update({
|
||||||
|
'data': modify_game_list(response.json().get("response")),
|
||||||
|
'last_updated': time(),
|
||||||
|
'status': 'success'
|
||||||
|
})
|
||||||
|
else:
|
||||||
|
cache['status'] = f'error: {response.status_code}'
|
||||||
|
except Exception as e:
|
||||||
|
cache['status'] = f'error: {str(e)}'
|
||||||
|
|
||||||
|
if TOKEN:
|
||||||
|
scheduler = BackgroundScheduler()
|
||||||
|
scheduler.add_job(
|
||||||
|
func=lambda: api_request(recent, "IPlayerService", "GetRecentlyPlayedGames", steamid=76561198826355942),
|
||||||
|
trigger=IntervalTrigger(minutes=15),
|
||||||
|
id='risdeveau.steam.recent',
|
||||||
|
replace_existing=True
|
||||||
|
)
|
||||||
|
scheduler.add_job(
|
||||||
|
func=lambda: api_request(owned, "IPlayerService", "GetOwnedGames", steamid=76561198826355942, include_appinfo=1, include_played_free_games=1),
|
||||||
|
trigger=IntervalTrigger(minutes=60),
|
||||||
|
id='risdeveau.steam.owned',
|
||||||
|
replace_existing=True
|
||||||
|
)
|
||||||
|
scheduler.start()
|
||||||
|
|
||||||
|
api_request(recent, "IPlayerService", "GetRecentlyPlayedGames", steamid=76561198826355942)
|
||||||
|
api_request(owned, "IPlayerService", "GetOwnedGames", steamid=76561198826355942, include_appinfo=1, include_played_free_games=1)
|
||||||
|
|
||||||
|
atexit.register(lambda: scheduler.shutdown())
|
||||||
|
else:
|
||||||
|
print("STEAM_TOKEN is not defined")
|
||||||
@@ -48,6 +48,21 @@ h3 {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.steam {
|
||||||
|
.block {
|
||||||
|
display: flex;
|
||||||
|
|
||||||
|
img {
|
||||||
|
height: 7rem;
|
||||||
|
margin-right: .5rem;
|
||||||
|
}
|
||||||
|
|
||||||
|
p {
|
||||||
|
margin: .5rem 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
table, tbody {
|
table, tbody {
|
||||||
vertical-align: baseline;
|
vertical-align: baseline;
|
||||||
border-collapse: collapse;
|
border-collapse: collapse;
|
||||||
|
|||||||
@@ -23,6 +23,7 @@
|
|||||||
'info',
|
'info',
|
||||||
'contacts',
|
'contacts',
|
||||||
'listenbrainz',
|
'listenbrainz',
|
||||||
|
'steam',
|
||||||
'donate',
|
'donate',
|
||||||
'88x31'
|
'88x31'
|
||||||
) %}
|
) %}
|
||||||
|
|||||||
@@ -0,0 +1,54 @@
|
|||||||
|
<div class="block steam">
|
||||||
|
<h2><a href="https://steamcommunity.com/id/risdeveau">Steam</a></h2>
|
||||||
|
|
||||||
|
{% if recent.data.games %}
|
||||||
|
<h3>Recently played:</h3>
|
||||||
|
{% for g in recent.data.games %}
|
||||||
|
<a href="https://store.steampowered.com/app/{{ g.appid }}" class="block">
|
||||||
|
<picture>
|
||||||
|
<source media="(max-width: 45rem)" srcset="{{ g.v_cover }}">
|
||||||
|
<img src="{{ g.h_cover }}">
|
||||||
|
</picture>
|
||||||
|
|
||||||
|
<div>
|
||||||
|
<strong>{{ g.name }}</strong>
|
||||||
|
<p>Played last 2 weeks: {{ tmsmp(g.playtime_2weeks*60) }}
|
||||||
|
<p>
|
||||||
|
Total played:
|
||||||
|
{{ tmsmp(g.playtime_linux_forever*60) }} (<abbr title="On Linux">L</abbr>) +
|
||||||
|
{{ tmsmp(g.playtime_windows_forever*60) }} (<abbr title="On Windows">W</abbr>) =
|
||||||
|
{{ tmsmp(g.playtime_forever*60) }} (<abbr title="Total">T</abbr>)
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
</a>
|
||||||
|
{% endfor %}
|
||||||
|
<p>Last updated: {{ rtmsmp(owned.last_updated) }} ago</p>
|
||||||
|
{% endif %}
|
||||||
|
|
||||||
|
{% if owned.data.games %}
|
||||||
|
<h3>Top played games:</h3>
|
||||||
|
{% set owned_games = owned.data.games | sort(attribute="playtime_forever", reverse=true) %}
|
||||||
|
{% for g in owned_games[:5] %}
|
||||||
|
<a href="https://store.steampowered.com/app/{{ g.appid }}" class="block">
|
||||||
|
<picture>
|
||||||
|
<source media="(max-width: 45rem)" srcset="{{ g.v_cover }}">
|
||||||
|
<img src="{{ g.h_cover }}">
|
||||||
|
</picture>
|
||||||
|
|
||||||
|
<div>
|
||||||
|
<strong>{{ g.name }}</strong>
|
||||||
|
<p>
|
||||||
|
Total played:
|
||||||
|
{{ tmsmp(g.playtime_linux_forever*60) }} (<abbr title="On Linux">L</abbr>) +
|
||||||
|
{{ tmsmp(g.playtime_windows_forever*60) }} (<abbr title="On Windows">W</abbr>) =
|
||||||
|
{{ tmsmp(g.playtime_forever*60) }} (<abbr title="Total">T</abbr>)
|
||||||
|
</p>
|
||||||
|
{% if g.rtime_last_played != 0 %}
|
||||||
|
<p>Last played: {{ utmsmp(g.rtime_last_played) }}</p>
|
||||||
|
{% endif %}
|
||||||
|
</div>
|
||||||
|
</a>
|
||||||
|
{% endfor %}
|
||||||
|
<p>Last updated: {{ rtmsmp(owned.last_updated) }} ago</p>
|
||||||
|
{% endif %}
|
||||||
|
</div>
|
||||||
Reference in New Issue
Block a user