fix: update test to match new AdvancedPDFParser-based ingestion pipeline (#561)

Author: ionfwsrijan

backend/app/tasks.py

@@ -41,7 +41,6 @@ def process_document(
                 doc.status = "processing"  # Set explicitly to show UI activity
                 db.commit()
 
-<<<<<<< HEAD
         logger.info("Starting Advanced Layout-Aware Ingestion for document: %s", original_name)
 
         # 2. Trigger your advanced structural parser

backend/tests/test_celery_ingestion.py

@@ -27,20 +27,14 @@ def test_process_document_ingestion_pipeline(db_session):
     mock_session_factory.return_value.__enter__.return_value = db_session
     mock_session_factory.return_value = db_session
 
-    # Patch the factory globally, and patch ingest_document right where app.tasks calls it
+    # Patch the factory globally, and patch AdvancedPDFParser to avoid real file I/O
     with patch("app.database.SessionLocal", mock_session_factory, create=True), \
-         patch("app.services.document_ingestion.SessionLocal", mock_session_factory, create=True), \
-         patch("app.tasks.ingest_document") as mock_ingest:
-         
-        # Simulate what the underlying service does upon a successful processing run
-        def simulate_successful_ingestion(*args, **kwargs):
-            doc = db_session.query(Document).filter_by(id="test-doc-123").first()
-            if doc:
-                doc.status = "ready"
-                db_session.commit()
-            return {"status": "success"}
-
-        mock_ingest.side_effect = simulate_successful_ingestion
+         patch("app.tasks.AdvancedPDFParser") as mock_parser:
+
+        # Return empty chunks so the vectorization loop is a no-op
+        mock_parser_instance = MagicMock()
+        mock_parser.return_value = mock_parser_instance
+        mock_parser_instance.ingest_document.return_value = []
 
         task_result = process_document.apply(
             kwargs={
@@ -57,4 +51,4 @@ def simulate_successful_ingestion(*args, **kwargs):
         # Query the database to verify the state update
         updated_doc = db_session.query(Document).filter_by(id="test-doc-123").first()
         assert updated_doc is not None
-        assert updated_doc.status == "ready"
+        assert updated_doc.status == "completed"