more playerrank queries

Author: tslashd

surftimer/ck_playerrank.py

@@ -429,6 +429,43 @@ async def selectRankedPlayers(request: Request, response: Response):
 
     return xquery
 
+@router.get(
+    "/surftimer/selectRankedPlayer",
+    name="Select Ranked Players",
+    tags=["ck_playerrank"],
+)
+async def selectRankedPlayer(request: Request, response: Response, steamid32: str):
+    """`char[] sql_selectRankedPlayer = ....`"""
+    tic = time.perf_counter()
+
+    # Check if data is cached in Redis
+    cache_key = f"selectRankedPlayer"
+    cached_data = get_cache(cache_key)
+    if cached_data is not None:
+        print(f"[Redis] Loaded '{cache_key}' ({time.perf_counter() - tic:0.4f}s)")
+        return JSONResponse(
+            status_code=status.HTTP_200_OK, content=json.loads(cached_data)
+        )
+
+    xquery = selectQuery(surftimer.queries.sql_selectRankedPlayer.format(steamid32))
+    # xquery = []
+
+    if len(xquery) > 0:
+        xquery = xquery
+    else:
+        response.status_code = status.HTTP_404_NOT_FOUND
+        xquery = {}
+        xquery["xtime"] = time.perf_counter() - tic
+
+    toc = time.perf_counter()
+
+    print(f"Execution time {toc - tic:0.4f}")
+
+    # Cache the data in Redis
+    set_cache(cache_key, xquery)
+
+    return xquery
+
 
 @router.get(
     "/surftimer/countRankedPlayers",
@@ -590,3 +627,36 @@ async def selectUnknownPlayerProfile(
     set_cache(cache_key, xquery)
 
     return xquery
+
+@router.put(
+    "/surftimer/updatePlayerConnections",
+    name="Update Player Connections",
+    tags=["ck_playerrank"],
+)
+async def updatePlayerConnections(
+    request: Request,
+    response: Response,
+    steamid32: str,
+):
+    """```UPDATE ck_playerrank SET connections = connections + 1 WHERE steamid = '%s';```"""
+    tic = time.perf_counter()
+
+    sql = surftimer.queries.sql_updatePlayerConnections.format(steamid32)
+    xquery = insertQuery(sql)
+
+    content_data = {"updated": xquery, "xtime": time.perf_counter() - tic}
+    if xquery < 1:
+        response.body = json.dumps(content_data).encode('utf-8')
+        response.headers['content-type'] = 'application/json'
+        response.status_code = status.HTTP_304_NOT_MODIFIED
+        return response
+
+    # Prepare the response
+    toc = time.perf_counter()
+    print(f"Execution time {toc - tic:0.4f}")
+
+    response.body = json.dumps(content_data).encode('utf-8')
+    response.headers['content-type'] = 'application/json'
+    response.status_code = status.HTTP_200_OK
+    return response
+

surftimer/queries.py

@@ -72,6 +72,7 @@
     "SELECT COUNT(steamid) FROM ck_playerrank where points > 0 AND style = {};"
 )
 sql_selectPlayerProfile = "SELECT steamid, steamid64, name, country, points, wrpoints, wrbpoints, wrcppoints, top10points, groupspoints, mappoints, bonuspoints, finishedmapspro, finishedbonuses, finishedstages, wrs, wrbs, wrcps, top10s, `groups`, lastseen, countryCode, continentCode FROM ck_playerrank WHERE steamid = '{}' AND style = '{}';"
+sql_updatePlayerConnections = "UPDATE ck_playerrank SET connections = connections + 1 WHERE steamid = '{}';"
 
 ## ck_playertemp
 sql_createPlayertmp = "CREATE TABLE IF NOT EXISTS ck_playertemp (steamid VARCHAR(32), mapname VARCHAR(32), cords1 FLOAT NOT NULL DEFAULT '-1.0', cords2 FLOAT NOT NULL DEFAULT '-1.0', cords3 FLOAT NOT NULL DEFAULT '-1.0', angle1 FLOAT NOT NULL DEFAULT '-1.0',angle2 FLOAT NOT NULL DEFAULT '-1.0',angle3 FLOAT NOT NULL DEFAULT '-1.0', EncTickrate INT(12) DEFAULT '-1.0', runtimeTmp decimal(12,6) NOT NULL DEFAULT '-1.000000', Stage INT, zonegroup INT NOT NULL DEFAULT 0, PRIMARY KEY(steamid,mapname)) DEFAULT CHARSET=utf8mb4;"