PragmaRX\Health\Checkers\Broadcasting

Complexity

Total Complexity

11

Size/Duplication

Total Lines	130
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

61.7%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	bootRouter()	0	6	1
A	check()	0	14	1
A	dispatchEvent()	0	10	1
A	createPing()	0	6	1
A	createPingRow()	0	8	1
A	parseDate()	0	4	1
A	pong()	0	12	2
A	pingTimedout()	0	26	3

<?php

namespace PragmaRX\Health\Checkers;

use Carbon\Carbon;
use PragmaRX\Health\Support\Result;
use PragmaRX\Health\Events\HealthPing;
use PragmaRX\Health\Support\Traits\Routing;
use PragmaRX\Health\Support\Traits\Database;

This use statement conflicts with another class in this namespace, PragmaRX\Health\Checkers\Database.

class Broadcasting extends Base
{
    use Routing, Database;

    protected function bootRouter()
    {
        $this->target->routes->each(function ($route, $name) {

The property routes does not seem to exist in PragmaRX\Health\Support\Target.

            $this->registerRoute($route, $name);
        });
    }

    /**
     * Check resource.
     *
     * @return Result
     */
    public function check()
    {
        $this->loadDatabase();

        $this->bootRouter();

        $isHealthy = ! $this->pingTimedout();

        $this->createPing();

        $this->dispatchEvent();

        return $this->makeResult($isHealthy, $this->target->getErrorMessage());
    }

    /**
     * Dispatch event.
     */
    protected function dispatchEvent()
    {
        event(
            new HealthPing(
                $this->target->channel,

The property channel does not seem to exist in PragmaRX\Health\Support\Target.

                route($this->target->routeName, [$this->target->secret]),

The property routeName does not seem to exist in PragmaRX\Health\Support\Target.

The property secret does not seem to exist in PragmaRX\Health\Support\Target.

                $this->target
            )
        );
    }

    /**
     * Create and persist ping.
     */
    protected function createPing()
    {
        $this->database->push($this->createPingRow());

        $this->persist();
    }

    /**
     * Create ping row array.
     *
     * @return array
     */
    protected function createPingRow()
    {
        return [
            'pinged_at' => Carbon::now(),
            'ponged_at' => null,
            'secret' => $this->target->secret,

The property secret does not seem to exist in PragmaRX\Health\Support\Target.

        ];
    }

    /**
     * Parse date.
     *
     * @param $date
     * @return Carbon
     */
    protected function parseDate($date)
    {
        return Carbon::parse($date['date'], $date['timezone']);
    }

    /**
     * Create and persist pong.
     *
     * @param $secret
     */
    public function pong($secret)
    {
        $this->database = $this->database->map(function ($item) use ($secret) {
            if ($item['secret'] == $secret) {
                $item['ponged_at'] = Carbon::now();
            }

            return $item;
        });

        $this->persist();
    }

    /**
     * Check if a ping timed out.
     *
     * @return bool
     */
    protected function pingTimedout()
    {
        $timedout = false;

        $this->database = $this->database->filter(function ($item) use (
            &$timedout
        ) {
            if (! $item['ponged_at']) {
                if (
                    Carbon::now()->diffInSeconds(
                        $this->parseDate($item['pinged_at'])
                    ) > $this->target->timeout

The property timeout does not seem to exist in PragmaRX\Health\Support\Target.

                ) {
                    $timedout = true;

                    return false;
                }

                return true;
            }

            return false;
        });

        return $timedout;
    }
}