DoctrineProvider::receive() - Code Metrics - Inspection of "Doctrine provider" - uecode/qpush-bundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#110)

unknown

created 2016-09-02 13:50 UTC

DoctrineProvider::receive() B

↳ Parent: DoctrineProvider

Complexity

Conditions	3
Paths	3

Size

Total Lines	24
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	12

Importance

Changes	4
Bugs	0	Features	2

Metric	Value
c	4
b	0
f	2
dl	0
loc	24
ccs	0
cts	21
cp	0
rs	8.9713
cc	3
eloc	13
nc	3
nop	1
crap	12

<?php

namespace Uecode\Bundle\QPushBundle\Provider;

use Doctrine\Common\Cache\Cache;
use Monolog\Logger;
use Uecode\Bundle\QPushBundle\Message\Message;
use Uecode\Bundle\QPushBundle\Entity\DoctrineMessage;

class DoctrineProvider extends AbstractProvider
{

    protected $em;
    protected $repository;

    /**
     * Constructor for Provider classes
     *
     * @param string $name    Name of the Queue the provider is for
     * @param array  $options An array of configuration options for the Queue
     * @param mixed  $client  A Queue Client for the provider
     * @param Cache  $cache   An instance of Doctrine\Common\Cache\Cache
     * @param Logger $logger  An instance of Symfony\Bridge\Mongolog\Logger
     */
    public function __construct($name, array $options, $client, Cache $cache, Logger $logger)
    {
        $this->name = $name;
        $this->options = $options;
        $this->cache = $cache;
        $this->logger = $logger;
        $this->em = $client;
        $this->repository = $this->em->getRepository('Uecode\Bundle\QPushBundle\Entity\DoctrineMessage');
    }

    /**
     * Returns the name of the Queue that this Provider is for
     *
     * @return string
     */
    public function getName()
    {
        return $this->name;
    }

    /**
     * Returns the Queue Provider name
     *
     * @return string
     */
    public function getProvider()
    {
        return 'Doctrine';
    }

    /**
     * Returns the Provider's Configuration Options
     *
     * @return array
     */
    public function getOptions()
    {
        return $this->options;
    }

    /**
     * Returns the Cache service
     *
     * @return Cache
     */
    public function getCache()
    {
        return $this->cache;
    }

    /**
     * Returns the Logger service
     *
     * @return Logger
     */
    public function getLogger()
    {
        return $this->logger;
    }

    /**
     * Get repository
     * 
     * @return array
     */
    public function getRepository()
    {
        if (!$this->repository) {
            return;
        }
        return $this->repository;
    }

    /**
     * Creates the Queue
     *
     * All Create methods are idempotent, if the resource exists, the current ARN
     * will be returned
     */
    public function create()
    {
        
    }

    /**
     * Publishes a message to the Queue
     *
     * This method should return a string MessageId or Response
     *
     * @param array $message The message to queue
     * @param  array $options An array of options that override the queue defaults
     *
     * @return string
     */
    public function publish(array $message, array $options = [])
    {
        if (!$this->em) {
            return '';
        }

        $doctrineMessage = new DoctrineMessage();
        $doctrineMessage->setQueue($this->name)
                ->setDelivered(false)
                ->setMessage($message)
                ->setLength(strlen(serialize($message)));

        $this->em->persist($doctrineMessage);
        $this->em->flush();

        return (string) $doctrineMessage->getId();
    }

    /**
     * Polls the Queue for Messages
     *
     * Depending on the Provider, this method may keep the connection open for
     * a configurable amount of time, to allow for long polling.  In most cases,
     * this method is not meant to be used to long poll indefinitely, but should
     * return in reasonable amount of time
     *
     * @param  array $options An array of options that override the queue defaults
     *
     * @return array
     */
    public function receive(array $options = [])
    {
        if (!$this->em) {
            return [];
        }

        $doctrineMessages = $this->repository->findBy(
                [
            'delivered' => false,
            'queue' => $this->name
                ], [
            'id' => 'ASC'
                ]
        );

        $messages = [];
        foreach ($doctrineMessages as $doctrineMessage) {
            $messages[] = new Message($doctrineMessage->getId(), $doctrineMessage->getMessage(), []);
            $doctrineMessage->setDelivered(true);
        }
        $this->em->flush();

        return $messages;
    }

