| | |
| | | // send result |
| | | $this->putLine($reply); |
| | | $line = $this->readLine(1024); |
| | | |
| | | |
| | | if ($line[0] == '+') { |
| | | $challenge = substr($line, 2); |
| | | } |
| | |
| | | if (array_key_exists('namespace', $this->prefs)) { |
| | | return $this->prefs['namespace']; |
| | | } |
| | | |
| | | |
| | | if (!$this->getCapability('NAMESPACE')) { |
| | | return self::ERROR_BAD; |
| | | } |
| | |
| | | * Executes STATUS comand |
| | | * |
| | | * @param string $mailbox Mailbox name |
| | | * @param array $items Requested item names |
| | | * @param array $items Additional requested item names. By default |
| | | * MESSAGES and UNSEEN are requested. Other defined |
| | | * in RFC3501: UIDNEXT, UIDVALIDITY, RECENT |
| | | * |
| | | * @return array Status item-value hash |
| | | * @access public |
| | | * @since 0.5-beta |
| | | */ |
| | | function status($mailbox, $items) |
| | | function status($mailbox, $items=array()) |
| | | { |
| | | if (empty($mailbox) || empty($items)) { |
| | | if (empty($mailbox)) { |
| | | return false; |
| | | } |
| | | |
| | | if (!in_array('MESSAGES', $items)) { |
| | | $items[] = 'MESSAGES'; |
| | | } |
| | | if (!in_array('UNSEEN', $items)) { |
| | | $items[] = 'UNSEEN'; |
| | | } |
| | | |
| | | list($code, $response) = $this->execute('STATUS', array($this->escape($mailbox), |
| | | '(' . implode(' ', (array) $items) . ')')); |
| | |
| | | for ($i=0, $len=count($items); $i<$len; $i += 2) { |
| | | $result[$items[$i]] = (int) $items[$i+1]; |
| | | } |
| | | |
| | | $this->data['STATUS:'.$mailbox] = $result; |
| | | |
| | | return $result; |
| | | } |
| | |
| | | return $this->data['EXISTS']; |
| | | } |
| | | |
| | | // Try STATUS, should be faster |
| | | $counts = $this->status($mailbox, array('MESSAGES')); |
| | | // Check internal cache |
| | | $cache = $this->data['STATUS:'.$mailbox]; |
| | | if (!empty($cache) && isset($cache['MESSAGES'])) { |
| | | return (int) $cache['MESSAGES']; |
| | | } |
| | | |
| | | // Try STATUS (should be faster than SELECT) |
| | | $counts = $this->status($mailbox); |
| | | if (is_array($counts)) { |
| | | return (int) $counts['MESSAGES']; |
| | | } |
| | |
| | | */ |
| | | function countUnseen($mailbox) |
| | | { |
| | | // Try STATUS, should be faster |
| | | $counts = $this->status($mailbox, array('UNSEEN')); |
| | | // Check internal cache |
| | | $cache = $this->data['STATUS:'.$mailbox]; |
| | | if (!empty($cache) && isset($cache['UNSEEN'])) { |
| | | return (int) $cache['UNSEEN']; |
| | | } |
| | | |
| | | // Try STATUS (should be faster than SELECT+SEARCH) |
| | | $counts = $this->status($mailbox); |
| | | if (is_array($counts)) { |
| | | return (int) $counts['UNSEEN']; |
| | | } |
| | |
| | | return null; |
| | | } |
| | | |
| | | if (!$this->select($folder)) { |
| | | if (!$this->select($mailbox)) { |
| | | return null; |
| | | } |
| | | |
| | |
| | | return false; |
| | | } |
| | | do { |
| | | $line = $this->readLine(1024); |
| | | $line = $this->readLine(4096); |
| | | $line = $this->multLine($line); |
| | | |
| | | if (!$line) |
| | |
| | | if ($field == 'date' || $field == 'internaldate') { |
| | | $field = 'timestamp'; |
| | | } |
| | | |
| | | if (empty($flag)) { |
| | | $flag = 'ASC'; |
| | | } else { |
| | | $flag = strtoupper($flag); |
| | | } |
| | | |
| | | $stripArr = ($field=='subject') ? array('Re: ','Fwd: ','Fw: ','"') : array('"'); |
| | | |
| | | $c = count($a); |
| | | if ($c > 0) { |
| | | |
| | | // Strategy: |
| | | // First, we'll create an "index" array. |
| | | // Then, we'll use sort() on that array, |
| | |
| | | } else { |
| | | $data = $val->$field; |
| | | if (is_string($data)) { |
| | | $data = strtoupper(str_replace($stripArr, '', $data)); |
| | | $data = str_replace('"', '', $data); |
| | | if ($field == 'subject') { |
| | | $data = preg_replace('/^(Re: \s*|Fwd:\s*|Fw:\s*)+/i', '', $data); |
| | | } |
| | | $data = strtoupper($data); |
| | | } |
| | | } |
| | | $index[$key]=$data; |
| | | $index[$key] = $data; |
| | | } |
| | | |
| | | // sort index |
| | | $i = 0; |
| | | if ($flag == 'ASC') { |
| | | asort($index); |
| | | } else { |
| | |
| | | $result = array(); |
| | | reset($index); |
| | | while (list($key, $val) = each($index)) { |
| | | $result[$key]=$a[$key]; |
| | | $i++; |
| | | $result[$key] = $a[$key]; |
| | | } |
| | | } |
| | | |
| | |
| | | if (!$this->select($mailbox)) { |
| | | return false; |
| | | } |
| | | |
| | | // Clear internal status cache |
| | | unset($this->data['STATUS:'.$mailbox]); |
| | | |
| | | $result = $this->execute($messages ? 'UID EXPUNGE' : 'EXPUNGE', |
| | | array($messages), self::COMMAND_NORESPONSE); |
| | |
| | | if (!$this->select($mailbox)) { |
| | | return false; |
| | | } |
| | | |
| | | // Clear internal status cache |
| | | if ($flag == 'SEEN') { |
| | | unset($this->data['STATUS:'.$mailbox]['UNSEEN']); |
| | | } |
| | | |
| | | $flag = $this->flags[strtoupper($flag)]; |
| | | $result = $this->execute('UID STORE', array( |
| | |
| | | return false; |
| | | } |
| | | |
| | | // Clear internal status cache |
| | | unset($this->data['STATUS:'.$to]); |
| | | |
| | | $result = $this->execute('UID COPY', array( |
| | | $this->compressMessageSet($messages), $this->escape($to)), |
| | | self::COMMAND_NORESPONSE); |
| | |
| | | $r = $this->copy($messages, $from, $to); |
| | | |
| | | if ($r) { |
| | | // Clear internal status cache |
| | | unset($this->data['STATUS:'.$from]); |
| | | |
| | | return $this->delete($from, $messages); |
| | | } |
| | | return $r; |
| | |
| | | return $node; |
| | | } |
| | | |
| | | function thread($folder, $algorithm='REFERENCES', $criteria='', $encoding='US-ASCII') |
| | | function thread($mailbox, $algorithm='REFERENCES', $criteria='', $encoding='US-ASCII') |
| | | { |
| | | $old_sel = $this->selected; |
| | | |
| | | if (!$this->select($folder)) { |
| | | if (!$this->select($mailbox)) { |
| | | return false; |
| | | } |
| | | |
| | | // return empty result when folder is empty and we're just after SELECT |
| | | if ($old_sel != $folder && !$this->data['EXISTS']) { |
| | | if ($old_sel != $mailbox && !$this->data['EXISTS']) { |
| | | return array(array(), array(), array()); |
| | | } |
| | | |
| | |
| | | $cmd = strtoupper($this->tokenizeResponse($response, 1)); |
| | | // * LIST (<options>) <delimiter> <mailbox> |
| | | if (!$lstatus || $cmd == 'LIST' || $cmd == 'LSUB') { |
| | | list($opts, $delim, $folder) = $this->tokenizeResponse($response, 3); |
| | | list($opts, $delim, $mailbox) = $this->tokenizeResponse($response, 3); |
| | | |
| | | // Add to result array |
| | | if (!$lstatus) { |
| | | $folders[] = $folder; |
| | | $folders[] = $mailbox; |
| | | } |
| | | else { |
| | | $folders[$folder] = array(); |
| | | $folders[$mailbox] = array(); |
| | | } |
| | | |
| | | // Add to options array |
| | | if (!empty($opts)) { |
| | | if (empty($this->data['LIST'][$folder])) |
| | | $this->data['LIST'][$folder] = $opts; |
| | | if (empty($this->data['LIST'][$mailbox])) |
| | | $this->data['LIST'][$mailbox] = $opts; |
| | | else |
| | | $this->data['LIST'][$folder] = array_unique(array_merge( |
| | | $this->data['LIST'][$folder], $opts)); |
| | | $this->data['LIST'][$mailbox] = array_unique(array_merge( |
| | | $this->data['LIST'][$mailbox], $opts)); |
| | | } |
| | | } |
| | | // * STATUS <mailbox> (<result>) |
| | | else if ($cmd == 'STATUS') { |
| | | list($folder, $status) = $this->tokenizeResponse($response, 2); |
| | | list($mailbox, $status) = $this->tokenizeResponse($response, 2); |
| | | |
| | | for ($i=0, $len=count($status); $i<$len; $i += 2) { |
| | | list($name, $value) = $this->tokenizeResponse($status, 2); |
| | | $folders[$folder][$name] = $value; |
| | | $folders[$mailbox][$name] = $value; |
| | | } |
| | | } |
| | | } |
| | |
| | | return false; |
| | | } |
| | | |
| | | function createFolder($folder) |
| | | function createFolder($mailbox) |
| | | { |
| | | $result = $this->execute('CREATE', array($this->escape($folder)), |
| | | $result = $this->execute('CREATE', array($this->escape($mailbox)), |
| | | self::COMMAND_NORESPONSE); |
| | | |
| | | return ($result == self::ERROR_OK); |
| | |
| | | return ($result == self::ERROR_OK); |
| | | } |
| | | |
| | | function deleteFolder($folder) |
| | | function deleteFolder($mailbox) |
| | | { |
| | | $result = $this->execute('DELETE', array($this->escape($folder)), |
| | | $result = $this->execute('DELETE', array($this->escape($mailbox)), |
| | | self::COMMAND_NORESPONSE); |
| | | |
| | | return ($result == self::ERROR_OK); |
| | | } |
| | | |
| | | function clearFolder($folder) |
| | | function clearFolder($mailbox) |
| | | { |
| | | $num_in_trash = $this->countMessages($folder); |
| | | $num_in_trash = $this->countMessages($mailbox); |
| | | if ($num_in_trash > 0) { |
| | | $this->delete($folder, '1:*'); |
| | | $this->delete($mailbox, '1:*'); |
| | | } |
| | | return ($this->expunge($folder) >= 0); |
| | | return ($this->expunge($mailbox) >= 0); |
| | | } |
| | | |
| | | function subscribe($folder) |
| | | function subscribe($mailbox) |
| | | { |
| | | $result = $this->execute('SUBSCRIBE', array($this->escape($folder)), |
| | | $result = $this->execute('SUBSCRIBE', array($this->escape($mailbox)), |
| | | self::COMMAND_NORESPONSE); |
| | | |
| | | return ($result == self::ERROR_OK); |
| | | } |
| | | |
| | | function unsubscribe($folder) |
| | | function unsubscribe($mailbox) |
| | | { |
| | | $result = $this->execute('UNSUBSCRIBE', array($this->escape($folder)), |
| | | $result = $this->execute('UNSUBSCRIBE', array($this->escape($mailbox)), |
| | | self::COMMAND_NORESPONSE); |
| | | |
| | | return ($result == self::ERROR_OK); |
| | | } |
| | | |
| | | function append($folder, &$message) |
| | | function append($mailbox, &$message) |
| | | { |
| | | if (!$folder) { |
| | | if (!$mailbox) { |
| | | return false; |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | $key = $this->next_tag(); |
| | | $request = sprintf("$key APPEND %s (\\Seen) {%d%s}", $this->escape($folder), |
| | | $request = sprintf("$key APPEND %s (\\Seen) {%d%s}", $this->escape($mailbox), |
| | | $len, ($this->prefs['literal+'] ? '+' : '')); |
| | | |
| | | if ($this->putLine($request)) { |
| | |
| | | $line = $this->readLine(); |
| | | } while (!$this->startsWith($line, $key, true, true)); |
| | | |
| | | // Clear internal status cache |
| | | unset($this->data['STATUS:'.$mailbox]); |
| | | |
| | | return ($this->parseResult($line, 'APPEND: ') == self::ERROR_OK); |
| | | } |
| | | else { |
| | |
| | | return false; |
| | | } |
| | | |
| | | function appendFromFile($folder, $path, $headers=null) |
| | | function appendFromFile($mailbox, $path, $headers=null) |
| | | { |
| | | if (!$folder) { |
| | | if (!$mailbox) { |
| | | return false; |
| | | } |
| | | |
| | |
| | | |
| | | // send APPEND command |
| | | $key = $this->next_tag(); |
| | | $request = sprintf("$key APPEND %s (\\Seen) {%d%s}", $this->escape($folder), |
| | | $request = sprintf("$key APPEND %s (\\Seen) {%d%s}", $this->escape($mailbox), |
| | | $len, ($this->prefs['literal+'] ? '+' : '')); |
| | | |
| | | if ($this->putLine($request)) { |
| | |
| | | $line = $this->readLine(); |
| | | } while (!$this->startsWith($line, $key, true, true)); |
| | | |
| | | // Clear internal status cache |
| | | unset($this->data['STATUS:'.$mailbox]); |
| | | |
| | | return ($this->parseResult($line, 'APPEND: ') == self::ERROR_OK); |
| | | } |
| | |
| | | return false; |
| | | } |
| | | |
| | | function fetchStructureString($folder, $id, $is_uid=false) |
| | | function fetchStructureString($mailbox, $id, $is_uid=false) |
| | | { |
| | | if (!$this->select($folder)) { |
| | | if (!$this->select($mailbox)) { |
| | | return false; |
| | | } |
| | | |