Файл: concrete5.7.5.6/concrete/vendor/zendframework/zend-mail/src/Storage/Imap.php
Строк: 639
<?php
/**
* Zend Framework (http://framework.zend.com/)
*
* @link http://github.com/zendframework/zf2 for the canonical source repository
* @copyright Copyright (c) 2005-2014 Zend Technologies USA Inc. (http://www.zend.com)
* @license http://framework.zend.com/license/new-bsd New BSD License
*/
namespace ZendMailStorage;
use ZendMail;
use ZendMailProtocol;
class Imap extends AbstractStorage implements FolderFolderInterface, WritableWritableInterface
{
// TODO: with an internal cache we could optimize this class, or create an extra class with
// such optimizations. Especially the various fetch calls could be combined to one cache call
/**
* protocol handler
* @var null|ZendMailProtocolImap
*/
protected $protocol;
/**
* name of current folder
* @var string
*/
protected $currentFolder = '';
/**
* IMAP flags to constants translation
* @var array
*/
protected static $knownFlags = array('Passed' => MailStorage::FLAG_PASSED,
'Answered' => MailStorage::FLAG_ANSWERED,
'Seen' => MailStorage::FLAG_SEEN,
'Deleted' => MailStorage::FLAG_DELETED,
'Draft' => MailStorage::FLAG_DRAFT,
'Flagged' => MailStorage::FLAG_FLAGGED);
/**
* IMAP flags to search criteria
* @var array
*/
protected static $searchFlags = array('Recent' => 'RECENT',
'Answered' => 'ANSWERED',
'Seen' => 'SEEN',
'Deleted' => 'DELETED',
'Draft' => 'DRAFT',
'Flagged' => 'FLAGGED');
/**
* Count messages all messages in current box
*
* @param null $flags
* @throws ExceptionRuntimeException
* @throws ZendMailProtocolExceptionRuntimeException
* @return int number of messages
*/
public function countMessages($flags = null)
{
if (!$this->currentFolder) {
throw new ExceptionRuntimeException('No selected folder to count');
}
if ($flags === null) {
return count($this->protocol->search(array('ALL')));
}
$params = array();
foreach ((array) $flags as $flag) {
if (isset(static::$searchFlags[$flag])) {
$params[] = static::$searchFlags[$flag];
} else {
$params[] = 'KEYWORD';
$params[] = $this->protocol->escapeString($flag);
}
}
return count($this->protocol->search($params));
}
/**
* get a list of messages with number and size
*
* @param int $id number of message
* @return int|array size of given message of list with all messages as array(num => size)
* @throws ZendMailProtocolExceptionRuntimeException
*/
public function getSize($id = 0)
{
if ($id) {
return $this->protocol->fetch('RFC822.SIZE', $id);
}
return $this->protocol->fetch('RFC822.SIZE', 1, INF);
}
/**
* Fetch a message
*
* @param int $id number of message
* @return ZendMailStorageMessage
* @throws ZendMailProtocolExceptionRuntimeException
*/
public function getMessage($id)
{
$data = $this->protocol->fetch(array('FLAGS', 'RFC822.HEADER'), $id);
$header = $data['RFC822.HEADER'];
$flags = array();
foreach ($data['FLAGS'] as $flag) {
$flags[] = isset(static::$knownFlags[$flag]) ? static::$knownFlags[$flag] : $flag;
}
return new $this->messageClass(array('handler' => $this, 'id' => $id, 'headers' => $header, 'flags' => $flags));
}
/*
* Get raw header of message or part
*
* @param int $id number of message
* @param null|array|string $part path to part or null for message header
* @param int $topLines include this many lines with header (after an empty line)
* @param int $topLines include this many lines with header (after an empty line)
* @return string raw header
* @throws ExceptionRuntimeException
* @throws ZendMailProtocolExceptionRuntimeException
*/
public function getRawHeader($id, $part = null, $topLines = 0)
{
if ($part !== null) {
// TODO: implement
throw new ExceptionRuntimeException('not implemented');
}
// TODO: toplines
return $this->protocol->fetch('RFC822.HEADER', $id);
}
/*
* Get raw content of message or part
*
* @param int $id number of message
* @param null|array|string $part path to part or null for message content
* @return string raw content
* @throws ZendMailProtocolExceptionRuntimeException
* @throws ExceptionRuntimeException
*/
public function getRawContent($id, $part = null)
{
if ($part !== null) {
// TODO: implement
throw new ExceptionRuntimeException('not implemented');
}
return $this->protocol->fetch('RFC822.TEXT', $id);
}
/**
* create instance with parameters
* Supported parameters are
* - user username
* - host hostname or ip address of IMAP server [optional, default = 'localhost']
* - password password for user 'username' [optional, default = '']
* - port port for IMAP server [optional, default = 110]
* - ssl 'SSL' or 'TLS' for secure sockets
* - folder select this folder [optional, default = 'INBOX']
*
* @param array $params mail reader specific parameters
* @throws ExceptionRuntimeException
* @throws ExceptionInvalidArgumentException
* @throws ZendMailProtocolExceptionRuntimeException
*/
public function __construct($params)
{
if (is_array($params)) {
$params = (object) $params;
}
$this->has['flags'] = true;
if ($params instanceof ProtocolImap) {
$this->protocol = $params;
try {
$this->selectFolder('INBOX');
} catch (ExceptionExceptionInterface $e) {
throw new ExceptionRuntimeException('cannot select INBOX, is this a valid transport?', 0, $e);
}
return;
}
if (!isset($params->user)) {
throw new ExceptionInvalidArgumentException('need at least user in params');
}
$host = isset($params->host) ? $params->host : 'localhost';
$password = isset($params->password) ? $params->password : '';
$port = isset($params->port) ? $params->port : null;
$ssl = isset($params->ssl) ? $params->ssl : false;
$this->protocol = new ProtocolImap();
$this->protocol->connect($host, $port, $ssl);
if (!$this->protocol->login($params->user, $password)) {
throw new ExceptionRuntimeException('cannot login, user or password wrong');
}
$this->selectFolder(isset($params->folder) ? $params->folder : 'INBOX');
}
/**
* Close resource for mail lib. If you need to control, when the resource
* is closed. Otherwise the destructor would call this.
*/
public function close()
{
$this->currentFolder = '';
$this->protocol->logout();
}
/**
* Keep the server busy.
*
* @throws ExceptionRuntimeException
*/
public function noop()
{
if (!$this->protocol->noop()) {
throw new ExceptionRuntimeException('could not do nothing');
}
}
/**
* Remove a message from server. If you're doing that from a web environment
* you should be careful and use a uniqueid as parameter if possible to
* identify the message.
*
* @param int $id number of message
* @throws ExceptionRuntimeException
*/
public function removeMessage($id)
{
if (!$this->protocol->store(array(MailStorage::FLAG_DELETED), $id, null, '+')) {
throw new ExceptionRuntimeException('cannot set deleted flag');
}
// TODO: expunge here or at close? we can handle an error here better and are more fail safe
if (!$this->protocol->expunge()) {
throw new ExceptionRuntimeException('message marked as deleted, but could not expunge');
}
}
/**
* get unique id for one or all messages
*
* if storage does not support unique ids it's the same as the message number
*
* @param int|null $id message number
* @return array|string message number for given message or all messages as array
* @throws ZendMailProtocolExceptionRuntimeException
*/
public function getUniqueId($id = null)
{
if ($id) {
return $this->protocol->fetch('UID', $id);
}
return $this->protocol->fetch('UID', 1, INF);
}
/**
* get a message number from a unique id
*
* I.e. if you have a webmailer that supports deleting messages you should use unique ids
* as parameter and use this method to translate it to message number right before calling removeMessage()
*
* @param string $id unique id
* @throws ExceptionInvalidArgumentException
* @return int message number
*/
public function getNumberByUniqueId($id)
{
// TODO: use search to find number directly
$ids = $this->getUniqueId();
foreach ($ids as $k => $v) {
if ($v == $id) {
return $k;
}
}
throw new ExceptionInvalidArgumentException('unique id not found');
}
/**
* get root folder or given folder
*
* @param string $rootFolder get folder structure for given folder, else root
* @throws ExceptionRuntimeException
* @throws ExceptionInvalidArgumentException
* @throws ZendMailProtocolExceptionRuntimeException
* @return ZendMailStorageFolder root or wanted folder
*/
public function getFolders($rootFolder = null)
{
$folders = $this->protocol->listMailbox((string) $rootFolder);
if (!$folders) {
throw new ExceptionInvalidArgumentException('folder not found');
}
ksort($folders, SORT_STRING);
$root = new Folder('/', '/', false);
$stack = array(null);
$folderStack = array(null);
$parentFolder = $root;
$parent = '';
foreach ($folders as $globalName => $data) {
do {
if (!$parent || strpos($globalName, $parent) === 0) {
$pos = strrpos($globalName, $data['delim']);
if ($pos === false) {
$localName = $globalName;
} else {
$localName = substr($globalName, $pos + 1);
}
$selectable = !$data['flags'] || !in_array('\Noselect', $data['flags']);
array_push($stack, $parent);
$parent = $globalName . $data['delim'];
$folder = new Folder($localName, $globalName, $selectable);
$parentFolder->$localName = $folder;
array_push($folderStack, $parentFolder);
$parentFolder = $folder;
break;
} elseif ($stack) {
$parent = array_pop($stack);
$parentFolder = array_pop($folderStack);
}
} while ($stack);
if (!$stack) {
throw new ExceptionRuntimeException('error while constructing folder tree');
}
}
return $root;
}
/**
* select given folder
*
* folder must be selectable!
*
* @param ZendMailStorageFolder|string $globalName global name of folder or instance for subfolder
* @throws ExceptionRuntimeException
* @throws ZendMailProtocolExceptionRuntimeException
*/
public function selectFolder($globalName)
{
$this->currentFolder = $globalName;
if (!$this->protocol->select($this->currentFolder)) {
$this->currentFolder = '';
throw new ExceptionRuntimeException('cannot change folder, maybe it does not exist');
}
}
/**
* get ZendMailStorageFolder instance for current folder
*
* @return ZendMailStorageFolder instance of current folder
*/
public function getCurrentFolder()
{
return $this->currentFolder;
}
/**
* create a new folder
*
* This method also creates parent folders if necessary. Some mail storages may restrict, which folder
* may be used as parent or which chars may be used in the folder name
*
* @param string $name global name of folder, local name if $parentFolder is set
* @param string|ZendMailStorageFolder $parentFolder parent folder for new folder, else root folder is parent
* @throws ExceptionRuntimeException
*/
public function createFolder($name, $parentFolder = null)
{
// TODO: we assume / as the hierarchy delim - need to get that from the folder class!
if ($parentFolder instanceof Folder) {
$folder = $parentFolder->getGlobalName() . '/' . $name;
} elseif ($parentFolder != null) {
$folder = $parentFolder . '/' . $name;
} else {
$folder = $name;
}
if (!$this->protocol->create($folder)) {
throw new ExceptionRuntimeException('cannot create folder');
}
}
/**
* remove a folder
*
* @param string|ZendMailStorageFolder $name name or instance of folder
* @throws ExceptionRuntimeException
*/
public function removeFolder($name)
{
if ($name instanceof Folder) {
$name = $name->getGlobalName();
}
if (!$this->protocol->delete($name)) {
throw new ExceptionRuntimeException('cannot delete folder');
}
}
/**
* rename and/or move folder
*
* The new name has the same restrictions as in createFolder()
*
* @param string|ZendMailStorageFolder $oldName name or instance of folder
* @param string $newName new global name of folder
* @throws ExceptionRuntimeException
*/
public function renameFolder($oldName, $newName)
{
if ($oldName instanceof Folder) {
$oldName = $oldName->getGlobalName();
}
if (!$this->protocol->rename($oldName, $newName)) {
throw new ExceptionRuntimeException('cannot rename folder');
}
}
/**
* append a new message to mail storage
*
* @param string $message message as string or instance of message class
* @param null|string|ZendMailStorageFolder $folder folder for new message, else current folder is taken
* @param null|array $flags set flags for new message, else a default set is used
* @throws ExceptionRuntimeException
*/
// not yet * @param string|ZendMailMessage|ZendMimeMessage $message message as string or instance of message class
public function appendMessage($message, $folder = null, $flags = null)
{
if ($folder === null) {
$folder = $this->currentFolder;
}
if ($flags === null) {
$flags = array(MailStorage::FLAG_SEEN);
}
// TODO: handle class instances for $message
if (!$this->protocol->append($folder, $message, $flags)) {
throw new ExceptionRuntimeException('cannot create message, please check if the folder exists and your flags');
}
}
/**
* copy an existing message
*
* @param int $id number of message
* @param string|ZendMailStorageFolder $folder name or instance of target folder
* @throws ExceptionRuntimeException
*/
public function copyMessage($id, $folder)
{
if (!$this->protocol->copy($folder, $id)) {
throw new ExceptionRuntimeException('cannot copy message, does the folder exist?');
}
}
/**
* move an existing message
*
* NOTE: IMAP has no native move command, thus it's emulated with copy and delete
*
* @param int $id number of message
* @param string|ZendMailStorageFolder $folder name or instance of target folder
* @throws ExceptionRuntimeException
*/
public function moveMessage($id, $folder)
{
$this->copyMessage($id, $folder);
$this->removeMessage($id);
}
/**
* set flags for message
*
* NOTE: this method can't set the recent flag.
*
* @param int $id number of message
* @param array $flags new flags for message
* @throws ExceptionRuntimeException
*/
public function setFlags($id, $flags)
{
if (!$this->protocol->store($flags, $id)) {
throw new ExceptionRuntimeException('cannot set flags, have you tried to set the recent flag or special chars?');
}
}
}