track

core/models.py

@@ -73,7 +73,7 @@ class ClientUser(Base):
     __tablename__ = "client_users"
 
     id = Column(Integer, primary_key=True, autoincrement=True, index=True)
-    user_id = Column(String(50), ForeignKey("users.user_id"), index=True, nullable=False)
+    user_id = Column(String(50), ForeignKey("users.user_id"), index=True, nullable=True)  # Nullable for anonymous tracking
     client_user_id = Column(String(100), index=True, nullable=True)  # Client-side temp identifier
     
     # IP tracking for network/location correlation

routers/blink.py

@@ -2,8 +2,7 @@
 Blink Router - Admin endpoints for viewing and tracking data.
 Uses AuditLog for unified client/server event tracking.
 """
-from fastapi import APIRouter, Depends, HTTPException, status, Query, Request
-from fastapi.responses import JSONResponse
+from fastapi import APIRouter, Depends, HTTPException, status, Query, Request, Response
 from sqlalchemy.ext.asyncio import AsyncSession
 from sqlalchemy import select, func
 import ipaddress
@@ -498,17 +497,17 @@ async def blink(
         # Determine server user_id (if authenticated)
         server_user_id = current_user.user_id if current_user else None
         
-        # If authenticated, always create a new ClientUser entry
-        if current_user:
-            new_client_user = ClientUser(
-                user_id=current_user.user_id,
-                client_user_id=client_user_id,
-                ipv4_address=ipv4_address,
-                ipv6_address=ipv6_address,
-                device_info={"user_agent": user_agent} if user_agent else None
-            )
-            db.add(new_client_user)
-            logger.info(f"Created ClientUser entry: user_id={current_user.user_id}, client_user_id={client_user_id}")
+        # Always create a ClientUser entry (user_id is None for anonymous users)
+        new_client_user = ClientUser(
+            user_id=server_user_id,  # None if anonymous, user_id if authenticated
+            client_user_id=client_user_id,
+            ipv4_address=ipv4_address,
+            ipv6_address=ipv6_address,
+            device_info={"user_agent": user_agent} if user_agent else None
+        )
+        db.add(new_client_user)
+        auth_status = "authenticated" if current_user else "anonymous"
+        logger.info(f"Created ClientUser entry: user_id={server_user_id}, client_user_id={client_user_id}, auth: {auth_status}")
         
         # Store each decrypted result as separate audit log entries
         records_created = 0
@@ -556,7 +555,7 @@ async def blink(
         logger.info(f"Successfully processed blink for client: {client_user_id}, records: {records_created}, auth: {auth_status}")
         
         # Return 204 No Content for silent tracking
-        return JSONResponse(status_code=status.HTTP_204_NO_CONTENT, content=None)
+        return Response(status_code=status.HTTP_204_NO_CONTENT)
         
     except HTTPException:
         raise