Add Steam info
This commit is contained in:
@@ -2,6 +2,7 @@ import os
|
||||
import magic
|
||||
from pathlib import Path
|
||||
from htmlmin import minify
|
||||
from time import time
|
||||
from datetime import datetime, timedelta
|
||||
from musicbrainzngs import get_image_front
|
||||
from flask import (
|
||||
@@ -14,6 +15,30 @@ from flask import (
|
||||
)
|
||||
|
||||
from .modules.api.lb import listens, listening
|
||||
from .modules.api.steam import recent, owned
|
||||
|
||||
def tmsmp(sec: int) -> str:
|
||||
if sec == 0:
|
||||
return 0
|
||||
elif sec < 60:
|
||||
return f"{sec} s"
|
||||
elif sec < 60*60:
|
||||
minutes = round(sec / 60, 1)
|
||||
return f"{minutes:.0f} m" if minutes.is_integer() else f"{minutes:.1f} m"
|
||||
elif sec < 60*60*24:
|
||||
hours = round(sec / 3600, 1)
|
||||
return f"{hours:.0f} h" if hours.is_integer() else f"{hours:.1f} h"
|
||||
else:
|
||||
days = round(sec / 86400, 1)
|
||||
return f"{days:.0f} d" if days.is_integer() else f"{days:.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(
|
||||
"risdeveau",
|
||||
@@ -47,6 +72,16 @@ def mb_cover(mbid):
|
||||
.strftime('%a, %d %b %Y %H:%M:%S GMT')
|
||||
return r
|
||||
|
||||
args = {
|
||||
"lb": listens,
|
||||
"lb_now": listening,
|
||||
"recent": recent,
|
||||
"owned": owned,
|
||||
"tmsmp": tmsmp,
|
||||
"utmsmp": utmsmp,
|
||||
"rtmsmp": rtmsmp
|
||||
}
|
||||
|
||||
@bp.route("/")
|
||||
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 {
|
||||
vertical-align: baseline;
|
||||
border-collapse: collapse;
|
||||
|
||||
@@ -23,6 +23,7 @@
|
||||
'info',
|
||||
'contacts',
|
||||
'listenbrainz',
|
||||
'steam',
|
||||
'donate',
|
||||
'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(recent.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