feat: pre-create named session on widget load via /api/session/init

app/api/schemas.py

@@ -25,3 +25,8 @@ class HealthResponse(BaseModel):
 class SessionUpdateNameRequest(BaseModel):
     session_id: str
     user_name: str
+
+
+class SessionInitRequest(BaseModel):
+    session_id: str
+    user_name: str | None = Field(default=None, description="User name to associate with the session at creation time")

app/main.py

@@ -6,7 +6,7 @@ from fastapi.middleware.cors import CORSMiddleware
 from fastapi.staticfiles import StaticFiles
 import os
 
-from app.api.schemas import ChatRequest, ChatResponse, HealthResponse, SessionUpdateNameRequest
+from app.api.schemas import ChatRequest, ChatResponse, HealthResponse, SessionUpdateNameRequest, SessionInitRequest
 from app.core.config import get_settings
 from app.services.embeddings import EmbeddingService
 from app.services.llm import LLMService
@@ -193,6 +193,30 @@ async def update_session_user_name(payload: SessionUpdateNameRequest):
     return {"status": "ok", "new_session_id": new_id}
 
 
+@fastapi_app.post("/api/session/init")
+async def init_session(payload: SessionInitRequest):
+    """
+    Pre-creates a session on widget load — before the user opens the chat.
+    If user_name is provided the session is immediately renamed to the canonical
+    named session (merging any existing temp session).  The caller should store
+    the returned session_id in localStorage so subsequent requests use the same ID.
+    """
+    import re
+
+    # Ensure the temp session file exists first
+    await _ss.ensure_session(payload.session_id)
+
+    if payload.user_name and payload.user_name.strip():
+        # Immediately promote to named session
+        clean_name = re.sub(r'[^\w\s-]', '', payload.user_name).strip().replace(' ', '_')
+        new_id = await _ss.rename_session(payload.session_id, payload.user_name)
+        logger.info("session/init: pre-created named session '%s' for user '%s'", new_id, payload.user_name)
+        return {"status": "ok", "session_id": new_id}
+    else:
+        logger.info("session/init: pre-created temp session '%s' (name unknown yet)", payload.session_id)
+        return {"status": "ok", "session_id": payload.session_id}
+
+
 @fastapi_app.get("/api/session/history/{session_id}")
 async def get_session_history(session_id: str):
     """Returns the chat history for a session formatted for the frontend."""

static/addon.html

@@ -425,20 +425,23 @@
             localStorage.setItem('martech_last_user_name', userName);
         }
 
-        // Sync name with backend FIRST → get the real session ID before fetching history
-        // (Bug fix: previously history was fetched before session ID was finalized)
-        if (userName) {
-            try {
-                const rData = await fetch(BASE_URL + "/api/session/update-name", {
-                    method: 'POST',
-                    headers: { 'Content-Type': 'application/json' },
-                    body: JSON.stringify({ session_id: sessionId, user_name: userName })
-                }).then(r => r.json());
-                if (rData.new_session_id && rData.new_session_id !== sessionId) {
-                    sessionId = rData.new_session_id;
-                    localStorage.setItem('martech_session_id', sessionId);
-                }
-            } catch (e) {}
+        // ── PRE-CREATE SESSION AT BACKEND ON WIDGET LOAD ────────────────────
+        // This creates the session with the user's name BEFORE the user even
+        // opens the chat window, so it is immediately visible in the admin panel.
+        try {
+            const initData = await fetch(BASE_URL + "/api/session/init", {
+                method: 'POST',
+                headers: { 'Content-Type': 'application/json' },
+                body: JSON.stringify({ session_id: sessionId, user_name: userName || null })
+            }).then(r => r.json());
+            // Backend may return a canonical named session_id (e.g. "Ali_Hassan")
+            if (initData.session_id && initData.session_id !== sessionId) {
+                sessionId = initData.session_id;
+                localStorage.setItem('martech_session_id', sessionId);
+            }
+        } catch (e) {
+            // Non-fatal: session will still be created on first message if this fails
+            console.warn('Martech: background session pre-creation failed', e);
         }
 
         // Now fetch history using the finalized session ID
@@ -457,6 +460,7 @@
         } catch (e) {}
 
         // If name still not found, set up continuous lightweight background resolution
+        // so the session gets named as soon as auth is available
         if (!userName) {
             let _isResolving = false;
             
@@ -469,13 +473,14 @@
                 if (resolved) {
                     localStorage.setItem('martech_last_user_name', resolved);
                     try {
-                        const rData = await fetch(BASE_URL + "/api/session/update-name", {
+                        // Re-init with the now-known name to promote temp → named session
+                        const rData = await fetch(BASE_URL + "/api/session/init", {
                             method: 'POST',
                             headers: { 'Content-Type': 'application/json' },
                             body: JSON.stringify({ session_id: sessionId, user_name: resolved })
                         }).then(r => r.json());
-                        if (rData.new_session_id && rData.new_session_id !== sessionId) {
-                            sessionId = rData.new_session_id;
+                        if (rData.session_id && rData.session_id !== sessionId) {
+                            sessionId = rData.session_id;
                             localStorage.setItem('martech_session_id', sessionId);
                         }
                     } catch (e) {}