rcube_imap.inc
No OneTemporary
Actions

Authored By

Unknown

Size

34 KB

Referenced Files

None

Subscribers

None

rcube_imap.inc
View Options

	<?php

	/*
	+-----------------------------------------------------------------------+
	\| program/include/rcube_imap.inc \|
	\| \|
	\| This file is part of the RoundCube Webmail client \|
	\| Copyright (C) 2005, RoundCube Dev. - Switzerland \|
	\| Licensed under the GNU GPL \|
	\| \|
	\| PURPOSE: \|
	\| IMAP wrapper that implements the Iloha IMAP Library (IIL) \|
	\| See http://ilohamail.org/ for details \|
	\| \|
	+-----------------------------------------------------------------------+
	\| Author: Thomas Bruederli <roundcube@gmail.com> \|
	+-----------------------------------------------------------------------+

	$Id$

	*/


	require_once('lib/imap.inc');
	require_once('lib/mime.inc');
	require_once('lib/utf7.inc');


	class rcube_imap
	{
	var $conn;
	var $root_ns = '';
	var $root_dir = '';
	var $mailbox = 'INBOX';
	var $list_page = 1;
	var $page_size = 10;
	var $delimiter = NULL;
	var $caching_enabled = FALSE;
	var $default_folders = array('inbox', 'drafts', 'sent', 'junk', 'trash');
	var $cache = array();
	var $cache_changes = array();
	var $uid_id_map = array();
	var $msg_headers = array();


	// PHP 5 constructor
	function __construct()
	{

	}

	// PHP 4 compatibility
	function rcube_imap()
	{
	$this->__construct();
	}


	function connect($host, $user, $pass, $port=143, $use_ssl=FALSE)
	{
	global $ICL_SSL, $ICL_PORT, $CONFIG;

	// check for Open-SSL support in PHP build
	if ($use_ssl && in_array('openssl', get_loaded_extensions()))
	$ICL_SSL = TRUE;
	else if ($use_ssl)
	{
	raise_error(array('code' => 403,
	'type' => 'imap',
	'file' => __FILE__,
	'message' => 'Open SSL not available;'), TRUE, FALSE);
	$port = 143;
	}

	$ICL_PORT = $port;
	$this->conn = iil_Connect($host, $user, $pass, array('imap' => 'check'));
	$this->host = $host;
	$this->user = $user;
	$this->pass = $pass;
	$this->port = $port;
	$this->ssl = $use_ssl;

	// print trace mesages
	if ($this->conn && ($CONFIG['debug_level'] & 8))
	console($this->conn->message);

	// write error log
	else if (!$this->conn && $GLOBALS['iil_error'])
	{
	raise_error(array('code' => 403,
	'type' => 'imap',
	'message' => $GLOBALS['iil_error']), TRUE, FALSE);
	}

	// get account namespace
	if ($this->conn)
	{
	iil_C_NameSpace($this->conn);

	if (!empty($this->conn->delimiter))
	$this->delimiter = $this->conn->delimiter;
	if (!empty($this->conn->rootdir))
	{
	$this->set_rootdir($this->conn->rootdir);
	$this->root_ns = ereg_replace('[\.\/]$', '', $this->conn->rootdir);
	}
	}

	return $this->conn ? TRUE : FALSE;
	}


	function close()
	{
	if ($this->conn)
	iil_Close($this->conn);
	}


	function reconnect()
	{
	$this->close();
	$this->connect($this->host, $this->user, $this->pass, $this->port, $this->ssl);
	}


	function set_rootdir($root)
	{
	if (ereg('[\.\/]$', $root)) //(substr($root, -1, 1)==='/')
	$root = substr($root, 0, -1);

	$this->root_dir = $root;

	if (empty($this->delimiter))
	$this->get_hierarchy_delimiter();
	}


	function set_default_mailboxes($arr)
	{
	if (is_array($arr))
	{
	$this->default_folders = array();

	// add mailbox names lower case
	foreach ($arr as $mbox)
	$this->default_folders[] = strtolower($mbox);

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


	function set_mailbox($mbox)
	{
	$mailbox = $this->_mod_mailbox($mbox);

	if ($this->mailbox == $mailbox)
	return;

	$this->mailbox = $mailbox;

	// clear messagecount cache for this mailbox
	$this->_clear_messagecount($mailbox);
	}


	function set_page($page)
	{
	$this->list_page = (int)$page;
	}


	function set_pagesize($size)
	{
	$this->page_size = (int)$size;
	}


	function get_mailbox_name()
	{
	return $this->conn ? $this->_mod_mailbox($this->mailbox, 'out') : '';
	}


	function get_hierarchy_delimiter()
	{
	if ($this->conn && empty($this->delimiter))
	$this->delimiter = iil_C_GetHierarchyDelimiter($this->conn);

	if (empty($this->delimiter))
	$this->delimiter = '/';

	return $this->delimiter;
	}

	// public method for mailbox listing
	// convert mailbox name with root dir first
	function list_mailboxes($root='', $filter='*')
	{
	$a_out = array();
	$a_mboxes = $this->_list_mailboxes($root, $filter);

	foreach ($a_mboxes as $mbox)
	{
	$name = $this->_mod_mailbox($mbox, 'out');
	if (strlen($name))
	$a_out[] = $name;
	}

	// sort mailboxes
	$a_out = $this->_sort_mailbox_list($a_out);

	return $a_out;
	}

	// private method for mailbox listing
	function _list_mailboxes($root='', $filter='*')
	{
	$a_defaults = $a_out = array();

	// get cached folder list
	$a_mboxes = $this->get_cache('mailboxes');
	if (is_array($a_mboxes))
	return $a_mboxes;

	// retrieve list of folders from IMAP server
	$a_folders = iil_C_ListSubscribed($this->conn, $this->_mod_mailbox($root), $filter);

	if (!is_array($a_folders) \|\| !sizeof($a_folders))
	$a_folders = array();

	// create INBOX if it does not exist
	if (!in_array_nocase('INBOX', $a_folders))
	{
	$this->create_mailbox('INBOX', TRUE);
	array_unshift($a_folders, 'INBOX');
	}

	$a_mailbox_cache = array();

	// write mailboxlist to cache
	$this->update_cache('mailboxes', $a_folders);

	return $a_folders;
	}


	// get message count for a specific mailbox; acceptes modes are: ALL, UNSEEN
	function messagecount($mbox='', $mode='ALL', $force=FALSE)
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;
	return $this->_messagecount($mailbox, $mode, $force);
	}

	// private method for getting nr of mesages
	function _messagecount($mailbox='', $mode='ALL', $force=FALSE)
	{
	$a_mailbox_cache = FALSE;
	$mode = strtoupper($mode);

	if (!$mailbox)
	$mailbox = $this->mailbox;

	$a_mailbox_cache = $this->get_cache('messagecount');

	// return cached value
	if (!$force && is_array($a_mailbox_cache[$mailbox]) && isset($a_mailbox_cache[$mailbox][$mode]))
	return $a_mailbox_cache[$mailbox][$mode];

	// get message count and store in cache
	if ($mode == 'UNSEEN')
	$count = iil_C_CountUnseen($this->conn, $mailbox);
	else
	$count = iil_C_CountMessages($this->conn, $mailbox);

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

	$a_mailbox_cache[$mailbox][$mode] = (int)$count;

	// write back to cache
	$this->update_cache('messagecount', $a_mailbox_cache);

	return (int)$count;
	}


	// public method for listing headers
	// convert mailbox name with root dir first
	function list_headers($mbox='', $page=NULL, $sort_field='date', $sort_order='DESC')
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;
	return $this->_list_headers($mailbox, $page, $sort_field, $sort_order);
	}


	// private method for listing message header
	// by DrSlump <drslump@drslump.biz>
	function __list_headers($mailbox='', $page=NULL, $sort_field='date', $sort_order='DESC')
	{
	$a_out = array();
	$cached_count = 0;

	if (!strlen($mailbox))
	return $a_out;

	$mbox_count = $this->_messagecount($mailbox /, 'ALL', TRUE/);

	$revalidate = false;
	if ($mbox_count)
	{
	// get cached headers
	$a_out = $this->get_cache($mailbox.'.msg');
	$a_out = is_array($a_out) ? $a_out : array(); // make sure we get an array

	$cached_count = count($a_out);
	$a_new = array();
	$revalidate = true; // revalidate by default

	// if the cache count is greater then there have been changes for sure
	if ($cached_count <= $mbox_count)
	{
	$from = $cached_count?$cached_count:1;

	//get new headers (at least one is returned)
	$a_temp = iil_C_FetchHeaders($this->conn, $mailbox, $from . ':' . $mbox_count);
	$duplicated = $cached_count?true:false;

	foreach ($a_temp as $hdr)
	{
	//skip the first one if duplicated
	if ($duplicated)
	{
	//check for changes using the UID
	$lastCacheHdr = end($a_out);
	if ($hdr->uid === $lastCacheHdr->uid)
	$revalidate = false;

	$duplicated = false;
	continue;
	}

	//skip deleted ones
	if (! $hdr->deleted)
	$a_new[ $hdr->uid ] = $hdr;
	}
	}

	//revalidate cache if needed
	$to = $mbox_count - count($a_new);
	if ($revalidate && $to !== 0) //we'll need to reindex the array so we have to make a copy
	{
	$a_dirty = $a_out;
	$a_out = array();
	$a_buffers = array();

	//fetch chunks of 20 headers
	$step = 20;
	$found = false;

	//fetch headers in blocks starting from new to old
	do {
	$from = $to-$step;
	if ($from < 1) $from = 1;

	//store the block in a temporal buffer
	$a_buffers[$from] = iil_C_FetchHeaders($this->conn, $mailbox, $from . ':' . $to);

	//compare the fetched headers with the ones in the cache
	$idx = 0;
	foreach ($a_buffers[$from] as $k=>$hdr)
	{
	//if it's different the comparison ends
	if (!isset($a_dirty[$hdr->uid]) \|\| $a_dirty[$hdr->uid]->id !== $hdr->id)
	break;

	//if we arrive here then we know that the older messages in cache are ok
	$found = $hdr->id;
	$idx++;
	}

	//remove from the buffer the headers which are already cached
	if ($found)
	$a_buffers[$from] = array_splice($a_buffers[$from], 0, $idx );

	$to = $from-1;
	}
	while ($found===false && $from > 1);

	//just keep the headers we are certain that didn't change in the cache
	if ($found !== false)
	{
	foreach ($a_dirty as $hdr)
	{
	if ($hdr->id > $found) break;
	$a_out[$hdr->uid] = $hdr;
	}
	}

	//we builded the block buffers from new to older, we process them in reverse order
	ksort($a_buffers, SORT_NUMERIC);
	foreach ($a_buffers as $a_buff)
	{
	foreach ($a_buff as $hdr)
	{
	if (! $hdr->deleted)
	$a_out[$hdr->uid] = $hdr;
	}
	}
	}

	//array_merge() would reindex the keys, so we use this 'hack'
	$a_out += $a_new;
	}

	//write headers list to cache if needed
	if ($revalidate \|\| count($a_out)!=$cached_count) {
	$this->update_cache($mailbox.'.msg', $a_out);
	}

	//sort headers by a specific col
	$a_out = iil_SortHeaders( $a_out, $sort_field, $sort_order );

	// return complete list of messages
	if (strtolower($page)=='all')
	return $a_out;

	$start_msg = ($this->list_page-1) * $this->page_size;
	return array_slice($a_out, $start_msg, $this->page_size);
	}


	// old function; replaced 2005/10/18
	// private method for listing message header
	function _list_headers($mailbox='', $page=NULL, $sort_field='date', $sort_order='DESC')
	{
	$max = $this->_messagecount($mailbox);

	if (!strlen($mailbox))
	return array();

	// get cached headers
	$a_msg_headers = $this->get_cache($mailbox.'.msg');

	// retrieve headers from IMAP
	if (!is_array($a_msg_headers) \|\| sizeof($a_msg_headers) != $max)
	{
	$a_header_index = iil_C_FetchHeaders($this->conn, $mailbox, "1:$max");
	$a_msg_headers = array();

	if (!empty($a_header_index))
	foreach ($a_header_index as $i => $headers)
	if (!$headers->deleted)
	$a_msg_headers[$headers->uid] = $headers;
	}
	else
	$headers_cached = TRUE;

	if (!is_array($a_msg_headers))
	return array();

	// sort headers by a specific col
	$a_headers = iil_SortHeaders($a_msg_headers, $sort_field, $sort_order);

	// free memory
	unset($a_msg_headers);

	// write headers list to cache
	if (!$headers_cached)
	$this->update_cache($mailbox.'.msg', $a_headers);

	if (empty($a_headers))
	return array();

	// return complete list of messages
	if (strtolower($page)=='all')
	return $a_headers;

	$start_msg = ($this->list_page-1) * $this->page_size;
	return array_slice($a_headers, $start_msg, $this->page_size);
	}


	// return sorted array of message UIDs
	function message_index($mbox='', $sort_field='date', $sort_order='DESC')
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;
	$a_out = array();

	// get array of message headers
	$a_headers = $this->_list_headers($mailbox, 'all', $sort_field, $sort_order);

	if (is_array($a_headers))
	foreach ($a_headers as $header)
	$a_out[] = $header->uid;

	return $a_out;
	}


	function sync_header_index($mbox=NULL)
	{

	}


	function search($mbox='', $criteria='ALL')
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;
	$a_messages = iil_C_Search($this->conn, $mailbox, $criteria);
	return $a_messages;
	}


	function get_headers($uid, $mbox=NULL)
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;

	// get cached headers
	$a_msg_headers = $this->get_cache($mailbox.'.msg');

	// return cached header
	if ($a_msg_headers[$uid])
	return $a_msg_headers[$uid];

	$msg_id = $this->_uid2id($uid);
	$header = iil_C_FetchHeader($this->conn, $mailbox, $msg_id);

	// write headers cache
	$a_msg_headers[$uid] = $header;
	$this->update_cache($mailbox.'.msg', $a_msg_headers);

	return $header;
	}


	function get_body($uid, $part=1)
	{
	if (!($msg_id = $this->_uid2id($uid)))
	return FALSE;

	$structure_str = iil_C_FetchStructureString($this->conn, $this->mailbox, $msg_id);
	$structure = iml_GetRawStructureArray($structure_str);
	$body = iil_C_FetchPartBody($this->conn, $this->mailbox, $msg_id, $part);

	$encoding = iml_GetPartEncodingCode($structure, $part);

	if ($encoding==3) $body = $this->mime_decode($body, 'base64');
	else if ($encoding==4) $body = $this->mime_decode($body, 'quoted-printable');

	return $body;
	}


	function get_raw_body($uid)
	{
	if (!($msg_id = $this->_uid2id($uid)))
	return FALSE;

	$body = iil_C_FetchPartHeader($this->conn, $this->mailbox, $msg_id, NULL);
	$body .= iil_C_HandlePartBody($this->conn, $this->mailbox, $msg_id, NULL, 1);

	return $body;
	}


	// set message flag to one or several messages
	// possible flgs are: SEEN, DELETED, RECENT, ANSWERED, DRAFT
	function set_flag($uids, $flag)
	{
	$flag = strtoupper($flag);
	$msg_ids = array();
	if (!is_array($uids))
	$uids = array($uids);

	foreach ($uids as $uid)
	$msg_ids[] = $this->_uid2id($uid);

	if ($flag=='UNSEEN')
	$result = iil_C_Unseen($this->conn, $this->mailbox, join(',', $msg_ids));
	else
	$result = iil_C_Flag($this->conn, $this->mailbox, join(',', $msg_ids), $flag);

	// reload message headers if cached
	$cache_key = $this->mailbox.'.msg';
	if ($this->caching_enabled && $result && ($a_cached_headers = $this->get_cache($cache_key)))
	{
	// close and re-open connection
	$this->reconnect();

	foreach ($uids as $uid)
	{
	if (isset($a_cached_headers[$uid]))
	{
	unset($this->cache[$cache_key][$uid]);
	$this->get_headers($uid);
	}
	}
	}

	// set nr of messages that were flaged
	$count = sizeof($msg_ids);

	// clear message count cache
	if ($result && $flag=='SEEN')
	$this->_set_messagecount($this->mailbox, 'UNSEEN', $count*(-1));
	else if ($result && $flag=='UNSEEN')
	$this->_set_messagecount($this->mailbox, 'UNSEEN', $count);
	else if ($result && $flag=='DELETED')
	$this->_set_messagecount($this->mailbox, 'ALL', $count*(-1));

	return $result;
	}


	// append a mail message (source) to a specific mailbox
	function save_message($mbox, $message)
	{
	$mailbox = $this->_mod_mailbox($mbox);

	// make shure mailbox exists
	if (in_array($mailbox, $this->_list_mailboxes()))
	$saved = iil_C_Append($this->conn, $mailbox, $message);

	if ($saved)
	{
	// increase messagecount of the target mailbox
	$this->_set_messagecount($mailbox, 'ALL', 1);
	}

	return $saved;
	}


	// move a message from one mailbox to another
	function move_message($uids, $to_mbox, $from_mbox='')
	{
	$to_mbox = $this->_mod_mailbox($to_mbox);
	$from_mbox = $from_mbox ? $this->_mod_mailbox($from_mbox) : $this->mailbox;

	// make shure mailbox exists
	if (!in_array($to_mbox, $this->_list_mailboxes()))
	return FALSE;

	// convert the list of uids to array
	$a_uids = is_string($uids) ? explode(',', $uids) : (is_array($uids) ? $uids : NULL);

	// exit if no message uids are specified
	if (!is_array($a_uids))
	return false;

	// convert uids to message ids
	$a_mids = array();
	foreach ($a_uids as $uid)
	$a_mids[] = $this->_uid2id($uid, $from_mbox);

	$moved = iil_C_Move($this->conn, join(',', $a_mids), $from_mbox, $to_mbox);

	// send expunge command in order to have the moved message
	// really deleted from the source mailbox
	if ($moved)
	{
	$this->expunge($from_mbox, FALSE);
	$this->clear_cache($to_mbox.'.msg');
	$this->_clear_messagecount($from_mbox);
	$this->_clear_messagecount($to_mbox);
	}

	// update cached message headers
	$cache_key = $from_mbox.'.msg';
	if ($moved && ($a_cached_headers = $this->get_cache($cache_key)))
	{
	foreach ($a_uids as $uid)
	unset($a_cached_headers[$uid]);

	$this->update_cache($cache_key, $a_cached_headers);
	}

	return $moved;
	}


	// mark messages as deleted and expunge mailbox
	function delete_message($uids, $mbox='')
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;

	// convert the list of uids to array
	$a_uids = is_string($uids) ? explode(',', $uids) : (is_array($uids) ? $uids : NULL);

	// exit if no message uids are specified
	if (!is_array($a_uids))
	return false;


	// convert uids to message ids
	$a_mids = array();
	foreach ($a_uids as $uid)
	$a_mids[] = $this->_uid2id($uid, $mailbox);

	$deleted = iil_C_Delete($this->conn, $mailbox, join(',', $a_mids));

	// send expunge command in order to have the deleted message
	// really deleted from the mailbox
	if ($deleted)
	{
	$this->expunge($mailbox, FALSE);
	$this->_clear_messagecount($mailbox);
	}

	// remove deleted messages from cache
	if ($deleted && ($a_cached_headers = $this->get_cache($mailbox.'.msg')))
	{
	foreach ($a_uids as $uid)
	unset($a_cached_headers[$uid]);

	$this->update_cache($mailbox.'.msg', $a_cached_headers);
	}

	return $deleted;
	}


	// clear all messages in a specific mailbox
	function clear_mailbox($mbox)
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;
	$msg_count = $this->_messagecount($mailbox, 'ALL');

	if ($msg_count>0)
	return iil_C_ClearFolder($this->conn, $mailbox);
	else
	return 0;
	}


	// send IMAP expunge command and clear cache
	function expunge($mbox='', $clear_cache=TRUE)
	{
	$mailbox = $mbox ? $this->_mod_mailbox($mbox) : $this->mailbox;

	$result = iil_C_Expunge($this->conn, $mailbox);

	if ($result>=0 && $clear_cache)
	{
	$this->clear_cache($mailbox.'.msg');
	$this->_clear_messagecount($mailbox);
	}

	return $result;
	}



	/* --------------------------------
	* folder managment
	* --------------------------------*/


	// return an array with all folders available in IMAP server
	function list_unsubscribed($root='')
	{
	static $sa_unsubscribed;

	if (is_array($sa_unsubscribed))
	return $sa_unsubscribed;

	// retrieve list of folders from IMAP server
	$a_mboxes = iil_C_ListMailboxes($this->conn, $this->_mod_mailbox($root), '*');

	// modify names with root dir
	foreach ($a_mboxes as $mbox)
	{
	$name = $this->_mod_mailbox($mbox, 'out');
	if (strlen($name))
	$a_folders[] = $name;
	}

	// filter folders and sort them
	$sa_unsubscribed = $this->_sort_mailbox_list($a_folders);
	return $sa_unsubscribed;
	}


	// subscribe to a specific mailbox(es)
	function subscribe($mbox, $mode='subscribe')
	{
	if (is_array($mbox))
	$a_mboxes = $mbox;
	else if (is_string($mbox) && strlen($mbox))
	$a_mboxes = explode(',', $mbox);

	// let this common function do the main work
	return $this->_change_subscription($a_mboxes, 'subscribe');
	}


	// unsubscribe mailboxes
	function unsubscribe($mbox)
	{
	if (is_array($mbox))
	$a_mboxes = $mbox;
	else if (is_string($mbox) && strlen($mbox))
	$a_mboxes = explode(',', $mbox);

	// let this common function do the main work
	return $this->_change_subscription($a_mboxes, 'unsubscribe');
	}


	// create a new mailbox on the server and register it in local cache
	function create_mailbox($name, $subscribe=FALSE)
	{
	$result = FALSE;
	$name_enc = UTF7EncodeString($name);
	$abs_name = $this->_mod_mailbox($name_enc);
	$a_mailbox_cache = $this->get_cache('mailboxes');

	//if (strlen($this->root_ns))
	// $abs_name = $this->root_ns.$abs_name;

	if (strlen($abs_name) && (!is_array($a_mailbox_cache) \|\| !in_array($abs_name, $a_mailbox_cache)))
	$result = iil_C_CreateFolder($this->conn, $abs_name);

	// update mailboxlist cache
	if ($result && $subscribe)
	$this->subscribe($name_enc);

	return $result ? $name : FALSE;
	}


	// set a new name to an existing mailbox
	function rename_mailbox($mbox, $new_name)
	{
	// not implemented yet
	}


	// remove mailboxes from server
	function delete_mailbox($mbox)
	{
	$deleted = FALSE;

	if (is_array($mbox))
	$a_mboxes = $mbox;
	else if (is_string($mbox) && strlen($mbox))
	$a_mboxes = explode(',', $mbox);

	if (is_array($a_mboxes))
	foreach ($a_mboxes as $mbox)
	{
	$mailbox = $this->_mod_mailbox($mbox);

	// unsubscribe mailbox before deleting
	iil_C_UnSubscribe($this->conn, $mailbox);

	// send delete command to server
	$result = iil_C_DeleteFolder($this->conn, $mailbox);
	if ($result>=0)
	$deleted = TRUE;
	}

	// clear mailboxlist cache
	if ($deleted)
	$this->clear_cache('mailboxes');

	return $updated;
	}




	/* --------------------------------
	* internal caching functions
	* --------------------------------*/


	function set_caching($set)
	{
	if ($set && function_exists('rcube_read_cache'))
	$this->caching_enabled = TRUE;
	else
	$this->caching_enabled = FALSE;
	}

	function get_cache($key)
	{
	// read cache
	if (!isset($this->cache[$key]) && $this->caching_enabled)
	{
	$cache_data = rcube_read_cache('IMAP.'.$key);
	$this->cache[$key] = strlen($cache_data) ? unserialize($cache_data) : FALSE;
	}

	return $this->cache[$key];
	}


	function update_cache($key, $data)
	{
	$this->cache[$key] = $data;
	$this->cache_changed = TRUE;
	$this->cache_changes[$key] = TRUE;
	}


	function write_cache()
	{
	if ($this->caching_enabled && $this->cache_changed)
	{
	foreach ($this->cache as $key => $data)
	{
	if ($this->cache_changes[$key])
	rcube_write_cache('IMAP.'.$key, serialize($data));
	}
	}
	}


	function clear_cache($key=NULL)
	{
	if ($key===NULL)
	{
	foreach ($this->cache as $key => $data)
	rcube_clear_cache('IMAP.'.$key);

	$this->cache = array();
	$this->cache_changed = FALSE;
	$this->cache_changes = array();
	}
	else
	{
	rcube_clear_cache('IMAP.'.$key);
	$this->cache_changes[$key] = FALSE;
	unset($this->cache[$key]);
	}
	}



	/* --------------------------------
	* encoding/decoding functions
	* --------------------------------*/


	function decode_address_list($input, $max=NULL)
	{
	$a = $this->_parse_address_list($input);
	$out = array();

	if (!is_array($a))
	return $out;

	$c = count($a);
	$j = 0;

	foreach ($a as $val)
	{
	$j++;
	$address = $val['address'];
	$name = preg_replace(array('/^[\'"]/', '/[\'"]$/'), '', trim($val['name']));
	$string = $name!==$address ? sprintf('%s <%s>', strpos($name, ',')!==FALSE ? '"'.$name.'"' : $name, $address) : $address;

	$out[$j] = array('name' => $name,
	'mailto' => $address,
	'string' => $string);

	if ($max && $j==$max)
	break;
	}

	return $out;
	}


	function decode_header($input)
	{
	$out = '';

	$pos = strpos($input, '=?');
	if ($pos !== false)
	{
	$out = substr($input, 0, $pos);

	$end_cs_pos = strpos($input, "?", $pos+2);
	$end_en_pos = strpos($input, "?", $end_cs_pos+1);
	$end_pos = strpos($input, "?=", $end_en_pos+1);

	$encstr = substr($input, $pos+2, ($end_pos-$pos-2));
	$rest = substr($input, $end_pos+2);

	$out .= $this->decode_mime_string($encstr);
	$out .= $this->decode_header($rest);

	return $out;
	}
	else
	return $input;
	}


	function decode_mime_string($str)
	{
	$a = explode('?', $str);
	$count = count($a);

	// should be in format "charset?encoding?base64_string"
	if ($count >= 3)
	{
	for ($i=2; $i<$count; $i++)
	$rest.=$a[$i];

	if (($a[1]=="B")\|\|($a[1]=="b"))
	$rest = base64_decode($rest);
	else if (($a[1]=="Q")\|\|($a[1]=="q"))
	{
	$rest = str_replace("_", " ", $rest);
	$rest = quoted_printable_decode($rest);
	}

	return decode_specialchars($rest, $a[0]);
	}
	else
	return $str; //we dont' know what to do with this
	}


	function mime_decode($input, $encoding='7bit')
	{
	switch (strtolower($encoding))
	{
	case '7bit':
	return $input;
	break;

	case 'quoted-printable':
	return quoted_printable_decode($input);
	break;

	case 'base64':
	return base64_decode($input);
	break;

	default:
	return $input;
	}
	}


	function mime_encode($input, $encoding='7bit')
	{
	switch ($encoding)
	{
	case 'quoted-printable':
	return quoted_printable_encode($input);
	break;

	case 'base64':
	return base64_encode($input);
	break;

	default:
	return $input;
	}
	}


	// convert body chars according to the ctype_parameters
	function charset_decode($body, $ctype_param)
	{
	if (is_array($ctype_param) && !empty($ctype_param['charset']))
	return decode_specialchars($body, $ctype_param['charset']);

	return $body;
	}


	/* --------------------------------
	* private methods
	* --------------------------------*/


	function _mod_mailbox($mbox, $mode='in')
	{
	if ((!empty($this->root_ns) && $this->root_ns == $mbox) \|\| ($mbox == 'INBOX' && $mode == 'in'))
	return $mbox;

	if (!empty($this->root_dir) && $mode=='in')
	$mbox = $this->root_dir.$this->delimiter.$mbox;
	else if (strlen($this->root_dir) && $mode=='out')
	$mbox = substr($mbox, strlen($this->root_dir)+1);

	return $mbox;
	}


	// sort mailboxes first by default folders and then in alphabethical order
	function _sort_mailbox_list($a_folders)
	{
	$a_out = $a_defaults = array();

	// find default folders and skip folders starting with '.'
	foreach($a_folders as $i => $folder)
	{
	if ($folder{0}=='.')
	continue;

	if (($p = array_search(strtolower($folder), $this->default_folders))!==FALSE)
	$a_defaults[$p] = $folder;
	else
	$a_out[] = $folder;
	}

	sort($a_out);
	ksort($a_defaults);

	return array_merge($a_defaults, $a_out);
	}


	function _uid2id($uid, $mbox=NULL)
	{
	if (!$mbox)
	$mbox = $this->mailbox;

	if (!isset($this->uid_id_map[$mbox][$uid]))
	$this->uid_id_map[$mbox][$uid] = iil_C_UID2ID($this->conn, $mbox, $uid);

	return $this->uid_id_map[$mbox][$uid];
	}


	// subscribe/unsubscribe a list of mailboxes and update local cache
	function _change_subscription($a_mboxes, $mode)
	{
	$updated = FALSE;

	if (is_array($a_mboxes))
	foreach ($a_mboxes as $i => $mbox)
	{
	$mailbox = $this->_mod_mailbox($mbox);
	$a_mboxes[$i] = $mailbox;

	if ($mode=='subscribe')
	$result = iil_C_Subscribe($this->conn, $mailbox);
	else if ($mode=='unsubscribe')
	$result = iil_C_UnSubscribe($this->conn, $mailbox);

	if ($result>=0)
	$updated = TRUE;
	}

	// get cached mailbox list
	if ($updated)
	{
	$a_mailbox_cache = $this->get_cache('mailboxes');
	if (!is_array($a_mailbox_cache))
	return $updated;

	// modify cached list
	if ($mode=='subscribe')
	$a_mailbox_cache = array_merge($a_mailbox_cache, $a_mboxes);
	else if ($mode=='unsubscribe')
	$a_mailbox_cache = array_diff($a_mailbox_cache, $a_mboxes);

	// write mailboxlist to cache
	$this->update_cache('mailboxes', $this->_sort_mailbox_list($a_mailbox_cache));
	}

	return $updated;
	}


	// increde/decrese messagecount for a specific mailbox
	function _set_messagecount($mbox, $mode, $increment)
	{
	$a_mailbox_cache = FALSE;
	$mailbox = $mbox ? $mbox : $this->mailbox;
	$mode = strtoupper($mode);

	$a_mailbox_cache = $this->get_cache('messagecount');

	if (!is_array($a_mailbox_cache[$mailbox]) \|\| !isset($a_mailbox_cache[$mailbox][$mode]) \|\| !is_numeric($increment))
	return FALSE;

	// add incremental value to messagecount
	$a_mailbox_cache[$mailbox][$mode] += $increment;

	// write back to cache
	$this->update_cache('messagecount', $a_mailbox_cache);

	return TRUE;
	}


	// remove messagecount of a specific mailbox from cache
	function _clear_messagecount($mbox='')
	{
	$a_mailbox_cache = FALSE;
	$mailbox = $mbox ? $mbox : $this->mailbox;

	$a_mailbox_cache = $this->get_cache('messagecount');

	if (is_array($a_mailbox_cache[$mailbox]))
	{
	unset($a_mailbox_cache[$mailbox]);
	$this->update_cache('messagecount', $a_mailbox_cache);
	}
	}


	function _parse_address_list($str)
	{
	$a = $this->_explode_quoted_string(',', $str);
	$result = array();

	foreach ($a as $key => $val)
	{
	$val = str_replace("\"<", "\" <", $val);
	$sub_a = $this->_explode_quoted_string(' ', $val);

	foreach ($sub_a as $k => $v)
	{
	if ((strpos($v, '@') > 0) && (strpos($v, '.') > 0))
	$result[$key]['address'] = str_replace('<', '', str_replace('>', '', $v));
	else
	$result[$key]['name'] .= (empty($result[$key]['name'])?'':' ').str_replace("\"",'',stripslashes($v));
	}

	if (empty($result[$key]['name']))
	$result[$key]['name'] = $result[$key]['address'];

	$result[$key]['name'] = $this->decode_header($result[$key]['name']);
	}

	return $result;
	}


	function _explode_quoted_string($delimiter, $string)
	{
	$quotes = explode("\"", $string);
	foreach ($quotes as $key => $val)
	if (($key % 2) == 1)
	$quotes[$key] = str_replace($delimiter, "_!@!_", $quotes[$key]);

	$string = implode("\"", $quotes);

	$result = explode($delimiter, $string);
	foreach ($result as $key => $val)
	$result[$key] = str_replace("_!@!_", $delimiter, $result[$key]);

	return $result;
	}
	}





	function quoted_printable_encode($input="", $line_max=76, $space_conv=false)
	{
	$hex = array('0','1','2','3','4','5','6','7','8','9','A','B','C','D','E','F');
	$lines = preg_split("/(?:\r\n\|\r\|\n)/", $input);
	$eol = "\r\n";
	$escape = "=";
	$output = "";

	while( list(, $line) = each($lines))
	{
	//$line = rtrim($line); // remove trailing white space -> no =20\r\n necessary
	$linlen = strlen($line);
	$newline = "";
	for($i = 0; $i < $linlen; $i++)
	{
	$c = substr( $line, $i, 1 );
	$dec = ord( $c );
	if ( ( $i == 0 ) && ( $dec == 46 ) ) // convert first point in the line into =2E
	{
	$c = "=2E";
	}
	if ( $dec == 32 )
	{
	if ( $i == ( $linlen - 1 ) ) // convert space at eol only
	{
	$c = "=20";
	}
	else if ( $space_conv )
	{
	$c = "=20";
	}
	}
	else if ( ($dec == 61) \|\| ($dec < 32 ) \|\| ($dec > 126) ) // always encode "\t", which is not required
	{
	$h2 = floor($dec/16);
	$h1 = floor($dec%16);
	$c = $escape.$hex["$h2"].$hex["$h1"];
	}

	if ( (strlen($newline) + strlen($c)) >= $line_max ) // CRLF is not counted
	{
	$output .= $newline.$escape.$eol; // soft line break; " =\r\n" is okay
	$newline = "";
	// check if newline first character will be point or not
	if ( $dec == 46 )
	{
	$c = "=2E";
	}
	}
	$newline .= $c;
	} // end of for
	$output .= $newline.$eol;
	} // end of while

	return trim($output);
	}

	?>

File Metadata

Mime Type: text/x-php
Expires: Sun, Apr 5, 11:52 PM (1 w, 4 d ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 18812379
Default Alt Text: rcube_imap.inc (34 KB)

rcube_imap.incNo OneTemporaryActions

rcube_imap.incView Options

File Metadata

Event Timeline

rcube_imap.inc
No OneTemporary
Actions

rcube_imap.inc
View Options