@@ -76,18 +76,18 @@ discard block |
||
76 | 76 | |
77 | 77 | $name = Str::camel($name); |
78 | 78 | |
79 | - if(strtolower(substr($name, 0, 3)) === 'not') { |
|
79 | + if (strtolower(substr($name, 0, 3)) === 'not') { |
|
80 | 80 | $that = $that->whereNot(); |
81 | 81 | $name = substr($name, 3); |
82 | 82 | } |
83 | 83 | |
84 | - if (strpos(strtolower($name), "where") === false){ |
|
84 | + if (strpos(strtolower($name), "where") === false) { |
|
85 | 85 | $method = 'where'.ucfirst($name); |
86 | - }else{ |
|
86 | + }else { |
|
87 | 87 | $method = lcfirst($name); |
88 | 88 | } |
89 | 89 | |
90 | - if(method_exists($this, $method) === true){ |
|
90 | + if (method_exists($this, $method) === true) { |
|
91 | 91 | return call_user_func_array([$that, $method], $arguments); |
92 | 92 | } |
93 | 93 | |
@@ -106,7 +106,7 @@ discard block |
||
106 | 106 | if (substr($criteria, 0, 7) === "CUSTOM ") { |
107 | 107 | return substr($criteria, 7); |
108 | 108 | } |
109 | - if(in_array($criteria, $this->available_criteria) === false) { |
|
109 | + if (in_array($criteria, $this->available_criteria) === false) { |
|
110 | 110 | throw new InvalidWhereQueryCriteriaException(); |
111 | 111 | } |
112 | 112 | |
@@ -121,20 +121,20 @@ discard block |
||
121 | 121 | * @throws InvalidWhereQueryCriteriaException |
122 | 122 | */ |
123 | 123 | public function where($criteria, $value = null) { |
124 | - if(is_array($criteria)){ |
|
125 | - foreach($criteria as $key => $value){ |
|
126 | - if(is_numeric($key)){ |
|
124 | + if (is_array($criteria)) { |
|
125 | + foreach ($criteria as $key => $value) { |
|
126 | + if (is_numeric($key)) { |
|
127 | 127 | return $this->where($value); |
128 | 128 | } |
129 | 129 | return $this->where($key, $value); |
130 | 130 | } |
131 | - }else{ |
|
131 | + }else { |
|
132 | 132 | $criteria = $this->validate_criteria($criteria); |
133 | 133 | $value = $this->parse_value($value); |
134 | 134 | |
135 | - if($value === null || $value === ''){ |
|
135 | + if ($value === null || $value === '') { |
|
136 | 136 | $this->query->push([$criteria]); |
137 | - }else{ |
|
137 | + }else { |
|
138 | 138 | $this->query->push([$criteria, $value]); |
139 | 139 | } |
140 | 140 | } |
@@ -149,7 +149,7 @@ discard block |
||
149 | 149 | */ |
150 | 150 | public function orWhere(\Closure $closure = null) { |
151 | 151 | $this->query->push(['OR']); |
152 | - if($closure !== null) $closure($this); |
|
152 | + if ($closure !== null) $closure($this); |
|
153 | 153 | |
154 | 154 | return $this; |
155 | 155 | } |
@@ -161,7 +161,7 @@ discard block |
||
161 | 161 | */ |
162 | 162 | public function andWhere(\Closure $closure = null) { |
163 | 163 | $this->query->push(['AND']); |
164 | - if($closure !== null) $closure($this); |
|
164 | + if ($closure !== null) $closure($this); |
|
165 | 165 | |
166 | 166 | return $this; |
167 | 167 | } |
@@ -401,7 +401,7 @@ discard block |
||
401 | 401 | * @return WhereQuery |
402 | 402 | * @throws InvalidWhereQueryCriteriaException |
403 | 403 | */ |
404 | - public function whereNoXSpam(){ |
|
404 | + public function whereNoXSpam() { |
|
405 | 405 | return $this->where("CUSTOM X-Spam-Flag NO"); |
406 | 406 | } |
407 | 407 | |
@@ -409,7 +409,7 @@ discard block |
||
409 | 409 | * @return WhereQuery |
410 | 410 | * @throws InvalidWhereQueryCriteriaException |
411 | 411 | */ |
412 | - public function whereIsXSpam(){ |
|
412 | + public function whereIsXSpam() { |
|
413 | 413 | return $this->where("CUSTOM X-Spam-Flag YES"); |
414 | 414 | } |
415 | 415 | |
@@ -421,7 +421,7 @@ discard block |
||
421 | 421 | * @return WhereQuery |
422 | 422 | * @throws InvalidWhereQueryCriteriaException |
423 | 423 | */ |
424 | - public function whereHeader($header, $value){ |
|
424 | + public function whereHeader($header, $value) { |
|
425 | 425 | return $this->where("CUSTOM HEADER $header $value"); |
426 | 426 | } |
427 | 427 | |
@@ -432,7 +432,7 @@ discard block |
||
432 | 432 | * @return WhereQuery |
433 | 433 | * @throws InvalidWhereQueryCriteriaException |
434 | 434 | */ |
435 | - public function whereMessageId($messageId){ |
|
435 | + public function whereMessageId($messageId) { |
|
436 | 436 | return $this->whereHeader("Message-ID", $messageId); |
437 | 437 | } |
438 | 438 | |
@@ -443,7 +443,7 @@ discard block |
||
443 | 443 | * @return WhereQuery |
444 | 444 | * @throws InvalidWhereQueryCriteriaException |
445 | 445 | */ |
446 | - public function whereInReplyTo($messageId){ |
|
446 | + public function whereInReplyTo($messageId) { |
|
447 | 447 | return $this->whereHeader("In-Reply-To", $messageId); |
448 | 448 | } |
449 | 449 | |
@@ -453,7 +453,7 @@ discard block |
||
453 | 453 | * @return WhereQuery |
454 | 454 | * @throws InvalidWhereQueryCriteriaException |
455 | 455 | */ |
456 | - public function whereLanguage($country_code){ |
|
456 | + public function whereLanguage($country_code) { |
|
457 | 457 | return $this->where("Content-Language $country_code"); |
458 | 458 | } |
459 | 459 | } |
460 | 460 | \ No newline at end of file |
@@ -194,11 +194,11 @@ discard block |
||
194 | 194 | * @param array $config |
195 | 195 | * @param array $default_config |
196 | 196 | */ |
197 | - private function setAccountConfig($key, $config, $default_config){ |
|
197 | + private function setAccountConfig($key, $config, $default_config) { |
|
198 | 198 | $value = $this->default_account_config[$key]; |
199 | - if(isset($config[$key])) { |
|
199 | + if (isset($config[$key])) { |
|
200 | 200 | $value = $config[$key]; |
201 | - }elseif(isset($default_config[$key])) { |
|
201 | + }elseif (isset($default_config[$key])) { |
|
202 | 202 | $value = $default_config[$key]; |
203 | 203 | } |
204 | 204 | $this->$key = $value; |
@@ -210,9 +210,9 @@ discard block |
||
210 | 210 | */ |
211 | 211 | protected function setEventsFromConfig($config) { |
212 | 212 | $this->events = ClientManager::get("events"); |
213 | - if(isset($config['events'])){ |
|
214 | - if(isset($config['events'])) { |
|
215 | - foreach($config['events'] as $section => $events) { |
|
213 | + if (isset($config['events'])) { |
|
214 | + if (isset($config['events'])) { |
|
215 | + foreach ($config['events'] as $section => $events) { |
|
216 | 216 | $this->events[$section] = array_merge($this->events[$section], $events); |
217 | 217 | } |
218 | 218 | } |
@@ -226,45 +226,45 @@ discard block |
||
226 | 226 | * @throws MaskNotFoundException |
227 | 227 | */ |
228 | 228 | protected function setMaskFromConfig($config) { |
229 | - $default_config = ClientManager::get("masks"); |
|
229 | + $default_config = ClientManager::get("masks"); |
|
230 | 230 | |
231 | - if(isset($config['masks'])){ |
|
232 | - if(isset($config['masks']['message'])) { |
|
233 | - if(class_exists($config['masks']['message'])) { |
|
231 | + if (isset($config['masks'])) { |
|
232 | + if (isset($config['masks']['message'])) { |
|
233 | + if (class_exists($config['masks']['message'])) { |
|
234 | 234 | $this->default_message_mask = $config['masks']['message']; |
235 | - }else{ |
|
235 | + }else { |
|
236 | 236 | throw new MaskNotFoundException("Unknown mask provided: ".$config['masks']['message']); |
237 | 237 | } |
238 | - }else{ |
|
239 | - if(class_exists($default_config['message'])) { |
|
238 | + }else { |
|
239 | + if (class_exists($default_config['message'])) { |
|
240 | 240 | $this->default_message_mask = $default_config['message']; |
241 | - }else{ |
|
241 | + }else { |
|
242 | 242 | throw new MaskNotFoundException("Unknown mask provided: ".$default_config['message']); |
243 | 243 | } |
244 | 244 | } |
245 | - if(isset($config['masks']['attachment'])) { |
|
246 | - if(class_exists($config['masks']['attachment'])) { |
|
245 | + if (isset($config['masks']['attachment'])) { |
|
246 | + if (class_exists($config['masks']['attachment'])) { |
|
247 | 247 | $this->default_message_mask = $config['masks']['attachment']; |
248 | - }else{ |
|
248 | + }else { |
|
249 | 249 | throw new MaskNotFoundException("Unknown mask provided: ".$config['masks']['attachment']); |
250 | 250 | } |
251 | - }else{ |
|
252 | - if(class_exists($default_config['attachment'])) { |
|
251 | + }else { |
|
252 | + if (class_exists($default_config['attachment'])) { |
|
253 | 253 | $this->default_message_mask = $default_config['attachment']; |
254 | - }else{ |
|
254 | + }else { |
|
255 | 255 | throw new MaskNotFoundException("Unknown mask provided: ".$default_config['attachment']); |
256 | 256 | } |
257 | 257 | } |
258 | - }else{ |
|
259 | - if(class_exists($default_config['message'])) { |
|
258 | + }else { |
|
259 | + if (class_exists($default_config['message'])) { |
|
260 | 260 | $this->default_message_mask = $default_config['message']; |
261 | - }else{ |
|
261 | + }else { |
|
262 | 262 | throw new MaskNotFoundException("Unknown mask provided: ".$default_config['message']); |
263 | 263 | } |
264 | 264 | |
265 | - if(class_exists($default_config['attachment'])) { |
|
265 | + if (class_exists($default_config['attachment'])) { |
|
266 | 266 | $this->default_message_mask = $default_config['attachment']; |
267 | - }else{ |
|
267 | + }else { |
|
268 | 268 | throw new MaskNotFoundException("Unknown mask provided: ".$default_config['attachment']); |
269 | 269 | } |
270 | 270 | } |
@@ -329,7 +329,7 @@ discard block |
||
329 | 329 | $this->connection = new ImapProtocol($this->validate_cert, $this->encryption); |
330 | 330 | $this->connection->setConnectionTimeout($timeout); |
331 | 331 | $this->connection->setProxy($this->proxy); |
332 | - }else{ |
|
332 | + }else { |
|
333 | 333 | if (extension_loaded('imap') === false) { |
334 | 334 | throw new ConnectionFailedException("connection setup failed", 0, new ProtocolNotSupportedException($protocol." is an unsupported protocol")); |
335 | 335 | } |
@@ -442,7 +442,7 @@ discard block |
||
442 | 442 | $pattern = $parent_folder.($hierarchical ? '%' : '*'); |
443 | 443 | $items = $this->connection->folders('', $pattern); |
444 | 444 | |
445 | - if(is_array($items)){ |
|
445 | + if (is_array($items)) { |
|
446 | 446 | foreach ($items as $folder_name => $item) { |
447 | 447 | $folder = new Folder($this, $folder_name, $item["delimiter"], $item["flags"]); |
448 | 448 | |
@@ -457,7 +457,7 @@ discard block |
||
457 | 457 | } |
458 | 458 | |
459 | 459 | return $folders; |
460 | - }else{ |
|
460 | + }else { |
|
461 | 461 | throw new FolderFetchingException("failed to fetch any folders"); |
462 | 462 | } |
463 | 463 | } |
@@ -493,10 +493,10 @@ discard block |
||
493 | 493 | $this->checkConnection(); |
494 | 494 | $status = $this->connection->createFolder($folder); |
495 | 495 | |
496 | - if($expunge) $this->expunge(); |
|
496 | + if ($expunge) $this->expunge(); |
|
497 | 497 | |
498 | 498 | $folder = $this->getFolder($folder); |
499 | - if($status && $folder) { |
|
499 | + if ($status && $folder) { |
|
500 | 500 | $event = $this->getEvent("folder", "new"); |
501 | 501 | $event::dispatch($folder); |
502 | 502 | } |
@@ -521,7 +521,7 @@ discard block |
||
521 | 521 | * |
522 | 522 | * @return Folder |
523 | 523 | */ |
524 | - public function getFolderPath(){ |
|
524 | + public function getFolderPath() { |
|
525 | 525 | return $this->active_folder; |
526 | 526 | } |
527 | 527 | |
@@ -575,7 +575,7 @@ discard block |
||
575 | 575 | * |
576 | 576 | * @return int |
577 | 577 | */ |
578 | - public function getTimeout($type){ |
|
578 | + public function getTimeout($type) { |
|
579 | 579 | return $this->connection->getConnectionTimeout(); |
580 | 580 | } |
581 | 581 | |
@@ -584,7 +584,7 @@ discard block |
||
584 | 584 | * |
585 | 585 | * @return string |
586 | 586 | */ |
587 | - public function getDefaultMessageMask(){ |
|
587 | + public function getDefaultMessageMask() { |
|
588 | 588 | return $this->default_message_mask; |
589 | 589 | } |
590 | 590 | |
@@ -594,7 +594,7 @@ discard block |
||
594 | 594 | * |
595 | 595 | * @return array |
596 | 596 | */ |
597 | - public function getDefaultEvents($section){ |
|
597 | + public function getDefaultEvents($section) { |
|
598 | 598 | return $this->events[$section]; |
599 | 599 | } |
600 | 600 | |
@@ -606,7 +606,7 @@ discard block |
||
606 | 606 | * @throws MaskNotFoundException |
607 | 607 | */ |
608 | 608 | public function setDefaultMessageMask($mask) { |
609 | - if(class_exists($mask)) { |
|
609 | + if (class_exists($mask)) { |
|
610 | 610 | $this->default_message_mask = $mask; |
611 | 611 | |
612 | 612 | return $this; |
@@ -620,7 +620,7 @@ discard block |
||
620 | 620 | * |
621 | 621 | * @return string |
622 | 622 | */ |
623 | - public function getDefaultAttachmentMask(){ |
|
623 | + public function getDefaultAttachmentMask() { |
|
624 | 624 | return $this->default_attachment_mask; |
625 | 625 | } |
626 | 626 | |
@@ -632,7 +632,7 @@ discard block |
||
632 | 632 | * @throws MaskNotFoundException |
633 | 633 | */ |
634 | 634 | public function setDefaultAttachmentMask($mask) { |
635 | - if(class_exists($mask)) { |
|
635 | + if (class_exists($mask)) { |
|
636 | 636 | $this->default_attachment_mask = $mask; |
637 | 637 | |
638 | 638 | return $this; |
@@ -159,10 +159,10 @@ discard block |
||
159 | 159 | * |
160 | 160 | * @throws InvalidMessageDateException |
161 | 161 | */ |
162 | - protected function parse(){ |
|
162 | + protected function parse() { |
|
163 | 163 | if ($this->header === null) { |
164 | 164 | $body = $this->findHeaders(); |
165 | - }else{ |
|
165 | + }else { |
|
166 | 166 | $body = $this->raw; |
167 | 167 | } |
168 | 168 | |
@@ -174,11 +174,11 @@ discard block |
||
174 | 174 | $this->name = $this->header->get("name"); |
175 | 175 | $this->filename = $this->header->get("filename"); |
176 | 176 | |
177 | - if(!empty($this->header->get("id"))) { |
|
177 | + if (!empty($this->header->get("id"))) { |
|
178 | 178 | $this->id = $this->header->get("id"); |
179 | - } else if(!empty($this->header->get("x_attachment_id"))){ |
|
179 | + }else if (!empty($this->header->get("x_attachment_id"))) { |
|
180 | 180 | $this->id = $this->header->get("x_attachment_id"); |
181 | - } else if(!empty($this->header->get("content_id"))){ |
|
181 | + }else if (!empty($this->header->get("content_id"))) { |
|
182 | 182 | $this->id = strtr($this->header->get("content_id"), [ |
183 | 183 | '<' => '', |
184 | 184 | '>' => '' |
@@ -186,7 +186,7 @@ discard block |
||
186 | 186 | } |
187 | 187 | |
188 | 188 | $content_types = $this->header->get("content_type"); |
189 | - if(!empty($content_types)){ |
|
189 | + if (!empty($content_types)) { |
|
190 | 190 | $this->subtype = $this->parseSubtype($content_types); |
191 | 191 | $content_type = $content_types; |
192 | 192 | if (is_array($content_types)) { |
@@ -207,7 +207,7 @@ discard block |
||
207 | 207 | * @return string |
208 | 208 | * @throws InvalidMessageDateException |
209 | 209 | */ |
210 | - private function findHeaders(){ |
|
210 | + private function findHeaders() { |
|
211 | 211 | $body = $this->raw; |
212 | 212 | while (($pos = strpos($body, "\r\n")) > 0) { |
213 | 213 | $body = substr($body, $pos + 2); |
@@ -226,16 +226,16 @@ discard block |
||
226 | 226 | * |
227 | 227 | * @return string |
228 | 228 | */ |
229 | - private function parseSubtype($content_type){ |
|
229 | + private function parseSubtype($content_type) { |
|
230 | 230 | if (is_array($content_type)) { |
231 | - foreach ($content_type as $part){ |
|
232 | - if ((strpos($part, "/")) !== false){ |
|
231 | + foreach ($content_type as $part) { |
|
232 | + if ((strpos($part, "/")) !== false) { |
|
233 | 233 | return $this->parseSubtype($part); |
234 | 234 | } |
235 | 235 | } |
236 | 236 | return null; |
237 | 237 | } |
238 | - if (($pos = strpos($content_type, "/")) !== false){ |
|
238 | + if (($pos = strpos($content_type, "/")) !== false) { |
|
239 | 239 | return substr($content_type, $pos + 1); |
240 | 240 | } |
241 | 241 | return null; |
@@ -244,9 +244,9 @@ discard block |
||
244 | 244 | /** |
245 | 245 | * Try to parse the disposition if any is present |
246 | 246 | */ |
247 | - private function parseDisposition(){ |
|
247 | + private function parseDisposition() { |
|
248 | 248 | $content_disposition = $this->header->get("content_disposition"); |
249 | - if($content_disposition !== null) { |
|
249 | + if ($content_disposition !== null) { |
|
250 | 250 | $this->ifdisposition = true; |
251 | 251 | $this->disposition = (is_array($content_disposition)) ? implode(' ', $content_disposition) : $content_disposition; |
252 | 252 | } |
@@ -255,9 +255,9 @@ discard block |
||
255 | 255 | /** |
256 | 256 | * Try to parse the description if any is present |
257 | 257 | */ |
258 | - private function parseDescription(){ |
|
258 | + private function parseDescription() { |
|
259 | 259 | $content_description = $this->header->get("content_description"); |
260 | - if($content_description !== null) { |
|
260 | + if ($content_description !== null) { |
|
261 | 261 | $this->ifdescription = true; |
262 | 262 | $this->description = $content_description; |
263 | 263 | } |
@@ -266,9 +266,9 @@ discard block |
||
266 | 266 | /** |
267 | 267 | * Try to parse the encoding if any is present |
268 | 268 | */ |
269 | - private function parseEncoding(){ |
|
269 | + private function parseEncoding() { |
|
270 | 270 | $encoding = $this->header->get("content_transfer_encoding"); |
271 | - if($encoding !== null) { |
|
271 | + if ($encoding !== null) { |
|
272 | 272 | switch (strtolower($encoding)) { |
273 | 273 | case "quoted-printable": |
274 | 274 | $this->encoding = IMAP::MESSAGE_ENC_QUOTED_PRINTABLE; |
@@ -298,7 +298,7 @@ discard block |
||
298 | 298 | * |
299 | 299 | * @return bool |
300 | 300 | */ |
301 | - public function isAttachment(){ |
|
301 | + public function isAttachment() { |
|
302 | 302 | if ($this->type == IMAP::MESSAGE_TYPE_TEXT && |
303 | 303 | ($this->ifdisposition == 0 || |
304 | 304 | (empty($this->disposition) || !in_array(strtolower($this->disposition), ClientManager::get('options.dispositions'))) |
@@ -77,7 +77,7 @@ discard block |
||
77 | 77 | * @throws MessageContentFetchingException |
78 | 78 | * @throws InvalidMessageDateException |
79 | 79 | */ |
80 | - protected function parse(){ |
|
80 | + protected function parse() { |
|
81 | 81 | $this->findContentType(); |
82 | 82 | $this->parts = $this->find_parts(); |
83 | 83 | } |
@@ -85,13 +85,13 @@ discard block |
||
85 | 85 | /** |
86 | 86 | * Determine the message content type |
87 | 87 | */ |
88 | - public function findContentType(){ |
|
88 | + public function findContentType() { |
|
89 | 89 | |
90 | 90 | $content_type = $this->header->get("content_type"); |
91 | 91 | $content_type = (is_array($content_type)) ? implode(' ', $content_type) : $content_type; |
92 | - if(stripos($content_type, 'multipart') === 0) { |
|
92 | + if (stripos($content_type, 'multipart') === 0) { |
|
93 | 93 | $this->type = IMAP::MESSAGE_TYPE_MULTIPART; |
94 | - }else{ |
|
94 | + }else { |
|
95 | 95 | $this->type = IMAP::MESSAGE_TYPE_TEXT; |
96 | 96 | } |
97 | 97 | } |
@@ -99,7 +99,7 @@ discard block |
||
99 | 99 | /** |
100 | 100 | * Determine the message content type |
101 | 101 | */ |
102 | - public function getBoundary(){ |
|
102 | + public function getBoundary() { |
|
103 | 103 | $boundary = $this->header->find("/boundary=\"?([^\"]*)[\";\s]/"); |
104 | 104 | return str_replace('"', '', $boundary); |
105 | 105 | } |
@@ -111,9 +111,9 @@ discard block |
||
111 | 111 | * @throws MessageContentFetchingException |
112 | 112 | * @throws InvalidMessageDateException |
113 | 113 | */ |
114 | - public function find_parts(){ |
|
115 | - if($this->type === IMAP::MESSAGE_TYPE_MULTIPART) { |
|
116 | - if (($boundary = $this->getBoundary()) === null) { |
|
114 | + public function find_parts() { |
|
115 | + if ($this->type === IMAP::MESSAGE_TYPE_MULTIPART) { |
|
116 | + if (($boundary = $this->getBoundary()) === null) { |
|
117 | 117 | throw new MessageContentFetchingException("no content found", 0); |
118 | 118 | } |
119 | 119 | |
@@ -122,21 +122,21 @@ discard block |
||
122 | 122 | ]; |
123 | 123 | |
124 | 124 | if (preg_match("/boundary\=\"?(.*)\"?/", $this->raw, $match) == 1) { |
125 | - if(is_array($match[1])){ |
|
126 | - foreach($match[1] as $matched){ |
|
125 | + if (is_array($match[1])) { |
|
126 | + foreach ($match[1] as $matched) { |
|
127 | 127 | $boundaries[] = str_replace('"', '', $matched); |
128 | 128 | } |
129 | - }else{ |
|
130 | - if(!empty($match[1])) { |
|
129 | + }else { |
|
130 | + if (!empty($match[1])) { |
|
131 | 131 | $boundaries[] = str_replace('"', '', $match[1]); |
132 | 132 | } |
133 | 133 | } |
134 | 134 | } |
135 | 135 | |
136 | - $raw_parts = explode( $boundaries[0], str_replace($boundaries, $boundaries[0], $this->raw) ); |
|
136 | + $raw_parts = explode($boundaries[0], str_replace($boundaries, $boundaries[0], $this->raw)); |
|
137 | 137 | $parts = []; |
138 | 138 | $part_number = 0; |
139 | - foreach($raw_parts as $part) { |
|
139 | + foreach ($raw_parts as $part) { |
|
140 | 140 | $part = trim(rtrim($part)); |
141 | 141 | if ($part !== "--") { |
142 | 142 | $parts[] = new Part($part, null, $part_number); |
@@ -200,7 +200,7 @@ discard block |
||
200 | 200 | public function __construct($uid, $msglist, Client $client, $fetch_options = null, $fetch_body = false, $fetch_flags = false, $sequence = null) { |
201 | 201 | |
202 | 202 | $default_mask = $client->getDefaultMessageMask(); |
203 | - if($default_mask != null) { |
|
203 | + if ($default_mask != null) { |
|
204 | 204 | $this->mask = $default_mask; |
205 | 205 | } |
206 | 206 | $this->events["message"] = $client->getDefaultEvents("message"); |
@@ -224,7 +224,7 @@ discard block |
||
224 | 224 | if ($this->sequence === IMAP::ST_UID) { |
225 | 225 | $this->uid = $uid; |
226 | 226 | $this->msgn = $this->client->getConnection()->getMessageNumber($this->uid); |
227 | - }else{ |
|
227 | + }else { |
|
228 | 228 | $this->msgn = $uid; |
229 | 229 | $this->uid = $this->client->getConnection()->getUid($this->msgn); |
230 | 230 | } |
@@ -264,13 +264,13 @@ discard block |
||
264 | 264 | * @throws MessageContentFetchingException |
265 | 265 | * @throws \ReflectionException |
266 | 266 | */ |
267 | - public static function make($uid, $msglist, Client $client, $raw_header, $raw_body, $raw_flags, $fetch_options = null, $sequence = null){ |
|
267 | + public static function make($uid, $msglist, Client $client, $raw_header, $raw_body, $raw_flags, $fetch_options = null, $sequence = null) { |
|
268 | 268 | $reflection = new \ReflectionClass(self::class); |
269 | 269 | /** @var self $instance */ |
270 | 270 | $instance = $reflection->newInstanceWithoutConstructor(); |
271 | 271 | |
272 | 272 | $default_mask = $client->getDefaultMessageMask(); |
273 | - if($default_mask != null) { |
|
273 | + if ($default_mask != null) { |
|
274 | 274 | $instance->setMask($default_mask); |
275 | 275 | } |
276 | 276 | $instance->setEvents([ |
@@ -289,7 +289,7 @@ discard block |
||
289 | 289 | if ($instance->getSequence() === IMAP::ST_UID) { |
290 | 290 | $instance->setUid($uid); |
291 | 291 | $instance->setMsglist($msglist); |
292 | - }else{ |
|
292 | + }else { |
|
293 | 293 | $instance->setMsgn($uid, $msglist); |
294 | 294 | } |
295 | 295 | |
@@ -317,13 +317,13 @@ discard block |
||
317 | 317 | * @throws MethodNotFoundException |
318 | 318 | */ |
319 | 319 | public function __call($method, $arguments) { |
320 | - if(strtolower(substr($method, 0, 3)) === 'get') { |
|
320 | + if (strtolower(substr($method, 0, 3)) === 'get') { |
|
321 | 321 | $name = Str::snake(substr($method, 3)); |
322 | 322 | return $this->get($name); |
323 | 323 | }elseif (strtolower(substr($method, 0, 3)) === 'set') { |
324 | 324 | $name = Str::snake(substr($method, 3)); |
325 | 325 | |
326 | - if(in_array($name, array_keys($this->attributes))) { |
|
326 | + if (in_array($name, array_keys($this->attributes))) { |
|
327 | 327 | $this->attributes[$name] = array_pop($arguments); |
328 | 328 | |
329 | 329 | return $this->attributes[$name]; |
@@ -364,7 +364,7 @@ discard block |
||
364 | 364 | * @return mixed|null |
365 | 365 | */ |
366 | 366 | public function get($name) { |
367 | - if(isset($this->attributes[$name])) { |
|
367 | + if (isset($this->attributes[$name])) { |
|
368 | 368 | return $this->attributes[$name]; |
369 | 369 | } |
370 | 370 | |
@@ -438,7 +438,7 @@ discard block |
||
438 | 438 | * |
439 | 439 | * @throws InvalidMessageDateException |
440 | 440 | */ |
441 | - public function parseRawHeader($raw_header){ |
|
441 | + public function parseRawHeader($raw_header) { |
|
442 | 442 | $this->header = new Header($raw_header); |
443 | 443 | } |
444 | 444 | |
@@ -449,8 +449,8 @@ discard block |
||
449 | 449 | public function parseRawFlags($raw_flags) { |
450 | 450 | $this->flags = FlagCollection::make([]); |
451 | 451 | |
452 | - foreach($raw_flags as $flag) { |
|
453 | - if (strpos($flag, "\\") === 0){ |
|
452 | + foreach ($raw_flags as $flag) { |
|
453 | + if (strpos($flag, "\\") === 0) { |
|
454 | 454 | $flag = substr($flag, 1); |
455 | 455 | } |
456 | 456 | $flag_key = strtolower($flag); |
@@ -553,7 +553,7 @@ discard block |
||
553 | 553 | |
554 | 554 | if ($part->isAttachment()) { |
555 | 555 | $this->fetchAttachment($part); |
556 | - }else{ |
|
556 | + }else { |
|
557 | 557 | $encoding = $this->getEncoding($part); |
558 | 558 | |
559 | 559 | $content = $this->decodeString($part->content, $part->encoding); |
@@ -591,7 +591,7 @@ discard block |
||
591 | 591 | if ($oAttachment->getName() !== null && $oAttachment->getSize() > 0) { |
592 | 592 | if ($oAttachment->getId() !== null) { |
593 | 593 | $this->attachments->put($oAttachment->getId(), $oAttachment); |
594 | - } else { |
|
594 | + }else { |
|
595 | 595 | $this->attachments->push($oAttachment); |
596 | 596 | } |
597 | 597 | } |
@@ -725,7 +725,7 @@ discard block |
||
725 | 725 | |
726 | 726 | if (function_exists('iconv') && $from != 'UTF-7' && $to != 'UTF-7') { |
727 | 727 | return @iconv($from, $to.'//IGNORE', $str); |
728 | - } else { |
|
728 | + }else { |
|
729 | 729 | if (!$from) { |
730 | 730 | return mb_convert_encoding($str, $to); |
731 | 731 | } |
@@ -746,9 +746,9 @@ discard block |
||
746 | 746 | return EncodingAliases::get($parameter->value); |
747 | 747 | } |
748 | 748 | } |
749 | - }elseif (property_exists($structure, 'charset')){ |
|
749 | + }elseif (property_exists($structure, 'charset')) { |
|
750 | 750 | return EncodingAliases::get($structure->charset); |
751 | - }elseif (is_string($structure) === true){ |
|
751 | + }elseif (is_string($structure) === true) { |
|
752 | 752 | return mb_detect_encoding($structure); |
753 | 753 | } |
754 | 754 | |
@@ -762,7 +762,7 @@ discard block |
||
762 | 762 | * @throws Exceptions\ConnectionFailedException |
763 | 763 | * @throws Exceptions\FolderFetchingException |
764 | 764 | */ |
765 | - public function getFolder(){ |
|
765 | + public function getFolder() { |
|
766 | 766 | return $this->client->getFolder($this->folder_path); |
767 | 767 | } |
768 | 768 | |
@@ -777,13 +777,13 @@ discard block |
||
777 | 777 | * @throws Exceptions\FolderFetchingException |
778 | 778 | * @throws Exceptions\GetMessagesFailedException |
779 | 779 | */ |
780 | - public function thread($sent_folder = null, &$thread = null, $folder = null){ |
|
780 | + public function thread($sent_folder = null, &$thread = null, $folder = null) { |
|
781 | 781 | $thread = $thread ? $thread : MessageCollection::make([]); |
782 | - $folder = $folder ? $folder : $this->getFolder(); |
|
782 | + $folder = $folder ? $folder : $this->getFolder(); |
|
783 | 783 | $sent_folder = $sent_folder ? $sent_folder : $this->client->getFolder(ClientManager::get("options.common_folders.sent", "INBOX/Sent")); |
784 | 784 | |
785 | 785 | /** @var Message $message */ |
786 | - foreach($thread as $message) { |
|
786 | + foreach ($thread as $message) { |
|
787 | 787 | if ($message->message_id == $this->message_id) { |
788 | 788 | return $thread; |
789 | 789 | } |
@@ -804,7 +804,7 @@ discard block |
||
804 | 804 | }); |
805 | 805 | |
806 | 806 | if (is_array($this->in_reply_to)) { |
807 | - foreach($this->in_reply_to as $in_reply_to) { |
|
807 | + foreach ($this->in_reply_to as $in_reply_to) { |
|
808 | 808 | $folder->query()->messageId($in_reply_to) |
809 | 809 | ->setFetchBody($this->getFetchBodyOption()) |
810 | 810 | ->leaveUnread()->get()->each(function($message) use(&$thread, $folder, $sent_folder){ |
@@ -849,13 +849,13 @@ discard block |
||
849 | 849 | |
850 | 850 | $this->client->openFolder($this->folder_path); |
851 | 851 | if ($this->client->getConnection()->copyMessage($folder->path, $this->getSequenceId(), null, $this->sequence === IMAP::ST_UID) == true) { |
852 | - if($expunge) $this->client->expunge(); |
|
852 | + if ($expunge) $this->client->expunge(); |
|
853 | 853 | |
854 | 854 | $this->client->openFolder($folder->path); |
855 | 855 | |
856 | 856 | if ($this->sequence === IMAP::ST_UID) { |
857 | 857 | $sequence_id = $next_uid; |
858 | - }else{ |
|
858 | + }else { |
|
859 | 859 | $sequence_id = $this->client->getConnection()->getMessageNumber($next_uid); |
860 | 860 | } |
861 | 861 | |
@@ -896,13 +896,13 @@ discard block |
||
896 | 896 | |
897 | 897 | $this->client->openFolder($this->folder_path); |
898 | 898 | if ($this->client->getConnection()->moveMessage($folder->path, $this->getSequenceId(), null, $this->sequence === IMAP::ST_UID) == true) { |
899 | - if($expunge) $this->client->expunge(); |
|
899 | + if ($expunge) $this->client->expunge(); |
|
900 | 900 | |
901 | 901 | $this->client->openFolder($folder->path); |
902 | 902 | |
903 | 903 | if ($this->sequence === IMAP::ST_UID) { |
904 | 904 | $sequence_id = $next_uid; |
905 | - }else{ |
|
905 | + }else { |
|
906 | 906 | $sequence_id = $this->client->getConnection()->getMessageNumber($next_uid); |
907 | 907 | } |
908 | 908 | |
@@ -928,7 +928,7 @@ discard block |
||
928 | 928 | */ |
929 | 929 | public function delete($expunge = true) { |
930 | 930 | $status = $this->setFlag("Deleted"); |
931 | - if($expunge) $this->client->expunge(); |
|
931 | + if ($expunge) $this->client->expunge(); |
|
932 | 932 | |
933 | 933 | $event = $this->getEvent("message", "deleted"); |
934 | 934 | $event::dispatch($this); |
@@ -947,7 +947,7 @@ discard block |
||
947 | 947 | */ |
948 | 948 | public function restore($expunge = true) { |
949 | 949 | $status = $this->unsetFlag("Deleted"); |
950 | - if($expunge) $this->client->expunge(); |
|
950 | + if ($expunge) $this->client->expunge(); |
|
951 | 951 | |
952 | 952 | $event = $this->getEvent("message", "restored"); |
953 | 953 | $event::dispatch($this); |
@@ -1102,7 +1102,7 @@ discard block |
||
1102 | 1102 | * |
1103 | 1103 | * @return Structure|null |
1104 | 1104 | */ |
1105 | - public function getStructure(){ |
|
1105 | + public function getStructure() { |
|
1106 | 1106 | return $this->structure; |
1107 | 1107 | } |
1108 | 1108 | |
@@ -1128,7 +1128,7 @@ discard block |
||
1128 | 1128 | * |
1129 | 1129 | * @return array |
1130 | 1130 | */ |
1131 | - public function getAttributes(){ |
|
1131 | + public function getAttributes() { |
|
1132 | 1132 | return array_merge($this->attributes, $this->header->getAttributes()); |
1133 | 1133 | } |
1134 | 1134 | |
@@ -1138,8 +1138,8 @@ discard block |
||
1138 | 1138 | * |
1139 | 1139 | * @return $this |
1140 | 1140 | */ |
1141 | - public function setMask($mask){ |
|
1142 | - if(class_exists($mask)){ |
|
1141 | + public function setMask($mask) { |
|
1142 | + if (class_exists($mask)) { |
|
1143 | 1143 | $this->mask = $mask; |
1144 | 1144 | } |
1145 | 1145 | |
@@ -1151,7 +1151,7 @@ discard block |
||
1151 | 1151 | * |
1152 | 1152 | * @return string |
1153 | 1153 | */ |
1154 | - public function getMask(){ |
|
1154 | + public function getMask() { |
|
1155 | 1155 | return $this->mask; |
1156 | 1156 | } |
1157 | 1157 | |
@@ -1162,9 +1162,9 @@ discard block |
||
1162 | 1162 | * @return mixed |
1163 | 1163 | * @throws MaskNotFoundException |
1164 | 1164 | */ |
1165 | - public function mask($mask = null){ |
|
1165 | + public function mask($mask = null) { |
|
1166 | 1166 | $mask = $mask !== null ? $mask : $this->mask; |
1167 | - if(class_exists($mask)){ |
|
1167 | + if (class_exists($mask)) { |
|
1168 | 1168 | return new $mask($this); |
1169 | 1169 | } |
1170 | 1170 | |
@@ -1177,7 +1177,7 @@ discard block |
||
1177 | 1177 | * |
1178 | 1178 | * @return $this |
1179 | 1179 | */ |
1180 | - public function setFolderPath($folder_path){ |
|
1180 | + public function setFolderPath($folder_path) { |
|
1181 | 1181 | $this->folder_path = $folder_path; |
1182 | 1182 | |
1183 | 1183 | return $this; |
@@ -1189,7 +1189,7 @@ discard block |
||
1189 | 1189 | * |
1190 | 1190 | * @return $this |
1191 | 1191 | */ |
1192 | - public function setConfig($config){ |
|
1192 | + public function setConfig($config) { |
|
1193 | 1193 | $this->config = $config; |
1194 | 1194 | |
1195 | 1195 | return $this; |
@@ -1201,7 +1201,7 @@ discard block |
||
1201 | 1201 | * |
1202 | 1202 | * @return $this |
1203 | 1203 | */ |
1204 | - public function setAttachments($attachments){ |
|
1204 | + public function setAttachments($attachments) { |
|
1205 | 1205 | $this->attachments = $attachments; |
1206 | 1206 | |
1207 | 1207 | return $this; |
@@ -1213,7 +1213,7 @@ discard block |
||
1213 | 1213 | * |
1214 | 1214 | * @return $this |
1215 | 1215 | */ |
1216 | - public function setFlags($flags){ |
|
1216 | + public function setFlags($flags) { |
|
1217 | 1217 | $this->flags = $flags; |
1218 | 1218 | |
1219 | 1219 | return $this; |
@@ -1226,7 +1226,7 @@ discard block |
||
1226 | 1226 | * @throws Exceptions\ConnectionFailedException |
1227 | 1227 | * @return $this |
1228 | 1228 | */ |
1229 | - public function setClient($client){ |
|
1229 | + public function setClient($client) { |
|
1230 | 1230 | $this->client = $client; |
1231 | 1231 | $this->client->openFolder($this->folder_path); |
1232 | 1232 | |
@@ -1241,7 +1241,7 @@ discard block |
||
1241 | 1241 | * @throws Exceptions\RuntimeException |
1242 | 1242 | * @return $this |
1243 | 1243 | */ |
1244 | - public function setUid($uid){ |
|
1244 | + public function setUid($uid) { |
|
1245 | 1245 | $this->uid = $uid; |
1246 | 1246 | $this->msgn = $this->client->getConnection()->getMessageNumber($this->uid); |
1247 | 1247 | $this->msglist = null; |
@@ -1258,7 +1258,7 @@ discard block |
||
1258 | 1258 | * @throws Exceptions\RuntimeException |
1259 | 1259 | * @return $this |
1260 | 1260 | */ |
1261 | - public function setMsgn($msgn, $msglist = null){ |
|
1261 | + public function setMsgn($msgn, $msglist = null) { |
|
1262 | 1262 | $this->msgn = $msgn; |
1263 | 1263 | $this->msglist = $msglist; |
1264 | 1264 | $this->uid = $this->client->getConnection()->getUid($this->msgn); |
@@ -1271,7 +1271,7 @@ discard block |
||
1271 | 1271 | * |
1272 | 1272 | * @return int |
1273 | 1273 | */ |
1274 | - public function getSequence(){ |
|
1274 | + public function getSequence() { |
|
1275 | 1275 | return $this->sequence; |
1276 | 1276 | } |
1277 | 1277 | |
@@ -1280,7 +1280,7 @@ discard block |
||
1280 | 1280 | * |
1281 | 1281 | * @return int |
1282 | 1282 | */ |
1283 | - public function getSequenceId(){ |
|
1283 | + public function getSequenceId() { |
|
1284 | 1284 | return $this->sequence === IMAP::ST_UID ? $this->uid : $this->msgn; |
1285 | 1285 | } |
1286 | 1286 | } |
@@ -87,7 +87,7 @@ discard block |
||
87 | 87 | throw new AuthFailedException($message); |
88 | 88 | } |
89 | 89 | |
90 | - if(!$this->stream) { |
|
90 | + if (!$this->stream) { |
|
91 | 91 | $errors = \imap_errors(); |
92 | 92 | $message = implode("; ", (is_array($errors) ? $errors : array())); |
93 | 93 | throw new AuthFailedException($message); |
@@ -118,7 +118,7 @@ discard block |
||
118 | 118 | if (!$this->cert_validation) { |
119 | 119 | $address .= '/novalidate-cert'; |
120 | 120 | } |
121 | - if (in_array($this->encryption,['tls', 'notls', 'ssl'])) { |
|
121 | + if (in_array($this->encryption, ['tls', 'notls', 'ssl'])) { |
|
122 | 122 | $address .= '/'.$this->encryption; |
123 | 123 | } elseif ($this->encryption === "starttls") { |
124 | 124 | $address .= '/tls'; |
@@ -146,7 +146,7 @@ discard block |
||
146 | 146 | * |
147 | 147 | * @return bool |
148 | 148 | */ |
149 | - public function connected(){ |
|
149 | + public function connected() { |
|
150 | 150 | return !$this->stream; |
151 | 151 | } |
152 | 152 | |
@@ -218,7 +218,7 @@ discard block |
||
218 | 218 | * |
219 | 219 | * @return array |
220 | 220 | */ |
221 | - public function headers($uids, $rfc = "RFC822", $uid = false){ |
|
221 | + public function headers($uids, $rfc = "RFC822", $uid = false) { |
|
222 | 222 | $result = []; |
223 | 223 | $uids = is_array($uids) ? $uids : [$uids]; |
224 | 224 | foreach ($uids as $uid) { |
@@ -234,7 +234,7 @@ discard block |
||
234 | 234 | * |
235 | 235 | * @return array |
236 | 236 | */ |
237 | - public function flags($uids, $uid = false){ |
|
237 | + public function flags($uids, $uid = false) { |
|
238 | 238 | $result = []; |
239 | 239 | $uids = is_array($uids) ? $uids : [$uids]; |
240 | 240 | foreach ($uids as $uid) { |
@@ -242,8 +242,8 @@ discard block |
||
242 | 242 | $flags = []; |
243 | 243 | if (is_array($raw_flags) && isset($raw_flags[0])) { |
244 | 244 | $raw_flags = (array) $raw_flags[0]; |
245 | - foreach($raw_flags as $flag => $value) { |
|
246 | - if ($value === 1 && in_array($flag, ["size", "uid", "msgno", "update"]) === false){ |
|
245 | + foreach ($raw_flags as $flag => $value) { |
|
246 | + if ($value === 1 && in_array($flag, ["size", "uid", "msgno", "update"]) === false) { |
|
247 | 247 | $flags[] = "\\".ucfirst($flag); |
248 | 248 | } |
249 | 249 | } |
@@ -264,7 +264,7 @@ discard block |
||
264 | 264 | if ($id === null) { |
265 | 265 | $overview = $this->overview("1:*"); |
266 | 266 | $uids = []; |
267 | - foreach($overview as $set){ |
|
267 | + foreach ($overview as $set) { |
|
268 | 268 | $uids[$set->msgno] = $set->uid; |
269 | 269 | } |
270 | 270 | return $uids; |
@@ -290,7 +290,7 @@ discard block |
||
290 | 290 | * @return array |
291 | 291 | */ |
292 | 292 | public function overview($sequence, $uid = false) { |
293 | - return \imap_fetch_overview($this->stream, $sequence,$uid ? IMAP::FT_UID : IMAP::NIL); |
|
293 | + return \imap_fetch_overview($this->stream, $sequence, $uid ? IMAP::FT_UID : IMAP::NIL); |
|
294 | 294 | } |
295 | 295 | |
296 | 296 | /** |
@@ -305,12 +305,12 @@ discard block |
||
305 | 305 | $result = []; |
306 | 306 | |
307 | 307 | $items = \imap_getmailboxes($this->stream, $this->getAddress(), $reference.$folder); |
308 | - if(is_array($items)){ |
|
308 | + if (is_array($items)) { |
|
309 | 309 | foreach ($items as $item) { |
310 | 310 | $name = $this->decodeFolderName($item->name); |
311 | 311 | $result[$name] = ['delimiter' => $item->delimiter, 'flags' => []]; |
312 | 312 | } |
313 | - }else{ |
|
313 | + }else { |
|
314 | 314 | throw new RuntimeException(\imap_last_error()); |
315 | 315 | } |
316 | 316 | |
@@ -332,9 +332,9 @@ discard block |
||
332 | 332 | public function store(array $flags, $from, $to = null, $mode = null, $silent = true, $uid = false) { |
333 | 333 | $flag = trim(is_array($flags) ? implode(" ", $flags) : $flags); |
334 | 334 | |
335 | - if ($mode == "+"){ |
|
335 | + if ($mode == "+") { |
|
336 | 336 | $status = \imap_setflag_full($this->stream, $from, $flag, $uid ? IMAP::FT_UID : IMAP::NIL); |
337 | - }else{ |
|
337 | + }else { |
|
338 | 338 | $status = \imap_clearflag_full($this->stream, $from, $flag, $uid ? IMAP::FT_UID : IMAP::NIL); |
339 | 339 | } |
340 | 340 | |
@@ -356,7 +356,7 @@ discard block |
||
356 | 356 | */ |
357 | 357 | public function appendMessage($folder, $message, $flags = null, $date = null) { |
358 | 358 | if ($date != null) { |
359 | - if ($date instanceof \Carbon\Carbon){ |
|
359 | + if ($date instanceof \Carbon\Carbon) { |
|
360 | 360 | $date = $date->format('d-M-Y H:i:s O'); |
361 | 361 | } |
362 | 362 | return \imap_append($this->stream, $folder, $message, $flags, $date); |
@@ -493,14 +493,14 @@ discard block |
||
493 | 493 | /** |
494 | 494 | * Enable the debug mode |
495 | 495 | */ |
496 | - public function enableDebug(){ |
|
496 | + public function enableDebug() { |
|
497 | 497 | $this->debug = true; |
498 | 498 | } |
499 | 499 | |
500 | 500 | /** |
501 | 501 | * Disable the debug mode |
502 | 502 | */ |
503 | - public function disableDebug(){ |
|
503 | + public function disableDebug() { |
|
504 | 504 | $this->debug = false; |
505 | 505 | } |
506 | 506 |
@@ -73,10 +73,10 @@ discard block |
||
73 | 73 | * @throws MethodNotFoundException |
74 | 74 | */ |
75 | 75 | public function __call($method, $arguments) { |
76 | - if(strtolower(substr($method, 0, 3)) === 'get') { |
|
76 | + if (strtolower(substr($method, 0, 3)) === 'get') { |
|
77 | 77 | $name = preg_replace('/(.)(?=[A-Z])/u', '$1_', substr(strtolower($method), 3)); |
78 | 78 | |
79 | - if(in_array($name, array_keys($this->attributes))) { |
|
79 | + if (in_array($name, array_keys($this->attributes))) { |
|
80 | 80 | return $this->attributes[$name]; |
81 | 81 | } |
82 | 82 | |
@@ -102,7 +102,7 @@ discard block |
||
102 | 102 | * @return mixed|null |
103 | 103 | */ |
104 | 104 | public function get($name) { |
105 | - if(isset($this->attributes[$name])) { |
|
105 | + if (isset($this->attributes[$name])) { |
|
106 | 106 | return $this->attributes[$name]; |
107 | 107 | } |
108 | 108 | |
@@ -118,7 +118,7 @@ discard block |
||
118 | 118 | public function find($pattern) { |
119 | 119 | if (preg_match_all($pattern, $this->raw, $matches)) { |
120 | 120 | if (isset($matches[1])) { |
121 | - if(count($matches[1]) > 0) { |
|
121 | + if (count($matches[1]) > 0) { |
|
122 | 122 | return $matches[1][0]; |
123 | 123 | } |
124 | 124 | } |
@@ -131,7 +131,7 @@ discard block |
||
131 | 131 | * |
132 | 132 | * @throws InvalidMessageDateException |
133 | 133 | */ |
134 | - protected function parse(){ |
|
134 | + protected function parse() { |
|
135 | 135 | $header = $this->rfc822_parse_headers($this->raw); |
136 | 136 | |
137 | 137 | $this->extractAddresses($header); |
@@ -152,7 +152,7 @@ discard block |
||
152 | 152 | $this->parseDate($header); |
153 | 153 | foreach ($header as $key => $value) { |
154 | 154 | $key = trim(rtrim(strtolower($key))); |
155 | - if(!isset($this->attributes[$key])){ |
|
155 | + if (!isset($this->attributes[$key])) { |
|
156 | 156 | $this->attributes[$key] = $value; |
157 | 157 | } |
158 | 158 | } |
@@ -168,12 +168,12 @@ discard block |
||
168 | 168 | * |
169 | 169 | * @return object |
170 | 170 | */ |
171 | - public function rfc822_parse_headers($raw_headers){ |
|
171 | + public function rfc822_parse_headers($raw_headers) { |
|
172 | 172 | $headers = []; |
173 | 173 | $imap_headers = []; |
174 | 174 | if (extension_loaded('imap')) { |
175 | 175 | $raw_imap_headers = (array) \imap_rfc822_parse_headers($this->raw); |
176 | - foreach($raw_imap_headers as $key => $values) { |
|
176 | + foreach ($raw_imap_headers as $key => $values) { |
|
177 | 177 | $key = str_replace("-", "_", $key); |
178 | 178 | $imap_headers[$key] = $values; |
179 | 179 | } |
@@ -181,7 +181,7 @@ discard block |
||
181 | 181 | |
182 | 182 | $lines = explode("\r\n", $raw_headers); |
183 | 183 | $prev_header = null; |
184 | - foreach($lines as $line) { |
|
184 | + foreach ($lines as $line) { |
|
185 | 185 | if (substr($line, 0, 1) === "\n") { |
186 | 186 | $line = substr($line, 1); |
187 | 187 | } |
@@ -201,19 +201,19 @@ discard block |
||
201 | 201 | } |
202 | 202 | if (is_array($headers[$prev_header])) { |
203 | 203 | $headers[$prev_header][] = $line; |
204 | - }else{ |
|
204 | + }else { |
|
205 | 205 | $headers[$prev_header] .= $line; |
206 | 206 | } |
207 | 207 | } |
208 | - }else{ |
|
208 | + }else { |
|
209 | 209 | if (($pos = strpos($line, ":")) > 0) { |
210 | 210 | $key = trim(rtrim(strtolower(substr($line, 0, $pos)))); |
211 | 211 | $key = str_replace("-", "_", $key); |
212 | 212 | |
213 | 213 | $value = trim(rtrim(substr($line, $pos + 1))); |
214 | 214 | if (isset($headers[$key])) { |
215 | - $headers[$key][] = $value; |
|
216 | - }else{ |
|
215 | + $headers[$key][] = $value; |
|
216 | + }else { |
|
217 | 217 | $headers[$key] = [$value]; |
218 | 218 | } |
219 | 219 | $prev_header = $key; |
@@ -221,10 +221,10 @@ discard block |
||
221 | 221 | } |
222 | 222 | } |
223 | 223 | |
224 | - foreach($headers as $key => $values) { |
|
224 | + foreach ($headers as $key => $values) { |
|
225 | 225 | if (isset($imap_headers[$key])) continue; |
226 | 226 | $value = null; |
227 | - switch($key){ |
|
227 | + switch ($key) { |
|
228 | 228 | case 'from': |
229 | 229 | case 'to': |
230 | 230 | case 'cc': |
@@ -239,7 +239,7 @@ discard block |
||
239 | 239 | break; |
240 | 240 | default: |
241 | 241 | if (is_array($values)) { |
242 | - foreach($values as $k => $v) { |
|
242 | + foreach ($values as $k => $v) { |
|
243 | 243 | if ($v == "") { |
244 | 244 | unset($values[$k]); |
245 | 245 | } |
@@ -251,7 +251,7 @@ discard block |
||
251 | 251 | $value = implode(" ", $values); |
252 | 252 | } elseif ($available_values > 2) { |
253 | 253 | $value = array_values($values); |
254 | - } else { |
|
254 | + }else { |
|
255 | 255 | $value = ""; |
256 | 256 | } |
257 | 257 | } |
@@ -271,12 +271,12 @@ discard block |
||
271 | 271 | * @return array The decoded elements are returned in an array of objects, where each |
272 | 272 | * object has two properties, charset and text. |
273 | 273 | */ |
274 | - public function mime_header_decode($text){ |
|
274 | + public function mime_header_decode($text) { |
|
275 | 275 | if (extension_loaded('imap')) { |
276 | 276 | return \imap_mime_header_decode($text); |
277 | 277 | } |
278 | 278 | $charset = $this->getEncoding($text); |
279 | - return [(object)[ |
|
279 | + return [(object) [ |
|
280 | 280 | "charset" => $charset, |
281 | 281 | "text" => $this->convertEncoding($text, $charset) |
282 | 282 | ]]; |
@@ -330,7 +330,7 @@ discard block |
||
330 | 330 | try { |
331 | 331 | if (function_exists('iconv') && $from != 'UTF-7' && $to != 'UTF-7') { |
332 | 332 | return iconv($from, $to, $str); |
333 | - } else { |
|
333 | + }else { |
|
334 | 334 | if (!$from) { |
335 | 335 | return mb_convert_encoding($str, $to); |
336 | 336 | } |
@@ -340,7 +340,7 @@ discard block |
||
340 | 340 | if (strstr($from, '-')) { |
341 | 341 | $from = str_replace('-', '', $from); |
342 | 342 | return $this->convertEncoding($str, $from, $to); |
343 | - } else { |
|
343 | + }else { |
|
344 | 344 | return $str; |
345 | 345 | } |
346 | 346 | } |
@@ -361,7 +361,7 @@ discard block |
||
361 | 361 | } |
362 | 362 | }elseif (property_exists($structure, 'charset')) { |
363 | 363 | return EncodingAliases::get($structure->charset, $this->fallback_encoding); |
364 | - }elseif (is_string($structure) === true){ |
|
364 | + }elseif (is_string($structure) === true) { |
|
365 | 365 | return mb_detect_encoding($structure); |
366 | 366 | } |
367 | 367 | |
@@ -382,7 +382,7 @@ discard block |
||
382 | 382 | $decoder = $this->config['decoder']['message']; |
383 | 383 | |
384 | 384 | if ($value !== null) { |
385 | - if($decoder === 'utf-8' && extension_loaded('imap')) { |
|
385 | + if ($decoder === 'utf-8' && extension_loaded('imap')) { |
|
386 | 386 | $value = \imap_utf8($value); |
387 | 387 | if (strpos(strtolower($value), '=?utf-8?') === 0) { |
388 | 388 | $value = mb_decode_mimeheader($value); |
@@ -390,14 +390,14 @@ discard block |
||
390 | 390 | if ($this->notDecoded($original_value, $value)) { |
391 | 391 | $decoded_value = $this->mime_header_decode($value); |
392 | 392 | if (count($decoded_value) > 0) { |
393 | - if(property_exists($decoded_value[0], "text")) { |
|
393 | + if (property_exists($decoded_value[0], "text")) { |
|
394 | 394 | $value = $decoded_value[0]->text; |
395 | 395 | } |
396 | 396 | } |
397 | 397 | } |
398 | - }elseif($decoder === 'iconv') { |
|
398 | + }elseif ($decoder === 'iconv') { |
|
399 | 399 | $value = iconv_mime_decode($value); |
400 | - }else{ |
|
400 | + }else { |
|
401 | 401 | $value = mb_decode_mimeheader($value); |
402 | 402 | } |
403 | 403 | |
@@ -420,7 +420,7 @@ discard block |
||
420 | 420 | * @return array |
421 | 421 | */ |
422 | 422 | private function decodeArray($values) { |
423 | - foreach($values as $key => $value) { |
|
423 | + foreach ($values as $key => $value) { |
|
424 | 424 | $values[$key] = $this->decode($value); |
425 | 425 | } |
426 | 426 | return $values; |
@@ -430,8 +430,8 @@ discard block |
||
430 | 430 | * Try to extract the priority from a given raw header string |
431 | 431 | */ |
432 | 432 | private function findPriority() { |
433 | - if(($priority = $this->get("x_priority")) === null) return; |
|
434 | - switch($priority){ |
|
433 | + if (($priority = $this->get("x_priority")) === null) return; |
|
434 | + switch ($priority) { |
|
435 | 435 | case IMAP::MESSAGE_PRIORITY_HIGHEST; |
436 | 436 | $priority = IMAP::MESSAGE_PRIORITY_HIGHEST; |
437 | 437 | break; |
@@ -463,7 +463,7 @@ discard block |
||
463 | 463 | */ |
464 | 464 | private function decodeAddresses($values) { |
465 | 465 | $addresses = []; |
466 | - foreach($values as $address) { |
|
466 | + foreach ($values as $address) { |
|
467 | 467 | $address = trim(rtrim($address)); |
468 | 468 | if (strpos($address, ",") == strlen($address) - 1) { |
469 | 469 | $address = substr($address, 0, -1); |
@@ -472,7 +472,7 @@ discard block |
||
472 | 472 | '/^(?:(?P<name>.+)\s)?(?(name)<|<?)(?P<email>[^\s]+?)(?(name)>|>?)$/', |
473 | 473 | $address, |
474 | 474 | $matches |
475 | - )){ |
|
475 | + )) { |
|
476 | 476 | $name = trim(rtrim($matches["name"])); |
477 | 477 | $email = trim(rtrim($matches["email"])); |
478 | 478 | list($mailbox, $host) = array_pad(explode("@", $email), 2, null); |
@@ -491,7 +491,7 @@ discard block |
||
491 | 491 | * @param object $header |
492 | 492 | */ |
493 | 493 | private function extractAddresses($header) { |
494 | - foreach(['from', 'to', 'cc', 'bcc', 'reply_to', 'sender'] as $key){ |
|
494 | + foreach (['from', 'to', 'cc', 'bcc', 'reply_to', 'sender'] as $key) { |
|
495 | 495 | if (property_exists($header, $key)) { |
496 | 496 | $this->attributes[$key] = $this->parseAddresses($header->$key); |
497 | 497 | } |
@@ -522,10 +522,10 @@ discard block |
||
522 | 522 | } |
523 | 523 | if (!property_exists($address, 'personal')) { |
524 | 524 | $address->personal = false; |
525 | - } else { |
|
525 | + }else { |
|
526 | 526 | $personalParts = $this->mime_header_decode($address->personal); |
527 | 527 | |
528 | - if(is_array($personalParts)) { |
|
528 | + if (is_array($personalParts)) { |
|
529 | 529 | $address->personal = ''; |
530 | 530 | foreach ($personalParts as $p) { |
531 | 531 | $address->personal .= $this->convertEncoding($p->text, $this->getEncoding($p)); |
@@ -545,18 +545,18 @@ discard block |
||
545 | 545 | /** |
546 | 546 | * Search and extract potential header extensions |
547 | 547 | */ |
548 | - private function extractHeaderExtensions(){ |
|
548 | + private function extractHeaderExtensions() { |
|
549 | 549 | foreach ($this->attributes as $key => $value) { |
550 | 550 | // Only parse strings and don't parse any attributes like the user-agent |
551 | 551 | if (is_string($value) === true && in_array($key, ["user_agent"]) === false) { |
552 | - if (($pos = strpos($value, ";")) !== false){ |
|
552 | + if (($pos = strpos($value, ";")) !== false) { |
|
553 | 553 | $original = substr($value, 0, $pos); |
554 | 554 | $this->attributes[$key] = trim(rtrim($original)); |
555 | 555 | |
556 | 556 | // Get all potential extensions |
557 | 557 | $extensions = explode(";", substr($value, $pos + 1)); |
558 | - foreach($extensions as $extension) { |
|
559 | - if (($pos = strpos($extension, "=")) !== false){ |
|
558 | + foreach ($extensions as $extension) { |
|
559 | + if (($pos = strpos($extension, "=")) !== false) { |
|
560 | 560 | $key = substr($extension, 0, $pos); |
561 | 561 | $key = trim(rtrim(strtolower($key))); |
562 | 562 | |
@@ -599,7 +599,7 @@ discard block |
||
599 | 599 | $parsed_date = null; |
600 | 600 | $date = $header->date; |
601 | 601 | |
602 | - if(preg_match('/\+0580/', $date)) { |
|
602 | + if (preg_match('/\+0580/', $date)) { |
|
603 | 603 | $date = str_replace('+0580', '+0530', $date); |
604 | 604 | } |
605 | 605 | |
@@ -622,7 +622,7 @@ discard block |
||
622 | 622 | $date = trim(array_pop($array)); |
623 | 623 | break; |
624 | 624 | } |
625 | - try{ |
|
625 | + try { |
|
626 | 626 | $parsed_date = Carbon::parse($date); |
627 | 627 | } catch (\Exception $_e) { |
628 | 628 | throw new InvalidMessageDateException("Invalid message date. ID:".$this->get("message_id"), 1100, $e); |
@@ -125,7 +125,7 @@ discard block |
||
125 | 125 | |
126 | 126 | $this->setDelimiter($delimiter); |
127 | 127 | $this->path = $folder_name; |
128 | - $this->full_name = $this->decodeName($folder_name); |
|
128 | + $this->full_name = $this->decodeName($folder_name); |
|
129 | 129 | $this->name = $this->getSimpleName($this->delimiter, $this->full_name); |
130 | 130 | |
131 | 131 | $this->parseAttributes($attributes); |
@@ -138,7 +138,7 @@ discard block |
||
138 | 138 | * @return WhereQuery |
139 | 139 | * @throws Exceptions\ConnectionFailedException |
140 | 140 | */ |
141 | - public function query($charset = 'UTF-8'){ |
|
141 | + public function query($charset = 'UTF-8') { |
|
142 | 142 | $this->getClient()->checkConnection(); |
143 | 143 | $this->getClient()->openFolder($this->path); |
144 | 144 | |
@@ -149,7 +149,7 @@ discard block |
||
149 | 149 | * @inheritdoc self::query($charset = 'UTF-8') |
150 | 150 | * @throws Exceptions\ConnectionFailedException |
151 | 151 | */ |
152 | - public function search($charset = 'UTF-8'){ |
|
152 | + public function search($charset = 'UTF-8') { |
|
153 | 153 | return $this->query($charset); |
154 | 154 | } |
155 | 155 | |
@@ -157,7 +157,7 @@ discard block |
||
157 | 157 | * @inheritdoc self::query($charset = 'UTF-8') |
158 | 158 | * @throws Exceptions\ConnectionFailedException |
159 | 159 | */ |
160 | - public function messages($charset = 'UTF-8'){ |
|
160 | + public function messages($charset = 'UTF-8') { |
|
161 | 161 | return $this->query($charset); |
162 | 162 | } |
163 | 163 | |
@@ -232,7 +232,7 @@ discard block |
||
232 | 232 | public function move($new_name, $expunge = true) { |
233 | 233 | $this->client->checkConnection(); |
234 | 234 | $status = $this->client->getConnection()->renameFolder($this->full_name, $new_name); |
235 | - if($expunge) $this->client->expunge(); |
|
235 | + if ($expunge) $this->client->expunge(); |
|
236 | 236 | |
237 | 237 | $folder = $this->client->getFolder($new_name); |
238 | 238 | $event = $this->getEvent("folder", "moved"); |
@@ -248,7 +248,7 @@ discard block |
||
248 | 248 | * @return array |
249 | 249 | * @throws ConnectionFailedException |
250 | 250 | */ |
251 | - public function overview($sequence = null){ |
|
251 | + public function overview($sequence = null) { |
|
252 | 252 | $this->client->openFolder($this->path); |
253 | 253 | $sequence = $sequence === null ? "1:*" : $sequence; |
254 | 254 | $uid = ClientManager::get('options.sequence', IMAP::ST_MSGN) == IMAP::ST_UID; |
@@ -273,7 +273,7 @@ discard block |
||
273 | 273 | */ |
274 | 274 | |
275 | 275 | if ($internal_date != null) { |
276 | - if ($internal_date instanceof Carbon){ |
|
276 | + if ($internal_date instanceof Carbon) { |
|
277 | 277 | $internal_date = $internal_date->format('d-M-Y H:i:s O'); |
278 | 278 | } |
279 | 279 | } |
@@ -307,7 +307,7 @@ discard block |
||
307 | 307 | */ |
308 | 308 | public function delete($expunge = true) { |
309 | 309 | $status = $this->client->getConnection()->deleteFolder($this->path); |
310 | - if($expunge) $this->client->expunge(); |
|
310 | + if ($expunge) $this->client->expunge(); |
|
311 | 311 | |
312 | 312 | $event = $this->getEvent("folder", "deleted"); |
313 | 313 | $event::dispatch($this); |
@@ -362,7 +362,7 @@ discard block |
||
362 | 362 | try { |
363 | 363 | $line = $connection->nextLine(); |
364 | 364 | if (($pos = strpos($line, "EXISTS")) !== false) { |
365 | - $msgn = (int) substr($line, 2, $pos -2); |
|
365 | + $msgn = (int) substr($line, 2, $pos - 2); |
|
366 | 366 | $connection->done(); |
367 | 367 | |
368 | 368 | $this->client->openFolder($this->path, true); |
@@ -374,8 +374,8 @@ discard block |
||
374 | 374 | |
375 | 375 | $connection->idle(); |
376 | 376 | } |
377 | - }catch (Exceptions\RuntimeException $e) { |
|
378 | - if(strpos($e->getMessage(), "connection closed") === false) { |
|
377 | + } catch (Exceptions\RuntimeException $e) { |
|
378 | + if (strpos($e->getMessage(), "connection closed") === false) { |
|
379 | 379 | throw $e; |
380 | 380 | } |
381 | 381 | } |
@@ -417,8 +417,8 @@ discard block |
||
417 | 417 | * Set the delimiter |
418 | 418 | * @param $delimiter |
419 | 419 | */ |
420 | - public function setDelimiter($delimiter){ |
|
421 | - if(in_array($delimiter, [null, '', ' ', false]) === true) { |
|
420 | + public function setDelimiter($delimiter) { |
|
421 | + if (in_array($delimiter, [null, '', ' ', false]) === true) { |
|
422 | 422 | $delimiter = ClientManager::get('options.delimiter', '/'); |
423 | 423 | } |
424 | 424 |
@@ -80,11 +80,11 @@ discard block |
||
80 | 80 | $this->setClient($client); |
81 | 81 | |
82 | 82 | $this->sequence = ClientManager::get('options.sequence', IMAP::ST_MSGN); |
83 | - if(ClientManager::get('options.fetch') === IMAP::FT_PEEK) $this->leaveUnread(); |
|
83 | + if (ClientManager::get('options.fetch') === IMAP::FT_PEEK) $this->leaveUnread(); |
|
84 | 84 | |
85 | 85 | if (ClientManager::get('options.fetch_order') === 'desc') { |
86 | 86 | $this->fetch_order = 'desc'; |
87 | - } else { |
|
87 | + }else { |
|
88 | 88 | $this->fetch_order = 'asc'; |
89 | 89 | } |
90 | 90 | |
@@ -98,7 +98,7 @@ discard block |
||
98 | 98 | /** |
99 | 99 | * Instance boot method for additional functionality |
100 | 100 | */ |
101 | - protected function boot(){} |
|
101 | + protected function boot() {} |
|
102 | 102 | |
103 | 103 | /** |
104 | 104 | * Parse a given value |
@@ -106,8 +106,8 @@ discard block |
||
106 | 106 | * |
107 | 107 | * @return string |
108 | 108 | */ |
109 | - protected function parse_value($value){ |
|
110 | - switch(true){ |
|
109 | + protected function parse_value($value) { |
|
110 | + switch (true) { |
|
111 | 111 | case $value instanceof \Carbon\Carbon: |
112 | 112 | $value = $value->format($this->date_format); |
113 | 113 | break; |
@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | * @throws MessageSearchValidationException |
125 | 125 | */ |
126 | 126 | protected function parse_date($date) { |
127 | - if($date instanceof \Carbon\Carbon) return $date; |
|
127 | + if ($date instanceof \Carbon\Carbon) return $date; |
|
128 | 128 | |
129 | 129 | try { |
130 | 130 | $date = Carbon::parse($date); |
@@ -175,7 +175,7 @@ discard block |
||
175 | 175 | * @return Collection |
176 | 176 | * @throws GetMessagesFailedException |
177 | 177 | */ |
178 | - protected function search(){ |
|
178 | + protected function search() { |
|
179 | 179 | $this->generate_query(); |
180 | 180 | |
181 | 181 | try { |
@@ -240,7 +240,7 @@ discard block |
||
240 | 240 | $raw_flag = isset($raw_flags[$uid]) ? $raw_flags[$uid] : []; |
241 | 241 | |
242 | 242 | $message = Message::make($uid, $msglist, $this->getClient(), $raw_header, $raw_content, $raw_flag, $this->getFetchOptions(), $this->sequence); |
243 | - switch ($message_key){ |
|
243 | + switch ($message_key) { |
|
244 | 244 | case 'number': |
245 | 245 | $message_key = $message->getMessageNo(); |
246 | 246 | break; |
@@ -262,7 +262,7 @@ discard block |
||
262 | 262 | |
263 | 263 | return $messages; |
264 | 264 | } catch (\Exception $e) { |
265 | - throw new GetMessagesFailedException($e->getMessage(),0, $e); |
|
265 | + throw new GetMessagesFailedException($e->getMessage(), 0, $e); |
|
266 | 266 | } |
267 | 267 | } |
268 | 268 | |
@@ -280,7 +280,7 @@ discard block |
||
280 | 280 | * @throws MessageHeaderFetchingException |
281 | 281 | * @throws \Webklex\PHPIMAP\Exceptions\EventNotFoundException |
282 | 282 | */ |
283 | - public function getMessage($uid, $msglist = null, $sequence = null){ |
|
283 | + public function getMessage($uid, $msglist = null, $sequence = null) { |
|
284 | 284 | return new Message($uid, $msglist, $this->getClient(), $this->getFetchOptions(), $this->getFetchBody(), $this->getFetchFlags(), $sequence ? $sequence : $this->sequence); |
285 | 285 | } |
286 | 286 | |
@@ -297,7 +297,7 @@ discard block |
||
297 | 297 | * @throws RuntimeException |
298 | 298 | * @throws \Webklex\PHPIMAP\Exceptions\EventNotFoundException |
299 | 299 | */ |
300 | - public function getMessageByMsgn($msgn, $msglist = null){ |
|
300 | + public function getMessageByMsgn($msgn, $msglist = null) { |
|
301 | 301 | return $this->getMessage($msgn, $msglist, IMAP::ST_MSGN); |
302 | 302 | } |
303 | 303 | |
@@ -313,7 +313,7 @@ discard block |
||
313 | 313 | * @throws RuntimeException |
314 | 314 | * @throws \Webklex\PHPIMAP\Exceptions\EventNotFoundException |
315 | 315 | */ |
316 | - public function getMessageByUid($uid){ |
|
316 | + public function getMessageByUid($uid) { |
|
317 | 317 | return $this->getMessage($uid, null, IMAP::ST_UID); |
318 | 318 | } |
319 | 319 | |
@@ -326,7 +326,7 @@ discard block |
||
326 | 326 | * @return LengthAwarePaginator |
327 | 327 | * @throws GetMessagesFailedException |
328 | 328 | */ |
329 | - public function paginate($per_page = 5, $page = null, $page_name = 'imap_page'){ |
|
329 | + public function paginate($per_page = 5, $page = null, $page_name = 'imap_page') { |
|
330 | 330 | if ( |
331 | 331 | $page === null |
332 | 332 | && isset($_GET[$page_name]) |
@@ -352,10 +352,10 @@ discard block |
||
352 | 352 | $this->query->each(function($statement) use(&$query) { |
353 | 353 | if (count($statement) == 1) { |
354 | 354 | $query .= $statement[0]; |
355 | - } else { |
|
356 | - if($statement[1] === null){ |
|
355 | + }else { |
|
356 | + if ($statement[1] === null) { |
|
357 | 357 | $query .= $statement[0]; |
358 | - }else{ |
|
358 | + }else { |
|
359 | 359 | $query .= $statement[0].' "'.$statement[1].'"'; |
360 | 360 | } |
361 | 361 | } |
@@ -385,7 +385,7 @@ discard block |
||
385 | 385 | * @return $this |
386 | 386 | */ |
387 | 387 | public function limit($limit, $page = 1) { |
388 | - if($page >= 1) $this->page = $page; |
|
388 | + if ($page >= 1) $this->page = $page; |
|
389 | 389 | $this->limit = $limit; |
390 | 390 | |
391 | 391 | return $this; |