reports history

routes/reports/general.py

@@ -17,7 +17,9 @@ def get_report(report):
     user = User.find(get_jwt_identity())
 
     try:
-        report_data = general_report_service.get_report(user=user, report=report)
+        report_data = general_report_service.get_report(
+            user=user, report=report, filename=request.args.get("filename", "current")
+        )
     except ValidationError as e:
         return {"status": "error", "message": str(e), "code": e.code}, e.httpStatus
 

services/reports/cache_service.py

@@ -55,3 +55,19 @@ def get_cache_data(report, schema, filename="current"):
         }
     except ClientError:
         return {"exists": False, "updatedAt": None}
+
+
+def list_available_reports(schema: str, report: str):
+    client = _get_client()
+    files = client.list_objects_v2(
+        Bucket=Config.CACHE_BUCKET_NAME,
+        Prefix=f"reports/{schema}/{report}/",
+    )
+
+    file_list = []
+    for f in files["Contents"]:
+        filename = f["Key"].split("/")[-1].replace(".gz", "")
+        if filename != "current":
+            file_list.append(f["Key"].split("/")[-1].replace(".gz", ""))
+
+    return file_list

services/reports/general_report_service.py

@@ -24,5 +24,8 @@ def get_report(user, report, filename="current"):
 
     return {
         "cached": True,
-        "url": cache_service.generate_link(report, user.schema),
+        "availableReports": cache_service.list_available_reports(
+            schema=user.schema, report=report
+        ),
+        "url": cached_link,
     }