list commits

Author: swilly22

code_graph/git_utils/__init__.py

@@ -1 +1 @@
-from .git_utils import build_commit_graph, switch_commit, GitGraph
+from .git_utils import *

code_graph/git_utils/git_graph.py

@@ -1,4 +1,4 @@
-from falkordb import FalkorDB
+from falkordb import FalkorDB, Node
 from typing import List, Optional
 
 class GitGraph():
@@ -23,6 +23,15 @@ def __init__(self, name: str, host: str = 'localhost', port: int = 6379,
         except Exception:
             pass
 
+    def _commit_from_node(self, node:Node) -> dict:
+        """
+            Returns a dict representing a commit node
+        """
+
+        return {'hash':    node.properties['hash'],
+                'date':    node.properties['date'],
+                'author':  node.properties['author'],
+                'message': node.properties['message']}
 
     def add_commit(self, commit_hash: str, author: str, message: str, date: int) -> None:
         """
@@ -32,6 +41,16 @@ def add_commit(self, commit_hash: str, author: str, message: str, date: int) ->
         params = {'hash': commit_hash, 'author': author, 'message': message, 'date': date}
         self.g.query(q, params)
 
+    def list_commits(self) -> List[Node]:
+        """
+        List all commits
+        """
+
+        q = "MATCH (c:Commit) RETURN c ORDER BY c.date"
+        result_set = self.g.query(q).result_set
+
+        return [self._commit_from_node(row[0]) for row in result_set]
+
     def get_commits(self, hashes: List[str]) -> List[dict]:
         q = """MATCH (c:Commit)
                WHERE c.hash IN $hashes
@@ -42,12 +61,7 @@ def get_commits(self, hashes: List[str]) -> List[dict]:
 
         commits = []
         for row in res:
-            commit = row[0]
-            commit = {'hash':    commit.properties['hash'],
-                      'date':    commit.properties['date'],
-                      'author':  commit.properties['author'],
-                      'message': commit.properties['message']}
-
+            commit = self._commit_from_node(row[0])
             commits.append(commit)
 
         return commits

code_graph/graph.py

@@ -17,7 +17,6 @@ def list_repos() -> List[str]:
                   username=FALKORDB_USERNAME, password=FALKORDB_PASSWORD)
 
     graphs = db.list_graphs()
-    print(f"graphs: {graphs}")
     graphs = [g for g in graphs if not g.endswith('_git')]
     return graphs
 

main.py

@@ -288,11 +288,9 @@ def process_auto_complete():
 
 @app.route('/list_repos', methods=['GET'])
 def process_list_repos():
-    print("Hello!")
     # Get JSON data from the request
 
     repos = list_repos()
-    print(f"repos: {repos}")
 
     # Create a response
     response = {
@@ -303,6 +301,30 @@ def process_list_repos():
     return jsonify(response), 200
 
 
+@app.route('/list_commits', methods=['POST'])
+def process_list_commits():
+    # Get JSON data from the request
+    data = request.get_json()
+
+    # name of repository
+    repo = data.get('repo')
+    if repo is None:
+        return jsonify({'status': f'Missing mandatory parameter "repo"'}), 400
+
+    # Get JSON data from the request
+    git_graph = GitGraph(GitRepoName(repo), host=FALKORDB_HOST, port=FALKORDB_PORT,
+                 username=FALKORDB_USERNAME, password=FALKORDB_PASSWORD)
+
+    commits = git_graph.list_commits()
+
+    # Create a response
+    response = {
+        'status': 'success',
+        'commits': commits
+    }
+
+    return jsonify(response), 200
+
 if __name__ == '__main__':
     app.run(debug=True)