test: Add database operations and app lifecycle tests

- Add test_database_extended.py: execute, fetch, fetchrow, fetchval, connect, disconnect
- Add test_lifecycle.py: startup/shutdown sequence, app metadata, OpenAPI tags
- Database coverage: 53% → 88%
- Overall coverage: 48% → 67%
- 39/39 tests passing

Author: Will Flores

tests/test_database_extended.py

@@ -0,0 +1,78 @@
+"""Extended database pool tests for coverage improvement."""
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+from core.database import DatabasePool
+
+
+@pytest.fixture
+def db():
+    return DatabasePool()
+
+
+@pytest.fixture
+def mock_pool():
+    pool = MagicMock()
+    conn = AsyncMock()
+    cm = AsyncMock()
+    cm.__aenter__.return_value = conn
+    cm.__aexit__.return_value = False
+    pool.acquire.return_value = cm
+    return pool, conn
+
+
+class TestDatabasePoolOperations:
+    @pytest.mark.asyncio
+    async def test_execute(self, db, mock_pool):
+        pool, conn = mock_pool
+        conn.execute.return_value = "INSERT 1"
+        db.pool = pool
+        result = await db.execute("INSERT INTO test VALUES ($1)", "val")
+        conn.execute.assert_called_once_with("INSERT INTO test VALUES ($1)", "val")
+        assert result == "INSERT 1"
+
+    @pytest.mark.asyncio
+    async def test_fetch(self, db, mock_pool):
+        pool, conn = mock_pool
+        conn.fetch.return_value = [{"id": 1}, {"id": 2}]
+        db.pool = pool
+        result = await db.fetch("SELECT * FROM test")
+        conn.fetch.assert_called_once()
+        assert len(result) == 2
+
+    @pytest.mark.asyncio
+    async def test_fetchrow(self, db, mock_pool):
+        pool, conn = mock_pool
+        conn.fetchrow.return_value = {"id": 1, "name": "test"}
+        db.pool = pool
+        result = await db.fetchrow("SELECT * FROM test WHERE id=$1", 1)
+        conn.fetchrow.assert_called_once()
+        assert result["name"] == "test"
+
+    @pytest.mark.asyncio
+    async def test_fetchval(self, db, mock_pool):
+        pool, conn = mock_pool
+        conn.fetchval.return_value = 42
+        db.pool = pool
+        result = await db.fetchval("SELECT COUNT(*) FROM test")
+        conn.fetchval.assert_called_once()
+        assert result == 42
+
+    @pytest.mark.asyncio
+    async def test_connect(self, db):
+        with patch("asyncpg.create_pool", new_callable=AsyncMock) as mock_create:
+            mock_create.return_value = AsyncMock()
+            await db.connect()
+            mock_create.assert_called_once()
+            assert db.pool is not None
+
+    @pytest.mark.asyncio
+    async def test_disconnect(self, db):
+        mock_pool = AsyncMock()
+        db.pool = mock_pool
+        await db.disconnect()
+        mock_pool.close.assert_called_once()
+
+    @pytest.mark.asyncio
+    async def test_disconnect_no_pool(self, db):
+        db.pool = None
+        await db.disconnect()

tests/test_lifecycle.py

@@ -0,0 +1,54 @@
+"""App lifecycle and startup/shutdown tests."""
+import pytest
+from unittest.mock import AsyncMock, patch, MagicMock
+
+
+class TestAppLifecycle:
+    """Test application startup and shutdown sequences."""
+
+    @pytest.mark.asyncio
+    async def test_startup_sequence(self):
+        with patch("main.startup_database", new_callable=AsyncMock) as mock_db, \
+             patch("main.startup_xrpl", new_callable=AsyncMock) as mock_xrpl, \
+             patch("main.log_auth_configuration") as mock_auth, \
+             patch("main.log_rate_limit_config") as mock_rate, \
+             patch("main.log_security_headers_config") as mock_sec:
+            from main import app
+            for handler in app.router.on_startup:
+                await handler()
+            mock_db.assert_called_once()
+            mock_xrpl.assert_called_once()
+            mock_auth.assert_called_once()
+            mock_rate.assert_called_once()
+            mock_sec.assert_called_once()
+
+    @pytest.mark.asyncio
+    async def test_shutdown_sequence(self):
+        with patch("main.shutdown_xrpl", new_callable=AsyncMock) as mock_xrpl, \
+             patch("main.shutdown_database", new_callable=AsyncMock) as mock_db:
+            from main import app
+            for handler in app.router.on_shutdown:
+                await handler()
+            mock_xrpl.assert_called_once()
+            mock_db.assert_called_once()
+
+    def test_app_metadata(self):
+        from main import app
+        assert app.title == "Ward Protocol API"
+        assert app.version == "0.1.0"
+        assert app.docs_url == "/docs"
+        assert app.redoc_url == "/redoc"
+
+    def test_openapi_tags(self):
+        from main import app
+        tags = app.openapi_tags
+        tag_names = [t["name"] for t in tags]
+        assert "Public" in tag_names
+        assert "Permissioned Domains" in tag_names
+        assert "Admin" in tag_names
+        assert "Monitoring" in tag_names
+
+    def test_docs_description(self):
+        from main import app
+        assert "XLS-80" in app.description
+        assert "Ward Protocol" in app.description