App\Console\Commands\TenantMigrate

Complexity

Total Complexity

10

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	prepareDatabase()	0	6	2
A	handle()	0	27	6
A	migrate()	0	4	1

<?php

namespace App\Console\Commands;

use App\Models\Tenant;
use App\Services\TenantManager;
use Illuminate\Console\Command;
use Symfony\Component\Console\Exception\RuntimeException;

class TenantMigrate extends Command
{
    protected $signature = 'tenant:migrate {tenantId?}';

    protected $description = 'Run tenant migrations for provided tenant or for all registered tenants';

    protected $tenantManager;

    protected $migrator;

    public function __construct(TenantManager $tenantManager)
    {
        parent::__construct();

        $this->tenantManager = $tenantManager;
        $this->migrator = app('migrator');
    }

    public function handle()
    {
        $tenantId = $this->argument('tenantId');

        if ($tenantId) {
            $tenant = Tenant::find($tenantId);
            if (!$tenant) {
                throw new RuntimeException('Tenant with ID = '.$tenantId.' does not exist.');

Are you sure $tenantId of type array|string can be used in concatenation?

            }

            $this->tenantManager->setTenant($tenant);
            \DB::purge('tenant');
            $this->migrate();

            return;
        }

        if (!$tenantId && $this->confirm('Do you wish to run migration for ALL tenants?')) {
            $tenants = Tenant::all();

            foreach ($tenants as $tenant) {
                $this->tenantManager->setTenant($tenant);
                \DB::purge('tenant');
                $this->migrate();
            }

            return;
        }
    }

    private function migrate()
    {
        $this->prepareDatabase();
        $this->migrator->run(database_path('migrations/tenants'), []);
    }

    protected function prepareDatabase()
    {
        $this->migrator->setConnection('tenant');

        if (!$this->migrator->repositoryExists()) {
            $this->call('migrate:install');
        }
    }
}