Spatie\ServerMonitor\CheckCollection

Complexity

Total Complexity

9

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	runAll()	0	10	4
A	startNextCheck()	0	14	2
A	handleFinishedChecks()	0	8	1
A	count()	0	4	1

<?php

namespace Spatie\ServerMonitor;

use Countable;
use Illuminate\Support\Collection;
use Spatie\ServerMonitor\Helpers\ConsoleOutput;
use Spatie\ServerMonitor\Models\Check;

class CheckCollection implements Countable
{
    /** @var \Illuminate\Support\Collection */
    protected $pendingChecks;

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

    public function __construct(Collection $checks)
    {
        $this->pendingChecks = $checks;

        $this->runningChecks = collect();
    }

    public function runAll()
    {
        while ($this->pendingChecks->isNotEmpty() || $this->runningChecks->isNotEmpty()) {
            if ($this->runningChecks->count() < config('server-monitor.concurrent_ssh_connections')) {
                $this->startNextCheck();
            }

            $this->handleFinishedChecks();
        }
    }

    protected function startNextCheck()
    {
        if ($this->pendingChecks->isEmpty()) {
            return;
        }

        $check = $this->pendingChecks->shift();

        ConsoleOutput::comment($check->host->name.": performing check `{$check->type}`...");

        $check->getProcess()->start();

        $this->runningChecks->push($check);
    }

    protected function handleFinishedChecks()
    {
        [$this->runningChecks, $finishedChecks] = $this->runningChecks->partition(function (Check $check) {

The variable $finishedChecks does not exist. Did you forget to declare it?

            return $check->getProcess()->isRunning();
        });

        $finishedChecks->each->handleFinishedProcess();
    }

    /**
     * @return int
     */
    public function count()
    {
        return count($this->pendingChecks);
    }
}