Webklex / php-imap

examples/custom_message_mask.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
      * New custom method which can be called through a mask
      * @return string
      */
-    public function token(){
+    public function token() {
         return implode('-', [$this->message_id, $this->uid, $this->message_no]);
     }
 

examples/custom_attachment_mask.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
      * New custom method which can be called through a mask
      * @return string
      */
-    public function token(){
+    public function token() {
         return implode('-', [$this->id, $this->getMessage()->getUid(), $this->name]);
     }
 

src/Support/PaginatedCollection.php

Spacing +1 added lines, -1 removed lines

@@ -69,7 +69,7 @@
      * @return int|null
      */
     public function total($total = null) {
-        if($total === null) {
+        if ($total === null) {
             return $this->total;
         }
 

src/Connection/Protocols/LegacyProtocol.php

Spacing +15 added lines, -15 removed lines

@@ -85,7 +85,7 @@ 
             throw new AuthFailedException($message);
         }
 
-        if(!$this->stream) {
+        if (!$this->stream) {
             $errors = \imap_errors();
             $message = implode("; ", (is_array($errors) ? $errors : array()));
             throw new AuthFailedException($message);
@@ -116,7 +116,7 @@ 
         if (!$this->cert_validation) {
             $address .= '/novalidate-cert';
         }
-        if (in_array($this->encryption,['tls', 'notls', 'ssl'])) {
+        if (in_array($this->encryption, ['tls', 'notls', 'ssl'])) {
             $address .= '/'.$this->encryption;
         } elseif ($this->encryption === "starttls") {
             $address .= '/tls';
@@ -144,7 +144,7 @@ 
      *
      * @return bool
      */
-    public function connected(){
+    public function connected() {
         return !$this->stream;
     }
 
@@ -210,7 +210,7 @@ 
      *
      * @return array
      */
-    public function headers($uids, $rfc = "RFC822"){
+    public function headers($uids, $rfc = "RFC822") {
         $headers = \imap_fetchheader($this->stream, $uids[0], IMAP::FT_UID);
         return [$uids[0] => $headers];
     }
@@ -221,13 +221,13 @@ 
      *
      * @return array
      */
-    public function flags($uids){
+    public function flags($uids) {
         $flags = \imap_fetch_overview($this->stream, $uids[0], IMAP::FT_UID);
         $result = [];
         if (is_array($flags) && isset($flags[0])) {
             $flags = (array) $flags[0];
-            foreach($flags as $flag => $value) {
-                if ($value === 1 && in_array($flag, ["size", "uid", "msgno", "update"]) === false){
+            foreach ($flags as $flag => $value) {
+                if ($value === 1 && in_array($flag, ["size", "uid", "msgno", "update"]) === false) {
                     $result[] = "\\".ucfirst($flag);
                 }
             }
@@ -245,7 +245,7 @@ 
         if ($id === null) {
             $overview = $this->overview("1:*");
             $uids = [];
-            foreach($overview as $set){
+            foreach ($overview as $set) {
                 $uids[$set->msgno] = $set->uid;
             }
             return $uids;
@@ -285,12 +285,12 @@ 
         $result = [];
 
         $items = \imap_getmailboxes($this->stream, $this->getAddress(), $reference.$folder);
-        if(is_array($items)){
+        if (is_array($items)) {
             foreach ($items as $item) {
                 $name = $this->decodeFolderName($item->name);
                 $result[$name] = ['delimiter' => $item->delimiter, 'flags' => []];
             }
-        }else{
+        }else {
             throw new RuntimeException(\imap_last_error());
         }
 
@@ -311,9 +311,9 @@ 
     public function store(array $flags, $from, $to = null, $mode = null, $silent = true) {
         $flag = "\\".trim(is_array($flags) ? implode(" \\", $flags) : $flags);
 
-        if ($mode == "+"){
+        if ($mode == "+") {
             $status = \imap_setflag_full($this->stream, $from, $flag, IMAP::SE_UID);
-        }else{
+        }else {
             $status = \imap_clearflag_full($this->stream, $from, $flag, IMAP::SE_UID);
         }
 
@@ -335,7 +335,7 @@ 
      */
     public function appendMessage($folder, $message, $flags = null, $date = null) {
         if ($date != null) {
-            if ($date instanceof \Carbon\Carbon){
+            if ($date instanceof \Carbon\Carbon) {
                 $date = $date->format('d-M-Y H:i:s O');
             }
             return \imap_append($this->stream, $folder, $message, $flags, $date);
@@ -457,14 +457,14 @@ 
     /**
      * Enable the debug mode
      */
-    public function enableDebug(){
+    public function enableDebug() {
         $this->debug = true;
     }
 
     /**
      * Disable the debug mode
      */
-    public function disableDebug(){
+    public function disableDebug() {
         $this->debug = false;
     }
 

src/Connection/Protocols/ImapProtocol.php

Spacing +41 added lines, -41 removed lines

@@ -82,7 +82,7 @@ 
      * @throws ConnectionFailedException
      * @throws RuntimeException
      */
-    protected function enableTls(){
+    protected function enableTls() {
         $response = $this->requestAndResponse('STARTTLS');
         $result = $response && stream_socket_enable_crypto($this->stream, true, $this->getCryptoMethod());
         if (!$result) {
@@ -144,7 +144,7 @@ 
         $stack = [];
 
         //  replace any trailing <NL> including spaces with a single space
-        $line = rtrim($line) . ' ';
+        $line = rtrim($line).' ';
         while (($pos = strpos($line, ' ')) !== false) {
             $token = substr($line, 0, $pos);
             if (!strlen($token)) {
@@ -174,11 +174,11 @@ 
                     if (strlen($token) > $chars) {
                         $line = substr($token, $chars);
                         $token = substr($token, 0, $chars);
-                    } else {
+                    }else {
                         $line .= $this->nextLine();
                     }
                     $tokens[] = $token;
-                    $line = trim($line) . ' ';
+                    $line = trim($line).' ';
                     continue;
                 }
             }
@@ -228,7 +228,7 @@ 
         $line = $this->nextTaggedLine($tag); // get next tag
         if (!$dontParse) {
             $tokens = $this->decodeLine($line);
-        } else {
+        }else {
             $tokens = $line;
         }
 
@@ -255,9 +255,9 @@ 
             // last to chars are still needed for response code
             $tokens = [substr($tokens, 0, 2)];
         }
-        if (is_array($lines)){
+        if (is_array($lines)) {
             if ($this->debug) echo "<< ".json_encode($lines)."\n";
-        }else{
+        }else {
             if ($this->debug) echo "<< ".$lines."\n";
         }
         // last line has response code
@@ -280,27 +280,27 @@ 
     public function sendRequest($command, $tokens = [], &$tag = null) {
         if (!$tag) {
             $this->noun++;
-            $tag = 'TAG' . $this->noun;
+            $tag = 'TAG'.$this->noun;
         }
 
-        $line = $tag . ' ' . $command;
+        $line = $tag.' '.$command;
 
         foreach ($tokens as $token) {
             if (is_array($token)) {
-                if (fwrite($this->stream, $line . ' ' . $token[0] . "\r\n") === false) {
+                if (fwrite($this->stream, $line.' '.$token[0]."\r\n") === false) {
                     throw new RuntimeException('failed to write - connection closed?');
                 }
                 if (!$this->assumedNextLine('+ ')) {
                     throw new RuntimeException('failed to send literal string');
                 }
                 $line = $token[1];
-            } else {
-                $line .= ' ' . $token;
+            }else {
+                $line .= ' '.$token;
             }
         }
         if ($this->debug) echo ">> ".$line."\n";
 
-        if (fwrite($this->stream, $line . "\r\n") === false) {
+        if (fwrite($this->stream, $line."\r\n") === false) {
             throw new RuntimeException('failed to write - connection closed?');
         }
     }
@@ -330,9 +330,9 @@ 
     public function escapeString($string) {
         if (func_num_args() < 2) {
             if (strpos($string, "\n") !== false) {
-                return ['{' . strlen($string) . '}', $string];
-            } else {
-                return '"' . str_replace(['\\', '"'], ['\\\\', '\\"'], $string) . '"';
+                return ['{'.strlen($string).'}', $string];
+            }else {
+                return '"'.str_replace(['\\', '"'], ['\\\\', '\\"'], $string).'"';
             }
         }
         $result = [];
@@ -357,7 +357,7 @@ 
             }
             $result[] = $this->escapeList($v);
         }
-        return '(' . implode(' ', $result) . ')';
+        return '('.implode(' ', $result).')';
     }
 
     /**
@@ -397,12 +397,12 @@ 
                     error_log("got an extra server challenge: $response");
                     // respond with an empty response.
                     $this->sendRequest('');
-                } else {
+                }else {
                     if (preg_match('/^NO /i', $response) ||
                         preg_match('/^BAD /i', $response)) {
                         error_log("got failure response: $response");
                         return false;
-                    } else if (preg_match("/^OK /i", $response)) {
+                    }else if (preg_match("/^OK /i", $response)) {
                         return true;
                     }
                 }
@@ -435,7 +435,7 @@ 
      *
      * @return bool
      */
-    public function connected(){
+    public function connected() {
         return (boolean) $this->stream;
     }
 
@@ -482,10 +482,10 @@ 
                     $result[strtolower($tokens[1])] = $tokens[0];
                     break;
                 case '[UIDVALIDITY':
-                    $result['uidvalidity'] = (int)$tokens[2];
+                    $result['uidvalidity'] = (int) $tokens[2];
                     break;
                 case '[UIDNEXT':
-                    $result['uidnext'] = (int)$tokens[2];
+                    $result['uidnext'] = (int) $tokens[2];
                     break;
                 default:
                     // ignore
@@ -539,17 +539,17 @@ 
         if (is_array($from)) {
             $set = implode(',', $from);
         } elseif ($to === null) {
-            $set = (int)$from;
+            $set = (int) $from;
         } elseif ($to === INF) {
-            $set = (int)$from . ':*';
-        } else {
-            $set = (int)$from . ':' . (int)$to;
+            $set = (int) $from.':*';
+        }else {
+            $set = (int) $from.':'.(int) $to;
         }
 
-        $items = (array)$items;
+        $items = (array) $items;
         $itemList = $this->escapeList($items);
 
-        $this->sendRequest(($uid ? 'UID ' : '') . 'FETCH', [$set, $itemList], $tag);
+        $this->sendRequest(($uid ? 'UID ' : '').'FETCH', [$set, $itemList], $tag);
 
         $result = [];
         $tokens = null; // define $tokens variable before first use
@@ -564,7 +564,7 @@ 
                 $count = count($tokens[2]);
                 if ($tokens[2][$count - 2] == 'UID') {
                     $uidKey = $count - 1;
-                } else {
+                }else {
                     $uidKey = array_search('UID', $tokens[2]) + 1;
                 }
             }
@@ -580,7 +580,7 @@ 
                     $data = $tokens[2][1];
                 } elseif ($uid && $tokens[2][2] == $items[0]) {
                     $data = $tokens[2][3];
-                } else {
+                }else {
                     // maybe the server send an other field we didn't wanted
                     $count = count($tokens[2]);
                     // we start with 2, because 0 was already checked
@@ -592,7 +592,7 @@ 
                         break;
                     }
                 }
-            } else {
+            }else {
                 $data = [];
                 while (key($tokens[2]) !== null) {
                     $data[current($tokens[2])] = next($tokens[2]);
@@ -637,7 +637,7 @@ 
      * @return array
      * @throws RuntimeException
      */
-    public function headers($uids, $rfc = "RFC822"){
+    public function headers($uids, $rfc = "RFC822") {
         return $this->fetch(["$rfc.HEADER"], $uids);
     }
 
@@ -648,7 +648,7 @@ 
      * @return array
      * @throws RuntimeException
      */
-    public function flags($uids){
+    public function flags($uids) {
         return $this->fetch(["FLAGS"], $uids);
     }
 
@@ -732,22 +732,22 @@ 
     public function store(array $flags, $from, $to = null, $mode = null, $silent = true) {
         $item = 'FLAGS';
         if ($mode == '+' || $mode == '-') {
-            $item = $mode . $item;
+            $item = $mode.$item;
         }
         if ($silent) {
             $item .= '.SILENT';
         }
 
         $flags = $this->escapeList($flags);
-        $set = (int)$from;
+        $set = (int) $from;
         if ($to !== null) {
-            $set .= ':' . ($to == INF ? '*' : (int)$to);
+            $set .= ':'.($to == INF ? '*' : (int) $to);
         }
 
         $result = $this->requestAndResponse('STORE', [$set, $item, $flags], $silent);
 
         if ($silent) {
-            return (bool)$result;
+            return (bool) $result;
         }
 
         $tokens = $result;
@@ -797,9 +797,9 @@ 
      * @throws RuntimeException
      */
     public function copyMessage($folder, $from, $to = null) {
-        $set = (int)$from;
+        $set = (int) $from;
         if ($to !== null) {
-            $set .= ':' . ($to == INF ? '*' : (int)$to);
+            $set .= ':'.($to == INF ? '*' : (int) $to);
         }
 
         return $this->requestAndResponse('COPY', [$set, $this->escapeString($folder)], true);
@@ -950,14 +950,14 @@ 
     /**
      * Enable the debug mode
      */
-    public function enableDebug(){
+    public function enableDebug() {
         $this->debug = true;
     }
 
     /**
      * Disable the debug mode
      */
-    public function disableDebug(){
+    public function disableDebug() {
         $this->debug = false;
     }
 }
\ No newline at end of file

src/Traits/HasEvents.php

Spacing +1 added lines, -1 removed lines

@@ -65,7 +65,7 @@
      *
      * @return array
      */
-    public function getEvents(){
+    public function getEvents() {
         return $this->events;
     }
 

src/Query/Query.php

Spacing +17 added lines, -17 removed lines

@@ -73,7 +73,7 @@ 
     public function __construct(Client $client, $charset = 'UTF-8') {
         $this->setClient($client);
 
-        if(ClientManager::get('options.fetch') === IMAP::FT_PEEK) $this->leaveUnread();
+        if (ClientManager::get('options.fetch') === IMAP::FT_PEEK) $this->leaveUnread();
 
         $this->date_format = ClientManager::get('date_format', 'd M y');
 
@@ -85,7 +85,7 @@ 
     /**
      * Instance boot method for additional functionality
      */
-    protected function boot(){}
+    protected function boot() {}
 
     /**
      * Parse a given value
@@ -93,8 +93,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;
@@ -111,7 +111,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);
@@ -150,7 +150,7 @@ 
      * @return Collection
      * @throws GetMessagesFailedException
      */
-    protected function search(){
+    protected function search() {
         $this->generate_query();
 
         try {
@@ -195,15 +195,15 @@ 
 
                 $options = ClientManager::get('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) {
                     $message = $query->getMessage($msgno, $msglist);
-                    switch ($options['message_key']){
+                    switch ($options['message_key']) {
                         case 'number':
                             $message_key = $message->getMessageNo();
                             break;
@@ -221,7 +221,7 @@ 
 
             return $messages;
         } catch (\Exception $e) {
-            throw new GetMessagesFailedException($e->getMessage(),0, $e);
+            throw new GetMessagesFailedException($e->getMessage(), 0, $e);
         }
     }
 
@@ -237,7 +237,7 @@ 
      * @throws MessageContentFetchingException
      * @throws MessageHeaderFetchingException
      */
-    public function getMessage($msgno, $msglist = null){
+    public function getMessage($msgno, $msglist = null) {
         return new Message($msgno, $msglist, $this->getClient(), $this->getFetchOptions(), $this->getFetchBody(), $this->getFetchFlags());
     }
 
@@ -250,7 +250,7 @@ 
      * @return 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;
 
@@ -261,7 +261,7 @@ 
             $messages->each(function($message) use(&$collection){
                 $collection[] = $message;
             });
-        }else{
+        }else {
             $collection = array_fill(0, $messages->total(), true);
         }
 
@@ -278,10 +278,10 @@ 
         $this->query->each(function($statement) use(&$query) {
             if (count($statement) == 1) {
                 $query .= $statement[0];
-            } else {
-                if($statement[1] === null){
+            }else {
+                if ($statement[1] === null) {
                     $query .= $statement[0];
-                }else{
+                }else {
                     $query .= $statement[0].' "'.$statement[1].'"';
                 }
             }
@@ -311,7 +311,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;

src/Query/WhereQuery.php

Spacing +16 added lines, -16 removed lines

@@ -76,18 +76,18 @@ 
 
         $name = Str::camel($name);
 
-        if(strtolower(substr($name, 0, 3)) === 'not') {
+        if (strtolower(substr($name, 0, 3)) === 'not') {
             $that = $that->whereNot();
             $name = substr($name, 3);
         }
 
-        if (strpos(strtolower($name), "where") === false){
+        if (strpos(strtolower($name), "where") === false) {
             $method = 'where'.ucfirst($name);
-        }else{
+        }else {
             $method = lcfirst($name);
         }
 
-        if(method_exists($this, $method) === true){
+        if (method_exists($this, $method) === true) {
             return call_user_func_array([$that, $method], $arguments);
         }
 
@@ -106,7 +106,7 @@ 
         if (substr($criteria, 0, 7) === "CUSTOM ") {
             return substr($criteria, 7);
         }
-        if(in_array($criteria, $this->available_criteria) === false) {
+        if (in_array($criteria, $this->available_criteria) === false) {
             throw new InvalidWhereQueryCriteriaException();
         }
 
@@ -121,20 +121,20 @@ 
      * @throws InvalidWhereQueryCriteriaException
      */
     public function where($criteria, $value = null) {
-        if(is_array($criteria)){
-            foreach($criteria as $key => $value){
-                if(is_numeric($key)){
+        if (is_array($criteria)) {
+            foreach ($criteria as $key => $value) {
+                if (is_numeric($key)) {
                     return $this->where($value);
                 }
                 return $this->where($key, $value);
             }
-        }else{
+        }else {
             $criteria = $this->validate_criteria($criteria);
             $value = $this->parse_value($value);
 
-            if($value === null || $value === ''){
+            if ($value === null || $value === '') {
                 $this->query->push([$criteria]);
-            }else{
+            }else {
                 $this->query->push([$criteria, $value]);
             }
         }
@@ -149,7 +149,7 @@ 
      */
     public function orWhere(\Closure $closure = null) {
         $this->query->push(['OR']);
-        if($closure !== null) $closure($this);
+        if ($closure !== null) $closure($this);
 
         return $this;
     }
@@ -161,7 +161,7 @@ 
      */
     public function andWhere(\Closure $closure = null) {
         $this->query->push(['AND']);
-        if($closure !== null) $closure($this);
+        if ($closure !== null) $closure($this);
 
         return $this;
     }
@@ -401,7 +401,7 @@ 
      * @return WhereQuery
      * @throws InvalidWhereQueryCriteriaException
      */
-    public function whereNoXSpam(){
+    public function whereNoXSpam() {
         return $this->where("CUSTOM X-Spam-Flag NO");
     }
 
@@ -409,7 +409,7 @@ 
      * @return WhereQuery
      * @throws InvalidWhereQueryCriteriaException
      */
-    public function whereIsXSpam(){
+    public function whereIsXSpam() {
         return $this->where("CUSTOM X-Spam-Flag YES");
     }
 
@@ -419,7 +419,7 @@ 
      * @return WhereQuery
      * @throws InvalidWhereQueryCriteriaException
      */
-    public function whereLanguage($country_code){
+    public function whereLanguage($country_code) {
         return $this->where("Content-Language $country_code");
     }
 }
\ No newline at end of file

src/ClientManager.php

Spacing +23 added lines, -23 removed lines

@@ -68,17 +68,17 @@ 
     public static function get($key, $default = null) {
         $parts = explode('.', $key);
         $value = null;
-        foreach($parts as $part) {
-            if($value === null) {
-                if(isset(self::$config[$part])) {
+        foreach ($parts as $part) {
+            if ($value === null) {
+                if (isset(self::$config[$part])) {
                     $value = self::$config[$part];
-                }else{
+                }else {
                     break;
                 }
-            }else{
-                if(isset($value[$part])) {
+            }else {
+                if (isset($value[$part])) {
                     $value = $value[$part];
-                }else{
+                }else {
                     break;
                 }
             }
@@ -171,7 +171,7 @@ 
      */
     public function setConfig($config) {
 
-        if(is_array($config) === false) {
+        if (is_array($config) === false) {
             $config = require $config;
         }
 
@@ -181,17 +181,17 @@ 
         $vendor_config = require $path;
         $config = $this->array_merge_recursive_distinct($vendor_config, $config);
 
-        if(is_array($config)){
-            if(isset($config['default'])){
-                if(isset($config['accounts']) && $config['default'] != false){
+        if (is_array($config)) {
+            if (isset($config['default'])) {
+                if (isset($config['accounts']) && $config['default'] != false) {
 
                     $default_config = $vendor_config['accounts']['default'];
-                    if(isset($config['accounts'][$config['default']])){
+                    if (isset($config['accounts'][$config['default']])) {
                         $default_config = array_merge($default_config, $config['accounts'][$config['default']]);
                     }
 
-                    if(is_array($config['accounts'])){
-                        foreach($config['accounts'] as $account_key => $account){
+                    if (is_array($config['accounts'])) {
+                        foreach ($config['accounts'] as $account_key => $account) {
                             $config['accounts'][$account_key] = array_merge($default_config, $account);
                         }
                     }
@@ -227,24 +227,24 @@ 
         $arrays = func_get_args();
         $base = array_shift($arrays);
 
-        if(!is_array($base)) $base = empty($base) ? array() : array($base);
+        if (!is_array($base)) $base = empty($base) ? array() : array($base);
 
-        foreach($arrays as $append) {
+        foreach ($arrays as $append) {
 
-            if(!is_array($append)) $append = array($append);
+            if (!is_array($append)) $append = array($append);
 
-            foreach($append as $key => $value) {
+            foreach ($append as $key => $value) {
 
-                if(!array_key_exists($key, $base) and !is_numeric($key)) {
+                if (!array_key_exists($key, $base) and !is_numeric($key)) {
                     $base[$key] = $append[$key];
                     continue;
                 }
 
-                if(is_array($value) or is_array($base[$key])) {
+                if (is_array($value) or is_array($base[$key])) {
                     $base[$key] = $this->array_merge_recursive_distinct($base[$key], $append[$key]);
-                } else if(is_numeric($key)) {
-                    if(!in_array($value, $base)) $base[] = $value;
-                } else {
+                }else if (is_numeric($key)) {
+                    if (!in_array($value, $base)) $base[] = $value;
+                }else {
                     $base[$key] = $value;
                 }