Distilleries\Contentful\Commands\Sync\SyncData

Complexity

Total Complexity

14

Size/Duplication

Total Lines	139
Duplicated Lines	17.27 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	handle()	0	16	2
A	setNewRelease()	0	7	1
A	syncAssets()	12	12	3
A	saveAssets()	0	12	2
A	syncEntries()	12	12	3
A	saveEntries()	0	12	2

<?php

namespace Distilleries\Contentful\Commands\Sync;

use Distilleries\Contentful\Models\Release;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;
use Distilleries\Contentful\Api\SyncApi;
use GuzzleHttp\Exception\GuzzleException;

class SyncData extends Command
{
    use Traits\SyncTrait;

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

    /**
     * {@inheritdoc}
     */
    protected $description = 'Synchronize Contentful entries and assets';

    /**
     * Contentful Sync API implementation.
     *
     * @var \Distilleries\Contentful\Api\SyncApi
     */
    protected $api;

    /**
     * SyncData command constructor.
     *
     * @param  \Distilleries\Contentful\Api\SyncApi  $api
     * @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(SyncApi $api)
    {
        parent::__construct();

        $this->api = $api;
    }

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

        $this->setNewRelease($release);
        $this->line('Clean previous synced data');
        DB::table('sync_entries')->truncate();

        $this->line('Syncing assets...');
        $this->syncAssets();

        $this->line('Syncing entries...');
        $this->syncEntries();
    }


    protected function setNewRelease(Release $release)
    {
        (new $release)->where('current', true)->update(['current' => false]);

        $release->current = true;
        $release->save();
    }

    /**
     * Synchronize assets via Sync API and store into DB for further use.
     *
     * @return void
     */
    protected function syncAssets()

This method seems to be duplicated in your project.

    {
        try {
            $assets = $this->api->syncInitial('Asset');
            while (! empty($assets)) {
                $this->saveAssets($assets);
                $assets = $this->api->syncNext();
            }
        } catch (GuzzleException $e) {
            $this->error($e->getMessage());
        }
    }

    /**
     * Save given Contentful assets.
     *
     * @param  array  $assets
     * @return void
     */
    protected function saveAssets(array $assets)
    {
        DB::transaction(function () use ($assets) {
            foreach ($assets as $asset) {
                DB::table('sync_entries')->insert([
                    'contentful_id' => $asset['sys']['id'],
                    'contentful_type' => 'asset',
                    'payload' => json_encode($asset),
                ]);
            }
        });
    }

    /**
     * Synchronize entries via Sync API and store into DB for further use.
     *
     * @return void
     */
    protected function syncEntries()

This method seems to be duplicated in your project.

    {
        try {
            $entries = $this->api->syncInitial('Entry');
            while (! empty($entries)) {
                $this->saveEntries($entries);
                $entries = $this->api->syncNext();
            }
        } catch (GuzzleException $e) {
            $this->error($e->getMessage());
        }
    }

    /**
     * Save given Contentful entries.
     *
     * @param  array  $entries
     * @return void
     */
    protected function saveEntries(array $entries)
    {
        DB::transaction(function () use ($entries) {
            foreach ($entries as $entry) {
                DB::table('sync_entries')->insert([
                    'contentful_id' => $entry['sys']['id'],
                    'contentful_type' => $entry['sys']['contentType']['sys']['id'],
                    'payload' => json_encode($entry),
                ]);
            }
        });
    }
}