bambuddy/backend/tests/integration/test_support_api.py

"""Integration tests for Support API endpoints.

Tests the full request/response cycle for /api/v1/support/ endpoints.
"""

import tempfile
from pathlib import Path
from unittest.mock import patch

import pytest
from httpx import AsyncClient


class TestSupportLogsAPI:
    """Integration tests for /api/v1/support/logs endpoints."""

    # ========================================================================
    # GET /api/v1/support/logs
    # ========================================================================

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_get_logs_empty_file(self, async_client: AsyncClient):
        """Verify get logs returns empty list when log file doesn't exist."""
        with patch("backend.app.services.log_reader.settings") as mock_settings:
            mock_settings.log_dir = Path("/nonexistent/path")

            response = await async_client.get("/api/v1/support/logs")

        assert response.status_code == 200
        result = response.json()
        assert result["entries"] == []
        assert result["total_in_file"] == 0
        assert result["filtered_count"] == 0

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_get_logs_with_entries(self, async_client: AsyncClient):
        """Verify get logs returns parsed log entries."""
        log_content = """2024-01-15 10:30:45,123 INFO [backend.app.main] Server started
2024-01-15 10:30:46,456 DEBUG [backend.app.services.printer] Connecting to printer
2024-01-15 10:30:47,789 WARNING [backend.app.services.mqtt] Connection timeout
2024-01-15 10:30:48,012 ERROR [backend.app.services.ftp] Failed to download file
"""
        with tempfile.TemporaryDirectory() as tmpdir:
            log_file = Path(tmpdir) / "bambuddy.log"
            log_file.write_text(log_content)

            with patch("backend.app.services.log_reader.settings") as mock_settings:
                mock_settings.log_dir = Path(tmpdir)

                response = await async_client.get("/api/v1/support/logs")

        assert response.status_code == 200
        result = response.json()
        assert len(result["entries"]) == 4
        assert result["total_in_file"] == 4
        assert result["filtered_count"] == 4

        # Entries are in newest-first order
        assert result["entries"][0]["level"] == "ERROR"
        assert result["entries"][1]["level"] == "WARNING"
        assert result["entries"][2]["level"] == "DEBUG"
        assert result["entries"][3]["level"] == "INFO"

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_get_logs_with_level_filter(self, async_client: AsyncClient):
        """Verify get logs filters by log level."""
        log_content = """2024-01-15 10:30:45,123 INFO [backend.app.main] Server started
2024-01-15 10:30:46,456 DEBUG [backend.app.services.printer] Connecting to printer
2024-01-15 10:30:47,789 ERROR [backend.app.services.mqtt] Connection timeout
2024-01-15 10:30:48,012 ERROR [backend.app.services.ftp] Failed to download file
"""
        with tempfile.TemporaryDirectory() as tmpdir:
            log_file = Path(tmpdir) / "bambuddy.log"
            log_file.write_text(log_content)

            with patch("backend.app.services.log_reader.settings") as mock_settings:
                mock_settings.log_dir = Path(tmpdir)

                response = await async_client.get("/api/v1/support/logs?level=ERROR")

        assert response.status_code == 200
        result = response.json()
        assert len(result["entries"]) == 2
        assert result["filtered_count"] == 2
        assert all(e["level"] == "ERROR" for e in result["entries"])

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_get_logs_with_search_filter(self, async_client: AsyncClient):
        """Verify get logs filters by search query."""
        log_content = """2024-01-15 10:30:45,123 INFO [backend.app.main] Server started
2024-01-15 10:30:46,456 INFO [backend.app.services.printer] Connecting to printer X1C
2024-01-15 10:30:47,789 ERROR [backend.app.services.mqtt] Connection to printer failed
2024-01-15 10:30:48,012 ERROR [backend.app.services.ftp] Failed to download file
"""
        with tempfile.TemporaryDirectory() as tmpdir:
            log_file = Path(tmpdir) / "bambuddy.log"
            log_file.write_text(log_content)

            with patch("backend.app.services.log_reader.settings") as mock_settings:
                mock_settings.log_dir = Path(tmpdir)

                response = await async_client.get("/api/v1/support/logs?search=printer")

        assert response.status_code == 200
        result = response.json()
        assert len(result["entries"]) == 2
        assert result["filtered_count"] == 2

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_get_logs_with_limit(self, async_client: AsyncClient):
        """Verify get logs respects limit parameter."""
        log_content = """2024-01-15 10:30:45,123 INFO [backend.app.main] Line 1
2024-01-15 10:30:46,456 INFO [backend.app.main] Line 2
2024-01-15 10:30:47,789 INFO [backend.app.main] Line 3
2024-01-15 10:30:48,012 INFO [backend.app.main] Line 4
2024-01-15 10:30:49,345 INFO [backend.app.main] Line 5
"""
        with tempfile.TemporaryDirectory() as tmpdir:
            log_file = Path(tmpdir) / "bambuddy.log"
            log_file.write_text(log_content)

            with patch("backend.app.services.log_reader.settings") as mock_settings:
                mock_settings.log_dir = Path(tmpdir)

                response = await async_client.get("/api/v1/support/logs?limit=2")

        assert response.status_code == 200
        result = response.json()
        assert len(result["entries"]) == 2
        assert result["filtered_count"] == 2
        # Should get the newest entries (Line 5 and Line 4)
        assert "Line 5" in result["entries"][0]["message"]
        assert "Line 4" in result["entries"][1]["message"]

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_get_logs_multiline_entry(self, async_client: AsyncClient):
        """Verify get logs handles multi-line log entries."""
        log_content = """2024-01-15 10:30:45,123 INFO [backend.app.main] Server started
2024-01-15 10:30:46,456 ERROR [backend.app.services.mqtt] Exception occurred
Traceback (most recent call last):
  File "test.py", line 10, in test
    raise ValueError("test error")
ValueError: test error
2024-01-15 10:30:47,789 INFO [backend.app.main] Recovery complete
"""
        with tempfile.TemporaryDirectory() as tmpdir:
            log_file = Path(tmpdir) / "bambuddy.log"
            log_file.write_text(log_content)

            with patch("backend.app.services.log_reader.settings") as mock_settings:
                mock_settings.log_dir = Path(tmpdir)

                response = await async_client.get("/api/v1/support/logs")

        assert response.status_code == 200
        result = response.json()
        assert len(result["entries"]) == 3

        # Find the error entry
        error_entry = next(e for e in result["entries"] if e["level"] == "ERROR")
        assert "Exception occurred" in error_entry["message"]
        assert "Traceback" in error_entry["message"]
        assert "ValueError" in error_entry["message"]

    # ========================================================================
    # DELETE /api/v1/support/logs
    # ========================================================================

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_clear_logs_success(self, async_client: AsyncClient):
        """Verify clear logs truncates the log file."""
        log_content = """2024-01-15 10:30:45,123 INFO [backend.app.main] Server started
2024-01-15 10:30:46,456 DEBUG [backend.app.services.printer] Some debug info
"""
        with tempfile.TemporaryDirectory() as tmpdir:
            log_file = Path(tmpdir) / "bambuddy.log"
            log_file.write_text(log_content)

            with patch("backend.app.api.routes.support.settings") as mock_settings:
                mock_settings.log_dir = Path(tmpdir)

                response = await async_client.delete("/api/v1/support/logs")

                # Verify file was cleared
                assert log_file.read_text() == ""

        assert response.status_code == 200
        result = response.json()
        assert "cleared" in result["message"].lower()

    @pytest.mark.asyncio
    @pytest.mark.integration
    async def test_clear_logs_no_file(self, async_client: AsyncClient):
        """Verify clear logs handles missing log file gracefully."""
        with patch("backend.app.api.routes.support.settings") as mock_settings:
            mock_settings.log_dir = Path("/nonexistent/path")

            response = await async_client.delete("/api/v1/support/logs")

        assert response.status_code == 200
        result = response.json()
        assert "does not exist" in result["message"].lower()


