ck_playertemp

Author: tslashd

README.md

@@ -15,7 +15,7 @@ SurfTimer FastAPI
 - [x] ck_maptier
 - [x] ck_playeroptions2
 - [x] ck_playerrank
-- [ ] ck_playertemp
+- [x] ck_playertemp
 - [ ] ck_playertimes
 - [ ] ck_spawnlocations
 - [ ] ck_vipadmins

main.py

@@ -29,6 +29,7 @@
 from surftimer.ck_playeroptions2 import router as ck_playeroptions2_router
 from surftimer.ck_bonus import router as ck_bonus_router
 from surftimer.ck_checkpoints import router as ck_checkpoints_router
+from surftimer.ck_playertemp import router as ck_playertemp_router
 
 
 # Responses
@@ -56,6 +57,7 @@ def to_dict(self):
     "syntaxHighlight.theme": "obsidian",
     "docExpansion": "none",
     "pluginLoadType": "chain",
+    "tagsSorter": "alpha",
 }
 app = FastAPI(
     title="SurfTimer API",
@@ -86,6 +88,7 @@ async def custom_swagger_ui_html_cdn():
 app.include_router(ck_playeroptions2_router)
 app.include_router(ck_bonus_router)
 app.include_router(ck_checkpoints_router)
+app.include_router(ck_playertemp_router)
 
 
 @app.middleware("http")

surftimer/ck_checkpoints.py

@@ -198,7 +198,7 @@ async def selectRecordCheckpoints(
     name="Delete Checkpoint",
     tags=["ck_checkpoints"],
 )
-def deleteCheckpoints(
+async def deleteCheckpoints(
     request: Request,
     response: Response,
     mapname: str,

surftimer/ck_playertemp.py

@@ -0,0 +1,181 @@
+from fastapi import APIRouter, Request, Response, status
+from fastapi.responses import JSONResponse
+from sql import selectQuery, insertQuery
+from globals import append_request_log, get_cache, set_cache
+from pydantic import BaseModel
+import time, json, surftimer.queries
+
+
+router = APIRouter()
+
+
+class PlayerTemp(BaseModel):
+    cords1: str
+    cords2: str
+    cords3: str
+    angle1: str
+    angle2: str
+    angle3: str
+    runtimeTmp: str
+    steamid: str
+    mapname: str
+    EncTickrate: str
+    Stage: int
+    zonegroup: int
+
+
+# ck_playertemp
+@router.post(
+    "/surftimer/insertPlayerTmp",
+    name="Insert Player Temp",
+    tags=["ck_playertemp"],
+)
+async def insertPlayerTmp(request: Request, response: Response, data: PlayerTemp):
+    """```c
+    char[] sql_insertPlayerTmp = ....
+    ```"""
+    tic = time.perf_counter()
+    append_request_log(request)
+
+    xquery = insertQuery(
+        surftimer.queries.sql_insertPlayerTmp.format(
+            data.cords1,
+            data.cords2,
+            data.cords3,
+            data.angle1,
+            data.angle2,
+            data.angle3,
+            data.runtimeTmp,
+            data.steamid,
+            data.mapname,
+            data.EncTickrate,
+            data.Stage,
+            data.zonegroup,
+        )
+    )
+
+    if xquery < 1:
+        return JSONResponse(
+            status_code=status.HTTP_204_NO_CONTENT,
+            content={"inserted": xquery, "xtime": time.perf_counter() - tic},
+        )
+
+    # Prepare the response
+    toc = time.perf_counter()
+    print(f"Execution time {toc - tic:0.4f}")
+    # output = ResponseInsertQuery(xquery)
+
+    return {"inserted": xquery, "xtime": time.perf_counter() - tic}
+
+
+@router.put(
+    "/surftimer/updatePlayerTmp",
+    name="Update Player Temp",
+    tags=["ck_playertemp"],
+)
+async def updatePlayerTmp(request: Request, response: Response, data: PlayerTemp):
+    """```c
+    char[] sql_updatePlayerOptions = ....
+    ```"""
+    tic = time.perf_counter()
+    append_request_log(request)
+
+    xquery = insertQuery(
+        surftimer.queries.sql_updatePlayerTmp.format(
+            data.cords1,
+            data.cords2,
+            data.cords3,
+            data.angle1,
+            data.angle2,
+            data.angle3,
+            data.runtimeTmp,
+            data.steamid,
+            data.mapname,
+            data.EncTickrate,
+            data.Stage,
+            data.zonegroup,
+        )
+    )
+
+    if xquery < 1:
+        return JSONResponse(
+            status_code=status.HTTP_204_NO_CONTENT,
+            content={"updated": xquery, "xtime": time.perf_counter() - tic},
+        )
+
+    # Prepare the response
+    toc = time.perf_counter()
+    print(f"Execution time {toc - tic:0.4f}")
+    # output = ResponseInsertQuery(xquery)
+
+    return {"updated": xquery, "xtime": time.perf_counter() - tic}
+
+
+@router.delete(
+    "/surftimer/deletePlayerTmp",
+    name="Delete Player Temp",
+    tags=["ck_playertemp"],
+)
+async def deletePlayerTmp(
+    request: Request,
+    response: Response,
+    steamid32: str,
+):
+    """```char sql_deletePlayerTmp[] = ....```"""
+    tic = time.perf_counter()
+
+    append_request_log(request)
+
+    xquery = insertQuery(surftimer.queries.sql_deletePlayerTmp.format(steamid32))
+
+    if xquery <= 0:
+        return JSONResponse(
+            status_code=status.HTTP_404_NOT_FOUND,
+            content={"xtime": time.perf_counter() - tic},
+        )
+
+    toc = time.perf_counter()
+    print(f"Execution time {toc - tic:0.4f}")
+
+    return {"inserted": xquery, "xtime": time.perf_counter() - tic}
+
+
+@router.get(
+    "/surftimer/selectPlayerTmp",
+    name="Get Player Temp",
+    tags=["ck_playertemp"],
+)
+async def selectPlayerTmp(
+    request: Request, response: Response, steamid32: str, mapname: str
+):
+    """`char[] sql_selectPlayerTmp = ....`"""
+    tic = time.perf_counter()
+    append_request_log(request)
+
+    # Check if data is cached in Redis
+    cache_key = f"selectPlayerTmp:{steamid32}-{mapname}"
+    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_selectPlayerTmp.format(steamid32, mapname)
+    )
+
+    if xquery:
+        xquery = xquery.pop()
+    else:
+        return JSONResponse(
+            status_code=status.HTTP_404_NOT_FOUND, content=json.loads(cached_data)
+        )
+
+    # Cache the data in Redis
+    set_cache(cache_key, xquery)
+
+    toc = time.perf_counter()
+    print(f"Execution time {toc - tic:0.4f}")
+
+    return xquery