Digia\Lumen\ContentfulSync\Console\Commands\AbstractSyncCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	0

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
	getQuery()	0	1	?
A	getTotalQuery()	0	7	1
A	__construct()	0	11	1
A	handle()	0	8	1
A	getClient()	0	4	1
A	resetCounters()	0	5	1

<?php

namespace Digia\Lumen\ContentfulSync\Console\Commands;

use Contentful\Delivery\Client\ClientInterface;
use Contentful\Delivery\Query;
use Digia\Lumen\ContentfulSync\Contracts\ContentfulSyncServiceContract;
use Illuminate\Console\Command;
use Jalle19\Laravel\LostInterfaces\Console\Command as CommandInterface;
use Nord\Lumen\Contentful\ContentfulServiceContract;

/**
 * Class AbstractSyncCommand
 * @package Digia\Lumen\ContentfulSync\Console\Commands
 */
abstract class AbstractSyncCommand extends Command implements CommandInterface
{

    /**
     * @var boolean
     */
    protected $ignoreExisting;

    /**
     * @var ContentfulServiceContract
     */
    protected $contentfulService;

    /**
     * @var ContentfulSyncServiceContract
     */
    protected $contentfulSyncService;

    /**
     * @var array
     */
    protected $contentTypes;

    /**
     * @var int
     */
    protected $numSynchronized;

    /**
     * @var int
     */
    protected $skip;

    /**
     * @var int
     */
    protected $batchSize;

    /**
     * @param null|string $contentType the content type, or null if not applicable
     *
     * @return Query the query used to fetch all entries/assets
     */
    abstract protected function getQuery(?string $contentType = null): Query;

    /**
     * @param null|string $contentType the content type, or null if not applicable
     *
     * @return Query the query used to get the total number of items
     */
    protected function getTotalQuery(?string $contentType = null): Query
    {
        $query = clone $this->getQuery($contentType);

        return $query->setSkip(0)
                     ->setLimit(1);
    }

    /**
     * AbstractSyncCommand constructor.
     *
     * @param array                         $contentTypes
     * @param ContentfulServiceContract     $contentfulService
     * @param ContentfulSyncServiceContract $contentfulSyncService
     */
    public function __construct(
        array $contentTypes,
        ContentfulServiceContract $contentfulService,
        ContentfulSyncServiceContract $contentfulSyncService
    ) {
        parent::__construct();

        $this->contentTypes          = $contentTypes;
        $this->contentfulService     = $contentfulService;
        $this->contentfulSyncService = $contentfulSyncService;
    }

    /**
     * @inheritdoc
     *
     * @throws \Throwable
     */
    public function handle()
    {
        // Parse options and reset counters
        $this->batchSize      = (int)$this->option('batchSize');
        $this->ignoreExisting = (bool)$this->option('ignoreExisting');

        $this->resetCounters();
    }

    /**
     * @return ClientInterface
     */
    protected function getClient(): ClientInterface
    {
        return $this->contentfulService->getClient();
    }

    /**
     * Resets the "skip" and "numSynchronized" counters
     */
    protected function resetCounters(): void
    {
        $this->numSynchronized = 0;
        $this->skip            = 0;
    }
}