/**

*

* @package phpBB3

* @version $Id: functions_messenger.php 9078 2008-11-22 19:55:00Z acydburn $

* @copyright (c) 2005 phpBB Group

* @license http://opensource.org/licenses/gpl-license.php GNU Public License

*

*/

/**

* @ignore

*/

if (!defined('IN_PHPBB'))

{

	exit;

}

/**

* Messenger

* @package phpBB3

*/

class messenger

{

	var $vars, $msg, $extra_headers, $replyto, $from, $subject;

	var $addresses = array();

	var $mail_priority = MAIL_NORMAL_PRIORITY;

	var $use_queue = true;

	var $tpl_msg = array();

	/**

	* Constructor

	*/

	function messenger($use_queue = true)

	{

		global $config;

		$this->use_queue = (!$config['email_package_size']) ? false : $use_queue;

		$this->subject = '';

	}

	/**

	* Resets all the data (address, template file, etc etc) to default

	*/

	function reset()

	{

		$this->addresses = $this->extra_headers = array();

		$this->vars = $this->msg = $this->replyto = $this->from = '';

		$this->mail_priority = MAIL_NORMAL_PRIORITY;

	}

	/**

	* Sets an email address to send to

	*/

	function to($address, $realname = '')

	{

		global $config;

		$pos = isset($this->addresses['to']) ? sizeof($this->addresses['to']) : 0;

		$this->addresses['to'][$pos]['email'] = trim($address);

		// If empty sendmail_path on windows, PHP changes the to line

		if (!$config['smtp_delivery'] && DIRECTORY_SEPARATOR == '\\')

		{

			$this->addresses['to'][$pos]['name'] = '';

		}

		else

		{

			$this->addresses['to'][$pos]['name'] = trim($realname);

		}

	}

	/**

	* Sets an cc address to send to

	*/

	function cc($address, $realname = '')

	{

		$pos = isset($this->addresses['cc']) ? sizeof($this->addresses['cc']) : 0;

		$this->addresses['cc'][$pos]['email'] = trim($address);

		$this->addresses['cc'][$pos]['name'] = trim($realname);

	}

	/**

	* Sets an bcc address to send to

	*/

	function bcc($address, $realname = '')

	{

		$pos = isset($this->addresses['bcc']) ? sizeof($this->addresses['bcc']) : 0;

		$this->addresses['bcc'][$pos]['email'] = trim($address);

		$this->addresses['bcc'][$pos]['name'] = trim($realname);

	}

	/**

	* Sets a im contact to send to

	*/

	function im($address, $realname = '')

	{

		// IM-Addresses could be empty

		if (!$address)

		{

			return;

		}

		$pos = isset($this->addresses['im']) ? sizeof($this->addresses['im']) : 0;

		$this->addresses['im'][$pos]['uid'] = trim($address);

		$this->addresses['im'][$pos]['name'] = trim($realname);

	}

	/**

	* Set the reply to address

	*/

	function replyto($address)

	{

		$this->replyto = trim($address);

	}

	/**

	* Set the from address

	*/

	function from($address)

	{

		$this->from = trim($address);

	}

	/**

	* set up subject for mail

	*/

	function subject($subject = '')

	{

		$this->subject = trim($subject);

	}

	/**

	* set up extra mail headers

	*/

	function headers($headers)

	{

		$this->extra_headers[] = trim($headers);

	}

	/**

	* Set the email priority

	*/

	function set_mail_priority($priority = MAIL_NORMAL_PRIORITY)

	{

		$this->mail_priority = $priority;

	}

	/**

	* Set email template to use

	*/

	function template($template_file, $template_lang = '')

	{

		global $config, $phpbb_root_path;

		if (!trim($template_file))

		{

			trigger_error('No template file set', E_USER_ERROR);

		}

		if (!trim($template_lang))

		{

			$template_lang = basename($config['default_lang']);

		}

		if (empty($this->tpl_msg[$template_lang . $template_file]))

		{

			$tpl_file = "{$phpbb_root_path}language/$template_lang/email/$template_file.txt";

			if (!file_exists($tpl_file))

			{

				trigger_error("Could not find email template file [ $tpl_file ]", E_USER_ERROR);

			}

			if (($data = @file_get_contents($tpl_file)) === false)

			{

				trigger_error("Failed opening template file [ $tpl_file ]", E_USER_ERROR);

			}

			$this->tpl_msg[$template_lang . $template_file] = $data;

		}

		$this->msg = $this->tpl_msg[$template_lang . $template_file];

		return true;

	}

	/**

	* assign variables to email template

	*/

	function assign_vars($vars)

	{

		$this->vars = (empty($this->vars)) ? $vars : $this->vars + $vars;

	}

	/**

	* Send the mail out to the recipients set previously in var $this->addresses

	*/

