<?php

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 OpenaireModelDeposition extends JModel {
      private $client = null;
      private $transport = null;
      private $statsExistUrl = null;
      private $statsChartUrl = null;

	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();

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

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

		$socket->setRecvTimeout($timeout);

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

		$this->client = new OpenAireConnectorClient($protocol);
		
		$db -> setQuery('SELECT `value` FROM `#__openaire` WHERE `key` = \'serviceUrl.stats.exist.repos\'');
		$this -> statsExistUrl = $db -> loadResult();
		
		$db -> setQuery('SELECT `value` FROM `#__openaire` WHERE `key` = \'serviceUrl.stats.chart.repos\'');
		$this -> statsChartUrl = $db -> loadResult();
	}
	
	function getStatsExistUrl() {
		return $this -> statsExistUrl;
	}
	
	function getStatsChartUrl() {
		return $this -> statsChartUrl;
	}

	function searchOrganizations($term, $limit) {
		// Open up the connection
		$this->transport->open();

		$list = $this->client->searchOrganizations($term, $limit);
		$this->transport->close();

		return $list;
	}

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

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

		return $list;
	}

	function quickSearchProjects($term, $limit) {
		// Open up the connection
		$this->transport->open();

		$list = $this->client->quickSearchProjects($term, $limit);
		$this->transport->close();

		return $list;
	}

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

		$info = $this->client->getProjectInfoByGrant($grant);

		$this->transport->close();

		return $info;
	}

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

		$info = $this->client->getProjectInfo($projectId);
		$this->transport->close();

		return $info;
	}

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

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

		return $list;
	}
}
?>