Carno\Traced\Chips\TransportSync::syncing()

Complexity

Conditions	5
Paths	1

Size

Total Lines	36
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

<?php
    private function syncing(
        Config $source,
        string $conf,
        array $schemes,
        Closure $setter,
        Closure $failure = null
    ) : void {
        $source->watching($conf, static function (string $dsn) use ($schemes, $setter, $failure) {
            // parsing dsn
            $parsed = parse_url($dsn) ?: [];

            /**
             * @var Transport $transfer
             * @var Protocol $codec
             */

            $transfer = $codec = null;

            if ($platform = $schemes[$parsed['scheme']] ?? null) {
                [$transport, $protocol] = $platform;

                $transfer = DI::object($transport);
                $codec = DI::object($protocol);

                try {
                    $transfer->connect(
                        new Address($parsed['host'], $parsed['port'] ?? null),
                        $parsed['path'] ?? null
                    );
                } catch (Throwable $e) {
                    $failure && $failure($e);
                }
            }

            // user setter
            $setter($transfer, $codec);
        });