dextervip / DatabaseSwiftMailerBundle

Spool/DatabaseSpool.php

Spacing +15 added lines, -15 removed lines

@@ -65,19 +65,19 @@ 
     public function queueMessage(Swift_Mime_Message $message)
     {
         $email = new Email();
-        $email->setFromEmail(implode('; ', array_keys($message->getFrom())) );
+        $email->setFromEmail(implode('; ', array_keys($message->getFrom())));
 
-        if($message->getTo() !== null ){
-            $email->setToEmail(implode('; ', array_keys($message->getTo())) );
+        if ($message->getTo() !== null) {
+            $email->setToEmail(implode('; ', array_keys($message->getTo())));
         }
-        if($message->getCc() !== null ){
-            $email->setCcEmail(implode('; ', array_keys($message->getCc())) );
+        if ($message->getCc() !== null) {
+            $email->setCcEmail(implode('; ', array_keys($message->getCc())));
         }
-        if($message->getBcc() !== null ){
-            $email->setBccEmail(implode('; ', array_keys($message->getBcc())) );
+        if ($message->getBcc() !== null) {
+            $email->setBccEmail(implode('; ', array_keys($message->getBcc())));
         }
-        if($message->getReplyTo() !== null ){
-            $email->setReplyToEmail(implode('; ', array_keys($message->getReplyTo())) );
+        if ($message->getReplyTo() !== null) {
+            $email->setReplyToEmail(implode('; ', array_keys($message->getReplyTo())));
         }
 
         $email->setBody($message->getBody());
@@ -105,17 +105,17 @@ 
         $count = 0;
         $emails = $this->repository->getEmailQueue($this->getMessageLimit());
 
-        foreach($emails as $email){
+        foreach ($emails as $email) {
             /*@var $message \Swift_Mime_Message */
             $message = $email->getMessage();
-            try{
-                $count+= $transport->send($message, $failedRecipients);
-                if($count > 0){
+            try {
+                $count += $transport->send($message, $failedRecipients);
+                if ($count > 0) {
                     $this->repository->markCompleteSending($email);
-                }else{
+                }else {
                     throw new \Swift_SwiftException('The email was not sent.');
                 }
-            }catch(\Swift_SwiftException $ex){
+            }catch (\Swift_SwiftException $ex) {
                 $this->repository->markFailedSending($email, $ex);
             }
         }

Braces +2 added lines, -2 removed lines

@@ -112,10 +112,10 @@
                 $count+= $transport->send($message, $failedRecipients);
                 if($count > 0){
                     $this->repository->markCompleteSending($email);
-                }else{
+                } else{
                     throw new \Swift_SwiftException('The email was not sent.');
                 }
-            }catch(\Swift_SwiftException $ex){
+            } catch(\Swift_SwiftException $ex){
                 $this->repository->markFailedSending($email, $ex);
             }
         }

Entity/EmailRepository.php

Spacing +12 added lines, -12 removed lines

@@ -12,7 +12,7 @@ 
  */
 class EmailRepository extends EntityRepository
 {
-    public function addEmail(Email $email){
+    public function addEmail(Email $email) {
         $em = $this->getEntityManager();
         $email->setStatus(Email::STATUS_READY);
         $email->setRetries(0);
@@ -20,31 +20,31 @@ 
         $em->flush();
     }
 
-    public function getAllEmails(){
+    public function getAllEmails() {
         $qb = $this->createQueryBuilder('e');
 
-        $qb->addOrderBy('e.createdAt','DESC');
+        $qb->addOrderBy('e.createdAt', 'DESC');
         return $qb->getQuery();
     }
 
-    public function getEmailQueue($limit = 100){
+    public function getEmailQueue($limit = 100) {
         $qb = $this->createQueryBuilder('e');
 
-        $qb->where($qb->expr()->eq('e.status',':status'))->setParameter(':status' ,Email::STATUS_READY);
-        $qb->orWhere($qb->expr()->eq('e.status',':status_1'))->setParameter(':status_1' ,Email::STATUS_FAILED);
-        $qb->andWhere($qb->expr()->lt('e.retries',':retries'))->setParameter(':retries',10);
+        $qb->where($qb->expr()->eq('e.status', ':status'))->setParameter(':status', Email::STATUS_READY);
+        $qb->orWhere($qb->expr()->eq('e.status', ':status_1'))->setParameter(':status_1', Email::STATUS_FAILED);
+        $qb->andWhere($qb->expr()->lt('e.retries', ':retries'))->setParameter(':retries', 10);
 
 
-        $qb->addOrderBy('e.retries','ASC');
-        $qb->addOrderBy('e.createdAt','ASC');
-        if(empty($limit) === false){
+        $qb->addOrderBy('e.retries', 'ASC');
+        $qb->addOrderBy('e.createdAt', 'ASC');
+        if (empty($limit) === false) {
             $qb->setMaxResults($limit);
         }
 
         return $qb->getQuery()->getResult();
     }
 
-    public function markFailedSending(Email $email, \Exception $ex){
+    public function markFailedSending(Email $email, \Exception $ex) {
         $email->setErrorMessage($ex->getMessage());
         $email->setStatus(Email::STATUS_FAILED);
         $email->setRetries($email->getRetries()+1);
@@ -53,7 +53,7 @@ 
         $em->flush();
     }
 
-    public function markCompleteSending(Email $email){
+    public function markCompleteSending(Email $email) {
         $email->setStatus(Email::STATUS_COMPLETE);
         $email->setSentAt(new \DateTime());
         $email->setErrorMessage('');