Adds loggers to report flow

rocky/reports/views/base.py

@@ -302,6 +302,7 @@ def create_report_recipe(
             ooi=report_recipe,
             observed_at=datetime.now(timezone.utc),
         )
+        logger.info("ReportRecipe created", event_code="080091", report_recipe=report_recipe)
         return report_recipe
 
     def get_input_data(self) -> dict[str, Any]:

rocky/reports/views/mixins.py

@@ -3,6 +3,7 @@
 from typing import Any
 from uuid import uuid4
 
+import structlog
 from django.contrib import messages
 from django.utils.translation import gettext_lazy as _
 from tools.ooi_helpers import create_ooi
@@ -17,6 +18,8 @@
 from reports.report_types.multi_organization_report.report import MultiOrganizationReport, collect_report_data
 from reports.views.base import BaseReportView, ReportDataDict
 
+logger = structlog.get_logger(__name__)
+
 
 def collect_reports(observed_at: datetime, octopoes_connector: OctopoesAPIConnector, ooi_pks: list[str], report_types):
     error_reports = []
@@ -191,6 +194,8 @@ def save_report_data(
         )
 
         create_ooi(octopoes_api_connector, bytes_client, parent_report_ooi, observed_at)
+
+    logger.info("Report created", event_code="080071", report=parent_report_ooi)
     return parent_report_ooi
 
 
@@ -246,6 +251,7 @@ def save_aggregate_report_data(
                 raw=ReportDataDict(data | input_data).model_dump_json().encode(), manual_mime_types={"openkat/report"}
             )
 
+    logger.info("Report created", event_code="080071", report=report_ooi)
     return report_ooi
 
 
@@ -351,5 +357,6 @@ def save_report(self, report_names: list) -> Report:
         )
 
         create_ooi(self.octopoes_api_connector, self.bytes_client, report_ooi, observed_at)
+        logger.info("Report created", event_code="080071", report=report_ooi)
 
         return report_ooi

rocky/reports/views/report_overview.py

@@ -126,6 +126,7 @@ def run_bulk_actions(self) -> None:
 
     def delete_reports(self, report_references: list[Reference]) -> None:
         self.octopoes_api_connector.delete_many(report_references, datetime.now(timezone.utc))
+        logger.info("Reports deleted", event_code="080073", reports=report_references)
         messages.success(self.request, _("Deletion successful."))
 
     def rerun_reports(self, report_references: list[str]) -> None:
@@ -195,6 +196,7 @@ def recreate_report(
         )
 
         create_ooi(self.octopoes_api_connector, self.bytes_client, new_report_ooi, observed_at)
+        logger.info("Report created", event_code="080071", report=new_report_ooi)
 
         return new_report_ooi
 
@@ -297,6 +299,7 @@ def rename_reports(self, report_references: list[str]) -> None:
                 error_reports.append(f'"{report_ooi.name}"')
 
         if not error_reports:
+            logger.info("Reports created", event_code="080071", reports=report_references)
             return messages.success(self.request, _("Reports successfully renamed."))
 
         return messages.error(self.request, _("Report {} could not be renamed.").format(", ".join(error_reports)))

rocky/rocky/scheduler.py

@@ -299,13 +299,15 @@ def patch_schedule(self, schedule_id: str, params: dict[str, Any]) -> None:
         try:
             response = self._client.patch(f"/schedules/{schedule_id}", json=params)
             response.raise_for_status()
+            logger.info("Schedule updated", event_code="080082", schedule_id=schedule_id, params=params)
         except (HTTPStatusError, ConnectError):
             raise SchedulerHTTPError()
 
     def post_schedule(self, schedule: ScheduleRequest) -> ScheduleResponse:
         try:
             res = self._client.post("/schedules", json=schedule.model_dump(exclude_none=True))
             res.raise_for_status()
+            logger.info("Schedule created", event_code="080081", schedule=schedule)
             return ScheduleResponse.model_validate_json(res.content)
         except (ValidationError, HTTPStatusError, ConnectError):
             raise SchedulerValidationError(extra_message="Report schedule failed: ")
@@ -314,6 +316,7 @@ def delete_schedule(self, schedule_id: str) -> None:
         try:
             response = self._client.delete(f"/schedules/{schedule_id}")
             response.raise_for_status()
+            logger.info("Schedule deleted", event_code="080083", schedule_id=schedule_id)
         except (HTTPStatusError, ConnectError):
             raise SchedulerHTTPError()