| | |
| | | $a_msg_headers = array_slice(array_values($a_msg_headers), $from, $slice_length); |
| | | } |
| | | else { |
| | | if ($this->sort_order != $search_set->get_parameters('ORDER')) { |
| | | $search_set->revert(); |
| | | } |
| | | |
| | | // slice resultset first... |
| | | $fetch = array(); |
| | | foreach (array_slice($search_set->get(), $from, $slice_length) as $msg_id) { |
| | |
| | | * @param string $str Search criteria |
| | | * @param string $charset Search charset |
| | | * @param string $sort_field Header field to sort by |
| | | * |
| | | * @return rcube_result_index Search result object |
| | | * @todo: Search criteria should be provided in non-IMAP format, eg. array |
| | | */ |
| | | public function search($folder='', $str='ALL', $charset=NULL, $sort_field=NULL) |
| | |
| | | $this->threading = false; |
| | | |
| | | $searcher = new rcube_imap_search($this->options, $this->conn); |
| | | |
| | | // set limit to not exceed the client's request timeout |
| | | $searcher->set_timelimit(60); |
| | | |
| | | // continue existing incomplete search |
| | | if (!empty($this->search_set) && $this->search_set->incomplete && $str == $this->search_string) { |
| | | $searcher->set_results($this->search_set); |
| | | } |
| | | |
| | | // execute the search |
| | | $results = $searcher->exec( |
| | | $folder, |
| | | $str, |
| | |
| | | |
| | | $this->set_search_set(array($str, $results, $charset, $sort_field, |
| | | $this->threading || $this->search_sorted ? true : false)); |
| | | |
| | | return $results; |
| | | } |
| | | |
| | | |
| | |
| | | */ |
| | | public function search_once($folder = null, $str = 'ALL') |
| | | { |
| | | if (!$str) { |
| | | $str = 'ALL'; |
| | | } |
| | | |
| | | if (!strlen($folder)) { |
| | | $folder = $this->folder; |
| | | } |
| | | |
| | | if (!$this->check_connection()) { |
| | | return new rcube_result_index(); |
| | | } |
| | | |
| | | $index = $this->conn->search($folder, $str, true); |
| | | if (!$str) { |
| | | $str = 'ALL'; |
| | | } |
| | | |
| | | // multi-folder search |
| | | if (is_array($folder) && count($folder) > 1) { |
| | | $searcher = new rcube_imap_search($this->options, $this->conn); |
| | | $index = $searcher->exec($folder, $str, $this->default_charset); |
| | | } |
| | | else { |
| | | $folder = is_array($folder) ? $folder[0] : $folder; |
| | | if (!strlen($folder)) { |
| | | $folder = $this->folder; |
| | | } |
| | | $index = $this->conn->search($folder, $str, true); |
| | | } |
| | | |
| | | return $index; |
| | | } |
| | |
| | | return $this->get_search_set(); |
| | | } |
| | | |
| | | /** |
| | | * Flag certain result subsets as 'incomplete'. |
| | | * For subsequent refresh_search() calls to only refresh the updated parts. |
| | | */ |
| | | protected function set_search_dirty($folder) |
| | | { |
| | | if ($this->search_set && is_a($this->search_set, 'rcube_result_multifolder')) { |
| | | if ($subset = $this->search_set->get_set($folder)) { |
| | | $subset->incomplete = $this->search_set->incomplete = true; |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Return message headers object of a specific message |
| | |
| | | */ |
| | | public function get_message_headers($uid, $folder = null, $force = false) |
| | | { |
| | | if (!strlen($folder)) { |
| | | $folder = $this->folder; |
| | | // decode combined UID-folder identifier |
| | | if (preg_match('/^\d+-.+/', $uid)) { |
| | | list($uid, $folder) = explode('-', $uid, 2); |
| | | } |
| | | |
| | | // decode combined UID-folder identifier |
| | | if (preg_match('/^\d+-[^,]+$/', $uid)) { |
| | | list($uid, $folder) = explode('-', $uid, 2); |
| | | if (!strlen($folder)) { |
| | | $folder = $this->folder; |
| | | } |
| | | |
| | | // get cached headers |
| | |
| | | else { |
| | | $headers = $this->conn->fetchHeader( |
| | | $folder, $uid, true, true, $this->get_fetch_headers()); |
| | | |
| | | if (is_object($headers)) |
| | | $headers->folder = $folder; |
| | | } |
| | | |
| | | return $headers; |
| | |
| | | } |
| | | |
| | | // decode combined UID-folder identifier |
| | | if (preg_match('/^\d+-[^,]+$/', $uid)) { |
| | | if (preg_match('/^\d+-.+/', $uid)) { |
| | | list($uid, $folder) = explode('-', $uid, 2); |
| | | } |
| | | |
| | |
| | | $this->clear_message_cache($folder, $all_mode ? null : explode(',', $uids)); |
| | | } |
| | | } |
| | | |
| | | $this->set_search_dirty($folder); |
| | | } |
| | | |
| | | return $result; |
| | |
| | | if ($saved) { |
| | | // increase messagecount of the target folder |
| | | $this->set_messagecount($folder, 'ALL', 1); |
| | | |
| | | rcube::get_instance()->plugins->exec_hook('message_saved', array( |
| | | 'folder' => $folder, |
| | | 'message' => $message, |
| | | 'headers' => $headers, |
| | | 'is_file' => $is_file, |
| | | 'flags' => $flags, |
| | | 'date' => $date, |
| | | 'binary' => $binary, |
| | | 'result' => $saved, |
| | | )); |
| | | } |
| | | |
| | | return $saved; |
| | |
| | | if ($moved) { |
| | | $this->clear_messagecount($from_mbox); |
| | | $this->clear_messagecount($to_mbox); |
| | | |
| | | $this->set_search_dirty($from_mbox); |
| | | $this->set_search_dirty($to_mbox); |
| | | } |
| | | // moving failed |
| | | else if ($to_trash && $config->get('delete_always', false)) { |
| | |
| | | if ($this->search_threads || $all_mode) { |
| | | $this->refresh_search(); |
| | | } |
| | | else { |
| | | else if (!$this->search_set->incomplete) { |
| | | $this->search_set->filter(explode(',', $uids), $this->folder); |
| | | } |
| | | } |
| | |
| | | // unset threads internal cache |
| | | unset($this->icache['threads']); |
| | | |
| | | $this->set_search_dirty($folder); |
| | | |
| | | // remove message ids from search set |
| | | if ($this->search_set && $folder == $this->folder) { |
| | | // threads are too complicated to just remove messages from set |
| | | if ($this->search_threads || $all_mode) { |
| | | $this->refresh_search(); |
| | | } |
| | | else { |
| | | else if (!$this->search_set->incomplete) { |
| | | $this->search_set->filter(explode(',', $uids)); |
| | | } |
| | | } |