Add forced user_id lint check and demo router gating

backend/services/linkedin/content_generator.py

@@ -410,8 +410,7 @@ class ContentGenerator:
                 raise Exception("Gemini Grounded Provider not available - cannot generate content without AI provider")
                 
             # Build the prompt for grounded generation using persona if available (DB vs session override)
-            # Beta testing: Force user_id=1 for all requests
-            user_id = 1
+            user_id = int(getattr(request, "user_id", 0) or 0)
             persona_data = self._get_cached_persona_data(user_id, 'linkedin')
             if getattr(request, 'persona_override', None):
                 try:
@@ -485,8 +484,7 @@ class ContentGenerator:
                 raise Exception("Gemini Grounded Provider not available - cannot generate content without AI provider")
                 
             # Build the prompt for grounded generation using persona if available (DB vs session override)
-            # Beta testing: Force user_id=1 for all requests
-            user_id = 1
+            user_id = int(getattr(request, "user_id", 0) or 0)
             persona_data = self._get_cached_persona_data(user_id, 'linkedin')
             if getattr(request, 'persona_override', None):
                 try:

backend/services/monitoring_data_service.py

@@ -23,6 +23,11 @@ class MonitoringDataService:
     def __init__(self, db_session: Session):
         self.db = db_session
     
+
+    def _resolve_strategy_user_id(self, strategy_id: int) -> str:
+        strategy = self.db.query(EnhancedContentStrategy).filter(EnhancedContentStrategy.id == strategy_id).first()
+        return str(getattr(strategy, "user_id", "0") or "0")
+
     async def save_monitoring_data(self, strategy_id: int, monitoring_plan: Dict[str, Any]) -> bool:
         """Save monitoring plan and tasks to database."""
         try:
@@ -65,19 +70,22 @@ class MonitoringDataService:
                 
                 self.db.add(task)
             
+            strategy_user_id = self._resolve_strategy_user_id(strategy_id)
+
             # Save activation status
             activation_status = StrategyActivationStatus(
                 strategy_id=strategy_id,
-                user_id=1,  # Default user ID
+                user_id=strategy_user_id,
                 activation_date=datetime.utcnow(),
                 status='active'
             )
             self.db.add(activation_status)
             
             # Save initial performance metrics
+            strategy_user_id = self._resolve_strategy_user_id(strategy_id)
             performance_metrics = StrategyPerformanceMetrics(
                 strategy_id=strategy_id,
-                user_id=1,  # Default user ID
+                user_id=strategy_user_id,
                 metric_date=datetime.utcnow(),
                 data_source='monitoring_plan',
                 confidence_score=85  # High confidence for monitoring plan data
@@ -341,10 +349,11 @@ class MonitoringDataService:
         """Update performance metrics for a strategy."""
         try:
             logger.info(f"Updating performance metrics for strategy {strategy_id}")
+            strategy_user_id = self._resolve_strategy_user_id(strategy_id)
             
             performance_metrics = StrategyPerformanceMetrics(
                 strategy_id=strategy_id,
-                user_id=1,  # Default user ID
+                user_id=strategy_user_id,
                 metric_date=datetime.utcnow(),
                 traffic_growth_percentage=metrics.get('traffic_growth'),
                 engagement_rate_percentage=metrics.get('engagement_rate'),

backend/services/strategy_copilot_service.py

@@ -1,3 +1,4 @@
+import os
 from typing import Dict, Any, List, Optional
 from sqlalchemy.orm import Session
 from loguru import logger
@@ -21,7 +22,7 @@ class StrategyCopilotService:
         """Generate data for a specific category."""
         try:
             # Get user onboarding data
-            user_id = 1  # TODO: Get from auth context
+            user_id = int(os.getenv("ALWRITY_FALLBACK_USER_ID", "0"))
             integrated_data = await self.onboarding_integration_service.process_onboarding_data(str(user_id), self.db)
             onboarding_data = integrated_data.get('canonical_profile', {})
             
@@ -81,7 +82,7 @@ class StrategyCopilotService:
         """Analyze complete strategy for completeness and coherence."""
         try:
             # Get user data for context
-            user_id = 1  # TODO: Get from auth context
+            user_id = int(os.getenv("ALWRITY_FALLBACK_USER_ID", "0"))
             integrated_data = await self.onboarding_integration_service.process_onboarding_data(str(user_id), self.db)
             onboarding_data = integrated_data.get('canonical_profile', {})
             
@@ -118,7 +119,7 @@ class StrategyCopilotService:
             field_definition = self._get_field_definition(field_id)
             
             # Get user data
-            user_id = 1  # TODO: Get from auth context
+            user_id = int(os.getenv("ALWRITY_FALLBACK_USER_ID", "0"))
             # Use SSOT
             integrated_data = await self.onboarding_integration_service.process_onboarding_data(str(user_id), self.db)
             onboarding_data = integrated_data.get('canonical_profile', {})