From a03233cebafc62ec7d88a24856b8a7b37fef4381 Mon Sep 17 00:00:00 2001 From: Aleksander Machniak <alec@alec.pl> Date: Wed, 07 Oct 2015 03:14:18 -0400 Subject: [PATCH] CS fixes --- program/lib/Roundcube/rcube_imap.php | 114 ++++++++++++++++++++++++++++----------------------------- 1 files changed, 56 insertions(+), 58 deletions(-) diff --git a/program/lib/Roundcube/rcube_imap.php b/program/lib/Roundcube/rcube_imap.php index 51c5442..2940446 100644 --- a/program/lib/Roundcube/rcube_imap.php +++ b/program/lib/Roundcube/rcube_imap.php @@ -62,8 +62,6 @@ protected $sort_field = ''; protected $sort_order = 'DESC'; protected $struct_charset; - protected $uid_id_map = array(); - protected $msg_headers = array(); protected $search_set; protected $search_string = ''; protected $search_charset = ''; @@ -984,7 +982,7 @@ // gather messages from a multi-folder search if ($this->search_set->multi) { - $page_size = $this->page_size; + $page_size = $this->page_size; $sort_field = $this->sort_field; $search_set = $this->search_set; @@ -995,23 +993,26 @@ $slice_length = min($page_size, $cnt - $from); // fetch resultset headers, sort and slice them - if (!empty($sort_field)) { + if (!empty($sort_field) && $search_set->get_parameters('SORT') != $sort_field) { $this->sort_field = null; - $this->page_size = 1000; // fetch up to 1000 matching messages per folder - $this->threading = false; + $this->page_size = 1000; // fetch up to 1000 matching messages per folder + $this->threading = false; $a_msg_headers = array(); foreach ($search_set->sets as $resultset) { if (!$resultset->is_empty()) { - $this->search_set = $resultset; + $this->search_set = $resultset; $this->search_threads = $resultset instanceof rcube_result_thread; - $a_msg_headers = array_merge($a_msg_headers, $this->list_search_messages($resultset->get_parameters('MAILBOX'), 1)); + + $a_headers = $this->list_search_messages($resultset->get_parameters('MAILBOX'), 1); + $a_msg_headers = array_merge($a_msg_headers, $a_headers); + unset($a_headers); } } // sort headers if (!empty($a_msg_headers)) { - $a_msg_headers = $this->conn->sortHeaders($a_msg_headers, $sort_field, $this->sort_order); + $a_msg_headers = rcube_imap_generic::sortHeaders($a_msg_headers, $sort_field, $this->sort_order); } // store (sorted) message index @@ -1045,7 +1046,7 @@ // restore members $this->sort_field = $sort_field; - $this->page_size = $page_size; + $this->page_size = $page_size; $this->search_set = $search_set; return $a_msg_headers; @@ -1139,12 +1140,8 @@ return array(); } - if (!$this->check_connection()) { - return array(); - } - // if not already sorted - $a_msg_headers = $this->conn->sortHeaders( + $a_msg_headers = rcube_imap_generic::sortHeaders( $a_msg_headers, $this->sort_field, $this->sort_order); // only return the requested part of the set @@ -2427,7 +2424,7 @@ * * @param mixed $uids Message UIDs as array or comma-separated string, or '*' * @param string $flag Flag to set: SEEN, UNDELETED, DELETED, RECENT, ANSWERED, DRAFT, MDNSENT - * @param string $folder Folder name + * @param string $folder Folder name * @param boolean $skip_cache True to skip message cache clean up * * @return boolean Operation status @@ -2683,7 +2680,6 @@ // really deleted from the folder $this->expunge_message($uids, $folder, false); $this->clear_messagecount($folder); - unset($this->uid_id_map[$folder]); // unset threads internal cache unset($this->icache['threads']); @@ -3112,8 +3108,22 @@ */ public function folder_size($folder) { + if (!strlen($folder)) { + return false; + } + if (!$this->check_connection()) { return 0; + } + + // On Cyrus we can use special folder annotation, which should be much faster + if ($this->get_vendor() == 'cyrus') { + $idx = '/shared/vendor/cmu/cyrus-imapd/size'; + $result = $this->get_metadata($folder, $idx, array(), true); + + if (!empty($result) && is_numeric($result[$folder][$idx])) { + return $result[$folder][$idx]; + } } // @TODO: could we try to use QUOTA here? @@ -3879,30 +3889,33 @@ /** * Returns IMAP metadata/annotations (GETMETADATA/GETANNOTATION) * - * @param string $folder Folder name (empty for server metadata) - * @param array $entries Entries - * @param array $options Command options (with MAXSIZE and DEPTH keys) + * @param string $folder Folder name (empty for server metadata) + * @param array $entries Entries + * @param array $options Command options (with MAXSIZE and DEPTH keys) + * @param bool $force Disables cache use * * @return array Metadata entry-value hash array on success, NULL on error * @since 0.5-beta */ - public function get_metadata($folder, $entries, $options=array()) + public function get_metadata($folder, $entries, $options = array(), $force = false) { - $entries = (array)$entries; + $entries = (array) $entries; - // create cache key - // @TODO: this is the simplest solution, but we do the same with folders list - // maybe we should store data per-entry and merge on request - sort($options); - sort($entries); - $cache_key = 'mailboxes.metadata.' . $folder; - $cache_key .= '.' . md5(serialize($options).serialize($entries)); + if (!$force) { + // create cache key + // @TODO: this is the simplest solution, but we do the same with folders list + // maybe we should store data per-entry and merge on request + sort($options); + sort($entries); + $cache_key = 'mailboxes.metadata.' . $folder; + $cache_key .= '.' . md5(serialize($options).serialize($entries)); - // get cached data - $cached_data = $this->get_cache($cache_key); + // get cached data + $cached_data = $this->get_cache($cache_key); - if (is_array($cached_data)) { - return $cached_data; + if (is_array($cached_data)) { + return $cached_data; + } } if (!$this->check_connection()) { @@ -3941,11 +3954,12 @@ } if (isset($res)) { - $this->update_cache($cache_key, $res); + if (!$force) { + $this->update_cache($cache_key, $res); + } + return $res; } - - return null; } /** @@ -3966,7 +3980,6 @@ } // @TODO: log error - return null; } @@ -4235,19 +4248,11 @@ $folder = $this->folder; } - if ($uid = array_search($id, (array)$this->uid_id_map[$folder])) { - return $uid; - } - if (!$this->check_connection()) { return null; } - $uid = $this->conn->ID2UID($folder, $id); - - $this->uid_id_map[$folder][$uid] = $id; - - return $uid; + return $this->conn->ID2UID($folder, $id); } /** @@ -4255,22 +4260,16 @@ */ protected function change_subscription($folders, $mode) { - $updated = false; + $updated = 0; + $folders = (array) $folders; if (!empty($folders)) { if (!$this->check_connection()) { return false; } - foreach ((array)$folders as $i => $folder) { - $folders[$i] = $folder; - - if ($mode == 'subscribe') { - $updated = $this->conn->subscribe($folder); - } - else if ($mode == 'unsubscribe') { - $updated = $this->conn->unsubscribe($folder); - } + foreach ($folders as $folder) { + $updated += (int) $this->conn->{$mode}($folder); } } @@ -4279,7 +4278,7 @@ $this->clear_cache('mailboxes', true); } - return $updated; + return $updated == count($folders) ? true : false; } /** @@ -4354,7 +4353,6 @@ /** * This is our own debug handler for the IMAP connection - * @access public */ public function debug_handler(&$imap, $message) { -- Gitblit v1.9.1