RayRutjes\GetEventStore\Client\Http\ReadEventStreamFeedResponseInspector::inspect()

Complexity

Conditions	6
Paths	11

Size

Total Lines	35
Code Lines	22

Duplication

Lines	0
Ratio	0 %

<?php
    public function inspect(ResponseInterface $response)
    {
        $this->filterCommonErrors($response);
        switch ($response->getStatusCode()) {
            case 200:
                // OK.
                break;
            default:
                // KO.
                throw $this->newBadRequestException($response);
        }
        $data = $this->decodeResponseBody($response);

        // Todo: Handle parsing exceptions and throw corresponding errors.
        $links = [];
        foreach ($data['links'] as $link) {
            $links[] = new EventStreamFeedLink($link['uri'], $link['relation']);
        }

        $events = [];
        foreach ($data['entries'] as $entry) {
            $streamId = $entry['streamId'];

            $number = $entry['eventNumber'];
            $type = $entry['eventType'];
            $eventData = isset($entry['data']) ? $this->decodeData($entry['data']) : [];
            $eventMetadata = isset($entry['metaData']) ? $this->decodeData($entry['metaData']) : [];

            $events[] = new EventRecord($streamId, $number, $type, $eventData, $eventMetadata);
        }

        $isHeadOfStream = $data['headOfStream'];
        $eTag = $data['eTag'] ?? null;
        $this->feed = new EventStreamFeed($events, $links, $isHeadOfStream, $eTag);
    }