Tubee\Process

Complexity

Total Complexity

10

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	decorate()	0	28	6
A	getResourceNamespace()	0	4	1
A	getLogs()	0	7	1
A	getLog()	0	4	1

<?php

declare(strict_types=1);

/**
 * tubee.io
 *
 * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Tubee;

use DateTime;
use Generator;
use MongoDB\BSON\ObjectIdInterface;
use Psr\Http\Message\ServerRequestInterface;
use TaskScheduler\JobInterface;
use Tubee\Log\Factory as LogFactory;
use Tubee\Log\LogInterface;
use Tubee\Process\ProcessInterface;
use Tubee\Resource\AbstractResource;
use Tubee\Resource\AttributeResolver;
use Tubee\ResourceNamespace\ResourceNamespaceInterface;

class Process extends AbstractResource implements ProcessInterface
{
    /**
     * Namespace.
     *
     * @var ResourceNamespace
     */
    protected $namespace;

    /**
     * Log factory.
     *
     * @var LogFactory
     */
    protected $log_factory;

    /**
     * Process.
     */
    public function __construct(array $resource, ResourceNamespaceInterface $namespace, LogFactory $log_factory)
    {
        $this->resource = $resource;
        $this->namespace = $namespace;

$namespace is of type object<Tubee\ResourceNamespace\ResourceNamespaceInterface>, but the property $namespace was declared to be of type object<Tubee\ResourceNamespace>. Are you sure that you always receive this specific sub-class here, or does it make sense to add an instanceof check?

        $this->log_factory = $log_factory;
    }

    /**
     * {@inheritdoc}
     */
    public function decorate(ServerRequestInterface $request): array
    {
        $data = $this->getData();
        $parent = isset($data['parent']) ? (string) $data['parent'] : null;
        $job = isset($data['job']) ? $data['job'] : null;
        unset($data['parent'], $data['namespace'], $data['job']);

        $result = [
            '_links' => [
                'namespace' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$this->namespace->getName())],
            ],
            'kind' => 'Process',
            'namespace' => $this->namespace->getName(),
            'changed' => $this->getCreated()->toDateTime()->format('c'),
            'data' => $data,
            'status' => [
                'job' => $job,
                'parent' => $parent,
                'next' => $this->resource['options']['at'] === 0 ? null : (new DateTime('@'.(string) $this->resource['options']['at']))->format('c'),
                'started' => $this->resource['status'] === 0 ? null : $this->resource['started']->toDateTime()->format('c'),
                'ended' => $this->resource['status'] <= 2 ? null : $this->resource['ended']->toDateTime()->format('c'),
                'result' => JobInterface::STATUS_MAP[$this->resource['status']],
                'code' => $this->resource['status'],
            ],
        ];

        return AttributeResolver::resolve($request, $this, $result);
    }

    /**
     * {@inheritdoc}
     */
    public function getResourceNamespace(): ResourceNamespaceInterface
    {
        return $this->namespace;
    }

    /**
     * {@inheritdoc}
     */
    public function getLogs(array $query = [], ?int $offset = null, ?int $limit = null, ?array $sort = []): Generator
    {
        $query['$or'][] = ['context.process' => (string) $this->getId()];
        $query['$or'][] = ['context.parent' => (string) $this->getId()];

        return $this->log_factory->getAll($query, $offset, $limit, $sort);
    }

    /**
     * {@inheritdoc}
     */
    public function getLog(ObjectIdInterface $id): LogInterface
    {
        return $this->log_factory->getOne($id);

The call to getOne() misses a required argument $log.

    }
}