Add detailed MongoDB logging and verification endpoint

- Add detailed logging showing database and collection names
- Add verification step to confirm document exists after insert
- Add /mongo-status endpoint to check MongoDB connection and data
- Log database/collection names in all insert operations
- This will help diagnose why data might not be appearing in MongoDB

api/main.py

@@ -463,6 +463,37 @@ def logging_status(_: None = Depends(bearer_auth)) -> Dict[str, object]:
     return _admin_logging_status()
 
 
+@app.get("/mongo-status")
+def mongo_status(_: None = Depends(bearer_auth)) -> Dict[str, object]:
+    """Check MongoDB connection status and verify data storage."""
+    status = {
+        "mongo_configured": MONGO_URI is not None,
+        "mongo_connected": mongo_client is not None,
+        "database": mongo_db.name if mongo_db else None,
+        "collection": mongo_logs.name if mongo_logs else None,
+        "admin_logging": _admin_logging_status(),
+    }
+    
+    # Try to count documents in api_logs collection
+    if mongo_logs is not None:
+        try:
+            count = mongo_logs.count_documents({})
+            status["api_logs_count"] = count
+            # Get latest document
+            latest = mongo_logs.find_one(sort=[("timestamp", -1)])
+            if latest:
+                status["latest_log"] = {
+                    "_id": str(latest.get("_id")),
+                    "output_id": latest.get("output_id"),
+                    "status": latest.get("status"),
+                    "timestamp": latest.get("timestamp").isoformat() if isinstance(latest.get("timestamp"), datetime) else str(latest.get("timestamp")),
+                }
+        except Exception as err:
+            status["api_logs_error"] = str(err)
+    
+    return status
+
+
 @app.post("/upload-image")
 def upload_image(image: UploadFile = File(...), _: None = Depends(bearer_auth)) -> Dict[str, str]:
     file_id = _save_upload_to_gridfs(image, "image")
@@ -618,11 +649,23 @@ def inpaint(req: InpaintRequest, request: Request, _: None = Depends(bearer_auth
 
         if mongo_logs is not None:
             try:
-                log.debug("Inserting log document: %s", log_doc)
+                log.info("Inserting log to MongoDB - Database: %s, Collection: %s", mongo_logs.database.name, mongo_logs.name)
+                log.debug("Log document: %s", log_doc)
                 result = mongo_logs.insert_one(log_doc)
-                log.info("Mongo log inserted successfully: _id=%s, output_id=%s, status=%s", result.inserted_id, output_name, status)
+                log.info("Mongo log inserted successfully: _id=%s, output_id=%s, status=%s, db=%s, collection=%s", 
+                        result.inserted_id, output_name, status, mongo_logs.database.name, mongo_logs.name)
+                
+                # Verify the insert by reading it back
+                try:
+                    verify_doc = mongo_logs.find_one({"_id": result.inserted_id})
+                    if verify_doc:
+                        log.info("Verified: Document exists in MongoDB after insert")
+                    else:
+                        log.error("WARNING: Document not found after insert! _id=%s", result.inserted_id)
+                except Exception as verify_err:
+                    log.warning("Could not verify insert: %s", verify_err)
             except Exception as mongo_err:
-                log.error("Mongo log insert failed: %s, log_doc=%s", mongo_err, log_doc)
+                log.error("Mongo log insert failed: %s, log_doc=%s", mongo_err, log_doc, exc_info=True)
         else:
             log.warning("MongoDB not configured, skipping log insert")
 
@@ -704,10 +747,22 @@ def inpaint_url(req: InpaintRequest, request: Request, _: None = Depends(bearer_
             log_doc["error"] = error_msg
         if mongo_logs is not None:
             try:
+                log.info("Inserting log to MongoDB - Database: %s, Collection: %s", mongo_logs.database.name, mongo_logs.name)
                 result = mongo_logs.insert_one(log_doc)
-                log.info("Mongo log inserted successfully: _id=%s, output_id=%s", result.inserted_id, output_name)
+                log.info("Mongo log inserted successfully: _id=%s, output_id=%s, status=%s, db=%s, collection=%s", 
+                        result.inserted_id, output_name, status, mongo_logs.database.name, mongo_logs.name)
+                
+                # Verify the insert by reading it back
+                try:
+                    verify_doc = mongo_logs.find_one({"_id": result.inserted_id})
+                    if verify_doc:
+                        log.info("Verified: Document exists in MongoDB after insert")
+                    else:
+                        log.error("WARNING: Document not found after insert! _id=%s", result.inserted_id)
+                except Exception as verify_err:
+                    log.warning("Could not verify insert: %s", verify_err)
             except Exception as mongo_err:
-                log.error("Mongo log insert failed: %s", mongo_err)
+                log.error("Mongo log insert failed: %s, log_doc=%s", mongo_err, log_doc, exc_info=True)
         else:
             log.warning("MongoDB not configured, skipping log insert")
 
@@ -879,10 +934,22 @@ def inpaint_multipart(
             log_doc["error"] = error_msg
         if mongo_logs is not None:
             try:
+                log.info("Inserting log to MongoDB - Database: %s, Collection: %s", mongo_logs.database.name, mongo_logs.name)
                 result = mongo_logs.insert_one(log_doc)
-                log.info("Mongo log inserted successfully: _id=%s, output_id=%s", result.inserted_id, output_name)
+                log.info("Mongo log inserted successfully: _id=%s, output_id=%s, status=%s, db=%s, collection=%s", 
+                        result.inserted_id, output_name, status, mongo_logs.database.name, mongo_logs.name)
+                
+                # Verify the insert by reading it back
+                try:
+                    verify_doc = mongo_logs.find_one({"_id": result.inserted_id})
+                    if verify_doc:
+                        log.info("Verified: Document exists in MongoDB after insert")
+                    else:
+                        log.error("WARNING: Document not found after insert! _id=%s", result.inserted_id)
+                except Exception as verify_err:
+                    log.warning("Could not verify insert: %s", verify_err)
             except Exception as mongo_err:
-                log.error("Mongo log insert failed: %s", mongo_err)
+                log.error("Mongo log insert failed: %s, log_doc=%s", mongo_err, log_doc, exc_info=True)
         else:
             log.warning("MongoDB not configured, skipping log insert")
 
@@ -1025,10 +1092,22 @@ def remove_pink_segments(
             log_doc["error"] = error_msg
         if mongo_logs is not None:
             try:
+                log.info("Inserting log to MongoDB - Database: %s, Collection: %s", mongo_logs.database.name, mongo_logs.name)
                 result = mongo_logs.insert_one(log_doc)
-                log.info("Mongo log inserted successfully: _id=%s, output_id=%s", result.inserted_id, output_name)
+                log.info("Mongo log inserted successfully: _id=%s, output_id=%s, status=%s, db=%s, collection=%s", 
+                        result.inserted_id, output_name, status, mongo_logs.database.name, mongo_logs.name)
+                
+                # Verify the insert by reading it back
+                try:
+                    verify_doc = mongo_logs.find_one({"_id": result.inserted_id})
+                    if verify_doc:
+                        log.info("Verified: Document exists in MongoDB after insert")
+                    else:
+                        log.error("WARNING: Document not found after insert! _id=%s", result.inserted_id)
+                except Exception as verify_err:
+                    log.warning("Could not verify insert: %s", verify_err)
             except Exception as mongo_err:
-                log.error("Mongo log insert failed: %s", mongo_err)
+                log.error("Mongo log insert failed: %s, log_doc=%s", mongo_err, log_doc, exc_info=True)
         else:
             log.warning("MongoDB not configured, skipping log insert")