OhDear\ForgeSync\SyncSitesCommand

Complexity

Total Complexity

11

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	25	3
A	askOhDearTeamId()	0	11	1
A	syncSites()	0	32	5
A	teamChoices()	0	10	1
A	siteChoices()	0	6	1

<?php

namespace OhDear\ForgeSync;

use Exception;
use OhDear\PhpSdk\OhDear;
use Illuminate\Console\Command;

class SyncSitesCommand extends Command
{
    /** @var \OhDear\ForgeSync\ForgeSync */
    protected $sync;

    /** @var \Illuminate\Support\Collection */
    protected $availableTeams;

    /** @var \Illuminate\Support\Collection */
    protected $syncableSites;

    protected $signature = 'ohdear:forge-sync {--ohDearKey=} {--forgeKey=} {--dry-run}';

    protected $description = 'Import existing Laravel Forge sites to Oh Dear!';

    public function handle()
    {
        $ohDearTeamId = $this->askOhDearTeamId();

        $this->info('Scanning your Forge sites... (this could need a little bit of time).');

        $this->sync = new ForgeSync($ohDearTeamId, $this->option('ohDearKey'), $this->option('forgeKey'));

        $this->syncableSites = $this->sync->sites();

        if ($this->syncableSites->count() === 0) {
            $this->warn("You don't have any sites that can be imported!");

            return;
        }
        if ($this->option('dry-run')) {
            $this->warn('Running in dry-mode: we will not make any changes to your Oh Dear! account.');
        }

        $choice = $this->choice('Which Forge sites should be imported into Oh Dear?', $this->siteChoices());

        $this->syncSites($choice);

        $this->info('All done');
    }

    protected function askOhDearTeamId(): int
    {
        $choice = $this->choice(
            'Please select the Oh Dear! team into which you would like to import these sites.',
            $this->teamChoices()
        );

        return $this->availableTeams->filter(function ($team) use ($choice) {
            return "<comment>{$team['name']}</comment>" === $choice;
        })->first()['id'];
    }

    protected function syncSites(string $siteChoice)
    {
        if (str_is('<comment>All Sites</comment>', $siteChoice)) {
            $this->info('Importing all sites...');

            $this->syncableSites
                ->filter(function (Site $site) use ($siteChoice) {
                    if ($siteChoice === '<comment>All Sites</comment>') {
                        return true;
                    }

                    $url = str_replace(['<comment>', '</comment>'], '', $siteChoice);

                    return $site->url() === $url;
                })
                ->each(function (Site $site) {
                    if ($this->option('dry-run')) {
                        $this->comment("Would have added site `{$site->url()}` if not running in dry-mode.");

                        return;
                    }

                    try {
                        $this->sync->addToOhDear($site);

                        $this->comment("Added site `{$site->url()}`");
                    } catch (Exception $exception) {
                        $this->error("Could not add site `{$site->url()}` because {$exception->getMessage()}");
                    }
                });
        }
    }

    protected function teamChoices(): array
    {
        $ohDear = new OhDear($this->option('ohDearKey') ?? config('forge-sync.ohdear_api_token'));

        $this->availableTeams = collect($ohDear->me()->teams['data']->attributes);

        return $this->availableTeams->map(function ($team) {
            return "<comment>{$team['name']}</comment>";
        })->toArray();
    }

    protected function siteChoices(): array
    {
        return $this->syncableSites->map(function (Site $site) {
            return "<comment>{$site->url()}</comment>";
        })->merge(['<comment>All Sites</comment>'])->toArray();
    }
}