Hhxsv5\LaravelS\Components\Apollo\Process

Complexity

Total Complexity

5

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

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

<?php

namespace Hhxsv5\LaravelS\Components\Apollo;

use Hhxsv5\LaravelS\Swoole\Coroutine\Context;
use Hhxsv5\LaravelS\Swoole\Process\CustomProcessInterface;
use Swoole\Coroutine;
use Swoole\Http\Server;
use Swoole\Process as SwooleProcess;

class Process implements CustomProcessInterface
{
    /**@var Client $apollo */
    protected static $apollo;

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

    public static function callback(Server $swoole, SwooleProcess $process)
    {
        $filename = base_path('.env');
        $env = getenv('LARAVELS_ENV');
        if ($env) {
            $filename .= '.' . $env;
        }

        self::$apollo = Client::createFromEnv();
        self::$apollo->startWatchNotification(function (array $notifications) use ($process, $filename) {

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

            $configs = self::$apollo->pullAllAndSave($filename);
            app('log')->info('[ApolloProcess] Pull all configurations', $configs);
            $process->exec(PHP_BINARY, [base_path('bin/laravels'), 'reload']);
            if (Context::inCoroutine()) {
                Coroutine::sleep(5);
            } else {
                sleep(5);
            }
        });
    }

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