POData\SimpleDataService

Complexity

Total Complexity

11

Size/Duplication

Total Lines	107
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getStreamProviderX()	0	3	1
A	initializeService()	0	3	1
A	setStreamProvider()	0	3	2
A	getMetadataProvider()	0	3	1
A	initialize()	0	2	1
A	getReadQueryProvider()	0	3	1
A	__construct()	0	21	3
A	initializeDefaultConfig()	0	7	1

<?php

declare(strict_types=1);

namespace POData;

use POData\Common\ODataException;
use POData\Configuration\EntitySetRights;
use POData\Configuration\IServiceConfiguration;
use POData\ObjectModel\IObjectSerialiser;
use POData\OperationContext\ServiceHost;
use POData\Providers\Metadata\IMetadataProvider;
use POData\Providers\Metadata\SimpleMetadataProvider;
use POData\Providers\Query\IReadQueryProvider;
use POData\Providers\Stream\IStreamProvider2;
use POData\Providers\Stream\SimpleStreamProvider;

/**
 * DataService that implements IServiceProvider.
 **/
class SimpleDataService extends BaseService implements IService
{
    /**
     * @var IMetadataProvider
     */
    protected $metaProvider;
    /**
     * @var IReadQueryProvider
     */
    protected $readQueryProvider;

    /**
     * @var IStreamProvider2;
     */
    protected $streamProvider;

    /**
     * SimpleDataService constructor.
     * @param $db
     * @param  SimpleMetadataProvider     $metaProvider
     * @param  ServiceHost                $host
     * @param  IObjectSerialiser|null     $serialiser
     * @param  IStreamProvider2|null      $streamProvider
     * @param  IServiceConfiguration|null $config
     * @throws ODataException
     */
    public function __construct(
        $db,
        SimpleMetadataProvider $metaProvider,
        ServiceHost $host,
        IObjectSerialiser $serialiser = null,
        IStreamProvider2 $streamProvider = null,
        IServiceConfiguration $config = null
    ) {
        $this->metaProvider = $metaProvider;
        if ($db instanceof IReadQueryProvider) {
            $this->readQueryProvider = $db;
        } elseif (!empty($db->queryProviderClassName)) {
            $queryProviderClassName = $db->queryProviderClassName;
            $this->readQueryProvider    = new $queryProviderClassName($db);
        } else {
            throw new ODataException('Invalid query provider supplied', 500);
        }
        $this->setStreamProvider($streamProvider);

        $this->setHost($host);
        parent::__construct($serialiser, $metaProvider, $config);
    }

    /**
     * @param  IStreamProvider2|null $streamProvider
     * @return void
     */
    public function setStreamProvider(IStreamProvider2 $streamProvider = null)
    {
        $this->streamProvider = (null == $streamProvider) ? new SimpleStreamProvider() : $streamProvider;
    }

    /**
     * {@inheritdoc}
     * @throws Common\InvalidOperationException
     */
    public function initializeDefaultConfig(IServiceConfiguration $config)
    {
        $config->setEntitySetPageSize('*', 400);
        $config->setEntitySetAccessRule('*', EntitySetRights::ALL());
        $config->setAcceptCountRequests(true);
        $config->setAcceptProjectionRequests(true);
        return $config;
    }

    public function initialize(IServiceConfiguration $config)
    {
    }

    /**
     * @return IReadQueryProvider
     */
    public function getReadQueryProvider(): ?IReadQueryProvider
    {
        return $this->readQueryProvider;
    }

    /**
     * @return IMetadataProvider
     */
    public function getMetadataProvider()
    {
        return $this->metaProvider;
    }

    /**
     * @return IStreamProvider2
     */
    public function getStreamProviderX()
    {
        return $this->streamProvider;
    }

    /**
     * This method is called only once to initialize service-wide policies.
     *
     * @param IServiceConfiguration $config data service configuration
     */
    public function initializeService(IServiceConfiguration $config)
    {
        $config->setEntitySetAccessRule('*', EntitySetRights::ALL());
    }
}