DevNullTransportFactory.php

<?php

/*
 * This file is part of the gromnan/devnull-notifier package.
 *
 * (c) Jérôme Tamarelle <jerome@tamarelle.net>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace GromNaN\Notifier\Bridge\DevNull;

use Symfony\Component\Notifier\Exception\MissingRequiredOptionException;
use Symfony\Component\Notifier\Exception\UnsupportedSchemeException;
use Symfony\Component\Notifier\Transport\AbstractTransportFactory;
use Symfony\Component\Notifier\Transport\Dsn;

/**
 * @author Jérôme Tamarelle <jerome@tamarelle.net>
 */
final class DevNullTransportFactory extends AbstractTransportFactory
{
    public function create(Dsn $dsn): DevNullTransport
    {
        if ('devnull' !== $dsn->getScheme()) {
            throw new UnsupportedSchemeException($dsn, 'devnull', $this->getSupportedSchemes());
        }

        $privateKey = $dsn->getOption('private_key');

        if (!\is_string($privateKey) || '' === trim($privateKey)) {
            $privateKey = SshKeyLocator::fromEnvironment()->locate()
                ?? throw new MissingRequiredOptionException('private_key');
        }

        $signer = new SshSigner(
            $privateKey,
            $dsn->getOption('passphrase'),
            $dsn->getOption('namespace', SshSigner::NAMESPACE),
        );

        return (new DevNullTransport($signer, $dsn->getBooleanOption('ssl', true), $this->client, $this->dispatcher))
            ->setHost('default' === $dsn->getHost() ? null : $dsn->getHost())
            ->setPort($dsn->getPort());
    }

    protected function getSupportedSchemes(): array
    {
        return ['devnull'];
    }
}