Distilleries\Contentful\Commands\Sync\SyncFlatten

Complexity

Total Complexity

10

Size/Duplication

Total Lines	144
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	10

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	handle()	0	27	3
A	flattenSyncedData()	0	21	3
A	createProgressBar()	0	8	1
A	mapItemToContentfulModel()	0	10	2

<?php

namespace Distilleries\Contentful\Commands\Sync;

use stdClass;
use Exception;
use Illuminate\Console\Command;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;
use Distilleries\Contentful\Models\Locale;
use Symfony\Component\Console\Helper\ProgressBar;
use Distilleries\Contentful\Repositories\AssetsRepository;
use Distilleries\Contentful\Repositories\EntriesRepository;

class SyncFlatten extends Command
{
    use Traits\SyncTrait;

    /**
     * Number of entries to fetch per pagination.
     *
     * @var integer
     */
    const PER_BATCH = 50;

    /**
     * {@inheritdoc}
     */
    protected $signature = 'contentful:sync-flatten {--preview}';

    /**
     * {@inheritdoc}
     */
    protected $description = 'Map and persist previously synced Contentful data';

    /**
     * Assets repository instance.
     *
     * @var \Distilleries\Contentful\Repositories\AssetsRepository
     */
    protected $assets;

    /**
     * Entries repository instance.
     *
     * @var \Distilleries\Contentful\Repositories\EntriesRepository
     */
    protected $entries;

    /**
     * MapEntries command constructor.
     *
     * @return void

Adding a @return annotation to constructors is generally not recommended as a constructor does not have a meaningful return value.

     */
    public function __construct()
    {
        parent::__construct();

        $this->assets = new AssetsRepository;

        $this->entries = new EntriesRepository;
    }

    /**
     * Execute the console command.
     *
     * @return void
     */
    public function handle()
    {
        $isPreview = $this->option('preview');
        if ($isPreview) {
            use_contentful_preview();
        }

        $dumpPath = $this->dumpSync($isPreview);

$isPreview is of type string|array, but the function expects a boolean.

        $this->putSync($dumpPath, $isPreview,'mysql_sync');

$isPreview is of type string|array, but the function expects a boolean.

        $this->switchToSyncDb();
        $this->line('Truncate Contentful related tables');
        $this->assets->truncateRelatedTables();
        $this->entries->truncateRelatedTables();
        $this->line('Map and persist synced data');

        try {
            $this->flattenSyncedData();
        } catch (Exception $e) {
            echo PHP_EOL;
            $this->error($e->getMessage());
            return;
        }

        $dumpPath = $this->dumpSync($isPreview,'mysql_sync');

$isPreview is of type string|array, but the function expects a boolean.

        $this->putSync($dumpPath, $isPreview);

$isPreview is of type string|array, but the function expects a boolean.

    }

    /**
     * Map and persist synced data.
     *
     * @return void
     * @throws \Exception
     */
    private function flattenSyncedData()
    {
        $page = 1;
        $paginator = DB::table('sync_entries')->paginate(static::PER_BATCH, ['*'], 'page', $page);
        $locales = Locale::all();

        $bar = $this->createProgressBar($paginator->total());
        while ($paginator->isNotEmpty()) {
            foreach ($paginator->items() as $item) {
                $bar->setMessage('Map entry ID: ' . $item->contentful_id);
                $this->mapItemToContentfulModel($item,$locales);

It seems like $locales defined by \Distilleries\Contentful\Models\Locale::all() on line 107 can also be of type array<integer,object<Illuminate\Database\Eloquent\Builder>>; however, Distilleries\Contentful\Commands\Sync\SyncFlatten::mapItemToContentfulModel() does only seem to accept object<Illuminate\Support\Collection>, maybe add an additional type check?

                $bar->advance();
            }

            $page++;
            $paginator = DB::table('sync_entries')->paginate(static::PER_BATCH, ['*'], 'page', $page);
        }
        $bar->finish();

        echo PHP_EOL;
    }

    /**
     * Create custom progress bar.
     *
     * @param  integer  $total
     * @return \Symfony\Component\Console\Helper\ProgressBar
     */
    private function createProgressBar(int $total): ProgressBar
    {
        $bar = $this->output->createProgressBar($total);

        $bar->setFormat("%message%" . PHP_EOL . " %current%/%max% [%bar%] %percent:3s%%");

        return $bar;
    }

    /**
     * Map and persist given sync_entries item.
     *
     * @param  \stdClass  $item
     * @param \Illuminate\Support\Collection $locales
     * @return void
     * @throws \Exception
     */
    private function mapItemToContentfulModel(stdClass $item, Collection $locales)
    {
        $entry = json_decode($item->payload, true);

        if ($item->contentful_type === 'asset') {
            $this->assets->toContentfulModel($entry,$locales);
        } else {
            $this->entries->toContentfulModel($entry,$locales);
        }
    }
}