added diagnostic route

core/agent.py

@@ -347,6 +347,10 @@ def queue_chat_history_to_telegram(
     user_input: str,
     assistant_response: str,
 ) -> str:
+    token, chat_id = _get_telegram_target(debug=False)
+    if not token or not chat_id:
+        return "FAILED: Telegram credentials are missing from the environment."
+        
     if _submit_background_task("chat_history_log", send_chat_history_to_telegram, session_id, user_input, assistant_response):
         return "QUEUED: chat history scheduled."
     return "FAILED: could not queue chat history."
@@ -423,6 +427,10 @@ def _attempt_notify_arun_with_retry_queue(
     user_input: str,
     user_metadata_json: str = "",
 ) -> str:
+    token, chat_id = _get_telegram_target(debug=False)
+    if not token or not chat_id:
+        return "FAILED: Telegram credentials are missing from the environment."
+
     submitted = _submit_background_task(
         "notify_arun_bg",
         _deliver_notify_arun,

core/api.py

@@ -93,6 +93,8 @@ async def chat_endpoint(req: ChatRequest):
                     pre_escalation_status = "Notification was not confirmed immediately. Retrying in background."
                 elif "QUEUED" in pre_escalation_result:
                     pre_escalation_status = "Sending notification to Arun in the background."
+                elif "credentials are missing" in pre_escalation_result:
+                    pre_escalation_status = "Error: Please set TELEGRAM_BOT_TOKEN and TELEGRAM_CHAT_ID in HuggingFace Spaces Settings!"
                 else:
                     pre_escalation_status = "Notification could not be confirmed."
 
@@ -209,11 +211,35 @@ async def chat_endpoint(req: ChatRequest):
     return StreamingResponse(event_generator(), media_type="application/x-ndjson")
 
 
+
+    return StreamingResponse(event_generator(), media_type="application/x-ndjson")
+
+
 @app.get("/health")
 async def health_check():
     return {"status": "online", "active_sessions": len(active_sessions)}
 
 
+@app.get("/test-telegram")
+def test_telegram():
+    import os, requests, traceback
+    token = os.getenv("TELEGRAM_BOT_TOKEN")
+    chat_id = os.getenv("TELEGRAM_CHAT_ID")
+    if not token or not chat_id:
+        return {"status": "error", "message": "Missing credentials", "has_token": bool(token), "has_chat_id": bool(chat_id)}
+    
+    token = token.strip(' "\'')
+    chat_id = chat_id.strip(' "\'')
+    url = f"https://api.telegram.org/bot{token}/sendMessage"
+    payload = {"chat_id": chat_id, "text": "Test message from HuggingFace backend!"}
+    
+    try:
+        response = requests.post(url, json=payload, timeout=10)
+        return {"status": "finished", "status_code": response.status_code, "response": response.text}
+    except Exception as e:
+        return {"status": "exception", "error": str(e), "traceback": traceback.format_exc()}
+
+
 if __name__ == "__main__":
     import uvicorn
     uvicorn.run("core.api:app", host="0.0.0.0", port=8000, reload=True)