- Fix check_recent action when skip_deleted=true (#1486535)

alecpl

2010-03-05 a4f77800443173a73ff05a172ac6b0dd4d5e9a42

 program/include/rcube_imap.php

@@ -56,7 +56,6 @@
  var $default_charset = 'ISO-8859-1';
  var $struct_charset = NULL;
  var $default_folders = array('INBOX');
  var $default_folders_lc = array('inbox');
  var $fetch_add_headers = '';
  var $cache = array();
  var $cache_keys = array();  
@@ -242,15 +241,10 @@
    if (is_array($arr))
      {
      $this->default_folders = $arr;
      $this->default_folders_lc = array();

      // add inbox if not included
      if (!in_array_nocase('INBOX', $this->default_folders))
      if (!in_array('INBOX', $this->default_folders))
        array_unshift($this->default_folders, 'INBOX');

      // create a second list with lower cased names
      foreach ($this->default_folders as $mbox)
        $this->default_folders_lc[] = strtolower($mbox);
      }
    }

@@ -415,7 +409,7 @@
      }

    // INBOX should always be available
    if (!in_array_nocase('INBOX', $a_out))
    if (!in_array('INBOX', $a_out))
      array_unshift($a_out, 'INBOX');

    // sort mailboxes
@@ -501,6 +495,9 @@
    if (!$force && is_array($a_mailbox_cache[$mailbox]) && isset($a_mailbox_cache[$mailbox][$mode]))
      return $a_mailbox_cache[$mailbox][$mode];

    if (!is_array($a_mailbox_cache[$mailbox]))
      $a_mailbox_cache[$mailbox] = array();

    // RECENT count is fetched a bit different
    if ($mode == 'RECENT')
       $count = iil_C_CheckForRecent($this->conn, $mailbox);
@@ -518,18 +515,19 @@
      // not very performant but more precise (using UNDELETED)
      $index = $this->_search_index($mailbox, $search_str);
      $count = is_array($index) ? count($index) : 0;

      if ($mode == 'ALL')
        $_SESSION['maxuid'][$mailbox] = $index ? $this->_id2uid(max($index)) : 0;
      }
    else
      {
    else {
      if ($mode == 'UNSEEN')
        $count = iil_C_CountUnseen($this->conn, $mailbox);
      else
      else {
        $count = iil_C_CountMessages($this->conn, $mailbox);
        $_SESSION['maxuid'][$mailbox] = $count ? $this->_id2uid($count) : 0;
      }
    }

    if (!is_array($a_mailbox_cache[$mailbox]))
      $a_mailbox_cache[$mailbox] = array();
      
    $a_mailbox_cache[$mailbox][$mode] = (int)$count;

    // write back to cache
@@ -604,22 +602,24 @@
      {
        if ($this->skip_deleted) {
          // @TODO: this could be cached
     if ($msg_index = $this->_search_index($mailbox, 'ALL UNDELETED')) {
          if ($msg_index = $this->_search_index($mailbox, 'ALL UNDELETED')) {
            $max = max($msg_index);
            list($begin, $end) = $this->_get_message_range(count($msg_index), $page);
            $msg_index = array_slice($msg_index, $begin, $end-$begin);
       }
   } else if ($max = iil_C_CountMessages($this->conn, $mailbox)) {
          }
        }
        else if ($max = iil_C_CountMessages($this->conn, $mailbox)) {
          list($begin, $end) = $this->_get_message_range($max, $page);
     $msg_index = range($begin+1, $end);
   } else
     $msg_index = array();
          $msg_index = range($begin+1, $end);
        }
        else
          $msg_index = array();

        if ($slice)
          $msg_index = array_slice($msg_index, ($this->sort_order == 'DESC' ? 0 : -$slice), $slice);

        // fetch reqested headers from server
   if ($msg_index)
        if ($msg_index)
          $this->_fetch_headers($mailbox, join(",", $msg_index), $a_msg_headers, $cache_key);
      }
    // use SORT command
