Source code for luna_api.app.handlers.events_handler

""" Get events and get events stats handlers. """

from sanic.response import HTTPResponse

from app.handlers.base_handler import EventServiceBaseHandler
from app.handlers.schemas import schemas


class EventHandler(EventServiceBaseHandler):
    """
    Get event. See `spec_event`_.

        .. _spec_event:
            _static/api.html#tag/events

    Resource: "/{api_version}/events"
    """

    allowedMethods = ("GET", "HEAD")


class EventsHandler(EventServiceBaseHandler):
    """
    Get events. See `spec_events`_.

        .. _spec_events:
            _static/api.html#tag/events

    Resource: "/{api_version}/events"
    """

    allowedMethods = ("GET",)

    async def get(self) -> HTTPResponse:
        """
        Proxy request with GET method to luna-events. See `spec_get_events`_.

        .. _spec_get_events:
            _static/api.html#operation/getEvents

        Returns:
            response from luna-events service
        """
        return await self.makeRequestToService()


class EventsStatsHandler(EventServiceBaseHandler):
    """
    Get events stats.

    Resource: "/{api_version}/events/stats"
    """

    allowedMethods = ("POST",)

    async def post(self) -> HTTPResponse:
        """
        Send request with POST method to luna-events. See `spec_event_stats`_.

        .. _spec_event_stats:
            _static/api.html#operation/getEventStats

        Returns:
            response from luna-events service
        """
        query = self.request.json
        self.validateJson(query, schemas.EVENT_STATISTICS_SCHEMA, useJsonSchema=False)
        if self.accountId:
            accountIdFilter = {
                "column": "account_id",
                "operator": "eq",
                "value": self.accountId,
            }
            query.setdefault("filters", [])
            query["filters"].append(accountIdFilter)
        eventStats = await self.luna3Client.lunaEvents.getEventsStats(query=query, raiseError=True)
        return self.success(200, outputJson=eventStats.json)