diff options
| -rw-r--r-- | program/lib/imap.inc | 2213 |
1 files changed, 1290 insertions, 923 deletions
diff --git a/program/lib/imap.inc b/program/lib/imap.inc index c5940773d..c3f1a2f4d 100644 --- a/program/lib/imap.inc +++ b/program/lib/imap.inc @@ -58,15 +58,28 @@ 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 (!$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; @@ -83,7 +96,11 @@ class iilConnection{ var $capability = array(); } -class iilBasicHeader{ +/** + * @todo Change class vars to public/private + */ +class iilBasicHeader +{ var $id; var $uid; var $subject; @@ -113,8 +130,11 @@ class iilBasicHeader{ var $junk = false; } - -class iilThreadHeader{ +/** + * @todo Change class vars to public/private + */ +class iilThreadHeader +{ var $id; var $sbj; var $irt; @@ -122,34 +142,36 @@ class iilThreadHeader{ } -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{ +function iil_ReadLine($fp, $size) { + $line = ''; + if ($fp) { + do { $buffer = fgets($fp, 2048); - if ($buffer === false) + if ($buffer === false) { break; + } $line.=$buffer; - }while($buffer[strlen($buffer)-1]!="\n"); + } 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){ + while (strlen($out)<$bytes) { $out.=chop(iil_ReadLine($fp, 1024)); } $line = $a[1][0]."\"$out\""; @@ -157,170 +179,212 @@ function iil_MultLine($fp, $line){ return $line; } -function iil_ReadBytes($fp, $bytes){ - $data = ""; - $len = 0; - do{ +function iil_ReadBytes($fp, $bytes) { + $data = ''; + $len = 0; + do { $data.=fread($fp, $bytes-$len); $len = strlen($data); - }while($len<$bytes); + } 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 = md5(iil_xor($pass,$opad) . pack("H*",md5(iil_xor($pass, $ipad) . base64_decode($encChallenge)))); + // generate reply - $reply = base64_encode($user." ".$hash); + $reply = base64_encode($user . ' ' . $hash); // send result, get reply 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); - 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; - }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")); - - if (!is_array($data)) return false; + } while (!iil_StartsWith($line, "ns1")); + 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 @@ -328,55 +392,72 @@ function iil_Connect($host, $user, $password){ // $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){ + if ($ICL_SSL) { $host = "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 @@ -384,41 +465,44 @@ function iil_Connect($host, $user, $password){ //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]=="+"){ + + 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{ + } 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"; @@ -426,36 +510,36 @@ function iil_Connect($host, $user, $password){ $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"; @@ -464,35 +548,35 @@ function iil_C_WriteCache(&$conn){ } } -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){ +function iil_C_LoadCache(&$conn, $folder) { if (!$conn->do_cache) return false; $key = $folder.".imap"; - if (!is_array($conn->cache[$folder])){ + 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 + 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++; @@ -502,15 +586,15 @@ function iil_C_ExpireCachedItems(&$conn, $folder, $message_set){ //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; @@ -518,7 +602,7 @@ function iil_C_ExpireCachedItems(&$conn, $folder, $message_set){ */ } -function iil_ExplodeQuotedString($delimiter, $string){ +function iil_ExplodeQuotedString($delimiter, $string) { $quotes=explode("\"", $string); while ( list($key, $val) = each($quotes)) if (($key % 2) == 1) @@ -532,87 +616,107 @@ function iil_ExplodeQuotedString($delimiter, $string){ 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 @@ -621,22 +725,23 @@ function iil_StrToTime($str){ //strip off day of week $pos=strpos($str, " "); - if (!is_numeric(substr($str, 0, $pos))) $str = substr($str, $pos+1); - + 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); @@ -644,33 +749,42 @@ function iil_StrToTime($str){ 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 (!$fields[$field]) - return false; + 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; + } + $is_uid = $is_uid ? 'UID ' : ''; - if (!empty($add)) - $add = " $add"; + if (!empty($add)) { + $add = " $add"; + } - $fp = $conn->fp; + $fp = $conn->fp; $command = 's '. $is_uid .'SORT ('.$field.') '.$encoding.' ALL'."$add\r\n"; - $line = $data = ''; + $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'); + } while ($line[0]!='s'); - if (empty($data)){ + if (empty($data)) { $conn->error = $line; return false; } @@ -679,67 +793,81 @@ function iil_C_Sort(&$conn, $mailbox, $field, $add='', $is_uid=FALSE, $encoding= 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; } @@ -748,12 +876,12 @@ function iil_C_FetchHeaderIndex(&$conn, $mailbox, $message_set, $index_field, $n } /* $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{ + do { $line = iil_ReadLine($fp, 0); $received+=strlen($line); $line = chop($line); @@ -763,82 +891,99 @@ function iil_C_FetchHeaderIndex(&$conn, $mailbox, $message_set, $index_field, $n 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{ + $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++); + } 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{ + if (!fputs($fp, $request)) { + return false; + } + do { $line=chop(iil_ReadLine($fp, 200)); - if ($line[0]=="*"){ + 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); + $a = explode(' ', $foo); $id = $a[1]; $open_pos = strpos($line, "\"") + 1; $close_pos = strrpos($line, "\""); - if ($open_pos && $close_pos){ + 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] = ''; + } + } } } @@ -846,25 +991,29 @@ function iil_C_FetchHeaderIndex(&$conn, $mailbox, $message_set, $index_field, $n } -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); sort($ids); $result = array(); $start = $prev = $ids[0]; - foreach($ids as $id){ + foreach ($ids as $id) { $incr = $id - $prev; - if ($incr>1){ //found a gap + 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 @@ -872,29 +1021,38 @@ function iil_CompressMessageSet($message_set){ $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(); +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(); + if ($num == 0) { + return array(); + } $message_set = '1'.($num>1?':'.$num:''); //if cache not enabled, just call iil_C_FetchHeaderIndex on 'UID' field @@ -902,123 +1060,151 @@ function iil_C_FetchUIDs(&$conn,$mailbox){ 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{ + 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:'))){ + 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); $new[strtoupper($field_name)] = trim($field_val); - }else if (ereg('^[[:space:]]', $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"; @@ -1027,129 +1213,165 @@ function iil_C_FetchThreadHeaders(&$conn, $mailbox, $message_set){ 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; + $id = $header->id; $new = array('id'=>$id, 'MESSAGE-ID'=>$header->mid, - 'IN-REPLY-TO'=>$header->irt, 'SUBJECT'=>$header->sbj); + '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; } @@ -1157,19 +1379,21 @@ function iil_SortThreads(&$tree, $index, $sort_order='ASC'){ //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 @@ -1185,7 +1409,7 @@ function iil_SortThreads(&$tree, $index, $sort_order='ASC'){ ksort($itree); $i=0; $out=array(); - foreach($itree as $k=>$node){ + foreach ($itree as $k=>$node) { $out[$i] = $itree[$k]; $i++; } @@ -1194,80 +1418,97 @@ function iil_SortThreads(&$tree, $index, $sort_order='ASC'){ 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 REFERENCES DISPOSITION-NOTIFICATION-TO)])\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 = ""; - $result[$id]->messageID = "mid:".$id; + $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)])\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 = ''; + $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)); } @@ -1281,24 +1522,26 @@ function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false){ 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; - }while(trim($line[0])!=")" && strncmp($line, $key, strlen($key))); // patch from "Maksim Rubis" <siburny@hotmail.com> + if (preg_match("/^\s*UID [0-9]+\)$/",$line)) { + break; + } + } while (trim($line[0]) != ')' && strncmp($line, $key, strlen($key))); // patch from "Maksim Rubis" <siburny@hotmail.com> - 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); - - switch ($field){ + 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); + + switch ($field) { case 'date'; $result[$id]->date = $string; $result[$id]->timestamp = iil_StrToTime($string); @@ -1310,7 +1553,7 @@ function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false){ $result[$id]->to = str_replace("\n", " ", $string); break; case 'subject': - $result[$id]->subject = str_replace("\n", "", $string); + $result[$id]->subject = str_replace("\n", '', $string); break; case 'reply-to': $result[$id]->replyto = str_replace("\n", " ", $string); @@ -1345,36 +1588,38 @@ function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false){ case 'message-id': $result[$id]->messageID = $string; break; - } - } - } - else { - $a=explode(" ", $line); - } - + } // end switch () + } // end while () + } 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{ + $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]=="*"){ + //$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 @@ -1383,31 +1628,37 @@ function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false){ //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); + $flags_str = eregi_replace('[\\\"]', '', $flags_str); + $flags_a = explode(' ', $flags_str); //echo "<!-- ID: $id FLAGS: ".implode(",", $flags_a)." //-->\n"; - 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; - else if (strcasecmp($val, "\$MDNSent")==0) $result[$id]->mdn_sent = 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_a; } @@ -1416,57 +1667,71 @@ function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false){ $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? - $result[$id]->internaldate = $time_str; + $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) { //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; } - 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. @@ -1475,33 +1740,36 @@ function iil_SortHeaders($a, $field, $flag){ */ // 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); - + 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++; } @@ -1510,557 +1778,644 @@ function iil_SortHeaders($a, $field, $flag){ return $result; } -function iil_C_Expunge(&$conn, $mailbox){ +function iil_C_Expunge(&$conn, $mailbox) { $fp = $conn->fp; - if (iil_C_Select($conn, $mailbox)){ + 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")); + } 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", - "MDNSENT"=>"\$MDNSent" - ); - $flag=strtoupper($flag); - $flag=$flags[$flag]; - if (iil_C_Select($conn, $mailbox)){ +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{ + 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( +function iil_FormatSearchDate($month, $day, $year) { + $month = (int) $month; + $months = $GLOBALS['IMAP_MONTHS']; + /* $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; + */ + 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)){ + 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; + 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; - + if (!$from || !$to) { + return -1; + } + $r=iil_C_Copy($conn, $messages, $from,$to); - if ($r==0){ + 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; +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{ + 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] != ')')) { $line=iil_ReadLine($fp, 300); - while(chop($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] == "}"){ + $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] == '}') { //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 .= chop($line)."\n"; + } else if ($mode==2) { + echo chop($line)."\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){ + if ($result) { $result = chop($result); return $result; // substr($result, 0, strlen($result)-1); - }else return false; - }else{ + } + 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{ + 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; - } + } while ($line[0]!="r"); + return (iil_ParseResult($line) == 0); + } + return false; } -function iil_C_DeleteFolder(&$conn, $folder){ +function iil_C_DeleteFolder(&$conn, $folder) { $fp = $conn->fp; - if (fputs($fp, "d DELETE \"".$folder."\"\r\n")){ - do{ + 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; + } 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){ +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)){ + $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)){ + if (fputs($fp, $request)) { $line=iil_ReadLine($fp, 100); //send file - while(!feof($in_fp)){ + while (!feof($in_fp)) { $buffer = fgets($in_fp, 4096); $bytes_sent += strlen($buffer); fputs($fp, $buffer); @@ -2070,89 +2425,99 @@ function iil_C_AppendFromFile(&$conn, $folder, $path){ fputs($fp, "\r\n"); //read response - 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"; - 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); + 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 ($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']; } } @@ -2160,9 +2525,11 @@ b OK Completed } -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); } |