@@ -754,12 +754,12 @@
      // 300: experimantal value for best result
      if (($cnt > 300 && $cnt > $this->page_size) || ($this->index_sort && $this->sort_field == 'date')) {
        // use memory less expensive (and quick) method for big result set
   $a_index = $this->message_index('', $this->sort_field, $this->sort_order);
        $a_index = $this->message_index('', $this->sort_field, $this->sort_order);
        // get messages uids for one page...
        $msgs = array_slice($a_index, $start_msg, min($cnt-$start_msg, $this->page_size));
        if ($slice)
          $msgs = array_slice($msgs, -$slice, $slice);
   // ...and fetch headers
        // ...and fetch headers
        $this->_fetch_headers($mailbox, join(',', $msgs), $a_msg_headers, NULL);

        // return empty array if no messages found
@@ -771,7 +771,7 @@
        $sorter->sort_headers($a_msg_headers);

        return array_values($a_msg_headers);
        }
      }
      else {
        // for small result set we can fetch all messages headers
        $this->_fetch_headers($mailbox, join(',', $msgs), $a_msg_headers, NULL);
@@ -782,9 +782,9 @@

        // if not already sorted
        $a_msg_headers = iil_SortHeaders($a_msg_headers, $this->sort_field, $this->sort_order);
      

        // only return the requested part of the set
   $a_msg_headers = array_slice(array_values($a_msg_headers), $start_msg, min($cnt-$start_msg, $this->page_size));
        $a_msg_headers = array_slice(array_values($a_msg_headers), $start_msg, min($cnt-$start_msg, $this->page_size));
        if ($slice)
          $a_msg_headers = array_slice($a_msg_headers, -$slice, $slice);

@@ -853,15 +853,15 @@

      foreach ($a_header_index as $i => $headers) {
        if ($this->caching_enabled && $cache_index[$headers->id] != $headers->uid) {
     // prevent index duplicates
     if ($cache_index[$headers->id]) {
       $this->remove_message_cache($cache_key, $headers->id, true);
       unset($cache_index[$headers->id]);
       }
          // prevent index duplicates
          if ($cache_index[$headers->id]) {
            $this->remove_message_cache($cache_key, $headers->id, true);
            unset($cache_index[$headers->id]);
          }
          // add message to cache
     $this->add_message_cache($cache_key, $headers->id, $headers, NULL,
       !in_array($headers->uid, $cache_index));
     }
          $this->add_message_cache($cache_key, $headers->id, $headers, NULL,
            !in_array($headers->uid, $cache_index));
        }

        $a_msg_headers[$headers->uid] = $headers;
        }
