introducing project class and some endpoints tests

Author: swilly22

app.py

@@ -1,7 +1,9 @@
 from .info import *
 from .graph import *
+from .project import *
 from .entities import *
 from .git_utils import *
+from .app import create_app
 from .code_coverage import *
 from .analyzers.source_analyzer import *
-from. auto_complete import prefix_search
+from .auto_complete import prefix_search

code_graph/__init__.py

@@ -1,9 +1,10 @@
 import io
-from typing import Union, Optional
-from pathlib import Path
+import os
 from ..utils import *
+from pathlib import Path
 from ...entities import *
 from ...graph import Graph
+from typing import Union, Optional
 from ..analyzer import AbstractAnalyzer
 
 import tree_sitter_c as tsc
@@ -347,7 +348,7 @@ def first_pass(self, path: Path, f: io.TextIOWrapper, graph:Graph) -> None:
         logger.info(f"Processing {path}")
 
         # Create file entity
-        file = File(str(path.parent), path.name, path.suffix)
+        file = File(os.path.dirname(path), path.name, path.suffix)
         graph.add_file(file)
 
         # Parse file
@@ -416,7 +417,7 @@ def second_pass(self, path: Path, f: io.TextIOWrapper, graph: Graph) -> None:
         logger.info(f"Processing {path}")
 
         # Get file entity
-        file = graph.get_file(str(path.parent), path.name, path.suffix)
+        file = graph.get_file(os.path.dirname(path), path.name, path.suffix)
         if file is None:
             logger.error(f"File entity not found for: {path}")
             return

code_graph/analyzers/c/analyzer.py

@@ -1,9 +1,10 @@
 import io
-from typing import Union, Optional
-from pathlib import Path
+import os
 from ..utils import *
+from pathlib import Path
 from ...entities import *
 from ...graph import Graph
+from typing import Union, Optional
 from ..analyzer import AbstractAnalyzer
 
 import tree_sitter_python as tspython
@@ -226,7 +227,7 @@ def first_pass(self, path: Path, f: io.TextIOWrapper, graph:Graph) -> None:
         logger.info(f"Python Processing {path}")
 
         # Create file entity
-        file = File(str(path.parent), path.name, path.suffix)
+        file = File(os.path.dirname(path), path.name, path.suffix)
         graph.add_file(file)
 
         # Parse file
@@ -367,7 +368,7 @@ def second_pass(self, path: Path, f: io.TextIOWrapper, graph: Graph) -> None:
         logger.info(f"Processing {path}")
 
         # Get file entity
-        file = graph.get_file(str(path.parent), path.name, path.suffix)
+        file = graph.get_file(os.path.dirname(path), path.name, path.suffix)
         if file is None:
             logger.error(f"File entity not found for: {path}")
             return

code_graph/analyzers/python/analyzer.py

@@ -1,6 +1,5 @@
 import os
 import shutil
-import subprocess
 import concurrent.futures
 
 from git import Repo
@@ -20,6 +19,12 @@
              '.py': PythonAnalyzer()}
 
 class SourceAnalyzer():
+
+    def supported_types(self) -> List[str]:
+        """
+        """
+        return list(analyzers.keys())
+
     def first_pass(self, ignore: List[str], executor: concurrent.futures.Executor) -> None:
         """
         Perform the first pass analysis on source files in the given directory tree.
@@ -53,6 +58,7 @@ def first_pass(self, ignore: List[str], executor: concurrent.futures.Executor) -
                     continue
 
                 logger.info(f'Processing file: {file_path}')
+                print(f'Processing file: {file_path}')
 
                 def process_file(path: Path) -> None:
                     with open(path, 'rb') as f:
@@ -111,6 +117,17 @@ def process_file(path: Path) -> None:
         # Wait for all tasks to complete
         concurrent.futures.wait(tasks)
 
+    def analyze_file(self, path: Path, graph: Graph) -> None:
+        ext = path.suffix
+        print(f"analyze_file: path: {path}")
+        print(f"analyze_file: ext: {ext}")
+        if ext not in analyzers:
+            return
+
+        with open(path, 'rb') as f:
+            analyzers[ext].first_pass(path, f, graph)
+            analyzers[ext].second_pass(path, f, graph)
+
     def analyze_sources(self, ignore: List[str]) -> None:
         with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor:
             # First pass analysis of the source code
@@ -119,62 +136,9 @@ def analyze_sources(self, ignore: List[str]) -> None:
             # Second pass analysis of the source code
             self.second_pass(ignore, executor)
 
-    def analyze_github_repository(
-        self,
-        url: str,
-        repo_path: Path,
-        repo_name: str,
-        ignore: Optional[List[str]] = []
-    ) -> None:
+    def analyze(self, path: str, g: Graph, ignore: Optional[List[str]] = []) -> None:
         """
-        Analyze a Git repository given its URL.
-
-        Args:
-            url: The URL of the Git repository to analyze
-            ignore_patterns: List of patterns to ignore during analysis
-
-        Raises:
-            subprocess.SubprocessError: If git clone fails
-            OSError: If there are filesystem operation errors
-        """
-
-        # Extract repository name more reliably
-        # Delete local repository if exists
-        if repo_path.exists():
-            shutil.rmtree(repo_path)
-
-        # Create directory
-        repo_path.mkdir(parents=True, exist_ok=True)
-
-        # Clone repository
-        # Prepare the git clone command
-        command = ["git", "clone", url, repo_path]
-
-        # Run the git clone command and wait for it to finish
-        result = subprocess.run(command, check=True, capture_output=True, text=True)
-
-        # Store original working directory
-        original_dir = Path.cwd()
-
-        # change working directory to local repository
-        os.chdir(repo_path)
-
-        try:
-            # Initialize the graph and analyzer
-            self.graph = Graph(repo_name)
-
-            # Analyze repository
-            self.analyze_sources(ignore)
-
-            logging.info(f"Successfully processed repository: {repo_name}")
-
-        finally:
-            # Ensure we always return to the original directory
-            os.chdir(original_dir)
-
-    def analyze_local_folder(self, path: str, ignore: Optional[List[str]] = []) -> Graph:
-        """
-        Analyze a local folder.
+        Analyze path.
 
         Args:
             path (str): Path to a local folder containing source files to process
@@ -184,18 +148,13 @@ def analyze_local_folder(self, path: str, ignore: Optional[List[str]] = []) -> G
         # change working directory to path
         os.chdir(path)
 
-        proj_name = os.path.split(os.path.normpath(path))[-1]
-        logger.debug(f'proj_name: {proj_name}')
-
         # Initialize the graph and analyzer
-        self.graph = Graph(proj_name)
+        self.graph = g
 
         # Analyze source files
         self.analyze_sources(ignore)
 
-        logger.info("Done processing folder")
-
-        return self.graph
+        logger.info("Done analyzing path")
 
     def analyze_local_repository(self, path: str, ignore: Optional[List[str]] = []) -> Graph:
         """