SmsGate\Adapter\LoggingAdapterDecorator

Complexity

Total Complexity

8

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
C	send()	0	51	7

<?php

declare(strict_types = 1);

/*
 * This file is part of the SmsGate package
 *
 * (c) SmsGate
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code
 */

namespace SmsGate\Adapter;

use Psr\Log\LoggerInterface;
use Psr\Log\LogLevel;
use SmsGate\Exception\SendSmsExceptionInterface;
use SmsGate\Message;
use SmsGate\Phone;
use SmsGate\ResultCollection;

/**
 * The decorator of adapter for write result to log.
 *
 * @author Vitaliy Zhuk <zhuk2205@gmail.com>
 */
class LoggingAdapterDecorator implements AdapterInterface
{
    /**
     * @var AdapterInterface
     */
    private $originAdapter;

    /**
     * @var
     */
    private $logger;

    /**
     * Constructor.
     *
     * @param AdapterInterface $originAdapter
     * @param LoggerInterface  $logger
     */
    public function __construct(AdapterInterface $originAdapter, LoggerInterface $logger)
    {
        $this->originAdapter = $originAdapter;
        $this->logger = $logger;
    }

    /**
     * {@inheritdoc}
     */
    public function send(Message $message, Phone ...$recipients): ResultCollection
    {
        $phoneNumbers = array_map(function (Phone $recipient) {
            return $recipient->getValue();
        }, $recipients);

        $this->logger->log(LogLevel::DEBUG, 'Start send sms.', [
            'numbers' => $phoneNumbers,
            'message' => [
                'text'   => $message->getMessage(),
                'sender' => $message->getSender(),
            ],
        ]);

        try {
            $result = $this->originAdapter->send($message, ...$recipients);
        } catch (SendSmsExceptionInterface $e) {
            $this->logger->log(LogLevel::CRITICAL, 'Fail send sms.', [
                'error' => $e->getMessage(),
            ]);

            throw $e;
        }

        foreach ($result as $element) {
            $logMessage = sprintf(
                '%s send sms to %s.',
                $element->isSuccessfully() ? 'Success' : 'Fail',
                $element->getPhone()
            );

            $level = $element->isSuccessfully() ? LogLevel::INFO : LogLevel::ERROR;

            $context = [
                'number' => $element->getPhone()->getValue(),
                'status' => $element->isSuccessfully(),
                'id'     => $element->getMessageId(),
            ];

            if ($element->isFailed() && $element->getError()) {
                $context['error'] = [
                    'reason'  => $element->getError()->getReason(),
                    'message' => $element->getError()->getMessage(),
                ];
            }

            $this->logger->log($level, $logMessage, $context);
        }

        return $result;
    }
}