Update main.py

main.py

@@ -204,22 +204,46 @@ def _resolve_uid_by_email(email: str):
         return None
 
 def fetch_syllabus_structure(remote_id: str):
+    url = f"{DATA_API_BASE_URL}/structure/{remote_id}"
     try:
-        resp = requests.get(f"{DATA_API_BASE_URL}/structure/{remote_id}", timeout=10)
-        return resp.json() if resp.status_code == 200 else None
+        logger.info(f"Fetching syllabus: {url}")
+        resp = requests.get(url, timeout=15)
+        logger.info(f"Syllabus fetch {remote_id}: HTTP {resp.status_code}")
+        if resp.status_code == 200:
+            return resp.json()
+        logger.error(f"Syllabus fetch failed {remote_id}: HTTP {resp.status_code} — {resp.text[:200]}")
+        return None
+    except requests.exceptions.Timeout:
+        logger.error(f"Syllabus fetch TIMEOUT after 15s: {url}")
+        return None
+    except requests.exceptions.ConnectionError as e:
+        logger.error(f"Syllabus fetch CONNECTION ERROR: {url} — {e}")
+        return None
     except Exception as e:
-        logger.error(f"Data API fetch {remote_id}: {e}")
+        logger.error(f"Syllabus fetch unexpected error {remote_id}: {type(e).__name__}: {e}")
         return None
 
 def search_syllabus_context(query: str, remote_id: str = None):
+    url = f"{DATA_API_BASE_URL}/search"
     try:
         payload = {"query": query}
         if remote_id:
             payload["filter_subject_id"] = remote_id
-        resp = requests.post(f"{DATA_API_BASE_URL}/search", json=payload, timeout=10)
-        return resp.json().get("results", []) if resp.status_code == 200 else []
+        logger.info(f"Searching syllabus: query='{query[:50]}' subject={remote_id}")
+        resp = requests.post(url, json=payload, timeout=15)
+        logger.info(f"Syllabus search: HTTP {resp.status_code}")
+        if resp.status_code == 200:
+            return resp.json().get("results", [])
+        logger.error(f"Syllabus search failed: HTTP {resp.status_code} — {resp.text[:200]}")
+        return []
+    except requests.exceptions.Timeout:
+        logger.error(f"Syllabus search TIMEOUT after 15s: {url}")
+        return []
+    except requests.exceptions.ConnectionError as e:
+        logger.error(f"Syllabus search CONNECTION ERROR: {url} — {e}")
+        return []
     except Exception as e:
-        logger.error(f"Data API search: {e}")
+        logger.error(f"Syllabus search unexpected error: {type(e).__name__}: {e}")
         return []
 
 # -----------------------------------------------------------------------------
@@ -1720,6 +1744,65 @@ def submit_path_node():
     return jsonify({"success": True, "passed": False, "message": "Score too low. Review the lesson and try again."})
 
 
+
+@app.route("/api/debug/data-api", methods=["GET"])
+def debug_data_api():
+    """
+    Diagnostic endpoint — tests connectivity from app server to infra server.
+    Call this from the browser to see exactly what the app server gets back.
+    Admin only.
+    """
+    uid = verify_token(request.headers.get("Authorization"))
+    if not uid:
+        return jsonify({"error": "Unauthorized"}), 401
+    try:
+        require_role(uid, ["admin"])
+    except PermissionError as e:
+        return jsonify({"error": str(e)}), 403
+
+    results = {"data_api_base_url": DATA_API_BASE_URL, "tests": []}
+
+    # Test 1: root/health
+    for test_path in ["/", "/health", "/v1/subjects"]:
+        url = DATA_API_BASE_URL.rstrip("/v1").rstrip("/") + test_path
+        try:
+            r = requests.get(url, timeout=10)
+            results["tests"].append({
+                "url": url, "status": r.status_code,
+                "ok": r.status_code == 200,
+                "body_preview": r.text[:300]
+            })
+        except Exception as e:
+            results["tests"].append({"url": url, "status": "ERROR", "ok": False, "error": str(e)})
+
+    # Test 2: specific structure fetch
+    test_remote_id = "A_9702"
+    url = f"{DATA_API_BASE_URL}/structure/{test_remote_id}"
+    try:
+        r = requests.get(url, timeout=10)
+        body = r.json() if r.status_code == 200 else r.text[:300]
+        results["tests"].append({
+            "url": url, "status": r.status_code, "ok": r.status_code == 200,
+            "has_tree": isinstance(body, dict) and "tree" in body,
+            "tree_length": len(body.get("tree", [])) if isinstance(body, dict) else 0
+        })
+    except Exception as e:
+        results["tests"].append({"url": url, "status": "ERROR", "ok": False, "error": str(e)})
+
+    # Test 3: search
+    url = f"{DATA_API_BASE_URL}/search"
+    try:
+        r = requests.post(url, json={"query": "kinematics motion"}, timeout=10)
+        body = r.json() if r.status_code == 200 else r.text[:300]
+        results["tests"].append({
+            "url": url, "status": r.status_code, "ok": r.status_code == 200,
+            "results_count": len(body.get("results", [])) if isinstance(body, dict) else 0
+        })
+    except Exception as e:
+        results["tests"].append({"url": url, "status": "ERROR", "ok": False, "error": str(e)})
+
+    return jsonify(results)
+
 # -----------------------------------------------------------------------------
 # 17. MAIN
 # -----------------------------------------------------------------------------