data-collector-gateway/app/api/modbus.py

from typing import Any

from fastapi import APIRouter

from app.schemas.modbus import ModbusPointReadRequest, ModbusRawReadRequest
from app.services.modbus_service import read_points, read_raw


router = APIRouter(tags=["modbus"])


@router.get("/health")
def health() -> dict[str, str]:
    return {"status": "ok"}


@router.post("/modbus/read")
def modbus_read(request: ModbusRawReadRequest) -> dict[str, Any]:
    return read_raw(request)


@router.post("/modbus/read-points", include_in_schema=False)
@router.post("/modbus/read_points")
def modbus_read_points(request: ModbusPointReadRequest) -> dict[str, Any]:
    return read_points(request)