Adding aql-queries endpoint

Author: apetenchea

arango/aql.py

@@ -17,6 +17,7 @@
     AQLQueryClearError,
     AQLQueryExecuteError,
     AQLQueryExplainError,
+    AQLQueryHistoryError,
     AQLQueryKillError,
     AQLQueryListError,
     AQLQueryRulesGetError,
@@ -627,6 +628,23 @@ def response_handler(resp: Response) -> Json:
 
         return self._execute(request, response_handler)
 
+    def history(self) -> Result[Json]:
+        """Return recently executed AQL queries (admin only).
+
+        :return: AQL query history.
+        :rtype: dict
+        :raise arango.exceptions.AQLQueryHistoryError: If retrieval fails.
+        """
+        request = Request(method="get", endpoint="/_admin/server/aql-queries")
+
+        def response_handler(resp: Response) -> Json:
+            if not resp.is_success:
+                raise AQLQueryHistoryError(resp, request)
+            res: Json = resp.body["result"]
+            return res
+
+        return self._execute(request, response_handler)
+
     def functions(self) -> Result[Jsons]:
         """List the AQL functions defined in the database.
 

arango/exceptions.py

@@ -121,6 +121,10 @@ class AQLQueryTrackingGetError(ArangoServerError):
     """Failed to retrieve AQL tracking properties."""
 
 
+class AQLQueryHistoryError(ArangoServerError):
+    """Failed to retrieve recent AQL queries."""
+
+
 class AQLQueryTrackingSetError(ArangoServerError):
     """Failed to configure AQL tracking properties."""
 

starter.sh

@@ -8,8 +8,8 @@
 # Example:
 #   ./starter.sh cluster enterprise 3.12.5
 
-setup="${1:-single}"
-license="${2:-community}"
+setup="${1:-cluster}"
+license="${2:-enterprise}"
 version="${3:-latest}"
 
 extra_ports=""

tests/test_aql.py

@@ -13,6 +13,7 @@
     AQLQueryClearError,
     AQLQueryExecuteError,
     AQLQueryExplainError,
+    AQLQueryHistoryError,
     AQLQueryKillError,
     AQLQueryListError,
     AQLQueryTrackingGetError,
@@ -30,7 +31,7 @@ def test_aql_attributes(db, username):
     assert repr(db.aql.cache) == f"<AQLQueryCache in {db.name}>"
 
 
-def test_aql_query_management(db_version, db, bad_db, col, docs):
+def test_aql_query_management(db_version, db, sys_db, bad_db, col, docs):
     explain_fields = [
         "estimatedNrItems",
         "estimatedCost",
@@ -192,6 +193,12 @@ def test_aql_query_management(db_version, db, bad_db, col, docs):
     db.begin_async_execution().aql.execute("RETURN SLEEP(100)")
     db.begin_async_execution().aql.execute("RETURN SLEEP(50)")
 
+    # Test query history
+    with assert_raises(AQLQueryHistoryError):
+        bad_db.aql.history()
+    history = sys_db.aql.history()
+    assert isinstance(history, dict)
+
     # Test list queries
     queries = db.aql.queries()
     for query in queries: