add: single Sensor Statistics Update Endpoint

Author: mosoriob

app/api/v1/routes/campaigns/campaign_station_sensors.py

@@ -4,7 +4,7 @@
 
 from app.api.dependencies.auth import get_current_user
 from app.api.dependencies.pytas import check_allocation_permission
-from app.api.v1.schemas.sensor import SensorItem, GetSensorResponse, ListSensorsResponsePagination, SensorStatistics, SensorCreateResponse, SensorUpdate, ForceUpdateSensorStatisticsResponse
+from app.api.v1.schemas.sensor import SensorItem, GetSensorResponse, ListSensorsResponsePagination, SensorStatistics, SensorCreateResponse, SensorUpdate, ForceUpdateSensorStatisticsResponse, UpdateSensorStatisticsResponse
 from app.api.v1.schemas.user import User
 from app.db.session import get_db
 from app.db.repositories.sensor_repository import SensorRepository, SortField
@@ -158,4 +158,25 @@ def force_update_sensor_statistics(
         measurement_repository=MeasurementRepository(db)
     )
 
-    return sensor_service.force_update_station_sensor_statistics(station_id)
+    return sensor_service.force_update_station_sensor_statistics(station_id)
+
+
+@router.post("/sensors/{sensor_id}/statistics", 
+             response_model=UpdateSensorStatisticsResponse,
+             description="Force update sensor statistics for a single sensor")
+def force_update_single_sensor_statistics(
+    campaign_id: int,
+    station_id: int,
+    sensor_id: int,
+    db: Session = Depends(get_db),
+    current_user: User = Depends(get_current_user),
+) -> UpdateSensorStatisticsResponse:
+    if not check_allocation_permission(current_user, campaign_id):
+        raise HTTPException(status_code=404, detail="Allocation is incorrect")
+    
+    sensor_service = SensorService(
+        sensor_repository=SensorRepository(db),
+        measurement_repository=MeasurementRepository(db)
+    )
+    
+    return sensor_service.force_update_single_sensor_statistics(sensor_id)

app/api/v1/schemas/sensor.py

@@ -76,4 +76,9 @@ class SensorUpdate(BaseModel):
 
 class ForceUpdateSensorStatisticsResponse(BaseModel):
     updated_sensor_ids: List[int]
-    total_updated: int
+    total_updated: int
+
+
+class UpdateSensorStatisticsResponse(BaseModel):
+    sensor_id: int
+    updated: bool

app/services/sensor_service.py

@@ -9,7 +9,8 @@
     SensorStatistics,
     SensorItem,
     SensorUpdate,
-    ForceUpdateSensorStatisticsResponse
+    ForceUpdateSensorStatisticsResponse,
+    UpdateSensorStatisticsResponse
 )
 from app.db.repositories.sensor_repository import SensorRepository, SortField
 from app.db.repositories.measurement_repository import MeasurementRepository
@@ -200,4 +201,14 @@ def force_update_station_sensor_statistics(self, station_id: int) -> ForceUpdate
         return ForceUpdateSensorStatisticsResponse(
             updated_sensor_ids=updated_sensor_ids,
             total_updated=len(updated_sensor_ids)
-        )
+        )
+
+    def force_update_single_sensor_statistics(self, sensor_id: int) -> UpdateSensorStatisticsResponse:
+        """Force update statistics for a single sensor."""
+        try:
+            self.sensor_repository.delete_sensor_statistics(sensor_id)
+            self.sensor_repository.refresh_sensor_statistics(sensor_id)
+            return UpdateSensorStatisticsResponse(sensor_id=sensor_id, updated=True)
+        except Exception as e:
+            logging.warning("Failed to update statistics for sensor ID %s: %s", sensor_id, str(e))
+            return UpdateSensorStatisticsResponse(sensor_id=sensor_id, updated=False)

docker-compose.yml

@@ -10,7 +10,7 @@ services:
     volumes:
       - .:/app
     ports:
-      - 8008:8000
+      - 8000:8000
     environment:
       - DATABASE_URL=postgresql://fastapi_traefik:fastapi_traefik@db:5432/fastapi_traefik
     depends_on: