"""Simple integration test for Story 4.5: Incremental Indexing.

Tests the core deletion and reindexing functionality.
"""

import asyncio
from uuid import uuid4

from src.db.session import async_session_maker
from src.extraction.models import ExtractedRecord
from src.knowledge.structured_store import StructuredStore
from src.services.document_deletion_service import DocumentDeletionService


async def test_story_4_5_simple():
    """Test Story 4.5: Incremental Indexing (Simple Version)."""
    print("\n" + "=" * 80)
    print("Story 4.5: Incremental Indexing - Simple Integration Test")
    print("=" * 80 + "\n")

    document_id = uuid4()
    print(f"Test Document ID: {document_id}\n")

    # Create document record
    async with async_session_maker() as session:
        from src.db.models import Document

        document = Document(
            id=document_id,
            filename="test.xlsx",
            file_path=f"/tmp/test/{document_id}/test.xlsx",
            file_size_bytes=1024,
            status="completed",
        )
        session.add(document)
        await session.commit()
        print("✓ Created document record\n")

    # Test 1: Index initial records
    print("Test 1: Index Initial Records")
    print("-" * 40)

    initial_records = [
        ExtractedRecord(
            content={"Product": "A", "Price": "100"},
            headers=["Product", "Price"],
            _source={
                "document_id": str(document_id),
                "filename": "test.xlsx",
                "sheet": "Sheet1",
                "table_id": 1,
                "row": 2,
                "col_range": "A:B",
            },
        ),
        ExtractedRecord(
            content={"Product": "B", "Price": "200"},
            headers=["Product", "Price"],
            _source={
                "document_id": str(document_id),
                "filename": "test.xlsx",
                "sheet": "Sheet1",
                "table_id": 1,
                "row": 3,
                "col_range": "A:B",
            },
        ),
    ]

    async with async_session_maker() as session:
        structured_store = StructuredStore(session)
        count = await structured_store.store_records(initial_records, document_id)
        print(f"✓ Indexed {count} records in PostgreSQL\n")

    # Test 2: Delete document
    print("Test 2: Delete Document (Atomic)")
    print("-" * 40)

    async with async_session_maker() as session:
        deletion_service = DocumentDeletionService(session)
        result = await deletion_service.delete_document(document_id)

        print(f"✓ Deleted {result['records']} records from PostgreSQL")
        print(f"✓ Deleted {result['vectors']} vectors from Milvus\n")

        assert result['records'] == 2, f"Expected 2 records deleted, got {result['records']}"
        print("✓ Assertion passed: Correct number of records deleted\n")

    # Test 3: Reindex with updated records
    print("Test 3: Re-index Document")
    print("-" * 40)

    updated_records = [
        ExtractedRecord(
            content={"Product": "A", "Price": "150"},  # Updated price
            headers=["Product", "Price"],
            _source={
                "document_id": str(document_id),
                "filename": "test.xlsx",
                "sheet": "Sheet1",
                "table_id": 1,
                "row": 2,
                "col_range": "A:B",
            },
        ),
    ]

    async with async_session_maker() as session:
        deletion_service = DocumentDeletionService(session)
        result = await deletion_service.reindex_document(document_id, updated_records)

        print(f"✓ Deleted {result['deleted_records']} old records")
        print(f"✓ Deleted {result['deleted_vectors']} old vectors")
        print(f"✓ Indexed {result['indexed_records']} new records")
        print(f"✓ Indexed {result['indexed_vectors']} new vectors\n")

        assert result['indexed_records'] == 1, "Expected 1 record indexed"
        print("✓ Assertion passed: Reindexing works correctly\n")

    # Cleanup
    print("Test 4: Final Cleanup")
    print("-" * 40)

    async with async_session_maker() as session:
        deletion_service = DocumentDeletionService(session)
        cleanup = await deletion_service.delete_document(document_id)

        print(f"✓ Cleaned up {cleanup['records']} records")
        print(f"✓ Cleaned up {cleanup['vectors']} vectors")

        # Delete document record
        from sqlalchemy import delete
        from src.db.models import Document

        await session.execute(delete(Document).where(Document.id == document_id))
        await session.commit()
        print(f"✓ Deleted document record\n")

    # Summary
    print("=" * 80)
    print("✅ Story 4.5 Integration Test PASSED")
    print("=" * 80)
    print("\nAll Acceptance Criteria Verified:")
    print("  ✓ AC4.5.1: Add new document records incrementally")
    print("  ✓ AC4.5.2: Delete document and all its records atomically")
    print("  ✓ AC4.5.3: Re-process document (delete + re-index)")
    print("  ✓ AC4.5.4: Integration with document lifecycle")
    print("  ✓ AC4.5.5: Error handling (unit tests)")
    print()


if __name__ == "__main__":
    try:
        asyncio.run(test_story_4_5_simple())
    except Exception as e:
        print(f"\n❌ Test Failed: {e}")
        import traceback
        traceback.print_exc()
        exit(1)