Source of file SubscribeTopicsCommand.php

Size: 3,088 Bytes - Last Modified: 2014-10-15T13:48:34+03:00

/Users/mcfedr/dev/awspushbundle/src/Mcfedr/AwsPushBundle/Command/SubscribeTopicsCommand.php

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
<?php
namespace Mcfedr\AwsPushBundle\Command;

use Aws\Sns\Exception\SubscriptionLimitExceededException;
use Aws\Sns\Exception\TopicLimitExceededException;
use Aws\Sns\SnsClient;
use Mcfedr\AwsPushBundle\Service\Topics;
use Psr\Log\LoggerInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

class SubscribeTopicsCommand extends Command
{
    /**
     * @var Topics
     */
    private $topics;

    /**
     * @var string
     */
    private $topicArn;

    /**
     * @var SnsClient
     */
    private $sns;

    /**
     * @var array
     */
    private $arns;

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

    /**
     * @param Topics $topics
     * @param string $topicArn
     * @param SnsClient $sns
     * @param array $arns
     * @param \Psr\Log\LoggerInterface $logger
     */
    public function __construct(Topics $topics, $topicArn, SnsClient $sns, $arns, LoggerInterface $logger = null)
    {
        $this->topics = $topics;
        $this->topicArn = $topicArn;
        $this->sns = $sns;
        $this->arns = $arns;
        $this->logger = $logger;

        parent::__construct();
    }


    protected function configure()
    {
        $this
            ->setName('mcfedr:aws:subscribe')
            ->setDescription('Subscribe existing devices to the topic')
            ->addOption(
                'topic',
                null,
                InputOption::VALUE_REQUIRED,
                'The topic to subscribe devices to',
                $this->topicArn
            );
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        try {
            foreach ($this->arns as $platform => $arn) {
                $this->subscribePlatform($platform, $input->getOption('topic'));
            }
        } catch (SubscriptionLimitExceededException $e) {
            $this->logger && $this->logger->error(
                'Failed to subscription to topic',
                [
                    'exception' => $e
                ]
            );
        } catch (TopicLimitExceededException $e) {
            $this->logger && $this->logger->error(
                'Failed to create topic',
                [
                    'exception' => $e
                ]
            );
        }
    }

    private function subscribePlatform($platform, $topic)
    {
        foreach ($this->sns->getListEndpointsByPlatformApplicationIterator(
            [
                'PlatformApplicationArn' => $this->arns[$platform]
            ]
        ) as $endpoint) {
            $this->logger && $this->logger->info(
                'Subscribing device to topic',
                [
                    'device' => $endpoint['EndpointArn'],
                    'topic' => $topic,
                    'platform' => $platform
                ]
            );
            $this->topics->registerDeviceOnTopic($endpoint['EndpointArn'], $topic);
        }
    }
}