	function send($method = NOTIFY_EMAIL, $break = false)

	{

		global $config, $user;

		// We add some standard variables we always use, no need to specify them always

		$this->vars['U_BOARD'] = (!isset($this->vars['U_BOARD'])) ? generate_board_url() : $this->vars['U_BOARD'];

		$this->vars['EMAIL_SIG'] = (!isset($this->vars['EMAIL_SIG'])) ? str_replace('
', "\n", "-- \n" . htmlspecialchars_decode($config['board_email_sig'])) : $this->vars['EMAIL_SIG'];

		$this->vars['SITENAME'] = (!isset($this->vars['SITENAME'])) ? htmlspecialchars_decode($config['sitename']) : $this->vars['SITENAME'];

		// Escape all quotes, else the eval will fail.

		$this->msg = str_replace ("'", "\'", $this->msg);

		$this->msg = preg_replace('#\{([a-z0-9\-_]*?)\}#is', "' . ((isset(\$this->vars['\\1'])) ? \$this->vars['\\1'] : '') . '", $this->msg);

		eval("\$this->msg = '$this->msg';");

		// We now try and pull a subject from the email body ... if it exists,

		// do this here because the subject may contain a variable

		$drop_header = '';

		$match = array();

		if (preg_match('#^(Subject:(.*?))$#m', $this->msg, $match))

		{

			$this->subject = (trim($match[2]) != '') ? trim($match[2]) : (($this->subject != '') ? $this->subject : $user->lang['NO_EMAIL_SUBJECT']);

			$drop_header .= '[\r\n]*?' . preg_quote($match[1], '#');

		}

		else

		{

			$this->subject = (($this->subject != '') ? $this->subject : $user->lang['NO_EMAIL_SUBJECT']);

		}

		if ($drop_header)

		{

			$this->msg = trim(preg_replace('#' . $drop_header . '#s', '', $this->msg));

		}

		if ($break)

		{

			return true;

		}

		switch ($method)

		{

			case NOTIFY_EMAIL:

				$result = $this->msg_email();

			break;

			case NOTIFY_IM:

				$result = $this->msg_jabber();

			break;

			case NOTIFY_BOTH:

				$result = $this->msg_email();

				$this->msg_jabber();

			break;

		}

		$this->reset();

		return $result;

	}

	/**

	* Add error message to log

	*/

	function error($type, $msg)

	{

		global $user, $phpEx, $phpbb_root_path, $config;

		// Session doesn't exist, create it

		if (!isset($user->session_id) || $user->session_id === '')

		{

			$user->session_begin();

		}

		$calling_page = (!empty($_SERVER['PHP_SELF'])) ? $_SERVER['PHP_SELF'] : $_ENV['PHP_SELF'];

		$message = '';

		switch ($type)

		{

			case 'EMAIL':

				$message = 'EMAIL/' . (($config['smtp_delivery']) ? 'SMTP' : 'PHP/' . $config['email_function_name'] . '()') . '';

			break;

			default:

				$message = "$type";

			break;

		}

		$message .= '
' . htmlspecialchars($calling_page) . '

' . $msg . '
';

		add_log('critical', 'LOG_ERROR_' . $type, $message);

	}

	/**

	* Save to queue

	*/

	function save_queue()

	{

		global $config;

		if ($config['email_package_size'] && $this->use_queue && !empty($this->queue))

		{

			$this->queue->save();

			return;

		}

	}

	/**

	* Return email header

	*/

	function build_header($to, $cc, $bcc)

	{

		global $config;

		$headers = array();

		$headers[] = 'From: ' . $this->from;

		if ($cc)

		{

			$headers[] = 'Cc: ' . $cc;

		}

		if ($bcc)

		{

			$headers[] = 'Bcc: ' . $bcc;

		}

		$headers[] = 'Reply-To: ' . $this->replyto;

		$headers[] = 'Return-Path: <' . $config['board_email'] . '>';

		$headers[] = 'Sender: <' . $config['board_email'] . '>';

		$headers[] = 'MIME-Version: 1.0';

		$headers[] = 'Message-ID: <' . md5(unique_id(time())) . '@' . $config['server_name'] . '>';

		$headers[] = 'Date: ' . date('r', time());

		$headers[] = 'Content-Type: text/plain; charset=UTF-8'; // format=flowed

		$headers[] = 'Content-Transfer-Encoding: 8bit'; // 7bit

		$headers[] = 'X-Priority: ' . $this->mail_priority;

		$headers[] = 'X-MSMail-Priority: ' . (($this->mail_priority == MAIL_LOW_PRIORITY) ? 'Low' : (($this->mail_priority == MAIL_NORMAL_PRIORITY) ? 'Normal' : 'High'));

		$headers[] = 'X-Mailer: PhpBB3';

		$headers[] = 'X-MimeOLE: phpBB3';

		$headers[] = 'X-phpBB-Origin: phpbb://' . str_replace(array('http://', 'https://'), array('', ''), generate_board_url());

		// We use \n here instead of \r\n because our smtp mailer is adjusting it to \r\n automatically, whereby the php mail function only works

		// if using \n.

		if (sizeof($this->extra_headers))

		{

			$headers[] = implode("\n", $this->extra_headers);

		}

		return implode("\n", $headers);

	}

	/**

	* Send out emails

	*/

	function msg_email()

	{

		global $config, $user;

		if (empty($config['email_enable']))

		{

			return false;

		}

		$use_queue = false;

		if ($config['email_package_size'] && $this->use_queue)

		{

			if (empty($this->queue))

			{

				$this->queue = new queue();

				$this->queue->init('email', $config['email_package_size']);

			}

			$use_queue = true;

		}

		if (empty($this->replyto))

		{

			$this->replyto = '<' . $config['board_contact'] . '>';

		}

		if (empty($this->from))

		{

			$this->from = '<' . $config['board_contact'] . '>';

		}

		// Build to, cc and bcc strings

		$to = $cc = $bcc = '';

		foreach ($this->addresses as $type => $address_ary)

		{

			if ($type == 'im')

			{

				continue;

			}

			foreach ($address_ary as $which_ary)

			{

				$$type .= (($$type != '') ? ', ' : '') . (($which_ary['name'] != '') ? '"' . mail_encode($which_ary['name']) . '" <' . $which_ary['email'] . '>' : $which_ary['email']);

			}

		}

		// Build header

		$headers = $this->build_header($to, $cc, $bcc);

		// Send message ...

		if (!$use_queue)

		{

			$mail_to = ($to == '') ? 'undisclosed-recipients:;' : $to;

			$err_msg = '';

			if ($config['smtp_delivery'])

			{

				$result = smtpmail($this->addresses, mail_encode($this->subject), wordwrap(utf8_wordwrap($this->msg), 997, "\n", true), $err_msg, $headers);

			}

			else

			{

				ob_start();

				$result = $config['email_function_name']($mail_to, mail_encode($this->subject), wordwrap(utf8_wordwrap($this->msg), 997, "\n", true), $headers);

				$err_msg = ob_get_clean();

			}

			if (!$result)

			{

				$this->error('EMAIL', $err_msg);

				return false;

			}

		}

		else

		{

			$this->queue->put('email', array(

				'to'			=> $to,

				'addresses'		=> $this->addresses,

				'subject'		=> $this->subject,

				'msg'			=> $this->msg,

				'headers'		=> $headers)

			);

		}

		return true;

	}

	/**

	* Send jabber message out

	*/

	function msg_jabber()

	{

		global $config, $db, $user, $phpbb_root_path, $phpEx;

		if (empty($config['jab_enable']) || empty($config['jab_host']) || empty($config['jab_username']) || empty($config['jab_password']))

		{

			return false;

		}

		if (empty($this->addresses['im']))

		{

			return false;

		}

		$use_queue = false;

		if ($config['jab_package_size'] && $this->use_queue)

		{

			if (empty($this->queue))

			{

				$this->queue = new queue();

				$this->queue->init('jabber', $config['jab_package_size']);

			}

			$use_queue = true;

		}

		$addresses = array();

		foreach ($this->addresses['im'] as $type => $uid_ary)

		{

			$addresses[] = $uid_ary['uid'];

		}

		$addresses = array_unique($addresses);

		if (!$use_queue)

		{

			include_once($phpbb_root_path . 'includes/functions_jabber.' . $phpEx);

			$this->jabber = new jabber($config['jab_host'], $config['jab_port'], $config['jab_username'], $config['jab_password'], $config['jab_use_ssl']);

			if (!$this->jabber->connect())

			{

				$this->error('JABBER', $user->lang['ERR_JAB_CONNECT'] . '
' . $this->jabber->get_log());

				return false;

			}

			if (!$this->jabber->login())

			{

				$this->error('JABBER', $user->lang['ERR_JAB_AUTH'] . '
' . $this->jabber->get_log());

				return false;

			}

			foreach ($addresses as $address)

			{

				$this->jabber->send_message($address, $this->msg, $this->subject);

			}

			$this->jabber->disconnect();

		}

		else

		{

			$this->queue->put('jabber', array(

				'addresses'		=> $addresses,

				'subject'		=> $this->subject,

				'msg'			=> $this->msg)

			);

		}

		unset($addresses);

		return true;

	}

}

/**

* handling email and jabber queue

* @package phpBB3

*/

class queue

{

	var $data = array();

	var $queue_data = array();

	var $package_size = 0;

	var $cache_file = '';

	/**

	* constructor

	*/

	function queue()

	{

		global $phpEx, $phpbb_root_path;

		$this->data = array();

		$this->cache_file = "{$phpbb_root_path}cache/queue.$phpEx";

	}

	/**

	* Init a queue object

	*/

	function init($object, $package_size)

	{

		$this->data[$object] = array();

		$this->data[$object]['package_size'] = $package_size;

		$this->data[$object]['data'] = array();

	}

	/**

	* Put object in queue

	*/

	function put($object, $scope)

	{

		$this->data[$object]['data'][] = $scope;

	}

	/**

	* Process queue

	* Using lock file

	*/

	function process()

	{

		global $db, $config, $phpEx, $phpbb_root_path, $user;

		set_config('last_queue_run', time(), true);

		// Delete stale lock file

		if (file_exists($this->cache_file . '.lock') && !file_exists($this->cache_file))

		{

			@unlink($this->cache_file . '.lock');

			return;

		}

		if (!file_exists($this->cache_file) || (file_exists($this->cache_file . '.lock') && filemtime($this->cache_file) > time() - $config['queue_interval']))

		{

			return;

		}

		$fp = @fopen($this->cache_file . '.lock', 'wb');

		fclose($fp);

		@chmod($this->cache_file . '.lock', 0777);

		include($this->cache_file);

		foreach ($this->queue_data as $object => $data_ary)

		{

			@set_time_limit(0);

			if (!isset($data_ary['package_size']))

			{

				$data_ary['package_size'] = 0;

			}

			$package_size = $data_ary['package_size'];

			$num_items = (!$package_size || sizeof($data_ary['data']) < $package_size) ? sizeof($data_ary['data']) : $package_size;

			// If the amount of emails to be sent is way more than package_size than we need to increase it to prevent backlogs...

			if (sizeof($data_ary['data']) > $package_size * 2.5)

			{

				$num_items = sizeof($data_ary['data']);

			}

			switch ($object)

			{

				case 'email':

					// Delete the email queued objects if mailing is disabled

					if (!$config['email_enable'])

					{

						unset($this->queue_data['email']);

						continue 2;

					}

				break;

				case 'jabber':

					if (!$config['jab_enable'])

					{

						unset($this->queue_data['jabber']);

						continue 2;

					}

					include_once($phpbb_root_path . 'includes/functions_jabber.' . $phpEx);

					$this->jabber = new jabber($config['jab_host'], $config['jab_port'], $config['jab_username'], $config['jab_password'], $config['jab_use_ssl']);

					if (!$this->jabber->connect())

					{

						messenger::error('JABBER', $user->lang['ERR_JAB_CONNECT']);

						continue 2;

					}

					if (!$this->jabber->login())

					{

						messenger::error('JABBER', $user->lang['ERR_JAB_AUTH']);

						continue 2;

					}

				break;

				default:

					return;

			}

			for ($i = 0; $i < $num_items; $i++)

			{

				// Make variables available...

				extract(array_shift($this->queue_data[$object]['data']));

				switch ($object)

				{

					case 'email':

						$err_msg = '';

						$to = (!$to) ? 'undisclosed-recipients:;' : $to;

						if ($config['smtp_delivery'])

						{

							$result = smtpmail($addresses, mail_encode($subject), wordwrap(utf8_wordwrap($msg), 997, "\n", true), $err_msg, $headers);

						}

						else

						{

							ob_start();

							$result = $config['email_function_name']($to, mail_encode($subject), wordwrap(utf8_wordwrap($msg), 997, "\n", true), $headers);

							$err_msg = ob_get_clean();

						}

						if (!$result)

						{

							@unlink($this->cache_file . '.lock');

							messenger::error('EMAIL', $err_msg);

							continue 2;

						}

					break;

					case 'jabber':

						foreach ($addresses as $address)

						{

							if ($this->jabber->send_message($address, $msg, $subject) === false)

							{

								messenger::error('JABBER', $this->jabber->get_log());

								continue 3;

							}

						}

					break;

				}

			}

			// No more data for this object? Unset it

			if (!sizeof($this->queue_data[$object]['data']))

			{

				unset($this->queue_data[$object]);

			}

			// Post-object processing

			switch ($object)

			{

				case 'jabber':

					// Hang about a couple of secs to ensure the messages are

					// handled, then disconnect

					$this->jabber->disconnect();

				break;

			}

		}

		if (!sizeof($this->queue_data))

		{

			@unlink($this->cache_file);

		}

		else

		{

			if ($fp = @fopen($this->cache_file, 'wb'))

			{

				@flock($fp, LOCK_EX);

				fwrite($fp, "queue_data = unserialize(" . var_export(serialize($this->queue_data), true) . ");\n\n?>");

				@flock($fp, LOCK_UN);

				fclose($fp);

				phpbb_chmod($this->cache_file, CHMOD_WRITE);

			}

		}

		@unlink($this->cache_file . '.lock');

	}

	/**