<?php
namespace JExtstore\Component\JChat\Administrator\Table;
/**
 *
 * @package JCHAT::FORM::components::com_jchat
 * @subpackage tables
 * @author Joomla! Extensions Store
 * @Copyright (C) 2015 - Joomla! Extensions Store
 * @license GNU/GPLv2 http://www.gnu.org/licenses/gpl-2.0.html
 */
// no direct access
defined ( '_JEXEC' ) or die ( 'Restricted access' );
use Joomla\CMS\Language\Text;
use Joomla\CMS\Table\Table;
use Joomla\Database\DatabaseDriver;

/**
 * ORM Table for session entities
 *
 * @package JCHAT::FORM::components::com_jchat
 * @subpackage tables
 * @since 2.4
 */
class SessionTable extends Table {
	/**
	 * Insert a session
	 *
	 * @param string $sessionId
	 *        	The session id
	 * @param integer $clientId
	 *        	The id of the client application
	 *        	
	 * @return boolean True on success
	 */
	public function insert($sessionId, $clientId) {
		$this->session_id = $sessionId;
		$this->client_id = $clientId;
		
		$this->time = time ();
		$ret = $this->_db->insertObject ( $this->_tbl, $this, 'session_id' );
		
		if (! $ret) {
			$this->setError ( Text::sprintf ( 'JLIB_DATABASE_ERROR_STORE_FAILED', strtolower ( get_class ( $this ) ), $this->_db->stderr () ) );
			
			return false;
		} else {
			return true;
		}
	}
	
	/**
	 * Updates the session
	 *
	 * @param boolean $updateNulls
	 *        	True to update fields even if they are null.
	 *        	
	 * @return boolean True on success.
	 */
	public function update($updateNulls = false) {
		$this->time = time ();
		$ret = $this->_db->updateObject ( $this->_tbl, $this, 'session_id', $updateNulls );
		
		if (! $ret) {
			$this->setError ( Text::sprintf ( 'JLIB_DATABASE_ERROR_STORE_FAILED', strtolower ( get_class ( $this ) ), $this->_db->stderr () ) );
			
			return false;
		} else {
			return true;
		}
	}
	
	/**
	 * Destroys the pre-existing session
	 *
	 * @param integer $userId
	 *        	Identifier of the user for this session.
	 * @param array $clientIds
	 *        	Array of client ids for which session(s) will be destroyed
	 *        	
	 * @return boolean True on success.
	 */
	public function destroy($userId, $clientIds = array()) {
		$clientIds = implode ( ',', $clientIds );
		
		$query = $this->_db->getQuery ( true )->delete ( $this->_db->quoteName ( $this->_tbl ) )->where ( $this->_db->quoteName ( 'userid' ) . ' = ' . $this->_db->quote ( $userId ) )->where ( $this->_db->quoteName ( 'client_id' ) . ' IN (' . $clientIds . ')' );
		$this->_db->setQuery ( $query );
		
		if (! $this->_db->execute ()) {
			$this->setError ( $this->_db->stderr () );
			
			return false;
		}
		
		return true;
	}
	
	/**
	 * Purge old sessions
	 *
	 * @param integer $maxLifetime
	 *        	Session age in seconds
	 *        	
	 * @return mixed Resource on success, null on fail
	 */
	public function purge($maxLifetime = 1440) {
		$past = time () - $maxLifetime;
		$query = $this->_db->getQuery ( true )->delete ( $this->_db->quoteName ( $this->_tbl ) )->where ( $this->_db->quoteName ( 'time' ) . ' < ' . ( int ) $past );
		$this->_db->setQuery ( $query );
		
		return $this->_db->execute ();
	}
	
	/**
	 * Find out if a user has a one or more active sessions
	 *
	 * @param integer $userid
	 *        	The identifier of the user
	 *        	
	 * @return boolean True if a session for this user exists
	 */
	public function exists($userid) {
		$query = $this->_db->getQuery ( true )->select ( 'COUNT(userid)' )->from ( $this->_db->quoteName ( $this->_tbl ) )->where ( $this->_db->quoteName ( 'userid' ) . ' = ' . $this->_db->quote ( $userid ) );
		$this->_db->setQuery ( $query );
		
		if (! $result = $this->_db->loadResult ()) {
			$this->setError ( $this->_db->stderr () );
			
			return false;
		}
		
		return ( boolean ) $result;
	}
	
	/**
	 * Overloaded delete method
	 *
	 * We must override it because of the non-integer primary key
	 *
	 * @param integer $oid
	 *        	The object id (optional).
	 *        	
	 * @return mixed True if successful otherwise an error message
	 */
	public function delete($oid = null) {
		$k = $this->_tbl_key;
		
		if ($oid) {
			$this->$k = $oid;
		}
		
		$query = $this->_db->getQuery ( true )->delete ( $this->_db->quoteName ( $this->_tbl ) )->where ( $this->_db->quoteName ( $this->_tbl_key ) . ' = ' . $this->_db->quote ( $this->$k ) );
		$this->_db->setQuery ( $query );
		
		$this->_db->execute ();
		
		return true;
	}
	
	/**
	 * Constructor
	 *
	 * @param Object $db Database driver object.
	 */
	public function __construct(DatabaseDriver $db) {
		parent::__construct ( '#__session', 'session_id', $db );
		
		$this->guest = 1;
		$this->username = '';
		$this->session_id = '';
		$this->userid = 0;
	}
}