test: add unit/integration coverage and CI pipeline

Author: Modal Agent Runner

.github/workflows/ci.yml

@@ -0,0 +1,48 @@
+name: ci
+
+on:
+  push:
+    branches: [main]
+  pull_request:
+
+jobs:
+  backend:
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Setup Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: "3.11"
+
+      - name: Install backend dependencies
+        run: |
+          python -m pip install --upgrade pip
+          pip install -r requirements.txt
+
+      - name: Run tests
+        run: pytest -q
+
+  frontend:
+    runs-on: ubuntu-latest
+    defaults:
+      run:
+        working-directory: frontend
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Setup Node
+        uses: actions/setup-node@v4
+        with:
+          node-version: "20"
+          cache: "npm"
+          cache-dependency-path: frontend/package.json
+
+      - name: Install frontend dependencies
+        run: npm install
+
+      - name: Build frontend
+        run: npm run build

pytest.ini

@@ -0,0 +1,4 @@
+[pytest]
+pythonpath = .
+asyncio_mode = auto
+testpaths = tests

tests/integration/test_api_basics.py

@@ -0,0 +1,66 @@
+import importlib
+import os
+from pathlib import Path
+
+from fastapi.testclient import TestClient
+
+
+TEST_DB = Path("./test_ic_workflow.db")
+os.environ["DATABASE_URL"] = "sqlite+aiosqlite:///./test_ic_workflow.db"
+os.environ["OPENAI_API_KEY"] = ""
+
+from src.core.config import get_settings
+
+get_settings.cache_clear()
+
+import src.database.session as session_module
+import src.main as main_module
+
+importlib.reload(session_module)
+importlib.reload(main_module)
+
+app = main_module.app
+
+
+def setup_module() -> None:
+    if TEST_DB.exists():
+        TEST_DB.unlink()
+
+
+def teardown_module() -> None:
+    if TEST_DB.exists():
+        TEST_DB.unlink()
+
+
+def test_health_endpoint() -> None:
+    with TestClient(app) as client:
+        response = client.get("/api/v1/health")
+        assert response.status_code == 200
+        payload = response.json()
+        assert payload["status"] == "ok"
+
+
+def test_create_and_list_deals() -> None:
+    with TestClient(app) as client:
+        create_response = client.post(
+            "/api/v1/deals",
+            json={
+                "deal_name": "Integration Deal",
+                "target_name": "Integration Target",
+                "deal_type": "equity",
+                "industry": "Fintech",
+                "geography": "US",
+                "deal_size": 2500000,
+                "valuation": 20000000,
+                "currency": "USD",
+            },
+            headers={"X-User": "integration@test.local"},
+        )
+        assert create_response.status_code == 201
+        deal = create_response.json()
+        assert deal["deal_name"] == "Integration Deal"
+
+        list_response = client.get("/api/v1/deals")
+        assert list_response.status_code == 200
+        deals = list_response.json()
+        assert any(item["id"] == deal["id"] for item in deals)

tests/unit/test_ic_decision.py

@@ -0,0 +1,18 @@
+from src.api.routes.ic_decisions import compute_approval_percentage
+
+
+def test_compute_approval_percentage() -> None:
+    value = compute_approval_percentage(
+        {
+            "a": "approve",
+            "b": "approved",
+            "c": "reject",
+            "d": "yes",
+        }
+    )
+
+    assert value == 0.75
+
+
+def test_compute_approval_percentage_empty_votes() -> None:
+    assert compute_approval_percentage({}) == 0.0

tests/unit/test_workflow_engine.py

@@ -0,0 +1,30 @@
+from src.models.database import DealStatus
+from src.workflows.state_machine import DealWorkflowEngine
+
+
+def test_transition_matrix_allows_expected_path() -> None:
+    engine = DealWorkflowEngine()
+
+    assert engine.can_transition(DealStatus.SUBMITTED, DealStatus.ANALYST_REVIEW)
+    assert engine.can_transition(DealStatus.ANALYST_REVIEW, DealStatus.RISK_REVIEW)
+    assert engine.can_transition(DealStatus.RISK_REVIEW, DealStatus.LEGAL_REVIEW)
+    assert engine.can_transition(DealStatus.LEGAL_REVIEW, DealStatus.IC_PENDING)
+    assert engine.can_transition(DealStatus.IC_PENDING, DealStatus.APPROVED)
+
+
+def test_transition_matrix_blocks_invalid_jump() -> None:
+    engine = DealWorkflowEngine()
+
+    assert not engine.can_transition(DealStatus.SUBMITTED, DealStatus.APPROVED)
+    assert not engine.can_transition(DealStatus.APPROVED, DealStatus.SUBMITTED)
+
+
+def test_task_templates_exist_for_review_stages() -> None:
+    engine = DealWorkflowEngine()
+
+    analyst_tasks = engine.next_tasks(DealStatus.ANALYST_REVIEW)
+    ic_tasks = engine.next_tasks(DealStatus.IC_PENDING)
+
+    assert analyst_tasks
+    assert ic_tasks
+    assert analyst_tasks[0].due_in_hours > 0