.-.-.-.-.-

<?php defined('_JEXEC') or die;
/**
 * @package   Fox Contact for Joomla
 * @copyright Copyright (c) Fox Labs, all rights reserved.
 * @license   Distributed under the terms of the GNU General Public License GNU/GPL v3 http://www.gnu.org/licenses/gpl-3.0.html
 * @see       Documentation: http://www.fox.ra.it/forum/2-documentation.html
 */

class Swift_FileSpool extends Swift_ConfigurableSpool
{
	private $_path;
	private $_retryLimit = 10;
	
	public function __construct($path)
	{
		$this->_path = $path;
		if (!file_exists($this->_path))
		{
			if (!mkdir($this->_path, 511, true))
			{
				throw new Swift_IoException(sprintf('Unable to create path "%s".', $this->_path));
			}
		
		}
	
	}
	
	
	public function isStarted()
	{
		return true;
	}
	
	
	public function start()
	{
	}
	
	
	public function stop()
	{
	}
	
	
	public function setRetryLimit($limit)
	{
		$this->_retryLimit = $limit;
	}
	
	
	public function queueMessage(Swift_Mime_Message $message)
	{
		$ser = serialize($message);
		$fileName = $this->_path . '/' . $this->getRandomString(10);
		for ($i = 0; $i < $this->_retryLimit; ++$i)
		{
			$fp = @fopen($fileName . '.message', 'x');
			if (false !== $fp)
			{
				if (false === fwrite($fp, $ser))
				{
					return false;
				}
				
				return fclose($fp);
			}
			else
			{
				$fileName .= $this->getRandomString(1);
			}
		
		}
		
		throw new Swift_IoException(sprintf('Unable to create a file for enqueuing Message in "%s".', $this->_path));
	}
	
	
	public function recover($timeout = 900)
	{
		foreach (new DirectoryIterator($this->_path) as $file)
		{
			$file = $file->getRealPath();
			if (substr($file, -16) == '.message.sending')
			{
				$lockedtime = filectime($file);
				if (time() - $lockedtime > $timeout)
				{
					rename($file, substr($file, 0, -8));
				}
			
			}
		
		}
	
	}
	
	
	public function flushQueue(Swift_Transport $transport, &$failedRecipients = null)
	{
		$directoryIterator = new DirectoryIterator($this->_path);
		if (!$transport->isStarted())
		{
			foreach ($directoryIterator as $file)
			{
				if (substr($file->getRealPath(), -8) == '.message')
				{
					$transport->start();
					break;
				}
			
			}
		
		}
		
		$failedRecipients = (array) $failedRecipients;
		$count = 0;
		$time = time();
		foreach ($directoryIterator as $file)
		{
			$file = $file->getRealPath();
			if (substr($file, -8) != '.message')
			{
				continue;
			}
			
			if (rename($file, $file . '.sending'))
			{
				$message = unserialize(file_get_contents($file . '.sending'));
				$count += $transport->send($message, $failedRecipients);
				unlink($file . '.sending');
			}
			else
			{
				continue;
			}
			
			if ($this->getMessageLimit() && $count >= $this->getMessageLimit())
			{
				break;
			}
			
			if ($this->getTimeLimit() && time() - $time >= $this->getTimeLimit())
			{
				break;
			}
		
		}
		
		return $count;
	}
	
	
	protected function getRandomString($count)
	{
		$base = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789_-';
		$ret = '';
		$strlen = strlen($base);
		for ($i = 0; $i < $count; ++$i)
		{
			$ret .= $base[(int) rand(0, $strlen - 1)];
		}
		
		return $ret;
	}

}

/home/locationbo/www/./libraries/foxcontact/swiftmailer/classes/Swift/FileSpool.php