You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
roundcubemail/program/lib/imap.inc

2635 lines
66 KiB
PHTML

19 years ago
<?php
/////////////////////////////////////////////////////////
//
// Iloha IMAP Library (IIL)
//
// (C)Copyright 2002 Ryo Chijiiwa <Ryo@IlohaMail.org>
//
// This file is part of IlohaMail. IlohaMail is free software released
// under the GPL license. See enclosed file COPYING for details, or
// see http://www.fsf.org/copyleft/gpl.html
//
/////////////////////////////////////////////////////////
/********************************************************
FILE: include/imap.inc
PURPOSE:
Provide alternative IMAP library that doesn't rely on the standard
C-Client based version. This allows IlohaMail to function regardless
of whether or not the PHP build it's running on has IMAP functionality
built-in.
USEAGE:
Function containing "_C_" in name require connection handler to be
passed as one of the parameters. To obtain connection handler, use
iil_Connect()
VERSION:
IlohaMail-0.9-20050415
CHANGES:
File altered by Thomas Bruederli <roundcube@gmail.com>
to fit enhanced equirements by the RoundCube Webmail:
- Added list of server capabilites and check these before invoking commands
- Added junk flag to iilBasicHeader
- Enhanced error reporting on fsockopen()
- Additional parameter for SORT command
- Removed Call-time pass-by-reference because deprecated
- Parse charset from content-type in iil_C_FetchHeaders()
- Enhanced heaer sorting
- Pass message as reference in iil_C_Append (to save memory)
- Added BCC and REFERENCE to the list of headers to fetch in iil_C_FetchHeaders()
- Leave messageID unchanged in iil_C_FetchHeaders()
- Avoid stripslahes in iil_Connect()
- Escape quotes and backslashes in iil_C_Login()
- Added patch to iil_SortHeaders() by Richard Green
- Removed <br> from error messages (better for logging)
- Added patch to iil_C_Sort() enabling UID SORT commands
- Added function iil_C_ID2UID()
- Casting date parts in iil_StrToTime() to avoid mktime() warnings
- Also acceppt LIST responses in iil_C_ListSubscribed()
- Sanity check of $message_set in iil_C_FetchHeaders(), iil_C_FetchHeaderIndex(), iil_C_FetchThreadHeaders()
- Implemented UID FETCH in iil_C_FetchHeaders()
- Abort do-loop on socket errors (fgets returns false)
- $ICL_SSL is not boolean anymore but contains the connection schema (ssl or tls)
- Removed some debuggers (echo ...)
File altered by Aleksander Machniak <alec@alec.pl>
17 years ago
- RFC3501 [7.1] don't call CAPABILITY if was returned in server
optional resposne in iil_Connect()
- trim(chop()) replaced by trim()
- added iil_Escape() with support for " and \ in folder names
- support \ character in username in iil_C_Login()
- fixed iil_MultLine(): use iil_ReadBytes() instead of iil_ReadLine()
- fixed iil_C_FetchStructureString() to handle many literal strings in response
- removed hardcoded data size in iil_ReadLine()
- added iil_PutLine() wrapper for fputs()
- code cleanup and identation fixes
19 years ago
********************************************************/
/**
* @todo Possibly clean up more CS.
17 years ago
* @todo Try to replace most double-quotes with single-quotes.
* @todo Split this file into smaller files.
* @todo Refactor code.
* @todo Replace echo-debugging (make it adhere to config setting and log)
*/
19 years ago
// changed path to work within roundcube webmail
17 years ago
include_once 'lib/icl_commons.inc';
19 years ago
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');
19 years ago
$iil_error;
$iil_errornum;
$iil_selected;
/**
* @todo Change class vars to public/private
*/
class iilConnection
{
19 years ago
var $fp;
var $error;
var $errorNum;
var $selected;
var $message;
var $host;
var $cache;
var $uid_cache;
var $do_cache;
var $exists;
var $recent;
var $rootdir;
var $delimiter;
var $capability = array();
19 years ago
}
/**
* @todo Change class vars to public/private
*/
class iilBasicHeader
{
19 years ago
var $id;
var $uid;
var $subject;
var $from;
var $to;
var $cc;
var $replyto;
var $in_reply_to;
var $date;
var $messageID;
var $size;
var $encoding;
var $charset;
19 years ago
var $ctype;
var $flags;
var $timestamp;
var $f;
var $internaldate;
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;
19 years ago
}
/**
* @todo Change class vars to public/private
*/
class iilThreadHeader
{
19 years ago
var $id;
var $sbj;
var $irt;
var $mid;
}
function iil_xor($string, $string2) {
$result = '';
$size = strlen($string);
for ($i=0; $i<$size; $i++) {
$result .= chr(ord($string[$i]) ^ ord($string2[$i]));
}
return $result;
}
function iil_PutLine($fp, $string, $endln=true) {
// console('C: '. $string);
return fputs($fp, $string . ($endln ? "\r\n" : ''));
19 years ago
}
function iil_ReadLine($fp, $size) {
$line = '';
if (!$fp) {
return $line;
}
if (!$size) {
$size = 1024;
}
do {
$buffer = fgets($fp, $size);
if ($buffer === false) {
break;
}
// console('S: '. chop($buffer));
$line .= $buffer;
} while ($buffer[strlen($buffer)-1] != "\n");
return $line;
19 years ago
}
function iil_MultLine($fp, $line) {
19 years ago
$line = chop($line);
if (ereg('\{[0-9]+\}$', $line)) {
$out = '';
19 years ago
preg_match_all('/(.*)\{([0-9]+)\}$/', $line, $a);
$bytes = $a[2][0];
while (strlen($out) < $bytes) {
$line = iil_ReadBytes($fp, $bytes);
$out .= $line;
19 years ago
}
$line = $a[1][0] . "\"$out\"";
// console('[...] '. $out);
19 years ago
}
return $line;
}
function iil_ReadBytes($fp, $bytes) {
$data = '';
$len = 0;
do {
$data .= fread($fp, $bytes-$len);
if ($len == strlen($data)) {
break; //nothing was read -> exit to avoid apache lockups
}
$len = strlen($data);
} while ($len < $bytes);
return $data;
19 years ago
}
function iil_ReadReply($fp) {
do {
$line = trim(iil_ReadLine($fp, 1024));
} while ($line[0] == '*');
19 years ago
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;
}
}
return -3;
19 years ago
}
// check if $string starts with $match
function iil_StartsWith($string, $match) {
19 years ago
$len = strlen($match);
if ($len == 0) {
return false;
}
if (strncmp($string, $match, $len) == 0) {
return true;
}
return false;
19 years ago
}
function iil_StartsWithI($string, $match) {
19 years ago
$len = strlen($match);
if ($len == 0) {
return false;
}
if (strncasecmp($string, $match, $len) == 0) {
return true;
}
return false;
19 years ago
}
function iil_Escape($string)
{
return strtr($string, array('"'=>'\\"', '\\' => '\\\\'));
}
function iil_C_Authenticate(&$conn, $user, $pass, $encChallenge) {
$ipad = '';
$opad = '';
19 years ago
// initialize ipad, opad
for ($i=0;$i<64;$i++) {
17 years ago
$ipad .= chr(0x36);
$opad .= chr(0x5C);
19 years ago
}
19 years ago
// pad $pass so it's 64 bytes
$padLen = 64 - strlen($pass);
for ($i=0;$i<$padLen;$i++) {
$pass .= chr(0);
}
19 years ago
// generate hash
$hash = iil_xor($pass,$opad);
17 years ago
$hash .= pack("H*", md5(iil_xor($pass, $ipad) . base64_decode($encChallenge)));
$hash = md5($hash);
19 years ago
// generate reply
$reply = base64_encode('"' . $user . '" "' . $hash . '"');
19 years ago
// send result, get reply
iil_PutLine($conn->fp, $reply);
19 years ago
$line = iil_ReadLine($conn->fp, 1024);
// process result
if (iil_ParseResult($line) == 0) {
$conn->error .= '';
$conn->errorNum = 0;
19 years ago
return $conn->fp;
}
$conn->error .= 'Authentication for ' . $user . ' failed (AUTH): "';
$conn->error .= htmlspecialchars($line) . '"';
$conn->errorNum = -2;
return false;
19 years ago
}
function iil_C_Login(&$conn, $user, $password) {
19 years ago
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 "));
$a = explode(' ', $line);
if (strcmp($a[1], 'OK') == 0) {
$result = $conn->fp;
$conn->error .= '';
$conn->errorNum = 0;
return $result;
19 years ago
}
$result = false;
fclose($conn->fp);
$conn->error .= 'Authentication for ' . $user . ' failed (LOGIN): "';
$conn->error .= htmlspecialchars($line)."\"";
$conn->errorNum = -2;
19 years ago
return $result;
}
function iil_ParseNamespace2($str, &$i, $len=0, $l) {
if (!$l) {
$str = str_replace('NIL', '()', $str);
}
if (!$len) {
$len = strlen($str);
}
$data = array();
19 years ago
$in_quotes = false;
$elem = 0;
for ($i;$i<$len;$i++) {
19 years ago
$c = (string)$str[$i];
if ($c == '(' && !$in_quotes) {
19 years ago
$i++;
$data[$elem] = iil_ParseNamespace2($str, $i, $len, $l++);
$elem++;
} else if ($c == ')' && !$in_quotes) {
return $data;
} else if ($c == '\\') {
19 years ago
$i++;
if ($in_quotes) {
$data[$elem] .= $c.$str[$i];
}
} else if ($c == '"') {
19 years ago
$in_quotes = !$in_quotes;
if (!$in_quotes) {
$elem++;
}
} else if ($in_quotes) {
19 years ago
$data[$elem].=$c;
}
}
return $data;
}
function iil_C_NameSpace(&$conn) {
19 years ago
global $my_prefs;
if (!in_array('NAMESPACE', $conn->capability)) {
return false;
}
if ($my_prefs["rootdir"]) {
return true;
}
iil_PutLine($conn->fp, "ns1 NAMESPACE");
do {
19 years ago
$line = iil_ReadLine($conn->fp, 1024);
if (iil_StartsWith($line, '* NAMESPACE')) {
$i = 0;
19 years ago
$data = iil_ParseNamespace2(substr($line,11), $i, 0, 0);
}
} while (!iil_StartsWith($line, "ns1"));
19 years ago
if (!is_array($data)) {
return false;
}
19 years ago
$user_space_data = $data[0];
if (!is_array($user_space_data)) {
return false;
}
19 years ago
$first_userspace = $user_space_data[0];
if (count($first_userspace)!=2) {
return false;
}
$conn->rootdir = $first_userspace[0];
$conn->delimiter = $first_userspace[1];
19 years ago
$my_prefs["rootdir"] = substr($conn->rootdir, 0, -1);
return true;
}
function iil_Connect($host, $user, $password) {
global $iil_error, $iil_errornum;
19 years ago
global $ICL_SSL, $ICL_PORT;
global $IMAP_NO_CACHE;
global $my_prefs, $IMAP_USE_INTERNAL_DATE;
$iil_error = '';
19 years ago
$iil_errornum = 0;
//strip slashes
// $user = stripslashes($user);
// $password = stripslashes($password);
19 years ago
//set auth method
$auth_method = 'plain';
if (func_num_args() >= 4) {
19 years ago
$auth_array = func_get_arg(3);
if (is_array($auth_array)) {
$auth_method = $auth_array['imap'];
}
if (empty($auth_method)) {
$auth_method = "plain";
}
19 years ago
}
$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);
19 years ago
$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;
}
19 years ago
//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;
}
19 years ago
//check for SSL
if ($ICL_SSL) {
17 years ago
$host = $ICL_SSL . '://' . $host;
19 years ago
}
//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";
$iil_errornum = -1;
19 years ago
return false;
}
$iil_error .= "Socket connection established\r\n";
$line = iil_ReadLine($conn->fp, 1024);
// RFC3501 [7.1] optional CAPABILITY response
// commented out, because it's not working always as should
// if (preg_match('/\[CAPABILITY ([^]]+)\]/i', $line, $matches)) {
// $conn->capability = explode(' ', $matches[1]);
// } else {
iil_PutLine($conn->fp, "cp01 CAPABILITY");
do {
$line = trim(iil_ReadLine($conn->fp, 1024));
17 years ago
$conn->message .= "$line\n";
17 years ago
$a = explode(' ', $line);
17 years ago
if ($line[0] == '*') {
while (list($k, $w) = each($a)) {
if ($w != '*' && $w != 'CAPABILITY')
$conn->capability[] = $w;
19 years ago
}
}
17 years ago
} while ($a[0] != 'cp01');
// }
19 years ago
if (strcasecmp($auth_method, "check") == 0) {
//check for supported auth methods
//default to plain text auth
$auth_method = 'plain';
//check for CRAM-MD5
foreach ($conn->capability as $c)
if (strcasecmp($c, 'AUTH=CRAM_MD5') == 0 ||
strcasecmp($c, 'AUTH=CRAM-MD5') == 0) {
$auth_method = 'auth';
break;
}
}
17 years ago
if (strcasecmp($auth_method, 'auth') == 0) {
$conn->message .= "Trying CRAM-MD5\n";
17 years ago
19 years ago
//do CRAM-MD5 authentication
iil_PutLine($conn->fp, "a000 AUTHENTICATE CRAM-MD5");
$line = trim(iil_ReadLine($conn->fp, 1024));
17 years ago
$conn->message .= "$line\n";
17 years ago
if ($line[0] == '+') {
$conn->message .= 'Got challenge: ' . htmlspecialchars($line) . "\n";
19 years ago
//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';
19 years ago
}
}
if ((!$result)||(strcasecmp($auth, "plain") == 0)) {
19 years ago
//do plain text auth
$result = iil_C_Login($conn, $user, $password);
$conn->message.="Tried PLAIN: $result \n";
}
$conn->message .= $auth;
if ($result) {
19 years ago
iil_C_Namespace($conn);
return $conn;
} else {
19 years ago
$iil_error = $conn->error;
$iil_errornum = $conn->errorNum;
return false;
}
}
function iil_Close(&$conn) {
19 years ago
iil_C_WriteCache($conn);
if (iil_PutLine($conn->fp, "I LOGOUT")) {
19 years ago
fgets($conn->fp, 1024);
fclose($conn->fp);
$conn->fp = false;
}
}
function iil_ClearCache($user, $host) {
19 years ago
}
function iil_C_WriteCache(&$conn) {
19 years ago
//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]) {
19 years ago
$key = $folder.".imap";
$result = cache_write($conn->user, $conn->host, $key, $data, true);
//echo "<!-- writing $key $data: $result //-->\n";
}
}
}
}
function iil_C_EnableCache(&$conn) {
19 years ago
$conn->do_cache = true;
}
function iil_C_DisableCache(&$conn) {
19 years ago
$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);
19 years ago
$conn->cache_dirty[$folder] = false;
}
}
function iil_C_ExpireCachedItems(&$conn, $folder, $message_set) {
19 years ago
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');
19 years ago
$num_removed = 0;
if (is_array($uids)) {
19 years ago
//echo "<!-- unsetting: ".implode(",",$uids)." //-->\n";
while (list($n,$uid)=each($uids)) {
19 years ago
unset($conn->cache[$folder][$uid]);
//$conn->cache[$folder][$uid] = false;
//$num_removed++;
}
$conn->cache_dirty[$folder] = true;
//echo '<!--'."\n";
//print_r($conn->cache);
//echo "\n".'//-->'."\n";
} else {
19 years ago
echo "<!-- failed to get uids: $message_set //-->\n";
}
/*
if ($num_removed>0) {
19 years ago
$new_cache;
reset($conn->cache[$folder]);
while (list($uid,$item)=each($conn->cache[$folder])) {
19 years ago
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) {
19 years ago
$quotes[$key] = str_replace($delimiter, "_!@!_", $quotes[$key]);
}
}
$string=implode('"', $quotes);
19 years ago
$result=explode($delimiter, $string);
while ( list($key, $val) = each($result) ) {
$result[$key] = str_replace('_!@!_', $delimiter, $result[$key]);
}
19 years ago
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) {
iil_PutLine($fp, "a002 EXAMINE \"".iil_Escape($mailbox)."\"");
do {
19 years ago
$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'));
19 years ago
iil_PutLine($fp, "a003 LOGOUT");
19 years ago
fclose($fp);
} else {
$result = -2;
}
19 years ago
return $result;
}
function iil_C_Select(&$conn, $mailbox) {
if (empty($mailbox)) {
return false;
}
if (strcmp($conn->selected, $mailbox) == 0) {
return true;
}
19 years ago
iil_C_LoadCache($conn, $mailbox);
if (iil_PutLine($conn->fp, "sel1 SELECT \"".iil_Escape($mailbox).'"')) {
do {
$line = chop(iil_ReadLine($conn->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];
}
19 years ago
}
} while (!iil_StartsWith($line, 'sel1'));
19 years ago
$a = explode(' ', $line);
19 years ago
if (strcasecmp($a[1], 'OK') == 0) {
19 years ago
$conn->selected = $mailbox;
return true;
}
19 years ago
}
return false;
19 years ago
}
function iil_C_CheckForRecent(&$conn, $mailbox) {
if (empty($mailbox)) {
$mailbox = 'INBOX';
}
19 years ago
iil_C_Select($conn, $mailbox);
if ($conn->selected == $mailbox) {
return $conn->recent;
}
return false;
19 years ago
}
function iil_C_CountMessages(&$conn, $mailbox, $refresh = false) {
if ($refresh) {
$conn->selected= '';
}
19 years ago
iil_C_Select($conn, $mailbox);
if ($conn->selected == $mailbox) {
return $conn->exists;
}
return false;
19 years ago
}
function iil_SplitHeaderLine($string) {
$pos=strpos($string, ':');
if ($pos>0) {
$res[0] = substr($string, 0, $pos);
$res[1] = trim(substr($string, $pos+1));
19 years ago
return $res;
}
return $string;
19 years ago
}
function iil_StrToTime($str) {
$IMAP_MONTHS = $GLOBALS['IMAP_MONTHS'];
$IMAP_SERVER_TZ = $GLOBALS['IMAP_SERVER_TR'];
19 years ago
if ($str) {
$time1 = strtotime($str);
}
if ($time1 && $time1 != -1) {
return $time1-$IMAP_SERVER_TZ;
}
19 years ago
//echo '<!--'.$str.'//-->';
//replace double spaces with single space
$str = trim($str);
$str = str_replace(' ', ' ', $str);
19 years ago
//strip off day of week
$pos = strpos($str, ' ');
if (!is_numeric(substr($str, 0, $pos))) {
$str = substr($str, $pos+1);
}
19 years ago
//explode, take good parts
17 years ago
$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];
19 years ago
//make UNIX timestamp
$time2 = mktime($hour, $minute, $second, $month, $day, $year);
//echo '<!--'.$time1.' '.$time2.' //-->'."\n";
return $time2;
}
function iil_C_Sort(&$conn, $mailbox, $field, $add='', $is_uid=FALSE,
$encoding = 'US-ASCII') {
19 years ago
/* Do "SELECT" command */
if (!iil_C_Select($conn, $mailbox)) {
return false;
}
19 years ago
$field = strtoupper($field);
if ($field == 'INTERNALDATE') {
$field = 'ARRIVAL';
}
17 years ago
$fields = array('ARRIVAL' => 1,'CC' => 1,'DATE' => 1,
'FROM' => 1, 'SIZE' => 1, 'SUBJECT' => 1, 'TO' => 1);
if (!$fields[$field]) {
return false;
}
$is_uid = $is_uid ? 'UID ' : '';
19 years ago
if (!empty($add)) {
$add = " $add";
}
17 years ago
$fp = $conn->fp;
$command = 's ' . $is_uid . 'SORT (' . $field . ') ';
$command .= $encoding . ' ALL' . $add;
17 years ago
$line = $data = '';
19 years ago
if (!iil_PutLine($fp, $command)) {
return false;
}
do {
19 years ago
$line = chop(iil_ReadLine($fp, 1024));
if (iil_StartsWith($line, '* SORT')) {
$data .= ($data?' ':'') . substr($line, 7);
}
} while ($line[0]!='s');
19 years ago
if (empty($data)) {
19 years ago
$conn->error = $line;
return false;
}
$out = explode(' ',$data);
return $out;
}
function iil_C_FetchHeaderIndex(&$conn, $mailbox, $message_set, $index_field,
$normalize=true) {
19 years ago
global $IMAP_USE_INTERNAL_DATE;
$c=0;
$result=array();
$fp = $conn->fp;
if (empty($index_field)) {
$index_field = 'DATE';
}
19 years ago
$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)) {
return false;
}
19 years ago
//$fields_a['DATE'] = ($IMAP_USE_INTERNAL_DATE?6:1);
$fields_a['DATE'] = 1;
19 years ago
$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;
19 years ago
$mode=$fields_a[$index_field];
if (!($mode > 0)) {
return false;
}
19 years ago
/* Do "SELECT" command */
if (!iil_C_Select($conn, $mailbox)) {
return false;
}
19 years ago
/* 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 {
19 years ago
$line=chop(iil_ReadLine($fp, 200));
$a=explode(' ', $line);
if (($line[0] == '*') && ($a[2] == 'FETCH')
&& ($line[strlen($line)-1] != ')')) {
19 years ago
$id=$a[1];
$str=$line=chop(iil_ReadLine($fp, 300));
while ($line[0] != ')') { //caution, this line works only in this particular case
19 years ago
$line=chop(iil_ReadLine($fp, 300));
if ($line[0] != ')') {
if (ord($line[0]) <= 32) { //continuation from previous header line
$str.= ' ' . trim($line);
19 years ago
}
if ((ord($line[0]) > 32) || (strlen($line[0]) == 0)) {
19 years ago
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]);
}
19 years ago
}
$str=$line;
}
}
}
}
/*
$end_pos = strlen($line)-1;
if (($line[0]=="*") && ($a[2]=="FETCH") && ($line[$end_pos]=="}")) {
19 years ago
$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);
19 years ago
if ($received>$bytes) {
break;
} else if (!$line) {
continue;
}
list($field, $string) = explode(': ', $line);
19 years ago
if (strcasecmp($field, 'date') == 0) {
19 years ago
$result[$id] = iil_StrToTime($string);
} else if ($index_field != 'DATE') {
$result[$id]=strtoupper(str_replace('"', '', $string));
}
} while ($line[0] != ')');
} else {
19 years ago
//one line response, not expected so ignore
}
*/
} while (!iil_StartsWith($line, $key));
}else if ($mode == 6) {
$key = 'fhi' . ($c++);
$request = $key . " FETCH $message_set (INTERNALDATE)";
if (!iil_PutLine($fp, $request)) {
return false;
}
do {
19 years ago
$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];
19 years ago
$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);
19 years ago
$result[$id] = strtotime($time_str);
}
} else {
$a = explode(' ', $line);
19 years ago
}
} 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;
}
19 years ago
/* FETCH uid, size, flags */
$key = 'fhi' .($c++);
$request = $key . " FETCH $message_set ($field_name)";
19 years ago
if (!iil_PutLine($fp, $request)) {
return false;
}
do {
19 years ago
$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);
19 years ago
$id = $a[1];
19 years ago
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
}
19 years ago
/* 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");
19 years ago
}
}
} while (!iil_StartsWith($line, $key));
19 years ago
}
//check number of elements...
17 years ago
list($start_mid, $end_mid) = explode(':', $message_set);
if (is_numeric($start_mid) && is_numeric($end_mid)) {
19 years ago
//count how many we should have
$should_have = $end_mid - $start_mid +1;
//if we have less, try and fill in the "gaps"
17 years ago
if (count($result) < $should_have) {
for ($i=$start_mid; $i<=$end_mid; $i++) {
if (!isset($result[$i])) {
$result[$i] = '';
}
}
19 years ago
}
}
return $result;
}
function iil_CompressMessageSet($message_set) {
19 years ago
//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;
}
19 years ago
//see if it's already been compress
if (strpos($message_set, ':') !== false) {
return $message_set;
}
19 years ago
//separate, then sort
17 years ago
$ids = explode(',', $message_set);
19 years ago
sort($ids);
$result = array();
17 years ago
$start = $prev = $ids[0];
foreach ($ids as $id) {
19 years ago
$incr = $id - $prev;
17 years ago
if ($incr > 1) { //found a gap
if ($start == $prev) {
$result[] = $prev; //push single id
} else {
17 years ago
$result[] = $start . ':' . $prev; //push sequence as start_id:end_id
}
$start = $id; //start of new sequence
19 years ago
}
$prev = $id;
}
19 years ago
//handle the last sequence/id
if ($start==$prev) {
$result[] = $prev;
} else {
$result[] = $start.':'.$prev;
}
19 years ago
//return as comma separated string
return implode(',', $result);
19 years ago
}
function iil_C_UIDsToMIDs(&$conn, $mailbox, $uids) {
if (!is_array($uids) || count($uids) == 0) {
return array();
}
17 years ago
return iil_C_Search($conn, $mailbox, 'UID ' . implode(',', $uids));
19 years ago
}
function iil_C_UIDToMID(&$conn, $mailbox, $uid) {
19 years ago
$result = iil_C_UIDsToMIDs($conn, $mailbox, array($uid));
17 years ago
if (count($result) == 1) {
return $result[0];
}
return false;
19 years ago
}
function iil_C_FetchUIDs(&$conn,$mailbox) {
19 years ago
global $clock;
$num = iil_C_CountMessages($conn, $mailbox);
if ($num == 0) {
return array();
}
$message_set = '1' . ($num>1?':' . $num:'');
19 years ago
//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';
19 years ago
$cache_good = true;
if ($conn->uid_cache) {
$data = $conn->uid_cache;
} else {
$data = cache_read($conn->user, $conn->host, $key);
}
19 years ago
//was anything cached at all?
if ($data === false) {
$cache_good = -1;
}
19 years ago
//make sure number of messages were the same
17 years ago
if ($cache_good > 0 && $data['n'] != $num) {
$cache_good = -2;
}
19 years ago
//if everything's okay so far...
17 years ago
if ($cache_good > 0) {
19 years ago
//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;
}
19 years ago
}
//if cached data's good, return it
17 years ago
if ($cache_good > 0) {
19 years ago
return $data['d'];
}
//otherwise, we need to fetch it
$data = array('n' => $num, 'd' => array());
19 years ago
$data['d'] = iil_C_FetchHeaderIndex($conn, $mailbox, $message_set, 'UID');
19 years ago
cache_write($conn->user, $conn->host, $key, $data);
$conn->uid_cache = $data;
return $data['d'];
}
function iil_SortThreadHeaders($headers, $index_a, $uids) {
19 years ago
asort($index_a);
$result = array();
foreach ($index_a as $mid=>$foobar) {
19 years ago
$uid = $uids[$mid];
$result[$uid] = $headers[$uid];
}
return $result;
}
function iil_C_FetchThreadHeaders(&$conn, $mailbox, $message_set) {
19 years ago
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)) {
return false;
}
19 years ago
$result = array();
$uids = iil_C_FetchUIDs($conn, $mailbox);
$debug = false;
19 years ago
/* Get cached records where possible */
if ($conn->do_cache) {
19 years ago
$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];
19 years ago
$result[$uid]->id = $id;
} else {
$needed_set .= ($needed_set ? ',' : '') . $id;
}
19 years ago
}
if ($needed_set) {
$message_set = $needed_set;
} else {
$message_set = '';
}
19 years ago
}
}
$message_set = iil_CompressMessageSet($message_set);
if ($debug) {
echo "Still need: ".$message_set;
}
19 years ago
/* if we're missing any, get them */
if ($message_set) {
19 years ago
/* FETCH date,from,subject headers */
$key = 'fh';
$fp = $conn->fp;
$request = $key . " FETCH $message_set ";
$request .= "(BODY.PEEK[HEADER.FIELDS (SUBJECT MESSAGE-ID IN-REPLY-TO)])";
$mid_to_id = array();
if (!iil_PutLine($fp, $request)) {
return false;
}
do {
19 years ago
$line = chop(iil_ReadLine($fp, 1024));
if ($debug) {
echo $line . "\n";
}
if (ereg('\{[0-9]+\}$', $line)) {
$a = explode(' ', $line);
19 years ago
$new = array();
$new_thhd = new iilThreadHeader;
$new_thhd->id = $a[1];
do {
17 years ago
$line = chop(iil_ReadLine($fp, 1024), "\r\n");
if (iil_StartsWithI($line, 'Message-ID:')
|| (iil_StartsWithI($line,'In-Reply-To:'))
|| (iil_StartsWithI($line,'SUBJECT:'))) {
17 years ago
$pos = strpos($line, ':');
19 years ago
$field_name = substr($line, 0, $pos);
17 years ago
$field_val = substr($line, $pos+1);
19 years ago
$new[strtoupper($field_name)] = trim($field_val);
17 years ago
} else if (ereg('^[[:space:]]', $line)) {
17 years ago
$new[strtoupper($field_name)] .= trim($line);
19 years ago
}
} while ($line[0] != ')');
19 years ago
$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'));
19 years ago
}
/* sort headers */
if (is_array($index_a)) {
19 years ago
$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);
}
19 years ago
}
//echo 'iil_FetchThreadHeaders:'."\n";
//print_r($result);
return $result;
}
function iil_C_BuildThreads2(&$conn, $mailbox, $message_set, &$clock) {
19 years ago
global $index_a;
list($from_idx, $to_idx) = explode(':', $message_set);
if (empty($message_set) || (isset($to_idx)
&& (int)$from_idx > (int)$to_idx)) {
return false;
}
$result = array();
$roots = array();
19 years ago
$root_mids = array();
$sub_mids = array();
$strays = array();
$messages = array();
$fp = $conn->fp;
$debug = false;
19 years ago
$sbj_filter_pat = '[a-zA-Z]{2,3}(\[[0-9]*\])?:([[:space:]]*)';
/* Do "SELECT" command */
if (!iil_C_Select($conn, $mailbox)) {
return false;
}
19 years ago
/* 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);
}
19 years ago
/* go through header records */
foreach ($headers as $header) {
19 years ago
//$id = $header['i'];
//$new = array('id'=>$id, 'MESSAGE-ID'=>$header['m'],
// 'IN-REPLY-TO'=>$header['r'], 'SUBJECT'=>$header['s']);
$id = $header->id;
17 years ago
$new = array('id' => $id, 'MESSAGE-ID' => $header->mid,
'IN-REPLY-TO' => $header->irt, 'SUBJECT' => $header->sbj);
19 years ago
/* 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'];
}
19 years ago
/* 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:';
}
19 years ago
/* 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;
19 years ago
/* 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];
19 years ago
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])) {
19 years ago
/* 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";
}
19 years ago
//reply to known message?
$temp = $sub_mids[$new['IN-REPLY-TO']];
if ($temp) {
19 years ago
//found it, root:=parent's root
if ($debug) {
echo "\tfound parent: ".$new['SUBJECT']."\n";
}
$result[$temp][] = $id;
19 years ago
$sub_mids[$new['MESSAGE-ID']] = $temp;
$sbj = '';
} else {
19 years ago
//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;
19 years ago
$sub_mids[$new['MESSAGE-ID']] = $id;
$result[$id] = array($id);
19 years ago
}
if ($debug) {
echo $new['MESSAGE-ID'] . "\t" . $sbj . "\n";
}
19 years ago
}
}
//now that we've gone through all the messages,
//go back and try and link up the stray threads
17 years ago
if (count($strays) > 0) {
foreach ($strays as $id=>$irt) {
19 years ago
$root_id = $sub_mids[$irt];
if (!$root_id || $root_id==$id) {
continue;
}
$result[$root_id] = array_merge($result[$root_id],$result[$id]);
19 years ago
unset($result[$id]);
}
}
if ($clock) {
$clock->register('data prepped');
}
if ($debug) {
print_r($roots);
}
19 years ago
return $result;
}
function iil_SortThreads(&$tree, $index, $sort_order = 'ASC') {
if (!is_array($tree) || !is_array($index)) {
return false;
}
19 years ago
//create an id to position lookup table
$i = 0;
foreach ($index as $id=>$val) {
19 years ago
$i++;
$index[$id] = $i;
}
$max = $i+1;
//for each tree, set array key to position
$itree = array();
foreach ($tree as $id=>$node) {
if (count($tree[$id])<=1) {
19 years ago
//for "threads" with only one message, key is position of that message
$n = $index[$id];
19 years ago
$itree[$n] = array($n=>$id);
} else {
19 years ago
//for "threads" with multiple messages,
$min = $max;
19 years ago
$new_a = array();
foreach ($tree[$id] as $mid) {
19 years ago
$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
}
19 years ago
}
$n = $min; //smallest position of child is thread position
//assign smallest position to root level key
//set children array to one created above
ksort($new_a);
$itree[$n] = $new_a;
}
}
//sort by key, this basically sorts all threads
ksort($itree);
17 years ago
$i = 0;
$out = array();
foreach ($itree as $k=>$node) {
19 years ago
$out[$i] = $itree[$k];
$i++;
}
return $out;
}
function iil_IndexThreads(&$tree) {
19 years ago
/* creates array mapping mid to thread id */
if (!is_array($tree)) {
return false;
}
19 years ago
$t_index = array();
foreach ($tree as $pos=>$kids) {
foreach ($kids as $kid) $t_index[$kid] = $pos;
19 years ago
}
return $t_index;
}
function iil_C_FetchHeaders(&$conn, $mailbox, $message_set, $uidfetch=false)
{
19 years ago
global $IMAP_USE_INTERNAL_DATE;
$c = 0;
$result = array();
$fp = $conn->fp;
19 years ago
list($from_idx, $to_idx) = explode(':', $message_set);
if (empty($message_set) || (isset($to_idx)
&& (int)$from_idx > (int)$to_idx)) {
return false;
}
19 years ago
/* Do "SELECT" command */
if (!iil_C_Select($conn, $mailbox)) {
19 years ago
$conn->error = "Couldn't select $mailbox";
return false;
}
/* Get cached records where possible */
if ($conn->do_cache) {
19 years ago
$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];
19 years ago
$result[$id]->id = $id;
} else {
$needed_set.=($needed_set ? ',': '') . $id;
}
19 years ago
}
//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;
}
19 years ago
}
}
/* FETCH date,from,subject headers */
$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)])";
if (!iil_PutLine($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;
19 years ago
/*
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;
19 years ago
$lines = array();
do {
$line = chop(iil_ReadLine($fp, 300), "\r\n");
if (ord($line[0])<=32) {
$lines[$i] .= (empty($lines[$i])?'':"\n").trim($line);
} else {
19 years ago
$i++;
$lines[$i] = trim($line);
19 years ago
}
/*
The preg_match below works around communigate imap, which outputs " UID <number>)".
Without this, the while statement continues on and gets the "fh0 OK completed" message.
If this loop gets the ending message, then the outer loop does not receive it from radline on line 1249.
This in causes the if statement on line 1278 to never be true, which causes the headers to end up missing
If the if statement was changed to pick up the fh0 from this loop, then it causes the outer loop to spin
An alternative might be:
if (!preg_match("/:/",$line) && preg_match("/\)$/",$line)) break;
however, unsure how well this would work with all imap clients.
*/
if (preg_match("/^\s*UID [0-9]+\)$/", $line)) {
break;
}
// patch from "Maksim Rubis" <siburny@hotmail.com>
} while (trim($line[0]) != ')' && strncmp($line, $key, strlen($key)));
19 years ago
if (strncmp($line, $key, strlen($key))) {
//process header, fill iilBasicHeader obj.
// initialize
if (is_array($headers)) {
reset($headers);
while (list($k, $bar) = each($headers)) {
$headers[$k] = '';
}
}
// create array with header field:data
while ( list($lines_key, $str) = each($lines) ) {
list($field, $string) = iil_SplitHeaderLine($str);
$field = strtolower($field);
$string = ereg_replace("\n[[:space:]]*"," ",$string);
switch ($field) {
case 'date';
$result[$id]->date = $string;
$result[$id]->timestamp = iil_StrToTime($string);
break;
case 'from':
$result[$id]->from = $string;
break;
case 'to':
$result[$id]->to = $string;
break;
case 'subject':
$result[$id]->subject = $string;
break;
case 'reply-to':
$result[$id]->replyto = $string;
break;
case 'cc':
$result[$id]->cc = $string;
break;
case 'bcc':
$result[$id]->bcc = $string;
break;
case 'content-transfer-encoding':
$result[$id]->encoding = $string;
break;
case 'content-type':
$ctype_parts = explode(";", $string);
$result[$id]->ctype = array_shift($ctype_parts);
foreach ($ctype_parts as $ctype_add) {
if (preg_match('/charset="?([a-z0-9\-\.\_]+)"?/i',
$ctype_add, $regs)) {
$result[$id]->charset = $regs[1];
}
}
break;
case 'in-reply-to':
$result[$id]->in_reply_to = ereg_replace("[\n<>]", '', $string);
break;
case 'references':
$result[$id]->references = $string;
break;
case 'return-receipt-to':
case 'disposition-notification-to':
case 'x-confirm-reading-to':
$result[$id]->mdn_to = $string;
break;
case 'message-id':
$result[$id]->messageID = $string;
break;
case 'x-priority':
if (preg_match('/^(\d+)/', $string, $matches))
$result[$id]->priority = intval($matches[1]);
break;
} // end switch ()
} // end while ()
} else {
$a = explode(' ', $line);
}
19 years ago
}
} while (strcmp($a[0], $key) != 0);
19 years ago
/*
FETCH uid, size, flags
Sample reply line: "* 3 FETCH (UID 2417 RFC822.SIZE 2730 FLAGS (\Seen \Deleted))"
*/
$command_key = 'fh' . ($c++);
17 years ago
$request = $command_key . $prefix;
$request .= " FETCH $message_set (UID RFC822.SIZE FLAGS INTERNALDATE)";
if (!iil_PutLine($fp, $request)) {
return false;
}
do {
$line = chop(iil_ReadLine($fp, 200));
//$a = explode(' ', $line);
//if (($line[0]=="*") && ($a[2]=="FETCH")) {
if ($line[0] == '*') {
19 years ago
//echo "<!-- $line //-->\n";
//get outter most parens
$open_pos = strpos($line, "(") + 1;
$close_pos = strrpos($line, ")");
if ($open_pos && $close_pos) {
19 years ago
//extract ID from pre-paren
$pre_str = substr($line, 0, $open_pos);
$pre_a = explode(' ', $line);
19 years ago
$id = $pre_a[1];
//get data
$len = $close_pos - $open_pos;
$str = substr($line, $open_pos, $len);
//swap parents with quotes, then explode
$str = eregi_replace("[()]", "\"", $str);
$a = iil_ExplodeQuotedString(' ', $str);
19 years ago
//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];
19 years ago
}
// process flags
$flags_str = eregi_replace('[\\\"]', '', $flags_str);
17 years ago
$flags_a = explode(' ', $flags_str);
/*
trigger_error("<!-- ID: $id FLAGS: ".implode(",", $flags_a)." //-->\n",
E_USER_WARNING);
*/
19 years ago
if (is_array($flags_a)) {
19 years ago
reset($flags_a);
while (list($key,$val)=each($flags_a)) {
if (strcasecmp($val,'Seen') == 0) {
$result[$id]->seen = true;
} else if (strcasecmp($val, 'Deleted') == 0) {
$result[$id]->deleted=true;
} else if (strcasecmp($val, 'Recent') == 0) {
$result[$id]->recent = true;
} else if (strcasecmp($val, 'Answered') == 0) {
$result[$id]->answered = true;
} else if (strcasecmp($val, "\$MDNSent") == 0) {
$result[$id]->mdn_sent = true;
}
19 years ago
}
$result[$id]->flags = $flags_a;
19 years ago
}
// if time is gmt...
$time_str = str_replace('GMT','+0000',$time_str);
//get timezone
$time_str = substr($time_str, 0, -1);
19 years ago
$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;
19 years ago
if ($IMAP_USE_INTERNAL_DATE || empty($result[$id]->date)) {
19 years ago
//calculate timestamp
$timestamp = strtotime($time_str); //return's server's time
$na_timestamp = $timestamp;
$timestamp -= $time_zone * 3600; //compensate for tz, get GMT
19 years ago
$result[$id]->timestamp = $timestamp;
$result[$id]->date = $time_str;
19 years ago
}
if ($conn->do_cache) {
19 years ago
$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 {
19 years ago
//echo "<!-- ERROR: $id : $str //-->\n";
}
}
}
} while (strpos($line, $command_key) === false);
19 years ago
return $result;
}
function iil_C_FetchHeader(&$conn, $mailbox, $id, $uidfetch=false) {
19 years ago
$fp = $conn->fp;
$a = iil_C_FetchHeaders($conn, $mailbox, $id, $uidfetch);
if (is_array($a)) {
return array_shift($a);
}
return false;
19 years ago
}
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('"');
19 years ago
$c=count($a);
17 years ago
if ($c > 0) {
19 years ago
/*
Strategy:
First, we'll create an "index" array.
Then, we'll use sort() on that array,
and use that to sort the main array.
*/
// create "index" array
$index = array();
19 years ago
reset($a);
while (list($key, $val)=each($a)) {
if ($field == 'timestamp') {
$data = @strtotime($val->date);
if ($data == false) {
$data = $val->timestamp;
}
} else {
$data = $val->$field;
if (is_string($data)) {
$data=strtoupper(str_replace($stripArr, '', $data));
}
}
19 years ago
$index[$key]=$data;
}
// sort index
$i = 0;
if ($flag == 'ASC') {
asort($index);
} else {
arsort($index);
}
19 years ago
// form new array based on index
$result = array();
19 years ago
reset($index);
while (list($key, $val)=each($index)) {
$result[$key]=$a[$key];
19 years ago
$i++;
}
}
return $result;
}
function iil_C_Expunge(&$conn, $mailbox) {
if (iil_C_Select($conn, $mailbox)) {
17 years ago
$c = 0;
iil_PutLine($conn->fp, "exp1 EXPUNGE");
do {
$line=chop(iil_ReadLine($conn->fp, 100));
if ($line[0] == '*') {
$c++;
}
} while (!iil_StartsWith($line, 'exp1'));
19 years ago
if (iil_ParseResult($line) == 0) {
$conn->selected = ''; //state has changed, need to reselect
19 years ago
//$conn->exists-=$c;
return $c;
}
$conn->error = $line;
19 years ago
}
return -1;
}
function iil_C_ModFlag(&$conn, $mailbox, $messages, $flag, $mod) {
if ($mod != '+' && $mod != '-') {
return -1;
}
$fp = $conn->fp;
$flags = array(
'SEEN' => '\\Seen',
'DELETED' => '\\Deleted',
'RECENT' => '\\Recent',
'ANSWERED' => '\\Answered',
'DRAFT' => '\\Draft',
'FLAGGED' => '\\Flagged',
'MDNSENT' => "\$MDNSent");
$flag = strtoupper($flag);
$flag = $flags[$flag];
if (iil_C_Select($conn, $mailbox)) {
17 years ago
$c = 0;
iil_PutLine($fp, "flg STORE $messages " . $mod . "FLAGS (" . $flag . ")");
do {
19 years ago
$line=chop(iil_ReadLine($fp, 100));
if ($line[0] == '*') {
$c++;
}
} while (!iil_StartsWith($line, 'flg'));
if (iil_ParseResult($line) == 0) {
19 years ago
iil_C_ExpireCachedItems($conn, $mailbox, $messages);
return $c;
}
$conn->error = $line;
19 years ago
return -1;
}
$conn->error = 'Select failed';
return -1;
19 years ago
}
function iil_C_Flag(&$conn, $mailbox, $messages, $flag) {
return iil_C_ModFlag($conn, $mailbox, $messages, $flag, '+');
19 years ago
}
function iil_C_Unflag(&$conn, $mailbox, $messages, $flag) {
return iil_C_ModFlag($conn, $mailbox, $messages, $flag, '-');
19 years ago
}
function iil_C_Delete(&$conn, $mailbox, $messages) {
return iil_C_ModFlag($conn, $mailbox, $messages, 'DELETED', '+');
19 years ago
}
function iil_C_Undelete(&$conn, $mailbox, $messages) {
return iil_C_ModFlag($conn, $mailbox, $messages, 'DELETED', '-');
19 years ago
}
function iil_C_Unseen(&$conn, $mailbox, $messages) {
return iil_C_ModFlag($conn, $mailbox, $messages, 'SEEN', '-');
19 years ago
}
function iil_C_Copy(&$conn, $messages, $from, $to) {
19 years ago
$fp = $conn->fp;
if (empty($from) || empty($to)) {
return -1;
}
if (iil_C_Select($conn, $from)) {
19 years ago
$c=0;
iil_PutLine($fp, "cpy1 COPY $messages \"".iil_Escape($to)."\"");
19 years ago
$line=iil_ReadReply($fp);
return iil_ParseResult($line);
} else {
19 years ago
return -1;
}
}
function iil_FormatSearchDate($month, $day, $year) {
$month = (int) $month;
$months = $GLOBALS['IMAP_MONTHS'];
return $day . '-' . $months[$month] . '-' . $year;
19 years ago
}
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;
19 years ago
}
function iil_C_UID2ID(&$conn, $folder, $uid) {
if ($uid > 0) {
19 years ago
$id_a = iil_C_Search($conn, $folder, "UID $uid");
if (is_array($id_a)) {
19 years ago
$count = count($id_a);
if ($count > 1) {
return false;
}
return $id_a[0];
19 years ago
}
}
return false;
}
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)")) {
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) {
19 years ago
$fp = $conn->fp;
if (iil_C_Select($conn, $folder)) {
17 years ago
$c = 0;
19 years ago
$query = 'srch1 SEARCH ' . chop($criteria);
iil_PutLine($fp, $query);
do {
$line=trim(iil_ReadLine($fp, 10000));
if (eregi("^\* SEARCH", $line)) {
19 years ago
$str = trim(substr($line, 8));
$messages = explode(' ', $str);
19 years ago
}
17 years ago
} while (!iil_StartsWith($line, 'srch1'));
19 years ago
17 years ago
$result_code = iil_ParseResult($line);
if ($result_code == 0) {
return $messages;
19 years ago
}
$conn->error = 'iil_C_Search: ' . $line . "\n";
return false;
19 years ago
}
$conn->error = "iil_C_Search: Couldn't select \"$folder\"\n";
return false;
19 years ago
}
function iil_C_Move(&$conn, $messages, $from, $to) {
17 years ago
$fp = $conn->fp;
if (!$from || !$to) {
return -1;
}
$r = iil_C_Copy($conn, $messages, $from,$to);
if ($r==0) {
return iil_C_Delete($conn, $from, $messages);
}
return $r;
19 years ago
}
/**
* 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;
19 years ago
$delimiter = false;
//try (LIST "" ""), should return delimiter (RFC2060 Sec 6.3.8)
if (!iil_PutLine($fp, 'ghd LIST "" ""')) {
return false;
}
do {
19 years ago
$line=iil_ReadLine($fp, 500);
if ($line[0] == '*') {
19 years ago
$line = rtrim($line);
$a=iil_ExplodeQuotedString(' ', $line);
if ($a[0] == '*') {
$delimiter = str_replace('"', '', $a[count($a)-2]);
}
19 years ago
}
} while (!iil_StartsWith($line, 'ghd'));
19 years ago
if (strlen($delimiter)>0) {
return $delimiter;
}
19 years ago
//if that fails, try namespace extension
//try to fetch namespace data
iil_PutLine($conn->fp, "ns1 NAMESPACE");
do {
19 years ago
$line = iil_ReadLine($conn->fp, 1024);
if (iil_StartsWith($line, '* NAMESPACE')) {
19 years ago
$i = 0;
$data = iil_ParseNamespace2(substr($line,11), $i, 0, 0);
}
} while (!iil_StartsWith($line, 'ns1'));
19 years ago
if (!is_array($data)) {
return false;
}
19 years ago
//extract user space data (opposed to global/shared space)
$user_space_data = $data[0];
if (!is_array($user_space_data)) {
return false;
}
19 years ago
//get first element
$first_userspace = $user_space_data[0];
if (!is_array($first_userspace)) {
return false;
}
19 years ago
//extract delimiter
$delimiter = $first_userspace[1];
return $delimiter;
}
function iil_C_ListMailboxes(&$conn, $ref, $mailbox) {
19 years ago
global $IGNORE_FOLDERS;
$ignore = $IGNORE_FOLDERS[strtolower($conn->host)];
$fp = $conn->fp;
if (empty($mailbox)) {
$mailbox = '*';
}
if (empty($ref) && $conn->rootdir) {
$ref = $conn->rootdir;
}
// send command
if (!iil_PutLine($fp, "lmb LIST \"".$ref."\" \"".iil_Escape($mailbox)."\"")) {
return false;
}
$i = 0;
// get folder list
do {
$line = iil_ReadLine($fp, 500);
$line = iil_MultLine($fp, $line);
19 years ago
$a = explode(' ', $line);
if (($line[0] == '*') && ($a[1] == 'LIST')) {
19 years ago
$line = rtrim($line);
// split one line
$a = iil_ExplodeQuotedString(' ', $line);
// last string is folder name
$folder = trim($a[count($a)-1], '"');
if (empty($ignore) || (!empty($ignore)
&& !eregi($ignore, $folder))) {
$folders[$i] = $folder;
}
// second from last is delimiter
$delim = trim($a[count($a)-2], '"');
// is it a container?
$i++;
19 years ago
}
} while (!iil_StartsWith($line, 'lmb'));
19 years ago
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) {
19 years ago
return array('INBOX');
} else {
19 years ago
$conn->error = $line;
return false;
}
}
function iil_C_ListSubscribed(&$conn, $ref, $mailbox) {
19 years ago
global $IGNORE_FOLDERS;
$ignore = $IGNORE_FOLDERS[strtolower($conn->host)];
$fp = $conn->fp;
if (empty($mailbox)) {
$mailbox = '*';
}
if (empty($ref) && $conn->rootdir) {
$ref = $conn->rootdir;
}
19 years ago
$folders = array();
// send command
if (!iil_PutLine($fp, 'lsb LSUB "' . $ref . '" "' . iil_Escape($mailbox).'"')) {
19 years ago
$conn->error = "Couldn't send LSUB command\n";
return false;
}
$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')) {
19 years ago
$line = rtrim($line);
// 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], '"');
if ((!in_array($folder, $folders)) && (empty($ignore)
|| (!empty($ignore) && !eregi($ignore, $folder)))) {
$folders[$i] = $folder;
}
// second from last is delimiter
$delim = trim($a[count($a)-2], '"');
// is it a container?
$i++;
19 years ago
}
} while (!iil_StartsWith($line, 'lsb'));
19 years ago
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;
19 years ago
}
$conn->error = $line;
return false;
19 years ago
}
function iil_C_Subscribe(&$conn, $folder) {
19 years ago
$fp = $conn->fp;
$query = 'sub1 SUBSCRIBE "' . iil_Escape($folder). '"';
iil_PutLine($fp, $query);
17 years ago
$line = trim(iil_ReadLine($fp, 10000));
19 years ago
return iil_ParseResult($line);
}
function iil_C_UnSubscribe(&$conn, $folder) {
19 years ago
$fp = $conn->fp;
$query = 'usub1 UNSUBSCRIBE "' . iil_Escape($folder) . '"';
iil_PutLine($fp, $query);
$line = trim(iil_ReadLine($fp, 10000));
19 years ago
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])";
if (!iil_PutLine($fp, $request)) return false;
do {
17 years ago
$line = chop(iil_ReadLine($fp, 200));
$a = explode(' ', $line);
if (($line[0] == '*') && ($a[2] == 'FETCH')
&& ($line[strlen($line)-1] != ')')) {
19 years ago
$line=iil_ReadLine($fp, 300);
while (trim($line) != ')') {
17 years ago
$result .= $line;
19 years ago
$line=iil_ReadLine($fp, 300);
}
}
17 years ago
} while (strcmp($a[0], $key) != 0);
19 years ago
}
return $result;
}
function iil_C_HandlePartBody(&$conn, $mailbox, $id, $part, $mode) {
/* modes:
19 years ago
1: return string
2: print
3: base64 and print
*/
$fp = $conn->fp;
$result = false;
17 years ago
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])";
// send request
if (!iil_PutLine($fp, $request)) {
return false;
}
// receive reply line
do {
$line = chop(iil_ReadLine($fp, 1000));
$a = explode(' ', $line);
} while ($a[2] != 'FETCH');
$len = strlen($line);
if ($line[$len-1] == ')') {
// one line response, get everything between first and last quotes
if (substr($line, -4, 3) == 'NIL') {
// NIL response
$result = '';
} else {
$from = strpos($line, '"') + 1;
$to = strrpos($line, '"');
$len = $to - $from;
$result = substr($line, $from, $len);
}
if ($mode == 2) {
echo $result;
} else if ($mode == 3) {
echo base64_decode($result);
}
} else if ($line[$len-1] == '}') {
//multi-line request, find sizes of content and receive that many bytes
$from = strpos($line, '{') + 1;
$to = strrpos($line, '}');
$len = $to - $from;
$sizeStr = substr($line, $from, $len);
$bytes = (int)$sizeStr;
$received = 0;
while ($received < $bytes) {
$remaining = $bytes - $received;
$line = iil_ReadLine($fp, 1024);
$len = strlen($line);
if ($len > $remaining) {
$line = substr($line, 0, $remaining);
}
$received += strlen($line);
if ($mode == 1) {
$result .= rtrim($line, "\t\r\n\0\x0B") . "\n";
} else if ($mode == 2) {
echo rtrim($line, "\t\r\n\0\x0B") . "\n"; flush();
} else if ($mode == 3) {
echo base64_decode($line); flush();
}
}
}
// read in anything up until 'til last line
do {
$line = iil_ReadLine($fp, 1024);
} while (!iil_StartsWith($line, $key));
19 years ago
if ($result) {
$result = rtrim($result, "\t\r\n\0\x0B");
return $result; // substr($result, 0, strlen($result)-1);
}
return false;
} else {
echo 'Select failed.';
19 years ago
}
if ($mode==1) {
return $result;
}
return $received;
19 years ago
}
function iil_C_FetchPartBody(&$conn, $mailbox, $id, $part) {
return iil_C_HandlePartBody($conn, $mailbox, $id, $part, 1);
19 years ago
}
function iil_C_PrintPartBody(&$conn, $mailbox, $id, $part) {
iil_C_HandlePartBody($conn, $mailbox, $id, $part, 2);
19 years ago
}
function iil_C_PrintBase64Body(&$conn, $mailbox, $id, $part) {
iil_C_HandlePartBody($conn, $mailbox, $id, $part, 3);
19 years ago
}
function iil_C_CreateFolder(&$conn, $folder) {
19 years ago
$fp = $conn->fp;
if (iil_PutLine($fp, 'c CREATE "' . iil_Escape($folder) . '"')) {
do {
19 years ago
$line=iil_ReadLine($fp, 300);
} while ($line[0] != 'c');
19 years ago
$conn->error = $line;
return (iil_ParseResult($line) == 0);
19 years ago
}
return false;
19 years ago
}
function iil_C_RenameFolder(&$conn, $from, $to) {
19 years ago
$fp = $conn->fp;
if (iil_PutLine($fp, 'r RENAME "' . iil_Escape($from) . '" "' . iil_Escape($to) . '"')) {
do {
17 years ago
$line = iil_ReadLine($fp, 300);
} while ($line[0] != 'r');
return (iil_ParseResult($line) == 0);
}
return false;
19 years ago
}
function iil_C_DeleteFolder(&$conn, $folder) {
19 years ago
$fp = $conn->fp;
if (iil_PutLine($fp, 'd DELETE "' . iil_Escape($folder). '"')) {
do {
19 years ago
$line=iil_ReadLine($fp, 300);
17 years ago
} while ($line[0] != 'd');
return (iil_ParseResult($line) == 0);
19 years ago
}
$conn->error = "Couldn't send command\n";
return false;
19 years ago
}
function iil_C_Append(&$conn, $folder, &$message) {
17 years ago
if (!$folder) {
return false;
}
19 years ago
$fp = $conn->fp;
$message = str_replace("\r", '', $message);
19 years ago
$message = str_replace("\n", "\r\n", $message);
$len = strlen($message);
17 years ago
if (!$len) {
return false;
17 years ago
}
$request = 'A APPEND "' . iil_Escape($folder) .'" (\\Seen) {' . $len . '}';
if (iil_PutLine($fp, $request)) {
$line=iil_ReadLine($fp, 100);
19 years ago
$sent = fwrite($fp, $message."\r\n");
do {
19 years ago
$line=iil_ReadLine($fp, 1000);
} while ($line[0] != 'A');
19 years ago
$result = (iil_ParseResult($line) == 0);
if (!$result) {
$conn->error .= $line . "\n";
}
19 years ago
return $result;
}
$conn->error .= "Couldn't send command \"$request\"\n";
return false;
19 years ago
}
function iil_C_AppendFromFile(&$conn, $folder, $path) {
if (!$folder) {
return false;
}
19 years ago
//open message file
$in_fp = false;
if (file_exists(realpath($path))) {
$in_fp = fopen($path, 'r');
}
if (!$in_fp) {
$conn->error .= "Couldn't open $path for reading\n";
19 years ago
return false;
}
$fp = $conn->fp;
19 years ago
$len = filesize($path);
if (!$len) {
return false;
}
19 years ago
//send APPEND command
$request = 'A APPEND "' . iil_Escape($folder) . '" (\\Seen) {' . $len . '}';
19 years ago
$bytes_sent = 0;
if (iil_PutLine($fp, $request)) {
17 years ago
$line = iil_ReadLine($fp, 100);
19 years ago
//send file
while (!feof($in_fp)) {
17 years ago
$buffer = fgets($in_fp, 4096);
19 years ago
$bytes_sent += strlen($buffer);
iil_PutLine($fp, $buffer, false);
19 years ago
}
fclose($in_fp);
iil_PutLine($fp, '');
19 years ago
//read response
do {
17 years ago
$line = iil_ReadLine($fp, 1000);
} while ($line[0] != 'A');
19 years ago
$result = (iil_ParseResult($line) == 0);
if (!$result) {
$conn->error .= $line . "\n";
}
return $result;
19 years ago
}
$conn->error .= "Couldn't send command \"$request\"\n";
return false;
19 years ago
}
function iil_C_FetchStructureString(&$conn, $folder, $id) {
$fp = $conn->fp;
$result = false;
if (iil_C_Select($conn, $folder)) {
$key = 'F1247';
if (iil_PutLine($fp, "$key FETCH $id (BODYSTRUCTURE)")) {
do {
$line = iil_ReadLine($fp, 5000);
$line = iil_MultLine($fp, $line);
$result .= $line;
17 years ago
} while (!preg_match("/^$key/", $line));
$result = trim(substr($result, strpos($result, 'BODYSTRUCTURE')+13, -(strlen($result)-strrpos($result, $key)+1)));
19 years ago
}
}
return $result;
}
function iil_C_PrintSource(&$conn, $folder, $id, $part) {
19 years ago
$header = iil_C_FetchPartHeader($conn, $folder, $id, $part);
//echo str_replace("\r", '', $header);
19 years ago
echo $header;
echo iil_C_PrintPartBody($conn, $folder, $id, $part);
}
function iil_C_GetQuota(&$conn) {
19 years ago
/*
* GETQUOTAROOT "INBOX"
* QUOTAROOT INBOX user/rchijiiwa1
* QUOTA user/rchijiiwa1 (STORAGE 654 9765)
b OK Completed
*/
$fp = $conn->fp;
$result = false;
$quota_line = '';
19 years ago
//get line containing quota info
if (iil_PutLine($fp, 'QUOT1 GETQUOTAROOT "INBOX"')) {
do {
19 years ago
$line=chop(iil_ReadLine($fp, 5000));
if (iil_StartsWith($line, '* QUOTA ')) {
$quota_line = $line;
}
} while (!iil_StartsWith($line, 'QUOT1'));
19 years ago
}
//return false if not found, parse if found
if (!empty($quota_line)) {
17 years ago
$quota_line = eregi_replace('[()]', '', $quota_line);
$parts = explode(' ', $quota_line);
$storage_part = array_search('STORAGE', $parts);
17 years ago
if ($storage_part > 0) {
19 years ago
$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'];
19 years ago
}
}
return $result;
}
function iil_C_ClearFolder(&$conn, $folder) {
19 years ago
$num_in_trash = iil_C_CountMessages($conn, $folder);
if ($num_in_trash > 0) {
iil_C_Delete($conn, $folder, '1:' . $num_in_trash);
}
19 years ago
return (iil_C_Expunge($conn, $folder) >= 0);
}
?>