5bb18f1127
messages are now handled on the IMAP server, rather than inside PHP, which makes it about 20x faster (literally).
338 lines
13 KiB
PHP
Executable file
338 lines
13 KiB
PHP
Executable file
<?php
|
|
/**
|
|
** imap_messages.php
|
|
**
|
|
** This implements functions that manipulate messages
|
|
**/
|
|
|
|
if (!$mime_php) include "../functions/mime.php";
|
|
|
|
/******************************************************************************
|
|
** Copies specified messages to specified folder
|
|
******************************************************************************/
|
|
function sqimap_messages_copy ($imap_stream, $start, $end, $mailbox) {
|
|
fputs ($imap_stream, "a001 COPY $start:$end \"$mailbox\"\r\n");
|
|
$read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
|
|
}
|
|
|
|
/******************************************************************************
|
|
** Deletes specified messages and moves them to trash if possible
|
|
******************************************************************************/
|
|
function sqimap_messages_delete ($imap_stream, $start, $end, $mailbox) {
|
|
global $move_to_trash, $trash_folder, $auto_expunge;
|
|
|
|
if (($move_to_trash == true) && (sqimap_mailbox_exists($imap_stream, $trash_folder))) {
|
|
sqimap_messages_copy ($imap_stream, $start, $end, $trash_folder);
|
|
sqimap_messages_flag ($imap_stream, $start, $end, "Deleted");
|
|
} else {
|
|
sqimap_messages_flag ($imap_stream, $start, $end, "Deleted");
|
|
}
|
|
}
|
|
|
|
/******************************************************************************
|
|
** Sets the specified messages with specified flag
|
|
******************************************************************************/
|
|
function sqimap_messages_flag ($imap_stream, $start, $end, $flag) {
|
|
fputs ($imap_stream, "a001 STORE $start:$end +FLAGS (\\$flag)\r\n");
|
|
$read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
|
|
}
|
|
|
|
/******************************************************************************
|
|
** Returns some general header information -- FROM, DATE, and SUBJECT
|
|
******************************************************************************/
|
|
class small_header {
|
|
var $from, $subject, $date;
|
|
}
|
|
|
|
function sqimap_get_small_header ($imap_stream, $id, $sent) {
|
|
fputs ($imap_stream, "a001 FETCH $id BODY.PEEK[HEADER.FIELDS (Date To From Subject)]\r\n");
|
|
$read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
|
|
|
|
$subject = _("(no subject)");
|
|
$from = _("Unknown Sender");
|
|
$g = 0;
|
|
for ($i = 0; $i < count($read); $i++) {
|
|
if ($sent == true) {
|
|
if (eregi ("^to:", $read[$i])) {
|
|
$from = sqimap_find_displayable_name(substr($read[$i], 3));
|
|
}
|
|
} else {
|
|
if (eregi ("^from:", $read[$i])) {
|
|
$from = sqimap_find_displayable_name(substr($read[$i], 5));
|
|
}
|
|
}
|
|
|
|
if (eregi ("^date:", $read[$i])) {
|
|
$date = substr($read[$i], 5);
|
|
} else if (eregi ("^subject:", $read[$i])) {
|
|
$subject = htmlspecialchars(eregi_replace ("^subject: ", "", $read[$i]));
|
|
if (strlen(Chop($subject)) == 0)
|
|
$subject = _("(no subject)");
|
|
}
|
|
}
|
|
|
|
$header = new small_header;
|
|
$header->from = $from;
|
|
$header->date = $date;
|
|
$header->subject = $subject;
|
|
|
|
return $header;
|
|
}
|
|
|
|
/******************************************************************************
|
|
** Returns the flags for the specified messages
|
|
******************************************************************************/
|
|
function sqimap_get_flags ($imap_stream, $i) {
|
|
fputs ($imap_stream, "a001 FETCH $i:$i FLAGS\r\n");
|
|
$read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
|
|
if (strpos($read[0], "FLAGS")) {
|
|
$tmp = ereg_replace("\(", "", $read[0]);
|
|
$tmp = ereg_replace("\)", "", $tmp);
|
|
$tmp = str_replace("\\", "", $tmp);
|
|
$tmp = substr($tmp, strpos($tmp, "FLAGS")+6, strlen($tmp));
|
|
$tmp = trim($tmp);
|
|
$flags = explode(" ", $tmp);
|
|
} else {
|
|
$flags[0] = "None";
|
|
}
|
|
return $flags;
|
|
}
|
|
|
|
/******************************************************************************
|
|
** Returns a message array with all the information about a message. See
|
|
** the documentation folder for more information about this array.
|
|
******************************************************************************/
|
|
function sqimap_get_message ($imap_stream, $id, $mailbox) {
|
|
|
|
$header = sqimap_get_message_header($imap_stream, $id, $mailbox);
|
|
$msg = sqimap_get_message_body($imap_stream, &$header);
|
|
return $msg;
|
|
}
|
|
|
|
/******************************************************************************
|
|
** Wrapper function that reformats the header information.
|
|
******************************************************************************/
|
|
function sqimap_get_message_header ($imap_stream, $id, $mailbox) {
|
|
fputs ($imap_stream, "a001 FETCH $id:$id BODY[HEADER]\r\n");
|
|
$read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
|
|
|
|
$header = sqimap_get_header($imap_stream, $read);
|
|
$header->id = $id;
|
|
$header->mailbox = $mailbox;
|
|
|
|
return $header;
|
|
}
|
|
|
|
/******************************************************************************
|
|
** Wrapper function that returns entity headers for use by decodeMime
|
|
******************************************************************************/
|
|
/*
|
|
function sqimap_get_entity_header ($imap_stream, &$read, &$type0, &$type1, &$bound, &$encoding, &$charset, &$filename) {
|
|
$header = sqimap_get_header($imap_stream, $read);
|
|
$type0 = $header["TYPE0"];
|
|
$type1 = $header["TYPE1"];
|
|
$bound = $header["BOUNDARY"];
|
|
$encoding = $header["ENCODING"];
|
|
$charset = $header["CHARSET"];
|
|
$filename = $header["FILENAME"];
|
|
}
|
|
*/
|
|
|
|
/******************************************************************************
|
|
** Queries the IMAP server and gets all header information.
|
|
******************************************************************************/
|
|
function sqimap_get_header ($imap_stream, $read) {
|
|
$hdr = new msg_header();
|
|
$i = 0;
|
|
// Set up some defaults
|
|
$hdr->type0 = "text";
|
|
$hdr->type1 = "plain";
|
|
$hdr->charset = "us-ascii";
|
|
|
|
while ($i < count($read)) {
|
|
if (substr($read[$i], 0, 17) == "MIME-Version: 1.0") {
|
|
$hdr->mime = true;
|
|
$i++;
|
|
}
|
|
|
|
/** ENCODING TYPE **/
|
|
else if (substr(strtolower($read[$i]), 0, 26) == "content-transfer-encoding:") {
|
|
$hdr->encoding = strtolower(trim(substr($read[$i], 26)));
|
|
$i++;
|
|
}
|
|
|
|
/** CONTENT-TYPE **/
|
|
else if (strtolower(substr($read[$i], 0, 13)) == "content-type:") {
|
|
$cont = strtolower(trim(substr($read[$i], 13)));
|
|
if (strpos($cont, ";"))
|
|
$cont = substr($cont, 0, strpos($cont, ";"));
|
|
|
|
|
|
if (strpos($cont, "/")) {
|
|
$hdr->type0 = substr($cont, 0, strpos($cont, "/"));
|
|
$hdr->type1 = substr($cont, strpos($cont, "/")+1);
|
|
} else {
|
|
$hdr->type0 = $cont;
|
|
}
|
|
|
|
|
|
$line = $read[$i];
|
|
$i++;
|
|
while ( (substr(substr($read[$i], 0, strpos($read[$i], " ")), -1) != ":") && (trim($read[$i]) != "") && (trim($read[$i]) != ")")) {
|
|
str_replace("\n", "", $line);
|
|
str_replace("\n", "", $read[$i]);
|
|
$line = "$line $read[$i]";
|
|
$i++;
|
|
}
|
|
|
|
/** Detect the boundary of a multipart message **/
|
|
if (eregi("boundary=\"([^\"]+)\"", $line, $regs)) {
|
|
$hdr->boundary = $regs[1];
|
|
}
|
|
|
|
/** Detect the charset **/
|
|
if (strpos(strtolower(trim($line)), "charset=")) {
|
|
$pos = strpos($line, "charset=") + 8;
|
|
$charset = trim($line);
|
|
if (strpos($line, " ", $pos) > 0) {
|
|
$charset = substr($charset, $pos, strpos($line, " ", $pos));
|
|
} else {
|
|
$charset = substr($charset, $pos);
|
|
}
|
|
$charset = str_replace("\"", "", $charset);
|
|
$hdr->charset = $charset;
|
|
} else {
|
|
$hdr->charset = "us-ascii";
|
|
}
|
|
|
|
}
|
|
|
|
else if (strtolower(substr($read[$i], 0, 20)) == "content-disposition:") {
|
|
/** Add better dontent-disposition support **/
|
|
|
|
$line = $read[$i];
|
|
$i++;
|
|
while ( (substr(substr($read[$i], 0, strpos($read[$i], " ")), -1) != ":") && (trim($read[$i]) != "") && (trim($read[$i]) != ")")) {
|
|
str_replace("\n", "", $line);
|
|
str_replace("\n", "", $read[$i]);
|
|
$line = "$line $read[$i]";
|
|
$i++;
|
|
}
|
|
|
|
/** Detects filename if any **/
|
|
if (strpos(strtolower(trim($line)), "filename=")) {
|
|
$pos = strpos($line, "filename=") + 9;
|
|
$name = trim($line);
|
|
if (strpos($line, " ", $pos) > 0) {
|
|
$name = substr($name, $pos, strpos($line, " ", $pos));
|
|
} else {
|
|
$name = substr($name, $pos);
|
|
}
|
|
$name = str_replace("\"", "", $name);
|
|
$hdr->filename = $name;
|
|
}
|
|
}
|
|
|
|
/** REPLY-TO **/
|
|
else if (strtolower(substr($read[$i], 0, 9)) == "reply-to:") {
|
|
$hdr->replyto = trim(substr($read[$i], 9, strlen($read[$i])));
|
|
$i++;
|
|
}
|
|
|
|
/** FROM **/
|
|
else if (strtolower(substr($read[$i], 0, 5)) == "from:") {
|
|
$hdr->from = trim(substr($read[$i], 5, strlen($read[$i]) - 6));
|
|
if ($hdr->replyto == "")
|
|
$hdr->replyto = $hdr->from;
|
|
$i++;
|
|
}
|
|
/** DATE **/
|
|
else if (strtolower(substr($read[$i], 0, 5)) == "date:") {
|
|
$d = substr($read[$i], 5);
|
|
$d = trim($d);
|
|
$d = ereg_replace(" ", " ", $d);
|
|
$d = explode(" ", $d);
|
|
$hdr->date = getTimeStamp($d);
|
|
$i++;
|
|
}
|
|
/** SUBJECT **/
|
|
else if (strtolower(substr($read[$i], 0, 8)) == "subject:") {
|
|
$hdr->subject = trim(substr($read[$i], 8, strlen($read[$i]) - 9));
|
|
if (strlen(Chop($hdr->subject)) == 0)
|
|
$hdr->subject = _("(no subject)");
|
|
$i++;
|
|
}
|
|
/** CC **/
|
|
else if (strtolower(substr($read[$i], 0, 3)) == "cc:") {
|
|
$pos = 0;
|
|
$hdr->cc[$pos] = trim(substr($read[$i], 4));
|
|
$i++;
|
|
while (((substr($read[$i], 0, 1) == " ") || (substr($read[$i], 0, 1) == "\t")) && (trim($read[$i]) != "")){
|
|
$pos++;
|
|
$hdr->cc[$pos] = trim($read[$i]);
|
|
$i++;
|
|
}
|
|
}
|
|
/** TO **/
|
|
else if (strtolower(substr($read[$i], 0, 3)) == "to:") {
|
|
$pos = 0;
|
|
$hdr->to[$pos] = trim(substr($read[$i], 4));
|
|
$i++;
|
|
while (((substr($read[$i], 0, 1) == " ") || (substr($read[$i], 0, 1) == "\t")) && (trim($read[$i]) != "")){
|
|
$pos++;
|
|
$hdr->to[$pos] = trim($read[$i]);
|
|
$i++;
|
|
}
|
|
}
|
|
/** MESSAGE ID **/
|
|
else if (strtolower(substr($read[$i], 0, 11)) == "message-id:") {
|
|
$hdr->message_id = trim(substr($read[$i], 11));
|
|
$i++;
|
|
}
|
|
|
|
|
|
/** ERROR CORRECTION **/
|
|
else if (substr($read[$i], 0, 1) == ")") {
|
|
if (strlen(trim($hdr->subject)) == 0)
|
|
$hdr->subject = _("(no subject)");
|
|
|
|
if (strlen(trim($hdr->from)) == 0)
|
|
$hdr->from = _("(unknown sender)");
|
|
|
|
if (strlen(trim($hdr->date)) == 0)
|
|
$hdr->date = time();
|
|
$i++;
|
|
}
|
|
else {
|
|
$i++;
|
|
}
|
|
}
|
|
return $hdr;
|
|
}
|
|
|
|
|
|
/******************************************************************************
|
|
** Returns the body of a message.
|
|
******************************************************************************/
|
|
function sqimap_get_message_body ($imap_stream, &$header) {
|
|
$id = $header->id;
|
|
//fputs ($imap_stream, "a001 FETCH $id:$id BODY[TEXT]\r\n");
|
|
//$read = sqimap_read_data ($imap_stream, "a001", true, $response, $message);
|
|
|
|
$i = 0;
|
|
$j = 0;
|
|
while ($i < count($read)-1) {
|
|
if ( ($i != 0) ) {
|
|
$body[$j] = $read[$i];
|
|
$j++;
|
|
}
|
|
$i++;
|
|
}
|
|
return decodeMime($body, &$header);
|
|
}
|
|
|
|
|
|
/******************************************************************************
|
|
** Returns an array with the body structure
|
|
******************************************************************************/
|
|
?>
|