PHPFastCGI\FastCGIDaemon\Driver\Userland\UserlandDaemonFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	createDaemon()	0	10	2
A	createTcpDaemon()	0	11	2
A	createDaemonFromStreamSocket()	0	7	1

<?php

declare(strict_types=1);

namespace PHPFastCGI\FastCGIDaemon\Driver\Userland;

use PHPFastCGI\FastCGIDaemon\DaemonInterface;
use PHPFastCGI\FastCGIDaemon\DaemonFactoryInterface;
use PHPFastCGI\FastCGIDaemon\DaemonOptions;
use PHPFastCGI\FastCGIDaemon\Driver\Userland\Connection\StreamSocketConnectionPool;
use PHPFastCGI\FastCGIDaemon\Driver\Userland\ConnectionHandler\ConnectionHandlerFactory;
use PHPFastCGI\FastCGIDaemon\KernelInterface;

/**
 * A factory class for instantiating UserlandDaemon objects.
 */
final class UserlandDaemonFactory implements DaemonFactoryInterface
{
    /**
     * Create a FastCGI daemon listening on file descriptor using the
     * userland FastCGI implementation.
     *
     * @param KernelInterface $kernel  The kernel to use for the daemon
     * @param DaemonOptions   $options The daemon configuration
     * @param int $fd file descriptor for listening defaults to FCGI_LISTENSOCK_FILENO
     *
     * @return UserlandDaemon
     *
     * @codeCoverageIgnore The FastCGI daemon
     */
    public function createDaemon(KernelInterface $kernel, DaemonOptions $options, int $fd = DaemonInterface::FCGI_LISTENSOCK_FILENO): DaemonInterface
    {
        $socket = fopen('php://fd/'.$fd, 'r');

        if (false === $socket) {
            throw new \RuntimeException('Could not open ' . $fd);
        }

        return $this->createDaemonFromStreamSocket($kernel, $options, $socket);
    }

    /**
     * Create a FastCGI daemon listening for TCP connections on a given address
     * using the userland FastCGI implementation. The default host is
     * 'localhost'.
     *
     * @param KernelInterface $kernel  The kernel to use for the daemon
     * @param DaemonOptions   $options The daemon configuration
     * @param string          $host    The host to bind to
     * @param int             $port    The port to bind to
     *
     * @return UserlandDaemon The FastCGI daemon
     *
     * @codeCoverageIgnore
     */
    public function createTcpDaemon(KernelInterface $kernel, DaemonOptions $options, string $host, int $port): DaemonInterface
    {
        $address = 'tcp://'.$host.':'.$port;
        $socket  = stream_socket_server($address);

        if (false === $socket) {
            throw new \RuntimeException('Could not create stream socket server on: '.$address);
        }

        return $this->createDaemonFromStreamSocket($kernel, $options, $socket);
    }

    /**
     * Create a FastCGI daemon from a stream socket which is configured for
     * accepting connections using the userland FastCGI implementation.
     *
     * @param KernelInterface $kernel  The kernel to use for the daemon
     * @param DaemonOptions   $options The daemon configuration
     * @param resource        $socket  The socket to accept connections from
     *
     * @return UserlandDaemon The FastCGI daemon
     */
    public function createDaemonFromStreamSocket(KernelInterface $kernel, DaemonOptions $options, $socket): DaemonInterface
    {
        $connectionPool           = new StreamSocketConnectionPool($socket);
        $connectionHandlerFactory = new ConnectionHandlerFactory();

        return new UserlandDaemon($kernel, $options, $connectionPool, $connectionHandlerFactory);
    }
}