DBC22-6244: updated stale/delayed stauts when updating webcam

Author: bcgov-brwang

src/backend/apps/consumer/processor.py

@@ -254,7 +254,6 @@ async def process_message(message: aio_pika.IncomingMessage):
         filename = message.headers.get("filename", "unknown.jpg")
         camera_id = filename.split("_")[0].split(".")[0]
         timestamp_utc = message.headers.get("timestamp", "unknown")
-        # camera_status = calculate_camera_status(camera_id, timestamp_utc)
         camera_status = await sync_to_async(calculate_camera_status)(camera_id, timestamp_utc)
 
         timestamp_local = await sync_to_async(safe_db_call)(

src/backend/apps/webcam/enums.py

@@ -4,11 +4,16 @@
     'caption',
     'is_on',
     'should_appear',
+    'marked_stale',
+    'marked_delayed',
 ]
 
 CAMERA_FIELD_MAPPING = {
     'name': 'cam_internetname',
     'caption': 'cam_internetcaption',
     'is_on': 'isOn',
     'should_appear': 'should_appear',
+    'marked_stale': 'stale',
+    'marked_delayed': 'delayed',
+
 }

src/backend/apps/webcam/tasks.py

@@ -173,7 +173,10 @@ def update_webcam_db(cam_id: int, cam_data: dict):
         for field in CAMERA_DIFF_FIELDS:
             source_field = CAMERA_FIELD_MAPPING.get(field, field)
             webcam_value = getattr(existing_webcam, field)
-            source_value = cam_data.get(source_field)
+            if field in ['marked_stale', 'marked_delayed']:
+                source_value = camera_status[source_field]
+            else:
+                source_value = cam_data.get(source_field)
             if webcam_value != source_value:
                 Webcam.objects.filter(id=cam_id).update(
                     is_on=True if cam_data.get("isOn") == 1 else False,
@@ -184,6 +187,10 @@ def update_webcam_db(cam_id: int, cam_data: dict):
                     is_on_demand=cam_data.get("isOnDemand"),
                     last_update_attempt=dt_utc,
                     last_update_modified=dt_utc,
+                    update_period_mean=camera_status["mean_interval"],
+                    update_period_stddev=camera_status["stddev_interval"],
+                    marked_stale=camera_status["stale"],
+                    marked_delayed=camera_status["delayed"],
                 )
                 is_updated = True
         return is_updated