D-Net

<?php

if (!class_exists('TBase')) {

	$GLOBALS['THRIFT_ROOT'] = dirname(__FILE__) . DS . 'models' . DS . 'thrift';

	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 modOpenAireStatsHelper {

	private static function setupThrift(&$params) {

		$host = $params->get('thriftHost');

		$port = $params->get('thriftPort');

		$socket = new TSocket($host, $port);

                $socket->setRecvTimeout(10000);

                $_transport = new TBufferedTransport($socket);

                $protocol = new TBinaryProtocol($_transport);

                $_client = new OpenAireConnectorClient($protocol);

		return array("client" => $_client, "transport" => $_transport);

	}

	public static function getStats($params) {

		$thrift = modOpenAireStatsHelper::setupThrift($params);

		// Open up the connection

		$thrift["transport"]->open();

//		$list = $thrift["client"]->getPublicationStatistics();

		$cache = & JFactory::getCache('mod_openairestats', 'callback');

		$conf =& JFactory::getConfig();

		$cacheactive = $conf->getValue('config.caching');

		$cache->setCaching(1); //enable caching

		$list = $cache->call(array($thrift['client'], 'getPublicationStatistics'));

		$cache->setCaching($cacheactive);

		$thrift["transport"]->close();

                return $list;

	}

}

function compareStatLines($line1, $line2) {

	$v1 = $line1->values[0]->value;

	$v2 = $line2->values[0]->value;

	if ($v1 == $v2)

		return 0;

	else

		return ($v1 < $v2 ?-1:1);

}

?>