| | |
| | | - 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) |
| | | - Removed some debuggers (echo ...) |
| | | |
| | | ********************************************************/ |
| | | |
| | | /** |
| | | * @todo Possibly clean up more CS. |
| | | * @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"); |
| | | |
| | | |
| | | 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; |
| | |
| | | var $capability = array(); |
| | | } |
| | | |
| | | class iilBasicHeader{ |
| | | /** |
| | | * @todo Change class vars to public/private |
| | | */ |
| | | class iilBasicHeader |
| | | { |
| | | var $id; |
| | | var $uid; |
| | | var $subject; |
| | |
| | | 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; |
| | |
| | | } |
| | | |
| | | |
| | | 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 { |
| | | // FIXME: hardcode size? |
| | | $buffer = fgets($fp, 2048); |
| | | $line.=$buffer; |
| | | }while($buffer[strlen($buffer)-1]!="\n"); |
| | | 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{ |
| | | 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 = 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 |
| | |
| | | // $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 |
| | |
| | | |
| | | //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"; |
| | | |
| | | 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"; |
| | |
| | | |
| | | $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"; |
| | |
| | | } |
| | | } |
| | | |
| | | 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++; |
| | |
| | | //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; |
| | |
| | | */ |
| | | } |
| | | |
| | | 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); |
| | |
| | | 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; |
| | | $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'); |
| | | 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; |
| | | } |
| | |
| | | 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; |
| | | } |
| | |
| | | } |
| | | /* |
| | | $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); |
| | |
| | | |
| | | 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]=="*"){ |
| | | //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] = ''; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | } |
| | | |
| | | 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 ($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(); |
| | | 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{ |
| | | 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"; |
| | |
| | | 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; |
| | | } |
| | |
| | | |
| | | //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 |
| | | |
| | |
| | | ksort($itree); |
| | | $i=0; |
| | | $out=array(); |
| | | foreach($itree as $k=>$node){ |
| | | foreach ($itree as $k=>$node) { |
| | | $out[$i] = $itree[$k]; |
| | | $i++; |
| | | } |
| | |
| | | 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; |
| | | } |
| | | } 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 |
| | | $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); |
| | | } |
| | | |
| | | 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); |
| | | break; |
| | | case 'from': |
| | | $result[$id]->from = $string; |
| | | break; |
| | | case 'to': |
| | | $result[$id]->to = str_replace("\n", " ", $string); |
| | | break; |
| | | case 'subject': |
| | | $result[$id]->subject = str_replace("\n", '', $string); |
| | | break; |
| | | case 'reply-to': |
| | | $result[$id]->replyto = str_replace("\n", " ", $string); |
| | | break; |
| | | case 'cc': |
| | | $result[$id]->cc = str_replace("\n", " ", $string); |
| | | break; |
| | | case 'bcc': |
| | | $result[$id]->bcc = str_replace("\n", " ", $string); |
| | | break; |
| | | case 'content-transfer-encoding': |
| | | $result[$id]->encoding = str_replace("\n", " ", $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 = str_replace("\n", " ", $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); |
| | | } |
| | | } |
| | | }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 |
| | |
| | | |
| | | //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"; |
| | | |
| | | $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? |
| | | $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. |
| | |
| | | */ |
| | | |
| | | // 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++; |
| | | } |
| | |
| | | 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" |
| | | ); |
| | | $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; |
| | | /** |
| | | * 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{ |
| | | 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{ |
| | | 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{ |
| | | 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; |
| | | } while ($line[0]!="r"); |
| | | return (iil_ParseResult($line) == 0); |
| | | } |
| | | return false; |
| | | } |
| | | |
| | | function iil_C_Append(&$conn, $folder, &$message){ |
| | | 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)){ |
| | | $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); |
| | |
| | | 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); |
| | | $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']; |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | |
| | | 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); |
| | | } |
| | | |