turn down log noise. Fix duplicate initialization

Signed-off-by: phernandez <paul@basicmachines.co>

Author: phernandez

src/basic_memory/cli/main.py

@@ -16,13 +16,7 @@
     sync,
     tool,
 )
-from basic_memory.config import app_config
-from basic_memory.services.initialization import ensure_initialization
 
 if __name__ == "__main__":  # pragma: no cover
-    # Run initialization if we are starting as main
-    # if running via a typer command, initialization is already run in cli/app.py
-    ensure_initialization(app_config)
-
     # start the app
     app()

src/basic_memory/repository/repository.py

@@ -192,9 +192,9 @@ async def find_one(self, query: Select[tuple[T]]) -> Optional[T]:
         entity = result.scalars().one_or_none()
 
         if entity:
-            logger.debug(f"Found {self.Model.__name__}: {getattr(entity, 'id', None)}")
+            logger.trace(f"Found {self.Model.__name__}: {getattr(entity, 'id', None)}")
         else:
-            logger.debug(f"No {self.Model.__name__} found")
+            logger.trace(f"No {self.Model.__name__} found")
         return entity
 
     async def create(self, data: dict) -> T:
@@ -358,12 +358,12 @@ async def execute_query(
         """Execute a query asynchronously."""
 
         query = query.options(*self.get_load_options()) if use_query_options else query
-        logger.debug(f"Executing query: {query}, params: {params}")
+        logger.trace(f"Executing query: {query}, params: {params}")
         async with db.scoped_session(self.session_maker) as session:
             result = await session.execute(query, params)
             return result
 
     def get_load_options(self) -> List[LoaderOption]:
         """Get list of loader options for eager loading relationships.
         Override in subclasses to specify what to load."""
-        return []
+        return []

src/basic_memory/repository/search_repository.py

@@ -291,9 +291,9 @@ async def search(
             for row in rows
         ]
 
-        logger.debug(f"Found {len(results)} search results")
+        logger.trace(f"Found {len(results)} search results")
         for r in results:
-            logger.debug(
+            logger.trace(
                 f"Search result: project_id: {r.project_id} type:{r.type} title: {r.title} permalink: {r.permalink} score: {r.score}"
             )
 

src/basic_memory/services/initialization.py

@@ -86,6 +86,7 @@ async def migrate_legacy_projects(app_config: BasicMemoryConfig):
         await migrate_legacy_project_data(project, legacy_dir)
     logger.info("Legacy projects successfully migrated")
 
+
 async def migrate_legacy_project_data(project: Project, legacy_dir: Path) -> bool:
     """Check if project has legacy .basic-memory dir and migrate if needed.
 
@@ -189,6 +190,7 @@ async def initialize_app(
     Args:
         app_config: The Basic Memory project configuration
     """
+    logger.info("Initializing app...")
     # Initialize database first
     await initialize_database(app_config)
 

src/basic_memory/services/link_resolver.py

@@ -28,7 +28,7 @@ def __init__(self, entity_repository: EntityRepository, search_service: SearchSe
 
     async def resolve_link(self, link_text: str, use_search: bool = True) -> Optional[Entity]:
         """Resolve a markdown link to a permalink."""
-        logger.debug(f"Resolving link: {link_text}")
+        logger.trace(f"Resolving link: {link_text}")
 
         # Clean link text and extract any alias
         clean_text, alias = self._normalize_link_text(link_text)
@@ -62,7 +62,7 @@ async def resolve_link(self, link_text: str, use_search: bool = True) -> Optiona
             if results:
                 # Look for best match
                 best_match = min(results, key=lambda x: x.score)  # pyright: ignore
-                logger.debug(
+                logger.trace(
                     f"Selected best match from {len(results)} results: {best_match.permalink}"
                 )
                 if best_match.permalink:
@@ -94,4 +94,4 @@ def _normalize_link_text(self, link_text: str) -> Tuple[str, Optional[str]]:
             text = text.strip()
             alias = alias.strip()
 
-        return text, alias
+        return text, alias

src/basic_memory/services/search_service.py

@@ -66,7 +66,7 @@ async def search(self, query: SearchQuery, limit=10, offset=0) -> List[SearchInd
             logger.debug("no criteria passed to query")
             return []
 
-        logger.debug(f"Searching with query: {query}")
+        logger.trace(f"Searching with query: {query}")
 
         after_date = (
             (

src/basic_memory/sync/sync_service.py

@@ -219,7 +219,7 @@ async def sync_file(
             return entity, checksum
 
         except Exception as e:  # pragma: no cover
-            logger.exception("Failed to sync file", path=path, error=str(e))
+            logger.error(f"Failed to sync file: path={path}, error={str(e)}")
             return None, None
 
     async def sync_markdown_file(self, path: str, new: bool = True) -> Tuple[Optional[Entity], str]:
@@ -427,7 +427,7 @@ async def resolve_relations(self):
         logger.info("Resolving forward references", count=len(unresolved_relations))
 
         for relation in unresolved_relations:
-            logger.debug(
+            logger.trace(
                 "Attempting to resolve relation "
                 f"relation_id={relation.id} "
                 f"from_id={relation.from_id} "
@@ -495,7 +495,7 @@ async def scan_directory(self, directory: Path) -> ScanResult:
                 result.files[rel_path] = checksum
                 result.checksums[checksum] = rel_path
 
-                logger.debug(f"Found file, path={rel_path}, checksum={checksum}")
+                logger.trace(f"Found file, path={rel_path}, checksum={checksum}")
 
         duration_ms = int((time.time() - start_time) * 1000)
         logger.debug(
@@ -505,4 +505,4 @@ async def scan_directory(self, directory: Path) -> ScanResult:
             f"duration_ms={duration_ms}"
         )
 
-        return result
+        return result