DeviceBundle/Command/CreateDeviceCommand.php

<?php

namespace DeviceBundle\Command;

use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Buzz\Message\RequestInterface as HttpRequestInterface;

class CreateDeviceCommand extends ContainerAwareCommand
{

    protected function configure()
    {
        $this
            ->setName('device:create')
            ->setDescription('Create Device command')
            ->setHelp('Create Device command')
            ->addArgument('type', InputOption::VALUE_REQUIRED, 'Device Type. e.g. FTTHBundle:ONU, FTTHBundle:OLT')
            ->addOption('id', null, InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY, 'Device id. e.g. --id=1 --id=2')
            ->addOption('url', null, InputOption::VALUE_OPTIONAL, 'Device POST url for device creation')
            ->addOption('username', null, InputOption::VALUE_OPTIONAL, 'Username', 'admin')
            ->addOption('password', null, InputOption::VALUE_OPTIONAL, 'User password', 'adminpass')
        ;
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $ids = $input->getOption('id');
        $url = $input->getOption('url');
        $username = $input->getOption('username');
        $password = $input->getOption('password');
        try {
            // busco por device type e id
            $container = $this->getContainer();
            $em = $container->get('doctrine.orm.entity_manager');
            $repository = $em->getRepository($input->getArgument('type'));
            $entities = array();
            if (!empty($ids)) {
                if (!is_array($ids)) {
                    $ids = array($ids);
                }
                foreach ($ids as $id) {
                    if ($entity = $repository->find($id)) {
                        $entities[] = $entity;
                    } else {
                        $output->writeln("Entity id <error>{$id}</error> not found!");
                    }
                }
            } else {
                $entities = $repository->findAll();
            }

            // llamada POST para guardar el device
            if (!$url && $container->hasParameter('device_post_url')) {
                $url = $container->getParameter('device_post_url');
            }
            $deviceListener = $container->get('device.device_listener');
            foreach ($entities as $entity) {
                $response = $deviceListener->send($entity, $url, HttpRequestInterface::METHOD_POST, compact('username', 'password'));
                if (json_decode($response)) {
                    $output->writeln('<info>Device created!</info>');
                    $output->writeln($response);
                } else {
                    $output->writeln("Error: Device for entity id <error>{$id}</error> not created!");
                }
            }
        } catch (\Exception $ex) {
            $output->writeln($ex->getMessage());
        }
    }

}