tests/e2e/test_complete_workflows.py

#!/usr/bin/env python3
"""
E2E Tests for Complete User Workflows

Comprehensive end-to-end tests that simulate complete user journeys:
- Data room setup and processing
- Company analysis generation 
- Checklist matching workflow
- Questions processing workflow
- Q&A session workflow
- Export workflow
- Knowledge graph workflow
"""

import pytest
import os
from playwright.sync_api import Page, expect
from .conftest import StreamlitPageHelpers


class TestCompleteWorkflows:
    """Test complete user workflows from start to finish"""

    def test_complete_data_room_to_analysis_workflow(self, page: Page, streamlit_helpers: StreamlitPageHelpers, sample_test_data):
        """Test complete workflow: data room setup -> processing -> analysis generation"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Step 1: Configure data room
        sidebar = page.locator("[data-testid='stSidebar']")
        
        # Look for data room path input
        path_inputs = sidebar.locator("input[placeholder*='path'], input[aria-label*='path'], input[type='text']")
        
        if path_inputs.count() > 0 and sample_test_data["vdr_path"].exists():
            # Set data room path
            path_inputs.first.fill(str(sample_test_data["vdr_path"]))
            
            # Look for process button
            process_buttons = sidebar.locator("button:has-text(/.*[Pp]rocess.*|.*[Bb]uild.*|.*[Ll]oad.*/)")
            
            if process_buttons.count() > 0:
                # Step 2: Process data room
                process_buttons.first.click()
                
                # Wait for processing to complete or show progress
                page.wait_for_timeout(10000)  # Give it time to start processing
                
                # Step 3: Navigate to Company Analysis tab
                analysis_tab = page.locator("button:has-text('Company Analysis'), text='Company Analysis'").first
                if analysis_tab.count() > 0:
                    analysis_tab.click()
                    page.wait_for_timeout(2000)
                    
                    # Step 4: Generate analysis (if API key configured)
                    generate_buttons = page.locator("button:has-text(/.*[Gg]enerate.*|.*[Aa]nalysis.*/)")
                    
                    if generate_buttons.count() > 0:
                        generate_buttons.first.click()
                        
                        # Wait for analysis or error message
                        page.wait_for_timeout(5000)
                        
                        # Should show either analysis result or error about missing API key
                        analysis_content = page.locator("text=/.*[Aa]nalysis.*|.*[Ee]rror.*|.*API.*key.*/")
                        
                        # The workflow should complete without crashing
                        expect(page.locator("[data-testid='stApp']")).to_be_visible()

    def test_complete_checklist_workflow(self, page: Page, streamlit_helpers: StreamlitPageHelpers):
        """Test complete checklist matching workflow"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Navigate to Checklist tab
        checklist_tab = page.locator("button:has-text('Checklist'), text='Checklist'").first
        
        if checklist_tab.count() > 0:
            checklist_tab.click()
            page.wait_for_timeout(1000)
            
            # Should show checklist interface
            checklist_content = page.locator("text=/.*[Cc]hecklist.*|.*[Dd]ue.*[Dd]iligence.*|.*[Mm]atching.*/")
            
            # Look for process/analyze buttons
            process_buttons = page.locator("button:has-text(/.*[Pp]rocess.*|.*[Aa]nalyze.*|.*[Mm]atch.*/)")
            
            if process_buttons.count() > 0:
                process_buttons.first.click()
                
                # Wait for processing
                page.wait_for_timeout(3000)
                
                # Should show results or processing status
                results_indicators = page.locator("text=/.*[Rr]esults.*|.*[Cc]ompleted.*|.*[Ff]ound.*|.*[Pp]rocessing.*/")
                
                # Workflow should complete without errors
                expect(page.locator("[data-testid='stApp']")).to_be_visible()

    def test_complete_questions_workflow(self, page: Page, streamlit_helpers: StreamlitPageHelpers):
        """Test complete due diligence questions workflow"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Navigate to Questions tab
        questions_tab = page.locator("button:has-text('Questions'), text='Questions'").first
        
        if questions_tab.count() > 0:
            questions_tab.click()
            page.wait_for_timeout(1000)
            
            # Should show questions interface
            questions_content = page.locator("text=/.*[Qq]uestions.*|.*[Dd]ue.*[Dd]iligence.*/")
            
            # Look for process questions buttons
            process_buttons = page.locator("button:has-text(/.*[Pp]rocess.*|.*[Aa]nalyze.*|.*[Qq]uestions.*/)")
            
            if process_buttons.count() > 0:
                process_buttons.first.click()
                
                # Wait for processing
                page.wait_for_timeout(5000)
                
                # Should show question results or processing status
                question_results = page.locator("text=/.*[Qq]uestion.*|.*[Aa]nswer.*|.*[Pp]rocessing.*/")
                
                # Workflow should complete
                expect(page.locator("[data-testid='stApp']")).to_be_visible()

    def test_complete_qa_session_workflow(self, page: Page, streamlit_helpers: StreamlitPageHelpers):
        """Test complete Q&A session workflow"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Navigate to Q&A tab
        qa_tab = page.locator("button:has-text('Q&A'), text='Q&A'").first
        
        if qa_tab.count() > 0:
            qa_tab.click()
            page.wait_for_timeout(1000)
            
            # Look for question input
            question_inputs = page.locator("input[placeholder*='question'], textarea[placeholder*='question']")
            
            if question_inputs.count() > 0:
                # Enter a test question
                test_question = "What is the company's revenue?"
                question_inputs.first.fill(test_question)
                
                # Look for ask/submit button
                ask_buttons = page.locator("button:has-text(/.*[Aa]sk.*|.*[Ss]ubmit.*|.*[Ss]earch.*/)")
                
                if ask_buttons.count() > 0:
                    ask_buttons.first.click()
                    
                    # Wait for response or error
                    page.wait_for_timeout(5000)
                    
                    # Should show either answer or error about missing API key
                    response_content = page.locator("text=/.*[Aa]nswer.*|.*[Rr]esponse.*|.*API.*key.*|.*[Ee]rror.*/")
                    
                    # Q&A workflow should complete
                    expect(page.locator("[data-testid='stApp']")).to_be_visible()

    def test_complete_export_workflow(self, page: Page, streamlit_helpers: StreamlitPageHelpers):
        """Test complete export workflow across multiple tabs"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Test export functionality across different tabs
        tabs = page.locator("[data-testid='stTabs'] button, .stTabs button")
        
        export_found = False
        
        if tabs.count() > 0:
            for i in range(min(tabs.count(), 5)):  # Check first 5 tabs
                tabs.nth(i).click()
                page.wait_for_timeout(1000)
                
                # Look for export/download functionality
                export_buttons = page.locator("button:has-text(/.*[Ee]xport.*|.*[Dd]ownload.*|.*[Ss]ave.*|.*PDF.*/)")
                download_links = page.locator("a[download], a[href*='download']")
                
                if export_buttons.count() > 0:
                    export_buttons.first.click()
                    page.wait_for_timeout(2000)
                    
                    # Should trigger download or show export success
                    export_success = page.locator("text=/.*[Ee]xported.*|.*[Dd]ownloaded.*|.*[Ss]aved.*/")
                    
                    export_found = True
                    break
                    
                elif download_links.count() > 0:
                    # Download link should be functional
                    expect(download_links.first).to_be_visible()
                    export_found = True
                    break
        
        # At least one export option should be available
        # (It's okay if exports aren't available without content)
        expect(page.locator("[data-testid='stApp']")).to_be_visible()

    def test_complete_knowledge_graph_workflow(self, page: Page, streamlit_helpers: StreamlitPageHelpers):
        """Test complete knowledge graph workflow"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Navigate to Knowledge Graph tab
        graph_tab = page.locator("button:has-text('Graph'), text='Graph'").first
        
        if graph_tab.count() > 0:
            graph_tab.click()
            page.wait_for_timeout(1000)
            
            # Should show graph interface
            graph_content = page.locator("text=/.*[Gg]raph.*|.*[Kk]nowledge.*|.*[Ee]ntities.*|.*[Rr]elationships.*/")
            
            # Look for graph generation or visualization
            graph_buttons = page.locator("button:has-text(/.*[Gg]enerate.*|.*[Bb]uild.*|.*[Ss]how.*/)")
            
            if graph_buttons.count() > 0:
                graph_buttons.first.click()
                
                # Wait for graph processing
                page.wait_for_timeout(5000)
                
                # Look for graph visualization elements
                graph_viz = page.locator("canvas, svg, .plotly, [data-testid='stPlotlyChart']")
                
                # Graph workflow should complete
                expect(page.locator("[data-testid='stApp']")).to_be_visible()

    @pytest.mark.slow
    def test_complete_end_to_end_workflow(self, page_slow: Page, streamlit_helpers: StreamlitPageHelpers, sample_test_data):
        """Test complete end-to-end workflow covering all major features"""
        page = page_slow
        streamlit_helpers.wait_for_streamlit_load()
        
        # This test simulates a complete user session
        workflow_steps = [
            "Data Room Setup",
            "Company Analysis", 
            "Checklist Processing",
            "Questions Analysis",
            "Q&A Session",
            "Export Results"
        ]
        
        # Step 1: Data Room Setup
        sidebar = page.locator("[data-testid='stSidebar']")
        path_inputs = sidebar.locator("input[type='text']")
        
        if path_inputs.count() > 0 and sample_test_data["vdr_path"].exists():
            path_inputs.first.fill(str(sample_test_data["vdr_path"]))
            
            process_buttons = sidebar.locator("button:has-text(/.*[Pp]rocess.*/)")
            if process_buttons.count() > 0:
                process_buttons.first.click()
                page.wait_for_timeout(5000)  # Wait for processing
        
        # Step 2-6: Navigate through each major tab and perform key actions
        main_tabs = page.locator("[data-testid='stTabs'] button, .stTabs button")
        
        if main_tabs.count() > 0:
            for i in range(min(main_tabs.count(), 5)):  # Visit each main tab
                main_tabs.nth(i).click()
                page.wait_for_timeout(2000)
                
                # Perform relevant actions in each tab
                action_buttons = page.locator("button:has-text(/.*[Gg]enerate.*|.*[Pp]rocess.*|.*[Aa]nalyze.*/)")
                
                if action_buttons.count() > 0:
                    # Click first available action button
                    action_buttons.first.click()
                    page.wait_for_timeout(3000)
                
                # Verify tab remains functional
                expect(page.locator("[data-testid='stApp']")).to_be_visible()
        
        # Final verification: App should still be functional after full workflow
        expect(page.locator("[data-testid='stApp']")).to_be_visible()
        expect(page.locator("[data-testid='stSidebar']")).to_be_visible()

    def test_error_recovery_across_workflows(self, page: Page, streamlit_helpers: StreamlitPageHelpers):
        """Test that errors in one workflow don't break others"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Simulate error conditions and verify recovery
        error_scenarios = [
            # Invalid data room path
            lambda: self._trigger_invalid_path_error(page),
            # AI operation without API key
            lambda: self._trigger_ai_error(page),
            # File upload error
            lambda: self._trigger_file_error(page)
        ]
        
        for i, scenario in enumerate(error_scenarios):
            try:
                scenario()
                page.wait_for_timeout(3000)
                
                # After error, app should still be functional
                expect(page.locator("[data-testid='stApp']")).to_be_visible()
                
                # Should be able to navigate to different tabs
                tabs = page.locator("[data-testid='stTabs'] button, .stTabs button")
                if tabs.count() > i:
                    tabs.nth(i).click()
                    page.wait_for_timeout(1000)
                    expect(page.locator("[data-testid='stApp']")).to_be_visible()
                    
            except Exception as e:
                # Even if scenario triggers exception, app should remain functional
                expect(page.locator("[data-testid='stApp']")).to_be_visible()

    def _trigger_invalid_path_error(self, page: Page):
        """Helper to trigger invalid path error"""
        path_inputs = page.locator("input[type='text']")
        if path_inputs.count() > 0:
            path_inputs.first.fill("/invalid/nonexistent/path")
            
            process_buttons = page.locator("button:has-text(/.*[Pp]rocess.*/)")
            if process_buttons.count() > 0:
                process_buttons.first.click()

    def _trigger_ai_error(self, page: Page):
        """Helper to trigger AI operation error"""
        ai_buttons = page.locator("button:has-text(/.*[Gg]enerate.*|.*[Aa]nalyze.*/)")
        if ai_buttons.count() > 0:
            ai_buttons.first.click()

    def _trigger_file_error(self, page: Page):
        """Helper to trigger file operation error"""
        file_inputs = page.locator("input[type='file']")
        if file_inputs.count() > 0:
            # Try to upload non-existent file
            try:
                file_inputs.first.set_input_files("nonexistent_file.pdf")
            except:
                pass  # Expected to fail

    def test_session_persistence_across_workflows(self, page: Page, streamlit_helpers: StreamlitPageHelpers):
        """Test that session state persists correctly across different workflows"""
        streamlit_helpers.wait_for_streamlit_load()
        
        # Set some input in first tab
        tabs = page.locator("[data-testid='stTabs'] button, .stTabs button")
        
        if tabs.count() > 1:
            # Go to first tab and set some input
            tabs.nth(0).click()
            page.wait_for_timeout(1000)
            
            text_inputs = page.locator("input[type='text'], textarea")
            if text_inputs.count() > 0:
                test_value = "Session persistence test"
                text_inputs.first.fill(test_value)
                
                # Navigate through other tabs
                for i in range(1, min(tabs.count(), 4)):
                    tabs.nth(i).click()
                    page.wait_for_timeout(1000)
                    
                    # Perform some action to test session handling
                    buttons = page.locator("button")
                    if buttons.count() > 0:
                        try:
                            buttons.first.click(timeout=2000)
                        except:
                            pass  # Button might not be available
                    
                    page.wait_for_timeout(1000)
                
                # Return to first tab and check if input persisted
                tabs.nth(0).click()
                page.wait_for_timeout(1000)
                
                # Session persistence behavior may vary, but app should be stable
                expect(page.locator("[data-testid='stApp']")).to_be_visible()