Bernard\Driver\AppEngineDriver

Complexity

Total Complexity

14

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	12
Bugs	2	Features	4

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	listQueues()	0	4	1
A	createQueue()	0	3	1
A	countMessages()	0	3	1
A	popMessage()	0	3	1
A	acknowledgeMessage()	0	3	1
A	removeQueue()	0	3	1
A	peekQueue()	0	4	1
A	info()	0	4	1
A	pushMessage()	0	7	1
B	configurePushOptions()	0	29	2
A	resolveEndpoint()	0	8	2

<?php

namespace Bernard\Driver;

use google\appengine\api\taskqueue\PushTask;
use Symfony\Component\OptionsResolver\OptionsResolver;

/**
 * Simple driver for google AppEngine. Many features are not supported.
 * It takes a list of array('name' => 'endpoint') to route messages to the
 * correct place.
 *
 * @package Bernard
 */
class AppEngineDriver extends AbstractDriver
{
    protected $queueMap;

    /**
     * @param array $queueMap
     */
    public function __construct(array $queueMap)
    {
        $this->queueMap = $queueMap;
    }

    /**
     * {@inheritdoc}
     */
    public function listQueues()
    {
        return array_flip($this->queueMap);
    }

    /**
     * {@inheritdoc}
     */
    public function createQueue($queueName, array $options = [])
    {
    }

    /**
     * {@inheritdoc}
     */
    public function countMessages($queueName)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function pushMessage($queueName, $message, array $options = [])
    {
        $options = $this->validatePushOptions($options);

        $task = new PushTask($this->resolveEndpoint($queueName), compact('message'), $options);
        $task->add($queueName);
    }

    /**
     * {@inheritdoc}
     */
    public function popMessage($queueName, $duration = 5)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function acknowledgeMessage($queueName, $receipt)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function removeQueue($queueName)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function peekQueue($queueName, $index = 0, $limit = 20)
    {
        return [];
    }

    /**
     * {@inheritdoc}
     */
    public function info()
    {
        return [];
    }

    /**
     * {@inheritdoc}
     */
    public function configurePushOptions(OptionsResolver $resolver)
    {
        //BC layer to support 2.3+ and 2.7+/3.0+ versions
        if (interface_exists('Symfony\Component\OptionsResolver\OptionsResolverInterface')) {
            //2.3+
            $resolver

The method setOptional() does not seem to exist on object<Symfony\Component\OptionsResolver\OptionsResolver>.

                ->setOptional(array(
                    'method',
                    'name',
                    'delay_seconds',
                    'header',
                ))
                ->setAllowedValues(array(
                    'method' => array('POST', 'GET', 'HEAD', 'PUT', 'DELETE'),
                ))
            ;
        } else {
            //2.7+
            $resolver
                ->setDefined('method')
                ->setDefined('name')
                ->setDefined('delay_seconds')
                ->setDefined('header')
                ->setAllowedValues(
                    'method', array('POST', 'GET', 'HEAD', 'PUT', 'DELETE')
                )
            ;
        }
    }

    /**
     * @param string $queueName
     *
     * @throws InvalidArgumentException
     */
    protected function resolveEndpoint($queueName)
    {
        if (isset($this->queueMap[$queueName])) {
            return $this->queueMap[$queueName];
        }

        return '/_ah/queue/' . $queueName;
    }
}