elkay frontend api.py pp

phase/Student_view/games/profitpuzzle.py

@@ -1,12 +1,19 @@
-from utils import db as dbapi
+import os, time
 import streamlit as st
+from utils import api as backend         # HTTP to backend Space
+from utils import db as dbapi            # direct DB path (only if DISABLE_DB=0)
+
+DISABLE_DB = os.getenv("DISABLE_DB", "1") == "1"
 
 def _refresh_global_xp():
     user = st.session_state.get("user")
     if not user:
         return
     try:
-        stats = dbapi.user_xp_and_level(user["user_id"])
+        if DISABLE_DB:
+            stats = backend.user_stats(user["user_id"])
+        else:
+            stats = dbapi.user_xp_and_level(user["user_id"])
         st.session_state.xp = stats.get("xp", st.session_state.get("xp", 0))
         st.session_state.streak = stats.get("streak", st.session_state.get("streak", 0))
     except Exception as e:
@@ -279,6 +286,7 @@ def reset_game():
     st.session_state.show_solution = False
     st.session_state.score = 0
     st.session_state.completed_scenarios = []
+    st.session_state.pp_start_ts = time.time()
     st.rerun()
 
 
@@ -288,6 +296,9 @@ def show_profit_puzzle():
     # Load CSS styling
     load_css()
     
+    if "pp_start_ts" not in st.session_state:
+        st.session_state.pp_start_ts = time.time()
+
     st.markdown("""
     <div class="game-header">
         <h1>🎯 Profit Puzzle Challenge!</h1>
@@ -401,28 +412,58 @@ def show_profit_puzzle():
         # Persist to TiDB if logged in
         user = st.session_state.get("user")
         if user:
+            elapsed_ms = int((time.time() - st.session_state.get("pp_start_ts", time.time())) * 1000)
+
             try:
-                dbapi.record_profit_puzzle_result(
-                    user_id=user["user_id"],
-                    scenario_id=scenario.get("id") or f"scenario_{st.session_state.current_scenario}",
-                    title=scenario.get("title", f"Scenario {st.session_state.current_scenario+1}"),
-                    units=units, price=price, cost=cost,
-                    user_answer=user_val, actual_profit=float(actual_profit),
-                    is_correct=bool(correct), gained_xp=int(reward)
-                )
+                if DISABLE_DB:
+                    # Route to backend Space
+                    backend.record_profit_puzzler_play(
+                        user_id=user["user_id"],
+                        puzzles_solved=1 if correct else 0,
+                        mistakes=0 if correct else 1,
+                        elapsed_ms=elapsed_ms,
+                        gained_xp=reward  # keep UI and server in sync
+                    )
+                else:
+                    # Direct DB path if you keep it
+                    if hasattr(dbapi, "record_profit_puzzler_play"):
+                        dbapi.record_profit_puzzler_play(
+                            user_id=user["user_id"],
+                            puzzles_solved=1 if correct else 0,
+                            mistakes=0 if correct else 1,
+                            elapsed_ms=elapsed_ms,
+                            gained_xp=reward
+                        )
+                    else:
+                        # Fallback to your existing detailed writer
+                        dbapi.record_profit_puzzle_result(
+                            user_id=user["user_id"],
+                            scenario_id=scenario.get("id") or f"scenario_{st.session_state.current_scenario}",
+                            title=scenario.get("title", f"Scenario {st.session_state.current_scenario+1}"),
+                            units=int(scenario["variables"]["units"]),
+                            price=int(scenario["variables"]["sellingPrice"]),
+                            cost=int(scenario["variables"]["costPerUnit"]),
+                            user_answer=float(st.session_state.user_answer),
+                            actual_profit=float(actual_profit),
+                            is_correct=bool(correct),
+                            gained_xp=int(reward)
+                        )
+
                 _refresh_global_xp()
             except Exception as e:
-                st.warning(f"Could not save result: {e}")
+                st.warning(f"Save failed: {e}")
         else:
             st.info("Login to earn and save XP.")
 
         st.session_state.show_solution = True
 
     def next_scenario():
-        if st.session_state.current_scenario < len(scenarios) - 1:
+        if st.session_state.get("current_scenario", 0) < len(st.session_state.get("profit_scenarios", [])) - 1:
             st.session_state.current_scenario += 1
             st.session_state.user_answer = ""
             st.session_state.show_solution = False
+            st.session_state.pp_start_ts = time.time()
+        st.rerun()
 
     def reset_game():
         st.session_state.current_scenario = 0

utils/api.py

@@ -445,17 +445,8 @@ def record_debt_dilemma_play(user_id: int, loans_cleared: int,
     ])
 
 
-def record_profit_puzzler_play(user_id: int, puzzles_solved: int,
-                               mistakes: int, elapsed_ms: int,
-                               gained_xp: int | None = None):
-    payload = {
-        "user_id": user_id,
-        "puzzles_solved": puzzles_solved,
-        "mistakes": mistakes,
-        "elapsed_ms": elapsed_ms,
-    }
+def record_profit_puzzler_play(user_id: int, puzzles_solved: int, mistakes: int, elapsed_ms: int, gained_xp: int | None = None):
+    payload = {"user_id": user_id, "puzzles_solved": puzzles_solved, "mistakes": mistakes, "elapsed_ms": elapsed_ms}
     if gained_xp is not None:
         payload["gained_xp"] = gained_xp
-    return _try_candidates("POST", [
-        ("/games/profit_puzzler/record", {"json": payload}),
-    ])
+    return _try_candidates("POST", [("/games/profit_puzzler/record", {"json": payload})])