Remove sync_status_service

src/basic_memory/mcp/tools/build_context.py

@@ -106,28 +106,6 @@ async def build_context(
         # Get the active project using the new stateless approach
         active_project = await get_active_project(client, project, context)
 
-        # Check migration status and wait briefly if needed
-        from basic_memory.mcp.tools.utils import wait_for_migration_or_return_status
-
-        migration_status = await wait_for_migration_or_return_status(
-            timeout=5.0, project_name=active_project.name
-        )
-        if migration_status:  # pragma: no cover
-            # Return a proper GraphContext with status message
-            from basic_memory.schemas.memory import MemoryMetadata
-            from datetime import datetime
-
-            return GraphContext(
-                results=[],
-                metadata=MemoryMetadata(
-                    depth=depth or 1,
-                    timeframe=timeframe,
-                    generated_at=datetime.now().astimezone(),
-                    primary_count=0,
-                    related_count=0,
-                    uri=migration_status,  # Include status in metadata
-                ),
-            )
         project_url = active_project.project_url
 
         response = await call_get(

src/basic_memory/mcp/tools/read_note.py

@@ -97,14 +97,6 @@ async def read_note(
             )
             return f"# Error\n\nIdentifier '{identifier}' is not allowed - paths must stay within project boundaries"
 
-        # Check migration status and wait briefly if needed
-        from basic_memory.mcp.tools.utils import wait_for_migration_or_return_status
-
-        migration_status = await wait_for_migration_or_return_status(
-            timeout=5.0, project_name=active_project.name
-        )
-        if migration_status:  # pragma: no cover
-            return f"# System Status\n\n{migration_status}\n\nPlease wait for migration to complete before reading notes."
         project_url = active_project.project_url
 
         # Get the file via REST API - first try direct permalink lookup

src/basic_memory/mcp/tools/utils.py

@@ -512,71 +512,3 @@ async def call_delete(
         raise ToolError(error_message) from e
 
 
-def check_migration_status() -> Optional[str]:
-    """Check if sync/migration is in progress and return status message if so.
-
-    Returns:
-        Status message if sync is in progress, None if system is ready
-    """
-    try:
-        from basic_memory.services.sync_status_service import sync_status_tracker
-
-        if not sync_status_tracker.is_ready:
-            return sync_status_tracker.get_summary()
-        return None
-    except Exception:
-        # If there's any error checking sync status, assume ready
-        return None
-
-
-async def wait_for_migration_or_return_status(
-    timeout: float = 5.0, project_name: Optional[str] = None
-) -> Optional[str]:
-    """Wait briefly for sync/migration to complete, or return status message.
-
-    Args:
-        timeout: Maximum time to wait for sync completion
-        project_name: Optional project name to check specific project status.
-                     If provided, only checks that project's readiness.
-                     If None, uses global status check (legacy behavior).
-
-    Returns:
-        Status message if sync is still in progress, None if ready
-    """
-    try:
-        from basic_memory.services.sync_status_service import sync_status_tracker
-        import asyncio
-
-        # Check if we should use project-specific or global status
-        def is_ready() -> bool:
-            if project_name:
-                return sync_status_tracker.is_project_ready(project_name)
-            return sync_status_tracker.is_ready
-
-        if is_ready():
-            return None
-
-        # Wait briefly for sync to complete
-        start_time = asyncio.get_event_loop().time()
-        while (asyncio.get_event_loop().time() - start_time) < timeout:
-            if is_ready():
-                return None
-            await asyncio.sleep(0.1)  # Check every 100ms
-
-        # Still not ready after timeout
-        if project_name:
-            # For project-specific checks, get project status details
-            project_status = sync_status_tracker.get_project_status(project_name)
-            if project_status and project_status.status.value == "failed":
-                error_msg = project_status.error or "Unknown sync error"
-                return f"❌ Sync failed for project '{project_name}': {error_msg}"
-            elif project_status:
-                return f"🔄 Project '{project_name}' is still syncing: {project_status.message}"
-            else:
-                return f"⚠️ Project '{project_name}' status unknown"
-        else:
-            # Fall back to global summary for legacy calls
-            return sync_status_tracker.get_summary()
-    except Exception:  # pragma: no cover
-        # If there's any error, assume ready
-        return None

src/basic_memory/mcp/tools/write_note.py

@@ -140,15 +140,6 @@ async def write_note(
             )
             return f"# Error\n\nFolder path '{folder}' is not allowed - paths must stay within project boundaries"
 
-        # Check migration status and wait briefly if needed
-        from basic_memory.mcp.tools.utils import wait_for_migration_or_return_status
-
-        migration_status = await wait_for_migration_or_return_status(
-            timeout=5.0, project_name=active_project.name
-        )
-        if migration_status:  # pragma: no cover
-            return f"# System Status\n\n{migration_status}\n\nPlease wait for migration to complete before creating notes."
-
         # Process tags using the helper function
         tag_list = parse_tags(tags)
         # Create the entity request