feat: Add v2 import endpoints for ChatGPT, Claude, and memory JSON

Implements v2 versions of all import endpoints:
- POST /v2/projects/{project_id}/import/chatgpt
- POST /v2/projects/{project_id}/import/claude/conversations
- POST /v2/projects/{project_id}/import/claude/projects
- POST /v2/projects/{project_id}/import/memory-json

These endpoints use v2 dependencies (ProjectConfigV2Dep,
MarkdownProcessorV2Dep) for consistent ID-based operations.

Changes:
- Added v2 importer dependencies in deps.py
- Created v2 importer router with all four import endpoints
- Comprehensive test suite with 14 test cases covering:
  - All import formats (ChatGPT, Claude conversations/projects, memory JSON)
  - Error handling (invalid files, malformed JSON, empty files)
  - V2 path validation (project ID vs name)
  - Invalid project ID handling

All 14 SQLite tests pass successfully.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: jope-bm

src/basic_memory/api/app.py

@@ -28,6 +28,7 @@
     resource_router as v2_resource,
     directory_router as v2_directory,
     prompt_router as v2_prompt,
+    importer_router as v2_importer,
 )
 from basic_memory.config import ConfigManager
 from basic_memory.services.initialization import initialize_file_sync, initialize_app
@@ -92,6 +93,7 @@ async def lifespan(app: FastAPI):  # pragma: no cover
 app.include_router(v2_resource, prefix="/v2/projects/{project_id}")
 app.include_router(v2_directory, prefix="/v2/projects/{project_id}")
 app.include_router(v2_prompt, prefix="/v2/projects/{project_id}")
+app.include_router(v2_importer, prefix="/v2/projects/{project_id}")
 app.include_router(v2_project, prefix="/v2")
 
 # Project resource router works across projects

src/basic_memory/api/v2/__init__.py

@@ -20,6 +20,7 @@
     search_router,
     directory_router,
     prompt_router,
+    importer_router,
 )
 
 __all__ = [
@@ -30,4 +31,5 @@
     "search_router",
     "directory_router",
     "prompt_router",
+    "importer_router",
 ]

src/basic_memory/api/v2/routers/__init__.py

@@ -7,6 +7,7 @@
 from basic_memory.api.v2.routers.resource_router import router as resource_router
 from basic_memory.api.v2.routers.directory_router import router as directory_router
 from basic_memory.api.v2.routers.prompt_router import router as prompt_router
+from basic_memory.api.v2.routers.importer_router import router as importer_router
 
 __all__ = [
     "knowledge_router",
@@ -16,4 +17,5 @@
     "resource_router",
     "directory_router",
     "prompt_router",
+    "importer_router",
 ]

src/basic_memory/api/v2/routers/importer_router.py

