api: add stats endpoint (bug 1800074)

Author: zzzeid

landoapi/api/__init__.py

@@ -2,7 +2,49 @@
 # License, v. 2.0. If a copy of the MPL was not distributed with this
 # file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
+from landoapi.models.revisions import Revision, RevisionStatus as RS
+from landoapi.models.landing_job import LandingJob, LandingJobStatus as LJS
+
 
 def get():
     """Return a redirect repsonse to the swagger specification."""
     return None, 302, {"Location": "/swagger.json"}
+
+
+def get_stats():
+    """Return some useful statistics about the Lando system."""
+    data = {}
+    data["landing_jobs"] = {
+        "SUBMITTED": LandingJob.query.filter(
+            LandingJob.status == LJS.SUBMITTED
+        ).count(),
+        "DEFERRED": LandingJob.query.filter(LandingJob.status == LJS.DEFERRED).count(),
+        "FAILED": LandingJob.query.filter(LandingJob.status == LJS.FAILED).count(),
+        "CANCELLED": LandingJob.query.filter(
+            LandingJob.status == LJS.CANCELLED
+        ).count(),
+        "IN_PROGRESS": LandingJob.query.filter(
+            LandingJob.status == LJS.IN_PROGRESS
+        ).count(),
+        "LANDED": LandingJob.query.filter(LandingJob.status == LJS.LANDED).count(),
+    }
+
+    data["revisions"] = {
+        "NEW": Revision.query.filter(Revision.status == RS.NEW).count(),
+        "STALE": Revision.query.filter(Revision.status == RS.STALE).count(),
+        "PICKED_UP": Revision.query.filter(Revision.status == RS.PICKED_UP).count(),
+        "READY_FOR_PREPROCESSING": Revision.query.filter(
+            Revision.status == RS.READY_FOR_PREPROCESSING
+        ).count(),
+        "PREPROCESSING": Revision.query.filter(
+            Revision.status == RS.PREPROCESSING
+        ).count(),
+        "PROBLEM": Revision.query.filter(Revision.status == RS.PROBLEM).count(),
+        "READY": Revision.query.filter(Revision.status == RS.READY).count(),
+        "QUEUED": Revision.query.filter(Revision.status == RS.QUEUED).count(),
+        "LANDING": Revision.query.filter(Revision.status == RS.LANDING).count(),
+        "LANDED": Revision.query.filter(Revision.status == RS.LANDED).count(),
+        "FAILED": Revision.query.filter(Revision.status == RS.FAILED).count(),
+    }
+
+    return data, 200

landoapi/repos.py

@@ -196,7 +196,8 @@ def phab_identifier(self) -> str:
             push_path="ssh://autoland.hg//repos/third-repo",
             pull_path="http://hg.test/third-repo",
             config_override={"fix.black:command": "black -- -"},
-            approval_required=True,
+            approval_required=False,
+            use_revision_worker=True,
         ),
         # Approval is required for the uplift dev repo
         "uplift-target": Repo(

landoapi/spec/swagger.yml

@@ -44,17 +44,8 @@ paths:
               - $ref: '#/definitions/Error'
   /stats:
     get:
-      operationId: landoapi.api.landing_jobs.get_stats
-      description: Return various statistics about landing jobs.
-      parameters:
-        - name: start_date
-          in: query
-          type: string
-          format: date
-        - name: end_date
-          in: query
-          type: string
-          format: date
+      operationId: landoapi.api.get_stats
+      description: Return various statistics about landing jobs and revisions.
       responses:
         200:
           description: OK