refactor: remove unused code and dependencies

Author: macayu17

.github/workflows/ci.yml

@@ -13,7 +13,7 @@ jobs:
         with:
           python-version: "3.11"
       - run: python -m compileall api
-      - run: python -m pip install -r api/requirements.txt
+      - run: python -m pip install -r api/requirements-dev.txt
       - run: python -m pytest api
 
   mcp:

api/models/conversation.py

@@ -1,15 +1,6 @@
-from datetime import datetime
-
 from pydantic import BaseModel, Field, UUID4
 
 
-class ConversationResponse(BaseModel):
-    id: UUID4
-    extraction_status: str
-    memories_extracted: int
-    created_at: datetime
-
-
 class ConversationCaptureRequest(BaseModel):
     user_message: str = Field(min_length=1, max_length=20000)
     assistant_response: str = Field(min_length=1, max_length=20000)

api/models/log.py

@@ -1,6 +1,6 @@
 from datetime import datetime
 
-from pydantic import BaseModel, Field, UUID4
+from pydantic import BaseModel, UUID4
 
 
 class RetrievedMemoryLog(BaseModel):
@@ -37,9 +37,3 @@ class ClientRegistryResponse(BaseModel):
 
 class RetrievalLogDetailResponse(RetrievalLogResponse):
     query_embedding_dimensions: int | None
-
-
-class RetrievalLogListParams(BaseModel):
-    limit: int = Field(default=20, ge=1, le=100)
-    offset: int = Field(default=0, ge=0)
-    conversation_id: UUID4 | None = None

api/requirements-dev.txt

@@ -0,0 +1,3 @@
+-r requirements.txt
+pytest==8.2.2
+pytest-asyncio==0.23.7

api/requirements.txt

@@ -5,10 +5,5 @@ pydantic==2.7.0
 pydantic-settings==2.3.0
 sentence-transformers==3.0.0
 httpx==0.27.0
-python-multipart==0.0.9
-openai==1.35.0
-google-generativeai==0.7.0
-pytest==8.2.2
-pytest-asyncio==0.23.7
 cryptography==43.0.0
 stripe==15.3.0

api/services/memories.py

@@ -544,16 +544,6 @@ def build_memory_filters(
     return status_clause, category_clause, params
 
 
-def filter_memory_rows(rows: list[dict[str, object]], status: MemoryStatus | None, category: str | None) -> list[dict[str, object]]:
-    normalized_category = normalize_category(category) if category else None
-    return [
-        row
-        for row in rows
-        if (status is None or row.get("status") == status)
-        and (normalized_category is None or row.get("category") == normalized_category)
-    ]
-
-
 def normalize_category(category: str | None) -> str:
     if not category:
         return "general"

api/services/provider_keys.py

@@ -130,12 +130,3 @@ def summarize_provider_for_response(
         "has_user_api_key": decrypted is not None,
         "user_api_key_preview": mask_provider_key(decrypted),
     }
-
-
-def supported_providers() -> list[dict[str, str]]:
-    return [
-        {"name": "openai", "supports_override_key": "true"},
-        {"name": "gemini", "supports_override_key": "true"},
-        {"name": "ollama", "supports_override_key": "false"},
-        {"name": "anthropic", "supports_override_key": "true"},
-    ]

api/services/proxy.py

@@ -246,19 +246,9 @@ async def open_provider_stream(
         await client.aclose()
         raise RuntimeError(f"Provider request failed: {error}") from error
     return ProviderStream(client, response)
-
-
-def get_openai_compatible_url(provider: str) -> str:
-    if provider == "openai":
-        return build_chat_completions_url(settings.openai_base_url)
-    if provider == "gemini":
-        return build_chat_completions_url(settings.gemini_base_url)
-    if provider == "ollama":
-        return build_chat_completions_url(f"{settings.ollama_base_url.rstrip('/')}/v1")
-    raise ValueError(f"Unsupported provider: {provider}")
-
-
-def build_provider_headers(resolved: ResolvedProvider, incoming_headers: Mapping[str, str]) -> dict[str, str]:
+
+
+def build_provider_headers(resolved: ResolvedProvider, incoming_headers: Mapping[str, str]) -> dict[str, str]:
     headers = sanitize_passthrough_headers(incoming_headers)
     headers["content-type"] = "application/json"
     if resolved.name in {"openai", "gemini"}:

api/services/retrieval.py

@@ -27,23 +27,6 @@
 }
 
 
-def get_last_user_message(body: Mapping[str, object]) -> str:
-    messages = body.get("messages")
-    if not isinstance(messages, list):
-        return ""
-    for message in reversed(messages):
-        if not isinstance(message, dict):
-            continue
-        if message.get("role") != "user":
-            continue
-        content = message.get("content")
-        if isinstance(content, str):
-            return content
-        if isinstance(content, list):
-            return extract_text_from_content_parts(content)
-    return ""
-
-
 def get_retrieval_query(body: Mapping[str, object], max_user_messages: int = 6) -> str:
     messages = body.get("messages")
     if not isinstance(messages, list):

api/test_provider_keys.py

@@ -1,5 +1,4 @@
 import os
-from dataclasses import asdict
 from pathlib import Path
 
 import pytest