| | |
| | | - added \* flag support |
| | | - use PREG instead of EREG |
| | | - removed caching functions |
| | | - handling connection startup response |
| | | - added UID EXPUNGE support |
| | | - fixed problem with double quotes and spaces in folder names in LIST and LSUB |
| | | - rewritten iil_C_FetchHeaderIndex() |
| | | |
| | | ********************************************************/ |
| | | |
| | |
| | | * @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 (!isset($IMAP_USE_HEADER_DATE) || !$IMAP_USE_HEADER_DATE) { |
| | | $IMAP_USE_INTERNAL_DATE = true; |
| | | } |
| | | |
| | | /** |
| | | * @todo Maybe use date() to generate this. |
| | | */ |
| | | $GLOBALS['IMAP_MONTHS'] = array("Jan" => 1, "Feb" => 2, "Mar" => 3, "Apr" => 4, |
| | | "May" => 5, "Jun" => 6, "Jul" => 7, "Aug" => 8, "Sep" => 9, "Oct" => 10, |
| | | "Nov" => 11, "Dec" => 12); |
| | | |
| | | $GLOBALS['IMAP_SERVER_TZ'] = date('Z'); |
| | | |
| | | $GLOBALS['IMAP_FLAGS'] = array( |
| | | 'SEEN' => '\\Seen', |
| | |
| | | } |
| | | |
| | | function iil_PutLine($fp, $string, $endln=true) { |
| | | // console('C: '. rtrim($string)); |
| | | global $my_prefs; |
| | | |
| | | if (!empty($my_prefs['debug_mode'])) |
| | | write_log('imap', 'C: '. rtrim($string)); |
| | | |
| | | return fputs($fp, $string . ($endln ? "\r\n" : '')); |
| | | } |
| | | |
| | |
| | | return $res; |
| | | } |
| | | |
| | | function iil_ReadLine($fp, $size) { |
| | | function iil_ReadLine($fp, $size=1024) { |
| | | global $my_prefs; |
| | | |
| | | $line = ''; |
| | | |
| | | if (!$fp) { |
| | | return $line; |
| | | return NULL; |
| | | } |
| | | |
| | | if (!$size) { |
| | |
| | | } |
| | | |
| | | do { |
| | | if (feof($fp)) { |
| | | return $line ? $line : NULL; |
| | | } |
| | | |
| | | $buffer = fgets($fp, $size); |
| | | |
| | | if ($buffer === false) { |
| | | break; |
| | | } |
| | | // console('S: '. chop($buffer)); |
| | | if (!empty($my_prefs['debug_mode'])) |
| | | write_log('imap', 'S: '. chop($buffer)); |
| | | $line .= $buffer; |
| | | } while ($buffer[strlen($buffer)-1] != "\n"); |
| | | |
| | | |
| | | return $line; |
| | | } |
| | | |
| | | function iil_MultLine($fp, $line) { |
| | | function iil_MultLine($fp, $line, $escape=false) { |
| | | $line = chop($line); |
| | | if (preg_match('/\{[0-9]+\}$/', $line)) { |
| | | $out = ''; |
| | |
| | | $bytes = $a[2][0]; |
| | | while (strlen($out) < $bytes) { |
| | | $line = iil_ReadBytes($fp, $bytes); |
| | | if ($line === NULL) |
| | | break; |
| | | $out .= $line; |
| | | } |
| | | $line = $a[1][0] . "\"$out\""; |
| | | // console('[...] '. $out); |
| | | |
| | | $line = $a[1][0] . '"' . ($escape ? iil_Escape($out) : $out) . '"'; |
| | | } |
| | | return $line; |
| | | } |
| | | |
| | | function iil_ReadBytes($fp, $bytes) { |
| | | global $my_prefs; |
| | | $data = ''; |
| | | $len = 0; |
| | | do { |
| | | $data .= fread($fp, $bytes-$len); |
| | | if ($len == strlen($data)) { |
| | | while ($len < $bytes && !feof($fp)) |
| | | { |
| | | $d = fread($fp, $bytes-$len); |
| | | if (!empty($my_prefs['debug_mode'])) |
| | | write_log('imap', 'S: '. $d); |
| | | $data .= $d; |
| | | $data_len = strlen($data); |
| | | if ($len == $data_len) { |
| | | break; //nothing was read -> exit to avoid apache lockups |
| | | } |
| | | $len = strlen($data); |
| | | } while ($len < $bytes); |
| | | $len = $data_len; |
| | | }; |
| | | |
| | | return $data; |
| | | } |
| | | |
| | | // don't use it in loops, until you exactly know what you're doing |
| | | function iil_ReadReply($fp) { |
| | | do { |
| | | $line = trim(iil_ReadLine($fp, 1024)); |
| | | } while ($line[0] == '*'); |
| | | |
| | | |
| | | return $line; |
| | | } |
| | | |
| | | function iil_ParseResult($string) { |
| | | $a = explode(' ', $string); |
| | | if (count($a) > 2) { |
| | | if (strcasecmp($a[1], 'OK') == 0) { |
| | | $a = explode(' ', trim($string)); |
| | | if (count($a) >= 2) { |
| | | $res = strtoupper($a[1]); |
| | | if ($res == 'OK') { |
| | | return 0; |
| | | } else if (strcasecmp($a[1], 'NO') == 0) { |
| | | } else if ($res == 'NO') { |
| | | return -1; |
| | | } else if (strcasecmp($a[1], 'BAD') == 0) { |
| | | } else if ($res == 'BAD') { |
| | | return -2; |
| | | } else if (strcasecmp($a[1], 'BYE') == 0) { |
| | | } else if ($res == 'BYE') { |
| | | return -3; |
| | | } |
| | | } |
| | | } |
| | | return -4; |
| | | } |
| | |
| | | return false; |
| | | } |
| | | |
| | | function iil_StartsWithI($string, $match, $bye=false) { |
| | | function iil_StartsWithI($string, $match, $error=false) { |
| | | $len = strlen($match); |
| | | if ($len == 0) { |
| | | return false; |
| | |
| | | if (strncasecmp($string, $match, $len) == 0) { |
| | | return true; |
| | | } |
| | | if ($bye && strncmp($string, '* BYE ', 6) == 0) { |
| | | if ($error && preg_match('/^\* (BYE|BAD) /i', $string)) { |
| | | return true; |
| | | |
| | | } |
| | | return false; |
| | | } |
| | |
| | | |
| | | iil_PutLine($conn->fp, 'a001 LOGIN "'.iil_Escape($user).'" "'.iil_Escape($password).'"'); |
| | | |
| | | do { |
| | | $line = iil_ReadReply($conn->fp); |
| | | if ($line === false) { |
| | | break; |
| | | } |
| | | } while (!iil_StartsWith($line, 'a001 ', true)); |
| | | |
| | | $line = iil_ReadReply($conn->fp); |
| | | |
| | | // process result |
| | | $result = iil_ParseResult($line); |
| | | |
| | |
| | | // set some imap options |
| | | if (is_array($options)) { |
| | | foreach($options as $optkey => $optval) { |
| | | if ($optkey == 'imap') { |
| | | $auth_method = $optval; |
| | | if ($optkey == 'auth_method') { |
| | | $auth_method = strtoupper($optval); |
| | | } else if ($optkey == 'rootdir') { |
| | | $my_prefs['rootdir'] = $optval; |
| | | } else if ($optkey == 'delimiter') { |
| | | $my_prefs['delimiter'] = $optval; |
| | | } else if ($optkey == 'debug_mode') { |
| | | $my_prefs['debug_mode'] = $optval; |
| | | } |
| | | } |
| | | } |
| | | |
| | | if (empty($auth_method)) |
| | | $auth_method = 'check'; |
| | | $auth_method = 'CHECK'; |
| | | |
| | | $message = "INITIAL: $auth_method\n"; |
| | | |
| | |
| | | } 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)) { |
| | |
| | | $host = $ICL_SSL . '://' . $host; |
| | | } |
| | | |
| | | $conn->fp = fsockopen($host, $ICL_PORT, $errno, $errstr, 10); |
| | | $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 = -2; |
| | | return false; |
| | | } |
| | | |
| | | $iil_error .= "Socket connection established\r\n"; |
| | | $line = iil_ReadLine($conn->fp, 4096); |
| | | stream_set_timeout($conn->fp, 10); |
| | | $line = trim(fgets($conn->fp, 8192)); |
| | | |
| | | if ($my_prefs['debug_mode'] && $line) |
| | | write_log('imap', 'S: '. $line); |
| | | |
| | | // Connected to wrong port or connection error? |
| | | if (!preg_match('/^\* (OK|PREAUTH)/i', $line)) { |
| | | if ($line) |
| | | $iil_error = "Wrong startup greeting ($host:$ICL_PORT): $line"; |
| | | else |
| | | $iil_error = "Empty startup greeting ($host:$ICL_PORT)"; |
| | | $iil_errornum = -2; |
| | | return false; |
| | | } |
| | | |
| | | // RFC3501 [7.1] optional CAPABILITY response |
| | | if (preg_match('/\[CAPABILITY ([^]]+)\]/i', $line, $matches)) { |
| | |
| | | } |
| | | } |
| | | |
| | | if (strcasecmp($auth_method, "check") == 0) { |
| | | //check for supported auth methods |
| | | $orig_method = $auth_method; |
| | | |
| | | if ($auth_method == 'CHECK') { |
| | | // check for supported auth methods |
| | | if (iil_C_GetCapability($conn, 'AUTH=CRAM-MD5') || iil_C_GetCapability($conn, 'AUTH=CRAM_MD5')) { |
| | | $auth_method = 'auth'; |
| | | $auth_method = 'AUTH'; |
| | | } |
| | | else { |
| | | //default to plain text auth |
| | | $auth_method = 'plain'; |
| | | // default to plain text auth |
| | | $auth_method = 'PLAIN'; |
| | | } |
| | | } |
| | | |
| | | if (strcasecmp($auth_method, 'auth') == 0) { |
| | | $conn->message .= "Trying CRAM-MD5\n"; |
| | | |
| | | //do CRAM-MD5 authentication |
| | | if ($auth_method == 'AUTH') { |
| | | // do CRAM-MD5 authentication |
| | | iil_PutLine($conn->fp, "a000 AUTHENTICATE CRAM-MD5"); |
| | | $line = trim(iil_ReadLine($conn->fp, 1024)); |
| | | |
| | | $conn->message .= "$line\n"; |
| | | |
| | | if ($line[0] == '+') { |
| | | $conn->message .= 'Got challenge: ' . htmlspecialchars($line) . "\n"; |
| | | |
| | | //got a challenge string, try CRAM-5 |
| | | // got a challenge string, try CRAM-MD5 |
| | | $result = iil_C_Authenticate($conn, $user, $password, substr($line,2)); |
| | | |
| | | // stop if server sent BYE response |
| | | if($result == -3) { |
| | | if ($result == -3) { |
| | | $iil_error = $conn->error; |
| | | $iil_errornum = $conn->errorNum; |
| | | return false; |
| | | } |
| | | $conn->message .= "Tried CRAM-MD5: $result \n"; |
| | | } else { |
| | | $conn->message .='No challenge ('.htmlspecialchars($line)."), try plain\n"; |
| | | $auth = 'plain'; |
| | | } |
| | | |
| | | if (!is_resource($result) && $orig_method == 'CHECK') { |
| | | $auth_method = 'PLAIN'; |
| | | } |
| | | } |
| | | |
| | | if ((!$result)||(strcasecmp($auth, "plain") == 0)) { |
| | | //do plain text auth |
| | | if ($auth_method == 'PLAIN') { |
| | | // do plain text auth |
| | | $result = iil_C_Login($conn, $user, $password); |
| | | $conn->message .= "Tried PLAIN: $result \n"; |
| | | } |
| | | |
| | | $conn->message .= $auth; |
| | | |
| | | if (!is_int($result)) { |
| | | |
| | | if (is_resource($result)) { |
| | | iil_C_Namespace($conn); |
| | | return $conn; |
| | | } else { |
| | |
| | | |
| | | function iil_Close(&$conn) { |
| | | if (iil_PutLine($conn->fp, "I LOGOUT")) { |
| | | fgets($conn->fp, 1024); |
| | | if (!feof($conn->fp)) |
| | | fgets($conn->fp, 1024); |
| | | fclose($conn->fp); |
| | | $conn->fp = false; |
| | | } |
| | | } |
| | | |
| | | 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]); |
| | | } |
| | | $result = array(); |
| | | $strlen = strlen($string); |
| | | |
| | | for ($q=$p=$i=0; $i < $strlen; $i++) { |
| | | if ($string[$i] == "\"" && $string[$i-1] != "\\") { |
| | | $q = $q ? false : true; |
| | | } |
| | | else if (!$q && preg_match("/$delimiter/", $string[$i])) { |
| | | $result[] = substr($string, $p, $i - $p); |
| | | $p = $i + 1; |
| | | } |
| | | } |
| | | $string = implode('"', $quotes); |
| | | |
| | | $result = explode($delimiter, $string); |
| | | while ( list($key, $val) = each($result) ) { |
| | | $result[$key] = str_replace('_!@!_', $delimiter, $result[$key]); |
| | | } |
| | | |
| | | |
| | | $result[] = substr($string, $p); |
| | | return $result; |
| | | } |
| | | |
| | |
| | | if (empty($mailbox)) { |
| | | return false; |
| | | } |
| | | if (strcmp($conn->selected, $mailbox) == 0) { |
| | | if ($conn->selected == $mailbox) { |
| | | return true; |
| | | } |
| | | |
| | |
| | | $line = chop(iil_ReadLine($conn->fp, 300)); |
| | | $a = explode(' ', $line); |
| | | if (count($a) == 3) { |
| | | if (strcasecmp($a[2], 'EXISTS') == 0) { |
| | | $token = strtoupper($a[2]); |
| | | if ($token == 'EXISTS') { |
| | | $conn->exists = (int) $a[1]; |
| | | } |
| | | if (strcasecmp($a[2], 'RECENT') == 0) { |
| | | else if ($token == 'RECENT') { |
| | | $conn->recent = (int) $a[1]; |
| | | } |
| | | } |
| | |
| | | $conn->permanentflags = explode(' ', $match[1]); |
| | | } |
| | | } while (!iil_StartsWith($line, 'sel1', true)); |
| | | |
| | | $a = explode(' ', $line); |
| | | |
| | | if (strcasecmp($a[1], 'OK') == 0) { |
| | | $conn->selected = $mailbox; |
| | |
| | | return $string; |
| | | } |
| | | |
| | | function iil_StrToTime($str) { |
| | | $IMAP_MONTHS = $GLOBALS['IMAP_MONTHS']; |
| | | $IMAP_SERVER_TZ = $GLOBALS['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); |
| | | |
| | | //strip off day of week |
| | | $pos = strpos($str, ' '); |
| | | if (!is_numeric(substr($str, 0, $pos))) { |
| | | $str = substr($str, $pos+1); |
| | | } |
| | | //explode, take good parts |
| | | $a = explode(' ', $str); |
| | | function iil_StrToTime($date) { |
| | | |
| | | $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); |
| | | //echo '<!--'.$time1.' '.$time2.' //-->'."\n"; |
| | | return $time2; |
| | | // support non-standard "GMTXXXX" literal |
| | | $date = preg_replace('/GMT\s*([+-][0-9]+)/', '\\1', $date); |
| | | // if date parsing fails, we have a date in non-rfc format. |
| | | // remove token from the end and try again |
| | | while ((($ts = @strtotime($date))===false) || ($ts < 0)) |
| | | { |
| | | $d = explode(' ', $date); |
| | | array_pop($d); |
| | | if (!$d) break; |
| | | $date = implode(' ', $d); |
| | | } |
| | | |
| | | $ts = (int) $ts; |
| | | |
| | | return $ts < 0 ? 0 : $ts; |
| | | } |
| | | |
| | | function iil_C_Sort(&$conn, $mailbox, $field, $add='', $is_uid=FALSE, |
| | |
| | | $command = 's ' . $is_uid . 'SORT (' . $field . ') '; |
| | | $command .= $encoding . ' ALL' . $add; |
| | | $line = $data = ''; |
| | | |
| | | |
| | | if (!iil_PutLineC($conn->fp, $command)) { |
| | | return false; |
| | | } |
| | | do { |
| | | $line = chop(iil_ReadLine($conn->fp, 1024)); |
| | | $line = chop(iil_ReadLine($conn->fp)); |
| | | if (iil_StartsWith($line, '* SORT')) { |
| | | $data .= ($data ? ' ' : '') . substr($line, 7); |
| | | $data .= substr($line, 7); |
| | | } else if (preg_match('/^[0-9 ]+$/', $line)) { |
| | | $data .= $line; |
| | | } |
| | |
| | | return false; |
| | | } |
| | | |
| | | $out = explode(' ',$data); |
| | | return $out; |
| | | return preg_split('/\s+/', $data, -1, PREG_SPLIT_NO_EMPTY); |
| | | } |
| | | |
| | | 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'; |
| | | } |
| | | $index_field = strtoupper($index_field); |
| | | |
| | | function iil_C_FetchHeaderIndex(&$conn, $mailbox, $message_set, $index_field='', $skip_deleted=true, $uidfetch=false) { |
| | | |
| | | 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) && $to_idx != '*' && (int)$from_idx > (int)$to_idx)) { |
| | | return false; |
| | | } |
| | | |
| | | $index_field = empty($index_field) ? 'DATE' : strtoupper($index_field); |
| | | |
| | | //$fields_a['DATE'] = ($IMAP_USE_INTERNAL_DATE?6:1); |
| | | $fields_a['DATE'] = 1; |
| | | $fields_a['INTERNALDATE'] = 6; |
| | | $fields_a['INTERNALDATE'] = 4; |
| | | $fields_a['FROM'] = 1; |
| | | $fields_a['REPLY-TO'] = 1; |
| | | $fields_a['SENDER'] = 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; |
| | | $fields_a['RECENT'] = 3; |
| | | $fields_a['DELETED'] = 3; |
| | | |
| | | if (!($mode = $fields_a[$index_field])) { |
| | | return false; |
| | | } |
| | | |
| | | |
| | | /* Do "SELECT" command */ |
| | | if (!iil_C_Select($conn, $mailbox)) { |
| | | return false; |
| | | return false; |
| | | } |
| | | |
| | | /* FETCH date,from,subject headers */ |
| | | if ($mode == 1) { |
| | | $key = 'fhi' . ($c++); |
| | | $request = $key . " FETCH $message_set (BODY.PEEK[HEADER.FIELDS ($index_field)])"; |
| | | if (!iil_PutLine($fp, $request)) { |
| | | return false; |
| | | } |
| | | do { |
| | | |
| | | $line=chop(iil_ReadLine($fp, 200)); |
| | | $a=explode(' ', $line); |
| | | if (($line[0] == '*') && ($a[2] == 'FETCH') |
| | | && ($line[strlen($line)-1] != ')')) { |
| | | $id=$a[1]; |
| | | |
| | | // build FETCH command string |
| | | $key = 'fhi0'; |
| | | $cmd = $uidfetch ? 'UID FETCH' : 'FETCH'; |
| | | $deleted = $skip_deleted ? ' FLAGS' : ''; |
| | | |
| | | $str=$line=chop(iil_ReadLine($fp, 300)); |
| | | if ($mode == 1 && $index_field == 'DATE') |
| | | $request = " $cmd $message_set (INTERNALDATE BODY.PEEK[HEADER.FIELDS (DATE)]$deleted)"; |
| | | else if ($mode == 1) |
| | | $request = " $cmd $message_set (BODY.PEEK[HEADER.FIELDS ($index_field)]$deleted)"; |
| | | else if ($mode == 2) { |
| | | if ($index_field == 'SIZE') |
| | | $request = " $cmd $message_set (RFC822.SIZE$deleted)"; |
| | | else |
| | | $request = " $cmd $message_set ($index_field$deleted)"; |
| | | } else if ($mode == 3) |
| | | $request = " $cmd $message_set (FLAGS)"; |
| | | else // 4 |
| | | $request = " $cmd $message_set (INTERNALDATE$deleted)"; |
| | | |
| | | 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 ((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]); |
| | | } |
| | | } |
| | | $str=$line; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | /* |
| | | $end_pos = strlen($line)-1; |
| | | if (($line[0]=="*") && ($a[2]=="FETCH") && ($line[$end_pos]=="}")) { |
| | | $id = $a[1]; |
| | | $pos = strrpos($line, "{")+1; |
| | | $bytes = (int)substr($line, $pos, $end_pos-$pos); |
| | | $received = 0; |
| | | do { |
| | | $line = iil_ReadLine($fp, 0); |
| | | $received += strlen($line); |
| | | $line = chop($line); |
| | | $request = $key . $request; |
| | | |
| | | if (!iil_PutLine($conn->fp, $request)) |
| | | return false; |
| | | |
| | | $result = array(); |
| | | |
| | | do { |
| | | $line = chop(iil_ReadLine($conn->fp, 200)); |
| | | $line = iil_MultLine($conn->fp, $line); |
| | | |
| | | if (preg_match('/^\* ([0-9]+) FETCH/', $line, $m)) { |
| | | |
| | | $id = $m[1]; |
| | | $flags = NULL; |
| | | |
| | | if ($received>$bytes) { |
| | | break; |
| | | } else if (!$line) { |
| | | continue; |
| | | } |
| | | |
| | | list($field, $string) = explode(': ', $line); |
| | | |
| | | 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 { |
| | | //one line response, not expected so ignore |
| | | if ($skip_deleted && preg_match('/FLAGS \(([^)]+)\)/', $line, $matches)) { |
| | | $flags = explode(' ', strtoupper($matches[1])); |
| | | if (in_array('\\DELETED', $flags)) { |
| | | $deleted[$id] = $id; |
| | | continue; |
| | | } |
| | | } |
| | | */ |
| | | } while (!iil_StartsWith($line, $key, true)); |
| | | |
| | | }else if ($mode == 6) { |
| | | |
| | | $key = 'fhi' . ($c++); |
| | | $request = $key . " FETCH $message_set (INTERNALDATE)"; |
| | | if (!iil_PutLine($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]; |
| | | |
| | | $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); |
| | | if ($mode == 1 && $index_field == 'DATE') { |
| | | if (preg_match('/BODY\[HEADER\.FIELDS \("*DATE"*\)\] (.*)/', $line, $matches)) { |
| | | $value = preg_replace(array('/^"*[a-z]+:/i'), '', $matches[1]); |
| | | $value = trim($value); |
| | | $result[$id] = iil_StrToTime($value); |
| | | } |
| | | } else { |
| | | $a = explode(' ', $line); |
| | | } |
| | | } while (!iil_StartsWith($a[0], $key, true)); |
| | | } 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)"; |
| | | |
| | | if (!iil_PutLine($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); |
| | | |
| | | $id = $a[1]; |
| | | |
| | | if (isset($result[$id])) { |
| | | continue; //if we already got the data, skip forward |
| | | // non-existent/empty Date: header, use INTERNALDATE |
| | | if (empty($result[$id])) { |
| | | if (preg_match('/INTERNALDATE "([^"]+)"/', $line, $matches)) |
| | | $result[$id] = iil_StrToTime($matches[1]); |
| | | else |
| | | $result[$id] = 0; |
| | | } |
| | | 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 if ($mode == 1) { |
| | | if (preg_match('/BODY\[HEADER\.FIELDS \("?(FROM|REPLY-TO|SENDER|TO|SUBJECT)"?\)\] (.*)/', $line, $matches)) { |
| | | $value = preg_replace(array('/^"*[a-z]+:/i', '/\s+$/sm'), array('', ''), $matches[2]); |
| | | $result[$id] = trim($value); |
| | | } else { |
| | | $haystack = strtoupper($line); |
| | | $result[$id] = (strpos($haystack, $index_field) > 0 ? "F" : "N"); |
| | | $result[$id] = ''; |
| | | } |
| | | } else if ($mode == 2) { |
| | | if (preg_match('/\((UID|RFC822\.SIZE) ([0-9]+)/', $line, $matches)) { |
| | | $result[$id] = trim($matches[2]); |
| | | } else { |
| | | $result[$id] = 0; |
| | | } |
| | | } else if ($mode == 3) { |
| | | if (!$flags && preg_match('/FLAGS \(([^)]+)\)/', $line, $matches)) { |
| | | $flags = explode(' ', $matches[1]); |
| | | } |
| | | $result[$id] = in_array('\\'.$index_field, $flags) ? 1 : 0; |
| | | } else if ($mode == 4) { |
| | | if (preg_match('/INTERNALDATE "([^"]+)"/', $line, $matches)) { |
| | | $result[$id] = iil_StrToTime($matches[1]); |
| | | } else { |
| | | $result[$id] = 0; |
| | | } |
| | | } |
| | | } while (!iil_StartsWith($line, $key, true)); |
| | | } |
| | | } |
| | | } while (!iil_StartsWith($line, $key, true)); |
| | | |
| | | /* |
| | | //check number of elements... |
| | | list($start_mid, $end_mid) = explode(':', $message_set); |
| | | if (is_numeric($start_mid) && is_numeric($end_mid)) { |
| | | if (is_numeric($from_idx) && is_numeric($to_idx)) { |
| | | //count how many we should have |
| | | $should_have = $end_mid - $start_mid +1; |
| | | $should_have = $to_idx - $from_idx + 1; |
| | | |
| | | //if we have less, try and fill in the "gaps" |
| | | if (count($result) < $should_have) { |
| | | for ($i=$start_mid; $i<=$end_mid; $i++) { |
| | | for ($i=$from_idx; $i<=$to_idx; $i++) { |
| | | if (!isset($result[$i])) { |
| | | $result[$i] = ''; |
| | | } |
| | | } |
| | | } |
| | | } |
| | | */ |
| | | return $result; |
| | | } |
| | | |
| | |
| | | $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)) { |
| | | return false; |
| | | } |
| | | |
| | | /* Do "SELECT" command */ |
| | | if (!iil_C_Select($conn, $mailbox)) { |
| | | $conn->error = "Couldn't select $mailbox"; |
| | | return false; |
| | | } |
| | | |
| | | |
| | | $message_set = iil_CompressMessageSet($message_set); |
| | | |
| | | if ($add) |
| | | $add = ' '.strtoupper(trim($add)); |
| | | |
| | |
| | | $request .= "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".$add.")])"; |
| | | $request .= "REFERENCES DISPOSITION-NOTIFICATION-TO X-PRIORITY "; |
| | | $request .= "X-REPLY-UID X-FORWARD-UID".$add.")])"; |
| | | |
| | | if (!iil_PutLine($fp, $request)) { |
| | | return false; |
| | |
| | | $parts_count = count($a); |
| | | if ($parts_count>=6) { |
| | | for ($i=0; $i<$parts_count; $i=$i+2) { |
| | | if (strcasecmp($a[$i],'UID') == 0) |
| | | if ($a[$i] == 'UID') |
| | | $result[$id]->uid = $a[$i+1]; |
| | | else if (strcasecmp($a[$i],'RFC822.SIZE') == 0) |
| | | else if ($a[$i] == 'RFC822.SIZE') |
| | | $result[$id]->size = $a[$i+1]; |
| | | else if (strcasecmp($a[$i],'INTERNALDATE') == 0) |
| | | else if ($a[$i] == 'INTERNALDATE') |
| | | $time_str = $a[$i+1]; |
| | | else if (strcasecmp($a[$i],'FLAGS') == 0) |
| | | else if ($a[$i] == 'FLAGS') |
| | | $flags_str = $a[$i+1]; |
| | | } |
| | | |
| | |
| | | // if time is gmt... |
| | | $time_str = str_replace('GMT','+0000',$time_str); |
| | | |
| | | //get timezone |
| | | $time_str = substr($time_str, 0, -1); |
| | | $time_zone_str = substr($time_str, -5); // extract timezone |
| | | $time_str = substr($time_str, 0, -5); // remove timezone |
| | | $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? |
| | | } |
| | | |
| | | //calculate timestamp |
| | | $timestamp = strtotime($time_str); //return's server's time |
| | | $timestamp -= $time_zone * 3600; //compensate for tz, get GMT |
| | | |
| | | $result[$id]->internaldate = $time_str; |
| | | $result[$id]->timestamp = $timestamp; |
| | | $result[$id]->timestamp = iil_StrToTime($time_str); |
| | | $result[$id]->date = $time_str; |
| | | } |
| | | |
| | |
| | | if($bodystr) { |
| | | while (!preg_match('/ BODYSTRUCTURE (.*) BODY\[HEADER.FIELDS/s', $line, $m)) { |
| | | $line2 = iil_ReadLine($fp, 1024); |
| | | $line .= iil_MultLine($fp, $line2); |
| | | $line .= iil_MultLine($fp, $line2, true); |
| | | } |
| | | $result[$id]->body_structure = $m[1]; |
| | | } |
| | | |
| | | // the rest of the result |
| | | preg_match('/ BODY\[HEADER.FIELDS \(.*\)\]\s*(.*)/s', $line, $m); |
| | | preg_match('/ BODY\[HEADER.FIELDS \(.*?\)\]\s*(.*)$/s', $line, $m); |
| | | $reslines = explode("\n", trim($m[1], '"')); |
| | | // re-parse (see below) |
| | | foreach ($reslines as $line) { |
| | | if (ord($line[0])<=32) { |
| | | $lines[$ln] .= (empty($lines[$ln])?'':"\n").trim($line); |
| | | foreach ($reslines as $resln) { |
| | | if (ord($resln[0])<=32) { |
| | | $lines[$ln] .= (empty($lines[$ln])?'':"\n").trim($resln); |
| | | } else { |
| | | $lines[++$ln] = trim($line); |
| | | $lines[++$ln] = trim($resln); |
| | | } |
| | | } |
| | | } |
| | |
| | | $lines[++$ln] = trim($line); |
| | | } |
| | | // patch from "Maksim Rubis" <siburny@hotmail.com> |
| | | } while (trim($line[0]) != ')' && strncmp($line, $key, strlen($key))); |
| | | } while ($line[0] != ')' && !iil_StartsWith($line, $key, true)); |
| | | |
| | | if (strncmp($line, $key, strlen($key))) { |
| | | // process header, fill iilBasicHeader obj. |
| | |
| | | $headers[$k] = ''; |
| | | } |
| | | } |
| | | |
| | | |
| | | // create array with header field:data |
| | | while ( list($lines_key, $str) = each($lines) ) { |
| | | list($field, $string) = iil_SplitHeaderLine($str); |
| | |
| | | $result[$id]->encoding = $string; |
| | | break; |
| | | case 'content-type': |
| | | $ctype_parts = explode(";", $string); |
| | | $ctype_parts = preg_split('/[; ]/', $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]; |
| | | } |
| | | if (preg_match('/charset\s*=\s*"?([a-z0-9\-\.\_]+)"?/i', $string, $regs)) { |
| | | $result[$id]->charset = $regs[1]; |
| | | } |
| | | break; |
| | | case 'in-reply-to': |
| | |
| | | $flags_a = explode(' ', $flags_str); |
| | | |
| | | if (is_array($flags_a)) { |
| | | reset($flags_a); |
| | | while (list(,$val)=each($flags_a)) { |
| | | if (strcasecmp($val,'Seen') == 0) { |
| | | // reset($flags_a); |
| | | foreach($flags_a as $flag) { |
| | | $flag = strtoupper($flag); |
| | | if ($flag == 'SEEN') { |
| | | $result[$id]->seen = true; |
| | | } else if (strcasecmp($val, 'Deleted') == 0) { |
| | | $result[$id]->deleted=true; |
| | | } else if (strcasecmp($val, 'Recent') == 0) { |
| | | } else if ($flag == 'DELETED') { |
| | | $result[$id]->deleted = true; |
| | | } else if ($flag == 'RECENT') { |
| | | $result[$id]->recent = true; |
| | | } else if (strcasecmp($val, 'Answered') == 0) { |
| | | } else if ($flag == 'ANSWERED') { |
| | | $result[$id]->answered = true; |
| | | } else if (strcasecmp($val, '$Forwarded') == 0) { |
| | | } else if ($flag == '$FORWARDED') { |
| | | $result[$id]->forwarded = true; |
| | | } else if (strcasecmp($val, 'Draft') == 0) { |
| | | } else if ($flag == 'DRAFT') { |
| | | $result[$id]->is_draft = true; |
| | | } else if (strcasecmp($val, '$MDNSent') == 0) { |
| | | } else if ($flag == '$MDNSENT') { |
| | | $result[$id]->mdn_sent = true; |
| | | } else if (strcasecmp($val, 'Flagged') == 0) { |
| | | } else if ($flag == 'FLAGGED') { |
| | | $result[$id]->flagged = true; |
| | | } |
| | | } |
| | |
| | | } |
| | | } |
| | | } |
| | | } while (strcmp($a[0], $key) != 0); |
| | | } while (!iil_StartsWith($line, $key, true)); |
| | | |
| | | return $result; |
| | | } |
| | |
| | | while (list($key, $val)=each($a)) { |
| | | |
| | | if ($field == 'timestamp') { |
| | | $data = @strtotime($val->date); |
| | | if ($data == false) { |
| | | $data = iil_StrToTime($val->date); |
| | | if (!$data) { |
| | | $data = $val->timestamp; |
| | | } |
| | | } else { |
| | |
| | | return $result; |
| | | } |
| | | |
| | | function iil_C_Expunge(&$conn, $mailbox) { |
| | | function iil_C_Expunge(&$conn, $mailbox, $messages=NULL) { |
| | | |
| | | if (iil_C_Select($conn, $mailbox)) { |
| | | $c = 0; |
| | | iil_PutLine($conn->fp, "exp1 EXPUNGE"); |
| | | $command = $messages ? "UID EXPUNGE $messages" : "EXPUNGE"; |
| | | |
| | | iil_PutLine($conn->fp, "exp1 $command"); |
| | | do { |
| | | $line=chop(iil_ReadLine($conn->fp, 100)); |
| | | if ($line[0] == '*') { |
| | |
| | | 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_Copy(&$conn, $messages, $from, $to) { |
| | | $fp = $conn->fp; |
| | | |
| | |
| | | $c=0; |
| | | |
| | | iil_PutLine($fp, "cpy1 UID COPY $messages \"".iil_Escape($to)."\""); |
| | | $line=iil_ReadReply($fp); |
| | | $line = iil_ReadReply($fp); |
| | | return iil_ParseResult($line); |
| | | } else { |
| | | return -1; |
| | | } |
| | | } |
| | | |
| | | function iil_FormatSearchDate($month, $day, $year) { |
| | | $month = (int) $month; |
| | | $months = $GLOBALS['IMAP_MONTHS']; |
| | | return $day . '-' . $months[$month] . '-' . $year; |
| | | } |
| | | |
| | | function iil_C_CountUnseen(&$conn, $folder) { |
| | | $index = iil_C_Search($conn, $folder, 'ALL UNSEEN'); |
| | | if (is_array($index)) { |
| | | if (($cnt = count($index)) && $index[0] != '') { |
| | | return $cnt; |
| | | } |
| | | } |
| | | return false; |
| | | $index = iil_C_Search($conn, $folder, 'ALL UNSEEN'); |
| | | if (is_array($index)) |
| | | return count($index); |
| | | return false; |
| | | } |
| | | |
| | | function iil_C_UID2ID(&$conn, $folder, $uid) { |
| | |
| | | } |
| | | |
| | | function iil_C_ID2UID(&$conn, $folder, $id) { |
| | | $fp = $conn->fp; |
| | | |
| | | if ($id == 0) { |
| | | return -1; |
| | | } |
| | | $result = -1; |
| | | if (iil_C_Select($conn, $folder)) { |
| | | $key = 'FUID'; |
| | | if (iil_PutLine($fp, "$key FETCH $id (UID)")) { |
| | | $key = 'fuid'; |
| | | if (iil_PutLine($conn->fp, "$key FETCH $id (UID)")) { |
| | | do { |
| | | $line=chop(iil_ReadLine($fp, 1024)); |
| | | $line = chop(iil_ReadLine($conn->fp, 1024)); |
| | | if (preg_match("/^\* $id FETCH \(UID (.*)\)/i", $line, $r)) { |
| | | $result = $r[1]; |
| | | } |
| | | } while (!preg_match("/^$key/", $line)); |
| | | } while (!iil_StartsWith($line, $key, true)); |
| | | } |
| | | } |
| | | return $result; |
| | | } |
| | | |
| | | function iil_C_Search(&$conn, $folder, $criteria) { |
| | | $fp = $conn->fp; |
| | | |
| | | if (iil_C_Select($conn, $folder)) { |
| | | $c = 0; |
| | | $data = ''; |
| | | |
| | | $query = 'srch1 SEARCH ' . chop($criteria); |
| | | if (!iil_PutLineC($fp, $query)) { |
| | | if (!iil_PutLineC($conn->fp, $query)) { |
| | | return false; |
| | | } |
| | | do { |
| | | $line=trim(iil_ReadLine($fp, 10000)); |
| | | if (preg_match('/^\* SEARCH/i', $line)) { |
| | | $str = trim(substr($line, 8)); |
| | | $messages = explode(' ', $str); |
| | | $line = trim(iil_ReadLine($conn->fp)); |
| | | if (iil_StartsWith($line, '* SEARCH')) { |
| | | $data .= substr($line, 8); |
| | | } else if (preg_match('/^[0-9 ]+$/', $line)) { |
| | | $data .= $line; |
| | | } |
| | | } while (!iil_StartsWith($line, 'srch1', true)); |
| | | |
| | | $result_code = iil_ParseResult($line); |
| | | if ($result_code == 0) { |
| | | return $messages; |
| | | return preg_split('/\s+/', $data, -1, PREG_SPLIT_NO_EMPTY); |
| | | } |
| | | $conn->error = 'iil_C_Search: ' . $line . "\n"; |
| | | return false; |
| | |
| | | } |
| | | |
| | | function iil_C_Move(&$conn, $messages, $from, $to) { |
| | | $fp = $conn->fp; |
| | | |
| | | if (!$from || !$to) { |
| | | return -1; |
| | | } |
| | | $r = iil_C_Copy($conn, $messages, $from,$to); |
| | | |
| | | $r = iil_C_Copy($conn, $messages, $from, $to); |
| | | |
| | | if ($r==0) { |
| | | return iil_C_Delete($conn, $from, $messages); |
| | | } |
| | |
| | | // get folder list |
| | | do { |
| | | $line = iil_ReadLine($fp, 500); |
| | | $line = iil_MultLine($fp, $line); |
| | | $line = iil_MultLine($fp, $line, true); |
| | | |
| | | $a = explode(' ', $line); |
| | | if (($line[0] == '*') && ($a[1] == 'LIST')) { |
| | |
| | | // split one line |
| | | $a = iil_ExplodeQuotedString(' ', $line); |
| | | // last string is folder name |
| | | $folder = trim($a[count($a)-1], '"'); |
| | | $folder = preg_replace(array('/^"/', '/"$/'), '', iil_UnEscape($a[count($a)-1])); |
| | | |
| | | if (empty($ignore) || (!empty($ignore) |
| | | && !preg_match('/'.preg_quote(ignore, '/').'/i', $folder))) { |
| | |
| | | // get folder list |
| | | do { |
| | | $line = iil_ReadLine($fp, 500); |
| | | $line = iil_MultLine($fp, $line); |
| | | $line = iil_MultLine($fp, $line, true); |
| | | $a = explode(' ', $line); |
| | | |
| | | if (($line[0] == '*') && ($a[1] == 'LSUB' || $a[1] == 'LIST')) { |
| | |
| | | |
| | | // split one line |
| | | $a = iil_ExplodeQuotedString(' ', $line); |
| | | |
| | | // last string is folder name |
| | | //$folder = UTF7DecodeString(str_replace('"', '', $a[count($a)-1])); |
| | | $folder = trim($a[count($a)-1], '"'); |
| | | |
| | | $folder = preg_replace(array('/^"/', '/"$/'), '', iil_UnEscape($a[count($a)-1])); |
| | | |
| | | if ((!in_array($folder, $folders)) && (empty($ignore) |
| | | || (!empty($ignore) && !preg_match('/'.preg_quote(ignore, '/').'/i', $folder)))) { |
| | | $folders[$i] = $folder; |
| | |
| | | $query = 'sub1 SUBSCRIBE "' . iil_Escape($folder). '"'; |
| | | iil_PutLine($fp, $query); |
| | | |
| | | $line = trim(iil_ReadLine($fp, 10000)); |
| | | return iil_ParseResult($line); |
| | | $line = trim(iil_ReadLine($fp, 512)); |
| | | return (iil_ParseResult($line) == 0); |
| | | } |
| | | |
| | | function iil_C_UnSubscribe(&$conn, $folder) { |
| | |
| | | $query = 'usub1 UNSUBSCRIBE "' . iil_Escape($folder) . '"'; |
| | | iil_PutLine($fp, $query); |
| | | |
| | | $line = trim(iil_ReadLine($fp, 10000)); |
| | | return iil_ParseResult($line); |
| | | $line = trim(iil_ReadLine($fp, 512)); |
| | | return (iil_ParseResult($line) == 0); |
| | | } |
| | | |
| | | function iil_C_FetchMIMEHeaders(&$conn, $mailbox, $id, $parts) { |
| | | function iil_C_FetchMIMEHeaders(&$conn, $mailbox, $id, $parts, $mime=true) { |
| | | |
| | | $fp = $conn->fp; |
| | | |
| | |
| | | $key = 'fmh0'; |
| | | $peeks = ''; |
| | | $idx = 0; |
| | | $type = $mime ? 'MIME' : 'HEADER'; |
| | | |
| | | // format request |
| | | foreach($parts as $part) |
| | | $peeks[] = "BODY.PEEK[$part.MIME]"; |
| | | $peeks[] = "BODY.PEEK[$part.$type]"; |
| | | |
| | | $request = "$key FETCH $id (" . implode(' ', $peeks) . ')'; |
| | | |
| | |
| | | $line = iil_ReadLine($fp, 1000); |
| | | $line = iil_MultLine($fp, $line); |
| | | |
| | | if (preg_match('/BODY\[([0-9\.]+)\.MIME\]/', $line, $matches)) { |
| | | if (preg_match('/BODY\[([0-9\.]+)\.'.$type.'\]/', $line, $matches)) { |
| | | $idx = $matches[1]; |
| | | $result[$idx] = preg_replace('/^(\* '.$id.' FETCH \()?\s*BODY\['.$idx.'\.MIME\]\s+/', '', $line); |
| | | $result[$idx] = preg_replace('/^(\* '.$id.' FETCH \()?\s*BODY\['.$idx.'\.'.$type.'\]\s+/', '', $line); |
| | | $result[$idx] = trim($result[$idx], '"'); |
| | | $result[$idx] = rtrim($result[$idx], "\t\r\n\0\x0B"); |
| | | } |
| | |
| | | return $result; |
| | | } |
| | | |
| | | function iil_C_FetchPartHeader(&$conn, $mailbox, $id, $part) { |
| | | function iil_C_FetchPartHeader(&$conn, $mailbox, $id, $is_uid=false, $part=NULL) { |
| | | |
| | | $part = empty($part) ? 'HEADER' : $part.'.MIME'; |
| | | |
| | | return iil_C_HandlePartBody($conn, $mailbox, $id, $part, 1); |
| | | return iil_C_HandlePartBody($conn, $mailbox, $id, $is_uid, $part); |
| | | } |
| | | |
| | | function iil_C_HandlePartBody(&$conn, $mailbox, $id, $part='', $mode=1, $file=NULL) { |
| | | /* modes: |
| | | 1: return string (or write to $file pointer) |
| | | 2: print |
| | | 3: base64 and print (or write to $file pointer) |
| | | */ |
| | | function iil_C_HandlePartBody(&$conn, $mailbox, $id, $is_uid=false, $part='', $encoding=NULL, $print=NULL, $file=NULL) { |
| | | |
| | | $fp = $conn->fp; |
| | | $result = false; |
| | | |
| | | switch ($encoding) { |
| | | case 'base64': |
| | | $mode = 1; |
| | | break; |
| | | case 'quoted-printable': |
| | | $mode = 2; |
| | | break; |
| | | case 'x-uuencode': |
| | | case 'x-uue': |
| | | case 'uue': |
| | | case 'uuencode': |
| | | $mode = 3; |
| | | break; |
| | | default: |
| | | $mode = 0; |
| | | } |
| | | |
| | | if (iil_C_Select($conn, $mailbox)) { |
| | | $reply_key = '* ' . $id; |
| | | |
| | | // format request |
| | | $key = 'ftch' . ($c++) . ' '; |
| | | $request = $key . "FETCH $id (BODY.PEEK[$part])"; |
| | | $key = 'ftch0'; |
| | | $request = $key . ($is_uid ? ' UID' : '') . " FETCH $id (BODY.PEEK[$part])"; |
| | | // send request |
| | | if (!iil_PutLine($fp, $request)) { |
| | | return false; |
| | | } |
| | | |
| | | |
| | | // receive reply line |
| | | do { |
| | | $line = chop(iil_ReadLine($fp, 1000)); |
| | |
| | | $len = $to - $from; |
| | | $result = substr($line, $from, $len); |
| | | } |
| | | |
| | | if ($mode == 2) { |
| | | echo $result; |
| | | } else if ($mode == 3) { |
| | | if ($file) |
| | | fwrite($file, base64_decode($result)); |
| | | else |
| | | echo base64_decode($result); |
| | | } |
| | | |
| | | if ($mode == 1) |
| | | $result = base64_decode($result); |
| | | else if ($mode == 2) |
| | | $result = quoted_printable_decode($result); |
| | | else if ($mode == 3) |
| | | $result = convert_uudecode($result); |
| | | |
| | | } else if ($line[$len-1] == '}') { |
| | | //multi-line request, find sizes of content and receive that many bytes |
| | | $from = strpos($line, '{') + 1; |
| | |
| | | |
| | | if ($len > $bytes) { |
| | | $line = substr($line, 0, $bytes); |
| | | $len = strlen($line); |
| | | } |
| | | $bytes -= strlen($line); |
| | | |
| | | $line = rtrim($line, "\t\r\n\0\x0B"); |
| | | $bytes -= $len; |
| | | |
| | | if ($mode == 1) { |
| | | if ($file) |
| | | fwrite($file, $line . "\n"); |
| | | else |
| | | $result .= $line . "\n"; |
| | | } else if ($mode == 2) { |
| | | echo $line . "\n"; |
| | | } else if ($mode == 3) { |
| | | $line = rtrim($line, "\t\r\n\0\x0B"); |
| | | // create chunks with proper length for base64 decoding |
| | | $line = $prev.$line; |
| | | $length = strlen($line); |
| | |
| | | } |
| | | else |
| | | $prev = ''; |
| | | |
| | | |
| | | if ($file) |
| | | fwrite($file, base64_decode($line)); |
| | | else |
| | | else if ($print) |
| | | echo base64_decode($line); |
| | | else |
| | | $result .= base64_decode($line); |
| | | } else if ($mode == 2) { |
| | | $line = rtrim($line, "\t\r\0\x0B"); |
| | | if ($file) |
| | | fwrite($file, quoted_printable_decode($line)); |
| | | else if ($print) |
| | | echo quoted_printable_decode($line); |
| | | else |
| | | $result .= quoted_printable_decode($line); |
| | | } else if ($mode == 3) { |
| | | $line = rtrim($line, "\t\r\n\0\x0B"); |
| | | if ($line == 'end' || preg_match('/^begin\s+[0-7]+\s+.+$/', $line)) |
| | | continue; |
| | | if ($file) |
| | | fwrite($file, convert_uudecode($line)); |
| | | else if ($print) |
| | | echo convert_uudecode($line); |
| | | else |
| | | $result .= convert_uudecode($line); |
| | | } else { |
| | | $line = rtrim($line, "\t\r\n\0\x0B"); |
| | | if ($file) |
| | | fwrite($file, $line . "\n"); |
| | | else if ($print) |
| | | echo $line . "\n"; |
| | | else |
| | | $result .= $line . "\n"; |
| | | } |
| | | } |
| | | } |
| | |
| | | do { |
| | | $line = iil_ReadLine($fp, 1024); |
| | | } while (!iil_StartsWith($line, $key, true)); |
| | | |
| | | if ($mode == 3 && $file) { |
| | | return true; |
| | | } |
| | | |
| | | |
| | | if ($result) { |
| | | $result = rtrim($result, "\t\r\n\0\x0B"); |
| | | if ($file) { |
| | | fwrite($file, $result); |
| | | return true; |
| | | } |
| | | return $result; // substr($result, 0, strlen($result)-1); |
| | | } |
| | | |
| | | return false; |
| | | } |
| | | |
| | | if ($mode==1) { |
| | | if ($file && $result) { |
| | | fwrite($file, $result); |
| | | } else if ($print) { |
| | | echo $result; |
| | | } else |
| | | return $result; |
| | | |
| | | return true; |
| | | } |
| | | return $result; |
| | | } |
| | | } |
| | | |
| | | |
| | | return false; |
| | | } |
| | | |
| | | function iil_C_FetchPartBody(&$conn, $mailbox, $id, $part, $file=NULL) { |
| | | return iil_C_HandlePartBody($conn, $mailbox, $id, $part, 1, $file); |
| | | } |
| | | |
| | | function iil_C_PrintPartBody(&$conn, $mailbox, $id, $part) { |
| | | iil_C_HandlePartBody($conn, $mailbox, $id, $part, 2); |
| | | } |
| | | |
| | | function iil_C_PrintBase64Body(&$conn, $mailbox, $id, $part) { |
| | | iil_C_HandlePartBody($conn, $mailbox, $id, $part, 3); |
| | | } |
| | | |
| | | function iil_C_CreateFolder(&$conn, $folder) { |
| | |
| | | if (iil_PutLine($fp, 'c CREATE "' . iil_Escape($folder) . '"')) { |
| | | do { |
| | | $line=iil_ReadLine($fp, 300); |
| | | } while ($line[0] != 'c'); |
| | | $conn->error = $line; |
| | | } while (!iil_StartsWith($line, 'c ', true)); |
| | | return (iil_ParseResult($line) == 0); |
| | | } |
| | | return false; |
| | |
| | | if (iil_PutLine($fp, 'r RENAME "' . iil_Escape($from) . '" "' . iil_Escape($to) . '"')) { |
| | | do { |
| | | $line = iil_ReadLine($fp, 300); |
| | | } while ($line[0] != 'r'); |
| | | } while (!iil_StartsWith($line, 'r ', true)); |
| | | return (iil_ParseResult($line) == 0); |
| | | } |
| | | return false; |
| | |
| | | if (iil_PutLine($fp, 'd DELETE "' . iil_Escape($folder). '"')) { |
| | | do { |
| | | $line=iil_ReadLine($fp, 300); |
| | | } while ($line[0] != 'd'); |
| | | } while (!iil_StartsWith($line, 'd ', true)); |
| | | 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; |
| | | return false; |
| | | } |
| | | $fp = $conn->fp; |
| | | |
| | | $message = str_replace("\r", '', $message); |
| | | $message = str_replace("\n", "\r\n", $message); |
| | | $message = str_replace("\n", "\r\n", $message); |
| | | |
| | | $len = strlen($message); |
| | | if (!$len) { |
| | | return false; |
| | | return false; |
| | | } |
| | | |
| | | $request = 'A APPEND "' . iil_Escape($folder) .'" (\\Seen) {' . $len . '}'; |
| | | |
| | | $request = 'a APPEND "' . iil_Escape($folder) .'" (\\Seen) {' . $len . '}'; |
| | | |
| | | if (iil_PutLine($fp, $request)) { |
| | | $line=iil_ReadLine($fp, 100); |
| | | $sent = fwrite($fp, $message."\r\n"); |
| | | $line = iil_ReadLine($fp, 512); |
| | | |
| | | if ($line[0] != '+') { |
| | | // $errornum = iil_ParseResult($line); |
| | | $conn->error .= "Cannot write to folder: $line\n"; |
| | | return false; |
| | | } |
| | | |
| | | iil_PutLine($fp, $message); |
| | | |
| | | do { |
| | | $line=iil_ReadLine($fp, 1000); |
| | | } while ($line[0] != 'A'); |
| | | $line = iil_ReadLine($fp); |
| | | } while (!iil_StartsWith($line, 'a ', true)); |
| | | |
| | | $result = (iil_ParseResult($line) == 0); |
| | | if (!$result) { |
| | | $conn->error .= $line . "\n"; |
| | | } |
| | | } |
| | | return $result; |
| | | } |
| | | |
| | |
| | | return false; |
| | | } |
| | | |
| | | function iil_C_AppendFromFile(&$conn, $folder, $path) { |
| | | function iil_C_AppendFromFile(&$conn, $folder, $path, $headers=null, $separator="\n\n") { |
| | | if (!$folder) { |
| | | return false; |
| | | } |
| | | |
| | | //open message file |
| | | $in_fp = false; |
| | | $in_fp = false; |
| | | if (file_exists(realpath($path))) { |
| | | $in_fp = fopen($path, 'r'); |
| | | } |
| | |
| | | if (!$len) { |
| | | return false; |
| | | } |
| | | |
| | | |
| | | if ($headers) { |
| | | $headers = preg_replace('/[\r\n]+$/', '', $headers); |
| | | $len += strlen($headers) + strlen($separator); |
| | | } |
| | | |
| | | //send APPEND command |
| | | $request = 'A APPEND "' . iil_Escape($folder) . '" (\\Seen) {' . $len . '}'; |
| | | $bytes_sent = 0; |
| | | $request = 'a APPEND "' . iil_Escape($folder) . '" (\\Seen) {' . $len . '}'; |
| | | if (iil_PutLine($fp, $request)) { |
| | | $line = iil_ReadLine($fp, 100); |
| | | |
| | | //send file |
| | | $line = iil_ReadLine($fp, 512); |
| | | |
| | | if ($line[0] != '+') { |
| | | //$errornum = iil_ParseResult($line); |
| | | $conn->error .= "Cannot write to folder: $line\n"; |
| | | return false; |
| | | } |
| | | |
| | | // send headers with body separator |
| | | if ($headers) { |
| | | iil_PutLine($fp, $headers . $separator, false); |
| | | } |
| | | |
| | | // send file |
| | | while (!feof($in_fp)) { |
| | | $buffer = fgets($in_fp, 4096); |
| | | $bytes_sent += strlen($buffer); |
| | | $buffer = fgets($in_fp, 4096); |
| | | iil_PutLine($fp, $buffer, false); |
| | | } |
| | | fclose($in_fp); |
| | | |
| | | iil_PutLine($fp, ''); |
| | | iil_PutLine($fp, ''); // \r\n |
| | | |
| | | //read response |
| | | // read response |
| | | do { |
| | | $line = iil_ReadLine($fp, 1000); |
| | | } while ($line[0] != 'A'); |
| | | |
| | | $line = iil_ReadLine($fp); |
| | | } while (!iil_StartsWith($line, 'a ', true)); |
| | | |
| | | $result = (iil_ParseResult($line) == 0); |
| | | if (!$result) { |
| | | $conn->error .= $line . "\n"; |
| | | } |
| | | |
| | | |
| | | return $result; |
| | | } |
| | | |
| | |
| | | return false; |
| | | } |
| | | |
| | | function iil_C_FetchStructureString(&$conn, $folder, $id) { |
| | | function iil_C_FetchStructureString(&$conn, $folder, $id, $is_uid=false) { |
| | | $fp = $conn->fp; |
| | | $result = false; |
| | | |
| | | if (iil_C_Select($conn, $folder)) { |
| | | $key = 'F1247'; |
| | | |
| | | if (iil_PutLine($fp, "$key FETCH $id (BODYSTRUCTURE)")) { |
| | | if (iil_PutLine($fp, $key . ($is_uid ? ' UID' : '') ." FETCH $id (BODYSTRUCTURE)")) { |
| | | do { |
| | | $line = iil_ReadLine($fp, 5000); |
| | | $line = iil_MultLine($fp, $line); |
| | | list(, $index, $cmd, $rest) = explode(' ', $line); |
| | | if ($cmd != 'FETCH' || $index == $id || preg_match("/^$key/", $line)) |
| | | $line = iil_MultLine($fp, $line, true); |
| | | if (!preg_match("/^$key/", $line)) |
| | | $result .= $line; |
| | | } while (!preg_match("/^$key/", $line)); |
| | | } while (!iil_StartsWith($line, $key, true)); |
| | | |
| | | $result = trim(substr($result, strpos($result, 'BODYSTRUCTURE')+13, -(strlen($result)-strrpos($result, $key)+1))); |
| | | $result = trim(substr($result, strpos($result, 'BODYSTRUCTURE')+13, -1)); |
| | | } |
| | | } |
| | | return $result; |
| | | } |
| | | |
| | | function iil_C_PrintSource(&$conn, $folder, $id, $part) { |
| | | $header = iil_C_FetchPartHeader($conn, $folder, $id, $part); |
| | | //echo str_replace("\r", '', $header); |
| | | echo $header; |
| | | echo iil_C_PrintPartBody($conn, $folder, $id, $part); |
| | | } |
| | | |
| | | function iil_C_GetQuota(&$conn) { |