Merge branch 'hotfix/initial_message_not_sent' of https://github.com/BESSER-PEARL/bot-framework into hotfix/initial_message_not_sent

Author: Aran30

besser/agent/db/monitoring_db.py

@@ -453,7 +453,6 @@ def select_chat(
         stmt = (select(table).where(
             table.c.session_id == int(session_entry['id'][0])
         ))
-        
         if until_timestamp is not None:
             stmt = stmt.where(table.c.timestamp <= until_timestamp)
 

besser/agent/platforms/websocket/streamlit_ui/message_input.py

@@ -23,12 +23,7 @@ def submit_text():
             st.write(user_input)
         message = Message(t=MessageType.STR, content=user_input, is_user=True, timestamp=datetime.now())
         st.session_state.history.append(message)
-        if st.session_state.get("authenticated", False):
-            payload = Payload(action=PayloadAction.USER_MESSAGE,
-                            message=user_input)
-        else:
-            payload = Payload(action=PayloadAction.USER_MESSAGE,
-                            message=user_input)
+        payload = Payload(action=PayloadAction.USER_MESSAGE, message=user_input)
         try:
             ws = st.session_state[WEBSOCKET]
             ws.send(json.dumps(payload, cls=PayloadEncoder))

besser/agent/platforms/websocket/websocket_platform.py

@@ -45,7 +45,11 @@ def _extract_user_id_from_request(request) -> str | None:
         if not value:
             continue
         if isinstance(value, bytes):
-            value = value.decode("latin-1")
+            # Prefer UTF-8 for URL paths; fall back to latin-1 to remain robust to non-UTF-8 bytes.
+            try:
+                value = value.decode("utf-8")
+            except UnicodeDecodeError:
+                value = value.decode("latin-1", errors="replace")
         query = urlsplit(value).query
         if not query:
             continue
@@ -125,8 +129,6 @@ def message_handler(conn: ServerConnection) -> None:
             headers = getattr(request, "headers", {}) if request else {}
             header_user = headers.get("X-User-ID") if hasattr(headers, "get") else None
             query_user = _extract_user_id_from_request(request)
-
-
             session_key = header_user or query_user or str(conn.id)
             self._connections[str(session_key)] = conn
             session = self._agent.get_or_create_session(session_key, self)

docs/source/wiki/platforms/websocket_platform.rst

@@ -130,7 +130,7 @@ The WebSocket platform allows the following kinds of user messages:
 
 Enabling persistent user sessions
 ---------------------------------
-When building your own UI on top of the WebSocket API, implement user authentication so every connection can be tied to a stable identifier. BAF maps connections to sessions via the ``X-User-ID`` header or the ``user_id`` query parameter on the handshake URL; the header is used if both are supplied, otherwise the query parameter keeps the connection pinned to the authenticated user. If none of these identifiers is available, the platform falls back to treating the connection as a new anonymous user.
+When building your own UI on top of the WebSocket API, implement user authentication so every connection can be tied to a stable identifier. BAF maps connections to sessions using either the ``X-User-ID`` header or the ``user_id`` query parameter from the handshake URL. If both are provided, the header takes precedence. If neither identifier is available, the platform treats the connection as a new anonymous user.
 
 Once your client authenticates users, include the identifier in the WebSocket handshake headers: