From 6ee5ed253b92593ac5784300ac425f34f7fd1728 Mon Sep 17 00:00:00 2001 From: alecpl <alec@alec.pl> Date: Tue, 29 Apr 2008 04:13:26 -0400 Subject: [PATCH] #1485021: update dutch localization --- program/lib/imap.inc | 2591 +++++++++++++++++++++++++++++++++++----------------------- 1 files changed, 1,544 insertions(+), 1,047 deletions(-) diff --git a/program/lib/imap.inc b/program/lib/imap.inc index 6bc47a1..918e71a 100644 --- a/program/lib/imap.inc +++ b/program/lib/imap.inc @@ -48,24 +48,46 @@ - Also acceppt LIST responses in iil_C_ListSubscribed() - Sanity check of $message_set in iil_C_FetchHeaders(), iil_C_FetchHeaderIndex(), iil_C_FetchThreadHeaders() - Implemented UID FETCH in iil_C_FetchHeaders() + - Abort do-loop on socket errors (fgets returns false) + - $ICL_SSL is not boolean anymore but contains the connection schema (ssl or tls) - Removed some debuggers (echo ...) ********************************************************/ +/** + * @todo Possibly clean up more CS. + * @todo Try to replace most double-quotes with single-quotes. + * @todo Split this file into smaller files. + * @todo Refactor code. + * @todo Replace echo-debugging (make it adhere to config setting and log) + */ // changed path to work within roundcube webmail -include_once("lib/icl_commons.inc"); +include_once 'lib/icl_commons.inc'; -if (!$IMAP_USE_HEADER_DATE) $IMAP_USE_INTERNAL_DATE = true; -$IMAP_MONTHS=array("Jan"=>1,"Feb"=>2,"Mar"=>3,"Apr"=>4,"May"=>5,"Jun"=>6,"Jul"=>7,"Aug"=>8,"Sep"=>9,"Oct"=>10,"Nov"=>11,"Dec"=>12); -$IMAP_SERVER_TZ = date('Z'); +if (!isset($IMAP_USE_HEADER_DATE) || !$IMAP_USE_HEADER_DATE) { + $IMAP_USE_INTERNAL_DATE = true; +} + +/** + * @todo Maybe use date() to generate this. + */ +$GLOBALS['IMAP_MONTHS'] = array("Jan" => 1, "Feb" => 2, "Mar" => 3, "Apr" => 4, + "May" => 5, "Jun" => 6, "Jul" => 7, "Aug" => 8, "Sep" => 9, "Oct" => 10, + "Nov" => 11, "Dec" => 12); + +$GLOBALS['IMAP_SERVER_TZ'] = date('Z'); $iil_error; $iil_errornum; $iil_selected; -class iilConnection{ +/** + * @todo Change class vars to public/private + */ +class iilConnection +{ var $fp; var $error; var $errorNum; @@ -82,7 +104,11 @@ var $capability = array(); } -class iilBasicHeader{ +/** + * @todo Change class vars to public/private + */ +class iilBasicHeader +{ var $id; var $uid; var $subject; @@ -95,21 +121,29 @@ var $messageID; var $size; var $encoding; + var $charset; var $ctype; var $flags; var $timestamp; var $f; - var $seen; - var $deleted; - var $recent; - var $answered; - var $junk; var $internaldate; - var $is_reply; + var $references; + var $priority; + var $mdn_to; + var $mdn_sent = false; + var $is_reply = false; + var $seen = false; + var $deleted = false; + var $recent = false; + var $answered = false; + var $junk = false; } - -class iilThreadHeader{ +/** + * @todo Change class vars to public/private + */ +class iilThreadHeader +{ var $id; var $sbj; var $irt; @@ -117,201 +151,258 @@ } -function iil_xor($string, $string2){ - $result = ""; +function iil_xor($string, $string2) { + $result = ''; $size = strlen($string); - for ($i=0; $i<$size; $i++) $result .= chr(ord($string[$i]) ^ ord($string2[$i])); - + for ($i=0; $i<$size; $i++) { + $result .= chr(ord($string[$i]) ^ ord($string2[$i])); + } return $result; } -function iil_ReadLine($fp, $size){ - $line=""; - if ($fp){ - do{ - $buffer = fgets($fp, 2048); - $line.=$buffer; - }while($buffer[strlen($buffer)-1]!="\n"); - } - return $line; +function iil_ReadLine($fp, $size) { + $line = ''; + if (!$fp) { + return $line; + } + do { + // FIXME: hardcode size? + $buffer = fgets($fp, 2048); + if ($buffer === false) { + break; + } + $line .= $buffer; + } while ($buffer[strlen($buffer)-1] != "\n"); + return $line; } -function iil_MultLine($fp, $line){ +function iil_MultLine($fp, $line) { $line = chop($line); - if (ereg('\{[0-9]+\}$', $line)){ - $out = ""; + if (ereg('\{[0-9]+\}$', $line)) { + $out = ''; + preg_match_all('/(.*)\{([0-9]+)\}$/', $line, $a); $bytes = $a[2][0]; - while(strlen($out)<$bytes){ - $out.=chop(iil_ReadLine($fp, 1024)); + while (strlen($out) < $bytes) { + $line = iil_ReadLine($fp, 1024); + $out .= chop($line); } - $line = $a[1][0]."\"$out\""; + $line = $a[1][0] . "\"$out\""; } return $line; } -function iil_ReadBytes($fp, $bytes){ - $data = ""; - $len = 0; - do{ - $data.=fread($fp, $bytes-$len); - $len = strlen($data); - }while($len<$bytes); - return $data; +function iil_ReadBytes($fp, $bytes) { + $data = ''; + $len = 0; + do { + $data .= fread($fp, $bytes-$len); + if ($len == strlen($data)) { + break; //nothing was read -> exit to avoid apache lockups + } + $len = strlen($data); + } while ($len < $bytes); + return $data; } -function iil_ReadReply($fp){ - do{ +function iil_ReadReply($fp) { + do { $line = chop(trim(iil_ReadLine($fp, 1024))); - }while($line[0]=="*"); + } while ($line[0] == '*'); return $line; } -function iil_ParseResult($string){ - $a=explode(" ", $string); - if (count($a) > 2){ - if (strcasecmp($a[1], "OK")==0) return 0; - else if (strcasecmp($a[1], "NO")==0) return -1; - else if (strcasecmp($a[1], "BAD")==0) return -2; - }else return -3; +function iil_ParseResult($string) { + $a=explode(' ', $string); + if (count($a) > 2) { + if (strcasecmp($a[1], 'OK') == 0) { + return 0; + } else if (strcasecmp($a[1], 'NO') == 0) { + return -1; + } else if (strcasecmp($a[1], 'BAD') == 0) { + return -2; + } + } + return -3; } // check if $string starts with $match -function iil_StartsWith($string, $match){ +function iil_StartsWith($string, $match) { $len = strlen($match); - if ($len==0) return false; - if (strncmp($string, $match, $len)==0) return true; - else return false; + if ($len == 0) { + return false; + } + if (strncmp($string, $match, $len) == 0) { + return true; + } + return false; } -function iil_StartsWithI($string, $match){ +function iil_StartsWithI($string, $match) { $len = strlen($match); - if ($len==0) return false; - if (strncasecmp($string, $match, $len)==0) return true; - else return false; + if ($len == 0) { + return false; + } + if (strncasecmp($string, $match, $len) == 0) { + return true; + } + return false; } -function iil_C_Authenticate(&$conn, $user, $pass, $encChallenge){ +function iil_C_Authenticate(&$conn, $user, $pass, $encChallenge) { + + $ipad = ''; + $opad = ''; // initialize ipad, opad - for ($i=0;$i<64;$i++){ - $ipad.=chr(0x36); - $opad.=chr(0x5C); + for ($i=0;$i<64;$i++) { + $ipad .= chr(0x36); + $opad .= chr(0x5C); } // pad $pass so it's 64 bytes $padLen = 64 - strlen($pass); - for ($i=0;$i<$padLen;$i++) $pass .= chr(0); + for ($i=0;$i<$padLen;$i++) { + $pass .= chr(0); + } + // generate hash - $hash = md5(iil_xor($pass,$opad).pack("H*",md5(iil_xor($pass, $ipad).base64_decode($encChallenge)))); + $hash = iil_xor($pass,$opad); + $hash .= pack("H*", md5(iil_xor($pass, $ipad) . base64_decode($encChallenge))); + $hash = md5($hash); + // generate reply - $reply = base64_encode($user." ".$hash); + $reply = base64_encode('"' . $user . '" "' . $hash . '"'); // send result, get reply - fputs($conn->fp, $reply."\r\n"); + fputs($conn->fp, $reply . "\r\n"); $line = iil_ReadLine($conn->fp, 1024); // process result - if (iil_ParseResult($line)==0){ - $conn->error .= ""; - $conn->errorNum = 0; + if (iil_ParseResult($line) == 0) { + $conn->error .= ''; + $conn->errorNum = 0; return $conn->fp; - }else{ - $conn->error .= 'Authentication for '.$user.' failed (AUTH): "'.htmlspecialchars($line)."\""; - $conn->errorNum = -2; - return false; } + $conn->error .= 'Authentication for ' . $user . ' failed (AUTH): "'; + $conn->error .= htmlspecialchars($line) . '"'; + $conn->errorNum = -2; + return false; } -function iil_C_Login(&$conn, $user, $password){ +function iil_C_Login(&$conn, $user, $password) { $password = strtr($password, array('"'=>'\\"', '\\' => '\\\\')); fputs($conn->fp, "a001 LOGIN $user \"$password\"\r\n"); - do{ - $line = iil_ReadReply($conn->fp); - }while(!iil_StartsWith($line, "a001 ")); - $a=explode(" ", $line); - if (strcmp($a[1],"OK")==0){ - $result=$conn->fp; - $conn->error.=""; - $conn->errorNum = 0; - }else{ - $result=false; - fclose($conn->fp); - $conn->error .= 'Authentication for '.$user.' failed (LOGIN): "'.htmlspecialchars($line)."\""; - $conn->errorNum = -2; + do { + $line = iil_ReadReply($conn->fp); + if ($line === false) { + break; + } + } while (!iil_StartsWith($line, "a001 ")); + $a = explode(' ', $line); + if (strcmp($a[1], 'OK') == 0) { + $result = $conn->fp; + $conn->error .= ''; + $conn->errorNum = 0; + return $result; } + $result = false; + fclose($conn->fp); + + $conn->error .= 'Authentication for ' . $user . ' failed (LOGIN): "'; + $conn->error .= htmlspecialchars($line)."\""; + $conn->errorNum = -2; + return $result; } -function iil_ParseNamespace2($str, &$i, $len=0, $l){ - if (!$l) $str = str_replace("NIL", "()", $str); - if (!$len) $len = strlen($str); - $data = array(); +function iil_ParseNamespace2($str, &$i, $len=0, $l) { + if (!$l) { + $str = str_replace('NIL', '()', $str); + } + if (!$len) { + $len = strlen($str); + } + $data = array(); $in_quotes = false; - $elem = 0; - for($i;$i<$len;$i++){ + $elem = 0; + for ($i;$i<$len;$i++) { $c = (string)$str[$i]; - if ($c=='(' && !$in_quotes){ + if ($c == '(' && !$in_quotes) { $i++; $data[$elem] = iil_ParseNamespace2($str, $i, $len, $l++); $elem++; - }else if ($c==')' && !$in_quotes) return $data; - else if ($c=="\\"){ + } else if ($c == ')' && !$in_quotes) { + return $data; + } else if ($c == '\\') { $i++; - if ($in_quotes) $data[$elem].=$c.$str[$i]; - }else if ($c=='"'){ + if ($in_quotes) { + $data[$elem] .= $c.$str[$i]; + } + } else if ($c == '"') { $in_quotes = !$in_quotes; - if (!$in_quotes) $elem++; - }else if ($in_quotes){ + if (!$in_quotes) { + $elem++; + } + } else if ($in_quotes) { $data[$elem].=$c; } } return $data; } -function iil_C_NameSpace(&$conn){ +function iil_C_NameSpace(&$conn) { global $my_prefs; - if (!in_array('NAMESPACE', $conn->capability)) - return false; - - if ($my_prefs["rootdir"]) return true; - + if (!in_array('NAMESPACE', $conn->capability)) { + return false; + } + + if ($my_prefs["rootdir"]) { + return true; + } + fputs($conn->fp, "ns1 NAMESPACE\r\n"); - do{ + do { $line = iil_ReadLine($conn->fp, 1024); - if (iil_StartsWith($line, "* NAMESPACE")){ - $i = 0; + if (iil_StartsWith($line, '* NAMESPACE')) { + $i = 0; $data = iil_ParseNamespace2(substr($line,11), $i, 0, 0); } - }while(!iil_StartsWith($line, "ns1")); + } while (!iil_StartsWith($line, "ns1")); - if (!is_array($data)) return false; - + if (!is_array($data)) { + return false; + } + $user_space_data = $data[0]; - if (!is_array($user_space_data)) return false; - + if (!is_array($user_space_data)) { + return false; + } + $first_userspace = $user_space_data[0]; - if (count($first_userspace)!=2) return false; - - $conn->rootdir = $first_userspace[0]; - $conn->delimiter = $first_userspace[1]; + if (count($first_userspace)!=2) { + return false; + } + + $conn->rootdir = $first_userspace[0]; + $conn->delimiter = $first_userspace[1]; $my_prefs["rootdir"] = substr($conn->rootdir, 0, -1); return true; } -function iil_Connect($host, $user, $password){ +function iil_Connect($host, $user, $password) { global $iil_error, $iil_errornum; global $ICL_SSL, $ICL_PORT; global $IMAP_NO_CACHE; global $my_prefs, $IMAP_USE_INTERNAL_DATE; - $iil_error = ""; + $iil_error = ''; $iil_errornum = 0; //strip slashes @@ -319,97 +410,123 @@ // $password = stripslashes($password); //set auth method - $auth_method = "plain"; - if (func_num_args() >= 4){ + $auth_method = 'plain'; + if (func_num_args() >= 4) { $auth_array = func_get_arg(3); - if (is_array($auth_array)) $auth_method = $auth_array["imap"]; - if (empty($auth_method)) $auth_method = "plain"; + if (is_array($auth_array)) { + $auth_method = $auth_array['imap']; + } + if (empty($auth_method)) { + $auth_method = "plain"; + } } $message = "INITIAL: $auth_method\n"; $result = false; //initialize connection - $conn = new iilConnection; - $conn->error=""; - $conn->errorNum=0; - $conn->selected=""; - $conn->user = $user; - $conn->host = $host; - $conn->cache = array(); - $conn->do_cache = (function_exists("cache_write")&&!$IMAP_NO_CACHE); + $conn = new iilConnection; + $conn->error = ''; + $conn->errorNum = 0; + $conn->selected = ''; + $conn->user = $user; + $conn->host = $host; + $conn->cache = array(); + $conn->do_cache = (function_exists("cache_write")&&!$IMAP_NO_CACHE); $conn->cache_dirty = array(); - if ($my_prefs['sort_field']=='INTERNALDATE') $IMAP_USE_INTERNAL_DATE = true; - else if ($my_prefs['sort_field']=='DATE') $IMAP_USE_INTERNAL_DATE = false; + if ($my_prefs['sort_field'] == 'INTERNALDATE') { + $IMAP_USE_INTERNAL_DATE = true; + } else if ($my_prefs['sort_field'] == 'DATE') { + $IMAP_USE_INTERNAL_DATE = false; + } //echo '<!-- conn sort_field: '.$my_prefs['sort_field'].' //-->'; //check input - if (empty($host)) $iil_error .= "Invalid host\n"; - if (empty($user)) $iil_error .= "Invalid user\n"; - if (empty($password)) $iil_error .= "Invalid password\n"; - if (!empty($iil_error)) return false; - if (!$ICL_PORT) $ICL_PORT = 143; - + if (empty($host)) { + $iil_error .= "Invalid host\n"; + } + if (empty($user)) { + $iil_error .= "Invalid user\n"; + } + if (empty($password)) { + $iil_error .= "Invalid password\n"; + } + if (!empty($iil_error)) { + return false; + } + if (!$ICL_PORT) { + $ICL_PORT = 143; + } + //check for SSL - if ($ICL_SSL){ - $host = "ssl://".$host; + if ($ICL_SSL) { + $host = $ICL_SSL . '://' . $host; } //open socket connection - $conn->fp = @fsockopen($host, $ICL_PORT, $errno, $errstr, 10); - if (!$conn->fp){ - $iil_error = "Could not connect to $host at port $ICL_PORT: $errstr"; + $conn->fp = fsockopen($host, $ICL_PORT, $errno, $errstr, 10); + if (!$conn->fp) { + $iil_error = "Could not connect to $host at port $ICL_PORT: $errstr"; $iil_errornum = -1; return false; } - $iil_error.="Socket connection established\r\n"; - $line=iil_ReadLine($conn->fp, 300); + $iil_error .= "Socket connection established\r\n"; + $line = iil_ReadLine($conn->fp, 300); - if (strcasecmp($auth_method, "check")==0){ + if (strcasecmp($auth_method, "check") == 0) { //check for supported auth methods //default to plain text auth - $auth_method = "plain"; + $auth_method = 'plain'; //check for CRAM-MD5 fputs($conn->fp, "cp01 CAPABILITY\r\n"); - do{ - $line = trim(chop(iil_ReadLine($conn->fp, 100))); - $conn->message.="$line\n"; - $a = explode(" ", $line); - if ($line[0]=="*"){ - while ( list($k, $w) = each($a) ){ - if ($w!='*' && $w!='CAPABILITY') + do { + $line = trim(chop(iil_ReadLine($conn->fp, 100))); + + $conn->message .= "$line\n"; + + $a = explode(' ', $line); + if ($line[0] == '*') { + while (list($k, $w) = each($a)) { + if ($w != '*' && $w != 'CAPABILITY') { $conn->capability[] = $w; - if ((strcasecmp($w, "AUTH=CRAM_MD5")==0)|| - (strcasecmp($w, "AUTH=CRAM-MD5")==0)){ - $auth_method = "auth"; - } + } + if ((strcasecmp($w, "AUTH=CRAM_MD5") == 0)|| + (strcasecmp($w, "AUTH=CRAM-MD5") == 0)) { + $auth_method = "auth"; + } } } - }while($a[0]!="cp01"); + } while ($a[0] != 'cp01'); } - if (strcasecmp($auth_method, "auth")==0){ - $conn->message.="Trying CRAM-MD5\n"; + if (strcasecmp($auth_method, 'auth') == 0) { + $conn->message .= "Trying CRAM-MD5\n"; + //do CRAM-MD5 authentication fputs($conn->fp, "a000 AUTHENTICATE CRAM-MD5\r\n"); $line = trim(chop(iil_ReadLine($conn->fp, 1024))); - $conn->message.="$line\n"; - if ($line[0]=="+"){ - $conn->message.='Got challenge: '.htmlspecialchars($line)."\n"; + + $conn->message .= "$line\n"; + + if ($line[0] == '+') { + $conn->message .= 'Got challenge: ' . htmlspecialchars($line) . "\n"; + //got a challenge string, try CRAM-5 $result = iil_C_Authenticate($conn, $user, $password, substr($line,2)); - $conn->message.= "Tried CRAM-MD5: $result \n"; - }else{ - $conn->message.='No challenge ('.htmlspecialchars($line)."), try plain\n"; - $auth = "plain"; + + $conn->message .= "Tried CRAM-MD5: $result \n"; + } else { + $conn->message .='No challenge ('.htmlspecialchars($line)."), try plain\n"; + + $auth = 'plain'; } } - if ((!$result)||(strcasecmp($auth, "plain")==0)){ + if ((!$result)||(strcasecmp($auth, "plain") == 0)) { //do plain text auth $result = iil_C_Login($conn, $user, $password); $conn->message.="Tried PLAIN: $result \n"; @@ -417,36 +534,36 @@ $conn->message .= $auth; - if ($result){ + if ($result) { iil_C_Namespace($conn); return $conn; - }else{ + } else { $iil_error = $conn->error; $iil_errornum = $conn->errorNum; return false; } } -function iil_Close(&$conn){ +function iil_Close(&$conn) { iil_C_WriteCache($conn); - if (@fputs($conn->fp, "I LOGOUT\r\n")){ + if (fputs($conn->fp, "I LOGOUT\r\n")) { fgets($conn->fp, 1024); fclose($conn->fp); $conn->fp = false; } } -function iil_ClearCache($user, $host){ +function iil_ClearCache($user, $host) { } -function iil_C_WriteCache(&$conn){ +function iil_C_WriteCache(&$conn) { //echo "<!-- doing iil_C_WriteCache //-->\n"; if (!$conn->do_cache) return false; - if (is_array($conn->cache)){ - while(list($folder,$data)=each($conn->cache)){ - if ($folder && is_array($data) && $conn->cache_dirty[$folder]){ + if (is_array($conn->cache)) { + while (list($folder,$data)=each($conn->cache)) { + if ($folder && is_array($data) && $conn->cache_dirty[$folder]) { $key = $folder.".imap"; $result = cache_write($conn->user, $conn->host, $key, $data, true); //echo "<!-- writing $key $data: $result //-->\n"; @@ -455,35 +572,43 @@ } } -function iil_C_EnableCache(&$conn){ +function iil_C_EnableCache(&$conn) { $conn->do_cache = true; } -function iil_C_DisableCache(&$conn){ +function iil_C_DisableCache(&$conn) { $conn->do_cache = false; } -function iil_C_LoadCache(&$conn, $folder){ - if (!$conn->do_cache) return false; - - $key = $folder.".imap"; - if (!is_array($conn->cache[$folder])){ - $conn->cache[$folder] = cache_read($conn->user, $conn->host, $key); +function iil_C_LoadCache(&$conn, $folder) { + if (!$conn->do_cache) { + return false; + } + + $key = $folder.'.imap'; + if (!is_array($conn->cache[$folder])) { + $conn->cache[$folder] = cache_read($conn->user, $conn->host, $key); $conn->cache_dirty[$folder] = false; } } -function iil_C_ExpireCachedItems(&$conn, $folder, $message_set){ +function iil_C_ExpireCachedItems(&$conn, $folder, $message_set) { - if (!$conn->do_cache) return; //caching disabled - if (!is_array($conn->cache[$folder])) return; //cache not initialized|empty - if (count($conn->cache[$folder])==0) return; //cache not initialized|empty - - $uids = iil_C_FetchHeaderIndex($conn, $folder, $message_set, "UID"); + if (!$conn->do_cache) { + return; //caching disabled + } + if (!is_array($conn->cache[$folder])) { + return; //cache not initialized|empty + } + if (count($conn->cache[$folder]) == 0) { + return; //cache not initialized|empty + } + + $uids = iil_C_FetchHeaderIndex($conn, $folder, $message_set, 'UID'); $num_removed = 0; - if (is_array($uids)){ + if (is_array($uids)) { //echo "<!-- unsetting: ".implode(",",$uids)." //-->\n"; - while(list($n,$uid)=each($uids)){ + while (list($n,$uid)=each($uids)) { unset($conn->cache[$folder][$uid]); //$conn->cache[$folder][$uid] = false; //$num_removed++; @@ -493,15 +618,15 @@ //echo '<!--'."\n"; //print_r($conn->cache); //echo "\n".'//-->'."\n"; - }else{ + } else { echo "<!-- failed to get uids: $message_set //-->\n"; } /* - if ($num_removed>0){ + if ($num_removed>0) { $new_cache; reset($conn->cache[$folder]); - while(list($uid,$item)=each($conn->cache[$folder])){ + while (list($uid,$item)=each($conn->cache[$folder])) { if ($item) $new_cache[$uid] = $conn->cache[$folder][$uid]; } $conn->cache[$folder] = $new_cache; @@ -509,125 +634,153 @@ */ } -function iil_ExplodeQuotedString($delimiter, $string){ - $quotes=explode("\"", $string); - while ( list($key, $val) = each($quotes)) - if (($key % 2) == 1) +function iil_ExplodeQuotedString($delimiter, $string) { + $quotes=explode('"', $string); + while ( list($key, $val) = each($quotes)) { + if (($key % 2) == 1) { $quotes[$key] = str_replace($delimiter, "_!@!_", $quotes[$key]); - $string=implode("\"", $quotes); + } + } + $string=implode('"', $quotes); $result=explode($delimiter, $string); - while ( list($key, $val) = each($result) ) - $result[$key] = str_replace("_!@!_", $delimiter, $result[$key]); - + while ( list($key, $val) = each($result) ) { + $result[$key] = str_replace('_!@!_', $delimiter, $result[$key]); + } + return $result; } -function iil_CheckForRecent($host, $user, $password, $mailbox){ - if (empty($mailbox)) $mailbox="INBOX"; - - $conn=iil_Connect($host, $user, $password, "plain"); - $fp = $conn->fp; - if ($fp){ +function iil_CheckForRecent($host, $user, $password, $mailbox) { + if (empty($mailbox)) { + $mailbox = 'INBOX'; + } + + $conn = iil_Connect($host, $user, $password, 'plain'); + $fp = $conn->fp; + if ($fp) { fputs($fp, "a002 EXAMINE \"$mailbox\"\r\n"); - do{ + do { $line=chop(iil_ReadLine($fp, 300)); - $a=explode(" ", $line); - if (($a[0]=="*") && (strcasecmp($a[2], "RECENT")==0)) $result=(int)$a[1]; - }while (!iil_StartsWith($a[0],"a002")); + $a=explode(' ', $line); + if (($a[0] == '*') && (strcasecmp($a[2], 'RECENT') == 0)) { + $result = (int) $a[1]; + } + } while (!iil_StartsWith($a[0], 'a002')); fputs($fp, "a003 LOGOUT\r\n"); fclose($fp); - }else $result=-2; - + } else { + $result = -2; + } + return $result; } -function iil_C_Select(&$conn, $mailbox){ +function iil_C_Select(&$conn, $mailbox) { $fp = $conn->fp; - if (empty($mailbox)) return false; - if (strcmp($conn->selected, $mailbox)==0) return true; - + if (empty($mailbox)) { + return false; + } + if (strcmp($conn->selected, $mailbox) == 0) { + return true; + } + iil_C_LoadCache($conn, $mailbox); - if (fputs($fp, "sel1 SELECT \"$mailbox\"\r\n")){ - do{ + if (fputs($fp, "sel1 SELECT \"$mailbox\"\r\n")) { + do { $line=chop(iil_ReadLine($fp, 300)); - $a=explode(" ", $line); - if (count($a) == 3){ - if (strcasecmp($a[2], "EXISTS")==0) $conn->exists=(int)$a[1]; - if (strcasecmp($a[2], "RECENT")==0) $conn->recent=(int)$a[1]; + $a=explode(' ', $line); + if (count($a) == 3) { + if (strcasecmp($a[2], 'EXISTS') == 0) { + $conn->exists = (int) $a[1]; + } + if (strcasecmp($a[2], 'RECENT') == 0) { + $conn->recent = (int) $a[1]; + } } - }while (!iil_StartsWith($line, "sel1")); + } while (!iil_StartsWith($line, 'sel1')); - $a=explode(" ", $line); + $a=explode(' ', $line); - if (strcasecmp($a[1],"OK")==0){ + if (strcasecmp($a[1], 'OK') == 0) { $conn->selected = $mailbox; return true; - }else return false; - }else{ - return false; + } } + return false; } -function iil_C_CheckForRecent(&$conn, $mailbox){ - if (empty($mailbox)) $mailbox="INBOX"; - +function iil_C_CheckForRecent(&$conn, $mailbox) { + if (empty($mailbox)) { + $mailbox = 'INBOX'; + } + iil_C_Select($conn, $mailbox); - if ($conn->selected==$mailbox) return $conn->recent; - else return false; + if ($conn->selected == $mailbox) { + return $conn->recent; + } + return false; } -function iil_C_CountMessages(&$conn, $mailbox, $refresh=false){ - if ($refresh) $conn->selected=""; +function iil_C_CountMessages(&$conn, $mailbox, $refresh = false) { + if ($refresh) { + $conn->selected= ''; + } iil_C_Select($conn, $mailbox); - if ($conn->selected==$mailbox) return $conn->exists; - else return false; + if ($conn->selected == $mailbox) { + return $conn->exists; + } + return false; } -function iil_SplitHeaderLine($string){ - $pos=strpos($string, ":"); - if ($pos>0){ - $res[0]=substr($string, 0, $pos); - $res[1]=trim(substr($string, $pos+1)); +function iil_SplitHeaderLine($string) { + $pos=strpos($string, ':'); + if ($pos>0) { + $res[0] = substr($string, 0, $pos); + $res[1] = trim(substr($string, $pos+1)); return $res; - }else{ - return $string; } + return $string; } -function iil_StrToTime($str){ - global $IMAP_MONTHS,$IMAP_SERVER_TZ; +function iil_StrToTime($str) { + $IMAP_MONTHS = $GLOBALS['IMAP_MONTHS']; + $IMAP_SERVER_TZ = $GLOBALS['IMAP_SERVER_TR']; - if ($str) $time1 = strtotime($str); - if ($time1 && $time1!=-1) return $time1-$IMAP_SERVER_TZ; - + if ($str) { + $time1 = strtotime($str); + } + if ($time1 && $time1 != -1) { + return $time1-$IMAP_SERVER_TZ; + } //echo '<!--'.$str.'//-->'; //replace double spaces with single space $str = trim($str); - $str = str_replace(" ", " ", $str); + $str = str_replace(' ', ' ', $str); //strip off day of week - $pos=strpos($str, " "); - if (!is_numeric(substr($str, 0, $pos))) $str = substr($str, $pos+1); - + $pos = strpos($str, ' '); + if (!is_numeric(substr($str, 0, $pos))) { + $str = substr($str, $pos+1); + } //explode, take good parts - $a=explode(" ",$str); - //$month_a=array("Jan"=>1,"Feb"=>2,"Mar"=>3,"Apr"=>4,"May"=>5,"Jun"=>6,"Jul"=>7,"Aug"=>8,"Sep"=>9,"Oct"=>10,"Nov"=>11,"Dec"=>12); - $month_str=$a[1]; - $month=$IMAP_MONTHS[$month_str]; - $day=(int)$a[0]; - $year=(int)$a[2]; - $time=$a[3]; - $tz_str = $a[4]; - $tz = substr($tz_str, 0, 3); - $ta = explode(":",$time); - $hour=(int)$ta[0]-(int)$tz; - $minute=(int)$ta[1]; - $second=(int)$ta[2]; + $a = explode(' ', $str); + + $month_str = $a[1]; + $month = $IMAP_MONTHS[$month_str]; + $day = (int)$a[0]; + $year = (int)$a[2]; + $time = $a[3]; + $tz_str = $a[4]; + $tz = substr($tz_str, 0, 3); + $ta = explode(':', $time); + $hour = (int)$ta[0]-(int)$tz; + $minute = (int)$ta[1]; + $second = (int)$ta[2]; //make UNIX timestamp $time2 = mktime($hour, $minute, $second, $month, $day, $year); @@ -635,33 +788,45 @@ return $time2; } -function iil_C_Sort(&$conn, $mailbox, $field, $add='', $is_uid=FALSE, $encoding='US-ASCII'){ +function iil_C_Sort(&$conn, $mailbox, $field, $add='', $is_uid=FALSE, + $encoding = 'US-ASCII') { /* Do "SELECT" command */ - if (!iil_C_Select($conn, $mailbox)) return false; - + if (!iil_C_Select($conn, $mailbox)) { + return false; + } $field = strtoupper($field); - if ($field=='INTERNALDATE') $field='ARRIVAL'; - $fields = array('ARRIVAL'=>1,'CC'=>1,'DATE'=>1,'FROM'=>1,'SIZE'=>1,'SUBJECT'=>1,'TO'=>1); + if ($field == 'INTERNALDATE') { + $field = 'ARRIVAL'; + } + $fields = array('ARRIVAL' => 1,'CC' => 1,'DATE' => 1, + 'FROM' => 1, 'SIZE' => 1, 'SUBJECT' => 1, 'TO' => 1); - if (!$fields[$field]) - return false; - + if (!$fields[$field]) { + return false; + } + $is_uid = $is_uid ? 'UID ' : ''; - if (!empty($add)) - $add = " $add"; + if (!empty($add)) { + $add = " $add"; + } - $fp = $conn->fp; - $command = 's '. $is_uid .'SORT ('.$field.') '.$encoding.' ALL'."$add\r\n"; - $line = $data = ''; + $fp = $conn->fp; + $command = 's ' . $is_uid . 'SORT (' . $field . ') '; + $command .= $encoding . ' ALL' . "$add\r\n"; + $line = $data = ''; - if (!fputs($fp, $command)) return false; - do{ + if (!fputs($fp, $command)) { + return false; + } + do { $line = chop(iil_ReadLine($fp, 1024)); - if (iil_StartsWith($line, '* SORT')) $data.=($data?' ':'').substr($line,7); - }while($line[0]!='s'); + if (iil_StartsWith($line, '* SORT')) { + $data .= ($data?' ':'') . substr($line, 7); + } + } while ($line[0]!='s'); - if (empty($data)){ + if (empty($data)) { $conn->error = $line; return false; } @@ -670,67 +835,81 @@ return $out; } -function iil_C_FetchHeaderIndex(&$conn, $mailbox, $message_set, $index_field, $normalize=true){ +function iil_C_FetchHeaderIndex(&$conn, $mailbox, $message_set, $index_field, + $normalize=true) { global $IMAP_USE_INTERNAL_DATE; $c=0; $result=array(); $fp = $conn->fp; - if (empty($index_field)) $index_field="DATE"; + if (empty($index_field)) { + $index_field = 'DATE'; + } $index_field = strtoupper($index_field); list($from_idx, $to_idx) = explode(':', $message_set); - if (empty($message_set) || (isset($to_idx) && (int)$from_idx > (int)$to_idx)) + if (empty($message_set) || (isset($to_idx) + && (int)$from_idx > (int)$to_idx)) { return false; + } - //$fields_a["DATE"] = ($IMAP_USE_INTERNAL_DATE?6:1); - $fields_a['DATE'] = 1; + //$fields_a['DATE'] = ($IMAP_USE_INTERNAL_DATE?6:1); + $fields_a['DATE'] = 1; $fields_a['INTERNALDATE'] = 6; - $fields_a['FROM'] = 1; - $fields_a['REPLY-TO'] = 1; - $fields_a['SENDER'] = 1; - $fields_a['TO'] = 1; - $fields_a['SUBJECT'] = 1; - $fields_a['UID'] = 2; - $fields_a['SIZE'] = 2; - $fields_a['SEEN'] = 3; - $fields_a['RECENT'] = 4; - $fields_a['DELETED'] = 5; + $fields_a['FROM'] = 1; + $fields_a['REPLY-TO'] = 1; + $fields_a['SENDER'] = 1; + $fields_a['TO'] = 1; + $fields_a['SUBJECT'] = 1; + $fields_a['UID'] = 2; + $fields_a['SIZE'] = 2; + $fields_a['SEEN'] = 3; + $fields_a['RECENT'] = 4; + $fields_a['DELETED'] = 5; $mode=$fields_a[$index_field]; - if (!($mode > 0)) return false; - + if (!($mode > 0)) { + return false; + } + /* Do "SELECT" command */ - if (!iil_C_Select($conn, $mailbox)) return false; - + if (!iil_C_Select($conn, $mailbox)) { + return false; + } + /* FETCH date,from,subject headers */ - if ($mode==1){ - $key="fhi".($c++); - $request=$key." FETCH $message_set (BODY.PEEK[HEADER.FIELDS ($index_field)])\r\n"; - if (!fputs($fp, $request)) return false; - do{ + if ($mode == 1) { + $key = 'fhi' . ($c++); + $request = $key . " FETCH $message_set (BODY.PEEK[HEADER.FIELDS ($index_field)])\r\n"; + if (!fputs($fp, $request)) { + return false; + } + do { $line=chop(iil_ReadLine($fp, 200)); - $a=explode(" ", $line); - if (($line[0]=="*") && ($a[2]=="FETCH") && ($line[strlen($line)-1]!=")")){ + $a=explode(' ', $line); + if (($line[0] == '*') && ($a[2] == 'FETCH') + && ($line[strlen($line)-1] != ')')) { $id=$a[1]; $str=$line=chop(iil_ReadLine($fp, 300)); - while($line[0]!=")"){ //caution, this line works only in this particular case + while ($line[0] != ')') { //caution, this line works only in this particular case $line=chop(iil_ReadLine($fp, 300)); - if ($line[0]!=")"){ - if (ord($line[0]) <= 32){ //continuation from previous header line - $str.=" ".trim($line); + if ($line[0] != ')') { + if (ord($line[0]) <= 32) { //continuation from previous header line + $str.= ' ' . trim($line); } - if ((ord($line[0]) > 32) || (strlen($line[0]) == 0)){ + if ((ord($line[0]) > 32) || (strlen($line[0]) == 0)) { list($field, $string) = iil_SplitHeaderLine($str); - if (strcasecmp($field, "date")==0){ - $result[$id]=iil_StrToTime($string); - }else{ - $result[$id] = str_replace("\"", "", $string); - if ($normalize) $result[$id]=strtoupper($result[$id]); + if (strcasecmp($field, 'date') == 0) { + $result[$id] = iil_StrToTime($string); + } else { + $result[$id] = str_replace('"', '', $string); + if ($normalize) { + $result[$id] = strtoupper($result[$id]); + } } $str=$line; } @@ -739,277 +918,349 @@ } /* $end_pos = strlen($line)-1; - if (($line[0]=="*") && ($a[2]=="FETCH") && ($line[$end_pos]=="}")){ + if (($line[0]=="*") && ($a[2]=="FETCH") && ($line[$end_pos]=="}")) { $id = $a[1]; $pos = strrpos($line, "{")+1; $bytes = (int)substr($line, $pos, $end_pos-$pos); $received = 0; - do{ - $line = iil_ReadLine($fp, 0); - $received+=strlen($line); - $line = chop($line); + do { + $line = iil_ReadLine($fp, 0); + $received += strlen($line); + $line = chop($line); - if ($received>$bytes) break; - else if (!$line) continue; + if ($received>$bytes) { + break; + } else if (!$line) { + continue; + } + + list($field, $string) = explode(': ', $line); - list($field,$string)=explode(": ", $line); - - if (strcasecmp($field, "date")==0) + if (strcasecmp($field, 'date') == 0) { $result[$id] = iil_StrToTime($string); - else if ($index_field!="DATE") - $result[$id]=strtoupper(str_replace("\"", "", $string)); - }while($line[0]!=")"); - }else{ + } else if ($index_field != 'DATE') { + $result[$id]=strtoupper(str_replace('"', '', $string)); + } + } while ($line[0] != ')'); + } else { //one line response, not expected so ignore } */ - }while(!iil_StartsWith($line, $key)); - }else if ($mode==6){ - $key="fhi".($c++); - $request = $key." FETCH $message_set (INTERNALDATE)\r\n"; - if (!fputs($fp, $request)) return false; - do{ + } while (!iil_StartsWith($line, $key)); + + }else if ($mode == 6) { + + $key = 'fhi' . ($c++); + $request = $key . " FETCH $message_set (INTERNALDATE)\r\n"; + if (!fputs($fp, $request)) { + return false; + } + do { $line=chop(iil_ReadLine($fp, 200)); - if ($line[0]=="*"){ - //original: "* 10 FETCH (INTERNALDATE "31-Jul-2002 09:18:02 -0500")" - $paren_pos = strpos($line, "("); - $foo = substr($line, 0, $paren_pos); - $a = explode(" ", $foo); - $id = $a[1]; + if ($line[0] == '*') { + /* + * original: + * "* 10 FETCH (INTERNALDATE "31-Jul-2002 09:18:02 -0500")" + */ + $paren_pos = strpos($line, '('); + $foo = substr($line, 0, $paren_pos); + $a = explode(' ', $foo); + $id = $a[1]; - $open_pos = strpos($line, "\"") + 1; - $close_pos = strrpos($line, "\""); - if ($open_pos && $close_pos){ - $len = $close_pos - $open_pos; - $time_str = substr($line, $open_pos, $len); + $open_pos = strpos($line, '"') + 1; + $close_pos = strrpos($line, '"'); + if ($open_pos && $close_pos) { + $len = $close_pos - $open_pos; + $time_str = substr($line, $open_pos, $len); $result[$id] = strtotime($time_str); } - }else{ - $a = explode(" ", $line); + } else { + $a = explode(' ', $line); } - }while(!iil_StartsWith($a[0], $key)); - }else{ - if ($mode >= 3) $field_name="FLAGS"; - else if ($index_field=="SIZE") $field_name="RFC822.SIZE"; - else $field_name=$index_field; - + } while (!iil_StartsWith($a[0], $key)); + } else { + if ($mode >= 3) { + $field_name = 'FLAGS'; + } else if ($index_field == 'SIZE') { + $field_name = 'RFC822.SIZE'; + } else { + $field_name = $index_field; + } + /* FETCH uid, size, flags */ - $key="fhi".($c++); - $request=$key." FETCH $message_set ($field_name)\r\n"; + $key = 'fhi' .($c++); + $request = $key . " FETCH $message_set ($field_name)\r\n"; - if (!fputs($fp, $request)) return false; - do{ + if (!fputs($fp, $request)) { + return false; + } + do { $line=chop(iil_ReadLine($fp, 200)); - $a = explode(" ", $line); - if (($line[0]=="*") && ($a[2]=="FETCH")){ - $line=str_replace("(", "", $line); - $line=str_replace(")", "", $line); - $a=explode(" ", $line); + $a = explode(' ', $line); + if (($line[0] == '*') && ($a[2] == 'FETCH')) { + $line = str_replace('(', '', $line); + $line = str_replace(')', '', $line); + $a = explode(' ', $line); - $id=$a[1]; + $id = $a[1]; - if (isset($result[$id])) continue; //if we already got the data, skip forward - if ($a[3]!=$field_name) continue; //make sure it's returning what we requested - + if (isset($result[$id])) { + continue; //if we already got the data, skip forward + } + if ($a[3]!=$field_name) { + continue; //make sure it's returning what we requested + } + /* Caution, bad assumptions, next several lines */ - if ($mode==2) $result[$id]=$a[4]; - else{ - $haystack=strtoupper($line); - $result[$id]=(strpos($haystack, $index_field) > 0 ? "F" : "N"); + if ($mode == 2) { + $result[$id] = $a[4]; + } else { + $haystack = strtoupper($line); + $result[$id] = (strpos($haystack, $index_field) > 0 ? "F" : "N"); } } - }while(!iil_StartsWith($line, $key)); + } while (!iil_StartsWith($line, $key)); } //check number of elements... - list($start_mid,$end_mid)=explode(':',$message_set); - if (is_numeric($start_mid) && is_numeric($end_mid)){ + list($start_mid, $end_mid) = explode(':', $message_set); + if (is_numeric($start_mid) && is_numeric($end_mid)) { //count how many we should have $should_have = $end_mid - $start_mid +1; //if we have less, try and fill in the "gaps" - if (count($result)<$should_have){ - for($i=$start_mid;$i<=$end_mid;$i++) if (!isset($result[$i])) $result[$i] = ''; + if (count($result) < $should_have) { + for ($i=$start_mid; $i<=$end_mid; $i++) { + if (!isset($result[$i])) { + $result[$i] = ''; + } + } } } - return $result; - } -function iil_CompressMessageSet($message_set){ +function iil_CompressMessageSet($message_set) { //given a comma delimited list of independent mid's, //compresses by grouping sequences together //if less than 255 bytes long, let's not bother - if (strlen($message_set)<255) return $message_set; - + if (strlen($message_set)<255) { + return $message_set; + } + //see if it's already been compress - if (strpos($message_set,':')!==false) return $message_set; - + if (strpos($message_set, ':') !== false) { + return $message_set; + } + //separate, then sort - $ids = explode(',',$message_set); + $ids = explode(',', $message_set); sort($ids); $result = array(); - $start = $prev = $ids[0]; - foreach($ids as $id){ + $start = $prev = $ids[0]; + + foreach ($ids as $id) { $incr = $id - $prev; - if ($incr>1){ //found a gap - if ($start==$prev) $result[] = $prev; //push single id - else $result[] = $start.':'.$prev; //push sequence as start_id:end_id - $start = $id; //start of new sequence + if ($incr > 1) { //found a gap + if ($start == $prev) { + $result[] = $prev; //push single id + } else { + $result[] = $start . ':' . $prev; //push sequence as start_id:end_id + } + $start = $id; //start of new sequence } $prev = $id; } //handle the last sequence/id - if ($start==$prev) $result[] = $prev; - else $result[] = $start.':'.$prev; - + if ($start==$prev) { + $result[] = $prev; + } else { + $result[] = $start.':'.$prev; + } + //return as comma separated string - return implode(',',$result); + return implode(',', $result); } -function iil_C_UIDsToMIDs(&$conn, $mailbox, $uids){ - if (!is_array($uids) || count($uids)==0) return array(); - return iil_C_Search($conn, $mailbox, "UID ".implode(",", $uids)); +function iil_C_UIDsToMIDs(&$conn, $mailbox, $uids) { + if (!is_array($uids) || count($uids) == 0) { + return array(); + } + return iil_C_Search($conn, $mailbox, 'UID ' . implode(',', $uids)); } -function iil_C_UIDToMID(&$conn, $mailbox, $uid){ +function iil_C_UIDToMID(&$conn, $mailbox, $uid) { $result = iil_C_UIDsToMIDs($conn, $mailbox, array($uid)); - if (count($result)==1) return $result[0]; - else return false; + if (count($result) == 1) { + return $result[0]; + } + return false; } -function iil_C_FetchUIDs(&$conn,$mailbox){ +function iil_C_FetchUIDs(&$conn,$mailbox) { global $clock; $num = iil_C_CountMessages($conn, $mailbox); - if ($num==0) return array(); - $message_set = '1'.($num>1?':'.$num:''); + if ($num == 0) { + return array(); + } + $message_set = '1' . ($num>1?':' . $num:''); //if cache not enabled, just call iil_C_FetchHeaderIndex on 'UID' field if (!$conn->do_cache) return iil_C_FetchHeaderIndex($conn, $mailbox, $message_set, 'UID'); //otherwise, let's check cache first - $key = $mailbox.'.uids'; + $key = $mailbox.'.uids'; $cache_good = true; - if ($conn->uid_cache) $data = $conn->uid_cache; - else $data = cache_read($conn->user, $conn->host, $key); - + if ($conn->uid_cache) { + $data = $conn->uid_cache; + } else { + $data = cache_read($conn->user, $conn->host, $key); + } + //was anything cached at all? - if ($data===false) $cache_good = -1; - + if ($data === false) { + $cache_good = -1; + } + //make sure number of messages were the same - if ($cache_good>0 && $data['n']!=$num) $cache_good = -2; - + if ($cache_good > 0 && $data['n'] != $num) { + $cache_good = -2; + } + //if everything's okay so far... - if ($cache_good>0){ + if ($cache_good > 0) { //check UIDs of highest mid with current and cached - $temp = iil_C_Search($conn, $mailbox, 'UID '.$data['d'][$num]); - if (!$temp || !is_array($temp) || $temp[0]!=$num) $cache_good=-3; + $temp = iil_C_Search($conn, $mailbox, 'UID ' . $data['d'][$num]); + if (!$temp || !is_array($temp) || $temp[0] != $num) { + $cache_good = -3; + } } //if cached data's good, return it - if ($cache_good>0){ + if ($cache_good > 0) { return $data['d']; } //otherwise, we need to fetch it - $data = array('n'=>$num,'d'=>array()); + $data = array('n' => $num, 'd' => array()); $data['d'] = iil_C_FetchHeaderIndex($conn, $mailbox, $message_set, 'UID'); + cache_write($conn->user, $conn->host, $key, $data); $conn->uid_cache = $data; return $data['d']; } -function iil_SortThreadHeaders($headers, $index_a, $uids){ +function iil_SortThreadHeaders($headers, $index_a, $uids) { asort($index_a); $result = array(); - foreach($index_a as $mid=>$foobar){ + foreach ($index_a as $mid=>$foobar) { $uid = $uids[$mid]; $result[$uid] = $headers[$uid]; } return $result; } -function iil_C_FetchThreadHeaders(&$conn, $mailbox, $message_set){ +function iil_C_FetchThreadHeaders(&$conn, $mailbox, $message_set) { global $clock; global $index_a; list($from_idx, $to_idx) = explode(':', $message_set); - if (empty($message_set) || (isset($to_idx) && (int)$from_idx > (int)$to_idx)) + if (empty($message_set) || (isset($to_idx) + && (int)$from_idx > (int)$to_idx)) { return false; + } $result = array(); - $uids = iil_C_FetchUIDs($conn, $mailbox); - $debug = false; + $uids = iil_C_FetchUIDs($conn, $mailbox); + $debug = false; /* Get cached records where possible */ - if ($conn->do_cache){ + if ($conn->do_cache) { $cached = cache_read($conn->user, $conn->host, $mailbox.'.thhd'); - if ($cached && is_array($uids) && count($uids)>0){ - $needed_set = ""; - foreach($uids as $id=>$uid){ - if ($cached[$uid]){ - $result[$uid] = $cached[$uid]; + if ($cached && is_array($uids) && count($uids)>0) { + $needed_set = ''; + foreach ($uids as $id=>$uid) { + if ($cached[$uid]) { + $result[$uid] = $cached[$uid]; $result[$uid]->id = $id; - }else $needed_set.=($needed_set?",":"").$id; + } else { + $needed_set .= ($needed_set ? ',' : '') . $id; + } } - if ($needed_set) $message_set = $needed_set; - else $message_set = ''; + if ($needed_set) { + $message_set = $needed_set; + } else { + $message_set = ''; + } } } $message_set = iil_CompressMessageSet($message_set); - if ($debug) echo "Still need: ".$message_set; - + if ($debug) { + echo "Still need: ".$message_set; + } + /* if we're missing any, get them */ - if ($message_set){ + if ($message_set) { /* FETCH date,from,subject headers */ - $key="fh"; - $fp = $conn->fp; - $request=$key." FETCH $message_set (BODY.PEEK[HEADER.FIELDS (SUBJECT MESSAGE-ID IN-REPLY-TO)])\r\n"; - $mid_to_id = array(); - if (!fputs($fp, $request)) return false; - do{ + $key = 'fh'; + $fp = $conn->fp; + $request = $key . " FETCH $message_set "; + $request .= "(BODY.PEEK[HEADER.FIELDS (SUBJECT MESSAGE-ID IN-REPLY-TO)])\r\n"; + $mid_to_id = array(); + if (!fputs($fp, $request)) { + return false; + } + do { $line = chop(iil_ReadLine($fp, 1024)); - if ($debug) echo $line."\n"; - if (ereg('\{[0-9]+\}$', $line)){ - $a = explode(" ", $line); + if ($debug) { + echo $line . "\n"; + } + if (ereg('\{[0-9]+\}$', $line)) { + $a = explode(' ', $line); $new = array(); $new_thhd = new iilThreadHeader; $new_thhd->id = $a[1]; - do{ - $line=chop(iil_ReadLine($fp, 1024),"\r\n"); - if (iil_StartsWithI($line,'Message-ID:') || (iil_StartsWithI($line,'In-Reply-To:')) || (iil_StartsWithI($line,'SUBJECT:'))){ - $pos = strpos($line, ":"); + do { + $line = chop(iil_ReadLine($fp, 1024), "\r\n"); + if (iil_StartsWithI($line, 'Message-ID:') + || (iil_StartsWithI($line,'In-Reply-To:')) + || (iil_StartsWithI($line,'SUBJECT:'))) { + + $pos = strpos($line, ':'); $field_name = substr($line, 0, $pos); - $field_val = substr($line, $pos+1); + $field_val = substr($line, $pos+1); + $new[strtoupper($field_name)] = trim($field_val); - }else if (ereg('^[[:space:]]', $line)){ - $new[strtoupper($field_name)].= trim($line); + + } else if (ereg('^[[:space:]]', $line)) { + $new[strtoupper($field_name)] .= trim($line); } - }while($line[0]!=')'); + } while ($line[0] != ')'); + $new_thhd->sbj = $new['SUBJECT']; $new_thhd->mid = substr($new['MESSAGE-ID'], 1, -1); $new_thhd->irt = substr($new['IN-REPLY-TO'], 1, -1); $result[$uids[$new_thhd->id]] = $new_thhd; } - }while(!iil_StartsWith($line, "fh")); + } while (!iil_StartsWith($line, 'fh')); } /* sort headers */ - if (is_array($index_a)){ + if (is_array($index_a)) { $result = iil_SortThreadHeaders($result, $index_a, $uids); } /* write new set to cache */ - if ($conn->do_cache){ - if (count($result)!=count($cached)) - cache_write($conn->user, $conn->host, $mailbox.'.thhd', $result); + if ($conn->do_cache) { + if (count($result)!=count($cached)) { + cache_write($conn->user, $conn->host, $mailbox . '.thhd', $result); + } } //echo 'iil_FetchThreadHeaders:'."\n"; @@ -1018,129 +1269,165 @@ return $result; } -function iil_C_BuildThreads2(&$conn, $mailbox, $message_set, &$clock){ +function iil_C_BuildThreads2(&$conn, $mailbox, $message_set, &$clock) { global $index_a; list($from_idx, $to_idx) = explode(':', $message_set); - if (empty($message_set) || (isset($to_idx) && (int)$from_idx > (int)$to_idx)) + if (empty($message_set) || (isset($to_idx) + && (int)$from_idx > (int)$to_idx)) { return false; - - $result=array(); - $roots=array(); + } + + $result = array(); + $roots = array(); $root_mids = array(); - $sub_mids = array(); - $strays = array(); - $messages = array(); - $fp = $conn->fp; - $debug = false; + $sub_mids = array(); + $strays = array(); + $messages = array(); + $fp = $conn->fp; + $debug = false; $sbj_filter_pat = '[a-zA-Z]{2,3}(\[[0-9]*\])?:([[:space:]]*)'; /* Do "SELECT" command */ - if (!iil_C_Select($conn, $mailbox)) return false; - + if (!iil_C_Select($conn, $mailbox)) { + return false; + } + /* FETCH date,from,subject headers */ $mid_to_id = array(); - $messages = array(); - $headers = iil_C_FetchThreadHeaders($conn, $mailbox, $message_set); - if ($clock) $clock->register('fetched headers'); - - if ($debug) print_r($headers); - + $messages = array(); + $headers = iil_C_FetchThreadHeaders($conn, $mailbox, $message_set); + if ($clock) { + $clock->register('fetched headers'); + } + + if ($debug) { + print_r($headers); + } + /* go through header records */ - foreach($headers as $header){ + foreach ($headers as $header) { //$id = $header['i']; //$new = array('id'=>$id, 'MESSAGE-ID'=>$header['m'], // 'IN-REPLY-TO'=>$header['r'], 'SUBJECT'=>$header['s']); - $id = $header->id; - $new = array('id'=>$id, 'MESSAGE-ID'=>$header->mid, - 'IN-REPLY-TO'=>$header->irt, 'SUBJECT'=>$header->sbj); + $id = $header->id; + $new = array('id' => $id, 'MESSAGE-ID' => $header->mid, + 'IN-REPLY-TO' => $header->irt, 'SUBJECT' => $header->sbj); /* add to message-id -> mid lookup table */ $mid_to_id[$new['MESSAGE-ID']] = $id; /* if no subject, use message-id */ - if (empty($new['SUBJECT'])) $new['SUBJECT'] = $new['MESSAGE-ID']; - + if (empty($new['SUBJECT'])) { + $new['SUBJECT'] = $new['MESSAGE-ID']; + } + /* if subject contains 'RE:' or has in-reply-to header, it's a reply */ $sbj_pre =''; $has_re = false; - if (eregi($sbj_filter_pat, $new['SUBJECT'])) $has_re = true; - if ($has_re||$new['IN-REPLY-TO']) $sbj_pre = 'RE:'; - + if (eregi($sbj_filter_pat, $new['SUBJECT'])) { + $has_re = true; + } + if ($has_re||$new['IN-REPLY-TO']) { + $sbj_pre = 'RE:'; + } + /* strip out 're:', 'fw:' etc */ - if ($has_re) $sbj = ereg_replace($sbj_filter_pat,'', $new['SUBJECT']); - else $sbj = $new['SUBJECT']; - $new['SUBJECT'] = $sbj_pre.$sbj; + if ($has_re) { + $sbj = ereg_replace($sbj_filter_pat, '', $new['SUBJECT']); + } else { + $sbj = $new['SUBJECT']; + } + $new['SUBJECT'] = $sbj_pre.$sbj; /* if subject not a known thread-root, add to list */ - if ($debug) echo $id.' '.$new['SUBJECT']."\t".$new['MESSAGE-ID']."\n"; - $root_id = $roots[$sbj]; + if ($debug) { + echo $id . ' ' . $new['SUBJECT'] . "\t" . $new['MESSAGE-ID'] . "\n"; + } + $root_id = $roots[$sbj]; - if ($root_id && ($has_re || !$root_in_root[$root_id])){ - if ($debug) echo "\tfound root: $root_id\n"; - $sub_mids[$new['MESSAGE-ID']] = $root_id; - $result[$root_id][] = $id; - }else if (!isset($roots[$sbj])||(!$has_re&&$root_in_root[$root_id])){ + if ($root_id && ($has_re || !$root_in_root[$root_id])) { + if ($debug) { + echo "\tfound root: $root_id\n"; + } + $sub_mids[$new['MESSAGE-ID']] = $root_id; + $result[$root_id][] = $id; + }else if (!isset($roots[$sbj]) || (!$has_re && $root_in_root[$root_id])) { /* try to use In-Reply-To header to find root unless subject contains 'Re:' */ - if ($has_re&&$new['IN-REPLY-TO']){ - if ($debug) echo "\tlooking: ".$new['IN-REPLY-TO']."\n"; - + if ($has_re&&$new['IN-REPLY-TO']) { + if ($debug) { + echo "\tlooking: ".$new['IN-REPLY-TO']."\n"; + } //reply to known message? $temp = $sub_mids[$new['IN-REPLY-TO']]; - if ($temp){ + if ($temp) { //found it, root:=parent's root - if ($debug) echo "\tfound parent: ".$new['SUBJECT']."\n"; - $result[$temp][] = $id; + if ($debug) { + echo "\tfound parent: ".$new['SUBJECT']."\n"; + } + $result[$temp][] = $id; $sub_mids[$new['MESSAGE-ID']] = $temp; - $sbj = ''; - }else{ + $sbj = ''; + } else { //if we can't find referenced parent, it's a "stray" $strays[$id] = $new['IN-REPLY-TO']; } } //add subject as root - if ($sbj){ - if ($debug) echo "\t added to root\n"; - $roots[$sbj] = $id; - $root_in_root[$id] = !$has_re; + if ($sbj) { + if ($debug) { + echo "\t added to root\n"; + } + $roots[$sbj] = $id; + $root_in_root[$id] = !$has_re; $sub_mids[$new['MESSAGE-ID']] = $id; - $result[$id] = array($id); + $result[$id] = array($id); } - if ($debug) echo $new['MESSAGE-ID']."\t".$sbj."\n"; + if ($debug) { + echo $new['MESSAGE-ID'] . "\t" . $sbj . "\n"; + } } } //now that we've gone through all the messages, //go back and try and link up the stray threads - if (count($strays)>0){ - foreach($strays as $id=>$irt){ + if (count($strays) > 0) { + foreach ($strays as $id=>$irt) { $root_id = $sub_mids[$irt]; - if (!$root_id || $root_id==$id) continue; - $result[$root_id] = array_merge($result[$root_id],$result[$id]); + if (!$root_id || $root_id==$id) { + continue; + } + $result[$root_id] = array_merge($result[$root_id],$result[$id]); unset($result[$id]); } } - if ($clock) $clock->register('data prepped'); - - if ($debug) print_r($roots); - //print_r($result); + if ($clock) { + $clock->register('data prepped'); + } + + if ($debug) { + print_r($roots); + } + //print_r($result); return $result; } -function iil_SortThreads(&$tree, $index, $sort_order='ASC'){ - if (!is_array($tree) || !is_array($index)) return false; - +function iil_SortThreads(&$tree, $index, $sort_order = 'ASC') { + if (!is_array($tree) || !is_array($index)) { + return false; + } + //create an id to position lookup table $i = 0; - foreach($index as $id=>$val){ + foreach ($index as $id=>$val) { $i++; $index[$id] = $i; } @@ -1148,19 +1435,21 @@ //for each tree, set array key to position $itree = array(); - foreach($tree as $id=>$node){ - if (count($tree[$id])<=1){ + foreach ($tree as $id=>$node) { + if (count($tree[$id])<=1) { //for "threads" with only one message, key is position of that message - $n = $index[$id]; + $n = $index[$id]; $itree[$n] = array($n=>$id); - }else{ + } else { //for "threads" with multiple messages, - $min = $max; + $min = $max; $new_a = array(); - foreach($tree[$id] as $mid){ + foreach ($tree[$id] as $mid) { $new_a[$index[$mid]] = $mid; //create new sub-array mapping position to id - $pos = $index[$mid]; - if ($pos&&$pos<$min) $min = $index[$mid]; //find smallest position + $pos = $index[$mid]; + if ($pos&&$pos<$min) { + $min = $index[$mid]; //find smallest position + } } $n = $min; //smallest position of child is thread position @@ -1174,9 +1463,9 @@ //sort by key, this basically sorts all threads ksort($itree); - $i=0; - $out=array(); - foreach($itree as $k=>$node){ + $i = 0; + $out = array(); + foreach ($itree as $k=>$node) { $out[$i] = $itree[$k]; $i++; } @@ -1185,149 +1474,221 @@ return $out; } -function iil_IndexThreads(&$tree){ +function iil_IndexThreads(&$tree) { /* creates array mapping mid to thread id */ - if (!is_array($tree)) return false; - + if (!is_array($tree)) { + return false; + } + $t_index = array(); - foreach($tree as $pos=>$kids){ - foreach($kids as $kid) $t_index[$kid] = $pos; + foreach ($tree as $pos=>$kids) { + foreach ($kids as $kid) $t_index[$kid] = $pos; } return $t_index; } -function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false){ +function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false) +{ global $IMAP_USE_INTERNAL_DATE; - $c=0; - $result=array(); - $fp = $conn->fp; + $c = 0; + $result = array(); + $fp = $conn->fp; list($from_idx, $to_idx) = explode(':', $message_set); - if (empty($message_set) || (isset($to_idx) && (int)$from_idx > (int)$to_idx)) + if (empty($message_set) || (isset($to_idx) + && (int)$from_idx > (int)$to_idx)) { return false; + } /* Do "SELECT" command */ - if (!iil_C_Select($conn, $mailbox)){ + if (!iil_C_Select($conn, $mailbox)) { $conn->error = "Couldn't select $mailbox"; return false; } /* Get cached records where possible */ - if ($conn->do_cache){ + if ($conn->do_cache) { $uids = iil_C_FetchHeaderIndex($conn, $mailbox, $message_set, "UID"); - if (is_array($uids) && count($conn->cache[$mailbox]>0)){ - $needed_set = ""; - while(list($id,$uid)=each($uids)){ - if ($conn->cache[$mailbox][$uid]){ - $result[$id] = $conn->cache[$mailbox][$uid]; + if (is_array($uids) && count($conn->cache[$mailbox]>0)) { + $needed_set = ''; + while (list($id,$uid)=each($uids)) { + if ($conn->cache[$mailbox][$uid]) { + $result[$id] = $conn->cache[$mailbox][$uid]; $result[$id]->id = $id; - }else $needed_set.=($needed_set?",":"").$id; + } else { + $needed_set.=($needed_set ? ',': '') . $id; + } } //echo "<!-- iil_C_FetchHeader\nMessage Set: $message_set\nNeeded Set:$needed_set\n//-->\n"; - if ($needed_set) $message_set = iil_CompressMessageSet($needed_set); - else return $result; + if ($needed_set) { + $message_set = iil_CompressMessageSet($needed_set); + } else { + return $result; + } } } /* FETCH date,from,subject headers */ - $key="fh".($c++); - $prefix=$uidfetch?" UID":""; - $request=$key.$prefix." FETCH $message_set (BODY.PEEK[HEADER.FIELDS (DATE FROM TO SUBJECT REPLY-TO IN-REPLY-TO CC BCC CONTENT-TRANSFER-ENCODING CONTENT-TYPE MESSAGE-ID REFERENCE)])\r\n"; + $key = 'fh' . ($c++); + $prefix = $uidfetch?' UID':''; + $request = $key . $prefix; + $request .= " FETCH $message_set (BODY.PEEK[HEADER.FIELDS "; + $request .= "(DATE FROM TO SUBJECT REPLY-TO IN-REPLY-TO CC BCC "; + $request .= "CONTENT-TRANSFER-ENCODING CONTENT-TYPE MESSAGE-ID "; + $request .= "REFERENCES DISPOSITION-NOTIFICATION-TO X-PRIORITY)])\r\n"; - if (!fputs($fp, $request)) return false; - do{ - $line=chop(iil_ReadLine($fp, 200)); - $a=explode(" ", $line); - if (($line[0]=="*") && ($a[2]=="FETCH")){ - $id=$a[1]; - $result[$id]=new iilBasicHeader; - $result[$id]->id = $id; - $result[$id]->subject = ""; + if (!fputs($fp, $request)) { + return false; + } + do { + $line = chop(iil_ReadLine($fp, 200)); + $a = explode(' ', $line); + if (($line[0] == '*') && ($a[2] == 'FETCH')) { + $id = $a[1]; + + $result[$id] = new iilBasicHeader; + $result[$id]->id = $id; + $result[$id]->subject = ''; + $result[$id]->messageID = 'mid:' . $id; + /* Start parsing headers. The problem is, some header "lines" take up multiple lines. So, we'll read ahead, and if the one we're reading now is a valid header, we'll process the previous line. Otherwise, we'll keep adding the strings until we come to the next valid header line. */ - $i = 0; + $i = 0; $lines = array(); - do{ - $line = chop(iil_ReadLine($fp, 300),"\r\n"); - if (ord($line[0])<=32) $lines[$i].=(empty($lines[$i])?"":"\n").trim(chop($line)); - else{ + do { + $line = chop(iil_ReadLine($fp, 300), "\r\n"); + if (ord($line[0])<=32) { + $lines[$i] .= (empty($lines[$i])?'':"\n").trim(chop($line)); + } else { $i++; $lines[$i] = trim(chop($line)); } - }while($line[0]!=")" && strncmp($line, $key, strlen($key))); // patch from "Maksim Rubis" <siburny@hotmail.com> + /* + The preg_match below works around communigate imap, which outputs " UID <number>)". + Without this, the while statement continues on and gets the "fh0 OK completed" message. + If this loop gets the ending message, then the outer loop does not receive it from radline on line 1249. + This in causes the if statement on line 1278 to never be true, which causes the headers to end up missing + If the if statement was changed to pick up the fh0 from this loop, then it causes the outer loop to spin + An alternative might be: + if (!preg_match("/:/",$line) && preg_match("/\)$/",$line)) break; + however, unsure how well this would work with all imap clients. + */ + if (preg_match("/^\s*UID [0-9]+\)$/", $line)) { + break; + } + // patch from "Maksim Rubis" <siburny@hotmail.com> + } while (trim($line[0]) != ')' && strncmp($line, $key, strlen($key))); - if(strncmp($line, $key, strlen($key))) - { - //process header, fill iilBasicHeader obj. - // initialize - if (is_array($headers)){ - reset($headers); - while ( list($k, $bar) = each($headers) ) $headers[$k] = ""; + if (strncmp($line, $key, strlen($key))) { + //process header, fill iilBasicHeader obj. + // initialize + if (is_array($headers)) { + reset($headers); + while (list($k, $bar) = each($headers)) { + $headers[$k] = ''; + } + } + + // create array with header field:data + while ( list($lines_key, $str) = each($lines) ) { + list($field, $string) = iil_SplitHeaderLine($str); + + $field = strtolower($field); + $string = ereg_replace("\n[[:space:]]*"," ",$string); + + switch ($field) { + case 'date'; + $result[$id]->date = $string; + $result[$id]->timestamp = iil_StrToTime($string); + break; + case 'from': + $result[$id]->from = $string; + break; + case 'to': + $result[$id]->to = $string; + break; + case 'subject': + $result[$id]->subject = $string; + break; + case 'reply-to': + $result[$id]->replyto = $string; + break; + case 'cc': + $result[$id]->cc = $string; + break; + case 'bcc': + $result[$id]->bcc = $string; + break; + case 'content-transfer-encoding': + $result[$id]->encoding = $string; + break; + case 'content-type': + $ctype_parts = explode(";", $string); + $result[$id]->ctype = array_shift($ctype_parts); + foreach ($ctype_parts as $ctype_add) { + if (preg_match('/charset="?([a-z0-9\-\.\_]+)"?/i', + $ctype_add, $regs)) { + $result[$id]->charset = $regs[1]; + } + } + break; + case 'in-reply-to': + $result[$id]->in_reply_to = ereg_replace("[\n<>]", '', $string); + break; + case 'references': + $result[$id]->references = $string; + break; + case 'return-receipt-to': + case 'disposition-notification-to': + case 'x-confirm-reading-to': + $result[$id]->mdn_to = $string; + break; + case 'message-id': + $result[$id]->messageID = $string; + break; + case 'x-priority': + if (preg_match('/^(\d+)/', $string, $matches)) + $result[$id]->priority = intval($matches[1]); + break; + } // end switch () + } // end while () + } else { + $a = explode(' ', $line); } - - // create array with header field:data - $headers = array(); - while ( list($lines_key, $str) = each($lines) ){ - list($field, $string) = iil_SplitHeaderLine($str); - $field = strtolower($field); - $headers[$field] = $string; - } - $result[$id]->date = $headers["date"]; - $result[$id]->timestamp = iil_StrToTime($headers["date"]); - $result[$id]->from = $headers["from"]; - $result[$id]->to = str_replace("\n", " ", $headers["to"]); - $result[$id]->subject = str_replace("\n", "", $headers["subject"]); - $result[$id]->replyto = str_replace("\n", " ", $headers["reply-to"]); - $result[$id]->cc = str_replace("\n", " ", $headers["cc"]); - $result[$id]->bcc = str_replace("\n", " ", $headers["bcc"]); - $result[$id]->encoding = str_replace("\n", " ", $headers["content-transfer-encoding"]); - $result[$id]->ctype = str_replace("\n", " ", $headers["content-type"]); - $result[$id]->in_reply_to = ereg_replace("[\n<>]",'', $headers['in-reply-to']); - $result[$id]->reference = $headers["reference"]; - - list($result[$id]->ctype, $ctype_add) = explode(";", $headers["content-type"]); - - if (preg_match('/charset="?([a-z0-9\-]+)"?/i', $ctype_add, $regs)) - $result[$id]->charset = $regs[1]; - - $messageID = $headers["message-id"]; - if (!$messageID) "mid:".$id; - $result[$id]->messageID = $messageID; - } - else { - $a=explode(" ", $line); - } - } - }while(strcmp($a[0], $key)!=0); - + } while (strcmp($a[0], $key) != 0); + /* FETCH uid, size, flags Sample reply line: "* 3 FETCH (UID 2417 RFC822.SIZE 2730 FLAGS (\Seen \Deleted))" */ - $command_key="fh".($c++); - $request= $command_key.$prefix." FETCH $message_set (UID RFC822.SIZE FLAGS INTERNALDATE)\r\n"; - if (!fputs($fp, $request)) return false; - do{ - $line=chop(iil_ReadLine($fp, 200)); - //$a = explode(" ", $line); - //if (($line[0]=="*") && ($a[2]=="FETCH")){ - if ($line[0]=="*"){ + $command_key = 'fh' . ($c++); + $request = $command_key . $prefix; + $request .= " FETCH $message_set (UID RFC822.SIZE FLAGS INTERNALDATE)\r\n"; + + if (!fputs($fp, $request)) { + return false; + } + do { + $line = chop(iil_ReadLine($fp, 200)); + //$a = explode(' ', $line); + //if (($line[0]=="*") && ($a[2]=="FETCH")) { + if ($line[0] == '*') { //echo "<!-- $line //-->\n"; //get outter most parens $open_pos = strpos($line, "(") + 1; $close_pos = strrpos($line, ")"); - if ($open_pos && $close_pos){ + if ($open_pos && $close_pos) { //extract ID from pre-paren $pre_str = substr($line, 0, $open_pos); - $pre_a = explode(" ", $line); + $pre_a = explode(' ', $line); $id = $pre_a[1]; //get data @@ -1336,93 +1697,114 @@ //swap parents with quotes, then explode $str = eregi_replace("[()]", "\"", $str); - $a = iil_ExplodeQuotedString(" ", $str); + $a = iil_ExplodeQuotedString(' ', $str); //did we get the right number of replies? $parts_count = count($a); - if ($parts_count>=8){ - for ($i=0;$i<$parts_count;$i=$i+2){ - if (strcasecmp($a[$i],"UID")==0) $result[$id]->uid=$a[$i+1]; - else if (strcasecmp($a[$i],"RFC822.SIZE")==0) $result[$id]->size=$a[$i+1]; - else if (strcasecmp($a[$i],"INTERNALDATE")==0) $time_str = $a[$i+1]; - else if (strcasecmp($a[$i],"FLAGS")==0) $flags_str = $a[$i+1]; + if ($parts_count>=8) { + for ($i=0;$i<$parts_count;$i=$i+2) { + if (strcasecmp($a[$i],"UID") == 0) $result[$id]->uid=$a[$i+1]; + else if (strcasecmp($a[$i],"RFC822.SIZE") == 0) $result[$id]->size=$a[$i+1]; + else if (strcasecmp($a[$i],"INTERNALDATE") == 0) $time_str = $a[$i+1]; + else if (strcasecmp($a[$i],"FLAGS") == 0) $flags_str = $a[$i+1]; } // process flags - $flags_str = eregi_replace('[\\\"]', "", $flags_str); - $flags_a = explode(" ", $flags_str); - //echo "<!-- ID: $id FLAGS: ".implode(",", $flags_a)." //-->\n"; + $flags_str = eregi_replace('[\\\"]', '', $flags_str); + $flags_a = explode(' ', $flags_str); + + /* + trigger_error("<!-- ID: $id FLAGS: ".implode(",", $flags_a)." //-->\n", + E_USER_WARNING); + */ - $result[$id]->seen = false; - $result[$id]->recent = false; - $result[$id]->deleted = false; - $result[$id]->answered = false; - if (is_array($flags_a)){ + if (is_array($flags_a)) { reset($flags_a); - while (list($key,$val)=each($flags_a)){ - if (strcasecmp($val,"Seen")==0) $result[$id]->seen = true; - else if (strcasecmp($val, "Deleted")==0) $result[$id]->deleted=true; - else if (strcasecmp($val, "Recent")==0) $result[$id]->recent = true; - else if (strcasecmp($val, "Answered")==0) $result[$id]->answered = true; + while (list($key,$val)=each($flags_a)) { + if (strcasecmp($val,'Seen') == 0) { + $result[$id]->seen = true; + } else if (strcasecmp($val, 'Deleted') == 0) { + $result[$id]->deleted=true; + } else if (strcasecmp($val, 'Recent') == 0) { + $result[$id]->recent = true; + } else if (strcasecmp($val, 'Answered') == 0) { + $result[$id]->answered = true; + } else if (strcasecmp($val, "\$MDNSent") == 0) { + $result[$id]->mdn_sent = true; + } } - $result[$id]->flags=$flags_str; + $result[$id]->flags = $flags_a; } // if time is gmt... $time_str = str_replace('GMT','+0000',$time_str); //get timezone - $time_str = substr($time_str, 0, -1); + $time_str = substr($time_str, 0, -1); $time_zone_str = substr($time_str, -5); //extract timezone - $time_str = substr($time_str, 1, -6); //remove quotes - $time_zone = (float)substr($time_zone_str, 1, 2); //get first two digits - if ($time_zone_str[3]!='0') $time_zone += 0.5; //handle half hour offset - if ($time_zone_str[0]=="-") $time_zone = $time_zone * -1.0; //minus? + $time_str = substr($time_str, 1, -6); //remove quotes + $time_zone = (float)substr($time_zone_str, 1, 2); //get first two digits + if ($time_zone_str[3] != '0') { + $time_zone += 0.5; //handle half hour offset + } + if ($time_zone_str[0] == '-') { + $time_zone = $time_zone * -1.0; //minus? + } $result[$id]->internaldate = $time_str; - if ($IMAP_USE_INTERNAL_DATE){ + if ($IMAP_USE_INTERNAL_DATE || empty($result[$id]->date)) { //calculate timestamp - $timestamp = strtotime($time_str); //return's server's time - $na_timestamp = $timestamp; - $timestamp -= $time_zone * 3600; //compensate for tz, get GMT + $timestamp = strtotime($time_str); //return's server's time + $na_timestamp = $timestamp; + $timestamp -= $time_zone * 3600; //compensate for tz, get GMT + $result[$id]->timestamp = $timestamp; + $result[$id]->date = $time_str; } - if ($conn->do_cache){ + if ($conn->do_cache) { $uid = $result[$id]->uid; $conn->cache[$mailbox][$uid] = $result[$id]; $conn->cache_dirty[$mailbox] = true; } //echo "<!-- ID: $id : $time_str -- local: $na_timestamp (".date("F j, Y, g:i a", $na_timestamp).") tz: $time_zone -- GMT: ".$timestamp." (".date("F j, Y, g:i a", $timestamp).") //-->\n"; - }else{ + } else { //echo "<!-- ERROR: $id : $str //-->\n"; } } } - }while(strpos($line, $command_key)===false); + } while (strpos($line, $command_key) === false); return $result; } - -function iil_C_FetchHeader(&$conn, $mailbox, $id, $uidfetch=false){ +function iil_C_FetchHeader(&$conn, $mailbox, $id, $uidfetch=false) { $fp = $conn->fp; - $a=iil_C_FetchHeaders($conn, $mailbox, $id, $uidfetch); - if (is_array($a)) return array_shift($a); - else return false; + $a = iil_C_FetchHeaders($conn, $mailbox, $id, $uidfetch); + if (is_array($a)) { + return array_shift($a); + } + return false; } -function iil_SortHeaders($a, $field, $flag){ - if (empty($field)) $field="uid"; - $field=strtolower($field); - if ($field=="date"||$field=='internaldate') $field="timestamp"; - if (empty($flag)) $flag="ASC"; - $flag=strtoupper($flag); - $stripArr = ($field=='subject') ? array('Re: ','Fwd: ','Fw: ',"\"") : array("\""); +function iil_SortHeaders($a, $field, $flag) { + if (empty($field)) { + $field = 'uid'; + } + $field = strtolower($field); + if ($field == 'date' || $field == 'internaldate') { + $field = 'timestamp'; + } + if (empty($flag)) { + $flag = 'ASC'; + } + + $flag = strtoupper($flag); + $stripArr = ($field=='subject') ? array('Re: ','Fwd: ','Fw: ','"') : array('"'); $c=count($a); - if ($c>0){ + if ($c > 0) { /* Strategy: First, we'll create an "index" array. @@ -1431,33 +1813,36 @@ */ // create "index" array - $index=array(); + $index = array(); reset($a); - while (list($key, $val)=each($a)){ + while (list($key, $val)=each($a)) { - if ($field=="timestamp"){ + if ($field == 'timestamp') { $data = @strtotime($val->date); - if ($data == false) + if ($data == false) { $data = $val->timestamp; - } - else { + } + } else { $data = $val->$field; - if (is_string($data)) - $data=strtoupper(str_replace($stripArr, "", $data)); - } - + if (is_string($data)) { + $data=strtoupper(str_replace($stripArr, '', $data)); + } + } $index[$key]=$data; } // sort index - $i=0; - if ($flag=="ASC") asort($index); - else arsort($index); - + $i = 0; + if ($flag == 'ASC') { + asort($index); + } else { + arsort($index); + } + // form new array based on index - $result=array(); + $result = array(); reset($index); - while (list($key, $val)=each($index)){ + while (list($key, $val)=each($index)) { $result[$key]=$a[$key]; $i++; } @@ -1466,557 +1851,659 @@ return $result; } -function iil_C_Expunge(&$conn, $mailbox){ +function iil_C_Expunge(&$conn, $mailbox) { $fp = $conn->fp; - if (iil_C_Select($conn, $mailbox)){ - $c=0; + if (iil_C_Select($conn, $mailbox)) { + $c = 0; fputs($fp, "exp1 EXPUNGE\r\n"); - do{ + do { $line=chop(iil_ReadLine($fp, 100)); - if ($line[0]=="*") $c++; - }while (!iil_StartsWith($line, "exp1")); + if ($line[0] == '*') { + $c++; + } + } while (!iil_StartsWith($line, 'exp1')); - if (iil_ParseResult($line) == 0){ - $conn->selected = ""; //state has changed, need to reselect + if (iil_ParseResult($line) == 0) { + $conn->selected = ''; //state has changed, need to reselect //$conn->exists-=$c; return $c; - }else{ - $conn->error = $line; - return -1; } + $conn->error = $line; } return -1; } -function iil_C_ModFlag(&$conn, $mailbox, $messages, $flag, $mod){ - if ($mod!="+" && $mod!="-") return -1; - - $fp = $conn->fp; - $flags=array( - "SEEN"=>"\\Seen", - "DELETED"=>"\\Deleted", - "RECENT"=>"\\Recent", - "ANSWERED"=>"\\Answered", - "DRAFT"=>"\\Draft", - "FLAGGED"=>"\\Flagged" - ); - $flag=strtoupper($flag); - $flag=$flags[$flag]; - if (iil_C_Select($conn, $mailbox)){ - $c=0; - fputs($fp, "flg STORE $messages ".$mod."FLAGS (".$flag.")\r\n"); - do{ +function iil_C_ModFlag(&$conn, $mailbox, $messages, $flag, $mod) { + if ($mod != '+' && $mod != '-') { + return -1; + } + + $fp = $conn->fp; + $flags = array( + 'SEEN' => '\\Seen', + 'DELETED' => '\\Deleted', + 'RECENT' => '\\Recent', + 'ANSWERED' => '\\Answered', + 'DRAFT' => '\\Draft', + 'FLAGGED' => '\\Flagged', + 'MDNSENT' => "\$MDNSent"); + + $flag = strtoupper($flag); + $flag = $flags[$flag]; + + if (iil_C_Select($conn, $mailbox)) { + $c = 0; + fputs($fp, "flg STORE $messages " . $mod . "FLAGS (" . $flag . ")\r\n"); + do { $line=chop(iil_ReadLine($fp, 100)); - if ($line[0]=="*") $c++; - }while (!iil_StartsWith($line, "flg")); + if ($line[0] == '*') { + $c++; + } + } while (!iil_StartsWith($line, 'flg')); - if (iil_ParseResult($line) == 0){ + if (iil_ParseResult($line) == 0) { iil_C_ExpireCachedItems($conn, $mailbox, $messages); return $c; - }else{ - $conn->error = $line; - return -1; } - }else{ - $conn->error = "Select failed"; + $conn->error = $line; return -1; } + $conn->error = 'Select failed'; + return -1; } -function iil_C_Flag(&$conn, $mailbox, $messages, $flag){ - return iil_C_ModFlag($conn, $mailbox, $messages, $flag, "+"); +function iil_C_Flag(&$conn, $mailbox, $messages, $flag) { + return iil_C_ModFlag($conn, $mailbox, $messages, $flag, '+'); } -function iil_C_Unflag(&$conn, $mailbox, $messages, $flag){ - return iil_C_ModFlag($conn, $mailbox, $messages, $flag, "-"); +function iil_C_Unflag(&$conn, $mailbox, $messages, $flag) { + return iil_C_ModFlag($conn, $mailbox, $messages, $flag, '-'); } -function iil_C_Delete(&$conn, $mailbox, $messages){ - return iil_C_ModFlag($conn, $mailbox, $messages, "DELETED", "+"); +function iil_C_Delete(&$conn, $mailbox, $messages) { + return iil_C_ModFlag($conn, $mailbox, $messages, 'DELETED', '+'); } -function iil_C_Undelete(&$conn, $mailbox, $messages){ - return iil_C_ModFlag($conn, $mailbox, $messages, "DELETED", "-"); +function iil_C_Undelete(&$conn, $mailbox, $messages) { + return iil_C_ModFlag($conn, $mailbox, $messages, 'DELETED', '-'); } -function iil_C_Unseen(&$conn, $mailbox, $messages){ - return iil_C_ModFlag($conn, $mailbox, $messages, "SEEN", "-"); +function iil_C_Unseen(&$conn, $mailbox, $messages) { + return iil_C_ModFlag($conn, $mailbox, $messages, 'SEEN', '-'); } -function iil_C_Copy(&$conn, $messages, $from, $to){ +function iil_C_Copy(&$conn, $messages, $from, $to) { $fp = $conn->fp; - if (empty($from) || empty($to)) return -1; - - if (iil_C_Select($conn, $from)){ + if (empty($from) || empty($to)) { + return -1; + } + + if (iil_C_Select($conn, $from)) { $c=0; fputs($fp, "cpy1 COPY $messages \"$to\"\r\n"); $line=iil_ReadReply($fp); return iil_ParseResult($line); - }else{ + } else { return -1; } } -function iil_FormatSearchDate($month, $day, $year){ - $month = (int)$month; - $months=array( - 1=>"Jan", 2=>"Feb", 3=>"Mar", 4=>"Apr", - 5=>"May", 6=>"Jun", 7=>"Jul", 8=>"Aug", - 9=>"Sep", 10=>"Oct", 11=>"Nov", 12=>"Dec" - ); - return $day."-".$months[$month]."-".$year; +function iil_FormatSearchDate($month, $day, $year) { + $month = (int) $month; + $months = $GLOBALS['IMAP_MONTHS']; + return $day . '-' . $months[$month] . '-' . $year; } -function iil_C_CountUnseen(&$conn, $folder){ - $index = iil_C_Search($conn, $folder, "ALL UNSEEN"); - if (is_array($index)){ - $str = implode(",", $index); - if (empty($str)) return false; - else return count($index); - }else return false; +function iil_C_CountUnseen(&$conn, $folder) { + $index = iil_C_Search($conn, $folder, 'ALL UNSEEN'); + if (is_array($index)) { + $str = implode(',', $index); + if (empty($str)) { + return false; + } + return count($index); + } + return false; } -function iil_C_UID2ID(&$conn, $folder, $uid){ - if ($uid > 0){ +function iil_C_UID2ID(&$conn, $folder, $uid) { + if ($uid > 0) { $id_a = iil_C_Search($conn, $folder, "UID $uid"); - if (is_array($id_a)){ + if (is_array($id_a)) { $count = count($id_a); - if ($count > 1) return false; - else return $id_a[0]; + if ($count > 1) { + return false; + } + return $id_a[0]; } } return false; } -function iil_C_ID2UID(&$conn, $folder, $id){ +function iil_C_ID2UID(&$conn, $folder, $id) { $fp = $conn->fp; - $result=-1; - if ($id > 0) { - if (iil_C_Select($conn, $folder)){ - $key = "FUID"; - if (fputs($fp, "$key FETCH $id (UID)\r\n")){ - do{ - $line=chop(iil_ReadLine($fp, 1024)); - if (eregi("^\* $id FETCH \(UID (.*)\)", $line, $r)){ - $result = $r[1]; - } - } while (!preg_match("/^$key/", $line)); - } + if ($id == 0) { + return -1; + } + $result = -1; + if (iil_C_Select($conn, $folder)) { + $key = 'FUID'; + if (fputs($fp, "$key FETCH $id (UID)\r\n")) { + do { + $line=chop(iil_ReadLine($fp, 1024)); + if (eregi("^\* $id FETCH \(UID (.*)\)", $line, $r)) { + $result = $r[1]; + } + } while (!preg_match("/^$key/", $line)); } } return $result; } -function iil_C_Search(&$conn, $folder, $criteria){ +function iil_C_Search(&$conn, $folder, $criteria) { $fp = $conn->fp; - if (iil_C_Select($conn, $folder)){ - $c=0; + if (iil_C_Select($conn, $folder)) { + $c = 0; - $query = "srch1 SEARCH ".chop($criteria)."\r\n"; + $query = 'srch1 SEARCH ' . chop($criteria) . "\r\n"; fputs($fp, $query); - do{ + do { $line=trim(chop(iil_ReadLine($fp, 10000))); - if (eregi("^\* SEARCH", $line)){ + if (eregi("^\* SEARCH", $line)) { $str = trim(substr($line, 8)); - $messages = explode(" ", $str); + $messages = explode(' ', $str); } - }while(!iil_StartsWith($line, "srch1")); + } while (!iil_StartsWith($line, 'srch1')); - $result_code=iil_ParseResult($line); - if ($result_code==0) return $messages; - else{ - $conn->error = "iil_C_Search: ".$line."\n"; - return false; + $result_code = iil_ParseResult($line); + if ($result_code == 0) { + return $messages; } - - }else{ - $conn->error = "iil_C_Search: Couldn't select \"$folder\"\n"; + $conn->error = 'iil_C_Search: ' . $line . "\n"; return false; + } + $conn->error = "iil_C_Search: Couldn't select \"$folder\"\n"; + return false; } -function iil_C_Move(&$conn, $messages, $from, $to){ +function iil_C_Move(&$conn, $messages, $from, $to) { $fp = $conn->fp; - if (!$from || !$to) return -1; - - $r=iil_C_Copy($conn, $messages, $from,$to); - if ($r==0){ + if (!$from || !$to) { + return -1; + } + + $r = iil_C_Copy($conn, $messages, $from,$to); + if ($r==0) { return iil_C_Delete($conn, $from, $messages); - }else{ - return $r; } + return $r; } -function iil_C_GetHierarchyDelimiter(&$conn){ - if ($conn->delimiter) return $conn->delimiter; - - $fp = $conn->fp; +/** + * Gets the delimiter, for example: + * INBOX.foo -> . + * INBOX/foo -> / + * INBOX\foo -> \ + * + * @return mixed A delimiter (string), or false. + * @param object $conn The current connection. + * @see iil_Connect() + */ +function iil_C_GetHierarchyDelimiter(&$conn) { + if ($conn->delimiter) { + return $conn->delimiter; + } + + $fp = $conn->fp; $delimiter = false; //try (LIST "" ""), should return delimiter (RFC2060 Sec 6.3.8) - if (!fputs($fp, "ghd LIST \"\" \"\"\r\n")) return false; - do{ + if (!fputs($fp, 'ghd LIST "" ""' . "\r\n")) { + return false; + } + + do { $line=iil_ReadLine($fp, 500); - if ($line[0]=="*"){ + if ($line[0] == '*') { $line = rtrim($line); - $a=iil_ExplodeQuotedString(" ", $line); - if ($a[0]=="*") $delimiter = str_replace("\"", "", $a[count($a)-2]); + $a=iil_ExplodeQuotedString(' ', $line); + if ($a[0] == '*') { + $delimiter = str_replace('"', '', $a[count($a)-2]); + } } - }while (!iil_StartsWith($line, "ghd")); + } while (!iil_StartsWith($line, 'ghd')); - if (strlen($delimiter)>0) return $delimiter; - + if (strlen($delimiter)>0) { + return $delimiter; + } + //if that fails, try namespace extension //try to fetch namespace data fputs($conn->fp, "ns1 NAMESPACE\r\n"); - do{ + do { $line = iil_ReadLine($conn->fp, 1024); - if (iil_StartsWith($line, "* NAMESPACE")){ + if (iil_StartsWith($line, '* NAMESPACE')) { $i = 0; $data = iil_ParseNamespace2(substr($line,11), $i, 0, 0); } - }while(!iil_StartsWith($line, "ns1")); + } while (!iil_StartsWith($line, 'ns1')); - if (!is_array($data)) return false; - + if (!is_array($data)) { + return false; + } + //extract user space data (opposed to global/shared space) $user_space_data = $data[0]; - if (!is_array($user_space_data)) return false; - + if (!is_array($user_space_data)) { + return false; + } + //get first element $first_userspace = $user_space_data[0]; - if (!is_array($first_userspace)) return false; - + if (!is_array($first_userspace)) { + return false; + } + //extract delimiter $delimiter = $first_userspace[1]; return $delimiter; } -function iil_C_ListMailboxes(&$conn, $ref, $mailbox){ +function iil_C_ListMailboxes(&$conn, $ref, $mailbox) { global $IGNORE_FOLDERS; $ignore = $IGNORE_FOLDERS[strtolower($conn->host)]; $fp = $conn->fp; - if (empty($mailbox)) $mailbox="*"; - if (empty($ref) && $conn->rootdir) $ref = $conn->rootdir; - + if (empty($mailbox)) { + $mailbox = '*'; + } + if (empty($ref) && $conn->rootdir) { + $ref = $conn->rootdir; + } + // send command - if (!fputs($fp, "lmb LIST \"".$ref."\" \"$mailbox\"\r\n")) return false; - $i=0; + if (!fputs($fp, "lmb LIST \"".$ref."\" \"$mailbox\"\r\n")) { + return false; + } + + $i = 0; // get folder list - do{ - $line=iil_ReadLine($fp, 500); - $line=iil_MultLine($fp, $line); + do { + $line = iil_ReadLine($fp, 500); + $line = iil_MultLine($fp, $line); - $a = explode(" ", $line); - if (($line[0]=="*") && ($a[1]=="LIST")){ + $a = explode(' ', $line); + if (($line[0] == '*') && ($a[1] == 'LIST')) { $line = rtrim($line); // split one line - $a=iil_ExplodeQuotedString(" ", $line); + $a = iil_ExplodeQuotedString(' ', $line); + // last string is folder name - $folder = str_replace("\"", "", $a[count($a)-1]); - if (empty($ignore) || (!empty($ignore) && !eregi($ignore, $folder))) $folders[$i] = $folder; + $folder = str_replace('"', '', $a[count($a)-1]); + + if (empty($ignore) || (!empty($ignore) + && !eregi($ignore, $folder))) { + $folders[$i] = $folder; + } + // second from last is delimiter - $delim = str_replace("\"", "", $a[count($a)-2]); + $delim = str_replace('"', '', $a[count($a)-2]); // is it a container? $i++; } - }while (!iil_StartsWith($line, "lmb")); + } while (!iil_StartsWith($line, 'lmb')); - if (is_array($folders)){ - if (!empty($ref)){ + if (is_array($folders)) { + if (!empty($ref)) { // if rootdir was specified, make sure it's the first element // some IMAP servers (i.e. Courier) won't return it if ($ref[strlen($ref)-1]==$delim) $ref = substr($ref, 0, strlen($ref)-1); if ($folders[0]!=$ref) array_unshift($folders, $ref); } return $folders; - }else if (iil_ParseResult($line)==0){ + }else if (iil_ParseResult($line) == 0) { return array('INBOX'); - }else{ + } else { $conn->error = $line; return false; } } -function iil_C_ListSubscribed(&$conn, $ref, $mailbox){ +function iil_C_ListSubscribed(&$conn, $ref, $mailbox) { global $IGNORE_FOLDERS; $ignore = $IGNORE_FOLDERS[strtolower($conn->host)]; $fp = $conn->fp; - if (empty($mailbox)) $mailbox = "*"; - if (empty($ref) && $conn->rootdir) $ref = $conn->rootdir; + if (empty($mailbox)) { + $mailbox = '*'; + } + if (empty($ref) && $conn->rootdir) { + $ref = $conn->rootdir; + } $folders = array(); // send command - if (!fputs($fp, "lsb LSUB \"".$ref."\" \"".$mailbox."\"\r\n")){ + if (!fputs($fp, 'lsb LSUB "' . $ref . '" "' . $mailbox.'"' . "\r\n")) { $conn->error = "Couldn't send LSUB command\n"; return false; } - $i=0; + + $i = 0; + // get folder list - do{ - $line=iil_ReadLine($fp, 500); - $line=iil_MultLine($fp, $line); - $a = explode(" ", $line); - if (($line[0]=="*") && ($a[1]=="LSUB" || $a[1]=="LIST")){ + do { + $line = iil_ReadLine($fp, 500); + $line = iil_MultLine($fp, $line); + $a = explode(' ', $line); + + if (($line[0] == '*') && ($a[1] == 'LSUB' || $a[1] == 'LIST')) { $line = rtrim($line); + // split one line - $a=iil_ExplodeQuotedString(" ", $line); + $a = iil_ExplodeQuotedString(' ', $line); + // last string is folder name - //$folder = UTF7DecodeString(str_replace("\"", "", $a[count($a)-1])); - $folder = str_replace("\"", "", $a[count($a)-1]); - if ((!in_array($folder, $folders)) && (empty($ignore) || (!empty($ignore) && !eregi($ignore, $folder)))) $folders[$i] = $folder; + //$folder = UTF7DecodeString(str_replace('"', '', $a[count($a)-1])); + $folder = str_replace('"', '', $a[count($a)-1]); + + if ((!in_array($folder, $folders)) && (empty($ignore) + || (!empty($ignore) && !eregi($ignore, $folder)))) { + $folders[$i] = $folder; + } + // second from last is delimiter - $delim = str_replace("\"", "", $a[count($a)-2]); + $delim = str_replace('"', '', $a[count($a)-2]); + // is it a container? $i++; } - }while (!iil_StartsWith($line, "lsb")); + } while (!iil_StartsWith($line, 'lsb')); - if (is_array($folders)){ - if (!empty($ref)){ + if (is_array($folders)) { + if (!empty($ref)) { // if rootdir was specified, make sure it's the first element // some IMAP servers (i.e. Courier) won't return it - if ($ref[strlen($ref)-1]==$delim) $ref = substr($ref, 0, strlen($ref)-1); - if ($folders[0]!=$ref) array_unshift($folders, $ref); + if ($ref[strlen($ref)-1]==$delim) { + $ref = substr($ref, 0, strlen($ref)-1); + } + if ($folders[0]!=$ref) { + array_unshift($folders, $ref); + } } return $folders; - }else{ - $conn->error = $line; - return false; } + $conn->error = $line; + return false; } -function iil_C_Subscribe(&$conn, $folder){ +function iil_C_Subscribe(&$conn, $folder) { $fp = $conn->fp; - $query = "sub1 SUBSCRIBE \"".$folder."\"\r\n"; + $query = 'sub1 SUBSCRIBE "' . $folder. '"' . "\r\n"; fputs($fp, $query); - $line=trim(chop(iil_ReadLine($fp, 10000))); + + $line = trim(chop(iil_ReadLine($fp, 10000))); return iil_ParseResult($line); } -function iil_C_UnSubscribe(&$conn, $folder){ +function iil_C_UnSubscribe(&$conn, $folder) { $fp = $conn->fp; - $query = "usub1 UNSUBSCRIBE \"".$folder."\"\r\n"; + $query = 'usub1 UNSUBSCRIBE "' . $folder . '"' . "\r\n"; fputs($fp, $query); - $line=trim(chop(iil_ReadLine($fp, 10000))); + + $line = trim(chop(iil_ReadLine($fp, 10000))); return iil_ParseResult($line); } -function iil_C_FetchPartHeader(&$conn, $mailbox, $id, $part){ - $fp = $conn->fp; - $result=false; - if (($part==0)||(empty($part))) $part="HEADER"; - else $part.=".MIME"; - - if (iil_C_Select($conn, $mailbox)){ - $key="fh".($c++); - $request=$key." FETCH $id (BODY.PEEK[$part])\r\n"; +function iil_C_FetchPartHeader(&$conn, $mailbox, $id, $part) { + $fp = $conn->fp; + $result = false; + if (($part == 0) || (empty($part))) { + $part = 'HEADER'; + } else { + $part .= '.MIME'; + } + + if (iil_C_Select($conn, $mailbox)) { + $key = 'fh' . ($c++); + $request = $key . " FETCH $id (BODY.PEEK[$part])\r\n"; if (!fputs($fp, $request)) return false; - do{ - $line=chop(iil_ReadLine($fp, 200)); - $a=explode(" ", $line); - if (($line[0]=="*") && ($a[2]=="FETCH") && ($line[strlen($line)-1]!=")")){ + do { + $line = chop(iil_ReadLine($fp, 200)); + $a = explode(' ', $line); + if (($line[0] == '*') && ($a[2] == 'FETCH') + && ($line[strlen($line)-1] != ')')) { $line=iil_ReadLine($fp, 300); - while(chop($line)!=")"){ - $result.=$line; + while (chop($line) != ')') { + $result .= $line; $line=iil_ReadLine($fp, 300); } } - }while(strcmp($a[0], $key)!=0); + } while (strcmp($a[0], $key) != 0); } return $result; } -function iil_C_HandlePartBody(&$conn, $mailbox, $id, $part, $mode){ +function iil_C_HandlePartBody(&$conn, $mailbox, $id, $part, $mode) { /* modes: 1: return string 2: print 3: base64 and print */ - $fp = $conn->fp; - $result=false; - if (($part==0)||(empty($part))) $part="TEXT"; - - if (iil_C_Select($conn, $mailbox)){ - $reply_key="* ".$id; + $fp = $conn->fp; + $result = false; + if (($part == 0) || empty($part)) { + $part = 'TEXT'; + } + + if (iil_C_Select($conn, $mailbox)) { + $reply_key = '* ' . $id; + // format request - $key="ftch".($c++)." "; - $request=$key."FETCH $id (BODY.PEEK[$part])\r\n"; + $key = 'ftch' . ($c++) . ' '; + $request = $key . "FETCH $id (BODY.PEEK[$part])\r\n"; // send request - if (!fputs($fp, $request)) return false; + if (!fputs($fp, $request)) { + return false; + } + // receive reply line - do{ + do { $line = chop(iil_ReadLine($fp, 1000)); - $a = explode(" ", $line); - }while ($a[2]!="FETCH"); + $a = explode(' ', $line); + } while ($a[2] != 'FETCH'); $len = strlen($line); - if ($line[$len-1] == ")"){ + if ($line[$len-1] == ')') { //one line response, get everything between first and last quotes - $from = strpos($line, "\"") + 1; - $to = strrpos($line, "\""); - $len = $to - $from; - if ($mode==1) $result = substr($line, $from, $len); - else if ($mode==2) echo substr($line, $from, $len); - else if ($mode==3) echo base64_decode(substr($line, $from, $len)); - }else if ($line[$len-1] == "}"){ + if (substr($line, -4, 3) == 'NIL') { + // NIL response + $result = ''; + } else { + $from = strpos($line, '"') + 1; + $to = strrpos($line, '"'); + $len = $to - $from; + $result = substr($line, $from, $len); + } + + if ($mode == 2) { + echo $result; + } else if ($mode == 3) { + echo base64_decode($result); + } + } else if ($line[$len-1] == '}') { //multi-line request, find sizes of content and receive that many bytes - $from = strpos($line, "{") + 1; - $to = strrpos($line, "}"); - $len = $to - $from; - $sizeStr = substr($line, $from, $len); - $bytes = (int)$sizeStr; + $from = strpos($line, '{') + 1; + $to = strrpos($line, '}'); + $len = $to - $from; + $sizeStr = substr($line, $from, $len); + $bytes = (int)$sizeStr; $received = 0; - while ($received < $bytes){ + while ($received < $bytes) { $remaining = $bytes - $received; - $line = iil_ReadLine($fp, 1024); - $len = strlen($line); - if ($len > $remaining) $line = substr($line, 0, $remaining); + $line = iil_ReadLine($fp, 1024); + $len = strlen($line); + + if ($len > $remaining) { + $line = substr($line, 0, $remaining); + } $received += strlen($line); - if ($mode==1) $result .= chop($line)."\n"; - else if ($mode==2){ echo chop($line)."\n"; flush(); } - else if ($mode==3){ echo base64_decode($line); flush(); } + if ($mode == 1) { + $result .= rtrim($line, "\t\r\n\0\x0B") . "\n"; + } else if ($mode == 2) { + echo rtrim($line, "\t\r\n\0\x0B") . "\n"; flush(); + } else if ($mode == 3) { + echo base64_decode($line); flush(); + } } } // read in anything up until 'til last line - do{ + do { $line = iil_ReadLine($fp, 1024); - }while(!iil_StartsWith($line, $key)); + } while (!iil_StartsWith($line, $key)); - if ($result){ - $result = chop($result); + if ($result) { + $result = rtrim($result, "\t\r\n\0\x0B"); return $result; // substr($result, 0, strlen($result)-1); - }else return false; - }else{ - echo "Select failed."; + } + return false; + } else { + echo 'Select failed.'; } - if ($mode==1) return $result; - else return $received; + if ($mode==1) { + return $result; + } + return $received; } -function iil_C_FetchPartBody(&$conn, $mailbox, $id, $part){ +function iil_C_FetchPartBody(&$conn, $mailbox, $id, $part) { return iil_C_HandlePartBody($conn, $mailbox, $id, $part, 1); } -function iil_C_PrintPartBody(&$conn, $mailbox, $id, $part){ +function iil_C_PrintPartBody(&$conn, $mailbox, $id, $part) { iil_C_HandlePartBody($conn, $mailbox, $id, $part, 2); } -function iil_C_PrintBase64Body(&$conn, $mailbox, $id, $part){ +function iil_C_PrintBase64Body(&$conn, $mailbox, $id, $part) { iil_C_HandlePartBody($conn, $mailbox, $id, $part, 3); } -function iil_C_CreateFolder(&$conn, $folder){ +function iil_C_CreateFolder(&$conn, $folder) { $fp = $conn->fp; - if (fputs($fp, "c CREATE \"".$folder."\"\r\n")){ - do{ + if (fputs($fp, 'c CREATE "' . $folder . '"' . "\r\n")) { + do { $line=iil_ReadLine($fp, 300); - }while($line[0]!="c"); + } while ($line[0] != 'c'); $conn->error = $line; - return (iil_ParseResult($line)==0); - }else{ - return false; + return (iil_ParseResult($line) == 0); } + return false; } -function iil_C_RenameFolder(&$conn, $from, $to){ +function iil_C_RenameFolder(&$conn, $from, $to) { $fp = $conn->fp; - if (fputs($fp, "r RENAME \"".$from."\" \"".$to."\"\r\n")){ - do{ - $line=iil_ReadLine($fp, 300); - }while($line[0]!="r"); - return (iil_ParseResult($line)==0); - }else{ - return false; - } -} - -function iil_C_DeleteFolder(&$conn, $folder){ - $fp = $conn->fp; - if (fputs($fp, "d DELETE \"".$folder."\"\r\n")){ - do{ - $line=iil_ReadLine($fp, 300); - }while($line[0]!="d"); - return (iil_ParseResult($line)==0); - }else{ - $conn->error = "Couldn't send command\n"; - return false; + if (fputs($fp, 'r RENAME "' . $from . '" "' . $to . '"' . "\r\n")) { + do { + $line = iil_ReadLine($fp, 300); + } while ($line[0] != 'r'); + return (iil_ParseResult($line) == 0); } + return false; } -function iil_C_Append(&$conn, $folder, &$message){ - if (!$folder) return false; +function iil_C_DeleteFolder(&$conn, $folder) { + $fp = $conn->fp; + if (fputs($fp, 'd DELETE "' . $folder. '"' . "\r\n")) { + do { + $line=iil_ReadLine($fp, 300); + } while ($line[0] != 'd'); + return (iil_ParseResult($line) == 0); + } + $conn->error = "Couldn't send command\n"; + return false; +} + +function iil_C_Append(&$conn, $folder, &$message) { + if (!$folder) { + return false; + } $fp = $conn->fp; - $message = str_replace("\r", "", $message); + $message = str_replace("\r", '', $message); $message = str_replace("\n", "\r\n", $message); $len = strlen($message); - if (!$len) return false; - - $request="A APPEND \"".$folder."\" (\\Seen) {".$len."}\r\n"; - if (fputs($fp, $request)){ + if (!$len) { + return false; + } + $request = 'A APPEND "' . $folder .'" (\\Seen) {' . $len . "}\r\n"; + + if (fputs($fp, $request)) { $line=iil_ReadLine($fp, 100); $sent = fwrite($fp, $message."\r\n"); - flush(); - do{ + do { $line=iil_ReadLine($fp, 1000); - }while($line[0]!="A"); + } while ($line[0] != 'A'); - $result = (iil_ParseResult($line)==0); - if (!$result) $conn->error .= $line."\n"; + $result = (iil_ParseResult($line) == 0); + if (!$result) { + $conn->error .= $line . "\n"; + } return $result; - }else{ - $conn->error .= "Couldn't send command \"$request\"\n"; - return false; } + $conn->error .= "Couldn't send command \"$request\"\n"; + return false; } -function iil_C_AppendFromFile(&$conn, $folder, $path){ - if (!$folder) return false; - +function iil_C_AppendFromFile(&$conn, $folder, $path) { + if (!$folder) { + return false; + } + //open message file $in_fp = false; - if (file_exists(realpath($path))) $in_fp = fopen($path, "r"); - if (!$in_fp){ + if (file_exists(realpath($path))) { + $in_fp = fopen($path, 'r'); + } + if (!$in_fp) { $conn->error .= "Couldn't open $path for reading\n"; return false; } - $fp = $conn->fp; + $fp = $conn->fp; $len = filesize($path); - if (!$len) return false; - + if (!$len) { + return false; + } + //send APPEND command - $request="A APPEND \"".$folder."\" (\\Seen) {".$len."}\r\n"; + $request = 'A APPEND "' . $folder . '" (\\Seen) {' . $len . "}\r\n"; $bytes_sent = 0; - if (fputs($fp, $request)){ - $line=iil_ReadLine($fp, 100); + if (fputs($fp, $request)) { + $line = iil_ReadLine($fp, 100); //send file - while(!feof($in_fp)){ - $buffer = fgets($in_fp, 4096); + while (!feof($in_fp)) { + $buffer = fgets($in_fp, 4096); $bytes_sent += strlen($buffer); fputs($fp, $buffer); } @@ -2025,100 +2512,110 @@ fputs($fp, "\r\n"); //read response - do{ - $line=iil_ReadLine($fp, 1000); - }while($line[0]!="A"); + do { + $line = iil_ReadLine($fp, 1000); + } while ($line[0] != 'A'); - $result = (iil_ParseResult($line)==0); - if (!$result) $conn->error .= $line."\n"; - return $result; + $result = (iil_ParseResult($line) == 0); + if (!$result) { + $conn->error .= $line . "\n"; + } + return $result; - }else{ - $conn->error .= "Couldn't send command \"$request\"\n"; - return false; } + $conn->error .= "Couldn't send command \"$request\"\n"; + return false; } -function iil_C_FetchStructureString(&$conn, $folder, $id){ - $fp = $conn->fp; - $result=false; - if (iil_C_Select($conn, $folder)){ - $key = "F1247"; - if (fputs($fp, "$key FETCH $id (BODYSTRUCTURE)\r\n")){ - do{ +function iil_C_FetchStructureString(&$conn, $folder, $id) { + $fp = $conn->fp; + $result = false; + if (iil_C_Select($conn, $folder)) { + $key = 'F1247'; + + if (fputs($fp, "$key FETCH $id (BODYSTRUCTURE)\r\n")) { + do { $line=chop(iil_ReadLine($fp, 5000)); - if ($line[0]=="*"){ - if (ereg("\}$", $line)){ + if ($line[0] == '*') { + if (ereg("\}$", $line)) { preg_match('/(.+)\{([0-9]+)\}/', $line, $match); $result = $match[1]; - do{ + do { $line = chop(iil_ReadLine($fp, 100)); - if (!preg_match("/^$key/", $line)) $result .= $line; - else $done = true; - }while(!$done); - }else{ + if (!preg_match("/^$key/", $line)) { + $result .= $line; + } else { + $done = true; + } + } while (!$done); + } else { $result = $line; } - list($pre, $post) = explode("BODYSTRUCTURE ", $result); - $result = substr($post, 0, strlen($post)-1); //truncate last ')' and return + list($pre, $post) = explode('BODYSTRUCTURE ', $result); + + //truncate last ')' and return + $result = substr($post, 0, strlen($post)-1); } - }while (!preg_match("/^$key/",$line)); + } while (!preg_match("/^$key/", $line)); } } return $result; } -function iil_C_PrintSource(&$conn, $folder, $id, $part){ +function iil_C_PrintSource(&$conn, $folder, $id, $part) { $header = iil_C_FetchPartHeader($conn, $folder, $id, $part); - //echo str_replace("\r", "", $header); + //echo str_replace("\r", '', $header); echo $header; echo iil_C_PrintPartBody($conn, $folder, $id, $part); } -function iil_C_GetQuota(&$conn){ +function iil_C_GetQuota(&$conn) { /* -b GETQUOTAROOT "INBOX" -* QUOTAROOT INBOX user/rchijiiwa1 -* QUOTA user/rchijiiwa1 (STORAGE 654 9765) -b OK Completed -*/ - $fp = $conn->fp; - $result=false; - $quota_line = ""; + * GETQUOTAROOT "INBOX" + * QUOTAROOT INBOX user/rchijiiwa1 + * QUOTA user/rchijiiwa1 (STORAGE 654 9765) + b OK Completed + */ + $fp = $conn->fp; + $result = false; + $quota_line = ''; //get line containing quota info - if (fputs($fp, "QUOT1 GETQUOTAROOT \"INBOX\"\r\n")){ - do{ + if (fputs($fp, 'QUOT1 GETQUOTAROOT "INBOX"' . "\r\n")) { + do { $line=chop(iil_ReadLine($fp, 5000)); - if (iil_StartsWith($line, "* QUOTA ")) $quota_line = $line; - }while(!iil_StartsWith($line, "QUOT1")); + if (iil_StartsWith($line, '* QUOTA ')) { + $quota_line = $line; + } + } while (!iil_StartsWith($line, 'QUOT1')); } //return false if not found, parse if found - if (!empty($quota_line)){ - $quota_line = eregi_replace("[()]", "", $quota_line); - $parts = explode(" ", $quota_line); - $storage_part = array_search("STORAGE", $parts); - if ($storage_part>0){ + if (!empty($quota_line)) { + $quota_line = eregi_replace('[()]', '', $quota_line); + $parts = explode(' ', $quota_line); + $storage_part = array_search('STORAGE', $parts); + if ($storage_part > 0) { $result = array(); - $used = $parts[$storage_part+1]; - $total = $parts[$storage_part+2]; - $result["used"] = $used; - $result["total"] = (empty($total)?"??":$total); - $result["percent"] = (empty($total)?"??":round(($used/$total)*100)); - $result["free"] = 100 - $result["percent"]; + $used = $parts[$storage_part+1]; + $total = $parts[$storage_part+2]; + + $result['used'] = $used; + $result['total'] = (empty($total)?"??":$total); + $result['percent'] = (empty($total)?"??":round(($used/$total)*100)); + $result['free'] = 100 - $result['percent']; } } - return $result; } -function iil_C_ClearFolder(&$conn, $folder){ +function iil_C_ClearFolder(&$conn, $folder) { $num_in_trash = iil_C_CountMessages($conn, $folder); - if ($num_in_trash > 0) iil_C_Delete($conn, $folder, "1:".$num_in_trash); + if ($num_in_trash > 0) { + iil_C_Delete($conn, $folder, '1:' . $num_in_trash); + } return (iil_C_Expunge($conn, $folder) >= 0); } - ?> -- Gitblit v1.9.1