Update app.py

app.py

@@ -307,17 +307,20 @@ async def face_swap_api(
             # ---------- media_clicks update only if user_id exists ----------
             if user_id:
                 try:
-                    print("\n======= MEDIA_CLICKS DEBUG LOG =======")
-                    print("user_id received:", user_id)
-                    print("category_id resolved from subcategory:", category_id)
-                    print("ADMIN_MONGO_URL:", ADMIN_MONGO_URL)
-            
-                    user_oid = ObjectId(user_id)
-                    cat_oid = ObjectId(category_id)
-            
+                    logger.info("======= MEDIA_CLICKS DEBUG LOG =======")
+                    logger.info(f"user_id received: {user_id}")
+                    logger.info(f"category_id resolved from subcategory: {category_id}")
+                    logger.info(f"ADMIN_MONGO_URL: {ADMIN_MONGO_URL}")
+                    
+                    try:
+                        user_oid = ObjectId(user_id)
+                        cat_oid = ObjectId(category_id)
+                    except Exception as conv_err:
+                        logger.error(f"❌ ObjectId conversion failed: {conv_err}")
+                        raise HTTPException(status_code=400, detail=f"Invalid user_id or category_id: {conv_err}")
+                    
                     now = datetime.utcnow()
-            
-                    # Try to update existing category entry
+                    
                     update_result = await media_clicks_col.update_one(
                         {
                             "userId": user_oid,
@@ -333,14 +336,13 @@ async def face_swap_api(
                             }
                         }
                     )
-            
-                    print("Existing category update matched_count:", update_result.matched_count)
-                    print("Existing category update modified_count:", update_result.modified_count)
-            
-                    # If category did not exist, push new category object
+                    
+                    logger.info(f"Existing category update matched_count: {update_result.matched_count}")
+                    logger.info(f"Existing category update modified_count: {update_result.modified_count}")
+                    
                     if update_result.matched_count == 0:
-                        print("Category not found under this user → pushing new category entry")
-            
+                        logger.info("Category not found → pushing new category entry")
+                    
                         insert_result = await media_clicks_col.update_one(
                             {"userId": user_oid},
                             {
@@ -356,10 +358,11 @@ async def face_swap_api(
                             },
                             upsert=True
                         )
-            
-                        print("Insert/upsert raw_result:", insert_result.raw_result)
-            
-                    print("======= END MEDIA_CLICKS LOG =======\n")
+                    
+                        logger.info(f"Insert/upsert raw_result: {insert_result.raw_result}")
+                    
+                    logger.info("======= END MEDIA_CLICKS LOG =======")
+
             
                 except Exception as media_err:
                     print("❌ ERROR while saving media_clicks:", str(media_err))