removed the returning levels

app.py

@@ -486,50 +486,77 @@ db = client.crayonics
 collection = db['Points']
 
 # A function to handle changes
-def handle_change(change):
-    print("Change detected in point making changes immediately")
-    # add everybodies points and add it to the leaderboard table
-    collections = db.list_collection_names()
-    if "LeaderBoard" not in collections:
-        print("No leaderboard so creating one now")
-        users = get_all_users()
-        for user in users:
-            print("inserting user",f"user id {user['_id']}")
-            points = get_all_simple_points_func(userId=str(user['_id']))
-            tempDreamJob =  get_dream_job(userId=str(user['_id'])) 
-            dreamJob = tempDreamJob if type(tempDreamJob)==str else "IncompleteProfile"
-            
-            create_leaderboard_ranking(LeaderBoardRanking(userId=str(user['_id']),firstName=user['first_name'],lastName=user['last_name'],totalpoints=points.totalpoints,lastUpdated=datetime.now(),careerPath=dreamJob,))
-            leaderBoardcollection = db['LeaderBoard']
-            # index = leaderBoardcollection.create_index([
-            #         ('lastName', 1),
-            #         ('totalpoints', -1)
-            #     ])
-            # print("index",index)
-    else:
-        if change['operationType'] == 'insert':
-            # Extract the full document
-            full_document = change['fullDocument']
-            
-            # Extract the userId and numOfPoints
+def handle_change(change=None,new_point=None):
+    import logging
+    logging.basicConfig(level=logging.INFO)
+    logger = logging.getLogger(__name__)
+    if new_point!=None:
+        logger.info(f"Extra info: {new_point}")
+        if "LeaderBoard" not in collections:
+            print("No leaderboard so creating one now")
+            users = get_all_users()
+            for user in users:
+                print("inserting user",f"user id {user['_id']}")
+                points = get_all_simple_points_func(userId=str(user['_id']))
+                tempDreamJob =  get_dream_job(userId=str(user['_id'])) 
+                dreamJob = tempDreamJob if type(tempDreamJob)==str else "IncompleteProfile"
+                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:
             
-            user_id =full_document.get('userId')
+            # 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)
             tempDreamJob =  get_dream_job(userId=user_id) 
             dreamJob = tempDreamJob if type(tempDreamJob)==str else "IncompleteProfile"
             create_leaderboard_ranking(LeaderBoardRanking(userId=user_id,firstName=leveleduser['first_name'],lastName=leveleduser['last_name'],totalpoints=points.totalpoints,lastUpdated=datetime.now(),careerPath=dreamJob,))
-        elif change['operationType'] == 'update':
-            dockey = str(change['documentKey']['_id'])
-            user_id = get_user_id_from_docKey(dockId=dockey)
-            leveleduser = get_all_users(user_id=user_id)
-            points = get_all_simple_points_func(userId=user_id)
-            tempDreamJob =  get_dream_job(userId=user_id)
-            dreamJob = tempDreamJob if type(tempDreamJob)==str else "IncompleteProfile"
-            create_leaderboard_ranking(LeaderBoardRanking(userId=user_id,firstName=leveleduser['first_name'],lastName=leveleduser['last_name'],totalpoints=points.totalpoints,lastUpdated=datetime.now(),careerPath=dreamJob,))
-            
+                
         
-    print(f"Change detected: {dumps(change)}")
+    elif new_point==None and change!=None:
+        print("Change detected in point making changes immediately")
+        logger.info(f"Change detected: {change}")
+        # add everybodies points and add it to the leaderboard table
+        collections = db.list_collection_names()
+        if "LeaderBoard" not in collections:
+            print("No leaderboard so creating one now")
+            users = get_all_users()
+            for user in users:
+                print("inserting user",f"user id {user['_id']}")
+                points = get_all_simple_points_func(userId=str(user['_id']))
+                tempDreamJob =  get_dream_job(userId=str(user['_id'])) 
+                dreamJob = tempDreamJob if type(tempDreamJob)==str else "IncompleteProfile"
+                
+                create_leaderboard_ranking(LeaderBoardRanking(userId=str(user['_id']),firstName=user['first_name'],lastName=user['last_name'],totalpoints=points.totalpoints,lastUpdated=datetime.now(),careerPath=dreamJob,))
+                leaderBoardcollection = db['LeaderBoard']
+                # index = leaderBoardcollection.create_index([
+                #         ('lastName', 1),
+                #         ('totalpoints', -1)
+                #     ])
+                # print("index",index)
+        else:
+            if change['operationType'] == 'insert':
+                # Extract the full document
+                full_document = change['fullDocument']
+                
+                # Extract the userId and numOfPoints
+                
+                user_id =full_document.get('userId')
+                leveleduser = get_all_users(userId=user_id)
+                points = get_all_simple_points_func(userId=user_id)
+                tempDreamJob =  get_dream_job(userId=user_id) 
+                dreamJob = tempDreamJob if type(tempDreamJob)==str else "IncompleteProfile"
+                create_leaderboard_ranking(LeaderBoardRanking(userId=user_id,firstName=leveleduser['first_name'],lastName=leveleduser['last_name'],totalpoints=points.totalpoints,lastUpdated=datetime.now(),careerPath=dreamJob,))
+            elif change['operationType'] == 'update':
+                dockey = str(change['documentKey']['_id'])
+                user_id = get_user_id_from_docKey(dockId=dockey)
+                leveleduser = get_all_users(user_id=user_id)
+                points = get_all_simple_points_func(userId=user_id)
+                tempDreamJob =  get_dream_job(userId=user_id)
+                dreamJob = tempDreamJob if type(tempDreamJob)==str else "IncompleteProfile"
+                create_leaderboard_ranking(LeaderBoardRanking(userId=user_id,firstName=leveleduser['first_name'],lastName=leveleduser['last_name'],totalpoints=points.totalpoints,lastUpdated=datetime.now(),careerPath=dreamJob,))
+                
+            
+        print(f"Change detected: {dumps(change)}")
 
 # Function to run the change stream in a separate thread (non-blocking)
 def watch_change_stream():

gamification/pointLogic.py

@@ -1,4 +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
@@ -41,6 +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})
         return True
     else:
         client.close()