changed some stuff I can't remember no need for background processes

app.py

@@ -490,7 +490,9 @@ def handle_change(change=None,new_point=None):
     import logging
     logging.basicConfig(level=logging.INFO)
     logger = logging.getLogger(__name__)
+    
     if new_point!=None:
+        collections = db.list_collection_names()
         logger.info(f"Extra info: {new_point}")
         if "LeaderBoard" not in collections:
             print("No leaderboard so creating one now")
@@ -503,7 +505,6 @@ def handle_change(change=None,new_point=None):
                 create_leaderboard_ranking(LeaderBoardRanking(userId=str(user['_id']),firstName=user['first_name'],lastName=user['last_name'],totalpoints=points.totalpoints,lastUpdated=datetime.now(),careerPath=dreamJob,))
         else:
             
-            # implement logic that takes new_point['userId'] and does the same thing update would have
             user_id =new_point.get('userId')
             leveleduser = get_all_users(userId=user_id)
             points = get_all_simple_points_func(userId=user_id)

gamification/logic.py

@@ -3,7 +3,8 @@ from gamification.objects import PlatformEngagement, UserFeedback, UserLevel, Us
 from gamification.levelLogic import create_level_func,get_all_levels_func,edit_level_func,delete_level_func
 from gamification.imports import *
 from gamification.pointLogic import create_points_func,get_all_simple_points_func,get_all_points_func
-
+from concurrent.futures import ThreadPoolExecutor
+executor = ThreadPoolExecutor(max_workers=5)
 
 # Normal Math
 def caculate_rate_change_func(c0,c1,days_ago):
@@ -62,7 +63,7 @@ def create_feedback_func(document:UserFeedback)->bool:
     # Insert the document
     if document!=None:
         feedbackPoints= Points(userId=document.userId,platformEngagement=PlatformEngagement(providing_feedback=15))
-        create_points_func(document=feedbackPoints)
+        executor.submit(create_points_func, document=feedbackPoints)
         result = collection.insert_one(document.model_dump())
         return True
     else:

gamification/pointLogic.py

@@ -1,5 +1,5 @@
 
-from app import handle_change
+
 from gamification.objects import UserPoints ,SimpleIndividualUserLevel,IndividualUserLevel,UserLevel
 from gamification.imports import *
 from gamification.levelLogic import get_all_levels_func
@@ -29,7 +29,7 @@ def get_dream_job(userId):
 
 
 def create_points_func(document:UserPoints)->bool:
-
+    from app import handle_change
     db_uri = MONGO_URI
     db_name = "crayonics"
     collection_name="Points"
@@ -42,7 +42,7 @@ def create_points_func(document:UserPoints)->bool:
         doc = document.model_dump()
         doc['earnedAt']=datetime.now()
         result = collection.insert_one(doc)
-        handle_change(new_point={"userId",document.userId})
+        handle_change(new_point={"userId":document.userId})
         return True
     else:
         client.close()

streaksManagement.py

@@ -3,7 +3,8 @@ from datetime import datetime, timedelta
 from typing import Dict, List, Union
 from gamification.objects import Points,PointMultipliersWeekendWarrior,PlatformEngagement
 from gamification.logic import create_points_func 
-
+from concurrent.futures import ThreadPoolExecutor
+executor = ThreadPoolExecutor(max_workers=5)
 
 def get_current_date() -> str:
     # Get the current date and return it in YYYY-MM-DD format
@@ -107,17 +108,20 @@ def streaks_manager(db_uri: str, document: Dict) -> Union[bool, str]:
                     today = datetime.date(datetime.now())
                     if (today.weekday()>=5):
                         streakPoints= Points(userId=document['user_id'],platformEngagement=PlatformEngagement(daily_check_in=5),weekendWarrior=PointMultipliersWeekendWarrior())
-                        create_points_func(document=streakPoints)
+                        executor.submit(create_points_func,document=streakPoints)
+                        # create_points_func(document=streakPoints)
                     else:
                         streakPoints= Points(userId=document['user_id'],platformEngagement=PlatformEngagement(daily_check_in=5))