    /**
     * Deletes the Queue Message
     *
     * @param mixed $id A message identifier or resource
     */
    public function delete($id)
    {
        $doctrineMessage = $this->repository->findById($id);
        $doctrineMessage->setDelivered(true);
        $this->em->flush();
    }

    /**
     * Destroys a Queue and clears any Queue related Cache
     *
     * @return bool
     */
    public function destroy()
    {
        $qb = $this->repository->createQueryBuilder('dm');
        $qb->delete();
        $qb->where('dm.queue = :queue');
        $qb->setParameter('queue', $this->name);
        $qb->getQuery()->getResult();
    }

    /**
     * Returns a specific message
     * 
     * @param integer $id
     * 
     * @return Message
     */
    public function getById($id)
    {
        return $this->repository->find($id);
    }

    /*
     * Returns a query of the message queue
     * 
     * @param string $contains
     * @param DateTime $from
     * @param DateTime $to
     * 
     * @return Query
     */

    public function findBy($contains = null, $from = null, $to = null)
    {

        $qb = $this->repository->createQueryBuilder('p');
        $qb->select('p');
        $qb->where('p.queue = :queue');
        $qb->setParameter('queue', $this->name);

        if ($contains !== null) {
            $qb->addWhere('p.message like %:contains%');
            $qb->setParameter('contains', $contains);
        }
        
        if ($from) {
            $qb->addWhere('p.created > %:from%');
            $qb->setParameter('from', $from);
        }
        
        if ($to) {
            $qb->addWhere('p.created < %:to%');
            $qb->setParameter('to', $to);
        }
        
        return $qb->getQuery();
    }

}


