k

.env

@@ -30,7 +30,7 @@ HDEV_SMS_API_ID=HDEV-23fb1b59-aec0-4aef-a351-bfc1c3aa3c52-ID
 HDEV_SMS_API_KEY=HDEV-6e36c286-19bb-4b45-838e-8b5cd0240857-KEY
 
 # Chat Model Configuration
-CHAT_MODEL=meta-llama/llama-3.1-8b-instruct
+CHAT_MODEL=meta-llama/llama-4-maverick
 EMBED_MODEL=nomic-embed-text
 SENT_EMBED_MODEL=nomic-embed-text
 OLLAMA_BASE_URL=https://openrouter.ai/api/v1

app.py

@@ -531,7 +531,7 @@ class RiskDetector:
     def __init__(self):
         # Risk indicators patterns
         self.critical_indicators = [
-            r'\b(suicide|kill myself|end it all',
+            r'\b(suicide|kill myself|end it all'
         ]
         self.high_risk_indicators = [
             r'\b(hopeless|worthless|burden|better off without)\b',

chatbot/app.js

@@ -193,7 +193,12 @@
       await updateHistoryList();
     } catch (err) {
       console.error("session error", err);
-      appendMessage("bot", "Could not start session. Try again.");
+      // Fallback: create a client-side conversation ID if server session fails
+      if (!convId) {
+        convId = newConvId();
+        localStorage.setItem("aimhsa_conv", convId);
+      }
+      appendMessage("bot", "Session initialized. How can I help you today?");
     }
   }
 
@@ -256,15 +261,21 @@
       if (account) payload.account = account;
       const model = getSelectedModel();
       if (model) payload.model = model;
+      
       const resp = await api("/ask", {
         method: "POST",
         headers: { "Content-Type": "application/json" },
         body: JSON.stringify(payload),
       });
+      
       removeTypingIndicator();
-      appendMessage("assistant", resp.answer || "(no answer)");
       
-      // Silent language detection: backend already replies in user's language
+      // Ensure we got a valid response
+      if (!resp.answer || resp.answer.trim() === '') {
+        appendMessage("assistant", "I'm here to help. Could you please rephrase your question?");
+      } else {
+        appendMessage("assistant", resp.answer);
+      }
       
       // Risk assessment is handled in backend only (no display)
       // But show booking confirmation to user
@@ -286,7 +297,17 @@
     } catch (err) {
       console.error("ask error", err);
       removeTypingIndicator();
-      appendMessage("bot", "Error contacting server. Try again.");
+      
+      // Provide helpful error message based on error type
+      let errorMessage = "I'm having trouble connecting to the server. Please check your internet connection and try again.";
+      
+      if (err.message && err.message.includes('405')) {
+        errorMessage = "There's a server configuration issue. Please try refreshing the page or contact support.";
+      } else if (err.message && err.message.includes('500')) {
+        errorMessage = "The server encountered an error. Please try again in a moment.";
+      }
+      
+      appendMessage("bot", errorMessage);
     } finally {
       disableComposer(false);
     }

run_aimhsa.py

@@ -404,6 +404,56 @@ def api_reset():
     
     return jsonify({"ok": True})
 
+@app.route('/session', methods=['POST'])
+def api_session():
+    """
+    Create or retrieve session by IP or account.
+    Request JSON: { "account": "<optional account id>" }
+    Returns: { "id": "<conv_id>", "new": true|false }
+    """
+    try:
+        data = request.get_json(silent=True) or {}
+    except Exception:
+        data = {}
+    
+    account = (data.get("account") or "").strip()
+    if account:
+        key = f"acct:{account}"
+    else:
+        ip = request.remote_addr or "unknown"
+        key = f"ip:{ip}"
+    
+    # Simple session creation logic
+    conv_id = str(uuid.uuid4())
+    
+    # Save session to database
+    conn = sqlite3.connect(DB_FILE)
+    try:
+        # Check if session exists
+        cur = conn.execute("SELECT conv_id FROM sessions WHERE key = ?", (key,))
+        row = cur.fetchone()
+        if row:
+            # Update existing session
+            conn.execute("UPDATE sessions SET ts = ? WHERE key = ?", (time.time(), key))
+            conn.commit()
+            return jsonify({"id": row[0], "new": False})
+        else:
+            # Create new session
+            conn.execute(
+                "INSERT INTO sessions (key, conv_id, ts) VALUES (?, ?, ?)",
+                (key, conv_id, time.time())
+            )
+            
+            # Also create a conversations entry
+            conn.execute(
+                "INSERT OR IGNORE INTO conversations (conv_id, owner_key, preview, ts) VALUES (?, ?, ?, ?)",
+                (conv_id, key, "New chat", time.time())
+            )
+            conn.commit()
+            return jsonify({"id": conv_id, "new": True})
+    finally:
+        conn.close()
+
 # ============================================================================
 # MAIN FUNCTION
 # ============================================================================