fixed errors

.vscode/settings.json

@@ -6,7 +6,7 @@
   "python.linting.ruffEnabled": true,
   "[python]": {
     "editor.codeActionsOnSave": {
-      "source.fixAll.ruff": true
+      "source.fixAll.ruff": "explicit"
     },
     "editor.defaultFormatter": "charliermarsh.ruff"
   }

app/main.py

@@ -14,7 +14,7 @@ import pathlib
 from datetime import datetime, timedelta
 
 # ─── Third-Party ──────────────────────────────────────────────────────────────
-from fastapi import FastAPI, Depends, HTTPException, Request, Query, BackgroundTasks
+from fastapi import FastAPI, Depends, HTTPException, Request, Query, BackgroundTasks,json
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import JSONResponse
 from contextlib import asynccontextmanager

app/routers/analytics_stream.py

@@ -4,12 +4,14 @@ from typing import List, Dict
 import json
 import asyncio
 from datetime import datetime
+import logging
 from app.deps import get_current_user,APP_URL
 
 from app.redis_client import redis
 import uuid
 from app.qstash_client import publish_message, is_qstash_available
 from fastapi import BackgroundTasks, Body, Depends
+logger = logging.getLogger(__name__)
 router = APIRouter(prefix="/api/v1/analytics/stream", tags=["analytics"])
 
 class AnalyticsStreamManager:
@@ -73,7 +75,7 @@ async def get_recent_analytics(
     org_id = current_user["org_id"]
     source_id = current_user.get("source_id", "default")
     """Poll recent analytics (replaces Socket.io)"""
-    if user.org_id != org_id:
+    if current_user.org_id != org_id:
         raise HTTPException(status_code=403, detail="Unauthorized")
     
     manager = AnalyticsStreamManager(org_id, source_id)

app/routers/datasources.py

@@ -1,4 +1,4 @@
-from fastapi import APIRouter, Query, Form, File, UploadFile, Depends, HTTPException,BackgroundTasks
+from fastapi import APIRouter, Query, Form, File, UploadFile, Depends, HTTPException
 from typing import Dict, Any, List, Union 
 from fastapi.responses import JSONResponse
 from pydantic import BaseModel

app/routers/schema.py

@@ -2,6 +2,7 @@
 from fastapi import APIRouter, Depends
 from app.deps import get_current_user
 from typing import Dict 
+from app.service.schema_service import OrgSchema
 router = APIRouter(prefix="/api/v1/schema", tags=["schema"])
 
 @router.get("/discover")

app/schemas/org_schema.py

@@ -36,7 +36,7 @@ class OrgSchema:
         self.org_id = org_id
         self.cache_key = f"schema:{org_id}:ai:v3"
         self.stats_key = f"schema:stats:{org_id}"
-        self.llm = LLMService()
+        self.llm = LocalLLMService()
         self.vector = VectorService()
     
     def get_mapping(self) -> Dict[str, str]:

app/service/llm_service.py

@@ -97,7 +97,7 @@ class LocalLLMService:
     @property
     def is_loading(self):  # ✅ Add this missing property
         with self._lock:
-            return self._is_loadin
+            return self._is_loading
     @property
     def load_error(self):
         with self._lock:

app/tasks/analytics_worker.py

@@ -3,7 +3,7 @@ import asyncio
 import json
 import pandas as pd
 import logging
-from datetime import datetime
+from datetime import datetime,timedelta
 from typing import Dict, Any
 import time
 

app/tasks/vector_cleanup_worker.py

@@ -1,5 +1,6 @@
 # app/tasks/vector_cleanup_worker.py
 import asyncio
+from app.redis_client import redis
 from app.services.vector_service import VectorService
 import logging