Webklex / laravel-imap

src/IMAP/Query/Query.php

Spacing +19 added lines, -19 removed lines

@@ -69,7 +69,7 @@ 
     public function __construct(Client $client, $charset = 'UTF-8') {
         $this->setClient($client);
 
-        if(config('imap.options.fetch') === IMAP::FT_PEEK) $this->leaveUnread();
+        if (config('imap.options.fetch') === IMAP::FT_PEEK) $this->leaveUnread();
 
         $this->date_format = config('imap.date_format', 'd M y');
 
@@ -81,7 +81,7 @@ 
     /**
      * Instance boot method for additional functionality
      */
-    protected function boot(){}
+    protected function boot() {}
 
     /**
      * Parse a given value
@@ -89,8 +89,8 @@ 
      *
      * @return string
      */
-    protected function parse_value($value){
-        switch(true){
+    protected function parse_value($value) {
+        switch (true) {
             case $value instanceof \Carbon\Carbon:
                 $value = $value->format($this->date_format);
                 break;
@@ -107,7 +107,7 @@ 
      * @throws MessageSearchValidationException
      */
     protected function parse_date($date) {
-        if($date instanceof \Carbon\Carbon) return $date;
+        if ($date instanceof \Carbon\Carbon) return $date;
 
         try {
             $date = Carbon::parse($date);
@@ -146,7 +146,7 @@ 
      * @return \Illuminate\Support\Collection
      * @throws \Webklex\IMAP\Exceptions\ConnectionFailedException
      */
-    protected function search(){
+    protected function search() {
         $this->generate_query();
         $available_messages = [];
 
@@ -159,14 +159,14 @@ 
         try {
             if ($this->getCharset() == null) {
                 $available_messages = \imap_search($this->getClient()->getConnection(), $this->getRawQuery(), IMAP::SE_UID);
-            }else{
+            } else {
                 $available_messages = \imap_search($this->getClient()->getConnection(), $this->getRawQuery(), IMAP::SE_UID, $this->getCharset());
             }
         } catch (\Exception $e) {
             if (strpos($e, ' [BADCHARSET (')) {
                 preg_match('/ \[BADCHARSET \((.*)\)\]/', $e, $matches);
                 if (isset($matches[1])) {
-                    if ($matches[1] !== $this->getCharset()){
+                    if ($matches[1] !== $this->getCharset()) {
                         $this->setCharset($matches[1]);
                         return $this->search();
                     }
@@ -210,15 +210,15 @@ 
 
                 $options = config('imap.options');
 
-                if(strtolower($options['fetch_order']) === 'desc'){
+                if (strtolower($options['fetch_order']) === 'desc') {
                     $available_messages = $available_messages->reverse();
                 }
 
-                $query =& $this;
+                $query = & $this;
 
                 $available_messages->forPage($this->page, $this->limit)->each(function($msgno, $msglist) use(&$messages, $options, $query) {
                     $oMessage = new Message($msgno, $msglist, $query->getClient(), $query->getFetchOptions(), $query->getFetchBody(), $query->getFetchAttachment(), $query->getFetchFlags());
-                    switch ($options['message_key']){
+                    switch ($options['message_key']) {
                         case 'number':
                             $message_key = $oMessage->getMessageNo();
                             break;
@@ -249,7 +249,7 @@ 
      * @return \Illuminate\Pagination\LengthAwarePaginator
      * @throws GetMessagesFailedException
      */
-    public function paginate($per_page = 5, $page = null, $page_name = 'imap_page'){
+    public function paginate($per_page = 5, $page = null, $page_name = 'imap_page') {
         $this->page = $page > $this->page ? $page : $this->page;
         $this->limit = $per_page;
 
@@ -264,13 +264,13 @@ 
      * @throws \Webklex\IMAP\Exceptions\ConnectionFailedException
      * @throws \Webklex\IMAP\Exceptions\InvalidMessageDateException
      */
-    public function idle(callable $callback = null, $timeout = 10){
+    public function idle(callable $callback = null, $timeout = 10) {
         $known_messages = [];
         $this->getClient()->overview()->each(function($message) use(&$known_messages){
             /** @var object $message */
             $known_messages[] = $message->uid;
         });
-        while ($this->getClient()->isConnected()){
+        while ($this->getClient()->isConnected()) {
             $this->getClient()->expunge();
             $new_messages = [];
             $this->getClient()->overview()->each(function($message) use(&$new_messages, &$known_messages){
@@ -281,10 +281,10 @@ 
                 }
             });
 
-            foreach($new_messages as $msg) {
+            foreach ($new_messages as $msg) {
                 $message = new Message($msg->uid, $msg->msgno, $this->getClient());
                 MessageNewEvent::dispatch($message);
-                if ($callback){
+                if ($callback) {
                     $callback($message);
                 }
             }
@@ -304,9 +304,9 @@ 
             if (count($statement) == 1) {
                 $query .= $statement[0];
             } else {
-                if($statement[1] === null){
+                if ($statement[1] === null) {
                     $query .= $statement[0];
-                }else{
+                } else {
                     $query .= $statement[0].' "'.$statement[1].'"';
                 }
             }
@@ -336,7 +336,7 @@ 
      * @return $this
      */
     public function limit($limit, $page = 1) {
-        if($page >= 1) $this->page = $page;
+        if ($page >= 1) $this->page = $page;
         $this->limit = $limit;
 
         return $this;