Update app.py

app.py

@@ -307,34 +307,34 @@ async def face_swap_api(
             # ------------------------------------------------------------------
             # MEDIA_CLICKS (ONLY IF user_id PRESENT)
             # ------------------------------------------------------------------
+            # MEDIA_CLICKS (ONLY IF user_id PRESENT)
             if user_id:
                 try:
                     user_oid = ObjectId(user_id.strip())
                     now = datetime.utcnow()
-
+            
+                    # Try updating existing subCategory
                     update_result = await media_clicks_col.update_one(
-                        #{"userId": user_oid, "categories.categoryId": category_oid},
-                        {"userId": user_oid, "categories.categoryId": subcategory_oid},
+                        {"userId": user_oid, "subCategories.subCategoryId": subcategory_oid},
                         {
                             "$set": {
                                 "updatedAt": now,
-                                "categories.$.lastClickedAt": now
+                                "subCategories.$.lastClickedAt": now
                             },
-                            "$inc": {"categories.$.click_count": 1}
+                            "$inc": {"subCategories.$.click_count": 1}
                         }
                     )
-
+            
+                    # If subCategory does NOT exist → push new one
                     if update_result.matched_count == 0:
-                        # category does not exist → push new entry
                         await media_clicks_col.update_one(
                             {"userId": user_oid},
                             {
                                 "$setOnInsert": {"createdAt": now},
                                 "$set": {"updatedAt": now},
                                 "$push": {
-                                    "categories": {
-                                        #"categoryId": category_oid,
-                                        "categoryId": subcategory_oid,
+                                    "subCategories": {
+                                        "subCategoryId": subcategory_oid,
                                         "click_count": 1,
                                         "lastClickedAt": now
                                     }
@@ -342,9 +342,51 @@ async def face_swap_api(
                             },
                             upsert=True
                         )
-
+            
                 except Exception as media_err:
                     logger.error(f"MEDIA_CLICK ERROR: {media_err}")
+
+            # if user_id:
+            #     try:
+            #         user_oid = ObjectId(user_id.strip())
+            #         now = datetime.utcnow()
+
+            #         update_result = await media_clicks_col.update_one(
+            #             #{"userId": user_oid, "categories.categoryId": category_oid},
+            #             {"userId": user_oid, "categories.subcategoryId": subcategory_oid},
+                        
+
+            #             {
+            #                 "$set": {
+            #                     "updatedAt": now,
+            #                     "categories.$.lastClickedAt": now
+            #                 },
+            #                 "$inc": {"categories.$.click_count": 1}
+            #             }
+            #         )
+
+            #         if update_result.matched_count == 0:
+            #             # category does not exist → push new entry
+            #             await media_clicks_col.update_one(
+            #                 {"userId": user_oid},
+            #                 {
+            #                     "$setOnInsert": {"createdAt": now},
+            #                     "$set": {"updatedAt": now},
+            #                     "$push": {
+            #                         "categories": {
+            #                             #"categoryId": category_oid,
+            #                             #categoryId": subcategory_oid,
+            #                             "subCategoryId": subcategory_oid,
+            #                             "click_count": 1,
+            #                             "lastClickedAt": now
+            #                         }
+            #                     }
+            #                 },
+            #                 upsert=True
+            #             )
+
+            #     except Exception as media_err:
+            #         logger.error(f"MEDIA_CLICK ERROR: {media_err}")
                     # do NOT interrupt faceswap flow
 
         # ------------------------------------------------------------------