Use \PDO::fetchAll() instead of PreparedStatement::fetchColumns()

[GitHub/WoltLab/WCF.git] / wcfsetup / install / files / lib / system / edit / EditHistoryManager.class.php

<?php
namespace wcf\system\edit;
use wcf\data\edit\history\entry\EditHistoryEntryList;
use wcf\data\object\type\ObjectTypeCache;
use wcf\system\exception\SystemException;
use wcf\system\SingletonFactory;
use wcf\system\WCF;

/**
 * Manages the edit history.
 * 
 * @author	Tim Duesterhus
 * @copyright	2001-2015 WoltLab GmbH
 * @license	GNU Lesser General Public License <http://opensource.org/licenses/lgpl-license.php>
 * @package	com.woltlab.wcf
 * @subpackage	system.search
 * @category	Community Framework
 */
class EditHistoryManager extends SingletonFactory {
	/**
	 * list of available object types
	 * @var	array
	 */
	protected $availableObjectTypes = array();
	
	/**
	 * @see	\wcf\system\SingletonFactory::init()
	 */
	protected function init() {
		// get available object types
		$this->availableObjectTypes = ObjectTypeCache::getInstance()->getObjectTypes('com.woltlab.wcf.edit.historySavingObject');
	}
	
	/**
	 * Returns the id of the object type with the given name.
	 * 
	 * @param	string		$objectType
	 * @return	integer
	 * @throws	SystemException
	 */
	public function getObjectTypeID($objectType) {
		if (!isset($this->availableObjectTypes[$objectType])) {
			throw new SystemException("unknown object type '".$objectType."'");
		}
		
		return $this->availableObjectTypes[$objectType]->objectTypeID;
	}
	
	/**
	 * Adds a new entry.
	 * 
	 * @param	string		$objectType
	 * @param	integer		$objectID
	 * @param	string		$message
	 * @param	integer		$time
	 * @param	integer		$userID
	 * @param	string		$username
	 * @param	string		$editReason
	 * @param	integer		$obsoletedByUserID	The userID of the user that forced this entry to become outdated
	 */
	public function add($objectType, $objectID, $message, $time, $userID, $username, $editReason, $obsoletedByUserID) {
		// no op, if edit history is disabled
		if (!MODULE_EDIT_HISTORY) return;
		
		// save new entry
		$sql = "INSERT INTO	wcf".WCF_N."_edit_history_entry
					(objectTypeID, objectID, message, time, obsoletedAt, userID, username, editReason, obsoletedByUserID)
			VALUES		(?, ?, ?, ?, ?, ?, ?, ?, ?)";
		$statement = WCF::getDB()->prepareStatement($sql);
		$statement->execute(array($this->getObjectTypeID($objectType), $objectID, $message, $time, TIME_NOW, $userID, $username, $editReason, $obsoletedByUserID));
	}
	
	/**
	 * Deletes edit history entries.
	 * 
	 * @param	string		$objectType
	 * @param	integer[]	$objectIDs
	 */
	public function delete($objectType, array $objectIDs) {
		$objectTypeID = $this->getObjectTypeID($objectType);
		
		$sql = "DELETE FROM	wcf".WCF_N."_edit_history_entry
			WHERE		objectTypeID = ?
				AND	objectID = ?";
		$statement = WCF::getDB()->prepareStatement($sql);
		WCF::getDB()->beginTransaction();
		foreach ($objectIDs as $objectID) {
			$statement->execute(array($objectTypeID, $objectID));
		}
		WCF::getDB()->commitTransaction();
	}
	
	/**
	 * Performs mass reverting of edits by the given users in the given timeframe.
	 * 
	 * @param	integer[]	$userIDs
	 * @param	integer		$timeframe
	 */
	public function bulkRevert(array $userIDs, $timeframe = 86400) {
		if (empty($userIDs)) return;
		
		// 1: Select the newest edit history item for each object ("newestEntries")
		// 2: Check whether the edit was made by the offending users ("vandalizedEntries")
		// 3: Fetch the newest version that is either:
		//    a) older than $timeframe days
		//    b) by a non offending user
		$userIDPlaceholders = '?'.str_repeat(',?', count($userIDs) - 1);
		$sql = "SELECT	MAX(entryID)
			FROM	wcf".WCF_N."_edit_history_entry revertTo
			INNER JOIN(
				SELECT	vandalizedEntries.objectID,
					vandalizedEntries.objectTypeID
				FROM	wcf".WCF_N."_edit_history_entry vandalizedEntries
				INNER JOIN (
					SELECT		MAX(newestEntries.entryID) AS entryID
					FROM		wcf".WCF_N."_edit_history_entry newestEntries
					WHERE		newestEntries.obsoletedAt > ?
					GROUP BY	newestEntries.objectTypeID, newestEntries.objectID
				) newestEntries2
				WHERE		newestEntries2.entryID = vandalizedEntries.entryID
					AND	vandalizedEntries.obsoletedByUserID IN (".$userIDPlaceholders.")
			) AS vandalizedEntries2
			WHERE		revertTo.objectID = vandalizedEntries2.objectID
				AND	revertTo.objectTypeID = vandalizedEntries2.objectTypeID
				AND	(	revertTo.obsoletedAt <= ?
					OR	revertTo.userID NOT IN(".$userIDPlaceholders."))
			GROUP BY revertTo.objectTypeID, revertTo.objectID";
		$statement = WCF::getDB()->prepareStatement($sql);
		$statement->execute(array_merge(
			array(TIME_NOW - $timeframe),
			$userIDs,
			array(TIME_NOW - $timeframe),
			$userIDs
		));
		
		$entryIDs = $statement->fetchAll(\PDO::FETCH_COLUMN);
		if (empty($entryIDs)) return;
		
		$list = new EditHistoryEntryList();
		$list->getConditionBuilder()->add('entryID IN(?)', array($entryIDs));
		$list->readObjects();
		foreach ($list as $entry) {
			$entry->getObject()->revertVersion($entry);
		}
	}
}