2023-11-10 22:34:12 +08:00
|
|
|
import pathlib
|
|
|
|
import time
|
2022-08-06 17:23:49 +08:00
|
|
|
from stats_schema_achievement_gen import achievements_gen
|
2023-11-10 22:34:12 +08:00
|
|
|
from external_components import (
|
|
|
|
ach_watcher_gen, cdx_gen, app_images, app_details, safe_name
|
|
|
|
)
|
2022-08-08 11:10:03 +08:00
|
|
|
from controller_config_generator import parse_controller_vdf
|
2022-08-06 17:23:49 +08:00
|
|
|
from steam.client import SteamClient
|
|
|
|
from steam.client.cdn import CDNClient
|
|
|
|
from steam.enums import common
|
2022-08-07 16:36:50 +08:00
|
|
|
from steam.enums.common import EResult
|
2022-08-06 17:23:49 +08:00
|
|
|
from steam.enums.emsg import EMsg
|
|
|
|
from steam.core.msg import MsgProto
|
|
|
|
import os
|
|
|
|
import sys
|
2022-08-07 16:36:50 +08:00
|
|
|
import json
|
2022-08-08 11:10:03 +08:00
|
|
|
import urllib.request
|
2022-08-14 02:38:37 +08:00
|
|
|
import urllib.error
|
|
|
|
import threading
|
|
|
|
import queue
|
2023-11-10 22:34:12 +08:00
|
|
|
import shutil
|
2022-08-07 16:36:50 +08:00
|
|
|
|
2022-08-06 17:23:49 +08:00
|
|
|
|
|
|
|
def get_stats_schema(client, game_id, owner_id):
|
|
|
|
message = MsgProto(EMsg.ClientGetUserStats)
|
|
|
|
message.body.game_id = game_id
|
|
|
|
message.body.schema_local_version = -1
|
|
|
|
message.body.crc_stats = 0
|
|
|
|
message.body.steam_id_for_user = owner_id
|
|
|
|
|
|
|
|
client.send(message)
|
|
|
|
return client.wait_msg(EMsg.ClientGetUserStatsResponse, timeout=5)
|
|
|
|
|
2023-11-10 22:34:12 +08:00
|
|
|
def download_achievement_images(game_id : int, image_names : set[str], output_folder : str):
|
|
|
|
print(f"downloading achievements images inside '{output_folder }', images count = {len(image_names)}")
|
|
|
|
q : queue.Queue[str] = queue.Queue()
|
2022-08-14 02:38:37 +08:00
|
|
|
|
|
|
|
def downloader_thread():
|
|
|
|
while True:
|
|
|
|
name = q.get()
|
|
|
|
if name is None:
|
|
|
|
q.task_done()
|
|
|
|
return
|
2023-11-10 22:34:12 +08:00
|
|
|
|
|
|
|
succeeded = False
|
2022-08-14 02:38:37 +08:00
|
|
|
for u in ["https://cdn.akamai.steamstatic.com/steamcommunity/public/images/apps/", "https://cdn.cloudflare.steamstatic.com/steamcommunity/public/images/apps/"]:
|
|
|
|
url = "{}{}/{}".format(u, game_id, name)
|
|
|
|
try:
|
|
|
|
with urllib.request.urlopen(url) as response:
|
|
|
|
image_data = response.read()
|
|
|
|
with open(os.path.join(output_folder, name), "wb") as f:
|
|
|
|
f.write(image_data)
|
|
|
|
succeeded = True
|
|
|
|
break
|
|
|
|
except urllib.error.HTTPError as e:
|
|
|
|
print("HTTPError downloading", url, e.code)
|
|
|
|
except urllib.error.URLError as e:
|
|
|
|
print("URLError downloading", url, e.code)
|
|
|
|
if not succeeded:
|
|
|
|
print("error could not download", name)
|
2023-11-10 22:34:12 +08:00
|
|
|
|
2022-08-14 02:38:37 +08:00
|
|
|
q.task_done()
|
|
|
|
|
2023-11-10 22:34:12 +08:00
|
|
|
num_threads = 50
|
2022-08-14 02:38:37 +08:00
|
|
|
for i in range(num_threads):
|
|
|
|
threading.Thread(target=downloader_thread, daemon=True).start()
|
|
|
|
|
|
|
|
for name in image_names:
|
|
|
|
q.put(name)
|
|
|
|
q.join()
|
|
|
|
|
|
|
|
for i in range(num_threads):
|
|
|
|
q.put(None)
|
|
|
|
q.join()
|
2023-11-10 22:34:12 +08:00
|
|
|
print("finished downloading achievements images")
|
2022-08-14 02:38:37 +08:00
|
|
|
|
2023-11-10 22:34:12 +08:00
|
|
|
#steam ids with public profiles that own a lot of games
|
|
|
|
# https://steamladder.com/ladder/games/
|
|
|
|
# in browser console:
|
|
|
|
#const links = $x("/html/body/div[3]/table/tbody/tr/td[2]/a[@href]/@href");
|
|
|
|
#console.clear();
|
|
|
|
#for (let index = 0; index < links.length; index++) {
|
|
|
|
# const usr_link = links[index].textContent.split('/').filter(s => s);
|
|
|
|
# const usr_id = usr_link[usr_link.length - 1]
|
|
|
|
# console.log(usr_id)
|
|
|
|
#}
|
|
|
|
TOP_OWNER_IDS = set([
|
|
|
|
76561198213148949,
|
|
|
|
76561198108581917,
|
|
|
|
76561198028121353,
|
|
|
|
76561197979911851,
|
|
|
|
76561198355625888,
|
|
|
|
76561198237402290,
|
|
|
|
76561197969050296,
|
|
|
|
76561198152618007,
|
|
|
|
76561198001237877,
|
|
|
|
76561198037867621,
|
|
|
|
76561198001678750,
|
|
|
|
76561198217186687,
|
|
|
|
76561198094227663,
|
|
|
|
76561197993544755,
|
|
|
|
76561197963550511,
|
|
|
|
76561198095049646,
|
|
|
|
76561197973009892,
|
|
|
|
76561197969810632,
|
|
|
|
76561198388522904,
|
|
|
|
76561198864213876,
|
|
|
|
# 76561198017975643,
|
|
|
|
# 76561198044596404,
|
|
|
|
# 76561197976597747,
|
|
|
|
# 76561197962473290,
|
|
|
|
# 76561197976968076,
|
|
|
|
# 76561198235911884,
|
|
|
|
# 76561198313790296,
|
|
|
|
# 76561198407953371,
|
|
|
|
# 76561198063574735,
|
|
|
|
# 76561198122859224,
|
|
|
|
# 76561198154462478,
|
|
|
|
# 76561197996432822,
|
|
|
|
# 76561197979667190,
|
|
|
|
# 76561198139084236,
|
|
|
|
# 76561198842864763,
|
|
|
|
# 76561198096081579,
|
|
|
|
# 76561198019712127,
|
|
|
|
# 76561198033715344,
|
|
|
|
# 76561198121398682,
|
|
|
|
# 76561198027233260,
|
|
|
|
# 76561198104323854,
|
|
|
|
# 76561197995070100,
|
|
|
|
# 76561198001221571,
|
|
|
|
# 76561198005337430,
|
|
|
|
# 76561198085065107,
|
|
|
|
# 76561198027214426,
|
|
|
|
# 76561198062901118,
|
|
|
|
# 76561198008181611,
|
|
|
|
# 76561198124872187,
|
|
|
|
# 76561198048373585,
|
|
|
|
# 76561197974742349,
|
|
|
|
# 76561198040421250,
|
|
|
|
# 76561198017902347,
|
|
|
|
# 76561198010615256,
|
|
|
|
# 76561197970825215,
|
|
|
|
# 76561198077213101,
|
|
|
|
# 76561197971011821,
|
|
|
|
# 76561197992133229,
|
|
|
|
# 76561197963534359,
|
|
|
|
# 76561198077248235,
|
|
|
|
# 76561198152760885,
|
|
|
|
# 76561198256917957,
|
|
|
|
# 76561198326510209,
|
|
|
|
# 76561198019009765,
|
|
|
|
# 76561198047438206,
|
|
|
|
# 76561198128158703,
|
|
|
|
# 76561198037809069,
|
|
|
|
# 76561198121336040,
|
|
|
|
# 76561198102767019,
|
|
|
|
# 76561198063728345,
|
|
|
|
# 76561198082995144,
|
|
|
|
# 76561197981111953,
|
|
|
|
# 76561197995008105,
|
|
|
|
# 76561198109083829,
|
|
|
|
# 76561197968410781,
|
|
|
|
# 76561198808371265,
|
|
|
|
# 76561198025858988,
|
|
|
|
# 76561198252374474,
|
|
|
|
# 76561198382166453,
|
|
|
|
# 76561198396723427,
|
|
|
|
# 76561197992548975,
|
|
|
|
# 76561198134044398,
|
|
|
|
# 76561198029503957,
|
|
|
|
# 76561197990233857,
|
|
|
|
# 76561197971026489,
|
|
|
|
# 76561197965978376,
|
|
|
|
# 76561197976796589,
|
|
|
|
# 76561197994616562,
|
|
|
|
# 76561197984235967,
|
|
|
|
# 76561197992967892,
|
|
|
|
# 76561198097945516,
|
|
|
|
# 76561198251835488,
|
|
|
|
# 76561198281128349,
|
|
|
|
# 76561198044387084,
|
|
|
|
# 76561198015685843,
|
|
|
|
# 76561197993312863,
|
|
|
|
# 76561198020125851,
|
|
|
|
# 76561198006391846,
|
|
|
|
# 76561198158932704,
|
|
|
|
# 76561198039492467,
|
|
|
|
# 76561198035552258,
|
|
|
|
# 76561198031837797,
|
|
|
|
# 76561197982718230,
|
|
|
|
# 76561198025653291,
|
|
|
|
# 76561197972951657,
|
|
|
|
# 76561198269242105,
|
|
|
|
# 76561198004332929,
|
|
|
|
# 76561197972378106,
|
|
|
|
# 76561197962630138,
|
|
|
|
# 76561198192399786,
|
|
|
|
# 76561198119667710,
|
|
|
|
# 76561198120120943,
|
|
|
|
# 76561198015992850,
|
|
|
|
# 76561198096632451,
|
|
|
|
# 76561198008797636,
|
|
|
|
# 76561198118726910,
|
|
|
|
# 76561198018254158,
|
|
|
|
# 76561198061393233,
|
|
|
|
# 76561198086250077,
|
|
|
|
# 76561198025391492,
|
|
|
|
# 76561198050474710,
|
|
|
|
# 76561197997477460,
|
|
|
|
# 76561198105279930,
|
|
|
|
# 76561198026221141,
|
|
|
|
# 76561198443388781,
|
|
|
|
# 76561197981228012,
|
|
|
|
# 76561197986240493,
|
|
|
|
# 76561198003041763,
|
|
|
|
# 76561198056971296,
|
|
|
|
# 76561198072936438,
|
|
|
|
# 76561198264362271,
|
|
|
|
# 76561198101049562,
|
|
|
|
# 76561198831075066,
|
|
|
|
# 76561197991699268,
|
|
|
|
# 76561198042965266,
|
|
|
|
# 76561198019555404,
|
|
|
|
# 76561198111433283,
|
|
|
|
# 76561197984010356,
|
|
|
|
# 76561198427572372,
|
|
|
|
# 76561198071709714,
|
|
|
|
# 76561198034213886,
|
|
|
|
# 76561198846208086,
|
|
|
|
# 76561197991613008,
|
|
|
|
# 76561197978640923,
|
|
|
|
# 76561198009596142,
|
|
|
|
# 76561199173688191,
|
|
|
|
# 76561198294806446,
|
|
|
|
# 76561197992105918,
|
|
|
|
# 76561198155124847,
|
|
|
|
# 76561198032614383,
|
|
|
|
# 76561198051740093,
|
|
|
|
# 76561198051725954,
|
|
|
|
# 76561198048151962,
|
|
|
|
# 76561198172367910,
|
|
|
|
# 76561198043532513,
|
|
|
|
# 76561198029532782,
|
|
|
|
# 76561198106145311,
|
|
|
|
# 76561198020746864,
|
|
|
|
# 76561198122276418,
|
|
|
|
# 76561198844130640,
|
|
|
|
# 76561198890581618,
|
|
|
|
# 76561198021180815,
|
|
|
|
# 76561198046642155,
|
|
|
|
# 76561197985091630,
|
|
|
|
# 76561198119915053,
|
|
|
|
# 76561198318547224,
|
|
|
|
# 76561198426000196,
|
|
|
|
# 76561197988052802,
|
|
|
|
# 76561198008549198,
|
|
|
|
# 76561198054210948,
|
|
|
|
# 76561198028011423,
|
|
|
|
# 76561198026306582,
|
|
|
|
# 76561198079227501,
|
|
|
|
# 76561198070220549,
|
|
|
|
# 76561198034503074,
|
|
|
|
# 76561198172925593,
|
|
|
|
# 76561198286209051,
|
|
|
|
# 76561197998058239,
|
|
|
|
# 76561198057648189,
|
|
|
|
# 76561197982273259,
|
|
|
|
# 76561198093579202,
|
|
|
|
# 76561198035612474,
|
|
|
|
# 76561197970307937,
|
|
|
|
# 76561197996825541,
|
|
|
|
# 76561197981027062,
|
|
|
|
# 76561198019841907,
|
|
|
|
# 76561197970727958,
|
|
|
|
# 76561197967716198,
|
|
|
|
# 76561197970545939,
|
|
|
|
# 76561198315929726,
|
|
|
|
# 76561198093753361,
|
|
|
|
# 76561198413266831,
|
|
|
|
# 76561198045540632,
|
|
|
|
# 76561198015514779,
|
|
|
|
# 76561198004532679,
|
|
|
|
# 76561198080773680,
|
|
|
|
# 76561198079896896,
|
|
|
|
# 76561198005299723,
|
|
|
|
# 76561198337784749,
|
|
|
|
# 76561198150126284,
|
|
|
|
# 76561197988445370,
|
|
|
|
# 76561198258304011,
|
|
|
|
# 76561198321551799,
|
|
|
|
# 76561197973701057,
|
|
|
|
# 76561197973230221,
|
|
|
|
# 76561198002535276,
|
|
|
|
# 76561198100306249,
|
|
|
|
# 76561198116086535,
|
|
|
|
# 76561197970970678,
|
|
|
|
# 76561198085238363,
|
|
|
|
# 76561198007200913,
|
|
|
|
# 76561198025111129,
|
|
|
|
# 76561198068747739,
|
|
|
|
# 76561197970539274,
|
|
|
|
# 76561198148627568,
|
|
|
|
# 76561197970360549,
|
|
|
|
# 76561198098314980,
|
|
|
|
# 76561197972529138,
|
|
|
|
# 76561198007403855,
|
|
|
|
# 76561197977403803,
|
|
|
|
# 76561198124865933,
|
|
|
|
# 76561197981323238,
|
|
|
|
# 76561197960330700,
|
|
|
|
# 76561198217979953,
|
|
|
|
# 76561197960366517,
|
|
|
|
# 76561198044067612,
|
|
|
|
# 76561197967197052,
|
|
|
|
# 76561198027066612,
|
|
|
|
# 76561198072833066,
|
|
|
|
# 76561198033967307,
|
|
|
|
# 76561198104561325,
|
|
|
|
# 76561198272374716,
|
|
|
|
# 76561197970127197,
|
|
|
|
# 76561197970257188,
|
|
|
|
# 76561198026921217,
|
|
|
|
# 76561198027904347,
|
|
|
|
# 76561198062469228,
|
|
|
|
# 76561198026278913,
|
|
|
|
# 76561197970548935,
|
|
|
|
# 76561197966617426,
|
|
|
|
# 76561198356842617,
|
|
|
|
# 76561198034276722,
|
|
|
|
# 76561198355953202,
|
|
|
|
# 76561197986603983,
|
|
|
|
# 76561197967923946,
|
|
|
|
# 76561197961542845,
|
|
|
|
# 76561198121938079,
|
|
|
|
# 76561197992357639,
|
|
|
|
# 76561198002536379,
|
|
|
|
# 76561198017054389,
|
|
|
|
# 76561198031129658,
|
|
|
|
# 76561198020728639,
|
|
|
|
])
|
|
|
|
|
|
|
|
def generate_achievement_stats(client, game_id : int, output_directory, backup_directory) -> list[dict]:
|
|
|
|
steam_id_list = TOP_OWNER_IDS.copy()
|
|
|
|
steam_id_list.add(client.steam_id)
|
|
|
|
stats_schema_found = None
|
|
|
|
print(f"finding achievements stats...")
|
|
|
|
for id in steam_id_list:
|
|
|
|
#print(f"finding achievements stats using account ID {id}...")
|
|
|
|
out = get_stats_schema(client, game_id, id)
|
|
|
|
if out is not None and len(out.body.schema) > 0:
|
|
|
|
stats_schema_found = out
|
|
|
|
#print(f"found achievement stats using account ID {id}")
|
|
|
|
break
|
|
|
|
|
|
|
|
if stats_schema_found is None: # nothing found
|
|
|
|
print(f"[X] app id {game_id} has not achievements")
|
|
|
|
return []
|
|
|
|
|
|
|
|
achievement_images_dir = os.path.join(output_directory, "img")
|
|
|
|
images_to_download : set[str] = set()
|
|
|
|
|
|
|
|
with open(os.path.join(backup_directory, f'UserGameStatsSchema_{game_id}.bin'), 'wb') as f:
|
|
|
|
f.write(stats_schema_found.body.schema)
|
|
|
|
(
|
|
|
|
achievements, stats,
|
|
|
|
copy_default_unlocked_img, copy_default_locked_img
|
|
|
|
) = achievements_gen.generate_stats_achievements(stats_schema_found.body.schema, output_directory)
|
|
|
|
|
|
|
|
for ach in achievements:
|
|
|
|
icon = f"{ach.get('icon', '')}".strip()
|
|
|
|
if icon:
|
|
|
|
images_to_download.add(icon)
|
|
|
|
icon_gray = f"{ach.get('icon_gray', '')}".strip()
|
|
|
|
if icon_gray:
|
|
|
|
images_to_download.add(icon_gray)
|
|
|
|
|
|
|
|
if images_to_download:
|
2022-08-14 02:38:37 +08:00
|
|
|
if not os.path.exists(achievement_images_dir):
|
|
|
|
os.makedirs(achievement_images_dir)
|
2023-11-10 22:34:12 +08:00
|
|
|
if copy_default_unlocked_img:
|
|
|
|
shutil.copy("steam_default_icon_unlocked.jpg", achievement_images_dir)
|
|
|
|
if copy_default_locked_img:
|
|
|
|
shutil.copy("steam_default_icon_locked.jpg", achievement_images_dir)
|
2022-08-14 02:38:37 +08:00
|
|
|
download_achievement_images(game_id, images_to_download, achievement_images_dir)
|
|
|
|
|
2023-11-10 22:34:12 +08:00
|
|
|
return achievements
|
|
|
|
|
2022-08-08 11:10:03 +08:00
|
|
|
def get_ugc_info(client, published_file_id):
|
|
|
|
return client.send_um_and_wait('PublishedFile.GetDetails#1', {
|
|
|
|
'publishedfileids': [published_file_id],
|
|
|
|
'includetags': False,
|
|
|
|
'includeadditionalpreviews': False,
|
|
|
|
'includechildren': False,
|
|
|
|
'includekvtags': False,
|
|
|
|
'includevotes': False,
|
|
|
|
'short_description': True,
|
|
|
|
'includeforsaledata': False,
|
|
|
|
'includemetadata': False,
|
|
|
|
'language': 0
|
|
|
|
})
|
|
|
|
|
|
|
|
def download_published_file(client, published_file_id, backup_directory):
|
|
|
|
ugc_info = get_ugc_info(client, published_file_id)
|
|
|
|
|
|
|
|
if (ugc_info is None):
|
|
|
|
print("failed getting published file", published_file_id)
|
|
|
|
return None
|
|
|
|
|
|
|
|
file_details = ugc_info.body.publishedfiledetails[0]
|
|
|
|
if (file_details.result != EResult.OK):
|
|
|
|
print("failed getting published file", published_file_id, file_details.result)
|
|
|
|
return None
|
|
|
|
|
|
|
|
if not os.path.exists(backup_directory):
|
|
|
|
os.makedirs(backup_directory)
|
|
|
|
|
|
|
|
with open(os.path.join(backup_directory, "info.txt"), "w") as f:
|
|
|
|
f.write(str(ugc_info.body))
|
|
|
|
|
2022-08-17 07:27:44 +08:00
|
|
|
if len(file_details.file_url) > 0:
|
|
|
|
with urllib.request.urlopen(file_details.file_url) as response:
|
|
|
|
data = response.read()
|
|
|
|
with open(os.path.join(backup_directory, file_details.filename.replace("/", "_").replace("\\", "_")), "wb") as f:
|
|
|
|
f.write(data)
|
|
|
|
return data
|
|
|
|
return None
|
|
|
|
else:
|
|
|
|
print("Could not download file", published_file_id, "no url (you can ignore this if the game doesn't need a controller config)")
|
|
|
|
return None
|
|
|
|
|
2022-08-08 11:10:03 +08:00
|
|
|
|
2022-08-15 02:54:12 +08:00
|
|
|
def get_inventory_info(client, game_id):
|
|
|
|
return client.send_um_and_wait('Inventory.GetItemDefMeta#1', {
|
|
|
|
'appid': game_id
|
|
|
|
})
|
|
|
|
|
|
|
|
def generate_inventory(client, game_id):
|
2023-11-10 22:34:12 +08:00
|
|
|
inventory = get_inventory_info(client, game_id)
|
2022-08-15 02:54:12 +08:00
|
|
|
if inventory.header.eresult != EResult.OK:
|
|
|
|
return None
|
|
|
|
|
2023-11-10 22:34:12 +08:00
|
|
|
url = f"https://api.steampowered.com/IGameInventory/GetItemDefArchive/v0001?appid={game_id}&digest={inventory.body.digest}"
|
2022-08-15 02:54:12 +08:00
|
|
|
try:
|
|
|
|
with urllib.request.urlopen(url) as response:
|
|
|
|
return response.read()
|
|
|
|
except urllib.error.HTTPError as e:
|
|
|
|
print("HTTPError getting", url, e.code)
|
|
|
|
except urllib.error.URLError as e:
|
|
|
|
print("URLError getting", url, e.code)
|
|
|
|
return None
|
|
|
|
|
2022-08-08 11:10:03 +08:00
|
|
|
def get_dlc(raw_infos):
|
|
|
|
try:
|
2023-11-10 22:34:12 +08:00
|
|
|
dlc_list = set()
|
|
|
|
depot_app_list = set()
|
|
|
|
all_depots = set()
|
2022-08-08 11:10:03 +08:00
|
|
|
try:
|
2023-11-10 22:34:12 +08:00
|
|
|
dlc_list = set(map(lambda a: int(f"{a}".strip()), raw_infos["extended"]["listofdlc"].split(",")))
|
|
|
|
except Exception:
|
2022-08-08 11:10:03 +08:00
|
|
|
dlc_list = set()
|
2023-11-10 22:34:12 +08:00
|
|
|
|
2022-08-08 11:10:03 +08:00
|
|
|
if "depots" in raw_infos:
|
2023-11-10 22:34:12 +08:00
|
|
|
depots : dict[str, object] = raw_infos["depots"]
|
2022-08-08 11:10:03 +08:00
|
|
|
for dep in depots:
|
|
|
|
depot_info = depots[dep]
|
|
|
|
if "dlcappid" in depot_info:
|
|
|
|
dlc_list.add(int(depot_info["dlcappid"]))
|
|
|
|
if "depotfromapp" in depot_info:
|
|
|
|
depot_app_list.add(int(depot_info["depotfromapp"]))
|
2023-11-10 22:34:12 +08:00
|
|
|
if dep.isnumeric():
|
|
|
|
all_depots.add(int(dep))
|
|
|
|
|
|
|
|
return (dlc_list, depot_app_list, all_depots)
|
|
|
|
except Exception:
|
2022-08-08 11:10:03 +08:00
|
|
|
print("could not get dlc infos, are there any dlcs ?")
|
2023-11-10 22:34:12 +08:00
|
|
|
return (set(), set(), set())
|
|
|
|
|
|
|
|
EXTRA_FEATURES: list[tuple[str, str]] = [
|
|
|
|
("disable_account_avatar.txt", "disable avatar functionality."),
|
|
|
|
("disable_networking.txt", "disable all networking functionality."),
|
|
|
|
("disable_overlay.txt", "disable the overlay."),
|
|
|
|
("disable_overlay_achievement_notification.txt", "disable the achievement notifications."),
|
|
|
|
("disable_overlay_friend_notification.txt", "disable the friend invite and message notifications."),
|
|
|
|
("disable_source_query.txt", "Do not send server details for the server browser. Only works for game servers."),
|
|
|
|
]
|
|
|
|
|
|
|
|
def disable_all_extra_features(emu_settings_dir : str) -> None:
|
|
|
|
for item in EXTRA_FEATURES:
|
|
|
|
with open(os.path.join(emu_settings_dir, item[0]), 'wt', encoding='utf-8') as f:
|
|
|
|
f.write(item[1])
|
|
|
|
|
|
|
|
|
|
|
|
def help():
|
|
|
|
exe_name = os.path.basename(sys.argv[0])
|
|
|
|
print(f"\nUsage: {exe_name} [-shots] [-thumbs] [-vid] [-imgs] [-name] [-cdx] [-aw] [-clean] appid appid appid ... ")
|
|
|
|
print(f" Example: {exe_name} 421050 420 480")
|
|
|
|
print(f" Example: {exe_name} -shots -thumbs -vid -imgs -name -cdx -aw -clean 421050")
|
|
|
|
print("\nSwitches:")
|
|
|
|
print(" -shots: download screenshots for each app if they're available")
|
|
|
|
print(" -thumbs: download screenshots thumbnails for each app if they're available")
|
|
|
|
print(" -vid: download the first video available for each app: trailer, gameplay, announcement, etc...")
|
|
|
|
print(" -imgs: download common images for each app: Steam generated background, icon, logo, etc...")
|
|
|
|
print(" -name: save the output of each app in a folder with the same name as the app, unsafe characters are discarded")
|
|
|
|
print(" -cdx: generate .ini file for CODEX Steam emu for each app")
|
|
|
|
print(" -aw: generate schemas of all possible languages for Achievement Watcher")
|
|
|
|
print(" -clean: delete any folder/file with the same name as the output before generating any data")
|
|
|
|
print("\nAll switches are optional except app id, at least 1 app id must be provided\n")
|
|
|
|
|
|
|
|
|
|
|
|
def main():
|
|
|
|
USERNAME = ""
|
|
|
|
PASSWORD = ""
|
|
|
|
|
|
|
|
DOWNLOAD_SCREESHOTS = False
|
|
|
|
DOWNLOAD_THUMBNAILS = False
|
|
|
|
DOWNLOAD_VIDEOS = False
|
|
|
|
DOWNLOAD_COMMON_IMAGES = False
|
|
|
|
SAVE_APP_NAME = False
|
|
|
|
GENERATE_CODEX_INI = False
|
|
|
|
GENERATE_ACHIEVEMENT_WATCHER_SCHEMAS = False
|
|
|
|
CLEANUP_BEFORE_GENERATING = False
|
|
|
|
|
|
|
|
prompt_for_unavailable = True
|
|
|
|
|
|
|
|
if len(sys.argv) < 2:
|
|
|
|
help()
|
|
|
|
sys.exit(1)
|
|
|
|
|
|
|
|
appids : set[int] = set()
|
|
|
|
for appid in sys.argv[1:]:
|
|
|
|
if f'{appid}'.isnumeric():
|
|
|
|
appids.add(int(appid))
|
|
|
|
elif f'{appid}'.lower() == '-shots':
|
|
|
|
DOWNLOAD_SCREESHOTS = True
|
|
|
|
elif f'{appid}'.lower() == '-thumbs':
|
|
|
|
DOWNLOAD_THUMBNAILS = True
|
|
|
|
elif f'{appid}'.lower() == '-vid':
|
|
|
|
DOWNLOAD_VIDEOS = True
|
|
|
|
elif f'{appid}'.lower() == '-imgs':
|
|
|
|
DOWNLOAD_COMMON_IMAGES = True
|
|
|
|
elif f'{appid}'.lower() == '-name':
|
|
|
|
SAVE_APP_NAME = True
|
|
|
|
elif f'{appid}'.lower() == '-cdx':
|
|
|
|
GENERATE_CODEX_INI = True
|
|
|
|
elif f'{appid}'.lower() == '-aw':
|
|
|
|
GENERATE_ACHIEVEMENT_WATCHER_SCHEMAS = True
|
|
|
|
elif f'{appid}'.lower() == '-clean':
|
|
|
|
CLEANUP_BEFORE_GENERATING = True
|
|
|
|
else:
|
|
|
|
print(f'[X] invalid switch: {appid}')
|
|
|
|
help()
|
|
|
|
sys.exit(1)
|
|
|
|
|
|
|
|
if not appids:
|
|
|
|
print(f'[X] no app id was provided')
|
|
|
|
help()
|
|
|
|
sys.exit(1)
|
|
|
|
|
|
|
|
client = SteamClient()
|
|
|
|
if not os.path.exists("login_temp"):
|
|
|
|
os.makedirs("login_temp")
|
|
|
|
client.set_credential_location("login_temp")
|
|
|
|
|
|
|
|
if os.path.isfile("my_login.txt"):
|
|
|
|
filedata = ['']
|
|
|
|
with open("my_login.txt", "r") as f:
|
|
|
|
filedata = f.readlines()
|
|
|
|
filedata = list(map(lambda s: s.strip().replace("\r", "").replace("\n", ""), filedata))
|
|
|
|
filedata = [l for l in filedata if l]
|
|
|
|
if len(filedata) == 2:
|
|
|
|
USERNAME = filedata[0]
|
|
|
|
PASSWORD = filedata[1]
|
|
|
|
|
|
|
|
if (len(USERNAME) == 0 or len(PASSWORD) == 0):
|
|
|
|
client.cli_login()
|
|
|
|
else:
|
|
|
|
result = client.login(USERNAME, password=PASSWORD)
|
|
|
|
auth_code, two_factor_code = None, None
|
|
|
|
while result in (EResult.AccountLogonDenied, EResult.InvalidLoginAuthCode,
|
|
|
|
EResult.AccountLoginDeniedNeedTwoFactor, EResult.TwoFactorCodeMismatch,
|
|
|
|
EResult.TryAnotherCM, EResult.ServiceUnavailable,
|
|
|
|
EResult.InvalidPassword,
|
|
|
|
):
|
|
|
|
|
|
|
|
if result == EResult.InvalidPassword:
|
|
|
|
print("invalid password, the password you set is wrong.")
|
|
|
|
exit(1)
|
|
|
|
|
|
|
|
elif result in (EResult.AccountLogonDenied, EResult.InvalidLoginAuthCode):
|
|
|
|
prompt = ("Enter email code: " if result == EResult.AccountLogonDenied else
|
|
|
|
"Incorrect code. Enter email code: ")
|
|
|
|
auth_code, two_factor_code = input(prompt), None
|
|
|
|
|
|
|
|
elif result in (EResult.AccountLoginDeniedNeedTwoFactor, EResult.TwoFactorCodeMismatch):
|
|
|
|
prompt = ("Enter 2FA code: " if result == EResult.AccountLoginDeniedNeedTwoFactor else
|
|
|
|
"Incorrect code. Enter 2FA code: ")
|
|
|
|
auth_code, two_factor_code = None, input(prompt)
|
|
|
|
|
|
|
|
elif result in (EResult.TryAnotherCM, EResult.ServiceUnavailable):
|
|
|
|
if prompt_for_unavailable and result == EResult.ServiceUnavailable:
|
|
|
|
while True:
|
|
|
|
answer = input("Steam is down. Keep retrying? [y/n]: ").lower()
|
|
|
|
if answer in 'yn': break
|
|
|
|
|
|
|
|
prompt_for_unavailable = False
|
|
|
|
if answer == 'n': break
|
|
|
|
|
|
|
|
client.reconnect(maxdelay=15)
|
|
|
|
|
|
|
|
result = client.login(USERNAME, PASSWORD, None, auth_code, two_factor_code)
|
|
|
|
|
|
|
|
for appid in appids:
|
|
|
|
print(f"********* generating info for app id {appid} *********")
|
|
|
|
raw = client.get_product_info(apps=[appid])
|
|
|
|
game_info : dict = raw["apps"][appid]
|
|
|
|
|
|
|
|
game_info_common : dict = game_info.get("common", {})
|
|
|
|
app_name = game_info_common.get("name", "")
|
|
|
|
app_name_on_disk = f"{appid}"
|
|
|
|
if app_name:
|
|
|
|
print(f"App name on store: '{app_name}'")
|
|
|
|
if SAVE_APP_NAME:
|
|
|
|
sanitized_name = safe_name.create_safe_name(app_name)
|
|
|
|
if sanitized_name:
|
|
|
|
app_name_on_disk = f'{sanitized_name}-{appid}'
|
|
|
|
else:
|
|
|
|
app_name = f"Unknown_Steam_app_{appid}" # we need this for later use in the Achievement Watcher
|
|
|
|
print(f"[X] Couldn't find app name on store")
|
|
|
|
|
|
|
|
root_backup_dir = "backup"
|
|
|
|
backup_dir = os.path.join(root_backup_dir, f"{appid}")
|
|
|
|
if not os.path.exists(backup_dir):
|
|
|
|
os.makedirs(backup_dir)
|
|
|
|
|
|
|
|
root_out_dir = "output"
|
|
|
|
base_out_dir = os.path.join(root_out_dir, app_name_on_disk)
|
|
|
|
emu_settings_dir = os.path.join(base_out_dir, "steam_settings")
|
|
|
|
info_out_dir = os.path.join(base_out_dir, "info")
|
|
|
|
|
|
|
|
if CLEANUP_BEFORE_GENERATING:
|
|
|
|
print("cleaning output folder before generating any data")
|
|
|
|
base_dir_path = pathlib.Path(base_out_dir)
|
|
|
|
if base_dir_path.is_file():
|
|
|
|
base_dir_path.unlink()
|
|
|
|
time.sleep(0.05)
|
|
|
|
elif base_dir_path.is_dir():
|
|
|
|
shutil.rmtree(base_dir_path)
|
|
|
|
time.sleep(0.05)
|
|
|
|
|
|
|
|
while base_dir_path.exists():
|
|
|
|
time.sleep(0.05)
|
|
|
|
|
|
|
|
if not os.path.exists(emu_settings_dir):
|
|
|
|
os.makedirs(emu_settings_dir)
|
|
|
|
|
|
|
|
if not os.path.exists(info_out_dir):
|
|
|
|
os.makedirs(info_out_dir)
|
|
|
|
|
|
|
|
print(f"output dir: '{base_out_dir}'")
|
|
|
|
|
|
|
|
with open(os.path.join(info_out_dir, "product_info.json"), "wt", encoding='utf-8') as f:
|
|
|
|
json.dump(game_info, f, ensure_ascii=False, indent=2)
|
|
|
|
|
|
|
|
app_details.download_app_details(
|
|
|
|
base_out_dir, info_out_dir,
|
|
|
|
appid,
|
|
|
|
DOWNLOAD_SCREESHOTS,
|
|
|
|
DOWNLOAD_THUMBNAILS,
|
|
|
|
DOWNLOAD_VIDEOS)
|
|
|
|
|
|
|
|
clienticon : str = None
|
|
|
|
icon : str = None
|
|
|
|
logo : str = None
|
|
|
|
logo_small : str = None
|
|
|
|
achievements : list[dict] = []
|
|
|
|
languages : list[str] = []
|
|
|
|
app_exe = ''
|
|
|
|
if game_info_common:
|
|
|
|
if "clienticon" in game_info_common:
|
|
|
|
clienticon = f"{game_info_common['clienticon']}"
|
|
|
|
|
|
|
|
if "icon" in game_info_common:
|
|
|
|
icon = f"{game_info_common['icon']}"
|
|
|
|
|
|
|
|
if "logo" in game_info_common:
|
|
|
|
logo = f"{game_info_common['logo']}"
|
|
|
|
|
|
|
|
if "logo_small" in game_info_common:
|
|
|
|
logo_small = f"{game_info_common['logo_small']}"
|
|
|
|
|
|
|
|
#print(f"generating achievement stats")
|
|
|
|
#if "community_visible_stats" in game_info_common: #NOTE: checking this seems to skip stats on a few games so it's commented out
|
|
|
|
achievements = generate_achievement_stats(client, appid, emu_settings_dir, backup_dir)
|
|
|
|
|
|
|
|
if "supported_languages" in game_info_common:
|
|
|
|
langs : dict[str, dict] = game_info_common["supported_languages"]
|
|
|
|
languages = [lang for lang in langs if langs[lang].get("supported", "").lower() == "true"]
|
|
|
|
|
|
|
|
if languages:
|
|
|
|
with open(os.path.join(emu_settings_dir, "supported_languages.txt"), 'wt', encoding='utf-8') as f:
|
|
|
|
for lang in languages:
|
|
|
|
f.write(f'{lang}\n')
|
|
|
|
|
|
|
|
with open(os.path.join(emu_settings_dir, "steam_appid.txt"), 'w') as f:
|
|
|
|
f.write(str(appid))
|
|
|
|
|
|
|
|
if "depots" in game_info:
|
|
|
|
if "branches" in game_info["depots"]:
|
|
|
|
if "public" in game_info["depots"]["branches"]:
|
|
|
|
if "buildid" in game_info["depots"]["branches"]["public"]:
|
|
|
|
buildid = game_info["depots"]["branches"]["public"]["buildid"]
|
|
|
|
with open(os.path.join(emu_settings_dir, "build_id.txt"), 'wt', encoding='utf-8') as f:
|
|
|
|
f.write(str(buildid))
|
|
|
|
|
|
|
|
dlc_config_list : list[tuple[int, str]] = []
|
|
|
|
dlc_list, depot_app_list, all_depots = get_dlc(game_info)
|
|
|
|
dlc_raw = {}
|
|
|
|
if dlc_list:
|
|
|
|
dlc_raw = client.get_product_info(apps=dlc_list)["apps"]
|
|
|
|
for dlc in dlc_raw:
|
|
|
|
dlc_name = ''
|
|
|
|
try:
|
|
|
|
dlc_name = f'{dlc_raw[dlc]["common"]["name"]}'
|
|
|
|
except Exception:
|
|
|
|
pass
|
|
|
|
|
|
|
|
if not dlc_name:
|
|
|
|
dlc_name = f"Unknown Steam app {dlc}"
|
|
|
|
|
|
|
|
dlc_config_list.append((dlc, dlc_name))
|
|
|
|
|
|
|
|
if dlc_config_list:
|
|
|
|
with open(os.path.join(emu_settings_dir, "DLC.txt"), 'wt', encoding="utf-8") as f:
|
|
|
|
for x in dlc_config_list:
|
|
|
|
f.write(f"{x[0]}={x[1]}\n")
|
|
|
|
|
|
|
|
if all_depots:
|
|
|
|
with open(os.path.join(emu_settings_dir, "depots.txt"), 'wt', encoding="utf-8") as f:
|
|
|
|
for game_depot in all_depots:
|
|
|
|
f.write(f"{game_depot}\n")
|
|
|
|
|
|
|
|
config_generated = False
|
|
|
|
if "config" in game_info:
|
|
|
|
if "steamcontrollerconfigdetails" in game_info["config"]:
|
|
|
|
controller_details = game_info["config"]["steamcontrollerconfigdetails"]
|
|
|
|
for id in controller_details:
|
|
|
|
details = controller_details[id]
|
|
|
|
controller_type = ""
|
|
|
|
enabled_branches = ""
|
|
|
|
if "controller_type" in details:
|
|
|
|
controller_type = details["controller_type"]
|
|
|
|
if "enabled_branches" in details:
|
|
|
|
enabled_branches = details["enabled_branches"]
|
|
|
|
print(id, controller_type)
|
|
|
|
out_vdf = download_published_file(client, int(id), os.path.join(backup_dir, controller_type + str(id)))
|
|
|
|
if out_vdf is not None and not config_generated:
|
|
|
|
if (controller_type in ["controller_xbox360", "controller_xboxone"] and (("default" in enabled_branches) or ("public" in enabled_branches))):
|
|
|
|
parse_controller_vdf.generate_controller_config(out_vdf.decode('utf-8'), os.path.join(emu_settings_dir, "controller"))
|
|
|
|
config_generated = True
|
|
|
|
if "steamcontrollertouchconfigdetails" in game_info["config"]:
|
|
|
|
controller_details = game_info["config"]["steamcontrollertouchconfigdetails"]
|
|
|
|
for id in controller_details:
|
|
|
|
details = controller_details[id]
|
|
|
|
controller_type = ""
|
|
|
|
enabled_branches = ""
|
|
|
|
if "controller_type" in details:
|
|
|
|
controller_type = details["controller_type"]
|
|
|
|
if "enabled_branches" in details:
|
|
|
|
enabled_branches = details["enabled_branches"]
|
|
|
|
print(id, controller_type)
|
|
|
|
out_vdf = download_published_file(client, int(id), os.path.join(backup_dir, controller_type + str(id)))
|
|
|
|
if "launch" in game_info["config"]:
|
|
|
|
launch_configs = game_info["config"]["launch"]
|
|
|
|
with open(os.path.join(info_out_dir, "launch_config.json"), "wt", encoding='utf-8') as f:
|
|
|
|
json.dump(launch_configs, f, ensure_ascii=False, indent=2)
|
|
|
|
|
|
|
|
first_app_exe : str = None
|
|
|
|
prefered_app_exe : str = None
|
|
|
|
unwanted_app_exes = ["launch", "start", "play", "try", "demo", "_vr",]
|
|
|
|
for cfg in launch_configs.values():
|
|
|
|
if "executable" in cfg:
|
|
|
|
app_exe = f'{cfg["executable"]}'
|
|
|
|
|
|
|
|
if app_exe.lower().endswith(".exe"):
|
|
|
|
app_exe = app_exe.replace("\\", "/").split('/')[-1]
|
|
|
|
if first_app_exe is None:
|
|
|
|
first_app_exe = app_exe
|
|
|
|
if all(app_exe.lower().find(unwanted_exe) < 0 for unwanted_exe in unwanted_app_exes):
|
|
|
|
prefered_app_exe = app_exe
|
|
|
|
break
|
|
|
|
|
|
|
|
if prefered_app_exe:
|
|
|
|
app_exe = prefered_app_exe
|
|
|
|
elif first_app_exe:
|
|
|
|
app_exe = first_app_exe
|
|
|
|
|
|
|
|
if GENERATE_ACHIEVEMENT_WATCHER_SCHEMAS:
|
|
|
|
ach_watcher_gen.generate_all_ach_watcher_schemas(
|
|
|
|
base_out_dir,
|
|
|
|
appid,
|
|
|
|
app_name,
|
|
|
|
app_exe,
|
|
|
|
achievements,
|
|
|
|
icon)
|
|
|
|
|
|
|
|
if GENERATE_CODEX_INI:
|
|
|
|
cdx_gen.generate_cdx_ini(
|
|
|
|
base_out_dir,
|
|
|
|
appid,
|
|
|
|
dlc_config_list,
|
|
|
|
achievements)
|
|
|
|
|
|
|
|
if DOWNLOAD_COMMON_IMAGES:
|
|
|
|
app_images.download_app_images(
|
|
|
|
base_out_dir,
|
|
|
|
appid,
|
|
|
|
clienticon,
|
|
|
|
icon,
|
|
|
|
logo,
|
|
|
|
logo_small)
|
|
|
|
|
|
|
|
disable_all_extra_features(emu_settings_dir)
|
|
|
|
|
|
|
|
inventory_data = generate_inventory(client, appid)
|
|
|
|
if inventory_data is not None:
|
|
|
|
out_inventory = {}
|
|
|
|
default_items = {}
|
|
|
|
inventory = json.loads(inventory_data.rstrip(b"\x00"))
|
|
|
|
raw_inventory = json.dumps(inventory, indent=4)
|
|
|
|
with open(os.path.join(backup_dir, "inventory.json"), "w") as f:
|
|
|
|
f.write(raw_inventory)
|
|
|
|
for i in inventory:
|
|
|
|
index = str(i["itemdefid"])
|
|
|
|
x = {}
|
|
|
|
for t in i:
|
|
|
|
if i[t] is True:
|
|
|
|
x[t] = "true"
|
|
|
|
elif i[t] is False:
|
|
|
|
x[t] = "false"
|
|
|
|
else:
|
|
|
|
x[t] = str(i[t])
|
|
|
|
out_inventory[index] = x
|
|
|
|
default_items[index] = 1
|
|
|
|
|
|
|
|
with open(os.path.join(emu_settings_dir, "items.json"), "wt", encoding='utf-8') as f:
|
|
|
|
json.dump(out_inventory, f, ensure_ascii=False, indent=2)
|
|
|
|
|
|
|
|
with open(os.path.join(emu_settings_dir, "default_items.json"), "wt", encoding='utf-8') as f:
|
|
|
|
json.dump(default_items, f, ensure_ascii=False, indent=2)
|
|
|
|
|
|
|
|
with open(os.path.join(backup_dir, "product_info.json"), "wt", encoding='utf-8') as f:
|
|
|
|
json.dump(game_info, f, ensure_ascii=False, indent=2)
|
|
|
|
|
|
|
|
with open(os.path.join(backup_dir, "dlc_product_info.json"), "wt", encoding='utf-8') as f:
|
|
|
|
json.dump(dlc_raw, f, ensure_ascii=False, indent=2)
|
|
|
|
|
|
|
|
print(f"######### done for app id {appid} #########\n\n")
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
|
try:
|
|
|
|
main()
|
|
|
|
except Exception as e:
|
|
|
|
print("Unexpected error:")
|
|
|
|
print(e)
|
|
|
|
sys.exit(1)
|
|
|
|
|