Delete main.py

main.py

@@ -1,97 +0,0 @@
-import os
-import re
-import jwt
-import faiss
-import time
-import numpy as np
-import requests
-from datetime import datetime, timedelta
-from fastapi import FastAPI, Depends, HTTPException, status
-from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
-from pydantic import BaseModel, validator
-from sentence_transformers import SentenceTransformer
-from typing import List
-
-# --- SETTINGS ---
-SECRET_KEY = "352f67b35a544f408c58c74c654cfd7e"
-ALGORITHM = "HS256"
-ACCESS_TOKEN_EXPIRE_MINUTES = 60
-NEWS_API_KEY = os.getenv("NEWS_API_KEY")
-security = HTTPBearer()
-model = SentenceTransformer("all-MiniLM-L6-v2")
-
-app = FastAPI(title="Finance News API", version="2.0.0")
-
-# --- AUTH MODELS ---
-class LoginSchema(BaseModel):
-    username: str
-    password: str
-
-class QuerySchema(BaseModel):
-    query: str
-
-    @validator("query")
-    def sanitize_query(cls, v):
-        if not re.match("^[a-zA-Z0-9 .,!?()-]+$", v):
-            raise ValueError("Invalid characters in query")
-        return v
-
-# --- JWT UTILS ---
-def create_access_token(data: dict):
-    to_encode = data.copy()
-    expire = datetime.utcnow() + timedelta(minutes=ACCESS_TOKEN_EXPIRE_MINUTES)
-    to_encode.update({"exp": expire})
-    return jwt.encode(to_encode, SECRET_KEY, algorithm=ALGORITHM)
-
-def get_current_user(token: HTTPAuthorizationCredentials = Depends(security)):
-    try:
-        payload = jwt.decode(token.credentials, SECRET_KEY, algorithms=[ALGORITHM])
-        return payload.get("sub")
-    except jwt.ExpiredSignatureError:
-        raise HTTPException(status_code=401, detail="Token expired")
-    except:
-        raise HTTPException(status_code=401, detail="Invalid token")
-
-# --- LOGIN ---
-@app.post("/login")
-def login(data: LoginSchema):
-    if data.username == "admin" and data.password == "admin123":
-        token = create_access_token({"sub": data.username})
-        return {"access_token": token}
-    raise HTTPException(status_code=401, detail="Invalid login")
-
-# --- NEWS FETCH ---
-def fetch_news():
-    url = f"https://newsapi.org/v2/everything?q=india finance&apiKey={NEWS_API_KEY}"
-    r = requests.get(url)
-    articles = r.json().get("articles", [])[:20]
-    corpus = [a["title"] + " " + (a["description"] or "") for a in articles]
-    return articles, corpus
-
-# --- VECTOR STORE ---
-articles, corpus = fetch_news()
-embeddings = model.encode(corpus)
-dimension = embeddings.shape[1]
-index = faiss.IndexFlatL2(dimension)
-index.add(embeddings)
-
-# --- SEARCH ---
-def semantic_search(query: str, k: int = 5):
-    q_vec = model.encode([query])
-    distances, indices = index.search(q_vec, k)
-    
-    return [articles[i] for i in indices[0] if i < len(articles)]
-
-# --- SECURE QUERY ENDPOINT ---
-@app.post("/secure-search")
-def secure_search(
-    payload: QuerySchema,
-    user: str = Depends(get_current_user)
-):
-    results = semantic_search(payload.query)
-    return {"results": results, "user": user}
-
-# --- HEALTH ---
-@app.get("/health")
-def health():
-    return {"status": "OK", "faiss": index.ntotal}