very scripted

app.py

@@ -69,7 +69,7 @@ def extract_course_info(text: str) -> CourseRecommendation:
 
 
 
-@app.get("/get/course",tags=["Scrape"])
+@app.get("/courses",tags=["Scrape"])
 def get_course(query):
 # Example search query
     results = google_search(query, API_KEY, CX)
@@ -120,7 +120,7 @@ def get_course_func(query):
 
 
 
-@app.post("/upload",tags=["AI"])
+@app.post("/Ai/upload",tags=["AI"])
 async def upload_file(file: UploadFile = File(...),authorization: str = Header(...)):
      # Extract the token from the Authorization header (Bearer token)
     token = authorization.split("Bearer ")[-1]
@@ -162,7 +162,7 @@ async def upload_file(file: UploadFile = File(...),authorization: str = Header(.
 
 
 
-@app.post("/ask",tags=["AI"])
+@app.post("/Ai/ask",tags=["AI"])
 def ask_ai_about_resume(req:AiAnalysis,authorization: str = Header(...)):
     # Retrieve context from your vector database
     token = authorization.split("Bearer ")[-1]
@@ -196,8 +196,8 @@ def ask_ai_about_resume(req:AiAnalysis,authorization: str = Header(...)):
     
     return {"Ai_Response":response.text}
 
-@app.post("/recommend/courses",tags=["AI"])
-def ask_ai_about_resume(request:UserCourse,authorization:str=Header(...)):
+@app.post("/Ai/recommend",tags=["AI"])
+def ask_ai_to_recommnd_courses(request:UserCourse,authorization:str=Header(...)):
     """
 User Profile Information for Career Development
 
@@ -281,7 +281,7 @@ Parameters:
 
 
 
-@app.post("/login",tags=["Authentication"])
+@app.post("/auth/login",tags=["Authentication"])
 def login(user:UserBody):
     user ={"email":user.email,"password":user.password,"firstName":user.firstName,"lastName":user.lastName}
     user_id= login_user(db_uri=MONGO_URI,db_name="crayonics",collection_name="Users",document=user)
@@ -296,7 +296,7 @@ def login(user:UserBody):
     return JSONResponse(status_code=401,content="Invalid login details")
 
 
-@app.post("/signup",tags=["Authentication"])
+@app.post("/auth/signup",tags=["Authentication"])
 def signUp(user:UserBody):
     user ={"email":user.email,"password":user.password}
     user_id= create_user(db_uri=MONGO_URI,db_name="crayonics",collection_name="users",document=user)
@@ -310,7 +310,27 @@ def signUp(user:UserBody):
     return JSONResponse(status_code=401,content="Invalid Sign Up details")
 
 
-@app.post("/accessToken",tags=["Authentication"])
+
+
+@app.post("/auth/logout",tags=["Authentication"])
+def signUp(refresh:Token,authorization: str = Header(...)):
+    
+    token = authorization.split("Bearer ")[-1]
+    
+    decoded_user_id,decoded_access_token = decode_jwt(token) 
+    is_valid = verify_access_token(db_uri=MONGO_URI, user_id=decoded_user_id, access_token=decoded_access_token)
+    if is_valid != True:  # Example check
+        raise HTTPException(status_code=status.HTTP_401_UNAUTHORIZED, detail="Invalid token")
+    
+    result = logout(db_uri=MONGO_URI,refresh_token= refresh.refreshToken)
+    if result ==True:
+        return {"content": f"successful"}
+    else:
+        return JSONResponse(status_code=status.HTTP_410_GONE,content={"content": f"unsuccessful"})
+
+
+
+@app.post("/auth/refresh",tags=["Authentication"])
 def refresh_access_token(refresh_token:Token, authorization: str = Header(...)):
     
     token = authorization.split("Bearer ")[-1]

streaksManagement.py

@@ -68,5 +68,3 @@ def streaks_manager(db_uri: str,  document: dict) -> str:
     # Close the connection
     
 
-
-# streaks_manager(db_uri="mongodb+srv://groupcresearchseminar:[email protected]/?retryWrites=true&w=majority&appName=Cluster0",document={"user_id":"67c9600773ef7350189a2d90"})

tokenManagement.py

@@ -44,9 +44,7 @@ def create_accessToken(db_uri: str, user_id: str, refresh_token: str) -> str:
     collection.find_one_and_delete({"refresh_token":refresh_token})
     # Insert the document
     result = collection.insert_one({"user_id":user_id,"refresh_token":refresh_token,"current_time":current_time,"expire_at":expire_at})
-    streaks_doc={}
-    streaks_doc['user_id'] = user_id
-    streaks_manager(db_uri=db_uri,document=streaks_doc)
+
     client.close()
     return str(result.inserted_id)
 
@@ -150,3 +148,35 @@ def verify_access_token(db_uri: str, user_id: str, access_token: str) -> bool:
 
 
 
+
+    
+def logout(db_uri: str, refresh_token: str) -> str:
+    from pymongo import MongoClient
+    current_time = datetime.datetime.now()
+    expire_at = current_time + datetime.timedelta(days=30)
+
+    """
+    Inserts a new document into the specified MongoDB collection.
+
+    Parameters:
+        db_uri (str): MongoDB connection URI.
+        user_id (str): id of user .
+
+
+    Returns:
+        str: The ID of the inserted document.
+    """
+
+    # Connect to MongoDB
+    client = MongoClient(db_uri)
+    db = client["crayonics"]
+    collection = db["RefreshToken"]
+    # Insert the document
+    result = collection.find_one_and_delete(filter={"_id":ObjectId(refresh_token)})
+    
+    return True
+    
+    # Close the connection
+    
+    
+    

utils.py

@@ -137,9 +137,9 @@ def create_user(db_uri: str, db_name: str, collection_name: str, document: dict)
     document['password']= password
     if s==None:
         result = collection.insert_one(document)
-        client.close()
+        
         streaks_doc={}
-        streaks_doc['user_id'] = result.inserted_id
+        streaks_doc['user_id'] = str(result.inserted_id)
         streaks_manager(db_uri=db_uri,document=streaks_doc)
         return str(result.inserted_id)
     else:
@@ -211,7 +211,6 @@ def login_user(db_uri: str, db_name: str, collection_name: str, document: dict)
         if check_password(password=document['password'],hashed_password=s['password']):
             streaks_doc['user_id'] = s.get("_id")
             streaks_manager(db_uri=db_uri,document=streaks_doc)
-            client.close()
             return str(s['_id'])
         else:
             return "Wrong Password"