Carno\HTTP\Client\Persistent::assign()

Complexity

Conditions	3
Paths	3

Size

Total Lines	30
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public static function assign(string $host, int $port, array $headers, HOptions $options = null) : Client
    {
        $pk = "{$host}:{$port}";

        if (isset(self::$keeps[$pk])) {
            return self::$keeps[$pk];
        }

        $hsl = array_change_key_case($headers, CASE_LOWER);

        if (strtolower($hsl['connection'] ?? '') === 'keep-alive') {
            self::$keeps[$pk] = $cli = new Client(
                ($options ?? (new HOptions)->setTimeouts())
                    ->keepalive(
                        new POptions(1, 128, 4, 0, 55, 15, 0, 2000, 1000),
                        sprintf('http:%s:%d', $host, $port)
                    ),
                new Address($host, $port)
            );

            $cli->keepalived(static function (Pool $pool) use ($pk) {
                $pool->closed()->then(function () use ($pk) {
                    unset(self::$keeps[$pk]);
                });
            });

            return $cli;
        }

        return new Client($options ?? new HOptions);
    }