Tubee\Rest\Helper::watchAll()

Complexity

Conditions	5
Paths	2

Size

Total Lines

46

Duplication

Lines	15
Ratio	32.61 %

Code Coverage

Tests	0
CRAP Score	30

Importance

Changes

0

<?php
    public static function watchAll(ServerRequestInterface $request, Identity $identity, Acl $acl, iterable $cursor): ResponseInterface

The parameter $identity is not used and could be removed.

The parameter $acl is not used and could be removed.

    {
        //Watcher is valid for 5min, after a new requests needs to be sent
        ini_set('max_execution_time', '300');

        $query = $request->getQueryParams();
        $options = isset($query['pretty']) ? JSON_PRETTY_PRINT : 0;

        $stream = new StreamIterator($cursor, function ($event) use ($request, $options) {
            if ($this->tell() === 0) {

The method tell() does not seem to exist on object<Tubee\Rest\Helper>.

                echo  '[';
            } else {
                echo  ',';
            }

            echo json_encode([
                $event[0],
                $event[1]->decorate($request),
            ], $options);

            if ($this->eof()) {

The method eof() does not seem to exist on object<Tubee\Rest\Helper>.

                echo ']';
            }

            flush();
        }, function (\Throwable $e) {

The call to StreamIterator::__construct() has too many arguments starting with function (\Throwable $e) { if ($this->tell() === 0) { echo '['; } else { echo ','; } echo json_encode(array('ADDED', array('kind' => 'StreamError', 'error' => $e->getMessage(), 'class' => get_class($e)))) . ']'; flush(); }.

This code seems to be duplicated across your project.

            if ($this->tell() === 0) {

The method tell() does not seem to exist on object<Tubee\Rest\Helper>.

                echo  '[';
            } else {
                echo  ',';
            }

            echo json_encode(['ADDED', [
                'kind' => 'StreamError',
                'error' => $e->getMessage(),
                'class' => get_class($e),
            ]]).']';

            flush();
        });

        return (new Response($stream))
            ->withHeader('X-Accel-Buffering', 'no')
            ->withHeader('Content-Type', 'application/json;stream=watch')
            ->withStatus(StatusCodeInterface::STATUS_OK);
    }
}