Yokai\MessengerBundle\Channel\MobileChannel

Complexity

Total Complexity

7

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	supports()	0	4	1
A	configure()	0	6	1
A	handle()	0	26	4

<?php

namespace Yokai\MessengerBundle\Channel;

use Sly\NotificationPusher\Adapter\AdapterInterface;
use Sly\NotificationPusher\Collection\DeviceCollection;
use Sly\NotificationPusher\Model\Device;
use Sly\NotificationPusher\Model\Message;
use Sly\NotificationPusher\Model\Push;
use Sly\NotificationPusher\PushManager;
use Symfony\Component\OptionsResolver\OptionsResolver;
use Yokai\MessengerBundle\Delivery;
use Yokai\MessengerBundle\Recipient\NotificationRecipientInterface;

/**
 * @author Yann Eugoné <eugone.yann@gmail.com>
 */
class MobileChannel implements ChannelInterface
{
    /**
     * @var PushManager
     */
    private $pushManager;

    /**
     * @var AdapterInterface[]
     */
    private $adapters;

    /**
     * @param PushManager        $pushManager
     * @param AdapterInterface[] $adapters
     */
    public function __construct(PushManager $pushManager, array $adapters)
    {
        $this->pushManager = $pushManager;
        $this->adapters = $adapters;
    }

    /**
     * @inheritdoc
     */
    public function supports($recipient)
    {
        return $recipient instanceof NotificationRecipientInterface;
    }

    /**
     * @inheritdoc
     */
    public function configure(OptionsResolver $resolver)
    {
        $resolver
            ->setDefault('mobile_data', [])
        ;
    }

    /**
     * @inheritdoc
     */
    public function handle(Delivery $delivery)
    {
        /** @var $recipient NotificationRecipientInterface */
        $recipient = $delivery->getRecipient();

        $options = $delivery->getOptions();
        $options = array_intersect_key($delivery->getParameters(), array_flip($options['mobile_data']));

        $message = new Message($delivery->getSubject(), $options);

        foreach ($this->adapters as $adapter) {
            $devices = new DeviceCollection();

            foreach ($recipient->getDevicesTokens() as $token) {
                if ($adapter->supports($token)) {
                    $devices->add(new Device($token));
                }
            }

            $push = new Push($adapter, $devices, $message);

            $this->pushManager->add($push);
        }

        $this->pushManager->push();
    }
}