Hhxsv5\LaravelS\Swoole\Process\ApolloServiceProcess

Complexity

Total Complexity

3

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	onReload()	0	4	1
A	getDefinition()	0	7	1
A	callback()	0	7	1

<?php

namespace Hhxsv5\LaravelS\Swoole\Process;

use Hhxsv5\LaravelS\Components\Apollo\Apollo;
use Swoole\Coroutine;
use Swoole\Http\Server;
use Swoole\Process;

class ApolloServiceProcess implements CustomProcessInterface
{
    /**@var Apollo $apollo */
    protected static $apollo;

    public static function getDefinition()
    {
        return [
            'apollo-service' => [
                'class'    => self::class,
                'redirect' => false,
                'pipe'     => 0,
            ],
        ];
    }

    public static function callback(Server $swoole, Process $process)
    {
        self::$apollo = Apollo::createFromEnv();
        self::$apollo->startWatchNotification(function (array $notifications) use ($swoole) {

The parameter $notifications is not used and could be removed.

            self::$apollo->pullAllAndSave(base_path('.env'), false);
            $swoole->reload();
            Coroutine::sleep(3);
        });
    }

    public static function onReload(Server $swoole, Process $process)
    {
        // Stop the process...
        self::$apollo->stopWatchNotification();
    }
}