<?php
// Survey database interface class as intermediate for storing data from the site to the RDF database 
require_once 'rdfConstants.php';
// Include RAP Library to write RDF files
include(RDFAPI_INCLUDE_DIR . "RDFAPI.php");

/**
 * Description of SessionInstanceConnector
 *
 * @author jkraaijeveld
 */
class SessionInstanceConnector extends Connector  
{
	protected $db;

	/**
	 * Constructor for the SessionInstanceConnector.
	 */

	public function __construct()
	{
		$this->fileName = 'data/sessions/sessioninstances.rdf';
		//Ensure the required folder for this connector exists.
		if(!is_dir('data/sessions'))
			mkdir('data/sessions');
	}

	/**
	 * function get()
	 * @param type $arguments : An array containing one or more of the following elements:
	 * 'uid', 'title', 'location', 'facilitator', 'starttime', 'endtime' 'notes', 'session', 'resultset'
	 */
	public function get($arguments)
	{
		$this->load();

		//Build the query string
		$querystring = '
			PREFIX predicates: <' . SURVEYTOOL_PREDICATES_NAMESPACE . '>
			PREFIX resources: <' . SURVEYTOOL_RESOURCES_NAMESPACE . '>
			SELECT DISTINCT ?uid, ?title, ?location, ?facilitator, ?starttime, ?endtime, ?of_session, ?has_resultset 
			WHERE
			{
				_sessioninstance predicates:resource_type resources:sessioninstance ;
				predicates:uid ?uid ;
				predicates:title ?title ;
				predicates:location ?location ;
				predicates:facilitator ?facilitator ;
				predicates:starttime ?starttime ;
				predicates:endtime ?endtime ;
				predicates:of_session ?of_session ;
				' . $this->createArguments($arguments) . '
	}';
		//Query the model
		$results = $this->model->sparqlQuery($querystring);
		$sessioninstances = array();
		if(!empty($results))
		{	
			$this->db = new DatabaseInterface();
			foreach($results as $result)
			{
				//Create a SessionInstance object out of every result. Get all the required fields as well.
				$notes = $this->getNotes($result['?uid']->label);
				$resultset = $this->getResultSet($result['?uid']->label);
				$starttime = new DateTime();
				$starttime->setTimestamp(intval($result['?starttime']->label));
				$endtime = new DateTime();
				$endtime->setTimestamp(intval($result['?endtime']->label));
				$sessioninstances[] = new SessionInstance(  
					$result['?uid']->label,
					$result['?title']->label,
					$result['?location']->label,
					$result['?facilitator']->label,
					$starttime,
					$endtime,
					$notes,
					$result['?of_session'],
					$resultset
				);
			}
		}
		return $sessioninstances;
	}
	
	/**
	 * function getNotes()
	 * param type $uid : The SessionInstance uid for which the notes should be retrieved.
	 */
	public function getNotes($uid)
	{
		$result = $this->model->findRegex("[(".$uid.")]", "[(has_note)]", null);
		$iterator = $result->getStatementIterator();
		$notes = array();
		while($iterator->hasNext())
		{
			$element = $iterator->next();
			$notes[] = $element->getLabelObject();
		}
		return $notes;
	}

	/**
	 * function getResultSet($uid)
	 * param type $uid : The SessionInstance uid for which the ResultSet should be gotten.
	 */
	public function getResultSet($udi)
	{
		//TODO: Implement when ResultSet is in.
		return null;
	}

	/**
	 * function set()
	 * @param type $rToolObject: The ResearchToolObject to be saved.
	 */
	public function set($rToolObject)
	{
		$this->load();
		//If evaluation fails, some references are incorrect.
		//We shouldn't save in this case. Instead - let the user know. This function returns false if the evaluation has failed.
		//TODO: Decide how to fix invalid references graciously.
		if(!$rToolObject->evaluate()) 
			return false;
		$resourceSInstance = new Resource(SESSIONINSTANCE . '/' . $rToolObject->uid);
		//Remove the old value stored with the given id
		$this->model->subtract($this->model->find($resourceSInstance, null, null));

		//Set the new values
		$resourceSInstanceType = new Resource(SESSIONINSTANCE);
		$predicateType = new Resource(RTYPE);
		$this->model->add(new Statement($resourceSInstance, $predicateType, $resourceSInstanceType));

		$sInstanceId = new Literal($rToolObject->uid);
		$predicateId = new Resource(UID);
		$this->model->add(new Statement($resourceSInstance, $predicateId, $sInstanceId));

		$sInstanceTitle = new Literal($rToolObject->title);
		$predicateTitle = new Resource(TITLE);
		$this->model->add(new Statement($resourceSInstance, $predicateTitle, $sInstanceTitle));

		$sInstanceLocation = new Literal($rToolObject->location);
		$predicateLocation = new Resource(LOCATION);
		$this->model->add(new Statement($resourceSInstance, $predicateLocation, $sInstanceLocation));

		$sInstanceFacilitator = new Literal($rToolObject->facilitator->uid);
		$predicateFacilitator = new Resource(FACILITATOR);
		$this->model->add(new Statement($resourceSInstance, $predicateFacilitator, $sInstanceFacilitator));

		$sInstanceStartTime = new Literal($rToolObject->starttime->getTimestamp());
		$predicateStartTime = new Resource(STARTTIME);
		$this->model->add(new Statement($resourceSInstance, $predicateStartTime, $sInstanceStartTime));

		$sInstanceEndTime = new Literal($rToolObject->endtime->getTimestamp());
		$predicateEndTime = new Resource(ENDTIME);
		$this->model->add(new Statement($resourceSInstance, $predicateEndTime, $sInstanceEndTime));

		if(isset($rToolObject->notes))
		{
			foreach($rToolObject->notes as $note)
			{
				$sInstanceNote = new Literal($note);
				$predicateNote = new Resource(HAS_NOTE);
				$this->model->add(new Statement($resourceSInstance, $predicateNote, $sInstanceNote));
			}
		}

		$sInstanceSession = new Literal($rToolObject->session->uid);
		$predicateSession = new Resource(OF_SESSION);
		$this->model->add(new Statement($resourceSInstance, $predicateSession, $sInstanceSession));

		if(isset($rToolObject->resultset))
		{
			//$sInstanceResultSet = new Literal($rToolObject->resultset->uid);
			$sInstanceResultSet = new Literal($rToolObject->resultset);
			$predicateResultSet = new Resource(HAS_RESULTSET);
			$this->model->add(new Statement($resourceSInstance, $predicateResultSet, $sInstanceResultSet));
		}
		$this->save();
		return true;
	}
}
?>