Update app.py

app.py

@@ -303,47 +303,108 @@ async def face_swap_api(
             target_url = asset["url"]
             category_id = str(doc["categoryId"])
 
+            # ---------- media_clicks update only if user_id exists ----------
             # ---------- media_clicks update only if user_id exists ----------
             if user_id:
-                user_oid = ObjectId(user_id)
-                cat_oid = ObjectId(category_id)
-
-                now = datetime.utcnow()
-
-                # Try to update existing category entry
-                update_result = await media_clicks_col.update_one(
-                    {
-                        "userId": user_oid,
-                        "categories.categoryId": cat_oid
-                    },
-                    {
-                        "$set": {
-                            "updatedAt": now,
-                            "categories.$.lastClickedAt": now
+                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)
+            
+                    now = datetime.utcnow()
+            
+                    # Try to update existing category entry
+                    update_result = await media_clicks_col.update_one(
+                        {
+                            "userId": user_oid,
+                            "categories.categoryId": cat_oid
                         },
-                        "$inc": {
-                            "categories.$.click_count": 1
-                        }
-                    }
-                )
-
-                # If category did not exist, push new category object
-                if update_result.matched_count == 0:
-                    await media_clicks_col.update_one(
-                        {"userId": user_oid},
                         {
-                            "$setOnInsert": {"createdAt": now},
-                            "$set": {"updatedAt": now},
-                            "$push": {
-                                "categories": {
-                                    "categoryId": cat_oid,
-                                    "click_count": 1,
-                                    "lastClickedAt": now
-                                }
+                            "$set": {
+                                "updatedAt": now,
+                                "categories.$.lastClickedAt": now
+                            },
+                            "$inc": {
+                                "categories.$.click_count": 1
                             }
-                        },
-                        upsert=True
+                        }
                     )
+            
+                    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
+                    if update_result.matched_count == 0:
+                        print("Category not found under this user → pushing new category entry")
+            
+                        insert_result = await media_clicks_col.update_one(
+                            {"userId": user_oid},
+                            {
+                                "$setOnInsert": {"createdAt": now},
+                                "$set": {"updatedAt": now},
+                                "$push": {
+                                    "categories": {
+                                        "categoryId": cat_oid,
+                                        "click_count": 1,
+                                        "lastClickedAt": now
+                                    }
+                                }
+                            },
+                            upsert=True
+                        )
+            
+                        print("Insert/upsert raw_result:", insert_result.raw_result)
+            
+                    print("======= END MEDIA_CLICKS LOG =======\n")
+            
+                except Exception as media_err:
+                    print("❌ ERROR while saving media_clicks:", str(media_err))
+        # DO NOT break the face-swap flow
+
+            # if user_id:
+            #     user_oid = ObjectId(user_id)
+            #     cat_oid = ObjectId(category_id)
+
+            #     now = datetime.utcnow()
+
+            #     # Try to update existing category entry
+            #     update_result = await media_clicks_col.update_one(
+            #         {
+            #             "userId": user_oid,
+            #             "categories.categoryId": cat_oid
+            #         },
+            #         {
+            #             "$set": {
+            #                 "updatedAt": now,
+            #                 "categories.$.lastClickedAt": now
+            #             },
+            #             "$inc": {
+            #                 "categories.$.click_count": 1
+            #             }
+            #         }
+            #     )
+
+            #     # If category did not exist, push new category object
+            #     if update_result.matched_count == 0:
+            #         await media_clicks_col.update_one(
+            #             {"userId": user_oid},
+            #             {
+            #                 "$setOnInsert": {"createdAt": now},
+            #                 "$set": {"updatedAt": now},
+            #                 "$push": {
+            #                     "categories": {
+            #                         "categoryId": cat_oid,
+            #                         "click_count": 1,
+            #                         "lastClickedAt": now
+            #                     }
+            #                 }
+            #             },
+            #             upsert=True
+            #         )
 
         # ==========================================================
         # CASE 2: EXISTING TARGET_CATEGORY_ID (DigitalOcean)