Add PHP5-style constructor
[squirrelmail.git] / functions / imap_general.php
CommitLineData
59177427 1<?php
bccadd02 2
35586184 3/**
a6fd80f5 4 * imap_general.php
35586184 5 *
0e1a248b 6 * This implements all functions that do general IMAP functions.
35586184 7 *
f197ec88 8 * @copyright 1999-2016 The SquirrelMail Project Team
4b4abf93 9 * @license http://opensource.org/licenses/gpl-license.php GNU Public License
eb19bc67 10 * @version $Id$
d6c32258 11 * @package squirrelmail
eb19bc67 12 * @subpackage imap
35586184 13 */
14
d6c32258 15/** Includes.. */
202bcbcc 16
17require_once(SM_PATH . 'functions/rfc822address.php');
47a29326 18
35586184 19
48af4b64 20/**
21 * Generates a new session ID by incrementing the last one used;
22 * this ensures that each command has a unique ID.
0e1a248b 23 * @param bool $unique_id (since 1.3.0) controls use of unique
b35a5862 24 * identifiers/message sequence numbers in IMAP commands. See IMAP
25 * rfc 'UID command' chapter.
48af4b64 26 * @return string IMAP session id of the form 'A000'.
b35a5862 27 * @since 1.2.0
48af4b64 28 */
2aca19a1 29function sqimap_session_id($unique_id = FALSE) {
30 static $sqimap_session_id = 1;
31
487daa81 32 if (!$unique_id) {
098ea084 33 return( sprintf("A%03d", $sqimap_session_id++) );
487daa81 34 } else {
098ea084 35 return( sprintf("A%03d", $sqimap_session_id++) . ' UID' );
487daa81 36 }
9c737111 37}
38
48af4b64 39/**
3411d4ec 40 * Both send a command and accept the result from the command.
41 * This is to allow proper session number handling.
95e3afc1 42 * @param stream $imap_stream imap connection resource
b35a5862 43 * @param string $query imap command
44 * @param boolean $handle_errors see sqimap_retrieve_imap_response()
95e3afc1 45 * @param array $response
46 * @param array $message
47 * @param boolean $unique_id (since 1.3.0) see sqimap_session_id().
0e1a248b 48 * @return mixed returns false on imap error. displays error message
b35a5862 49 * if imap stream is not available.
50 * @since 1.2.3
3411d4ec 51 */
487daa81 52function sqimap_run_command_list ($imap_stream, $query, $handle_errors, &$response, &$message, $unique_id = false) {
c5809184 53 if ($imap_stream) {
098ea084 54 $sid = sqimap_session_id($unique_id);
55 fputs ($imap_stream, $sid . ' ' . $query . "\r\n");
bc78cc6e 56 $tag_uid_a = explode(' ',trim($sid));
57 $tag = $tag_uid_a[0];
0dc05a81 58 $read = sqimap_retrieve_imap_response ($imap_stream, $tag, $handle_errors, $response, $message, $query );
bc78cc6e 59 /* get the response and the message */
60 $message = $message[$tag];
1e0a2f0e 61 $response = $response[$tag];
bc78cc6e 62 return $read[$tag];
426815a3 63//FIXME: obey $handle_errors below!
c5809184 64 } else {
65 global $squirrelmail_language, $color;
66 set_up_language($squirrelmail_language);
b729dba8 67//FIXME: NO HTML IN CORE!
6fd95361 68 $string = "<b><font color=\"$color[2]\">\n" .
0e1a248b 69 _("ERROR: No available IMAP stream.") .
b729dba8 70//FIXME: NO HTML IN CORE!
c5809184 71 "</b></font>\n";
1b858d86 72 error_box($string);
098ea084 73 return false;
c5809184 74 }
1c72b151 75}
76
b35a5862 77/**
95e3afc1 78 * @param stream $imap_stream imap connection resource
b35a5862 79 * @param string $query imap command
80 * @param boolean $handle_errors see sqimap_retrieve_imap_response()
95e3afc1 81 * @param array $response empty string, if return = false
82 * @param array $message empty string, if return = false
83 * @param boolean $unique_id (since 1.3.0) see sqimap_session_id()
84 * @param boolean $filter (since 1.4.1 and 1.5.0) see sqimap_fread()
85 * @param mixed $outputstream (since 1.4.1 and 1.5.0) see sqimap_fread()
86 * @param boolean $no_return (since 1.4.1 and 1.5.0) see sqimap_fread()
0e1a248b 87 * @return mixed returns false on imap error. displays error message
b35a5862 88 * if imap stream is not available.
89 * @since 1.2.3
90 */
1e0a2f0e 91function sqimap_run_command ($imap_stream, $query, $handle_errors, &$response,
7c7b74b3 92 &$message, $unique_id = false,$filter=false,
93 $outputstream=false,$no_return=false) {
c5809184 94 if ($imap_stream) {
95 $sid = sqimap_session_id($unique_id);
1e0a2f0e 96 fputs ($imap_stream, $sid . ' ' . $query . "\r\n");
bc78cc6e 97 $tag_uid_a = explode(' ',trim($sid));
98 $tag = $tag_uid_a[0];
1e0a2f0e 99
bc78cc6e 100 $read = sqimap_read_data ($imap_stream, $tag, $handle_errors, $response,
7c7b74b3 101 $message, $query,$filter,$outputstream,$no_return);
0e1a248b 102 if (empty($read)) { //IMAP server dropped its connection
ec73f243 103 $response = '';
104 $message = '';
105 return false;
106 }
bc78cc6e 107 /* retrieve the response and the message */
108 $response = $response[$tag];
109 $message = $message[$tag];
1e0a2f0e 110
bc78cc6e 111 if (!empty($read[$tag])) {
8439f61d 112 /* sqimap_read_data should be called for one response
113 but since it just calls sqimap_retrieve_imap_response
114 which handles multiple responses we need to check for
115 that and merge the $read[$tag] array IF they are
116 separated and IF it was a FETCH response. */
117
118 if (isset($read[$tag][1]) && is_array($read[$tag][1]) && isset($read[$tag][1][0])
119 && preg_match('/^\* \d+ FETCH/', $read[$tag][1][0])) {
120 $result = array();
121 foreach($read[$tag] as $index => $value) {
122 $result = array_merge($result, $read[$tag]["$index"]);
123 }
124 return $result;
125 }
126
bc78cc6e 127 return $read[$tag][0];
128 } else {
129 return $read[$tag];
130 }
5adca076 131//FIXME: obey $handle_errors below!
c5809184 132 } else {
133 global $squirrelmail_language, $color;
134 set_up_language($squirrelmail_language);
b729dba8 135//FIXME: NO HTML IN CORE!
6fd95361 136 $string = "<b><font color=\"$color[2]\">\n" .
0e1a248b 137 _("ERROR: No available IMAP stream.") .
b729dba8 138//FIXME: NO HTML IN CORE!
c5809184 139 "</b></font>\n";
1b858d86 140 error_box($string);
098ea084 141 return false;
1e0a2f0e 142 }
bc78cc6e 143}
48af4b64 144
0022f6db 145/**
146 * @param mixed $new_query
147 * @param string $tag
148 * @param array $aQuery
95e3afc1 149 * @param boolean $unique_id see sqimap_session_id()
0022f6db 150 * @since 1.5.0
151 */
bc78cc6e 152function sqimap_prepare_pipelined_query($new_query,&$tag,&$aQuery,$unique_id) {
153 $sid = sqimap_session_id($unique_id);
154 $tag_uid_a = explode(' ',trim($sid));
155 $tag = $tag_uid_a[0];
0b38d197 156 $query = $sid . ' '.$new_query."\r\n";
bc78cc6e 157 $aQuery[$tag] = $query;
42a07ac1 158}
159
0022f6db 160/**
95e3afc1 161 * @param stream $imap_stream imap stream
0022f6db 162 * @param array $aQueryList
163 * @param boolean $handle_errors
164 * @param array $aServerResponse
165 * @param array $aServerMessage
95e3afc1 166 * @param boolean $unique_id see sqimap_session_id()
167 * @param boolean $filter see sqimap_fread()
168 * @param mixed $outputstream see sqimap_fread()
169 * @param boolean $no_return see sqimap_fread()
0022f6db 170 * @since 1.5.0
171 */
1e0a2f0e 172function sqimap_run_pipelined_command ($imap_stream, $aQueryList, $handle_errors,
bc78cc6e 173 &$aServerResponse, &$aServerMessage, $unique_id = false,
1e0a2f0e 174 $filter=false,$outputstream=false,$no_return=false) {
bc78cc6e 175 $aResponse = false;
5c300c60 176
1e0a2f0e 177 /*
0e1a248b 178 Do not fire all calls at once to the IMAP server but split the calls up
1e0a2f0e 179 in portions of $iChunkSize. If we do not do that I think we misbehave as
0e1a248b 180 IMAP client or should handle BYE calls if the IMAP server drops the
52c8b585 181 connection because the number of queries is to large. This isn't tested
182 but a wild guess how it could work in the field.
1e0a2f0e 183
184 After testing it on Exchange 2000 we discovered that a chunksize of 32
0b38d197 185 was quicker then when we raised it to 128.
52c8b585 186 */
187 $iQueryCount = count($aQueryList);
188 $iChunkSize = 32;
189 // array_chunk would also do the job but it's supported from php > 4.2
190 $aQueryChunks = array();
191 $iLoops = floor($iQueryCount / $iChunkSize);
192
5c300c60 193 if ($iLoops * $iChunkSize != $iQueryCount) ++$iLoops;
52c8b585 194
195 if (!function_exists('array_chunk')) { // arraychunk replacement
5c300c60 196 reset($aQueryList);
52c8b585 197 for($i=0;$i<$iLoops;++$i) {
5c300c60 198 for($j=0;$j<$iChunkSize;++$j) {
199 $key = key($aQueryList);
200 $aTmp[$key] = $aQueryList[$key];
201 if (next($aQueryList) === false) break;
202 }
203 $aQueryChunks[] = $aTmp;
1e0a2f0e 204 }
52c8b585 205 } else {
206 $aQueryChunks = array_chunk($aQueryList,$iChunkSize,true);
bc78cc6e 207 }
1e0a2f0e 208
52c8b585 209 for ($i=0;$i<$iLoops;++$i) {
210 $aQuery = $aQueryChunks[$i];
211 foreach($aQuery as $tag => $query) {
212 fputs($imap_stream,$query);
213 $aResults[$tag] = false;
214 }
52c8b585 215 foreach($aQuery as $tag => $query) {
5c300c60 216 if ($aResults[$tag] == false) {
1e0a2f0e 217 $aReturnedResponse = sqimap_retrieve_imap_response ($imap_stream, $tag,
bc78cc6e 218 $handle_errors, $response, $message, $query,
219 $filter,$outputstream,$no_return);
52c8b585 220 foreach ($aReturnedResponse as $returned_tag => $aResponse) {
5c300c60 221 if (!empty($aResponse)) {
52c8b585 222 $aResults[$returned_tag] = $aResponse[0];
5c300c60 223 } else {
224 $aResults[$returned_tag] = $aResponse;
225 }
52c8b585 226 $aServerResponse[$returned_tag] = $response[$returned_tag];
227 $aServerMessage[$returned_tag] = $message[$returned_tag];
228 }
bc78cc6e 229 }
230 }
231 }
b7277e4f 232 return $aResults;
bc78cc6e 233}
9c737111 234
1e0a2f0e 235/**
0e1a248b 236 * Custom fgets function: gets a line from the IMAP server,
48af4b64 237 * no matter how big it may be.
95e3afc1 238 * @param stream $imap_stream the stream to read from
48af4b64 239 * @return string a line
0022f6db 240 * @since 1.2.8
b8c285ab 241 */
b8c285ab 242function sqimap_fgets($imap_stream) {
243 $read = '';
244 $buffer = 4096;
245 $results = '';
c41daf03 246 $offset = 0;
247 while (strpos($results, "\r\n", $offset) === false) {
b8c285ab 248 if (!($read = fgets($imap_stream, $buffer))) {
329a7ca5 249 /* this happens in case of an error */
250 /* reset $results because it's useless */
251 $results = false;
b8c285ab 252 break;
253 }
c41daf03 254 if ( $results != '' ) {
255 $offset = strlen($results) - 1;
256 }
b8c285ab 257 $results .= $read;
258 }
259 return $results;
260}
261
0022f6db 262/**
263 * @param stream $imap_stream
264 * @param integer $iSize
95e3afc1 265 * @param boolean $filter
266 * @param mixed $outputstream stream or 'php://stdout' string
0e1a248b 267 * @param boolean $no_return controls data returned by function
0022f6db 268 * @return string
269 * @since 1.4.1
270 */
7c7b74b3 271function sqimap_fread($imap_stream,$iSize,$filter=false,
272 $outputstream=false, $no_return=false) {
273 if (!$filter || !$outputstream) {
274 $iBufferSize = $iSize;
275 } else {
811318c5 276 // see php bug 24033. They changed fread behaviour %$^&$%
977a6085 277 $iBufferSize = 7800; // multiple of 78 in case of base64 decoding.
278 }
279 if ($iSize < $iBufferSize) {
280 $iBufferSize = $iSize;
7c7b74b3 281 }
7c0ec1d8 282
5eba0be2 283 $iRetrieved = 0;
977a6085 284 $results = '';
285 $sRead = $sReadRem = '';
1e0a2f0e 286 // NB: fread can also stop at end of a packet on sockets.
977a6085 287 while ($iRetrieved < $iSize) {
7c7b74b3 288 $sRead = fread($imap_stream,$iBufferSize);
977a6085 289 $iLength = strlen($sRead);
290 $iRetrieved += $iLength ;
291 $iRemaining = $iSize - $iRetrieved;
292 if ($iRemaining < $iBufferSize) {
293 $iBufferSize = $iRemaining;
294 }
13aabbcf 295 if ($sRead == '') {
7c7b74b3 296 $results = false;
297 break;
298 }
13aabbcf 299 if ($sReadRem != '') {
977a6085 300 $sRead = $sReadRem . $sRead;
301 $sReadRem = '';
302 }
7c0ec1d8 303
13aabbcf 304 if ($filter && $sRead != '') {
1e0a2f0e 305 // in case the filter is base64 decoding we return a remainder
7c0ec1d8 306 $sReadRem = $filter($sRead);
7c7b74b3 307 }
13aabbcf 308 if ($outputstream && $sRead != '') {
7c7b74b3 309 if (is_resource($outputstream)) {
310 fwrite($outputstream,$sRead);
311 } else if ($outputstream == 'php://stdout') {
312 echo $sRead;
313 }
314 }
315 if ($no_return) {
316 $sRead = '';
1e0a2f0e 317 } else {
977a6085 318 $results .= $sRead;
7c7b74b3 319 }
7c7b74b3 320 }
1e0a2f0e 321 return $results;
322}
977a6085 323
7c0ec1d8 324
48af4b64 325/**
326 * Obsolete function, inform plugins that use it
95e3afc1 327 * @param stream $imap_stream
328 * @param string $tag
329 * @param boolean $handle_errors
330 * @param array $response
331 * @param array $message
332 * @param string $query
b35a5862 333 * @since 1.1.3
334 * @deprecated (since 1.5.0) use sqimap_run_command or sqimap_run_command_list instead
48af4b64 335 */
1e0a2f0e 336function sqimap_read_data_list($imap_stream, $tag, $handle_errors,
0dc05a81 337 &$response, &$message, $query = '') {
1b858d86 338 global $color, $oTemplate, $squirrelmail_language;
0dc05a81 339 set_up_language($squirrelmail_language);
b729dba8 340//FIXME: NO HTML IN CORE!
6fd95361 341 $string = "<b><font color=\"$color[2]\">\n" .
0e1a248b 342 _("ERROR: Bad function call.") .
b729dba8 343//FIXME: NO HTML IN CORE!
6fd95361 344 "</b><br />\n" .
0dc05a81 345 _("Reason:") . ' '.
6fd95361 346 'There is a plugin installed which make use of the <br />' .
347 'SquirrelMail internal function sqimap_read_data_list.<br />'.
348 'Please adapt the installed plugin and let it use<br />'.
349 'sqimap_run_command or sqimap_run_command_list instead<br /><br />'.
350 'The following query was issued:<br />'.
b729dba8 351//FIXME: NO HTML IN CORE!
3047e291 352 sm_encode_html_special_chars($query) . '<br />' . "</font><br />\n";
1b858d86 353 error_box($string);
354 $oTemplate->display('footer.tpl');
1e0a2f0e 355 exit;
0dc05a81 356}
7c7b74b3 357
48af4b64 358/**
0e1a248b 359 * Function to display an error related to an IMAP query.
48af4b64 360 * @param string title the caption of the error box
361 * @param string query the query that went wrong
ec73f243 362 * @param string message_title optional message title
363 * @param string message optional error message
364 * @param string $link an optional link to try again
48af4b64 365 * @return void
0022f6db 366 * @since 1.5.0
48af4b64 367 */
ec73f243 368function sqimap_error_box($title, $query = '', $message_title = '', $message = '', $link = '')
4974c2a0 369{
370 global $color, $squirrelmail_language;
371
372 set_up_language($squirrelmail_language);
b729dba8 373//FIXME: NO HTML IN CORE!
6fd95361 374 $string = "<font color=\"$color[2]\"><b>\n" . $title . "</b><br />\n";
bf15f116 375 $cmd = explode(' ',$query);
376 $cmd= strtolower($cmd[0]);
377
378 if ($query != '' && $cmd != 'login')
3047e291 379 $string .= _("Query:") . ' ' . sm_encode_html_special_chars($query) . '<br />';
4974c2a0 380 if ($message_title != '')
381 $string .= $message_title;
382 if ($message != '')
3047e291 383 $string .= sm_encode_html_special_chars($message);
b729dba8 384//FIXME: NO HTML IN CORE!
6fd95361 385 $string .= "</font><br />\n";
ec73f243 386 if ($link != '')
387 $string .= $link;
1b858d86 388 error_box($string);
4974c2a0 389}
390
48af4b64 391/**
3411d4ec 392 * Reads the output from the IMAP stream. If handle_errors is set to true,
393 * this will also handle all errors that are received. If it is not set,
48af4b64 394 * the errors will be sent back through $response and $message.
95e3afc1 395 * @param stream $imap_stream imap stream
396 * @param string $tag
397 * @param boolean $handle_errors handle errors internally or send them in $response and $message.
0022f6db 398 * @param array $response
399 * @param array $message
95e3afc1 400 * @param string $query command that can be printed if something fails
401 * @param boolean $filter see sqimap_fread()
402 * @param mixed $outputstream see sqimap_fread()
403 * @param boolean $no_return see sqimap_fread()
0022f6db 404 * @since 1.5.0
bee165ef 405 */
1e0a2f0e 406function sqimap_retrieve_imap_response($imap_stream, $tag, $handle_errors,
7c7b74b3 407 &$response, &$message, $query = '',
408 $filter = false, $outputstream = false, $no_return = false) {
9c737111 409 global $color, $squirrelmail_language;
9c737111 410 $read = '';
bc78cc6e 411 if (!is_array($message)) $message = array();
412 if (!is_array($response)) $response = array();
ec73f243 413 $aResponse = '';
b8c285ab 414 $resultlist = array();
415 $data = array();
ee231c8b 416 $sCommand = '';
417 if (preg_match("/^(\w+)\s*/",$query,$aMatch)) {
418 $sCommand = strtoupper($aMatch[1]);
419 } else {
420 // error reporting (shouldn't happen)
421 }
b8c285ab 422 $read = sqimap_fgets($imap_stream);
8d8da447 423 $i = 0;
bea3eb1e 424 while ($read) {
425 $char = $read{0};
426 switch ($char)
427 {
15bc7f66 428 case '+':
429 default:
430 $read = sqimap_fgets($imap_stream);
431 break;
432
433 case $tag{0}:
434 {
bea3eb1e 435 /* get the command */
436 $arg = '';
437 $i = strlen($tag)+1;
438 $s = substr($read,$i);
439 if (($j = strpos($s,' ')) || ($j = strpos($s,"\n"))) {
440 $arg = substr($s,0,$j);
441 }
442 $found_tag = substr($read,0,$i-1);
5c300c60 443 if ($found_tag) {
bea3eb1e 444 switch ($arg)
445 {
15bc7f66 446 case 'OK':
447 case 'BAD':
448 case 'NO':
449 case 'BYE':
450 case 'PREAUTH':
bc78cc6e 451 $response[$found_tag] = $arg;
452 $message[$found_tag] = trim(substr($read,$i+strlen($arg)));
453 if (!empty($data)) {
454 $resultlist[] = $data;
455 }
5c300c60 456 $aResponse[$found_tag] = $resultlist;
457 $data = $resultlist = array();
458 if ($found_tag == $tag) {
459 break 3; /* switch switch while */
460 }
461 break;
1e0a2f0e 462 default:
bea3eb1e 463 /* this shouldn't happen */
bc78cc6e 464 $response[$found_tag] = $arg;
465 $message[$found_tag] = trim(substr($read,$i+strlen($arg)));
466 if (!empty($data)) {
467 $resultlist[] = $data;
468 }
469 $aResponse[$found_tag] = $resultlist;
5c300c60 470 $data = $resultlist = array();
471 if ($found_tag == $tag) {
472 break 3; /* switch switch while */
473 }
bc78cc6e 474 }
bea3eb1e 475 }
5c300c60 476 $read = sqimap_fgets($imap_stream);
477 if ($read === false) { /* error */
4920e1e0 478 break 2; /* switch while */
5c300c60 479 }
480 break;
15bc7f66 481 } // end case $tag{0}
482
483 case '*':
484 {
202bcbcc 485 if (($sCommand == "FETCH" || $sCommand == "STORE") && preg_match('/^\*\s\d+\sFETCH/',$read)) {
bea3eb1e 486 /* check for literal */
487 $s = substr($read,-3);
488 $fetch_data = array();
489 do { /* outer loop, continue until next untagged fetch
490 or tagged reponse */
491 do { /* innerloop for fetching literals. with this loop
492 we prohibid that literal responses appear in the
493 outer loop so we can trust the untagged and
494 tagged info provided by $read */
935d09e1 495 $read_literal = false;
bea3eb1e 496 if ($s === "}\r\n") {
497 $j = strrpos($read,'{');
498 $iLit = substr($read,$j+1,-3);
499 $fetch_data[] = $read;
7c7b74b3 500 $sLiteral = sqimap_fread($imap_stream,$iLit,$filter,$outputstream,$no_return);
329a7ca5 501 if ($sLiteral === false) { /* error */
502 break 4; /* while while switch while */
503 }
bea3eb1e 504 /* backwards compattibility */
505 $aLiteral = explode("\n", $sLiteral);
506 /* release not neaded data */
507 unset($sLiteral);
508 foreach ($aLiteral as $line) {
509 $fetch_data[] = $line ."\n";
510 }
511 /* release not neaded data */
1e0a2f0e 512 unset($aLiteral);
bea3eb1e 513 /* next fgets belongs to this fetch because
514 we just got the exact literalsize and there
515 must follow data to complete the response */
329a7ca5 516 $read = sqimap_fgets($imap_stream);
517 if ($read === false) { /* error */
518 break 4; /* while while switch while */
519 }
935d09e1 520 $s = substr($read,-3);
521 $read_literal = true;
522 continue;
bea3eb1e 523 } else {
329a7ca5 524 $fetch_data[] = $read;
bea3eb1e 525 }
526 /* retrieve next line and check in the while
527 statements if it belongs to this fetch response */
528 $read = sqimap_fgets($imap_stream);
329a7ca5 529 if ($read === false) { /* error */
530 break 4; /* while while switch while */
531 }
bea3eb1e 532 /* check for next untagged reponse and break */
533 if ($read{0} == '*') break 2;
534 $s = substr($read,-3);
935d09e1 535 } while ($s === "}\r\n" || $read_literal);
bea3eb1e 536 $s = substr($read,-3);
537 } while ($read{0} !== '*' &&
106d4087 538 substr($read,0,strlen($tag)) !== $tag);
329a7ca5 539 $resultlist[] = $fetch_data;
bea3eb1e 540 /* release not neaded data */
541 unset ($fetch_data);
542 } else {
543 $s = substr($read,-3);
544 do {
545 if ($s === "}\r\n") {
546 $j = strrpos($read,'{');
547 $iLit = substr($read,$j+1,-3);
9c093ecf 548 // check for numeric value to avoid that untagged responses like:
549 // * OK [PARSE] Unexpected characters at end of address: {SET:debug=51}
550 // will trigger literal fetching ({SET:debug=51} !== int )
551 if (is_numeric($iLit)) {
552 $data[] = $read;
553 $sLiteral = fread($imap_stream,$iLit);
554 if ($sLiteral === false) { /* error */
555 $read = false;
556 break 3; /* while switch while */
557 }
558 $data[] = $sLiteral;
559 $data[] = sqimap_fgets($imap_stream);
560 } else {
561 $data[] = $read;
329a7ca5 562 }
bea3eb1e 563 } else {
329a7ca5 564 $data[] = $read;
bea3eb1e 565 }
566 $read = sqimap_fgets($imap_stream);
329a7ca5 567 if ($read === false) {
568 break 3; /* while switch while */
569 } else if ($read{0} == '*') {
106d4087 570 break;
571 }
bea3eb1e 572 $s = substr($read,-3);
573 } while ($s === "}\r\n");
574 break 1;
1e0a2f0e 575 }
bea3eb1e 576 break;
15bc7f66 577 } // end case '*'
578 } // end switch
c0b23345 579 } // end while
1e0a2f0e 580
c0b23345 581 /* error processing in case $read is false */
d7542838 582 if ($read === false) {
d3d9ef2d 583 // try to retrieve an untagged bye respons from the results
584 $sResponse = array_pop($data);
d7542838 585 if ($sResponse !== NULL && strpos($sResponse,'* BYE') !== false) {
586 if (!$handle_errors) {
587 $query = '';
588 }
0e1a248b 589 sqimap_error_box(_("ERROR: IMAP server closed the connection."), $query, _("Server responded:"),$sResponse);
b729dba8 590//FIXME: NO HTML IN CORE!
d7542838 591 echo '</body></html>';
592 exit;
593 } else if ($handle_errors) {
1e0a2f0e 594 unset($data);
0e1a248b 595 sqimap_error_box(_("ERROR: Connection dropped by IMAP server."), $query);
ec73f243 596 exit;
597 }
b8c285ab 598 }
1e0a2f0e 599
15bc7f66 600 /* Set $resultlist array */
b8c285ab 601 if (!empty($data)) {
bc78cc6e 602 //$resultlist[] = $data;
9c737111 603 }
b8c285ab 604 elseif (empty($resultlist)) {
1e0a2f0e 605 $resultlist[] = array();
b8c285ab 606 }
15bc7f66 607
608 /* Return result or handle errors */
bee165ef 609 if ($handle_errors == false) {
bc78cc6e 610 return $aResponse;
dd381002 611 }
4974c2a0 612 switch ($response[$tag]) {
dd381002 613 case 'OK':
bc78cc6e 614 return $aResponse;
329a7ca5 615 break;
1e0a2f0e 616 case 'NO':
dd381002 617 /* ignore this error from M$ exchange, it is not fatal (aka bug) */
6b6c2e06 618 if (strstr($message[$tag], 'command resulted in') === false) {
617a4d89 619 sqsession_register('NO', 'IMAP_FATAL_ERROR_TYPE');
620 sqsession_register($query, 'IMAP_FATAL_ERROR_QUERY');
621 sqsession_register($message[$tag], 'IMAP_FATAL_ERROR_MESSAGE');
0e1a248b 622 sqimap_error_box(_("ERROR: Could not complete request."), $query, _("Reason Given:") . ' ', $message[$tag]);
329a7ca5 623 echo '</body></html>';
052e0c26 624 exit;
9c737111 625 }
329a7ca5 626 break;
1e0a2f0e 627 case 'BAD':
617a4d89 628 sqsession_register('BAD', 'IMAP_FATAL_ERROR_TYPE');
629 sqsession_register($query, 'IMAP_FATAL_ERROR_QUERY');
630 sqsession_register($message[$tag], 'IMAP_FATAL_ERROR_MESSAGE');
0e1a248b 631 sqimap_error_box(_("ERROR: Bad or malformed request."), $query, _("Server responded:") . ' ', $message[$tag]);
b729dba8 632//FIXME: NO HTML IN CORE!
1e0a2f0e 633 echo '</body></html>';
634 exit;
635 case 'BYE':
617a4d89 636 sqsession_register('BYE', 'IMAP_FATAL_ERROR_TYPE');
637 sqsession_register($query, 'IMAP_FATAL_ERROR_QUERY');
638 sqsession_register($message[$tag], 'IMAP_FATAL_ERROR_MESSAGE');
0e1a248b 639 sqimap_error_box(_("ERROR: IMAP server closed the connection."), $query, _("Server responded:") . ' ', $message[$tag]);
b729dba8 640//FIXME: NO HTML IN CORE!
1e0a2f0e 641 echo '</body></html>';
9c737111 642 exit;
1e0a2f0e 643 default:
617a4d89 644 sqsession_register('UNKNOWN', 'IMAP_FATAL_ERROR_TYPE');
645 sqsession_register($query, 'IMAP_FATAL_ERROR_QUERY');
646 sqsession_register($message[$tag], 'IMAP_FATAL_ERROR_MESSAGE');
0e1a248b 647 sqimap_error_box(_("ERROR: Unknown IMAP response."), $query, _("Server responded:") . ' ', $message[$tag]);
329a7ca5 648 /* the error is displayed but because we don't know the reponse we
649 return the result anyway */
1e0a2f0e 650 return $aResponse;
329a7ca5 651 break;
9c737111 652 }
9c737111 653}
654
0022f6db 655/**
95e3afc1 656 * @param stream $imap_stream imap string
0022f6db 657 * @param string $tag_uid
658 * @param boolean $handle_errors
659 * @param array $response
660 * @param array $message
95e3afc1 661 * @param string $query (since 1.2.5)
662 * @param boolean $filter (since 1.4.1) see sqimap_fread()
663 * @param mixed $outputstream (since 1.4.1) see sqimap_fread()
664 * @param boolean $no_return (since 1.4.1) see sqimap_fread()
0022f6db 665 */
1e0a2f0e 666function sqimap_read_data ($imap_stream, $tag_uid, $handle_errors,
7c7b74b3 667 &$response, &$message, $query = '',
668 $filter=false,$outputstream=false,$no_return=false) {
bc78cc6e 669
670 $tag_uid_a = explode(' ',trim($tag_uid));
671 $tag = $tag_uid_a[0];
672
1e0a2f0e 673 $res = sqimap_retrieve_imap_response($imap_stream, $tag, $handle_errors,
674 $response, $message, $query,$filter,$outputstream,$no_return);
675 return $res;
9c737111 676}
677
48af4b64 678/**
b98732e8 679 * Connects to the IMAP server and returns a resource identifier for use with
a15f9d93 680 * the other SquirrelMail IMAP functions. Does NOT login!
48af4b64 681 * @param string server hostname of IMAP server
682 * @param int port port number to connect to
a15f9d93 683 * @param integer $tls whether to use plain text(0), TLS(1) or STARTTLS(2) when connecting.
684 * Argument was boolean before 1.5.1.
a9805897 685 * @param array $stream_options Stream context options, see config_local.php
9aaa9ae2 686 * for more details (OPTIONAL)
48af4b64 687 * @return imap-stream resource identifier
0022f6db 688 * @since 1.5.0 (usable only in 1.5.1 or later)
b98732e8 689 */
a9805897 690function sqimap_create_stream($server,$port,$tls=0,$stream_options=array()) {
ce68b76b 691 global $squirrelmail_language;
b98732e8 692
abc4a428 693 if (strstr($server,':') && ! preg_match("/^\[.*\]$/",$server)) {
694 // numerical IPv6 address must be enclosed in square brackets
695 $server = '['.$server.']';
696 }
a15f9d93 697
9aaa9ae2 698 // NB: Using "ssl://" ensures the highest possible TLS version
699 // will be negotiated with the server (whereas "tls://" only
700 // uses TLS version 1.0)
701 //
a15f9d93 702 if ($tls == 1) {
b98732e8 703 if ((check_php_version(4,3)) and (extension_loaded('openssl'))) {
9aaa9ae2 704 if (function_exists('stream_socket_client')) {
705 $server_address = 'ssl://' . $server . ':' . $port;
a9805897 706 $ssl_context = @stream_context_create($stream_options);
9aaa9ae2 707 $connect_timeout = ini_get('default_socket_timeout');
708 // null timeout is broken
709 if ($connect_timeout == 0)
710 $connect_timeout = 15;
711 $imap_stream = @stream_socket_client($server_address, $error_number, $error_string, $connect_timeout, STREAM_CLIENT_CONNECT, $ssl_context);
712 } else {
713 $imap_stream = @fsockopen('ssl://' . $server, $port, $error_number, $error_string, 15);
714 }
b98732e8 715 } else {
716 require_once(SM_PATH . 'functions/display_messages.php');
3b151851 717 logout_error( sprintf(_("Error connecting to IMAP server: %s."), $server).
718 '<br />'.
719 _("TLS is enabled, but this version of PHP does not support TLS sockets, or is missing the openssl extension.").
720 '<br /><br />'.
0a6be7d1 721 _("Please contact your system administrator and report this error."),
abc4a428 722 sprintf(_("Error connecting to IMAP server: %s."), $server));
b98732e8 723 }
9aaa9ae2 724 } else {
725 $imap_stream = @fsockopen($server, $port, $error_number, $error_string, 15);
b98732e8 726 }
727
b98732e8 728
729 /* Do some error correction */
730 if (!$imap_stream) {
731 set_up_language($squirrelmail_language, true);
732 require_once(SM_PATH . 'functions/display_messages.php');
3b151851 733 logout_error( sprintf(_("Error connecting to IMAP server: %s."), $server).
b729dba8 734//FIXME: NO HTML IN CORE!
0a6be7d1 735 "<br />\r\n$error_number : $error_string<br />\r\n",
abc4a428 736 sprintf(_("Error connecting to IMAP server: %s."), $server) );
b98732e8 737 exit;
738 }
739 $server_info = fgets ($imap_stream, 1024);
a15f9d93 740
741 /**
742 * Implementing IMAP STARTTLS (rfc2595) in php 5.1.0+
743 * http://www.php.net/stream-socket-enable-crypto
744 */
c4de9863 745 if ($tls === 2) {
a15f9d93 746 if (function_exists('stream_socket_enable_crypto')) {
747 // check starttls capability, don't use cached capability version
748 if (! sqimap_capability($imap_stream, 'STARTTLS', false)) {
749 // imap server does not declare starttls support
750 sqimap_error_box(sprintf(_("Error connecting to IMAP server: %s."), $server),
751 '','',
752 _("IMAP STARTTLS is enabled in SquirrelMail configuration, but used IMAP server does not support STARTTLS."));
753 exit;
754 }
755
756 // issue starttls command and check response
757 sqimap_run_command($imap_stream, 'STARTTLS', false, $starttls_response, $starttls_message);
758 // check response
759 if ($starttls_response!='OK') {
760 // starttls command failed
761 sqimap_error_box(sprintf(_("Error connecting to IMAP server: %s."), $server),
762 'STARTTLS',
3c021d16 763 _("Server replied:") . ' ',
a15f9d93 764 $starttls_message);
765 exit();
766 }
767
768 // start crypto on connection. suppress function errors.
769 if (@stream_socket_enable_crypto($imap_stream,true,STREAM_CRYPTO_METHOD_TLS_CLIENT)) {
770 // starttls was successful
771
772 /**
4ae9beb7 773 * RFC 2595 requires to discard CAPABILITY information after successful
774 * STARTTLS command. We don't follow RFC, because SquirrelMail stores CAPABILITY
775 * information only after successful login (src/redirect.php) and cached information
776 * is used only in other php script connections after successful STARTTLS. If script
777 * issues sqimap_capability() call before sqimap_login() and wants to get initial
778 * capability response, script should set third sqimap_capability() argument to false.
a15f9d93 779 */
4ae9beb7 780 //sqsession_unregister('sqimap_capabilities');
a15f9d93 781 } else {
782 /**
783 * stream_socket_enable_crypto() call failed. Possible issues:
784 * - broken ssl certificate (uw drops connection, error is in syslog mail facility)
4ae9beb7 785 * - some ssl error (can reproduce with STREAM_CRYPTO_METHOD_SSLv3_CLIENT, PHP E_WARNING
a15f9d93 786 * suppressed in stream_socket_enable_crypto() call)
787 */
788 sqimap_error_box(sprintf(_("Error connecting to IMAP server: %s."), $server),
789 '','',
790 _("Unable to start TLS."));
791 /**
4ae9beb7 792 * Bug: stream_socket_enable_crypto() does not register SSL errors in
793 * openssl_error_string() or stream notification wrapper and displays
794 * them in E_WARNING level message. It is impossible to retrieve error
a15f9d93 795 * message without own error handler.
796 */
797 exit;
798 }
799 } else {
800 // php install does not support stream_socket_enable_crypto() function
801 sqimap_error_box(sprintf(_("Error connecting to IMAP server: %s."), $server),
802 '','',
803 _("IMAP STARTTLS is enabled in SquirrelMail configuration, but used PHP version does not support functions that allow to enable encryption on open socket."));
804 exit;
805 }
806 }
b98732e8 807 return $imap_stream;
808}
809
48af4b64 810/**
0e1a248b 811 * Logs the user into the IMAP server. If $hide is set, no error messages
b86f98e4 812 * will be displayed (if set to 1, just exits, if set to 2, returns FALSE).
41d66087 813 * This function returns the IMAP connection handle.
0022f6db 814 * @param string $username user name
9c093ecf 815 * @param string $password password encrypted with onetimepad. Since 1.5.2
816 * function can use internal password functions, if parameter is set to
817 * boolean false.
0022f6db 818 * @param string $imap_server_address address of imap server
819 * @param integer $imap_port port of imap server
41d66087 820 * @param int $hide controls display connection errors:
5a908046 821 * 0 = do not hide
822 * 1 = show no errors (just exit)
823 * 2 = show no errors (return FALSE)
b4e0d365 824 * 3 = show no errors (return error string)
a9805897 825 * @param array $stream_options Stream context options, see config_local.php
9aaa9ae2 826 * for more details (OPTIONAL)
b4e0d365 827 * @return mixed The IMAP connection stream, or if the connection fails,
b86f98e4 828 * FALSE if $hide is set to 2 or an error string if $hide
b4e0d365 829 * is set to 3.
3411d4ec 830 */
9aaa9ae2 831function sqimap_login ($username, $password, $imap_server_address,
a9805897 832 $imap_port, $hide, $stream_options=array()) {
fe55c7c7 833 global $color, $squirrelmail_language, $onetimepad, $use_imap_tls,
9ae70b62 834 $imap_auth_mech, $sqimap_capabilities, $display_imap_login_error;
85fc999e 835
b0434236 836 // Note/TODO: This hack grabs the $authz argument from the session. In the short future,
837 // a new argument in function sqimap_login() will be used instead.
838 $authz = '';
839 global $authz;
840 sqgetglobalvar('authz' , $authz , SQ_SESSION);
841
842 if(!empty($authz)) {
843 /* authz plugin - specific:
b86f98e4 844 * Get proxy login parameters from authz plugin configuration. If they
b0434236 845 * exist, they will override the current ones.
846 * This is useful if we want to use different SASL authentication mechanism
847 * and/or different TLS settings for proxy logins. */
b86f98e4 848 global $authz_imap_auth_mech, $authz_use_imap_tls, $authz_imapPort_tls;
b0434236 849 $imap_auth_mech = !empty($authz_imap_auth_mech) ? strtolower($authz_imap_auth_mech) : $imap_auth_mech;
6a645613 850 $use_imap_tls = !empty($authz_use_imap_tls)? $authz_use_imap_tls : $use_imap_tls;
851 $imap_port = !empty($authz_use_imap_tls)? $authz_imapPort_tls : $imap_port;
b0434236 852
853 if($imap_auth_mech == 'login' || $imap_auth_mech == 'cram-md5') {
854 logout_error("Misconfigured Plugin (authz or equivalent):<br/>".
855 "The LOGIN and CRAM-MD5 authentication mechanisms cannot be used when attempting proxy login.");
856 exit;
857 }
858 }
859
045ec1a1 860 /* get imap login password */
861 if ($password===false) {
862 /* standard functions */
863 $password = sqauth_read_password();
864 } else {
865 /* old way. $key must be extracted from cookie */
866 if (!isset($onetimepad) || empty($onetimepad)) {
867 sqgetglobalvar('onetimepad' , $onetimepad , SQ_SESSION );
868 }
869 /* Decrypt the password */
870 $password = OneTimePadDecrypt($password, $onetimepad);
eb2f6102 871 }
045ec1a1 872
fe55c7c7 873 if (!isset($sqimap_capabilities)) {
72bc549b 874 sqgetglobalvar('sqimap_capabilities' , $sqimap_capabilities , SQ_SESSION );
fe55c7c7 875 }
876
b98732e8 877 $host = $imap_server_address;
bd9829d7 878 $imap_server_address = sqimap_get_user_server($imap_server_address, $username);
fe55c7c7 879
a9805897 880 $imap_stream = sqimap_create_stream($imap_server_address,$imap_port,$use_imap_tls,$stream_options);
fe55c7c7 881
b98732e8 882 if (($imap_auth_mech == 'cram-md5') OR ($imap_auth_mech == 'digest-md5')) {
3b151851 883 // We're using some sort of authentication OTHER than plain or login
b98732e8 884 $tag=sqimap_session_id(false);
885 if ($imap_auth_mech == 'digest-md5') {
098ea084 886 $query = $tag . " AUTHENTICATE DIGEST-MD5\r\n";
b98732e8 887 } elseif ($imap_auth_mech == 'cram-md5') {
098ea084 888 $query = $tag . " AUTHENTICATE CRAM-MD5\r\n";
b98732e8 889 }
890 fputs($imap_stream,$query);
891 $answer=sqimap_fgets($imap_stream);
892 // Trim the "+ " off the front
893 $response=explode(" ",$answer,3);
894 if ($response[0] == '+') {
098ea084 895 // Got a challenge back
b98732e8 896 $challenge=$response[1];
897 if ($imap_auth_mech == 'digest-md5') {
b0434236 898 $reply = digest_md5_response($username,$password,$challenge,'imap',$host,$authz);
b98732e8 899 } elseif ($imap_auth_mech == 'cram-md5') {
900 $reply = cram_md5_response($username,$password,$challenge);
901 }
902 fputs($imap_stream,$reply);
903 $read=sqimap_fgets($imap_stream);
904 if ($imap_auth_mech == 'digest-md5') {
3b151851 905 // DIGEST-MD5 has an extra step..
b98732e8 906 if (substr($read,0,1) == '+') { // OK so far..
098ea084 907 fputs($imap_stream,"\r\n");
908 $read=sqimap_fgets($imap_stream);
098ea084 909 }
b98732e8 910 }
911 $results=explode(" ",$read,3);
912 $response=$results[1];
913 $message=$results[2];
914 } else {
3b151851 915 // Fake the response, so the error trap at the bottom will work
b98732e8 916 $response="BAD";
917 $message='IMAP server does not appear to support the authentication method selected.';
918 $message .= ' Please contact your system administrator.';
919 }
fe0b18b3 920 } elseif ($imap_auth_mech == 'login') {
b98732e8 921 // Original IMAP login code
922 $query = 'LOGIN "' . quoteimap($username) . '" "' . quoteimap($password) . '"';
923 $read = sqimap_run_command ($imap_stream, $query, false, $response, $message);
1e7fc1cb 924 } elseif ($imap_auth_mech == 'plain') {
fe55c7c7 925 /***
b0434236 926 * SASL PLAIN, RFC 4616 (updates 2595)
fe55c7c7 927 *
b0434236 928 * The mechanism consists of a single message, a string of [UTF-8]
929 * encoded [Unicode] characters, from the client to the server. The
930 * client presents the authorization identity (identity to act as),
931 * followed by a NUL (U+0000) character, followed by the authentication
932 * identity (identity whose password will be used), followed by a NUL
933 * (U+0000) character, followed by the clear-text password. As with
934 * other SASL mechanisms, the client does not provide an authorization
935 * identity when it wishes the server to derive an identity from the
936 * credentials and use that as the authorization identity.
937 */
b98732e8 938 $tag=sqimap_session_id(false);
72bc549b 939 $sasl = (isset($sqimap_capabilities['SASL-IR']) && $sqimap_capabilities['SASL-IR']) ? true : false;
b0434236 940 if(!empty($authz)) {
941 $auth = base64_encode("$username\0$authz\0$password");
942 } else {
943 $auth = base64_encode("$username\0$username\0$password");
944 }
fe55c7c7 945 if ($sasl) {
946 // IMAP Extension for SASL Initial Client Response
2bd6b461 947 // <draft-siemborski-imap-sasl-initial-response-01b.txt>
fe55c7c7 948 $query = $tag . " AUTHENTICATE PLAIN $auth\r\n";
949 fputs($imap_stream, $query);
b98732e8 950 $read = sqimap_fgets($imap_stream);
fe55c7c7 951 } else {
952 $query = $tag . " AUTHENTICATE PLAIN\r\n";
953 fputs($imap_stream, $query);
954 $read=sqimap_fgets($imap_stream);
955 if (substr($read,0,1) == '+') { // OK so far..
956 fputs($imap_stream, "$auth\r\n");
957 $read = sqimap_fgets($imap_stream);
958 }
098ea084 959 }
b98732e8 960 $results=explode(" ",$read,3);
961 $response=$results[1];
962 $message=$results[2];
b0434236 963
b98732e8 964 } else {
965 $response="BAD";
966 $message="Internal SquirrelMail error - unknown IMAP authentication method chosen. Please contact the developers.";
967 }
fe55c7c7 968
b98732e8 969 /* If the connection was not successful, lets see why */
9c737111 970 if ($response != 'OK') {
b4e0d365 971 if (!$hide || $hide == 3) {
972//FIXME: UUURG... We don't want HTML in error messages, should also do html sanitizing of error messages elsewhere; should't assume output is destined for an HTML browser here
74424a43 973 if ($response != 'NO') {
3411d4ec 974 /* "BAD" and anything else gets reported here. */
3047e291 975 $message = sm_encode_html_special_chars($message);
9c737111 976 set_up_language($squirrelmail_language, true);
977 if ($response == 'BAD') {
b4e0d365 978 if ($hide == 3) return sprintf(_("Bad request: %s"), $message);
6fd95361 979 $string = sprintf (_("Bad request: %s")."<br />\r\n", $message);
9c737111 980 } else {
b4e0d365 981 if ($hide == 3) return sprintf(_("Unknown error: %s"), $message);
6fd95361 982 $string = sprintf (_("Unknown error: %s") . "<br />\n", $message);
9c737111 983 }
1e7fc1cb 984 if (isset($read) && is_array($read)) {
6fd95361 985 $string .= '<br />' . _("Read data:") . "<br />\n";
9c737111 986 foreach ($read as $line) {
3047e291 987 $string .= sm_encode_html_special_chars($line) . "<br />\n";
9c737111 988 }
989 }
1b858d86 990 error_box($string);
9c737111 991 exit;
165e24a7 992 } else {
3411d4ec 993 /*
994 * If the user does not log in with the correct
1c72b151 995 * username and password it is not possible to get the
996 * correct locale from the user's preferences.
997 * Therefore, apply the same hack as on the login
998 * screen.
3411d4ec 999 *
1000 * $squirrelmail_language is set by a cookie when
1c72b151 1001 * the user selects language and logs out
bee165ef 1002 */
fe55c7c7 1003
9c737111 1004 set_up_language($squirrelmail_language, true);
098ea084 1005 sqsession_destroy();
b86f98e4 1006
d5c472f1 1007 /* terminate the session nicely */
1008 sqimap_logout($imap_stream);
9ae70b62 1009
1010 // determine what error message to use
1011 //
1012 $fail_msg = _("Unknown user or password incorrect.");
1013 if ($display_imap_login_error) {
1014 // See if there is an error message from the server
1015 // Skip any rfc5530 response code: '[something]' at the
1016 // start of the message
1017 if (!empty($message)
1018 && $message{0} == '['
1019 && ($end = strstr($message, ']'))
1020 && $end != ']') {
1021 $message = substr($end, 1);
1022 }
1023 // Remove surrounding spaces and if there
1024 // is anything left, display that as the
1025 // error message:
1026 $message = trim($message);
1027 if (strlen($message))
1028 $fail_msg = _($message);
1029 }
1030
1031 if ($hide == 3) return $fail_msg;
1032 logout_error($fail_msg);
9c737111 1033 exit;
052e0c26 1034 }
9c737111 1035 } else {
41d66087 1036 if ($hide == 2) return FALSE;
052e0c26 1037 exit;
9c737111 1038 }
1039 }
1d20443c 1040
1041 /* Special error case:
1042 * Login referrals. The server returns:
0e1a248b 1043 * ? OK [REFERRAL <imap url>]
1044 * Check RFC 2221 for details. Since we do not support login referrals yet
1045 * we log the user out.
1046 */
2da1524c 1047 if ( stristr($message, 'REFERRAL imap') === TRUE ) {
0e1a248b 1048 sqimap_logout($imap_stream);
1d20443c 1049 set_up_language($squirrelmail_language, true);
1d20443c 1050 sqsession_destroy();
edde1f5c 1051 logout_error( _("Your mailbox is not located at this server. Try a different server or consult your system administrator") );
1d20443c 1052 exit;
1053 }
0e1a248b 1054
9c737111 1055 return $imap_stream;
1056}
f1e6f580 1057
48af4b64 1058/**
1059 * Simply logs out the IMAP session
95e3afc1 1060 * @param stream $imap_stream the IMAP connection to log out.
48af4b64 1061 * @return void
1062 */
9c737111 1063function sqimap_logout ($imap_stream) {
8d936b0c 1064 /* Logout is not valid until the server returns 'BYE'
1065 * If we don't have an imap_ stream we're already logged out */
26a2cc8b 1066 if(isset($imap_stream) && $imap_stream)
8d936b0c 1067 sqimap_run_command($imap_stream, 'LOGOUT', false, $response, $message);
9c737111 1068}
1069
48af4b64 1070/**
95e3afc1 1071 * Retrieve the CAPABILITY string from the IMAP server.
48af4b64 1072 * If capability is set, returns only that specific capability,
1073 * else returns array of all capabilities.
95e3afc1 1074 * @param stream $imap_stream
a15f9d93 1075 * @param string $capability (since 1.3.0)
4ae9beb7 1076 * @param boolean $bUseCache (since 1.5.1) Controls use of capability data stored in session
0e1a248b 1077 * @return mixed (string if $capability is set and found,
0022f6db 1078 * false, if $capability is set and not found,
1079 * array if $capability not set)
48af4b64 1080 */
a15f9d93 1081function sqimap_capability($imap_stream, $capability='', $bUseCache=true) {
1082 // sqgetGlobalVar('sqimap_capabilities', $sqimap_capabilities, SQ_SESSION);
0493ed11 1083
a15f9d93 1084 if (!$bUseCache || ! sqgetGlobalVar('sqimap_capabilities', $sqimap_capabilities, SQ_SESSION)) {
1c72b151 1085 $read = sqimap_run_command($imap_stream, 'CAPABILITY', true, $a, $b);
9c737111 1086 $c = explode(' ', $read[0]);
1087 for ($i=2; $i < count($c); $i++) {
1088 $cap_list = explode('=', $c[$i]);
3411d4ec 1089 if (isset($cap_list[1])) {
045dee91 1090 if(isset($sqimap_capabilities[trim($cap_list[0])]) &&
1091 !is_array($sqimap_capabilities[trim($cap_list[0])])) {
1092 // Remove array key that was added in 'else' block below
1093 // This is to accomodate for capabilities like:
1094 // SORT SORT=MODSEQ
1095 unset($sqimap_capabilities[trim($cap_list[0])]);
1096 }
3cfa833d 1097 $sqimap_capabilities[trim($cap_list[0])][] = $cap_list[1];
3411d4ec 1098 } else {
045dee91 1099 if(!isset($sqimap_capabilities[trim($cap_list[0])])) {
1100 $sqimap_capabilities[trim($cap_list[0])] = TRUE;
1101 }
3411d4ec 1102 }
f1e6f580 1103 }
9c737111 1104 }
487daa81 1105 if ($capability) {
098ea084 1106 if (isset($sqimap_capabilities[$capability])) {
1107 return $sqimap_capabilities[$capability];
1108 } else {
1109 return false;
1110 }
f1e6f580 1111 }
487daa81 1112 return $sqimap_capabilities;
9c737111 1113}
1114
48af4b64 1115/**
95e3afc1 1116 * Returns the delimiter between mailboxes: INBOX/Test, or INBOX.Test
0022f6db 1117 * @param stream $imap_stream
1118 * @return string
48af4b64 1119 */
9c737111 1120function sqimap_get_delimiter ($imap_stream = false) {
3411d4ec 1121 global $sqimap_delimiter, $optional_delimiter;
85fc999e 1122
9c737111 1123 /* Use configured delimiter if set */
1124 if((!empty($optional_delimiter)) && $optional_delimiter != 'detect') {
1125 return $optional_delimiter;
1126 }
85fc999e 1127
7eb6261e 1128 /* Delimiter is stored in the session from redirect. Try fetching from there first */
cc54580f 1129 if (empty($sqimap_delimiter)) {
7eb6261e 1130 sqgetGlobalVar('delimiter',$sqimap_delimiter,SQ_SESSION);
1131 }
1132
9c737111 1133 /* Do some caching here */
1134 if (!$sqimap_delimiter) {
ad2f0b54 1135 if (sqimap_capability($imap_stream, 'NAMESPACE')
3411d4ec 1136 /*
1137 * According to something that I can't find, this is supposed to work on all systems
1138 * OS: This won't work in Courier IMAP.
1139 * OS: According to rfc2342 response from NAMESPACE command is:
1140 * OS: * NAMESPACE (PERSONAL NAMESPACES) (OTHER_USERS NAMESPACE) (SHARED NAMESPACES)
1141 * OS: We want to lookup all personal NAMESPACES...
b86f98e4 1142 *
6a645613 1143 * TODO: remove this in favour of the information from sqimap_get_namespace()
3411d4ec 1144 */
ad2f0b54 1145 && ($read = sqimap_run_command($imap_stream, 'NAMESPACE', true, $a, $b))
1146 && preg_match('/\* NAMESPACE +(\( *\(.+\) *\)|NIL) +(\( *\(.+\) *\)|NIL) +(\( *\(.+\) *\)|NIL)/i', $read[0], $data)
1147 && preg_match('/^\( *\((.*)\) *\)/', $data[1], $data2)) {
1148 $pn = $data2[1];
1149 $pna = explode(')(', $pn);
1150 $delnew = array();
1151 while (list($k, $v) = each($pna)) {
1152 $lst = explode('"', $v);
1153 if (isset($lst[3])) {
1154 $delnew[$lst[1]] = $lst[3];
1155 } else {
1156 $delnew[$lst[1]] = '';
f1e6f580 1157 }
1158 }
ad2f0b54 1159 $sqimap_delimiter = array_shift($delnew);
f1e6f580 1160 } else {
1161 fputs ($imap_stream, ". LIST \"INBOX\" \"\"\r\n");
1162 $read = sqimap_read_data($imap_stream, '.', true, $a, $b);
91e0dccc 1163 $read = $read['.'][0]; //sqimap_read_data() now returns a tag array of response array
f1e6f580 1164 $quote_position = strpos ($read[0], '"');
1165 $sqimap_delimiter = substr ($read[0], $quote_position+1, 1);
1166 }
1167 }
1168 return $sqimap_delimiter;
9c737111 1169}
052e0c26 1170
6a645613 1171/**
1172 * Retrieves the namespaces from the IMAP server.
1173 * NAMESPACE is an IMAP extension defined in RFC 2342.
1174 *
1175 * @param stream $imap_stream
1176 * @return array
1177 */
1178function sqimap_get_namespace($imap_stream) {
1179 $read = sqimap_run_command($imap_stream, 'NAMESPACE', true, $a, $b);
1180 return sqimap_parse_namespace($read[0]);
1181}
b86f98e4 1182
6a645613 1183/**
1184 * Parses a NAMESPACE response and returns an array with the available
1185 * personal, users and shared namespaces.
1186 *
1187 * @param string $input
1188 * @return array The returned array has the following format:
1189 * <pre>
1190 * array(
1191 * 'personal' => array(
1192 * 0 => array('prefix'=>'INBOX.','delimiter' =>'.'),
1193 * 1 => ...
1194 * ),
1195 * 'users' => array(..
1196 * ),
1197 * 'shared' => array( ..
1198 * )
1199 * )
1200 * </pre>
1201 * Note that if a namespace is not defined in the server, then the corresponding
1202 * array will be empty.
1203 */
1204function sqimap_parse_namespace(&$input) {
1205 $ns_strings = array(1=>'personal', 2=>'users', 3=>'shared');
1206 $namespace = array();
1207
b7910e12 1208 if (preg_match('/NAMESPACE (\(\(.*\)\)|NIL) (\(\(.*\)\)|NIL) (\(\(.*\)\)|NIL)/', $input, $regs)) {
6a645613 1209 for($i=1; $i<=3; $i++) {
1210 if($regs[$i] == 'NIL') {
1211 $namespace[$ns_strings[$i]] = array();
1212 } else {
1213 // Pop-out the first ( and last ) for easier parsing
1214 $ns = substr($regs[$i], 1, sizeof($regs[$i])-2);
1215 if($c = preg_match_all('/\((?:(.*?)\s*?)\)/', $ns, $regs2)) {
1216 $namespace[$ns_strings[$i]] = array();
1217 for($j=0; $j<sizeof($regs2[1]); $j++) {
61d8f26d 1218 preg_match('/"(.*)"\s+("(.*)"|NIL)/', $regs2[1][$j], $regs3);
6a645613 1219 $namespace[$ns_strings[$i]][$j]['prefix'] = $regs3[1];
61d8f26d 1220 if($regs3[2] == 'NIL') {
1221 $namespace[$ns_strings[$i]][$j]['delimiter'] = null;
1222 } else {
1223 // $regs[3] is $regs[2] without the quotes
1224 $namespace[$ns_strings[$i]][$j]['delimiter'] = $regs3[3];
1225 }
6a645613 1226 unset($regs3);
1227 }
1228 }
1229 unset($ns);
1230 }
1231 }
1232 }
1233 return($namespace);
1234}
1235
48af4b64 1236/**
1237 * This encodes a mailbox name for use in IMAP commands.
95e3afc1 1238 * @param string $what the mailbox to encode
48af4b64 1239 * @return string the encoded mailbox string
0022f6db 1240 * @since 1.5.0
48af4b64 1241 */
b2306cbe 1242function sqimap_encode_mailbox_name($what)
1243{
b7910e12 1244 if (preg_match('/["\\\r\n]/', $what))
91e0dccc 1245 return '{' . strlen($what) . "}\r\n" . $what; /* 4.3 literal form */
1246 return '"' . $what . '"'; /* 4.3 quoted string form */
b2306cbe 1247}
1248
48af4b64 1249/**
1250 * Gets the number of messages in the current mailbox.
1e0a2f0e 1251 *
1252 * OBSOLETE use sqimap_status_messages instead.
95e3afc1 1253 * @param stream $imap_stream imap stream
1254 * @param string $mailbox
1255 * @deprecated
48af4b64 1256 */
9c737111 1257function sqimap_get_num_messages ($imap_stream, $mailbox) {
48879ef0 1258 $aStatus = sqimap_status_messages($imap_stream,$mailbox,array('MESSAGES'));
1259 return $aStatus['MESSAGES'];
9c737111 1260}
95e3afc1 1261
1e0a2f0e 1262/**
1263 * OBSOLETE FUNCTION should be removed after mailbox_display,
1264 * printMessage function is adapted
95e3afc1 1265 * $addr_ar = array(), $group = '' and $host='' arguments are used in 1.4.0
1266 * @param string $address
1267 * @param integer $max
1268 * @since 1.4.0
1269 * @deprecated See Rfc822Address.php
1e0a2f0e 1270 */
91688e5f 1271function parseAddress($address, $max=0) {
1e0a2f0e 1272 $aAddress = parseRFC822Address($address,array('limit'=> $max));
1273 /*
1274 * Because the expected format of the array element is changed we adapt it now.
1275 * This also implies that this function is obsolete and should be removed after the
1276 * rest of the source is adapted. See Rfc822Address.php for the new function.
1277 */
1278 array_walk($aAddress, '_adaptAddress');
1279 return $aAddress;
1280}
91688e5f 1281
1e0a2f0e 1282/**
1283 * OBSOLETE FUNCTION should be removed after mailbox_display,
1284 * printMessage function is adapted
95e3afc1 1285 *
0e1a248b 1286 * callback function used for formating of addresses array in
95e3afc1 1287 * parseAddress() function
1288 * @param array $aAddr
1289 * @param integer $k array key
1290 * @since 1.5.1
1291 * @deprecated
1e0a2f0e 1292 */
1293function _adaptAddress(&$aAddr,$k) {
1294 $sPersonal = (isset($aAddr[SQM_ADDR_PERSONAL]) && $aAddr[SQM_ADDR_PERSONAL]) ?
1295 $aAddr[SQM_ADDR_PERSONAL] : '';
1296 $sEmail = ($aAddr[SQM_ADDR_HOST]) ?
3cd52f38 1297 $aAddr[SQM_ADDR_MAILBOX] . '@'.$aAddr[SQM_ADDR_HOST] :
1298 $aAddr[SQM_ADDR_MAILBOX];
1e0a2f0e 1299 $aAddr = array($sEmail,$sPersonal);
1300}
91688e5f 1301
48af4b64 1302/**
1303 * Returns the number of unseen messages in this folder.
26e90c74 1304 * obsoleted by sqimap_status_messages !
95e3afc1 1305 * Arguments differ in 1.0.x
1306 * @param stream $imap_stream
1307 * @param string $mailbox
1308 * @return integer
1309 * @deprecated
3411d4ec 1310 */
9c737111 1311function sqimap_unseen_messages ($imap_stream, $mailbox) {
26e90c74 1312 $aStatus = sqimap_status_messages($imap_stream,$mailbox,array('UNSEEN'));
1313 return $aStatus['UNSEEN'];
9c737111 1314}
1315
48af4b64 1316/**
26e90c74 1317 * Returns the status items of a mailbox.
1318 * Default it returns MESSAGES,UNSEEN and RECENT
0e1a248b 1319 * Supported status items are MESSAGES, UNSEEN, RECENT (since 1.4.0),
95e3afc1 1320 * UIDNEXT (since 1.5.1) and UIDVALIDITY (since 1.5.1)
1321 * @param stream $imap_stream imap stream
1322 * @param string $mailbox mail folder
1323 * @param array $aStatusItems status items
1324 * @return array
1325 * @since 1.3.2
1f720b34 1326 */
1e0a2f0e 1327function sqimap_status_messages ($imap_stream, $mailbox,
26e90c74 1328 $aStatusItems = array('MESSAGES','UNSEEN','RECENT')) {
1329
3fedd15b 1330 $aStatusItems = implode(' ',$aStatusItems);
26e90c74 1331 $read_ary = sqimap_run_command ($imap_stream, 'STATUS ' . sqimap_encode_mailbox_name($mailbox) .
1332 " ($aStatusItems)", false, $result, $message);
1f720b34 1333 $i = 0;
26e90c74 1334 $messages = $unseen = $recent = $uidnext = $uidvalidity = false;
1f720b34 1335 $regs = array(false,false);
1336 while (isset($read_ary[$i])) {
1337 if (preg_match('/UNSEEN\s+([0-9]+)/i', $read_ary[$i], $regs)) {
098ea084 1338 $unseen = $regs[1];
1339 }
1f720b34 1340 if (preg_match('/MESSAGES\s+([0-9]+)/i', $read_ary[$i], $regs)) {
098ea084 1341 $messages = $regs[1];
1342 }
b8ec18ef 1343 if (preg_match('/RECENT\s+([0-9]+)/i', $read_ary[$i], $regs)) {
098ea084 1344 $recent = $regs[1];
1e0a2f0e 1345 }
26e90c74 1346 if (preg_match('/UIDNEXT\s+([0-9]+)/i', $read_ary[$i], $regs)) {
1347 $uidnext = $regs[1];
1e0a2f0e 1348 }
26e90c74 1349 if (preg_match('/UIDVALIDITY\s+([0-9]+)/i', $read_ary[$i], $regs)) {
1350 $uidvalidity = $regs[1];
1e0a2f0e 1351 }
1f720b34 1352 $i++;
1353 }
48879ef0 1354
1355 $status=array('MESSAGES' => $messages,
1e0a2f0e 1356 'UNSEEN'=>$unseen,
26e90c74 1357 'RECENT' => $recent,
1358 'UIDNEXT' => $uidnext,
1359 'UIDVALIDITY' => $uidvalidity);
48879ef0 1360
1361 if (!empty($messages)) { $hook_status['MESSAGES']=$messages; }
1362 if (!empty($unseen)) { $hook_status['UNSEEN']=$unseen; }
1363 if (!empty($recent)) { $hook_status['RECENT']=$recent; }
81de00c0 1364 if (!empty($hook_status)) {
48879ef0 1365 $hook_status['MAILBOX']=$mailbox;
1366 $hook_status['CALLER']='sqimap_status_messages';
d849b570 1367 do_hook('folder_status', $hook_status);
48879ef0 1368 }
1369 return $status;
1f720b34 1370}
1371
9c737111 1372
48af4b64 1373/**
1374 * Saves a message to a given folder -- used for saving sent messages
95e3afc1 1375 * @param stream $imap_stream
1376 * @param string $sent_folder
1377 * @param $length
81de00c0 1378 * @return string $sid
3411d4ec 1379 */
81de00c0 1380function sqimap_append ($imap_stream, $sMailbox, $length) {
1381 $sid = sqimap_session_id();
1382 $query = $sid . ' APPEND ' . sqimap_encode_mailbox_name($sMailbox) . " (\\Seen) {".$length."}";
1383 fputs ($imap_stream, "$query\r\n");
85fc999e 1384 $tmp = fgets ($imap_stream, 1024);
81de00c0 1385 sqimap_append_checkresponse($tmp, $sMailbox,$sid, $query);
1386 return $sid;
9c737111 1387}
1388
95e3afc1 1389/**
1390 * @param stream imap_stream
1391 * @param string $folder (since 1.3.2)
1392 */
81de00c0 1393function sqimap_append_done ($imap_stream, $sMailbox='') {
9c737111 1394 fputs ($imap_stream, "\r\n");
1395 $tmp = fgets ($imap_stream, 1024);
81de00c0 1396 while (!sqimap_append_checkresponse($tmp, $sMailbox)) {
1397 $tmp = fgets ($imap_stream, 1024);
1398 }
7ec3a6b9 1399}
1400
95e3afc1 1401/**
0e1a248b 1402 * Displays error messages, if there are errors in responses to
95e3afc1 1403 * commands issues by sqimap_append() and sqimap_append_done() functions.
1404 * @param string $response
81de00c0 1405 * @param string $sMailbox
1406 * @return bool $bDone
9948500c 1407 * @since 1.5.1 and 1.4.5
95e3afc1 1408 */
81de00c0 1409function sqimap_append_checkresponse($response, $sMailbox, $sid='', $query='') {
81de00c0 1410 // static vars to keep them available when sqimap_append_done calls this function.
1411 static $imapquery, $imapsid;
7ec3a6b9 1412
81de00c0 1413 $bDone = false;
1414
1415 if ($query) {
1416 $imapquery = $query;
1417 }
1418 if ($sid) {
1419 $imapsid = $sid;
1420 }
1421 if ($response{0} == '+') {
1422 // continuation request triggerd by sqimap_append()
1423 $bDone = true;
1424 } else {
1425 $i = strpos($response, ' ');
1426 $sRsp = substr($response,0,$i);
1427 $sMsg = substr($response,$i+1);
1428 $aExtra = array('MAILBOX' => $sMailbox);
1429 switch ($sRsp) {
1430 case '*': //untagged response
1431 $i = strpos($sMsg, ' ');
1432 $sRsp = strtoupper(substr($sMsg,0,$i));
1433 $sMsg = substr($sMsg,$i+1);
1434 if ($sRsp == 'NO' || $sRsp == 'BAD') {
1435 // for the moment disabled. Enable after 1.5.1 release.
1436 // Notices could give valueable information about the mailbox
4bc49df6 1437 // Update: seems this was forgotten, but now it is finally enabled
1438 sqm_trigger_imap_error('SQM_IMAP_APPEND_NOTICE',$imapquery,$sRsp,$sMsg);
81de00c0 1439 }
1440 $bDone = false;
1441 case $imapsid:
1442 // A001 OK message
1443 // $imapsid<space>$sRsp<space>$sMsg
1444 $bDone = true;
1445 $i = strpos($sMsg, ' ');
1446 $sRsp = strtoupper(substr($sMsg,0,$i));
1447 $sMsg = substr($sMsg,$i+1);
1448 switch ($sRsp) {
1449 case 'NO':
1450 if (preg_match("/(.*)(quota)(.*)$/i", $sMsg, $aMatch)) {
1451 sqm_trigger_imap_error('SQM_IMAP_APPEND_QUOTA_ERROR',$imapquery,$sRsp,$sMsg,$aExtra);
1452 } else {
1453 sqm_trigger_imap_error('SQM_IMAP_APPEND_ERROR',$imapquery,$sRsp,$sMsg,$aExtra);
1454 }
1455 break;
1456 case 'BAD':
1457 sqm_trigger_imap_error('SQM_IMAP_ERROR',$imapquery,$sRsp,$sMsg,$aExtra);
1458 break;
1459 case 'BYE':
1460 sqm_trigger_imap_error('SQM_IMAP_BYE',$imapquery,$sRsp,$sMsg,$aExtra);
1461 break;
1462 case 'OK':
1463 break;
1464 default:
1465 break;
1466 }
1467 break;
1468 default:
1469 // should be false because of the unexpected response but i'm not sure if
1470 // that will cause an endless loop in sqimap_append_done
1471 $bDone = true;
098ea084 1472 }
69146537 1473 }
81de00c0 1474 return $bDone;
9c737111 1475}
85fc999e 1476
95e3afc1 1477/**
0e1a248b 1478 * Allows mapping of IMAP server address with custom function
95e3afc1 1479 * see map_yp_alias()
1480 * @param string $imap_server imap server address or mapping
1481 * @param string $username
1482 * @return string
1483 * @since 1.3.0
1484 */
bd9829d7 1485function sqimap_get_user_server ($imap_server, $username) {
bd9829d7 1486 if (substr($imap_server, 0, 4) != "map:") {
1487 return $imap_server;
1488 }
bd9829d7 1489 $function = substr($imap_server, 4);
1490 return $function($username);
1491}
1492
48af4b64 1493/**
0e1a248b 1494 * This is an example that gets IMAP servers from yellowpages (NIS).
1e0a2f0e 1495 * you can simple put map:map_yp_alias in your $imap_server_address
bd9829d7 1496 * in config.php use your own function instead map_yp_alias to map your
0e1a248b 1497 * LDAP whatever way to find the users IMAP server.
1498 *
95e3afc1 1499 * Requires access to external ypmatch program
1500 * FIXME: it can be implemented in php yp extension or pecl (since php 5.1.0)
1501 * @param string $username
1502 * @return string
1503 * @since 1.3.0
48af4b64 1504 */
bd9829d7 1505function map_yp_alias($username) {
a28de419 1506 $safe_username = escapeshellarg($username);
1507 $yp = `ypmatch $safe_username aliases`;
bd9829d7 1508 return chop(substr($yp, strlen($username)+1));
1e0a2f0e 1509}