<?php
namespace wcf\data\chat\message;

/**
 * Provides functions to edit chat messages.
 *
 * @author 	Tim Düsterhus
 * @copyright	2010-2012 Tim Düsterhus
 * @license	Creative Commons Attribution-NonCommercial-ShareAlike <http://creativecommons.org/licenses/by-nc-sa/3.0/legalcode>
 * @package	be.bastelstu.wcf.chat
 * @subpackage	data.chat.message
 */
class ChatMessageEditor extends \wcf\data\DatabaseObjectEditor {
	/**
	 * @see	\wcf\data\DatabaseObjectDecorator::$baseClass
	 */
	protected static $baseClass = '\wcf\data\chat\message\ChatMessage';
	
	/**
	 * Notify the Push-Server.
	 */
	public static function create(array $parameters = array()) {
		try {
			if (CHAT_SOCKET_IO_PATH) {
				if (file_exists(WCF_DIR.'acp/be.bastelstu.wcf.chat.serverPush/data.sock')) {
					$sock = stream_socket_client('unix://'.WCF_DIR.'acp/be.bastelstu.wcf.chat.serverPush/data.sock', $errno, $errstr, 1);
					fclose($sock);
				}
			}
		}
		catch (\Exception $e) { }
		
		return parent::create($parameters);
	}
	
	/**
	 * Removes old messages.
	 *
	 * @param	integer	$lifetime	Delete messages older that this time.
	 * @return	integer			Number of deleted messages.
	 */
	public static function prune($lifetime = CHAT_LOG_ARCHIVETIME) {
		$sql = "SELECT
				".static::getDatabaseTableIndexName()."
			FROM
				".static::getDatabaseTableName()."
			WHERE
				time < ?";
		$stmt = \wcf\system\WCF::getDB()->prepareStatement($sql);
		$stmt->execute(array(TIME_NOW - $lifetime));
		$objectIDs = array();
		while ($objectIDs[] = $stmt->fetchColumn());
		
		return self::deleteAll($objectIDs);
	}
}