Carno\Consul\Chips\SDeregister::deregister()

Complexity

Conditions	5
Paths	1

Size

Total Lines	37
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function deregister() : Promised
    {
        return async(function (Service $service) {
            for (;;) {
                if (!$service->connected()) {
                    logger('consul')->info('Service has not been registered .. skip', ['svc' => $service->id()]);
                    return;
                }

                /**
                 * @var Result $result
                 */

                try {
                    $result = yield (new AgentServiceDeregister($service->hosting()))->service($service)->result();
                } catch (Throwable $e) {
                    logger('consul')->warning('Service deregistering error', [
                        'svc' => $service->id(),
                        'error' => sprintf('%s::%s', get_class($e), $e->getMessage()),
                    ]);
                    goto RETRYING;
                }

                if ($result->success()) {
                    return;
                }

                RETRYING:

                yield msleep($sleep = rand(Defaults::ERROR_RETRY_MIN, Defaults::ERROR_RETRY_MAX));

                logger('consul')->notice('Service deregister retrying', [
                    'svc' => $service->id(),
                    'delay' => $sleep,
                ]);
            }
        }, null, $this);
    }