Webklex / php-imap

rector.php

Spacing +2 added lines, -2 removed lines

@@ -5,8 +5,8 @@
 use Rector\Config\RectorConfig;
 use Rector\Set\ValueObject\SetList;
 
-return static function (RectorConfig $containerConfigurator): void {
-    $containerConfigurator->paths([__DIR__ . '/src', __DIR__ . '/tests']);
+return static function(RectorConfig $containerConfigurator): void {
+    $containerConfigurator->paths([__DIR__.'/src', __DIR__.'/tests']);
 
     $containerConfigurator->import(SetList::PHP_54);
     $containerConfigurator->import(SetList::PHP_55);

src/Header.php

Spacing +23 added lines, -23 removed lines

@@ -95,7 +95,7 @@ 
 
         }
 
-        throw new MethodNotFoundException("Method " . self::class . '::' . $method . '() is not supported');
+        throw new MethodNotFoundException("Method ".self::class.'::'.$method.'() is not supported');
     }
 
     /**
@@ -130,20 +130,20 @@ 
         if (isset($this->attributes[$name]) && $strict === false) {
             if ($this->attributize) {
                 $this->attributes[$name]->add($value, true);
-            } else {
+            }else {
                 if (isset($this->attributes[$name])) {
                     if (!is_array($this->attributes[$name])) {
                         $this->attributes[$name] = [$this->attributes[$name], $value];
-                    } else {
+                    }else {
                         $this->attributes[$name][] = $value;
                     }
-                } else {
+                }else {
                     $this->attributes[$name] = $value;
                 }
             }
         } elseif (!$this->attributize) {
             $this->attributes[$name] = $value;
-        } else {
+        }else {
             $this->attributes[$name] = new Attribute($name, $value);
         }
 
@@ -235,7 +235,7 @@ 
         $headers = [];
         $imap_headers = [];
         if (extension_loaded('imap') && $this->config["rfc822"]) {
-            $raw_imap_headers = (array)imap_rfc822_parse_headers($this->raw);
+            $raw_imap_headers = (array) imap_rfc822_parse_headers($this->raw);
             foreach ($raw_imap_headers as $key => $values) {
                 $key = str_replace("-", "_", $key);
                 $imap_headers[$key] = $values;
@@ -263,11 +263,11 @@ 
                     }
                     if (is_array($headers[$prev_header])) {
                         $headers[$prev_header][] = $line;
-                    } else {
+                    }else {
                         $headers[$prev_header] .= $line;
                     }
                 }
-            } else {
+            }else {
                 if (($pos = strpos($line, ":")) > 0) {
                     $key = trim(rtrim(strtolower(substr($line, 0, $pos))));
                     $key = str_replace("-", "_", $key);
@@ -275,7 +275,7 @@ 
                     $value = trim(rtrim(substr($line, $pos + 1)));
                     if (isset($headers[$key])) {
                         $headers[$key][] = $value;
-                    } else {
+                    }else {
                         $headers[$key] = [$value];
                     }
                     $prev_header = $key;
@@ -294,7 +294,7 @@ 
                 case 'reply_to':
                 case 'sender':
                     $value = $this->decodeAddresses($values);
-                    $headers[$key . "address"] = implode(", ", $values);
+                    $headers[$key."address"] = implode(", ", $values);
                     break;
                 case 'subject':
                     $value = implode(" ", $values);
@@ -313,7 +313,7 @@ 
                             $value = implode(" ", $values);
                         } elseif ($available_values > 2) {
                             $value = array_values($values);
-                        } else {
+                        }else {
                             $value = "";
                         }
                     }
@@ -322,7 +322,7 @@ 
             $headers[$key] = $value;
         }
 
-        return (object)array_merge($headers, $imap_headers);
+        return (object) array_merge($headers, $imap_headers);
     }
 
     /**
@@ -338,7 +338,7 @@ 
             return imap_mime_header_decode($text);
         }
         $charset = $this->getEncoding($text);
-        return [(object)[
+        return [(object) [
             "charset" => $charset,
             "text"    => $this->convertEncoding($text, $charset)
         ]];
@@ -501,7 +501,7 @@ 
      */
     private function findPriority(): void {
         if (($priority = $this->get("x_priority")) === null) return;
-        switch ((int)"$priority") {
+        switch ((int) "$priority") {
             case IMAP::MESSAGE_PRIORITY_HIGHEST;
                 $priority = IMAP::MESSAGE_PRIORITY_HIGHEST;
                 break;
@@ -540,7 +540,7 @@ 
                     if (isset($parsed_address['address'])) {
                         $mail_address = explode('@', $parsed_address['address']);
                         if (count($mail_address) == 2) {
-                            $addresses[] = (object)[
+                            $addresses[] = (object) [
                                 "personal" => $parsed_address['display'] ?? '',
                                 "mailbox"  => $mail_address[0],
                                 "host"     => $mail_address[1],
@@ -568,7 +568,7 @@ 
                     $name = trim(rtrim($matches["name"]));
                     $email = trim(rtrim($matches["email"]));
                     [$mailbox, $host] = array_pad(explode("@", $email), 2, null);
-                    $addresses[] = (object)[
+                    $addresses[] = (object) [
                         "personal" => $name,
                         "mailbox"  => $mailbox,
                         "host"     => $host,
@@ -605,7 +605,7 @@ 
         }
 
         foreach ($list as $item) {
-            $address = (object)$item;
+            $address = (object) $item;
 
             if (!property_exists($address, 'mailbox')) {
                 $address->mailbox = false;
@@ -615,7 +615,7 @@ 
             }
             if (!property_exists($address, 'personal')) {
                 $address->personal = false;
-            } else {
+            }else {
                 $personalParts = $this->mime_header_decode($address->personal);
 
                 if (is_array($personalParts)) {
@@ -630,8 +630,8 @@ 
                 }
             }
 
-            $address->mail = ($address->mailbox && $address->host) ? $address->mailbox . '@' . $address->host : false;
-            $address->full = ($address->personal) ? $address->personal . ' <' . $address->mail . '>' : $address->mail;
+            $address->mail = ($address->mailbox && $address->host) ? $address->mailbox.'@'.$address->host : false;
+            $address->full = ($address->personal) ? $address->personal.' <'.$address->mail.'>' : $address->mail;
 
             $addresses[] = new Address($address);
         }
@@ -646,8 +646,8 @@ 
         foreach ($this->attributes as $key => $value) {
             if (is_array($value)) {
                 $value = implode(", ", $value);
-            } else {
-                $value = (string)$value;
+            }else {
+                $value = (string) $value;
             }
             // Only parse strings and don't parse any attributes like the user-agent
             if (($key == "user_agent") === false) {
@@ -726,7 +726,7 @@ 
                     $parsed_date = Carbon::parse($date);
                 } catch (Exception $_e) {
                     if (!isset($this->config["fallback_date"])) {
-                        throw new InvalidMessageDateException("Invalid message date. ID:" . $this->get("message_id") . " Date:" . $header->date . "/" . $date, 1100, $e);
+                        throw new InvalidMessageDateException("Invalid message date. ID:".$this->get("message_id")." Date:".$header->date."/".$date, 1100, $e);
                     }
                     $parsed_date = Carbon::parse($this->config["fallback_date"]);
                 }

src/Structure.php

Spacing +6 added lines, -6 removed lines

@@ -79,9 +79,9 @@ 
     public function findContentType(): void{
         $content_type = $this->header->get("content_type");
         $content_type = is_array($content_type) ? implode(' ', $content_type) : $content_type;
-        if(stripos($content_type, 'multipart') === 0) {
+        if (stripos($content_type, 'multipart') === 0) {
             $this->type = IMAP::MESSAGE_TYPE_MULTIPART;
-        }else{
+        }else {
             $this->type = IMAP::MESSAGE_TYPE_TEXT;
         }
     }
@@ -118,9 +118,9 @@ 
      * @throws InvalidMessageDateException
      */
     private function detectParts(string $boundary, string $context, int $part_number = 0): array {
-        $base_parts = explode( $boundary, $context);
+        $base_parts = explode($boundary, $context);
         $final_parts = [];
-        foreach($base_parts as $ctx) {
+        foreach ($base_parts as $ctx) {
             $ctx = substr($ctx, 2);
             if ($ctx !== "--" && $ctx != "") {
                 $parts = $this->parsePart($ctx, $part_number);
@@ -142,8 +142,8 @@ 
      * @throws InvalidMessageDateException
      */
     public function find_parts(): array {
-        if($this->type === IMAP::MESSAGE_TYPE_MULTIPART) {
-            if (($boundary = $this->header->getBoundary()) === null)  {
+        if ($this->type === IMAP::MESSAGE_TYPE_MULTIPART) {
+            if (($boundary = $this->header->getBoundary()) === null) {
                 throw new MessageContentFetchingException("no content found", 0);
             }
 

src/ClientManager.php

Spacing +23 added lines, -23 removed lines

@@ -76,17 +76,17 @@ 
     public static function get(string $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;
                 }
             }
@@ -174,7 +174,7 @@ 
      */
     public function setConfig($config): self {
 
-        if(is_array($config) === false) {
+        if (is_array($config) === false) {
             $config = require $config;
         }
 
@@ -184,17 +184,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);
                         }
                     }
@@ -233,20 +233,20 @@ 
             return array_keys($arr) !== range(0, count($arr) - 1);
         };
 
-        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] = $value;
                     continue;
                 }
 
-                if(
+                if (
                     (
                         is_array($value)
                         && $isAssoc($value)
@@ -260,9 +260,9 @@ 
                     // else merging $baseConfig['dispositions'] = ['attachment', 'inline'] with $customConfig['dispositions'] = ['attachment']
                     // results in $resultConfig['dispositions'] = ['attachment', 'inline']
                     $base[$key] = $this->array_merge_recursive_distinct($base[$key], $value);
-                } 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;
                 }
 

src/Connection/Protocols/Protocol.php

Spacing +1 added lines, -1 removed lines

@@ -246,7 +246,7 @@
         if (is_numeric($uid)) {
             return "";
         }
-        return (string)$uid;
+        return (string) $uid;
     }
 
     public function buildUIDCommand($command, $uid) : string {

src/Connection/Protocols/LegacyProtocol.php

Spacing +13 added lines, -13 removed lines

@@ -88,16 +88,16 @@ 
             throw new AuthFailedException($message);
         }
 
-        if(!$this->stream) {
+        if (!$this->stream) {
             $errors = \imap_errors();
             $message = implode("; ", (is_array($errors) ? $errors : array()));
             throw new AuthFailedException($message);
         }
 
         $errors = \imap_errors();
-        if(is_array($errors)) {
+        if (is_array($errors)) {
             $status = $this->examineFolder();
-            if($status['exists'] !== 0) {
+            if ($status['exists'] !== 0) {
                 $message = implode("; ", (is_array($errors) ? $errors : array()));
                 throw new RuntimeException($message);
             }
@@ -128,7 +128,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';
@@ -286,7 +286,7 @@ 
 
             $overview = $this->overview("1:*");
             $uids = [];
-            foreach($overview as $set){
+            foreach ($overview as $set) {
                 $uids[$set->msgno] = $set->uid;
             }
 
@@ -315,7 +315,7 @@ 
      * @return array
      */
     public function overview(string $sequence, $uid = IMAP::ST_UID): array {
-        return \imap_fetch_overview($this->stream, $sequence,$uid ? IMAP::ST_UID : IMAP::NIL);
+        return \imap_fetch_overview($this->stream, $sequence, $uid ? IMAP::ST_UID : IMAP::NIL);
     }
 
     /**
@@ -330,12 +330,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());
         }
 
@@ -358,9 +358,9 @@ 
     public function store(array $flags, int $from, $to = null, $mode = null, bool $silent = true, $uid = IMAP::ST_UID, $item = null) {
         $flag = trim(is_array($flags) ? implode(" ", $flags) : $flags);
 
-        if ($mode == "+"){
+        if ($mode == "+") {
             $status = \imap_setflag_full($this->stream, $from, $flag, $uid ? IMAP::ST_UID : IMAP::NIL);
-        }else{
+        }else {
             $status = \imap_clearflag_full($this->stream, $from, $flag, $uid ? IMAP::ST_UID : IMAP::NIL);
         }
 
@@ -382,7 +382,7 @@ 
      */
     public function appendMessage(string $folder, string $message, $flags = null, $date = null): bool {
         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);
@@ -414,7 +414,7 @@ 
      * @return array|bool Tokens if operation successful, false if an error occurred
      */
     public function copyManyMessages(array $messages, string $folder, $uid = IMAP::ST_UID) {
-        foreach($messages as $msg) {
+        foreach ($messages as $msg) {
             if ($this->copyMessage($folder, $msg, null, $uid) == false) {
                 return false;
             }
@@ -446,7 +446,7 @@ 
      * @return array|bool Tokens if operation successful, false if an error occurred
      */
     public function moveManyMessages(array $messages, string $folder, $uid = IMAP::ST_UID) {
-        foreach($messages as $msg) {
+        foreach ($messages as $msg) {
             if ($this->moveMessage($folder, $msg, null, $uid) == false) {
                 return false;
             }

src/Connection/Protocols/ImapProtocol.php

Spacing +31 added lines, -31 removed lines

@@ -151,7 +151,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)) {
@@ -181,11 +181,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;
                 }
             }
@@ -235,7 +235,7 @@ 
         $line = $this->nextTaggedLine($tag); // get next tag
         if (!$dontParse) {
             $tokens = $this->decodeLine($line);
-        } else {
+        }else {
             $tokens = $line;
         }
         if ($this->debug) echo "<< ".$line."\n";
@@ -287,27 +287,27 @@ 
     public function sendRequest(string $command, array $tokens = [], ?string &$tag = null): void {
         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?');
         }
     }
@@ -337,9 +337,9 @@ 
     public function escapeString($string) {
         if (func_num_args() < 2) {
             if (strpos($string, "\n") !== false) {
-                return ['{' . strlen($string) . '}', $string];
+                return ['{'.strlen($string).'}', $string];
             }
-            return '"' . str_replace(['\\', '"'], ['\\\\', '\\"'], $string) . '"';
+            return '"'.str_replace(['\\', '"'], ['\\\\', '\\"'], $string).'"';
         }
         $result = [];
         foreach (func_get_args() as $string) {
@@ -363,7 +363,7 @@ 
             }
             $result[] = $this->escapeList($v);
         }
-        return '(' . implode(' ', $result) . ')';
+        return '('.implode(' ', $result).')';
     }
 
     /**
@@ -404,7 +404,7 @@ 
                     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");
@@ -491,10 +491,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
@@ -551,14 +551,14 @@ 
         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($this->buildUIDCommand("FETCH", $uid), [$set, $itemList], $tag);
@@ -576,9 +576,9 @@ 
                 $count = is_countable($tokens[2]) ? count($tokens[2]) : 0;
                 if ($tokens[2][$count - 2] == 'UID') {
                     $uidKey = $count - 1;
-                } else if ($tokens[2][0] == 'UID') {
+                }else if ($tokens[2][0] == 'UID') {
                     $uidKey = 1;
-                } else {
+                }else {
                     $uidKey = array_search('UID', $tokens[2]) + 1;
                 }
             }
@@ -595,7 +595,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 = is_countable($tokens[2]) ? count($tokens[2]) : 0;
                     // we start with 2, because 0 was already checked
@@ -607,7 +607,7 @@ 
                         break;
                     }
                 }
-            } else {
+            }else {
                 $data = [];
                 while (key($tokens[2]) !== null) {
                     $data[current($tokens[2])] = next($tokens[2]);
@@ -624,7 +624,7 @@ 
             }
             if ($uid) {
                 $result[$tokens[2][$uidKey]] = $data;
-            }else{
+            }else {
                 $result[$tokens[0]] = $data;
             }
         }
@@ -690,7 +690,7 @@ 
 
         if ($this->enable_uid_cache && $this->uid_cache) {
             $uids = $this->uid_cache;
-        } else {
+        }else {
             try {
                 $uids = $this->fetch('UID', 1, INF);
                 $this->setUidCache($uids); // set cache for this folder
@@ -790,7 +790,7 @@ 
         $response = $this->requestAndResponse($command, [$set, $item, $flags], $silent);
 
         if ($silent) {
-            return (bool)$response;
+            return (bool) $response;
         }
 
         $result = [];
@@ -1094,7 +1094,7 @@ 
         $ids = [];
         foreach ($uids as $msgn => $v) {
             $id = $uid ? $v : $msgn;
-            if ( ($to >= $id && $from <= $id) || ($to === "*" && $from <= $id) ){
+            if (($to >= $id && $from <= $id) || ($to === "*" && $from <= $id)) {
                 $ids[] = $id;
             }
         }
@@ -1127,10 +1127,10 @@ 
      * @return int|string
      */
     public function buildSet($from, $to = null) {
-        $set = (int)$from;
+        $set = (int) $from;
         if ($to === null) {
             return $set;
         }
-        return $set . ':' . ($to == INF ? '*' : (int)$to);
+        return $set.':'.($to == INF ? '*' : (int) $to);
     }
 }

src/Part.php

Spacing +12 added lines, -12 removed lines

@@ -159,7 +159,7 @@ 
     protected function parse(): void {
         if ($this->header === null) {
             $body = $this->findHeaders();
-        }else{
+        }else {
             $body = $this->raw;
         }
 
@@ -171,11 +171,11 @@ 
         $this->name = $this->header->get("name");
         $this->filename = $this->header->get("filename");
 
-        if(!empty($this->header->get("id"))) {
+        if (!empty($this->header->get("id"))) {
             $this->id = $this->header->get("id");
-        } else if(!empty($this->header->get("x_attachment_id"))){
+        }else if (!empty($this->header->get("x_attachment_id"))) {
             $this->id = $this->header->get("x_attachment_id");
-        } else if(!empty($this->header->get("content_id"))){
+        }else if (!empty($this->header->get("content_id"))) {
             $this->id = strtr($this->header->get("content_id"), [
                 '<' => '',
                 '>' => ''
@@ -183,7 +183,7 @@ 
         }
 
         $content_types = $this->header->get("content_type");
-        if(!empty($content_types)){
+        if (!empty($content_types)) {
             $this->subtype = $this->parseSubtype($content_types);
             $content_type = $content_types;
             if (is_array($content_types)) {
@@ -223,16 +223,16 @@ 
      *
      * @return string
      */
-    private function parseSubtype($content_type){
+    private function parseSubtype($content_type) {
         if (is_array($content_type)) {
-            foreach ($content_type as $part){
-                if ((strpos($part, "/")) !== false){
+            foreach ($content_type as $part) {
+                if ((strpos($part, "/")) !== false) {
                     return $this->parseSubtype($part);
                 }
             }
             return null;
         }
-        if (($pos = strpos($content_type, "/")) !== false){
+        if (($pos = strpos($content_type, "/")) !== false) {
             return substr($content_type, $pos + 1);
         }
         return null;
@@ -243,7 +243,7 @@ 
      */
     private function parseDisposition(): void {
         $content_disposition = $this->header->get("content_disposition");
-        if($content_disposition !== null) {
+        if ($content_disposition !== null) {
             $this->ifdisposition = true;
             $this->disposition = (is_array($content_disposition)) ? implode(' ', $content_disposition) : $content_disposition;
         }
@@ -254,7 +254,7 @@ 
      */
     private function parseDescription(): void {
         $content_description = $this->header->get("content_description");
-        if($content_description !== null) {
+        if ($content_description !== null) {
             $this->ifdescription = true;
             $this->description = $content_description;
         }
@@ -265,7 +265,7 @@ 
      */
     private function parseEncoding(): void {
         $encoding = $this->header->get("content_transfer_encoding");
-        if($encoding !== null) {
+        if ($encoding !== null) {
             switch (strtolower($encoding)) {
                 case "quoted-printable":
                     $this->encoding = IMAP::MESSAGE_ENC_QUOTED_PRINTABLE;

src/Message.php

Spacing +26 added lines, -26 removed lines

@@ -168,7 +168,7 @@ 
         $this->boot();
 
         $default_mask = $client->getDefaultMessageMask();
-        if($default_mask != null) {
+        if ($default_mask != null) {
             $this->mask = $default_mask;
         }
         $this->events["message"] = $client->getDefaultEvents("message");
@@ -226,7 +226,7 @@ 
         $instance->boot();
 
         $default_mask = $client->getDefaultMessageMask();
-        if($default_mask != null) {
+        if ($default_mask != null) {
             $instance->setMask($default_mask);
         }
         $instance->setEvents([
@@ -276,7 +276,7 @@ 
         }
         if (strtolower(substr($method, 0, 3)) === 'set') {
             $name = Str::snake(substr($method, 3));
-            if(in_array($name, array_keys($this->attributes))) {
+            if (in_array($name, array_keys($this->attributes))) {
                 return $this->__set($name, array_pop($arguments));
             }
         }
@@ -314,7 +314,7 @@ 
      * @return Attribute|mixed|null
      */
     public function get($name) {
-        if(isset($this->attributes[$name])) {
+        if (isset($this->attributes[$name])) {
             return $this->attributes[$name];
         }
 
@@ -399,8 +399,8 @@ 
     public function parseRawFlags(array $raw_flags): void {
         $this->flags = FlagCollection::make([]);
 
-        foreach($raw_flags as $flag) {
-            if (strpos($flag, "\\") === 0){
+        foreach ($raw_flags as $flag) {
+            if (strpos($flag, "\\") === 0) {
                 $flag = substr($flag, 1);
             }
             $flag_key = strtolower($flag);
@@ -521,7 +521,7 @@ 
     private function fetchPart(Part $part): void {
         if ($part->isAttachment()) {
             $this->fetchAttachment($part);
-        }else{
+        }else {
             $encoding = $this->getEncoding($part);
 
             $content = $this->decodeString($part->content, $part->encoding);
@@ -546,7 +546,7 @@ 
 
             if (isset($this->bodies[$subtype])) {
                 $this->bodies[$subtype] .= "\n".$content;
-            }else{
+            }else {
                 $this->bodies[$subtype] = $content;
             }
         }
@@ -566,7 +566,7 @@ 
         }
         if ($oAttachment->getId() !== null) {
             $this->attachments->put($oAttachment->getId(), $oAttachment);
-        } else {
+        }else {
             $this->attachments->push($oAttachment);
         }
     }
@@ -712,9 +712,9 @@ 
                     return EncodingAliases::get($parameter->value, "ISO-8859-2");
                 }
             }
-        }elseif (property_exists($structure, 'charset')){
+        }elseif (property_exists($structure, 'charset')) {
             return EncodingAliases::get($structure->charset, "ISO-8859-2");
-        }elseif (is_string($structure) === true){
+        }elseif (is_string($structure) === true) {
             return mb_detect_encoding($structure);
         }
 
@@ -729,7 +729,7 @@ 
      * @throws Exceptions\FolderFetchingException
      * @throws Exceptions\RuntimeException
      */
-    public function getFolder(){
+    public function getFolder() {
         return $this->client->getFolderByPath($this->folder_path);
     }
 
@@ -745,13 +745,13 @@ 
      * @throws Exceptions\GetMessagesFailedException
      * @throws Exceptions\RuntimeException
      */
-    public function thread(Folder $sent_folder = null, MessageCollection &$thread = null, Folder $folder = null): MessageCollection {
+    public function thread(Folder $sent_folder = null, MessageCollection & $thread = null, Folder $folder = null): MessageCollection {
         $thread = $thread ?: MessageCollection::make([]);
-        $folder = $folder ?:  $this->getFolder();
+        $folder = $folder ?: $this->getFolder();
         $sent_folder = $sent_folder ?: $this->client->getFolderByPath(ClientManager::get("options.common_folders.sent", "INBOX/Sent"));
 
         /** @var Message $message */
-        foreach($thread as $message) {
+        foreach ($thread as $message) {
             if ($message->message_id->first() == $this->message_id->first()) {
                 return $thread;
             }
@@ -762,7 +762,7 @@ 
         $this->fetchThreadByInReplyTo($thread, $this->message_id, $sent_folder, $folder, $sent_folder);
 
         if (is_array($this->in_reply_to)) {
-            foreach($this->in_reply_to as $in_reply_to) {
+            foreach ($this->in_reply_to as $in_reply_to) {
                 $this->fetchThreadByMessageId($thread, $in_reply_to, $folder, $folder, $sent_folder);
                 $this->fetchThreadByMessageId($thread, $in_reply_to, $sent_folder, $folder, $sent_folder);
             }
@@ -784,7 +784,7 @@ 
      * @throws Exceptions\RuntimeException
      * @throws Exceptions\FolderFetchingException
      */
-    protected function fetchThreadByInReplyTo(MessageCollection &$thread, string $in_reply_to, Folder $primary_folder, Folder $secondary_folder, Folder $sent_folder): void{
+    protected function fetchThreadByInReplyTo(MessageCollection & $thread, string $in_reply_to, Folder $primary_folder, Folder $secondary_folder, Folder $sent_folder): void{
         $primary_folder->query()->inReplyTo($in_reply_to)
         ->setFetchBody($this->getFetchBodyOption())
         ->leaveUnread()->get()->each(function($message) use(&$thread, $secondary_folder, $sent_folder): void{
@@ -806,7 +806,7 @@ 
      * @throws Exceptions\RuntimeException
      * @throws Exceptions\FolderFetchingException
      */
-    protected function fetchThreadByMessageId(MessageCollection &$thread, string $message_id, Folder $primary_folder, Folder $secondary_folder, Folder $sent_folder): void{
+    protected function fetchThreadByMessageId(MessageCollection & $thread, string $message_id, Folder $primary_folder, Folder $secondary_folder, Folder $sent_folder): void{
         $primary_folder->query()->messageId($message_id)
         ->setFetchBody($this->getFetchBodyOption())
         ->leaveUnread()->get()->each(function($message) use(&$thread, $secondary_folder, $sent_folder): void{
@@ -901,13 +901,13 @@ 
      * @throws MessageHeaderFetchingException
      */
     protected function fetchNewMail(Folder $folder, int $next_uid, string $event, bool $expunge): Message {
-        if($expunge) $this->client->expunge();
+        if ($expunge) $this->client->expunge();
 
         $this->client->openFolder($folder->path);
 
         if ($this->sequence === IMAP::ST_UID) {
             $sequence_id = $next_uid;
-        }else{
+        }else {
             $sequence_id = $this->client->getConnection()->getMessageNumber($next_uid);
         }
 
@@ -937,11 +937,11 @@ 
      */
     public function delete(bool $expunge = true, string $trash_path = null, bool $force_move = false) {
         $status = $this->setFlag("Deleted");
-        if($force_move) {
+        if ($force_move) {
             $trash_path ??= $this->config["common_folders"]["trash"];
             $status = $this->move($trash_path);
         }
-        if($expunge) $this->client->expunge();
+        if ($expunge) $this->client->expunge();
 
         $event = $this->getEvent("message", "deleted");
         $event::dispatch($this);
@@ -961,7 +961,7 @@ 
      */
     public function restore(bool $expunge = true): bool {
         $status = $this->unsetFlag("Deleted");
-        if($expunge) $this->client->expunge();
+        if ($expunge) $this->client->expunge();
 
         $event = $this->getEvent("message", "restored");
         $event::dispatch($this);
@@ -1204,7 +1204,7 @@ 
      * @return $this
      */
     public function setMask(string $mask): self {
-        if(class_exists($mask)){
+        if (class_exists($mask)) {
             $this->mask = $mask;
         }
 
@@ -1229,7 +1229,7 @@ 
      */
     public function mask($mask = null): object {
         $mask ??= $this->mask;
-        if(class_exists($mask)){
+        if (class_exists($mask)) {
             return new $mask($this);
         }
 
@@ -1381,7 +1381,7 @@ 
         if ($this->getSequence() === IMAP::ST_UID) {
             $this->setUid($uid);
             $this->setMsglist($msglist);
-        }else{
+        }else {
             $this->setMsgn($uid, $msglist);
         }
     }