1			<?php
2
3			namespace Uecode\Bundle\QPushBundle\Provider;
4
5			use Doctrine\Common\Cache\Cache;
6			use Monolog\Logger;
7			use Uecode\Bundle\QPushBundle\Message\Message;
8			use Uecode\Bundle\QPushBundle\Entity\DoctrineMessage;
9
10			class DoctrineProvider extends AbstractProvider
11			{
12
13			protected $em;
14			protected $repository;
15
16			/**
17			* Constructor for Provider classes
18			*
19			* @param string $name Name of the Queue the provider is for
20			* @param array $options An array of configuration options for the Queue
21			* @param mixed $client A Queue Client for the provider
22			* @param Cache $cache An instance of Doctrine\Common\Cache\Cache
23			* @param Logger $logger An instance of Symfony\Bridge\Mongolog\Logger
24			*/
25			public function __construct($name, array $options, $client, Cache $cache, Logger $logger)
26			{
27			$this->name = $name;
28			$this->options = $options;
29			$this->cache = $cache;
30			$this->logger = $logger;
31			$this->em = $client;
32			$this->repository = $this->em->getRepository('Uecode\Bundle\QPushBundle\Entity\DoctrineMessage');
33			}
34
35			/**
36			* Returns the name of the Queue that this Provider is for
37			*
38			* @return string
39			*/
40			public function getName()
41			{
42			return $this->name;
43			}
44
45			/**
46			* Returns the Queue Provider name
47			*
48			* @return string
49			*/
50			public function getProvider()
51			{
52			return 'Doctrine';
53			}
54
55			/**
56			* Returns the Provider's Configuration Options
57			*
58			* @return array
59			*/
60			public function getOptions()
61			{
62			return $this->options;
63			}
64
65			/**
66			* Returns the Cache service
67			*
68			* @return Cache
69			*/
70			public function getCache()
71			{
72			return $this->cache;
73			}
74
75			/**
76			* Returns the Logger service
77			*
78			* @return Logger
79			*/
80			public function getLogger()
81			{
82			return $this->logger;
83			}
84
85			/**
86			* Get repository
87			*
88			* @return array
89			*/
90			public function getRepository()
91			{
92			if (!$this->repository) {
93			return;
94			}
95			return $this->repository;
96			}
97
98			/**
99			* Creates the Queue
100			*
101			* All Create methods are idempotent, if the resource exists, the current ARN
102			* will be returned
103			*/
104			public function create()
105			{
106
107			}
108
109			/**
110			* Publishes a message to the Queue
111			*
112			* This method should return a string MessageId or Response
113			*
114			* @param array $message The message to queue
115			* @param array $options An array of options that override the queue defaults
116			*
117			* @return string
118			*/
119			public function publish(array $message, array $options = [])
120			{
121			if (!$this->em) {
122			return '';
123			}
124
125			$doctrineMessage = new DoctrineMessage();
126			$doctrineMessage->setQueue($this->name)
127			->setDelivered(false)
128			->setMessage($message)
129			->setLength(strlen(serialize($message)));
130
131			$this->em->persist($doctrineMessage);
132			$this->em->flush();
133
134			return (string) $doctrineMessage->getId();
135			}
136
137			/**
138			* Polls the Queue for Messages
139			*
140			* Depending on the Provider, this method may keep the connection open for
141			* a configurable amount of time, to allow for long polling. In most cases,
142			* this method is not meant to be used to long poll indefinitely, but should
143			* return in reasonable amount of time
144			*
145			* @param array $options An array of options that override the queue defaults
146			*
147			* @return array
148			*/
149			public function receive(array $options = [])
150			{
151			if (!$this->em) {
152			return [];
153			}
154
155			$doctrineMessages = $this->repository->findBy(
156			[
157			'delivered' => false,
158			'queue' => $this->name
159			], [
160			'id' => 'ASC'
161			]
162			);
163
164			$messages = [];
165			foreach ($doctrineMessages as $doctrineMessage) {
166			$messages[] = new Message($doctrineMessage->getId(), $doctrineMessage->getMessage(), []);
167			$doctrineMessage->setDelivered(true);
168			}
169			$this->em->flush();
170
171			return $messages;
172			}
173
174			/**
175			* Deletes the Queue Message
176			*
177			* @param mixed $id A message identifier or resource
178			*/
179			public function delete($id)
180			{
181			$doctrineMessage = $this->repository->findById($id);
182			$doctrineMessage->setDelivered(true);
183			$this->em->flush();
184			}
185
186			/**
187			* Destroys a Queue and clears any Queue related Cache
188			*
189			* @return bool
190			*/
191			public function destroy()
192			{
193			$qb = $this->repository->createQueryBuilder('dm');
194			$qb->delete();
195			$qb->where('dm.queue = :queue');
196			$qb->setParameter('queue', $this->name);
197			$qb->getQuery()->getResult();
198			}
199
200			/**
201			* Returns a specific message
202			*
203			* @param integer $id
204			*
205			* @return Message
206			*/
207			public function getById($id)
208			{
209			return $this->repository->find($id);
210			}
211
212			/*
213			* Returns a query of the message queue
214			*
215			* @param string $contains
216			* @param DateTime $from
217			* @param DateTime $to
218			*
219			* @return Query
220			*/
221
222			public function findBy($contains = null, $from = null, $to = null)
223			{
224
225			$qb = $this->repository->createQueryBuilder('p');
226			$qb->select('p');
227			$qb->where('p.queue = :queue');
228			$qb->setParameter('queue', $this->name);
229
230			if ($contains !== null) {
231			$qb->addWhere('p.message like %:contains%');
232			$qb->setParameter('contains', $contains);
233			}
234
235			if ($from) {
236			$qb->addWhere('p.created > %:from%');
237			$qb->setParameter('from', $from);
238			}
239
240			if ($to) {
241			$qb->addWhere('p.created < %:to%');
242			$qb->setParameter('to', $to);
243			}
244
245			return $qb->getQuery();
246			}
247
248			}
249

uecode / qpush-bundle

Pull Request — master (#110)

DoctrineProvider::receive() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like