@@ -869,7 +869,31 @@

    return count($a_msg_headers);
    }
  
  /**
   * Fetches IDS of pseudo recent messages.
   *
   * We compare the maximum UID to determine the number of
   * new messages because the RECENT flag is not reliable.
   *
   * @param string  Mailbox/folder name
   * @return array  List of recent message UIDs
   */
  function recent_uids($mbox_name = null, $nofetch = false)
  {
    $mailbox = $mbox_name ? $this->mod_mailbox($mbox_name) : $this->mailbox;
    $old_maxuid = intval($_SESSION['maxuid'][$mailbox]);
    
    // refresh message count -> will update $_SESSION['maxuid'][$mailbox]
    $this->_messagecount($mailbox, 'ALL', true);
    
    if ($_SESSION['maxuid'][$mailbox] > $old_maxuid) {
      $maxuid = max(1, $old_maxuid+1);
      return array_values((array)iil_C_FetchHeaderIndex($this->conn, $mailbox, "$maxuid:*", 'UID', $this->skip_deleted, true));
    }
    
    return array();
  }
  
  /**
   * Return sorted array of message IDs (not UIDs)
@@ -893,20 +917,20 @@
      
      // use message index sort for sorting by Date
      if ($this->index_sort && $this->sort_field == 'date')
        {
   $msgs = $this->search_set;
	
   if ($this->search_sort_field != 'date')
     sort($msgs);
	
      {
        $msgs = $this->search_set;

        if ($this->search_sort_field != 'date')
          sort($msgs);

        if ($this->sort_order == 'DESC')
          $this->cache[$key] = array_reverse($msgs);
        else
          $this->cache[$key] = $msgs;
        }
      }
      // sort with SORT command
      else if ($this->get_capability('sort'))
        {
      {
        if ($this->sort_field && $this->search_sort_field != $this->sort_field)
          $this->search('', $this->search_string, $this->search_charset, $this->sort_field);

@@ -914,9 +938,9 @@
          $this->cache[$key] = array_reverse($this->search_set);
        else
          $this->cache[$key] = $this->search_set;
        }
      }
      else
        {
      {
        $a_index = iil_C_FetchHeaderIndex($this->conn, $mailbox, join(',', $this->search_set), $this->sort_field, $this->skip_deleted);

        if ($this->sort_order=="ASC")
@@ -925,7 +949,7 @@
          arsort($a_index);

        $this->cache[$key] = array_keys($a_index);
   }
      }
    }

    // have stored it in RAM
@@ -1013,11 +1037,11 @@
      // other message at this position
      if (isset($cache_index[$id]))
        {
   $for_remove[] = $cache_index[$id];
        $for_remove[] = $cache_index[$id];
        unset($cache_index[$id]);
        }
        
   $for_update[] = $id;
        $for_update[] = $id;
      }

    // clear messages at wrong positions and those deleted that are still in cache_index      
@@ -1032,7 +1056,7 @@
      if ($headers = iil_C_FetchHeader($this->conn, $mailbox, join(',', $for_update), false, $this->fetch_add_headers))
        foreach ($headers as $header)
          $this->add_message_cache($cache_key, $header->id, $header, NULL,
      in_array($header->uid, (array)$for_remove));
            in_array($header->uid, (array)$for_remove));
      }
    }

@@ -1059,28 +1083,28 @@
    // try search with US-ASCII charset (should be supported by server)
    // only if UTF-8 search is not supported
    if (empty($results) && !is_array($results) && !empty($charset) && $charset != 'US-ASCII')
    {
      // convert strings to US_ASCII
      if(preg_match_all('/\{([0-9]+)\}\r\n/', $str, $matches, PREG_OFFSET_CAPTURE))
      {
   // convert strings to US_ASCII
        if(preg_match_all('/\{([0-9]+)\}\r\n/', $str, $matches, PREG_OFFSET_CAPTURE))
     {
     $last = 0; $res = '';
     foreach($matches[1] as $m)
       {
       $string_offset = $m[1] + strlen($m[0]) + 4; // {}\r\n
       $string = substr($str, $string_offset - 1, $m[0]);
       $string = rcube_charset_convert($string, $charset, 'US-ASCII');
       if (!$string) continue;
       $res .= sprintf("%s{%d}\r\n%s", substr($str, $last, $m[1] - $last - 1), strlen($string), $string);
       $last = $m[0] + $string_offset - 1;
       }
       if ($last < strlen($str))
         $res .= substr($str, $last, strlen($str)-$last);
     }
   else // strings for conversion not found
     $res = $str;
	  
   $results = $this->search($mbox_name, $res, NULL, $sort_field);
        $last = 0; $res = '';
        foreach($matches[1] as $m)
        {
          $string_offset = $m[1] + strlen($m[0]) + 4; // {}\r\n
          $string = substr($str, $string_offset - 1, $m[0]);
          $string = rcube_charset_convert($string, $charset, 'US-ASCII');
          if (!$string) continue;
          $res .= sprintf("%s{%d}\r\n%s", substr($str, $last, $m[1] - $last - 1), strlen($string), $string);
          $last = $m[0] + $string_offset - 1;
        }
        if ($last < strlen($str))
          $res .= substr($str, $last, strlen($str)-$last);
      }
      else // strings for conversion not found
      $res = $str;

      $results = $this->search($mbox_name, $res, NULL, $sort_field);
    }

    $this->set_search_set($str, $results, $charset, $sort_field);

@@ -1230,9 +1254,9 @@
      // Example of structure for malformed MIME message:
      // ("text" "plain" ("charset" "us-ascii") NIL NIL "7bit" 2154 70 NIL NIL NIL)
      if ($headers->ctype && $headers->ctype != 'text/plain'
     && $structure[0] == 'text' && $structure[1] == 'plain') {
   return false;  
   }
          && $structure[0] == 'text' && $structure[1] == 'plain') {
        return false;
      }

      $struct = &$this->_structure_part($structure);
      $struct->headers = get_object_vars($headers);
@@ -1283,17 +1307,17 @@
      for ($i=0, $count=0; $i<count($part); $i++)
        if (is_array($part[$i]) && count($part[$i]) > 3) {
          // fetch message headers if message/rfc822 or named part (could contain Content-Location header)
     if (!is_array($part[$i][0])) {
          if (!is_array($part[$i][0])) {
            $tmp_part_id = $struct->mime_id ? $struct->mime_id.'.'.($i+1) : $i+1;
            if (strtolower($part[$i][0]) == 'message' && strtolower($part[$i][1]) == 'rfc822') {
         $raw_part_headers[] = $tmp_part_id;
         $mime_part_headers[] = $tmp_part_id;
              }
              $raw_part_headers[] = $tmp_part_id;
              $mime_part_headers[] = $tmp_part_id;
            }
            else if (in_array('name', (array)$part[$i][2]) && (empty($part[$i][3]) || $part[$i][3]=='NIL')) {
         $mime_part_headers[] = $tmp_part_id;
         }
              $mime_part_headers[] = $tmp_part_id;
            }
          }
        }
        
      // pre-fetch headers of all parts (in one command for better performance)
      // @TODO: we could do this before _structure_part() call, to fetch
@@ -1311,8 +1335,8 @@
        if (is_array($part[$i]) && count($part[$i]) > 3) {
          $tmp_part_id = $struct->mime_id ? $struct->mime_id.'.'.($i+1) : $i+1;
          $struct->parts[] = $this->_structure_part($part[$i], ++$count, $struct->mime_id,
       $mime_part_headers[$tmp_part_id], $raw_part_headers[$tmp_part_id]);
   }
            $mime_part_headers[$tmp_part_id], $raw_part_headers[$tmp_part_id]);
        }

      return $struct;
      }
@@ -1433,7 +1457,7 @@
      // some servers (eg. dovecot-1.x) have no support for parameter value continuations
      // we must fetch and parse headers "manually"
      if ($i<2) {
   if (!$headers)
        if (!$headers)
          $headers = iil_C_FetchPartHeader($this->conn, $this->mailbox, $this->_msg_id, false, $part->mime_id);
        $filename_mime = '';
        $i = 0;
@@ -1450,7 +1474,7 @@
        $i++;
      }
      if ($i<2) {
   if (!$headers)
        if (!$headers)
          $headers = iil_C_FetchPartHeader($this->conn, $this->mailbox, $this->_msg_id, false, $part->mime_id);
        $filename_encoded = '';
        $i = 0; $matches = array();
@@ -1467,7 +1491,7 @@
        $i++;
      }
      if ($i<2) {
   if (!$headers)
        if (!$headers)
          $headers = iil_C_FetchPartHeader($this->conn, $this->mailbox, $this->_msg_id, false, $part->mime_id);
        $filename_mime = '';
        $i = 0; $matches = array();
@@ -1484,7 +1508,7 @@
        $i++;
      }
      if ($i<2) {
   if (!$headers)
        if (!$headers)
          $headers = iil_C_FetchPartHeader($this->conn, $this->mailbox, $this->_msg_id, false, $part->mime_id);
        $filename_encoded = '';
        $i = 0; $matches = array();
@@ -1506,8 +1530,8 @@
    // decode filename
    if (!empty($filename_mime)) {
      $part->filename = rcube_imap::decode_mime_string($filename_mime, 
        $part->charset ? $part->charset : $this->struct_charset ? $this->struct_charset :
       rc_detect_encoding($filename_mime, $this->default_charset));
        $part->charset ? $part->charset : ($this->struct_charset ? $this->struct_charset :
          rc_detect_encoding($filename_mime, $this->default_charset)));
      } 
    else if (!empty($filename_encoded)) {
      // decode filename according to RFC 2231, Section 4
@@ -1530,10 +1554,10 @@
  function _structure_charset($structure)
    {
      while (is_array($structure)) {
   if (is_array($structure[2]) && $structure[2][0] == 'charset')
     return $structure[2][1];
   $structure = $structure[0];
   }
        if (is_array($structure[2]) && $structure[2][0] == 'charset')
          return $structure[2][1];
        $structure = $structure[0];
      }
    } 


@@ -1772,7 +1796,7 @@
    // move messages
    $iil_move = iil_C_Move($this->conn, join(',', $a_uids), $from_mbox, $to_mbox);
    $moved = !($iil_move === false || $iil_move < 0);
    

    // send expunge command in order to have the moved message
    // really deleted from the source mailbox
    if ($moved) {
@@ -1781,8 +1805,8 @@
      $this->_clear_messagecount($to_mbox);
    }
    // moving failed
    else if (rcmail::get_instance()->config->get('delete_always', false)) {
      return iil_C_Delete($this->conn, $from_mbox, join(',', $a_uids));
    else if ($config->get('delete_always', false) && $tbox == $config->get('trash_mbox')) {
      return $this->delete_message($a_uids, $fbox);
    }

    // remove message ids from search set
@@ -2947,7 +2971,7 @@
      if ($folder{0}=='.')
        continue;

      if (($p = array_search(strtolower($folder), $this->default_folders_lc)) !== false && !$a_defaults[$p])
      if (($p = array_search($folder, $this->default_folders)) !== false && !$a_defaults[$p])
        $a_defaults[$p] = $folder;
      else
        $folders[$folder] = mb_strtolower(rcube_charset_convert($folder, 'UTF7-IMAP'));