Add API endpoints for sensor logs

Author: Bagus-DevLab

app/api/v1/logs.py

@@ -0,0 +1,25 @@
+from fastapi import APIRouter, Depends, HTTPException
+from sqlalchemy.orm import Session
+from typing import List
+
+from app.db.database import get_db  # Pastikan path ini sesuai dengan file koneksi DB kamu
+from app.crud import log as crud_log
+from app.schemas.log import LogResponse
+
+router = APIRouter()
+
+@router.get("/{device_id}", response_model=List[LogResponse])
+def read_device_logs(
+    device_id: str, 
+    limit: int = 20, 
+    db: Session = Depends(get_db)
+):
+    """
+    Ambil histori data sensor.
+    Contoh: GET /api/logs/ALAT_PALSU_01?limit=5
+    """
+    logs = crud_log.get_logs_by_device(db, device_id=device_id, limit=limit)
+    if not logs:
+        # Kita tidak return 404, tapi list kosong saja biar frontend gak error
+        return []
+    return logs

app/crud/log.py

@@ -0,0 +1,13 @@
+from sqlalchemy.orm import Session
+from app.models.device import SensorLog  # Pastikan import model kamu benar
+
+def get_logs_by_device(db: Session, device_id: str, limit: int = 100):
+    """
+    Mengambil data log sensor berdasarkan ID Alat.
+    Diurutkan dari yang paling baru.
+    """
+    return db.query(SensorLog)\
+             .filter(SensorLog.device_id == device_id)\
+             .order_by(SensorLog.created_at.desc())\
+             .limit(limit)\
+             .all()

app/main.py

@@ -11,6 +11,7 @@
 from app.mqtt.client import start_mqtt
 from app.api.v1.devices import router as device_router
 from app.core.limiter import limiter
+from app.api import logs
 
 # --- INIT DATABASE ---
 Base.metadata.create_all(bind=engine)
@@ -24,6 +25,7 @@
 
 # 2. Register Router
 app.include_router(device_router, prefix="/api/v1", tags=["Devices"])
+app.include_router(logs.router, prefix="/api/logs", tags=["Sensor Logs"])
 
 # --- STARTUP EVENTS ---
 @app.on_event("startup")

app/schemas/log.py

@@ -0,0 +1,16 @@
+from pydantic import BaseModel
+from datetime import datetime
+
+# Cetakan dasar (isi data)
+class LogBase(BaseModel):
+    topic_type: str
+    value: str
+
+# Cetakan untuk Response API (ditambah ID & Waktu)
+class LogResponse(LogBase):
+    id: int
+    device_id: str
+    created_at: datetime
+
+    class Config:
+        from_attributes = True  # Supaya bisa baca data dari SQLAlchemy