wshafer / psr11-monolog

use WShafer\PSR11MonoLog\FactoryInterface;

use WShafer\PSR11MonoLog\ServiceTrait;

class AmqpHandlerFactory implements FactoryInterface, ContainerAwareInterface

{

    use ServiceTrait;

    public function __invoke(array $options)

    {

        $exchange     = $this->getService($options['exchange'] ?? null);

        $exchangeName = (string)  ($options['exchangeName'] ?? 'log');

        $level        = (int)     ($options['level']     ?? Logger::DEBUG);

        $bubble       = (bool) ($options['bubble']    ?? true);

        return new AmqpHandler(

            $exchange,

            $exchangeName,

            $level,

            $bubble

        );

    }

}

use WShafer\PSR11MonoLog\FactoryInterface;

use WShafer\PSR11MonoLog\ServiceTrait;

class DynamoDbHandlerFactory implements FactoryInterface, ContainerAwareInterface

{

    use ServiceTrait;

    public function __invoke(array $options)

    {

        $client  = $this->getService($options['client'] ?? null);

        $table   = (string)  ($options['table']  ?? null);

        $level   = (int)     ($options['level']  ?? Logger::DEBUG);

        $bubble  = (bool) ($options['bubble'] ?? true);

        return new DynamoDbHandler(

            $client,

            $table,

            $level,

            $bubble

        );

    }

}

use WShafer\PSR11MonoLog\ContainerAwareInterface;

use WShafer\PSR11MonoLog\FactoryInterface;

class MandrillHandlerFactory implements FactoryInterface, ContainerAwareInterface

{

    use SwiftMessageTrait;

    public function __invoke(array $options)

    {

        $apiKey  = (string)  ($options['apiKey']  ?? '');

        $message = $this->getSwiftMessage($options);

        $level   = (int)     ($options['level']   ?? Logger::DEBUG);

        $bubble  = (bool) ($options['bubble']  ?? true);

        return new MandrillHandler(

            $apiKey,

            $message,

            $level,

            $bubble

        );

    }

}

use WShafer\PSR11MonoLog\FactoryInterface;

use WShafer\PSR11MonoLog\ServiceTrait;

class PHPConsoleHandlerFactory implements FactoryInterface, ContainerAwareInterface

{

    use ServiceTrait;

    public function __invoke(array $options)

    {

        $consoleOptions = (array)   ($options['options'] ?? []);

        $connector      = $this->getService($options['connector'] ?? null);

        $level          = (int)     ($options['level']   ?? Logger::DEBUG);

        $bubble         = (bool) ($options['bubble']  ?? true);

        return new PHPConsoleHandler(

            $consoleOptions,

            $connector,

            $level,

            $bubble

        );

    }

}

use WShafer\PSR11MonoLog\FactoryInterface;

use WShafer\PSR11MonoLog\ServiceTrait;

class SqsHandlerFactory implements FactoryInterface, ContainerAwareInterface

{

    use ServiceTrait;

    public function __invoke(array $options)

    {

        $sqsClient = $this->getService($options['sqsClient'] ?? null);

        $queueUrl  = (string)  ($options['queueUrl']  ?? Logger::DEBUG);

        $level     = (int)     ($options['level']  ?? Logger::DEBUG);

        $bubble    = (bool) ($options['bubble'] ?? true);

        return new SqsHandler($sqsClient, $queueUrl, $level, $bubble);

    }

}

use WShafer\PSR11MonoLog\ContainerAwareInterface;

use WShafer\PSR11MonoLog\FactoryInterface;

class SwiftMailerHandlerFactory implements FactoryInterface, ContainerAwareInterface

{

    use SwiftMessageTrait;

    public function __invoke(array $options)

    {

        $mailer  = $this->getService($options['mailer'] ?? null);

        $message = $this->getSwiftMessage($options);

        $level   = (int)     ($options['level']  ?? Logger::DEBUG);

        $bubble  = (bool) ($options['bubble'] ?? true);

        return new SwiftMailerHandler($mailer, $message, $level, $bubble);

    }

}