class TestLogParsingHelpers:
    """Tests for log parsing helper functions."""

    def test_parse_log_line_valid(self):
        """Verify _parse_log_line handles valid log lines."""
        from backend.app.services.log_reader import parse_log_line as _parse_log_line

        line = "2024-01-15 10:30:45,123 INFO [backend.app.main] Server started"
        entry = _parse_log_line(line)

        assert entry is not None
        assert entry.timestamp == "2024-01-15 10:30:45,123"
        assert entry.level == "INFO"
        assert entry.logger_name == "backend.app.main"
        assert entry.message == "Server started"

    def test_parse_log_line_invalid(self):
        """Verify _parse_log_line returns None for invalid lines."""
        from backend.app.services.log_reader import parse_log_line as _parse_log_line

        line = "This is not a valid log line"
        entry = _parse_log_line(line)

        assert entry is None

    def test_parse_log_line_with_brackets_in_message(self):
        """Verify _parse_log_line handles messages with brackets."""
        from backend.app.services.log_reader import parse_log_line as _parse_log_line

        line = "2024-01-15 10:30:45,123 INFO [backend.app.main] Processing [item 1] and [item 2]"
        entry = _parse_log_line(line)

        assert entry is not None
        assert entry.message == "Processing [item 1] and [item 2]"

    def test_parse_log_line_all_levels(self):
        """Verify _parse_log_line handles all log levels."""
        from backend.app.services.log_reader import parse_log_line as _parse_log_line

        levels = ["DEBUG", "INFO", "WARNING", "ERROR", "CRITICAL"]
        for level in levels:
            line = f"2024-01-15 10:30:45,123 {level} [test.module] Test message"
            entry = _parse_log_line(line)
            assert entry is not None
            assert entry.level == level