<?php
	// No direct access
	defined( '_JEXEC' ) or die( 'Restricted access' );

	jimport( 'joomla.application.component.model' );

	// Setup the path to the thrift library folder
	$GLOBALS['THRIFT_ROOT'] = dirname(__FILE__) . DS . 'thrift';

	// Load up all the thrift stuff
	require_once($GLOBALS['THRIFT_ROOT'] . DS . 'Thrift.php');
	require_once($GLOBALS['THRIFT_ROOT'] . DS . 'protocol' . DS . 'TBinaryProtocol.php');
	require_once($GLOBALS['THRIFT_ROOT'] . DS . 'transport' . DS . 'TSocket.php');
	require_once($GLOBALS['THRIFT_ROOT'] . DS . 'transport' . DS . 'TBufferedTransport.php');
	require_once ($GLOBALS['THRIFT_ROOT'] . DS . 'packages' . DS . 'openaire' . DS . 'OpenAireConnector.php');

	class OpenaireModelStatistics extends JModel {
	      private $client = null;
	      private $transport = null;
	      private $searchMenuId = 0;

		public function __construct($configuration) {
			parent :: __construct($configuration);
			$db =& JFactory :: getDBO();

			$db -> setQuery('SELECT `value` FROM `#__openaire` WHERE `key` = \'thriftConnectorHost\'');
			$host = $db -> loadResult();

			$db -> setQuery('SELECT `value` FROM `#__openaire` WHERE `key` = \'thriftConnectorPort\'');
			$port = $db -> loadResult();

			$db -> setQuery('SELECT `id` FROM #__menu where `link` like \'%com_openaire%\' and published=1 and alias=\'search\'');
			$this->searchMenuId = $db -> loadResult();

			// Create a thrift connection (Boiler plate)
			$socket = new TSocket($host, $port);

			$socket->setRecvTimeout(30000);

			$this->transport = new TBufferedTransport($socket);
			$protocol = new TBinaryProtocol($this->transport);

			$this->client = new OpenAireConnectorClient($protocol);
		}

		function getSearchMenuId() {
			return $this->searchMenuId;
		}

		function getEvaluationStatistics() {
			// Open up the connection
			$this->transport->open();

			$list = $this->client->getEvaluationStatistics();
			$this->transport->close();

			return $list;
		}

		function searchProjects($critName, $value) {
			switch ($critName) {
			  case 'programme':
			    $crit = ProjectSearchCriteria::programme;
			    break;
			  case 'subdivision':
			    $crit = ProjectSearchCriteria::subdivision;
			    break;
			  case 'country':
			    $crit = ProjectSearchCriteria::country;
			    break;
			  case 'organization':
			    $crit = ProjectSearchCriteria::organization;
			    break;
			  case 'sc39':
			    $crit = ProjectSearchCriteria::sc39;
			    break;
			  case 'noArticlesEmbargo':
			    $crit = ProjectSearchCriteria::noArticlesEmbargo;
			    break;
			}

			// Open up the connection
			$this->transport->open();
			$list = $this->client->searchProjects($crit, $value);
			$this->transport->close();

			return $list;
		}
	}
?>