Kreta\Notifier\Infrastructure\Symfony\HttpAction\GetDomainEventsAction::__invoke()

Complexity

Conditions	3
Paths	2

Size

Total Lines	26
Code Lines	17

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function __invoke(Request $request) : JsonResponse
    {
        $page = $request->query->getInt('page', 1);
        $since = $request->query->get('since');

        $this->queryBus->handle(
            new GetDomainEventsQuery(
                $page,
                self::PAGE_SIZE,
                $since
            ),
            $events
        );

        $numberOfEvents = count($events['data']);
        $isPageCompleted = $numberOfEvents === self::PAGE_SIZE;
        $response = new JsonResponse($events, 0 !== $numberOfEvents ? 200 : 404);

        if ($isPageCompleted) {
            $response
                ->setMaxAge(self::CACHE_LIFETIME)
                ->setSharedMaxAge(self::CACHE_LIFETIME);
        }

        return $response;
    }
}