<?php

/**
 * @file classes/log/EventLogDAO.inc.php
 *
 * Copyright (c) 2013-2015 Simon Fraser University Library
 * Copyright (c) 2003-2015 John Willinsky
 * Distributed under the GNU GPL v2. For full terms see the file docs/COPYING.
 *
 * @class EventLogDAO
 * @ingroup log
 * @see EventLogEntry
 *
 * @brief Class for inserting/accessing event log entries.
 */


import ('lib.pkp.classes.log.EventLogEntry');

class EventLogDAO extends DAO {
	/**
	 * Constructor
	 */
	function EventLogDAO() {
		parent::DAO();
	}

	/**
	 * Retrieve a log entry by ID.
	 * @param $logId int
	 * @param $assocId int optional
	 * @param $assocType int optional
	 * @return EventLogEntry
	 */
	function &getById($logId, $assocType = null, $assocId = null) {
		$params = array((int) $logId);
		if (isset($assocType)) {
			$params[] = (int) $assocType;
			$params[] = (int) $assocId;
		}

		$result =& $this->retrieve(
			'SELECT * FROM event_log WHERE log_id = ?' .
			(isset($assocType)?' AND assoc_type = ? AND assoc_id = ?':''),
			$params
		);

		$returner = null;
		if ($result->RecordCount() != 0) {
			$returner =& $this->build($result->GetRowAssoc(false));
		}

		$result->Close();
		unset($result);

		return $returner;
	}

	/**
	 * Retrieve all log entries matching the specified association.
	 * @param $assocType int
	 * @param $assocId int
	 * @param $rangeInfo object optional
	 * @return DAOResultFactory containing matching EventLogEntry ordered by sequence
	 */
	function &getByAssoc($assocType, $assocId, $rangeInfo = null) {
		$params = array((int) $assocType, (int) $assocId);

		$result =& $this->retrieveRange(
			'SELECT * FROM event_log WHERE assoc_type = ? AND assoc_id = ? ORDER BY log_id DESC',
			$params, $rangeInfo
		);

		$returner = new DAOResultFactory($result, $this, 'build');
		return $returner;
	}

	/**
	 * Instantiate a new data object
	 * @return object
	 */
	function newDataObject() {
		return new EventLogEntry();
	}

	/**
	 * Internal function to return an EventLogEntry object from a row.
	 * @param $row array
	 * @return EventLogEntry
	 */
	function &build(&$row) {
		$entry = $this->newDataObject();
		$entry->setId($row['log_id']);
		$entry->setUserId($row['user_id']);
		$entry->setDateLogged($this->datetimeFromDB($row['date_logged']));
		$entry->setIPAddress($row['ip_address']);
		$entry->setEventType($row['event_type']);
		$entry->setAssocType($row['assoc_type']);
		$entry->setAssocId($row['assoc_id']);
		$entry->setMessage($row['message']);
		$entry->setIsTranslated($row['is_translated']);

		$result =& $this->retrieve('SELECT * FROM event_log_settings WHERE log_id = ?', array((int) $entry->getId()));
		$params = array();
		while (!$result->EOF) {
			$r =& $result->getRowAssoc(false);
			$params[$r['setting_name']] = $this->convertFromDB(
				$r['setting_value'],
				$r['setting_type']
			);
			unset($r);
			$result->MoveNext();
		}
		$result->Close();
		unset($result);
		$entry->setParams($params);

		HookRegistry::call('EventLogDAO::build', array(&$entry, &$row));

		return $entry;
	}

	/**
	 * Insert a new log entry.
	 * @param $entry EventLogEntry
	 */
	function insertObject(&$entry) {
		$this->update(
			sprintf('INSERT INTO event_log
				(user_id, date_logged, ip_address, event_type, assoc_type, assoc_id, message, is_translated)
				VALUES
				(?, %s, ?, ?, ?, ?, ?, ?)',
				$this->datetimeToDB($entry->getDateLogged())),
			array(
				(int) $entry->getUserId(),
				$entry->getIPAddress(),
				(int) $entry->getEventType(),
				(int) $entry->getAssocType(),
				(int) $entry->getAssocId(),
				$entry->getMessage(),
				(int) $entry->getIsTranslated()
			)
		);
		$entry->setId($this->getInsertLogId());

		// Add name => value entries into the settings table
		$params = $entry->getParams();
		if (is_array($params)) foreach ($params as $key => $value) {
			$type = null;
			$value = $this->convertToDB($value, $type);
			$params = array(
				(int) $entry->getId(),
				$key, $value, $type
			);
			$this->update(
				'INSERT INTO event_log_settings (log_id, setting_name, setting_value, setting_type) VALUES (?, ?, ?, ?)',
				$params
			);
		}

		return $entry->getId();
	}

	/**
	 * Delete a single log entry (and associated settings).
	 * @param $logId int
	 */
	function deleteObject($logId, $assocType = null, $assocId = null) {
		$params = array((int) $logId);
		if ($assocType !== null) {
			$params[] = (int) $assocType;
			$params[] = (int) $assocId;
		}
		$this->update(
			'DELETE FROM event_log WHERE log_id = ?' .
			($assocType !== null?' AND assoc_type = ? AND assoc_id = ?':''),
			$params
		);
		if ($this->getAffectedRows()) $this->update('DELETE FROM event_log_settings WHERE log_id = ?', array((int) $logId));
	}

	/**
	 * Delete all log entries for an object.
	 * @param $assocType int
	 * @param $assocId int
	 */
	function deleteByAssoc($assocType, $assocId) {
		$entries =& $this->getByAssoc($assocType, $assocId);
		while ($entry =& $entries->next()) {
			$this->deleteObject($entry->getId());
			unset($entry);
		}
		unset($entries);
	}

	/**
	 * Transfer all log entries to another user.
	 * @param $oldUserId int
	 * @param $newUserId int
	 */
	function changeUser($oldUserId, $newUserId) {
		return $this->update(
			'UPDATE event_log SET user_id = ? WHERE user_id = ?',
			array((int) $newUserId, (int) $oldUserId)
		);
	}

	/**
	 * Get the ID of the last inserted log entry.
	 * @return int
	 */
	function getInsertLogId() {
		return $this->getInsertId('event_log', 'log_id');
	}
}

?>