@@ -0,0 +1,182 @@
+"""V2 Import Router - ID-based data import operations.
+
+This router uses v2 dependencies for consistent project ID handling.
+Import endpoints use project_id in the path for consistency with other v2 endpoints.
+"""
+
+import json
+import logging
+
+from fastapi import APIRouter, Form, HTTPException, UploadFile, status
+
+from basic_memory.deps import (
+    ChatGPTImporterV2Dep,
+    ClaudeConversationsImporterV2Dep,
+    ClaudeProjectsImporterV2Dep,
+    MemoryJsonImporterV2Dep,
+    ProjectIdPathDep,
+)
+from basic_memory.importers import Importer
+from basic_memory.schemas.importer import (
+    ChatImportResult,
+    EntityImportResult,
+    ProjectImportResult,
+)
+
+logger = logging.getLogger(__name__)
+
+router = APIRouter(prefix="/import", tags=["import-v2"])
+
+
+@router.post("/chatgpt", response_model=ChatImportResult)
+async def import_chatgpt(
+    project_id: ProjectIdPathDep,
+    importer: ChatGPTImporterV2Dep,
+    file: UploadFile,
+    folder: str = Form("conversations"),
+) -> ChatImportResult:
+    """Import conversations from ChatGPT JSON export.
+
+    Args:
+        project_id: Validated numeric project ID from URL path
+        file: The ChatGPT conversations.json file.
+        folder: The folder to place the files in.
+        importer: ChatGPT importer instance.
+
+    Returns:
+        ChatImportResult with import statistics.
+
+    Raises:
+        HTTPException: If import fails.
+    """
+    logger.info(f"V2 Importing ChatGPT conversations for project {project_id}")
+    return await import_file(importer, file, folder)
+
+
+@router.post("/claude/conversations", response_model=ChatImportResult)
+async def import_claude_conversations(
+    project_id: ProjectIdPathDep,
+    importer: ClaudeConversationsImporterV2Dep,
+    file: UploadFile,
+    folder: str = Form("conversations"),
+) -> ChatImportResult:
+    """Import conversations from Claude conversations.json export.
+
+    Args:
+        project_id: Validated numeric project ID from URL path
+        file: The Claude conversations.json file.
+        folder: The folder to place the files in.
+        importer: Claude conversations importer instance.
+
+    Returns:
+        ChatImportResult with import statistics.
+
+    Raises:
+        HTTPException: If import fails.
+    """
+    logger.info(f"V2 Importing Claude conversations for project {project_id}")
+    return await import_file(importer, file, folder)
+
+
+@router.post("/claude/projects", response_model=ProjectImportResult)
+async def import_claude_projects(
+    project_id: ProjectIdPathDep,
+    importer: ClaudeProjectsImporterV2Dep,
+    file: UploadFile,
+    folder: str = Form("projects"),
+) -> ProjectImportResult:
+    """Import projects from Claude projects.json export.
+
+    Args:
+        project_id: Validated numeric project ID from URL path
+        file: The Claude projects.json file.
+        folder: The base folder to place the files in.
+        importer: Claude projects importer instance.
+
+    Returns:
+        ProjectImportResult with import statistics.
+
+    Raises:
+        HTTPException: If import fails.
+    """
+    logger.info(f"V2 Importing Claude projects for project {project_id}")
+    return await import_file(importer, file, folder)
+
+
+@router.post("/memory-json", response_model=EntityImportResult)
+async def import_memory_json(
+    project_id: ProjectIdPathDep,
+    importer: MemoryJsonImporterV2Dep,
+    file: UploadFile,
+    folder: str = Form("conversations"),
+) -> EntityImportResult:
+    """Import entities and relations from a memory.json file.
+
+    Args:
+        project_id: Validated numeric project ID from URL path
+        file: The memory.json file.
+        folder: Optional destination folder within the project.
+        importer: Memory JSON importer instance.
+
+    Returns:
+        EntityImportResult with import statistics.
+
+    Raises:
+        HTTPException: If import fails.
+    """
+    logger.info(f"V2 Importing memory.json for project {project_id}")
+    try:
+        file_data = []
+        file_bytes = await file.read()
+        file_str = file_bytes.decode("utf-8")
+        for line in file_str.splitlines():
+            json_data = json.loads(line)
+            file_data.append(json_data)
+
+        result = await importer.import_data(file_data, folder)
+        if not result.success:  # pragma: no cover
+            raise HTTPException(
+                status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+                detail=result.error_message or "Import failed",
+            )
+    except Exception as e:
+        logger.exception("V2 Import failed")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail=f"Import failed: {str(e)}",
+        )
+    return result
+
+
+async def import_file(importer: Importer, file: UploadFile, destination_folder: str):
+    """Helper function to import a file using an importer instance.
+
+    Args:
+        importer: The importer instance to use
+        file: The file to import
+        destination_folder: Destination folder for imported content
+
+    Returns:
+        Import result from the importer
+
+    Raises:
+        HTTPException: If import fails
+    """
+    try:
+        # Process file
+        json_data = json.load(file.file)
+        result = await importer.import_data(json_data, destination_folder)
+        if not result.success:  # pragma: no cover
+            raise HTTPException(
+                status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+                detail=result.error_message or "Import failed",
+            )
+
+        return result
+
+    except Exception as e:
+        logger.exception("V2 Import failed")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail=f"Import failed: {str(e)}",
+        )

src/basic_memory/deps.py

@@ -644,3 +644,50 @@ async def get_memory_json_importer(
 
 
 MemoryJsonImporterDep = Annotated[MemoryJsonImporter, Depends(get_memory_json_importer)]
+
+
+# V2 Import dependencies
+
+
+async def get_chatgpt_importer_v2(
+    project_config: ProjectConfigV2Dep, markdown_processor: MarkdownProcessorV2Dep
+) -> ChatGPTImporter:
+    """Create ChatGPTImporter with v2 dependencies."""
+    return ChatGPTImporter(project_config.home, markdown_processor)
+
+
+ChatGPTImporterV2Dep = Annotated[ChatGPTImporter, Depends(get_chatgpt_importer_v2)]
+
+
+async def get_claude_conversations_importer_v2(
+    project_config: ProjectConfigV2Dep, markdown_processor: MarkdownProcessorV2Dep
+) -> ClaudeConversationsImporter:
+    """Create ClaudeConversationsImporter with v2 dependencies."""
+    return ClaudeConversationsImporter(project_config.home, markdown_processor)
+
+
+ClaudeConversationsImporterV2Dep = Annotated[
+    ClaudeConversationsImporter, Depends(get_claude_conversations_importer_v2)
+]
+
+
+async def get_claude_projects_importer_v2(
+    project_config: ProjectConfigV2Dep, markdown_processor: MarkdownProcessorV2Dep
+) -> ClaudeProjectsImporter:
+    """Create ClaudeProjectsImporter with v2 dependencies."""
+    return ClaudeProjectsImporter(project_config.home, markdown_processor)
+
+
+ClaudeProjectsImporterV2Dep = Annotated[
+    ClaudeProjectsImporter, Depends(get_claude_projects_importer_v2)
+]
+
+
+async def get_memory_json_importer_v2(
+    project_config: ProjectConfigV2Dep, markdown_processor: MarkdownProcessorV2Dep
+) -> MemoryJsonImporter:
+    """Create MemoryJsonImporter with v2 dependencies."""
+    return MemoryJsonImporter(project_config.home, markdown_processor)
+
+
+MemoryJsonImporterV2Dep = Annotated[MemoryJsonImporter, Depends(get_memory_json_importer_v2)]