More fixes for multi-folder search (#1485234)

pull/193/head
Thomas Bruederli 11 years ago
parent e7a3ae9a76
commit e8cb51669a

@ -1480,10 +1480,6 @@ class rcube_imap extends rcube_storage
$str = 'ALL'; $str = 'ALL';
} }
if (empty($folder)) {
$folder = $this->folder;
}
// multi-folder search // multi-folder search
if (is_array($folder) && count($folder) > 1 && $str != 'ALL') { if (is_array($folder) && count($folder) > 1 && $str != 'ALL') {
new rcube_result_index; // trigger autoloader and make these classes available for threaded context new rcube_result_index; // trigger autoloader and make these classes available for threaded context
@ -1506,6 +1502,9 @@ class rcube_imap extends rcube_storage
} }
else { else {
$folder = is_array($folder) ? $folder[0] : $folder; $folder = is_array($folder) ? $folder[0] : $folder;
if (!strlen($folder)) {
$folder = $this->folder;
}
$results = $this->search_index($folder, $str, $charset, $sort_field); $results = $this->search_index($folder, $str, $charset, $sort_field);
} }
@ -1664,8 +1663,12 @@ class rcube_imap extends rcube_storage
public function refresh_search() public function refresh_search()
{ {
if (!empty($this->search_string)) { if (!empty($this->search_string)) {
// FIXME: make this work with saved multi-folder searches $this->search(
$this->search('', $this->search_string, $this->search_charset, $this->search_sort_field); is_object($this->search_set) ? $this->search_set->get_parameters('MAILBOX') : '',
$this->search_string,
$this->search_charset,
$this->search_sort_field
);
} }
return $this->get_search_set(); return $this->get_search_set();

@ -65,6 +65,8 @@ class rcube_imap_search
{ {
$pthreads = defined('PTHREADS_INHERIT_ALL'); $pthreads = defined('PTHREADS_INHERIT_ALL');
$results = new rcube_result_multifolder($folders);
// start a search job for every folder to search in // start a search job for every folder to search in
foreach ($folders as $folder) { foreach ($folders as $folder) {
$job = new rcube_imap_search_job($folder, $str, $charset, $sort_field, $threading); $job = new rcube_imap_search_job($folder, $str, $charset, $sort_field, $threading);
@ -82,7 +84,6 @@ class rcube_imap_search
$this->shutdown(); $this->shutdown();
// gather results // gather results
$results = new rcube_result_multifolder;
foreach ($this->jobs as $job) { foreach ($this->jobs as $job) {
$results->add($job->get_result()); $results->add($job->get_result());
} }

@ -74,6 +74,11 @@ class rcube_message
*/ */
function __construct($uid, $folder = null) function __construct($uid, $folder = null)
{ {
// decode combined UID-folder identifier
if (preg_match('/^\d+-[^,]+$/', $uid)) {
list($uid, $folder) = explode('-', $uid);
}
$this->uid = $uid; $this->uid = $uid;
$this->app = rcube::get_instance(); $this->app = rcube::get_instance();
$this->storage = $this->app->get_storage(); $this->storage = $this->app->get_storage();

@ -32,6 +32,7 @@ class rcube_result_multifolder
protected $meta = array(); protected $meta = array();
protected $index = array(); protected $index = array();
protected $folders = array();
protected $sorting; protected $sorting;
protected $order = 'ASC'; protected $order = 'ASC';
@ -39,8 +40,9 @@ class rcube_result_multifolder
/** /**
* Object constructor. * Object constructor.
*/ */
public function __construct() public function __construct($folders = array())
{ {
$this->folders = $folders;
$this->meta = array('count' => 0); $this->meta = array('count' => 0);
} }
@ -228,6 +230,7 @@ class rcube_result_multifolder
$params = array( $params = array(
'SORT' => $this->sorting, 'SORT' => $this->sorting,
'ORDER' => $this->order, 'ORDER' => $this->order,
'MAILBOX' => $this->folders,
); );
if ($param !== null) { if ($param !== null) {

@ -5,7 +5,7 @@
| program/steps/mail/check_recent.inc | | program/steps/mail/check_recent.inc |
| | | |
| This file is part of the Roundcube Webmail client | | This file is part of the Roundcube Webmail client |
| Copyright (C) 2005-2010, The Roundcube Dev Team | | Copyright (C) 2005-2014, The Roundcube Dev Team |
| | | |
| Licensed under the GNU General Public License version 3 or | | Licensed under the GNU General Public License version 3 or |
| any later version with exceptions for skins & plugins. | | any later version with exceptions for skins & plugins. |
@ -29,10 +29,17 @@ $trash = $RCMAIL->config->get('trash_mbox');
$current = $RCMAIL->storage->get_folder(); $current = $RCMAIL->storage->get_folder();
$check_all = $RCMAIL->action != 'refresh' || (bool)$RCMAIL->config->get('check_all_folders'); $check_all = $RCMAIL->action != 'refresh' || (bool)$RCMAIL->config->get('check_all_folders');
$search_request = rcube_utils::get_input_value('_search', rcube_utils::INPUT_GPC);
if ($search_request && $_SESSION['search_request'] != $search_request)
$search_request = null;
// list of folders to check // list of folders to check
if ($check_all) { if ($check_all) {
$a_mailboxes = $RCMAIL->storage->list_folders_subscribed('', '*', 'mail'); $a_mailboxes = $RCMAIL->storage->list_folders_subscribed('', '*', 'mail');
} }
else if ($search_request && is_object($_SESSION['search'][1])) {
$a_mailboxes = (array) $_SESSION['search'][1]->get_parameters('MAILBOX');
}
else { else {
$a_mailboxes = (array) $current; $a_mailboxes = (array) $current;
if ($current != 'INBOX') { if ($current != 'INBOX') {
@ -46,7 +53,7 @@ $a_mailboxes = $plugin['folders'];
// check recent/unseen counts // check recent/unseen counts
foreach ($a_mailboxes as $mbox_name) { foreach ($a_mailboxes as $mbox_name) {
$is_current = $mbox_name == $current; $is_current = $mbox_name == $current || ($search_request && is_object($_SESSION['search'][1]) && in_array($mbox_name, (array)$_SESSION['search'][1]->get_parameters('MAILBOX')));
if ($is_current) { if ($is_current) {
// Synchronize mailbox cache, handle flag changes // Synchronize mailbox cache, handle flag changes
$RCMAIL->storage->folder_sync($mbox_name); $RCMAIL->storage->folder_sync($mbox_name);
@ -66,11 +73,11 @@ foreach ($a_mailboxes as $mbox_name) {
if ($status && $is_current) { if ($status && $is_current) {
// refresh saved search set // refresh saved search set
$search_request = rcube_utils::get_input_value('_search', rcube_utils::INPUT_GPC); if ($search_request && isset($_SESSION['search'])) {
if ($search_request && isset($_SESSION['search']) unset($search_request); // only do this once
&& $_SESSION['search_request'] == $search_request
) {
$_SESSION['search'] = $RCMAIL->storage->refresh_search(); $_SESSION['search'] = $RCMAIL->storage->refresh_search();
if ($_SESSION['search'][1]->multi)
$mbox_name = '';
} }
if (!empty($_GET['_quota'])) if (!empty($_GET['_quota']))
@ -116,7 +123,7 @@ foreach ($a_mailboxes as $mbox_name) {
} }
} }
// handle flag updates // handle flag updates
else if ($is_current && ($uids = rcube_utils::get_input_value('_uids', rcube_utils::INPUT_GPC))) { else if ($is_current && ($uids = rcube_utils::get_input_value('_uids', rcube_utils::INPUT_GPC)) && empty($search_request)) {
$data = $RCMAIL->storage->folder_data($mbox_name); $data = $RCMAIL->storage->folder_data($mbox_name);
if (empty($_SESSION['list_mod_seq']) || $_SESSION['list_mod_seq'] != $data['HIGHESTMODSEQ']) { if (empty($_SESSION['list_mod_seq']) || $_SESSION['list_mod_seq'] != $data['HIGHESTMODSEQ']) {

@ -189,15 +189,17 @@ $RCMAIL->register_action_map(array(
/** /**
* Returns message UID(s) and IMAP folder(s) from GET/POST data * Returns message UID(s) and IMAP folder(s) from GET/POST data
* *
* @return array List of message UIDs per folder * @param string UID value to decode
* @param string Default mailbox value (if not encoded in UIDs)
* @return array List of message UIDs per folder
*/ */
function rcmail_get_uids() function rcmail_get_uids($uids = null, $mbox = null)
{ {
// message UID (or comma-separated list of IDs) is provided in // message UID (or comma-separated list of IDs) is provided in
// the form of <ID>-<MBOX>[,<ID>-<MBOX>]* // the form of <ID>-<MBOX>[,<ID>-<MBOX>]*
$_uid = get_input_value('_uid', RCUBE_INPUT_GPC); $_uid = $uids ?: get_input_value('_uid', RCUBE_INPUT_GPC);
$_mbox = (string)get_input_value('_mbox', RCUBE_INPUT_GPC); $_mbox = $mbox ?: (string)get_input_value('_mbox', RCUBE_INPUT_GPC);
if (is_array($uid)) { if (is_array($uid)) {
return $uid; return $uid;
@ -1770,7 +1772,8 @@ function rcmail_draftinfo_encode($p)
{ {
$parts = array(); $parts = array();
foreach ($p as $key => $val) { foreach ($p as $key => $val) {
$parts[] = $key . '=' . ($key == 'folder' ? base64_encode($val) : $val); $encode = $key == 'folder' || strpos($val, ';') !== false;
$parts[] = $key . '=' . ($encode ? 'B::' . base64_encode($val) : $val);
} }
return join('; ', $parts); return join('; ', $parts);
@ -1782,7 +1785,10 @@ function rcmail_draftinfo_decode($str)
foreach (preg_split('/;\s+/', $str) as $part) { foreach (preg_split('/;\s+/', $str) as $part) {
list($key, $val) = explode('=', $part, 2); list($key, $val) = explode('=', $part, 2);
if ($key == 'folder') { if (strpos($val, 'B::') === 0) {
$val = base64_decode(substr($val, 3));
}
else if ($key == 'folder') {
$val = base64_decode($val); $val = base64_decode($val);
} }

@ -534,10 +534,16 @@ if (!$savedraft) {
} }
// set replied/forwarded flag // set replied/forwarded flag
if ($COMPOSE['reply_uid']) if ($COMPOSE['reply_uid']) {
$RCMAIL->storage->set_flag($COMPOSE['reply_uid'], 'ANSWERED', $COMPOSE['mailbox']); foreach (rcmail_get_uids($COMPOSE['reply_uid'], $COMPOSE['mailbox']) as $mbox => $uids) {
else if ($COMPOSE['forward_uid']) $RCMAIL->storage->set_flag($uids, 'ANSWERED', $mbox);
$RCMAIL->storage->set_flag($COMPOSE['forward_uid'], 'FORWARDED', $COMPOSE['mailbox']); }
}
else if ($COMPOSE['forward_uid']) {
foreach (rcmail_get_uids($COMPOSE['forward_uid'], $COMPOSE['mailbox']) as $mbox => $uids) {
$RCMAIL->storage->set_flag($uids, 'FORWARDED', $mbox);
}
}
} }
// Determine which folder to save message // Determine which folder to save message

Loading…
Cancel
Save