-                        create_points_func(document=streakPoints)
+                        executor.submit(create_points_func,document=streakPoints)
+                        # create_points_func(document=streakPoints)
                 else:
 
                     dates=found_user["streak_dates"]
-                collection.update_one(
+                result = collection.update_one(
                     {"user_id": document.get("user_id")},
                     {"$set": {"streak_dates": dates}}
-                )
+                ) 
+                print(result)
                 return True
             else:
                 save_in_streaks_history(db_uri=db_uri,document=found_user)

tokenManagement.py

@@ -2,7 +2,8 @@
 
 import datetime
 from bson import ObjectId
-
+from concurrent.futures import ThreadPoolExecutor
+executor = ThreadPoolExecutor(max_workers=5)
 from streaksManagement import streaks_manager
 
 
@@ -78,6 +79,7 @@ def create_refreshToken(db_uri: str, user_id: str) -> str:
     result = collection.insert_one({"user_id":user_id,"current_time":current_time,"expire_at":expire_at,"previous_access_token":"None"})
     streaks_doc={}
     streaks_doc['user_id'] = str(user_id)
+    # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
     streaks_manager(db_uri=db_uri,document=streaks_doc)
     client.close()
     return str(result.inserted_id)
@@ -131,16 +133,19 @@ def verify_access_token(db_uri: str, user_id: str, access_token: str) -> bool:
                 if isexpired(doc['expire_at'])!=False:
                     streaks_doc={}
                     streaks_doc['user_id'] = str(user_id)
+                    # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
                     streaks_manager(db_uri=db_uri,document=streaks_doc)
                     pass
                 else:
                     streaks_doc={}
                     streaks_doc['user_id'] = str(user_id)
+                    # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
                     streaks_manager(db_uri=db_uri,document=streaks_doc)
                     return True
             else:
                 streaks_doc={}
                 streaks_doc['user_id'] = str(user_id)
+                # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
                 streaks_manager(db_uri=db_uri,document=streaks_doc)
                 pass
     return False    
@@ -164,11 +169,13 @@ def verify_refresh_access_token(db_uri: str, user_id: str, access_token: str,ref
             if str(doc['previous_access_token']) == access_token:
                 streaks_doc={}
                 streaks_doc['user_id'] = str(user_id)
+                # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
                 streaks_manager(db_uri=db_uri,document=streaks_doc)
                 return True
             else:
                 streaks_doc={}
                 streaks_doc['user_id'] = str(user_id)
+                # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
                 streaks_manager(db_uri=db_uri,document=streaks_doc)
                 pass
     return False    

utils.py

@@ -10,7 +10,8 @@ from gamification.logic import create_points_func
 from gamification.objects import PlatformEngagement, Points
 from password import *
 from streaksManagement import streaks_manager
-
+from concurrent.futures import ThreadPoolExecutor
+executor = ThreadPoolExecutor(max_workers=5)
 def google_search(query, api_key, cx):
     url = f"https://www.googleapis.com/customsearch/v1?q={query}&key={api_key}&cx={cx}"
     
@@ -149,6 +150,7 @@ def create_user(db_uri: str, db_name: str, collection_name: str, document: dict)
         
         streaks_doc={}
         streaks_doc['user_id'] = str(result.inserted_id)
+        # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
         streaks_manager(db_uri=db_uri,document=streaks_doc)
         return str(result.inserted_id)
     else:
@@ -229,7 +231,9 @@ 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'] = str(s["_id"])
+            # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
             streaks_manager(db_uri=db_uri,document=streaks_doc)
+            
             return str(s['_id'])
         else:
             return False
@@ -277,6 +281,7 @@ def user_details_func(db_uri: str, document: Dict) -> Optional[Dict]:
     streaks_doc['user_id'] = user_id
     
     # Call streaks_manager (assuming this function exists elsewhere)
+    # executor.submit(streaks_manager,db_uri=db_uri,document=streaks_doc)
     streaks_manager(db_uri=db_uri, document=streaks_doc)
     
     if streaks_collection_doc: