from __future__ import annotations

from openstatus._gen.openstatus.monitor.v1.service_pb2 import (
    CreateDNSMonitorRequest,
    CreateDNSMonitorResponse,
    CreateHTTPMonitorRequest,
    CreateHTTPMonitorResponse,
    CreateTCPMonitorRequest,
    CreateTCPMonitorResponse,
    DeleteMonitorRequest,
    DeleteMonitorResponse,
    GetMonitorHTTPResponseLogRequest,
    GetMonitorHTTPResponseLogResponse,
    GetMonitorRequest,
    GetMonitorResponse,
    GetMonitorStatusRequest,
    GetMonitorStatusResponse,
    GetMonitorSummaryRequest,
    GetMonitorSummaryResponse,
    ListMonitorHTTPResponseLogsRequest,
    ListMonitorHTTPResponseLogsResponse,
    ListMonitorsRequest,
    ListMonitorsResponse,
    TriggerMonitorRequest,
    TriggerMonitorResponse,
    UpdateDNSMonitorRequest,
    UpdateDNSMonitorResponse,
    UpdateHTTPMonitorRequest,
    UpdateHTTPMonitorResponse,
    UpdateTCPMonitorRequest,
    UpdateTCPMonitorResponse,
)
from openstatus._transport import _AsyncJsonTransport, _JsonTransport

__all__ = ["AsyncMonitorServiceClient", "MonitorServiceClient"]

_FQN = "openstatus.monitor.v1.MonitorService"


class MonitorServiceClient:
    def __init__(self, transport: _JsonTransport) -> None:
        self._t = transport

    def create_http_monitor(
        self,
        request: CreateHTTPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> CreateHTTPMonitorResponse:
        return self._t.call(_FQN, "CreateHTTPMonitor", request, CreateHTTPMonitorResponse, headers)

    def create_tcp_monitor(
        self,
        request: CreateTCPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> CreateTCPMonitorResponse:
        return self._t.call(_FQN, "CreateTCPMonitor", request, CreateTCPMonitorResponse, headers)

    def create_dns_monitor(
        self,
        request: CreateDNSMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> CreateDNSMonitorResponse:
        return self._t.call(_FQN, "CreateDNSMonitor", request, CreateDNSMonitorResponse, headers)

    def update_http_monitor(
        self,
        request: UpdateHTTPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> UpdateHTTPMonitorResponse:
        return self._t.call(_FQN, "UpdateHTTPMonitor", request, UpdateHTTPMonitorResponse, headers)

    def update_tcp_monitor(
        self,
        request: UpdateTCPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> UpdateTCPMonitorResponse:
        return self._t.call(_FQN, "UpdateTCPMonitor", request, UpdateTCPMonitorResponse, headers)

    def update_dns_monitor(
        self,
        request: UpdateDNSMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> UpdateDNSMonitorResponse:
        return self._t.call(_FQN, "UpdateDNSMonitor", request, UpdateDNSMonitorResponse, headers)

    def trigger_monitor(
        self,
        request: TriggerMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> TriggerMonitorResponse:
        return self._t.call(_FQN, "TriggerMonitor", request, TriggerMonitorResponse, headers)

    def delete_monitor(
        self,
        request: DeleteMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> DeleteMonitorResponse:
        return self._t.call(_FQN, "DeleteMonitor", request, DeleteMonitorResponse, headers)

    def list_monitors(
        self,
        request: ListMonitorsRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> ListMonitorsResponse:
        return self._t.call(_FQN, "ListMonitors", request, ListMonitorsResponse, headers)

    def get_monitor_status(
        self,
        request: GetMonitorStatusRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorStatusResponse:
        return self._t.call(_FQN, "GetMonitorStatus", request, GetMonitorStatusResponse, headers)

    def get_monitor_summary(
        self,
        request: GetMonitorSummaryRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorSummaryResponse:
        return self._t.call(_FQN, "GetMonitorSummary", request, GetMonitorSummaryResponse, headers)

    def get_monitor(
        self,
        request: GetMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorResponse:
        return self._t.call(_FQN, "GetMonitor", request, GetMonitorResponse, headers)

    def list_monitor_http_response_logs(
        self,
        request: ListMonitorHTTPResponseLogsRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> ListMonitorHTTPResponseLogsResponse:
        return self._t.call(
            _FQN,
            "ListMonitorHTTPResponseLogs",
            request,
            ListMonitorHTTPResponseLogsResponse,
            headers,
        )

    def get_monitor_http_response_log(
        self,
        request: GetMonitorHTTPResponseLogRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorHTTPResponseLogResponse:
        return self._t.call(
            _FQN, "GetMonitorHTTPResponseLog", request, GetMonitorHTTPResponseLogResponse, headers
        )


class AsyncMonitorServiceClient:
    def __init__(self, transport: _AsyncJsonTransport) -> None:
        self._t = transport

    async def create_http_monitor(
        self,
        request: CreateHTTPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> CreateHTTPMonitorResponse:
        return await self._t.call(
            _FQN, "CreateHTTPMonitor", request, CreateHTTPMonitorResponse, headers
        )

    async def create_tcp_monitor(
        self,
        request: CreateTCPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> CreateTCPMonitorResponse:
        return await self._t.call(
            _FQN, "CreateTCPMonitor", request, CreateTCPMonitorResponse, headers
        )

    async def create_dns_monitor(
        self,
        request: CreateDNSMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> CreateDNSMonitorResponse:
        return await self._t.call(
            _FQN, "CreateDNSMonitor", request, CreateDNSMonitorResponse, headers
        )

    async def update_http_monitor(
        self,
        request: UpdateHTTPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> UpdateHTTPMonitorResponse:
        return await self._t.call(
            _FQN, "UpdateHTTPMonitor", request, UpdateHTTPMonitorResponse, headers
        )

    async def update_tcp_monitor(
        self,
        request: UpdateTCPMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> UpdateTCPMonitorResponse:
        return await self._t.call(
            _FQN, "UpdateTCPMonitor", request, UpdateTCPMonitorResponse, headers
        )

    async def update_dns_monitor(
        self,
        request: UpdateDNSMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> UpdateDNSMonitorResponse:
        return await self._t.call(
            _FQN, "UpdateDNSMonitor", request, UpdateDNSMonitorResponse, headers
        )

    async def trigger_monitor(
        self,
        request: TriggerMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> TriggerMonitorResponse:
        return await self._t.call(_FQN, "TriggerMonitor", request, TriggerMonitorResponse, headers)

    async def delete_monitor(
        self,
        request: DeleteMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> DeleteMonitorResponse:
        return await self._t.call(_FQN, "DeleteMonitor", request, DeleteMonitorResponse, headers)

    async def list_monitors(
        self,
        request: ListMonitorsRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> ListMonitorsResponse:
        return await self._t.call(_FQN, "ListMonitors", request, ListMonitorsResponse, headers)

    async def get_monitor_status(
        self,
        request: GetMonitorStatusRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorStatusResponse:
        return await self._t.call(
            _FQN, "GetMonitorStatus", request, GetMonitorStatusResponse, headers
        )

    async def get_monitor_summary(
        self,
        request: GetMonitorSummaryRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorSummaryResponse:
        return await self._t.call(
            _FQN, "GetMonitorSummary", request, GetMonitorSummaryResponse, headers
        )

    async def get_monitor(
        self,
        request: GetMonitorRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorResponse:
        return await self._t.call(_FQN, "GetMonitor", request, GetMonitorResponse, headers)

    async def list_monitor_http_response_logs(
        self,
        request: ListMonitorHTTPResponseLogsRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> ListMonitorHTTPResponseLogsResponse:
        return await self._t.call(
            _FQN,
            "ListMonitorHTTPResponseLogs",
            request,
            ListMonitorHTTPResponseLogsResponse,
            headers,
        )

    async def get_monitor_http_response_log(
        self,
        request: GetMonitorHTTPResponseLogRequest,
        *,
        headers: dict[str, str] | None = None,
    ) -> GetMonitorHTTPResponseLogResponse:
        return await self._t.call(
            _FQN, "GetMonitorHTTPResponseLog", request, GetMonitorHTTPResponseLogResponse, headers
        )