Leahnaya/DeathGarden_API_Rebirth
0
0
Fork 0
mirror of https://github.com/wolfswolke/DeathGarden_API_Rebirth.git synced 2026-07-19 01:13:31 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity
a3738cd5e6
DeathGarden_API_Rebirth/src/endpoints/user_handeling.py
ZKWolf a3738cd5e6 Fixed InitOrGetGroup to 99%
2024-02-05 19:25:05 +01:00

970 lines
50 KiB
Python
Raw Blame History

import sys
import time
from math import ceil
from flask_definitions import *
import requests
from logic.time_handler import get_time
global steam_api_key
def steam_login_function():
try:
steam_session_token = request.args.get('token')
appid = 555440
response = requests.get(
'https://api.steampowered.com/ISteamUserAuth/AuthenticateUserTicket/v1/?key={}&ticket={}&appid={}'.format(
steam_api_key, steam_session_token, appid))
if response.json() == {"response": {"error": {"errorcode": 102, "errordesc": "Ticket for other app"}}}:
appid = 854040
response = requests.get(
'https://api.steampowered.com/ISteamUserAuth/AuthenticateUserTicket/v1/?key={}&ticket={}&appid={}'.format(
steam_api_key, steam_session_token, appid))
steamid = response.json()["response"]["params"]["steamid"]
# owner_id = response.json()["response"]["params"]["result"]["ownersteamid"] # This is providerId
userid, token = mongo.user_db_handler(steamid)
current_time, expire_time = get_time()
logger.graylog_logger(level="info", handler="steam_login", message="User {} logged in".format(steamid))
# Read: Doc -> AUTH
# You can copy and paste the JSON from the Auth Doc here. If you don't have a steam api key.
# The Client does not validate this and just uses it.
return jsonify({"preferredLanguage": "en", "friendsFirstSync": {"steam": True}, "fixedMyFriendsUserPlatformId":
{"steam": True}, "id": userid, "provider": {"providerId": steamid, "providerName": "steam", "userId":
userid}, "providers": [{"providerName": "steam", "providerId": steamid}], "friends": [], "triggerResults":
{"success": [], "error": []}, "tokenId": userid, "generated": current_time,
"expire": expire_time,
"userId": userid, "token": token})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="steam_login", message=e)
# This works
@app.route("/api/v1/auth/provider/steam/login", methods=["POST"])
def steam_login():
# Read Doc\SteamAuth.md for more information
ip = check_for_game_client("soft")
user_agent = sanitize_input(request.headers.get('User-Agent'))
request_token = sanitize_input(request.args.get('token'))
if user_agent.startswith("TheExit/++UE4+Release-4.2"):
if request_token == "140000007B7B7B7B02000000E3FA3952010010017B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B7B":
userid, token = mongo.user_db_handler("Debug_session")
current_time, expire_time = get_time()
return_val = jsonify({"preferredLanguage": "en", "friendsFirstSync": {"steam": True},
"fixedMyFriendsUserPlatformId":
{"steam": True}, "id": userid,
"provider": {"providerId": userid, "providerName": "steam", "userId":
userid}, "providers": [{"providerName": "steam", "providerId": userid}],
"friends": [],
"triggerResults":
{"success": [], "error": []}, "tokenId": userid, "generated": current_time,
"expire": expire_time,
"userId": userid, "token": token})
session_cookie = session_manager.create_session(userid)
return_val.set_cookie("bhvrSession", session_cookie)
return return_val
try:
return_val = steam_login_function()
session_cookie = session_manager.create_session(return_val.json["id"])
print(f"Logged in with token: {session_cookie}", file=sys.stderr)
return_val.set_cookie("bhvrSession", session_cookie)
return return_val
except Exception as e:
logger.graylog_logger(level="error", handler="steam_login", message=e)
abort(401, "Unauthorized")
elif user_agent.startswith("game=TheExit, engine=UE4, version="):
return_val = steam_login_function()
session_cookie = session_manager.create_session(return_val.json["id"])
return_val.set_cookie("bhvrSession", session_cookie)
return return_val
else:
logger.graylog_logger(level="error", handler="steam_login", message={"text": "Access denied to User Agent",
"User-Agent": user_agent, "IP": ip})
abort(401, "Unauthorized")
# Dont know if this works
@app.route("/api/v1/modifierCenter/modifiers/me", methods=["GET"])
def modifiers():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
steamid, token = mongo.get_data_with_list(login=userid, login_steam=False,
items={"token", "steamid"})
try:
return jsonify({"TokenId": token, "UserId": userid, "RoleIds": ["755D4DFE-40DA1512-B01E3D8C-FF3C8D4D",
"C50FFFBF-46866131-82F45890-651797CE"]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="modifiers_me", message=e)
# This works
@app.route("/moderation/check/username", methods=["POST"])
def moderation_check_username():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
request_var = request.get_json()
userid = sanitize_input(request_var["userId"])
username = sanitize_input(request_var["username"])
steamid, token = mongo.get_user_info(userId=userid)
# temp test
return jsonify({
"PlayerName": username,
"UserId": steamid
})
#
return jsonify({"Id": userid, "Token": token,
"Provider": {"ProviderName": request_var["username"],
"ProviderId": steamid}}) # CLIENT:{"userId": "ID-ID-ID-ID-SEE-AUTH", "username": "Name-Name-Name"}
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="moderation_check_username", message=e)
# Doesn't work
@app.route("/api/v1/progression/experience", methods=["POST"])
def progression_experience():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
logger.graylog_logger(level="info", handler="user_handling_progression_experience", message=request.get_json())
return jsonify({"List": [
{"ObjectId": "PlayerProgression", "SchemaVersion": 11122233344, "Version": 11122233345,
"Data": {"ObjectId": "PlayerProgression", "Experience": 100, "Version": 1}},
{"ObjectId": "RunnerProgression", "SchemaVersion": 11122233345, "Version": 11122233345,
"Data": {"ObjectId": "Runner.Smoke", "Experience": 100, "Version": 1}},
{"ObjectId": "RunnerProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Runner.Ghost", "Experience": 100, "Version": 1}},
{"ObjectId": "RunnerProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Runner.Ink", "Experience": 100, "Version": 1}},
{"ObjectId": "RunnerProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Runner.Sawbones", "Experience": 100, "Version": 1}},
{"ObjectId": "RunnerProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Runner.Switch", "Experience": 100, "Version": 1}},
{"ObjectId": "RunnerProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Runner.Dash", "Experience": 100, "Version": 1}},
{"ObjectId": "HunterProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Hunter.Inquisitor", "Experience": 100, "Version": 1}},
{"ObjectId": "HunterProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Hunter.Stalker", "Experience": 100, "Version": 1}},
{"ObjectId": "HunterProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Hunter.Poacher", "Experience": 100, "Version": 1}},
{"ObjectId": "HunterProgression", "SchemaVersion": 11122233346, "Version": 11122233346,
"Data": {"ObjectId": "Hunter.Mass", "Experience": 100, "Version": 1}}
]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="progression_experience", message=e)
@app.route("/api/v1/extensions/challenges/getChallenges", methods=["POST"])
def challenges_get_challenges():
# client: {"data":{"userId":"619d6f42-db87-4f3e-8dc9-3c9995613614","challengeType":"Daily"}}
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
response = request.get_json()
challenge_type = sanitize_input(response["data"]["challengeType"])
if challenge_type == "Weekly":
return jsonify({"Challenges": ["ARBDamage_HunterWeekly", "AssaultRifleWins_HunterWeekly",
"BleedOut_HunterWeekly", "BleedOut_RunnerWeekly", "Damage_HunterWeekly",
"Double_HunterWeekly", "ActivateDrones", "Efficient_HunterWeekly",
"Emotional_HunterWeekly", "Emotional_RunnerWeekly", "Greed_HunterWeekly",
"Greed_RunnerWeekly", "Headshot", "HuntingShotgun_HunterWeekly",
"InDenial_HunterWeekly", "LMGWins_HunterWeekly", "Hunter_WeeklyMines_Name",
"Mines_RunnerWeekly", "Reveals_HunterWeekly", "RingOut_HunterWeekly",
"Shields_RunnerWeekly", "ShotgunDowns_HunterWeekly", "Speed_HunterWeekly",
"Speed_RunnerWeekly", "Stuns_RunnerWeekly", "Turrets_HunterWeekly",
"Turrets_RunnerWeekly", "BleedOut_RunnerWeekly", "Wasteful_HunterWeekly",
"Wasteful_RunnerWeekly", "WUP_HunterWeekly", "WUP_RunnerWeekly"]})
elif challenge_type == "Daily":
return jsonify({"Challenges": ["Daily_Domination_Hunter", "Daily_Domination_Runner"]})
else:
logger.graylog_logger(level="error", handler="getChallenges",
message=f"Unknown challenge type {challenge_type}")
return jsonify({"status": "error"})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="getChallenges", message=e)
@app.route("/api/v1/extensions/challenges/executeChallengeProgressionOperationBatch", methods=["POST"])
def challenges_execute_challenge_progression_operation_batch():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
logger.graylog_logger(level="info", handler="logging_executeChallengeProgressionOperationBatch",
message=request.get_json())
return jsonify({"Id": "AssaultRifleWins_HunterWeekly", "Type": 2, "Title": "Hunter_DroneCharger_Name",
"Body": "Hunter_DroneCharger_DESC", "Progress": 1, "ValueToReach": 10, "TimeLeft": 1440000000,
"ShouldShowCompleteAnimation": True, "Rewards":
[{"Type": "Weekly", "Id": "C90F72FC4D61B1F2FBC73F8A4685EA41", "Amount": 1.0,
"Claimed": False}]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="logging_executeChallengeProgressionOperationBatch",
message=e)
# idk dont think it works
@app.route("/api/v1/inventories", methods=["GET"])
def inventories():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
page = request.args.get('page', default=0, type=int)
limit = request.args.get('limit', default=500, type=int)
if page == 0:
return jsonify({"Code": 200, "Message": "OK",
"Data": {"PlayerId": userid,
"Inventory": [
{"ObjectId": "16FEF910-4BD42353-C010579D-56FD5B2F", "Quantity": 1,
"LastUpdateAt": 1687377305},
{"ObjectId": "C1672541-4A4B16B9-AD557C9E-E865D113", "Quantity": 1,
"LastUpdateAt": 1687377305},
{"ObjectId": "56B7B6F6-473712D0-B7A2F992-BB2C16CD", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "33E6325A-4E098D5D-47DBD48A-DE746024", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "18D077C2-4D7418C1-2CDE2297-CC661AF7", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "7B2C394F-46245407-23117D83-A6752CED", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "33E6325A-4E098D5D-47DBD48A-DE746024", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "38E5F7F2-41E2BA11-77419BB3-12FC1ACE", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "1A09DB19-434DA733-AAD3D9B5-B1929CD4", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "19FB6205-4E644ECD-C831E29F-C5B9E501", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "32065218-4E1A719D-EF1D3C93-95EE7344", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "69055D53-4DF27180-C4B36CAB-4B651054", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "1F5CD900-4224C567-46D81991-AA40448A", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "1E08AFFA-485E92BA-FF2C1BB8-5CEFB81E", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "01AFD779-45C31407-5E09ACBF-70455761", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "7CE5AFBF-459102E5-728DCDAA-6F88C0F1", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "2DBF9B11-4B82A639-40936396-CBA68BCD", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "10A8C667-45801664-6E2EFA94-52E3141A", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "08DC38B6-470A7A5B-0BA025B9-6279DAA8", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "51595917-43CBF0B5-7EC6FEB3-341960D6", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "36466540-42433114-08F6A0BD-4DCE05BD", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "307A0B13-417737DE-D675309F-8B978AB8", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "791F12E0-47DA9E26-E246E385-9C3F587E", "Quantity": 1,
"LastUpdateAt": 1687377305}
, {"ObjectId": "8A5BF227-4640C2F2-3EF3C996-A6F6404D", "Quantity": 1,
"LastUpdateAt": 1687377305}
], "NextPage": 0}})
elif page == 1:
return jsonify({"Code": 200, "Message": "OK", "Data": {"PlayerId": userid, "Inventory": [
{"ObjectId": "C1672541-4A4B16B9-AD557C9E-E865D113", "Quantity": 1, "LastUpdateAt": 1687377305}
], "NextPage": 0}})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="inventories", message=e)
# idk if this works
@app.route("/api/v1/players/me/splinteredstates/ProgressionGroups", methods=["GET"])
def progression_groups():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
# This is the real code but need to build this first
# return jsonify({"UserId": userid, "StateName": "Fstring", "Segment": "Fstring", "ObjectId": "Fstring",
# "Version": 1111, "schemaVersion": 1111, "Data": {}})
return jsonify({"List": [{"ObjectId": "C50FFFBF-46866131-82F45890-651797CE",
"SchemaVersion": 11111111,
"Version": 11111111,
"Data":
[{"Level": 5, "Ratio": 0.111}]},
{"ObjectId": "755D4DFE-40DA1512-B01E3D8C-FF3C8D4D",
"SchemaVersion": 11111111,
"Version": 11111111,
"Data":
[{"Level": 5, "Ratio": 0.111}]}
]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="ProgressionGroups", message=e)
# This works
@app.route("/api/v1/players/ban/status", methods=["GET"])
def ban_status():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
ban_data = mongo.get_data_with_list(login=userid, login_steam=False,
items={"is_banned", "ban_reason", "ban_start", "ban_expire"})
if ban_data is None:
return jsonify({"status": "error"})
elif ban_data["is_banned"]:
return jsonify({"IsBanned": ban_data["is_banned"], "BanInfo": {"BanPeriod": 10,
"BanReason": ban_data["ban_reason"],
"BanStart": ban_data["ban_start"],
"BanEnd": ban_data["ban_expire"],
"Confirmed": False, "Pending": False}})
elif not ban_data["is_banned"]:
return jsonify({"IsBanned": ban_data["is_banned"], "BanInfo": {"BanPeriod": 0,
"BanReason": "None",
"BanStart": 0,
"BanEnd": 0,
"Confirmed": False, "Pending": False}})
else:
return jsonify({"status": "error"})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="ban_status", message=e)
# broken. no need to fix... OG DG endpoint. Not needed.
@app.route("/api/v1/players/ban/getbaninfo", methods=["GET"])
def get_ban_info():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
return jsonify({"BanPeriod": None, "BanReason": None, "BanStart": None, "BanEnd": None,
"Confirmed": False})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="ban_status", message=e)
# This works
@app.route("/api/v1/wallet/currencies", methods=["GET"])
def wallet_currencies():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
currencies = mongo.get_data_with_list(login=userid, login_steam=False,
items={"currency_blood_cells", "currency_iron", "currency_ink_cells"})
return jsonify({"List": [{"Currency": "CurrencyA", "Balance": currencies["currency_iron"],
"CurrencyGroup": "SoftCurrencyGroup", "LastRefillTimeStamp": "1684862187"},
{"Currency": "CurrencyB", "Balance": currencies["currency_blood_cells"],
"CurrencyGroup": "SoftCurrencyGroup", "LastRefillTimeStamp": "1684862187"},
{"Currency": "CurrencyC", "Balance": currencies["currency_ink_cells"],
"CurrencyGroup": "SoftCurrencyGroup", "LastRefillTimeStamp": "1684862187"},
{"Currency": "HARD_CURRENCY", "Balance": 6969,
"CurrencyGroup": "HardCurrencyGroup", "LastRefillTimeStamp": "1684862187"},
{"Currency": "PROGRESSION_CURRENCY", "Balance": 10000,
"CurrencyGroup": "HardCurrencyGroup", "LastRefillTimeStamp": "1684862187"}]})
except TypeError:
return jsonify({"status": "error"})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="currencies", message=e)
# Does not work. Old DG endpoint. Not needed.
@app.route("/api/v1/wallet/currencies/PROGRESSION_CURRENCY", methods=["GET"])
def wallet_currencies_progression():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
return jsonify([{"Currency": 1, "Amount": 10}, {"Currency": 2, "Amount": 10}, {"Currency": 3, "Amount": 10}])
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="currencies", message=e)
# Dont know if this works. Dont think it does.
@app.route("/api/v1/players/me/splinteredstates/TheExit_Achievements", methods=["GET"])
def achievements_get():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
# I don't know how this fixes the console error but if it works for now idc...
return jsonify({"UserId": userid, "StateName": "Fstring", "Segment": "FString", "List": [
{
"ObjectId": "EFAB89E6465D1163D62A07B11048F2B6",
"Version": 11111111,
"SchemaVersion": 11111111,
"Data":
{
"Key": "Value"
}
},
{
"ObjectId": "2CAEBB354D506D7C43B941BC1DA775A0",
"Version": 11111111,
"SchemaVersion": 11111111,
"Data":
{
"Key": "Value"
}
},
{
"ObjectId": "E51981B946BEE3D45C5C41B2FCFF310B",
"Version": 11111111,
"SchemaVersion": 11111111,
"Data":
{
"Key": "Value"
}
},
{
"ObjectId": "AAD05B9D46471DC811BBE0BA91916AB7",
"Version": 11111111,
"SchemaVersion": 11111111,
"Data":
{
"Key": "Value"
}
},
{
"ObjectId": "BA2D4A5445CB70276A8F5D9E1AFCE080",
"Version": 11111111,
"SchemaVersion": 11111111,
"Data":
{
"Key": "Value"
}
}
]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="Achievment_handler", message=e)
# Does not work
@app.route("/api/v1/messages/count", methods=["GET"])
def messages_count():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
unread_message_ids = mongo.get_data_with_list(login=userid, login_steam=False, items={"unread_msg_ids"})
if unread_message_ids["unread_msg_ids"] == "" or unread_message_ids is None:
return jsonify({"Count": 0})
else:
try:
id_len = unread_message_ids["unread_msg_ids"].split(",")
return jsonify({"Count": len(id_len)})
except TypeError:
return jsonify({"Count": unread_message_ids["unread_msg_ids"]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="messages_count", message=e)
@app.route("/api/v1/messages/list", methods=["GET", "DELETE"])
def messages_list():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
if request.method == "GET":
limit = int(request.args.get("limit", 500))
page = int(request.args.get("page", 1))
unread_message_ids = mongo.get_data_with_list(login=userid, login_steam=False, items={"unread_msg_ids"})
ids = []
for items in unread_message_ids.get("unread_msg_ids", []):
ids.append(str(items))
json_file_path = os.path.join(app.root_path, "json", "placeholders", "messages.json")
with open(json_file_path, "r") as json_file:
data = json.load(json_file)
messages = []
for message_id in ids:
messages.extend(data.get(message_id, []))
total_messages = len(messages)
if total_messages <= limit * page:
pages = 0
else:
pages = ceil(total_messages / limit) - page
start_idx = (page - 1) * limit
end_idx = start_idx + limit
messages_page = messages[start_idx:end_idx]
return jsonify({"messages": messages_page, "NetPage": pages})
elif request.method == "DELETE":
return jsonify("", 204)
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="messages_list", message=str(e))
return jsonify({"messages": [], "NetPage": 0})
@app.route("/api/v1/messages/v2/markAs", methods=["POST"])
def messages_mark_as():
# {"messageList":[{"received":1687192385,"recipientId":"2"}],"flag":"READ"}
try:
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
data = request.get_json()
message_list = data["messageList"]
if not message_list:
mongo.write_data_with_list(login=userid, login_steam=False, items_dict={"unread_msg_ids": ""})
return jsonify({"List": [{"Received": get_time(), "Success": True, "RecipientId": userid}]})
message_id = message_list[0]["recipientId"]
unread_messages = mongo.get_data_with_list(login=userid, login_steam=False, items={"unread_msg_ids"})
unread_messages = unread_messages["unread_msg_ids"].split(",")
unread_messages.remove(message_id)
unread_messages = ",".join(unread_messages)
data = {"unread_msg_ids": unread_messages}
mongo.write_data_with_list(login=userid, login_steam=False, items_dict=data)
current_timestamp, expiration_timestamp = get_time()
return jsonify({"List": [{"Received": current_timestamp, "Success": True, "RecipientId": userid}]})
except TimeoutError:
return jsonify({"status": "Timeout error"})
except Exception as e:
logger.graylog_logger(level="error", handler="messages_mark_as", message=e)
return jsonify({"status": "API error"})
# Temp response.
@app.route("/moderation/check/chat", methods=["POST"])
def moderation_check_chat():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
data = request.get_json()
userid = sanitize_input(data["userId"])
language = sanitize_input(data["language"])
message = sanitize_input(data["message"])
# Why should we care? Can we get in trouble if we don't?
return jsonify({"status": "success", "result": "OK"}) # Testing stuff
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="moderation_check_chat", message=e)
# This is intently broken. If this works the game crashes in matchmaking.
@app.route("/api/v1/extensions/progression/initOrGetGroups", methods=["POST"])
def extension_progression_init_or_get_groups():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
logger.graylog_logger(level="info", handler="logging_initOrGetGroups", message=request.get_json())
# Client sends: {"data":{"skipProgressionGroups":false,"skipMetadataGroups":false,"playerName":"Steam-Name-Here"}}
# The client cant understand CharacterId for some reason??? But if this is removed the game doesn't load the
# "Choose Hunter or Runner" screen.
return jsonify({
"ProgressionGroups":[
{
"ObjectId":"EGMGroupTypeEnum::RunnerProgression",
"Version":1,
"SchemaVersion":1.1,
"Data":{
"Experience":{
"Level":1,
"CurrentExperience":2,
"ExperienceToReach":30
}
}
},
{
"ObjectId":"EGMGroupTypeEnum::HunterProgression",
"Version":1,
"SchemaVersion":1.1,
"Data":{
"Experience":{
"Level":1,
"CurrentExperience":12,
"ExperienceToReach":30
}
}
},
{
"ObjectId": "EGMGroupTypeEnum::PlayerProgression",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {
"Experience": {
"Level": 1,
"CurrentExperience": 12,
"ExperienceToReach": 30
}
}
}
],
"MetadataGroups":[
{
"ObjectId": "EGMGroupTypeEnum::RunnerMetadata",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {"CharacterId": {"TagName": "Runner.Ink"},
"Equipment": [],
"EquippedPerks": ["1E08AFFA-485E92BA-FF2C1BB8-5CEFB81E"],
"EquippedPowers": [],
"EquippedWeapons": ["C8AF3D53-4973F82F-ADBB40BD-A96F9DCD"],
"EquippedBonuses": []
}
},
{
"ObjectId": "EGMGroupTypeEnum::HunterMetadata",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {"CharacterId": {"TagName": "Hunter.Inquisitor"},
"Equipment": [],
"EquippedPerks": ["791F12E0-47DA9E26-E246E385-9C3F587E"],
"EquippedPowers": ["08DC38B6-470A7A5B-0BA025B9-6279DAA8"],
"EquippedWeapons": ["307A0B13-417737DE-D675309F-8B978AB8"],
"EquippedBonuses": []
}
},
{
"ObjectId": "EGMGroupTypeEnum::PlayerMetadata",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {
}
}
]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="logging_initOrGetGroups", message=e)
@app.route("/api/v1/extensions/progression/updateMetadataGroup", methods=["POST"])
def update_metadata_group():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
data = request.get_json()
object_id = data["data"]["objectId"]
version = data["data"]["version"]
metadata = data["data"]["metadata"]
last_played_faction = metadata["lastPlayedFaction"]
last_played_runner_id = metadata["lastPlayedRunnerId"]
last_played_hunter_id = metadata["lastPlayedHunterId"]
should_play_without_contextual_help = metadata["shouldPlayWithoutContextualHelp"]
has_played_death_garden_1 = metadata["hasPlayedDeathGarden1"]
reason = data["data"]["reason"]
logger.graylog_logger(level="info", handler="logging_updateMetadataGroup", message=data)
# return jsonify({"status": "success"})
return jsonify({
"ProgressionGroups":[
{
"ObjectId":"EGMGroupTypeEnum::RunnerProgression",
"Version":1,
"SchemaVersion":1.1,
"Data":{
"Experience":{
"Level":1,
"CurrentExperience":2,
"ExperienceToReach":30
}
}
},
{
"ObjectId":"EGMGroupTypeEnum::HunterProgression",
"Version":1,
"SchemaVersion":1.1,
"Data":{
"Experience":{
"Level":1,
"CurrentExperience":12,
"ExperienceToReach":30
}
}
},
{
"ObjectId": "EGMGroupTypeEnum::PlayerProgression",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {
"Experience": {
"Level": 1,
"CurrentExperience": 12,
"ExperienceToReach": 30
}
}
}
],
"MetadataGroups":[
{
"ObjectId": "EGMGroupTypeEnum::RunnerMetadata",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {"CharacterId": {"TagName": last_played_runner_id},
"Equipment": [],
"EquippedPerks": ["1E08AFFA-485E92BA-FF2C1BB8-5CEFB81E"],
"EquippedPowers": [],
"EquippedWeapons": ["C8AF3D53-4973F82F-ADBB40BD-A96F9DCD"],
"EquippedBonuses": []
}
},
{
"ObjectId": "EGMGroupTypeEnum::HunterMetadata",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {"CharacterId": {"TagName": last_played_hunter_id},
"Equipment": [],
"EquippedPerks": ["791F12E0-47DA9E26-E246E385-9C3F587E"],
"EquippedPowers": ["08DC38B6-470A7A5B-0BA025B9-6279DAA8"],
"EquippedWeapons": ["307A0B13-417737DE-D675309F-8B978AB8"],
"EquippedBonuses": []
}
},
{
"ObjectId": "EGMGroupTypeEnum::PlayerMetadata",
"Version": 1,
"SchemaVersion": 1.1,
"Data": {
"LastPlayedFaction": last_played_faction, "LastPlayedRunnerId": {"tagName": last_played_runner_id},
"LastPlayedHunterId": {"tagName": last_played_hunter_id},
"shouldPlayWithoutContextualHelp":should_play_without_contextual_help,"hasPlayedDeathGarden1":True
}
}
]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="logging_updateMetadataGroup", message=e)
# POST https://api.zkwolf.com/api/v1/extensions/progression/updateMetadataGroup HTTP/1.1
# {"data":{"objectId":"PlayerMetadata","version":2,"metadata":{
# "lastPlayedFaction":"Runner","lastPlayedRunnerId":{"tagName":"Runner.Ink"},"lastPlayedHunterId":{"tagName":"None"},
# "shouldPlayWithoutContextualHelp":false,"hasPlayedDeathGarden1":false},"reason":"SetLastPlayedCharacterId"}}
# dont know if this works. Hope it does.
@app.route("/api/v1/extensions/inventory/unlockSpecialItems", methods=["POST"])
def inventory_unlock_special_items():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
logger.graylog_logger(level="info", handler="unknown_unlockSpecialItems", message=request.get_json())
return jsonify({"UnlockedItems": ["9F54DE7A-4E15935B-503850A1-27B0A2A4"]})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="unknown_unlockSpecialItems", message=e)
# POST https://api.zkwolf.com//api/v1/extensions/progression/resetCharacterProgressionForPrestige HTTP/1.1
# {"data":{"characterId":"755D4DFE40DA1512B01E3D8CFF3C8D4D"}}
@app.route("/api/v1/extensions/progression/resetCharacterProgressionForPrestige", methods=["POST"])
def reset_prestige():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
data = request.get_json()
character_id = data["data"]["characterId"]
logger.graylog_logger(level="info", handler="resetCharacterProgressionForPrestige", message=data)
return jsonify({"status": "success"})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="resetCharacterProgressionForPrestige", message=e)
@app.route("/api/v1/extensions/challenges/getChallengeProgressionBatch", methods=["POST"])
def challenges_get_challenge_progression_batch():
check_for_game_client("strict")
session_cookie = sanitize_input(request.cookies.get("bhvrSession"))
userid = session_manager.get_user_id(session_cookie)
try:
logger.graylog_logger(level="info", handler="logging_getChallengeProgressionBatch",
message=request.get_json())
# MirrorsExtModelGetChallengeProgressionBatchResponse -> TArray MirrorsExtModelChallengeProgressionOperation
# {"data":{"userId":"619d6f42-db87-4f3e-8dc9-3c9995613614","challengeIds":["BA2D4A5445CB70276A8F5D9E1AFCE080",
# "AAD05B9D46471DC811BBE0BA91916AB7","E51981B946BEE3D45C5C41B2FCFF310B","2CAEBB354D506D7C43B941BC1DA775A0",
# "EFAB89E6465D1163D62A07B11048F2B6"]}}
data = request.get_json()
challenge_ids = data["data"]["challengeIds"]
challenge_list = []
for challenge in challenge_ids:
# todo Add Database Logic
# Achievement_0_Id=EFAB89E6465D1163D62A07B11048F2B6
# Achievement_0_bIsHidden=false
# Achievement_0_Title="Not A Quitter"
# Achievement_0_LockedDesc="Complete 50 matches as either a Runner, Hunter or a combination of the two"
# Achievement_0_UnlockedDesc="Not A Quitter achieved"
# Achievement_1_Id=2CAEBB354D506D7C43B941BC1DA775A0
# Achievement_1_bIsHidden=false
# Achievement_1_Title="Escapist"
# Achievement_1_LockedDesc="Escape the Garden 10 times"
# Achievement_1_UnlockedDesc="Escapist achieved"
# Achievement_2_Id=E51981B946BEE3D45C5C41B2FCFF310B
# Achievement_2_bIsHidden=false
# Achievement_2_Title="Special Delivery"
# Achievement_2_LockedDesc="Deliver a total of 500 Blood across matches"
# Achievement_2_UnlockedDesc="Special Delivery achieved"
# Achievement_3_Id=AAD05B9D46471DC811BBE0BA91916AB7
# Achievement_3_bIsHidden=false
# Achievement_3_Title="Don't Be A Downer"
# Achievement_3_LockedDesc="Down a total of 50 Runners"
# Achievement_3_UnlockedDesc="Don't Be A Downer achieved"
# Achievement_4_Id=BA2D4A5445CB70276A8F5D9E1AFCE080
# Achievement_4_bIsHidden=false
# Achievement_4_Title="Drone Zone"
# Achievement_4_LockedDesc="Power up a total of 100 Drones across matches"
# Achievement_4_UnlockedDesc="Drone Zone achieved"
#
# ({"Id": "AssaultRifleWins_HunterWeekly", "Type": 2, "Title": "Hunter_DroneCharger_Name",
# "Body": "Hunter_DroneCharger_DESC", "Progress": 1, "ValueToReach": 10, "TimeLeft": 1440000000,
# "ShouldShowCompleteAnimation": True, "Rewards":
# [{"Type": "Weekly", "Id": "C90F72FC4D61B1F2FBC73F8A4685EA41", "Amount": 1.0,
# "Claimed": False}]})
# MirrorsExtModelChallengeProgressionOperation
if challenge == "BA2D4A5445CB70276A8F5D9E1AFCE080":
challenge_list.append({"ChallengeId": "BA2D4A5445CB70276A8F5D9E1AFCE080",
"Type": 2,
"ChallengeType": 4,
"OperationName": "get",
"OperationData": {"Type": "Achievement", "Progress": 1, "ValueToReach": 100,
"Body": "Power up a total of 100 Drones across matches",
"Title": "Hunter_DroneCharger_Name",
"ShouldShowCompleteAnimation": True,
"Rewards": [{"Type": "Weekly",
"Id": "C90F72FC4D61B1F2FBC73F8A4685EA41",
"Amount": 1.0, "Claimed": False}]}})
elif challenge == "AAD05B9D46471DC811BBE0BA91916AB7":
challenge_list.append({"ChallengeId": "AAD05B9D46471DC811BBE0BA91916AB7",
"OperationName": "get",
"Type": "Weekly",
"ChallengeType": "Daily",
"OperationData": {"Type": "Achievement",
"Progress": 1,
"ValueToReach": 50,
"Body": "Down a total of 50 Runners",
"Title": "Don't Be A Downer",
"ShouldShowCompleteAnimation": True,
"Rewards": [{"Type": "Weekly",
"Id": "C90F72FC4D61B1F2FBC73F8A4685EA41",
"Amount": 1.0, "Claimed": False}]}})
elif challenge == "E51981B946BEE3D45C5C41B2FCFF310B":
challenge_list.append({"ChallengeId": "E51981B946BEE3D45C5C41B2FCFF310B",
"OperationName": "get",
"OperationData": {
"Type": "Achievement",
"Progress": 1,
"ValueToReach": 500,
"Body": "Deliver a total of 500 Blood across matches",
"Title": "Special Delivery",
"ShouldShowCompleteAnimation": True,
"Rewards": [{"Type": "Weekly",
"Id": "C90F72FC4D61B1F2FBC73F8A4685EA41",
"Amount": 1.0, "Claimed": False}]
}})
elif challenge == "2CAEBB354D506D7C43B941BC1DA775A0":
challenge_list.append({"ChallengeId": "2CAEBB354D506D7C43B941BC1DA775A0",
"OperationName": "get",
"OperationData": {
"Type": "Achievement",
"Progress": 1,
"ValueToReach": 10,
"Body": "Escape the Garden 10 times",
"Title": "Escapist",
"ShouldShowCompleteAnimation": True,
"Rewards": [{"Type": "Weekly",
"Id": "C90F72FC4D61B1F2FBC73F8A4685EA41",
"Amount": 1.0, "Claimed": False}]
}})
elif challenge == "EFAB89E6465D1163D62A07B11048F2B6":
challenge_list.append({"ChallengeId": "EFAB89E6465D1163D62A07B11048F2B6",
"OperationName": "get",
"OperationData": {
"Type": "Achievement",
"Progress": 1,
"ValueToReach": 50,
"Body": "Complete 50 matches as either a Runner, Hunter or a combination of the two",
"Title": "Not A Quitter",
"ShouldShowCompleteAnimation": True,
"Rewards": [{"Type": "Weekly",
"Id": "C90F72FC4D61B1F2FBC73F8A4685EA41",
"Amount": 1.0, "Claimed": False}]
}})
elif challenge == "24CE65364362CB2A90C0E08876176937":
challenge_list.append({"challengeId": "24CE65364362CB2A90C0E08876176937",
"operationName":"complete"
})
else:
logger.graylog_logger(level="error", handler="logging_missing_challenge",
message=f"Unknown challenge id {challenge}")
return jsonify({"ProgressionBatch": challenge_list})
except TimeoutError:
return jsonify({"status": "error"})
except Exception as e:
logger.graylog_logger(level="error", handler="logging_getChallengeProgressionBatch", message=e)
Reference in New Issue View Git Blame Copy Permalink