feat: complete memory system with Research Profile (Level 3)

app/api/routes/analysis.py

@@ -75,6 +75,7 @@ async def start_project_analysis(
             user_repo.deduct_credits(current_user, 50)
             
         request.user_id = str(current_user.id)
+        request.user_profile = current_user.research_profile
         target_project_id = project_id
         
         # If project_id is the "nil" UUID from frontend, use/create a real project for history
@@ -281,6 +282,7 @@ async def get_specific_analysis(
             k2_request = K2AnalysisRequest(
                 documents=docs,
                 user_id=str(current_user.id),
+                user_profile=current_user.research_profile,
                 reasoning_depth=depth,
                 ethics_rigor=rigor,
                 info_density=density

app/api/routes/users.py

@@ -196,8 +196,26 @@ async def register_and_login(user: UserCreate, db: Session = Depends(get_db)):
         )
 
 
+from pydantic import BaseModel
+
+class ProfileUpdate(BaseModel):
+    research_profile: str
+
 @router.get("/me", response_model=UserResponse)
 async def get_current_user_info(current_user = Depends(get_current_user), db: Session = Depends(get_db)):
     """Récupère les infos de l'utilisateur courant et déclenche le refill journalier si nécessaire"""
     user_repo = UserRepository(db)
     return user_repo.check_and_refill_credits(current_user)
+
+@router.put("/me/profile", response_model=UserResponse)
+async def update_research_profile(
+    profile_data: ProfileUpdate,
+    current_user = Depends(get_current_user),
+    db: Session = Depends(get_db)
+):
+    """Met à jour le profil de recherche de l'utilisateur"""
+    if current_user.id.hex.startswith("0000"):
+        raise HTTPException(status_code=400, detail="Cannot update profile in demo mode")
+    
+    user_repo = UserRepository(db)
+    return user_repo.update_profile(current_user, profile_data.research_profile)

app/db/models/user.py

@@ -21,6 +21,7 @@ class User(Base):
     role = Column(Text)
     credits = Column(Integer, default=2000)
     last_refill_date = Column(Date, default=datetime.utcnow().date())
+    research_profile = Column(Text, nullable=True)
     created_at = Column(DateTime, default=datetime.utcnow)
     
     # Relationships

app/db/repositories/user_repo.py

@@ -73,3 +73,11 @@ class UserRepository(BaseRepository[User, UserCreate, UserCreate]):
             self.db.refresh(user)
             return True
         return False
+
+    def update_profile(self, user: User, profile: str) -> User:
+        """Met à jour le profil de recherche de l'utilisateur"""
+        user.research_profile = profile
+        self.db.add(user)
+        self.db.commit()
+        self.db.refresh(user)
+        return user

app/main.py

@@ -58,6 +58,13 @@ async def lifespan(app: FastAPI):
             with engine.connect().execution_options(isolation_level="AUTOCOMMIT") as ddl_conn:
                 ddl_conn.execute(text("UPDATE users SET credits = 2000 WHERE credits IS NULL"))
             logger.info("Backfilled NULL credits to 2000 for existing users.")
+
+            # Check if 'research_profile' column exists
+            res_profile = conn.execute(text("SELECT column_name FROM information_schema.columns WHERE table_name='users' AND column_name='research_profile'")).fetchone()
+            if not res_profile:
+                with engine.connect().execution_options(isolation_level="AUTOCOMMIT") as ddl_conn:
+                    ddl_conn.execute(text("ALTER TABLE users ADD COLUMN research_profile TEXT"))
+                logger.info("Added 'research_profile' column to users table.")
     except Exception as e:
         logger.warning(f"Auto-migration warning (non-fatal): {str(e)}")
 

app/models/schemas.py

@@ -119,6 +119,7 @@ class AnalysisRequest(BaseModel):
     """Requête d'analyse scientifique"""
     documents: List[ScientificDocument]
     user_id: Optional[str] = None
+    user_profile: Optional[str] = None
     user_notes: Optional[str] = None
     
     # Scientific Settings from UI

app/services/k2_think_engine.py

@@ -118,6 +118,9 @@ Your core capability and primary directive is MULTI-DOCUMENT REASONING and KNOWL
 Do NOT just summarize individual papers. You MUST cross-reference, compare, and contrast the provided documents to uncover deeper strategic insights.
 {past_context_instruction}
 
+GLOBAL RESEARCHER PROFILE & OBJECTIVES (Apply these filters to your strategy):
+{request.user_profile if request.user_profile else "General scientific investigation without specific profile constraints."}
+
 REASONING GUIDELINES:
 - DEPTH: {depth_instruction}
 - ETHICS: {ethics_instruction}