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