<?php

/**
 * Copyright 2009, 2010 AEGEE-Europe
*
* This file is part of AEGEE-Europe Online Membership System.
*
* AEGEE-Europe Online Membership System is free software: you can
* redistribute it and/or modify it under the terms of the GNU General
* Public License as published by the Free Software Foundation, either
* version 3 of the License, or (at your option) any later version.
*
* AEGEE-Europe Online Membership System is distributed in the hope
* that it will be useful, but WITHOUT ANY WARRANTY; without even the
* implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
* PURPOSE.  See the GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with AEGEE-Europe Online Membership System.  If not, see
* <http://www.gnu.org/licenses/>.
*/

/**
 * Agorae Database Access Object. This class provides functionality to
* load and save Agorae title.
*/

require_once(FILESYSTEMROOTPATH."include/classes/IDao.php");
//require_once(FILESYSTEMROOTPATH."jc/include/model/Agorae.php");

class NotificationsDao implements IDao {
	/** MySQL object */
	private $mysql;

	/**
	 * Default constructor
	 */
	public function __construct(MySQL $mysql) {
		$this->mysql = $mysql;
	}

	/**
	 * Load Agorae by id
	 *
	 * @param id
	 * @return
	 */
	public function loadMine() {
		$aid = $_SESSION['JC_MODULE']['AgoraId'];
		$uid = $_SESSION['sess_uid'];
		$query = "SELECT `type`, COUNT(*) AS nn FROM notifications 
		WHERE `agora_id`=$aid AND `uid`='$uid' AND `open` < NOW() AND `close` > NOW() GROUP BY `type`";
		$ret =array('Proposal'=>0,'Rollcall'=>0,'Election'=>0, 'Poll'=>0, 'RankedVote'=>0);
		if( $this->mysql->query($query) ) {
			while($row = $this->mysql->fetchArray()){
			 $ret[$row['type']] = $row['nn'];	
			}
			return $ret;
		}else {
			return array();
		}
	}

	/**
	 * Load all CIA
	 *
	 * @return array of all Agorae
	 */
	public function create($pid, $type, $open, $close) {
		$aid = $_SESSION['JC_MODULE']['AgoraId']; 
		$query ="INSERT INTO notifications (`agora_id`,`uid`,`pid`,`type`,`open`,`close`)
		SELECT '$aid', `uid`, '$pid', '$type', '$open', '$close'
		FROM voting_delegates WHERE agora_id=".$aid;

		return $this->mysql->query($query);
	}
	
	public function update($pid, $type, $open, $close){
		$aid = $_SESSION['JC_MODULE']['AgoraId'];
		$query = "UPDATE notifications SET `open`='$open', `close`='$close'
		WHERE `pid`=$pid AND `type`='$type' AND `agora_id`=$aid";
		return $this->mysql->query($query);
	}
	
	public function seen($pid, $type){
		$aid = $_SESSION['JC_MODULE']['AgoraId'];
		$uid = $_SESSION['sess_uid'];
		$query = "DELETE FROM notifications 
		WHERE `agora_id`=$aid AND `uid`='$uid' AND `pid`='$pid' AND `type`='$type'";
		return $this->mysql->query($query);
	}
	
	public function exists($pid, $type){
		$aid = $_SESSION['JC_MODULE']['AgoraId'];
		$query = "SELECT count(*) AS nn FROM notifications
				WHERE `agora_id`=$aid AND `pid`='$pid' AND `type`='$type'";
		$this->mysql->query($query);
		$res = $this->mysql->fetchArray();
		if ($res['nn']>0){
			return true;
		}else{
			return false;
		}
	}
	
	/**
	 * Save or update Agorae:
	 * @param Agorae object with the data
	 * @return boolean true in case of success, false otherwise
	 */
	public function saveOrUpdate(IModel $model) {
		return '';
	}
	
	public function load($key){
		return '';
	}
}
?>