Tubee\DataObject

Complexity

Total Complexity

20

Size/Duplication

Total Lines	157
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	decorate()	0	31	7
A	getHistory()	0	4	1
A	toArray()	0	8	1
A	getCollection()	0	4	1
A	getEndpoints()	0	8	2
A	createOrUpdateRelation()	0	4	1
A	deleteRelation()	0	4	1
A	getResolvedRelationsAsArray()	0	13	3
A	getRelations()	0	4	1
A	getRelation()	0	4	1

<?php

declare(strict_types=1);

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

namespace Tubee;

use Generator;
use MongoDB\BSON\ObjectIdInterface;
use Psr\Http\Message\ServerRequestInterface;
use Tubee\Collection\CollectionInterface;
use Tubee\DataObject\DataObjectInterface;
use Tubee\DataObjectRelation\Factory as DataObjectRelationFactory;
use Tubee\Resource\AbstractResource;
use Tubee\Resource\AttributeResolver;

class DataObject extends AbstractResource implements DataObjectInterface
{
    /**
     * Datatype.
     *
     * @var CollectionInterface
     */
    protected $collection;

    /**
     * Data object relation factory.
     *
     * @var DataObjectRelationFactory
     */
    protected $relation_factory;

    /**
     * Relations.
     *
     * @var null|array
     */
    protected $relations;

    /**
     * Data object.
     */
    public function __construct(array $resource, CollectionInterface $collection, DataObjectRelationFactory $relation_factory)
    {
        $this->resource = $resource;
        $this->collection = $collection;
        $this->relation_factory = $relation_factory;
    }

    /**
     * {@inheritdoc}
     */
    public function decorate(ServerRequestInterface $request): array
    {
        $collection = $this->collection->getName();
        $namespace = $this->collection->getResourceNamespace()->getName();

        $resource = [
            '_links' => [
                'namespace' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace)],
                'collection' => ['href' => (string) $request->getUri()->withPath('/api/v1/namespaces/'.$namespace.'/collections/'.$collection)],
            ],
            'kind' => 'DataObject',
            'namespace' => $namespace,
            'collection' => $collection,
            'data' => $this->getData(),
            'status' => function ($object) {
                $endpoints = $object->getEndpoints();
                foreach ($endpoints as &$endpoint) {
                    $endpoint['last_sync'] = $endpoint['last_sync']->toDateTime()->format('c');
                    $endpoint['last_successful_sync'] = isset($endpoint['last_successful_sync']) ? $endpoint['last_successful_sync']->toDateTime()->format('c') : null;
                    $endpoint['success'] = isset($endpoint['success']) ? $endpoint['success'] : null;
                    $endpoint['garbage'] = isset($endpoint['garbage']) ? $endpoint['garbage'] : false;
                    $endpoint['result'] = isset($endpoint['result']) ? $endpoint['result'] : null;
                    $endpoint['exception'] = isset($endpoint['exception']) ? $endpoint['exception'] : null;
                }

                return ['endpoints' => $endpoints];
            },
        ];

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

    /**
     * {@inheritdoc}
     */
    public function getHistory(?array $query = null, ?int $offset = null, ?int $limit = null): iterable
    {
        return $this->collection->getObjectHistory($this->getId(), $query, $offset, $limit);

The method getObjectHistory() does not exist on Tubee\Collection\CollectionInterface. Did you maybe mean getObject()?

    }

    /**
     * {@inheritdoc}
     */
    public function toArray(): array
    {
        $resource = $this->resource;
        $resource['namespace'] = $this->collection->getResourceNamespace()->getName();
        $resource['collection'] = $this->collection->getName();

        return $resource;
    }

    /**
     * {@inheritdoc}
     */
    public function getCollection(): CollectionInterface
    {
        return $this->collection;
    }

    /**
     * Get endpoints.
     */
    public function getEndpoints(): array
    {
        if (!isset($this->resource['endpoints'])) {
            return [];
        }

        return $this->resource['endpoints'];
    }

    /**
     * Add or update relation.
     */
    public function createOrUpdateRelation(DataObjectInterface $object, array $context = [], bool $simulate = false, ?array $endpoints = null): ObjectIdInterface
    {
        return $this->relation_factory->createOrUpdate($this, $object, $context, $simulate, $endpoints);
    }

    /**
     * Delete relation.
     */
    public function deleteRelation(DataObjectInterface $object, bool $simulate = false): bool
    {
        return $this->relation_factory->deleteFromObject($this, $object, $simulate);
    }

    /**
     * Get relations as array (and cache).
     */
    public function getResolvedRelationsAsArray(): array
    {
        if ($this->relations === null) {
            $this->relations = [];
            foreach ($this->getRelations() as $relation) {
                $resource = $relation->toArray();
                $resource['object'] = $relation->getDataObject()->toArray();
                $this->relations[] = $resource;
            }
        }

        return $this->relations;
    }

    /**
     * Get relatives.
     */
    public function getRelations(): Generator
    {
        return $this->relation_factory->getAllFromObject($this);
    }

    /**
     * Get relative.
     */
    public function getRelation(string $name): Generator
    {
        return $this->relation_factory->getOneFromObject($this, $name);
    }
}