X-Git-Url: https://vcs.fsf.org/?a=blobdiff_plain;f=functions%2Fimap_messages.php;h=cb2cf325c13f5caf35cf41ace1c2ca8ecc032a71;hb=9211bcef4d591ce3cf59cee202c24311d06849fd;hp=5930134d09f5c52770f49529072765ad6ea9d46f;hpb=c075fcfeee6685e97ac75f7400f267ddaa7c3e28;p=squirrelmail.git diff --git a/functions/imap_messages.php b/functions/imap_messages.php index 5930134d..cb2cf325 100755 --- a/functions/imap_messages.php +++ b/functions/imap_messages.php @@ -1,110 +1,102 @@ 1) { $thread_new[$k] .= $thread_temp[$i]; @@ -447,7 +458,7 @@ function get_thread_sort ($imap_stream) { } } } - sqsession_register($thread_new, 'thread_new'); + $thread_new = array_reverse($thread_new); /* place the threads after each other in one string */ $thread_list = implode(" ", $thread_new); @@ -457,10 +468,7 @@ function get_thread_sort ($imap_stream) { $server_sort_array = $thread_list; $indent_array = get_parent_level ($thread_new); - sqsession_register($indent_array, 'indent_array'); - - sqsession_register($server_sort_array, 'server_sort_array'); - return $thread_list; + return array($thread_list,$indent_array); } @@ -470,7 +478,28 @@ function elapsedTime($start) { return $timepassed; } -// only used in sqimap_get_small_header_list + +function parsePriority($value) { + $value = strtolower(array_shift(split('/\w/',trim($value)))); + if ( is_numeric($value) ) { + return $value; + } + if ( $value == 'urgent' || $value == 'high' ) { + return 1; + } elseif ( $value == 'non-urgent' || $value == 'low' ) { + return 5; + } + return 3; +} + +/** + * Parses a string in an imap response. String starts with " or { which means it + * can handle double quoted strings and literal strings + * + * @param string $read imap response + * @param integer $i (reference) offset in string + * @return string $s parsed string without the double quotes or literal count + */ function parseString($read,&$i) { $char = $read{$i}; $s = ''; @@ -479,29 +508,29 @@ function parseString($read,&$i) { while (true) { $iPos = strpos($read,'"',$iPos); if (!$iPos) break; - if ($iPos && $read{$iPos -1} != '\\') { - $s = substr($read,$i,($iPos-$i)); - $i = $iPos; - break; - } - $iPos++; - if ($iPos > strlen($read)) { - break; - } + if ($iPos && $read{$iPos -1} != '\\') { + $s = substr($read,$i,($iPos-$i)); + $i = $iPos; + break; + } + $iPos++; + if ($iPos > strlen($read)) { + break; + } } } else if ($char == '{') { $lit_cnt = ''; ++$i; $iPos = strpos($read,'}',$i); if ($iPos) { - $lit_cnt = substr($read, $i, $iPos - $i); - $i += strlen($lit_cnt) + 3; /* skip } + \r + \n */ - /* Now read the literal */ - $s = ($lit_cnt ? substr($read,$i,$lit_cnt): ''); - $i += $lit_cnt; - /* temp bugfix (SM 1.5 will have a working clean version) - too much work to implement that version right now */ - --$i; + $lit_cnt = substr($read, $i, $iPos - $i); + $i += strlen($lit_cnt) + 3; /* skip } + \r + \n */ + /* Now read the literal */ + $s = ($lit_cnt ? substr($read,$i,$lit_cnt): ''); + $i += $lit_cnt; + /* temp bugfix (SM 1.5 will have a working clean version) + too much work to implement that version right now */ + --$i; } else { /* should never happen */ $i += 3; /* } + \r + \n */ $s = ''; @@ -513,7 +542,14 @@ function parseString($read,&$i) { return $s; } -// only used in sqimap_get_small_header_list + +/** + * Parses a string containing an array from an imap response. String starts with ( and end with ) + * + * @param string $read imap response + * @param integer $i (reference) offset in string + * @return array $a + */ function parseArray($read,&$i) { $i = strpos($read,'(',$i); $i_pos = strpos($read,')',$i); @@ -527,17 +563,25 @@ function parseArray($read,&$i) { } } -function sqimap_get_small_header_list ($imap_stream, $msg_list, $show_num=false, - $aHeaderFields = array('Date', 'To', 'Cc', 'From', 'Subject', 'X-Priority', 'Content-Type'), + +/** + * Retrieves a list with headers, flags, size or internaldate from the imap server + * @param resource $imap_stream imap connection + * @param array $msg_list array with id's to create a msgs set from + * @param array $aHeaderFields requested header fields + * @param array $aFetchItems requested other fetch items like FLAGS, RFC822.SIZE + * @return array $aMessages associative array with messages. Key is the UID, value is an associative array + */ +function sqimap_get_small_header_list($imap_stream, $msg_list, + $aHeaderFields = array('Date', 'To', 'Cc', 'From', 'Subject', 'X-Priority', 'Importance', 'Priority', 'Content-Type'), $aFetchItems = array('FLAGS', 'RFC822.SIZE', 'INTERNALDATE')) { - $messages = array(); - $read_list = array(); + $aMessageList = array(); $bUidFetch = ! in_array('UID', $aFetchItems, true); /* Get the small headers for each message in $msg_list */ - if ($show_num != '999999' && $show_num != '*' ) { + if ($msg_list !== NULL) { $msgs_str = sqimap_message_list_squisher($msg_list); /* * We need to return the data in the same order as the caller supplied @@ -546,15 +590,13 @@ function sqimap_get_small_header_list ($imap_stream, $msg_list, $show_num=false, */ if ($bUidFetch) { for ($i = 0; $i < sizeof($msg_list); $i++) { - $messages["$msg_list[$i]"] = array(); + $aMessageList["$msg_list[$i]"] = array(); } } } else { $msgs_str = '1:*'; } - - /* * Create the query */ @@ -569,21 +611,35 @@ function sqimap_get_small_header_list ($imap_stream, $msg_list, $show_num=false, $sFetchItems .= ' BODY.PEEK[HEADER.FIELDS ('.$sHeaderFields.')]'; } $query .= trim($sFetchItems) . ')'; + $aResponse = sqimap_run_command_list ($imap_stream, $query, true, $response, $message, $bUidFetch); + $aMessages = parseFetch($aResponse,$aMessageList); + array_reverse($aMessages); + return $aMessages; +} - $read_list = sqimap_run_command_list ($imap_stream, $query, true, $response, $message, $bUidFetch); - $i = 0; - foreach ($read_list as $r) { +/** + * Parses a fetch response, currently it can hande FLAGS, HEADERS, RFC822.SIZE, INTERNALDATE and UID + * @param array $aResponse Imap response + * @param array $aMessageList Placeholder array for results. The keys of the + * placeholder array should be the UID so we can reconstruct the order. + * @return array $aMessageList associative array with messages. Key is the UID, value is an associative array + * @author Marc Groot Koerkamp + */ +function parseFetch($aResponse,$aMessageList = array()) { + foreach ($aResponse as $r) { + $msg = array(); // use unset because we do isset below $read = implode('',$r); /* - * #idFETCH( - */ + * #idFETCH( + */ /* extract the message id */ $i_space = strpos($read,' ',2); $id = substr($read,2,$i_space-2); + $msg['ID'] = $id; $fetch = substr($read,$i_space+1,5); if (!is_numeric($id) && $fetch !== 'FETCH') { $msg['ERROR'] = $read; // htmlspecialchars should be done just before display. this is backend code @@ -644,7 +700,7 @@ function sqimap_get_small_header_list ($imap_stream, $msg_list, $show_num=false, case 'BODYSTRUCTURE': break; case 'INTERNALDATE': - $msg['INTERNALDATE'] = str_replace(' ', ' ',parseString($read,$i)); + $msg['INTERNALDATE'] = trim(str_replace(' ', ' ',parseString($read,$i))); break; case 'BODY.PEEK[HEADER.FIELDS': case 'BODY[HEADER.FIELDS': @@ -671,7 +727,10 @@ function sqimap_get_small_header_list ($imap_stream, $msg_list, $show_num=false, case 'date': $msg['DATE'] = str_replace(' ', ' ', $value); break; - case 'x-priority': $msg['PRIORITY'] = $value; break; + case 'x-priority': + case 'importance': + case 'priority': + $msg['PRIORITY'] = parsePriority($value); break; case 'subject': $msg['SUBJECT'] = $value; break; case 'content-type': $type = $value; @@ -705,15 +764,20 @@ function sqimap_get_small_header_list ($imap_stream, $msg_list, $show_num=false, } } $msgi ="$unique_id"; - $msg['ID'] = $unique_id; + $msg['UID'] = $unique_id; - $messages[$msgi] = $msg; + $aMessageList[$msgi] = $msg; ++$msgi; } - array_reverse($messages); - return $messages; + return $aMessageList; } + +/** + * Work in process + * @private + * @author Marc Groot Koerkamp + */ function sqimap_parse_envelope($read, &$i, &$msg) { $arg_no = 0; $arg_a = array(); @@ -775,7 +839,7 @@ function sqimap_parse_envelope($read, &$i, &$msg) { if (count($arg_a) > 9) { $d = strtr($arg_a[0], array(' ' => ' ')); $d = explode(' ', $d); - if (!$arg_a[1]) $arg_1[1] = ''; + if (!$arg_a[1]) $arg_a[1] = ''; $msg['DATE'] = $d; /* argument 1: date */ $msg['SUBJECT'] = $arg_a[1]; /* argument 2: subject */ $msg['FROM'] = is_array($arg_a[2]) ? $arg_a[2][0] : ''; /* argument 3: from */ @@ -789,6 +853,12 @@ function sqimap_parse_envelope($read, &$i, &$msg) { } } + +/** + * Work in process + * @private + * @author Marc Groot Koerkamp + */ function sqimap_parse_address($read, &$i) { $arg_a = array(); for (; $read{$i} != ')'; ++$i) { @@ -821,15 +891,21 @@ function sqimap_parse_address($read, &$i) { return $adr; } + /** -* 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) { + * Returns a message array with all the information about a message. + * See the documentation folder for more information about this array. + * + * @param resource $imap_stream imap connection + * @param integer $id uid of the message + * @param string $mailbox used for error handling, can be removed because we should return an error code and generate the message elsewhere + * @return Message Message object + */ +function sqimap_get_message($imap_stream, $id, $mailbox) { // typecast to int to prohibit 1:* msgs sets $id = (int) $id; $flags = array(); - $read = sqimap_run_command ($imap_stream, "FETCH $id (FLAGS BODYSTRUCTURE)", true, $response, $message, TRUE); + $read = sqimap_run_command($imap_stream, "FETCH $id (FLAGS BODYSTRUCTURE)", true, $response, $message, TRUE); if ($read) { if (preg_match('/.+FLAGS\s\((.*)\)\s/AUi',$read[0],$regs)) { if (trim($regs[1])) { @@ -848,11 +924,52 @@ function sqimap_get_message ($imap_stream, $id, $mailbox) { } $bodystructure = implode('',$read); $msg = mime_structure($bodystructure,$flags); - $read = sqimap_run_command ($imap_stream, "FETCH $id BODY[HEADER]", true, $response, $message, TRUE); + $read = sqimap_run_command($imap_stream, "FETCH $id BODY[HEADER]", true, $response, $message, TRUE); $rfc822_header = new Rfc822Header(); $rfc822_header->parseHeader($read); $msg->rfc822_header = $rfc822_header; return $msg; } -?> + +/** + * Deprecated !!!!!!! DO NOT USE THIS, use sqimap_msgs_list_copy instead + */ +function sqimap_messages_copy($imap_stream, $start, $end, $mailbox) { + $read = sqimap_run_command ($imap_stream, "COPY $start:$end " . sqimap_encode_mailbox_name($mailbox), true, $response, $message, TRUE); +} + + +/** + * Deprecated !!!!!!! DO NOT USE THIS, use sqimap_msgs_list_delete instead + */ +function sqimap_messages_delete($imap_stream, $start, $end, $mailbox, $bypass_trash=false) { + global $move_to_trash, $trash_folder; + + if (($move_to_trash == true) && ($bypass_trash != true) && + (sqimap_mailbox_exists($imap_stream, $trash_folder) && ($mailbox != $trash_folder))) { + sqimap_messages_copy ($imap_stream, $start, $end, $trash_folder); + } + sqimap_messages_flag ($imap_stream, $start, $end, "Deleted", true); +} + + +/** + * Deprecated !!!!!!! DO NOT USE THIS, use sqimap_toggle_flag instead + * Set a flag on the provided uid list + * @param resource imap connection + */ +function sqimap_messages_flag($imap_stream, $start, $end, $flag, $handle_errors) { + $read = sqimap_run_command ($imap_stream, "STORE $start:$end +FLAGS (\\$flag)", $handle_errors, $response, $message, TRUE); +} + + +/** + * @deprecated + */ +function sqimap_get_small_header($imap_stream, $id, $sent) { + $res = sqimap_get_small_header_list($imap_stream, $id, $sent); + return $res[0]; +} + +?> \ No newline at end of file