D-Net

<?php

defined('_JEXEC') or die('Access denied');

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

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

jimport('joomla.base.object');

jimport('joomla.cache.cache');

jimport('joomla.http.http');

jimport('joomla.log.log');

if(!defined('DS')) define('DS', DIRECTORY_SEPARATOR);

$GLOBALS['THRIFT_ROOT'] = dirname(__FILE__) . 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 . 'OpenAIREConnector' . DS . 'OpenAIREConnector.php');

// This model manages alerts using DB and Thrift.

class OpenAireModelAlerts extends JModelItem {

	const SUBSCRIPTIONS_CACHE_ID = 'subscriptions';

	const TOPICS_CACHE_ID = 'topics';

	const ALERT_MODES_CACHE_ID = 'alert.modes';

	const CACHE_GROUP = 'openaire.alerts';

	const LOG = 'openaire';

	private $databasePrefix;

	private $pageSize;

	private $atomUrn;

	private $jdbcUri;

	private $newsCategory;

	private $newsUser;

	private $twitterAccessToken;

	private $twitterAccessTokenSecret;

	private $transport;

	private $client;

	private $cache;

	// Construct a new OpenAireModelSearch.

	// $configuration the configuration to use		

	public function __construct($configuration = array()) {

		parent :: __construct($configuration);

		$this -> db = JFactory :: getDBO();

		$this -> databasePrefix = JFactory :: getApplication() -> getCfg('dbprefix');

		$parameters = JComponentHelper :: getParams('com_openaire');

		$this -> pageSize = intval($parameters -> get('alertsPageSize'));

		$this -> atomUrn = $parameters -> get('alertsAtomUrn');

		$this -> jdbcUri = $parameters -> get('alertsJdbcUri');

		$this -> newsCategory = intval($parameters -> get('alertsNewsCategory'));

		$this -> newsUser = intval($parameters -> get('alertsNewsUser'));

		$this -> twitterAccessToken = $parameters -> get('alertsTwitterAcccessToken');

		$this -> twitterAccessTokenSecret = $parameters -> get('alertsTwitterAccessTokenSecret');

		$socket = new TSocket($parameters -> get('thriftHost'), intval($parameters -> get('thriftPort')));

		$socket -> setRecvTimeout(intval($parameters -> get('thriftTimeout')));

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

		$this -> client = new OpenAireConnectorClient(new TBinaryProtocol($this -> transport));

		$this -> transport -> open();

		$this -> cache = JCache :: getInstance();

	}

	// Close Thrift transport.

	public function __destruct() {

		$this -> transport -> close();

	}

	// Retrieve the subscriptions of a user using cache if enabled.

	// $user the user to retrieve subscriptions for

	// return the subscriptions of the user specified (array)

	public function getSubscriptions($user) {

		if ($this -> cache -> getCaching()) {

			$id = self :: SUBSCRIPTIONS_CACHE_ID . '.' . $user -> get('username');

			$subscriptions = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($subscriptions === FALSE) {

				$subscriptions = $this -> _getSubscriptions($user);

				if ($subscriptions !== NULL)

					$this -> cache -> store($subscriptions, $id, self :: CACHE_GROUP);

			}

		} else

			$subscriptions = $this -> _getSubscriptions($user);

		return $subscriptions;

	}

	// Retrieve alert topics using cache if enabled.

	// $parent the id of the parent topic of the topics to retrieve

	// $name retrieve only topics whose name contains this substring

	// $limit the maximum number of topics to retrieve

	// return the alert topics matching the criteria specified (array)

	public function getTopics($parent, $name, $limit) {

		if ($this -> cache -> getCaching()) {

			$id = self :: TOPICS_CACHE_ID . '.' . $parent . '.' . $name . '.' . $limit;

			$topics = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($topics === FALSE) {

				$topics = $this -> _getTopics($parent, $name, $limit);

				if ($topics !== NULL)

					$this -> cache -> store($topics, $id, self :: CACHE_GROUP);

			}

		} else

			$topics = $this -> _getTopics($parent, $name, $limit);

		return $topics;

	}

	// Retrieve the alert modes available to a user using cache if enabled.

	// $user the user to retrieve alert modes for

	// return the alert modes available to the user specified (array)

	public function getAlertModes($user) {

		if ($this -> cache -> getCaching()) {

			$id = self :: ALERT_MODES_CACHE_ID . '.' . $user -> get('username');

			$alertModes = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($alertModes === FALSE) {

				$alertModes = $this -> _getAlertModes($user);

				if ($alertModes !== NULL)

					$this -> cache -> store($alertModes, $id, self :: CACHE_GROUP);

			}

		} else

			$alertModes = $this -> _getAlertModes($user);

		return $alertModes;

	}

	// Add a new subcsription using cache if enabled.

	// $templateId the unique identifier of the template of the new subscription

	// $notificationService the notification service of the new subscription

	// $queryId the unique identifier of the query of the new subscription

	// $resultId the unique identifier of the result of the new subscription

	// $alertMode the alert mode of the new subscription

	// $batchPeriod the batch period of the new subscription

	// $user the user to add the new subscription for

	public function addSubscription($templateId, $notificationService, $queryId, $resultId, $alertMode, $batchPeriod, $user) {

		$this -> _addSubscription($templateId, $notificationService, $queryId, $resultId, $alertMode, $batchPeriod, $user);

		if ($this -> cache -> getCaching()) {

			$id = self :: SUBSCRIPTIONS_CACHE_ID . $user -> get('username');

			$this -> cache -> remove($id, self :: CACHE_GROUP);

		}

	}

	// Remove a subscription using cache if enabled.

	// $templateId the unique identifier of the template of the subscription to remove

	// $notificationService the notification service of the subscription to remove

	// $queryId the unique identifier of the query of the subscription to remove

	// $resultId the unique identifier of the result of the subscription to remove

	// $alertMode the alert mode of the subscription to remove

	// $subscriber the subscriber URI of the subscription to remove

	// $user the user whose subscription to remove

	public function removeSubscription($templateId, $notificationService, $queryId, $resultId, $alertMode, $subscriber, $user) {

		$this -> _removeSubscription($templateId, $notificationService, $queryId, $resultId, $alertMode, $subscriber);

		if ($this -> cache -> getCaching()) {

			$id = self :: SUBSCRIPTIONS_CACHE_ID . $user -> get('username');

			$this -> cache -> remove($id, self :: CACHE_GROUP);

		}

	}

	// Retrieve the subscriptions of a user using cache if enabled.

	// $user the user to retrieve subscriptions for

	// return the subscriptions of the user specified (array) or NULL if any errors occur

	private function _getSubscriptions($user) {

		try {	

			$result = array();

			foreach ($this -> getAlertModes($user) as $alertMode) { // for each alert mode that the current user may use

				list($alertMode -> id, $subscriber) = $this -> getAlertModeAndSubscriber($alertMode -> id, 0, $user);

				for ($offset = 0; ; $offset += $this -> pageSize) {

					$subscriptions = $this -> client -> getSubscriptions($alertMode -> id, $subscriber, $this -> pageSize, $offset);

					foreach ($subscriptions as $subscription) {

						$subscription -> topic = $this -> getFullTopicName($subscription -> templateId, $subscription -> notificationService, $subscription -> queryId, $subscription -> resultId);

						list($subscription -> alertModeName, $subscription -> batchPeriod) = $this -> getAlertModeNameAndBatchPeriod($subscription -> alertMode, $subscription -> subscriber);

						$result[] = $subscription;

					}

					if (count($subscriptions) < $this -> pageSize)

						break;

				}

				if ($alertMode -> batch) { // alert mode is a batch alert mode too

					list($alertMode -> id, $subscriber) = $this -> getAlertModeAndSubscriber($alertMode -> id, NULL, $user);

					for ($offset = 0; ; $offset += $this -> pageSize) {

						$subscriptions = $this -> client -> getSubscriptions($alertMode -> id, $subscriber, $this -> pageSize, $offset);

						foreach ($subscriptions as $subscription) {

							$subscription -> topic = $this -> getFullTopicName($subscription -> templateId, $subscription -> notificationService, $subscription -> queryId, $subscription -> resultId);

							list($subscription -> alertModeName, $subscription -> batchPeriod) = $this -> getAlertModeNameAndBatchPeriod($subscription -> alertMode, $subscription -> subscriber);

							$result[] = $subscription;

						}

						if (count($subscriptions) < $this -> pageSize)

							break;

					}

				}

			}

			// sort subscriptions

			usort($result, function ($subscription1, $subscription2) {

				$topicComparison = strcmp($subscription1 -> topic, $subscription2 -> topic);

				$alertModeComparison = strcmp($subscription1 -> alertModeName, $subscription2 -> alertModeName);

				$batchPeriodComparison = strcmp($subscription1 -> batchPeriod, $subscription2 -> batchPeriod);

				return ($topicComparison == 0) ? (($alertModeComparison == 0) ? $batchPeriodComparison : $alertModeComparison) : $topicComparison;			

			});

			JLog :: add ('Retrieved ' . count($result) . ' subscriptions (user: ' . $user -> get('username') . ')', JLog :: INFO, self :: LOG);

			return $result;

		} catch (Exception $e) {

			JLog :: add('Error retrieving subscriptions (user: ' . $user -> get('username') . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve alert topics.

	// $parent the id of the parent topic of the topcis to retrieve

	// $name retrieve only topics whose name contains this substring

	// $limit the maximum number of topics to retrieve

	// return the alert topics matching the criteria specified (array) or NULL if any errors occur

	private function _getTopics($parent, $name, $limit) {

		try {

			$query = $this -> db -> getQuery(TRUE);

			$query -> select('id, name, description, templateId, notificationService, queryId, resultId');

			$query -> from('#__openaire_topic_hierarchy');

			$query -> where(($parent == NULL) ? 'parent IS NULL' : ('parent = ' . intval($parent)));

			$query -> where('name LIKE CONCAT(\'%\', ' . $this -> db -> quote($name) . ', \'%\')');

			$query -> order('id');

			$this -> db -> setQuery($query, 0, intval($limit));

			$topics = $this -> db -> loadObjectList();

			if ($topics === NULL)

				throw new Exception($this -> db -> getErrorMsg() . ' (' . $this -> db -> getErrorNum() . ')');

			JLog :: add('Retrieved ' . count($topics) . ' topics (parent: ' . (($parent == NULL) ? 'NULL' : $parent) . ', name: ' . $name . ', limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $topics;

		} catch (Exception $e) {

			JLog :: add('Error retrieving topics (parent: ' . (($parent == NULL) ? 'NULL' : $parent) . ', name: ' . $name . ', limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve the alert modes available to a user.

	// $user the user to retrieve alert modes for

	// return the alert modes available to the user specified (array) or NULL if any errors occur

	private function _getAlertModes($user) {

		try {

			$query = $this -> db -> getQuery(TRUE);

			$query -> select(array('id', 'name', 'description', 'batch'));

			$query -> from('#__openaire_alert_modes');

			if ($user -> username != 'admin')

				$query -> where('NOT `adminOnly`');

			$this -> db -> setQuery($query);

			$alertModes = $this -> db -> loadObjectList();

			if ($alertModes === NULL)

				throw new Exception($this -> db -> getErrorMsg() . ' (' . $this -> db -> getErrorNum() . ')');

			JLog :: add('Retrieved ' . count($alertModes) . ' alert modes (user: ' . $user -> get('username') . ')', JLog :: INFO, self :: LOG);

			return $alertModes;

		} catch (Exception $e) {

			JLog :: add('Error retrieving alert modes (user: ' . $user -> get('username') . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Add a new subscription.

	// $templateId the unique identifier of the template of the new subscription

	// $notificationService the notification service of the new subscription

	// $queryId the unique identifier of the query of the new subscription

	// $resultId the unique identifier of the result of the new subscription

	// $alertMode the alert mode of the new subscription

	// $batchPeriod the batch period of the new subscription

	// $user the user to add the new subscription for

	private function _addSubscription($templateId, $notificationService, $queryId, $resultId, $alertMode, $batchPeriod, $user) {

		try {

			list($alertMode, $subscriber) = $this -> getAlertModeAndSubscriber($alertMode, $batchPeriod, $user);

			$this -> client -> addSubscription(new AlertSubscription(array('templateId' => $templateId, 'notificationService' => $notificationService, 'queryId' => $queryId, 'resultId' => $resultId, 'alertMode' => $alertMode, 'subscriber' => $subscriber)));

			JLog :: add('Added subscription (template: ' . $templateId . ', notification service: ' . $notificationService . ', query: ' . $queryId . ', result: ' . $resultId . ', alert mode: ' . $alertMode . ', batch period: ' . $batchPeriod . ', user: ' . $user -> get('username') . ')', JLog :: INFO, self :: LOG);

		} catch (Exception $e) {

			JLog :: add('Error adding subscription (template: ' . $templateId . ', notification service: ' . $notificationService . ', query: ' . $queryId . ', result: ' . $resultId . ', alert mode: ' . $alertMode . ', batch period: ' . $batchPeriod . ', user: ' . $user -> get('username') . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

		}	

	}

	// Remove a subscription.

	// $templateId the unique identifier of the template of the subscription to remove

	// $notificationService the notification service of the subscription to remove

	// $queryId the unique identifier of the query of the subscription to remove

	// $resultId the unique identifier of the result of the subscription to remove

	// $alertMode the alert mode of the subscription to remove

	// $subscriber the subscriber URI of the subscription to remove

	private function _removeSubscription($templateId, $notificationService, $queryId, $resultId, $alertMode, $subscriber) {

		try {

			$this -> client -> removeSubscription(new AlertSubscription(array('templateId' => $templateId, 'notificationService' => $notificationService, 'queryId' => $queryId, 'resultId' => $resultId, 'alertMode' => $alertMode, 'subscriber' => $subscriber)));

			JLog :: add('Removed subscription (template: ' . $templateId . ', notification service: ' . $notificationService . ', query: ' . $queryId . ', result: ' . $resultId . ', alert mode: ' . $alertMode . ', subscriber: ' . $subscriber . ')', JLog :: INFO, self :: LOG);

		} catch (Exception $e) {

			JLog :: add('Error removing subscription (template: ' . $templateId . ', notification service: ' . $notificationService . ', query: ' . $queryId . ', result: ' . $resultId . ', alert mode: ' . $alertMode . ', subscriber: ' . $subscriber . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

		}

	}

	private function getAlertModeAndSubscriber($alertMode, $batchPeriod, $user) {

		switch($alertMode) {

		case 'Atom':

			$subscriber = $this -> atomUrn;

			break;

		case 'JDBC':

			$subscriber = $this -> jdbcUri . '&table=' . urlencode($this -> databasePrefix . 'openaire_alerts') . '&username=' . urlencode($user -> get('username')) . '&time=' . urlencode('$time') . '&title=' . urlencode('$title') . '&message=' . urlencode('$message') . '&link=' . urlencode('$link');

			break;

		case 'Joomla!':

			$subscriber = $this -> jdbcUri . '&tablePrefix=' . urlencode($this -> databasePrefix) . '&category=' . urlencode($this -> newsCategory) . '&userId=' . urlencode($this -> newsUser);

			break;

		case 'SMTP':

			$subscriber = 'mailto:' . $user -> get('email');

			break;

		case 'twitter':

			$subscriber = 'data:accessToken=' . urlencode($this -> twitterAccessToken) . '&accessTokenSecret=' . urlencode($this -> twitterAccessTokenSecret);

			break;

		}

		if (($batchPeriod !== 0) && ($batchPeriod !== '0')) { // convert alert mode to batch alert mode

			$alertMode = 'Batch ' . $alertMode;

			$subscriber = 'batch:' . $subscriber . '#' . $batchPeriod;

		}

		return array($alertMode, $subscriber);

	}

	private function getAlertModeNameAndBatchPeriod($alertMode, $subscriberUri) {

		if ((strpos($alertMode, 'Batch ') === 0) && (strpos($subscriberUri, 'batch:') === 0)) { // alert mode is a batch alert mode

			$alertMode = substr($alertMode, strlen('Batch ')); // ommit 'Batch ' to get alert mode

			$batchPeriod = substr($subscriberUri, strpos($subscriberUri, '#') + 1); // find batch period

			switch ($batchPeriod) {

			case 30 * 24 * 60:

				$batchPeriod = 'monthly';

				break;

			case 15 * 24 * 60:

				$batchPeriod = 'bi-monthly';

				break;

			case 7 * 24 * 60:

				$batchPeriod = 'weekly';

				break;

			case 24 * 60:

				$batchPeriod = 'daily';

				break;

			case 0: // batch period is either zero or null; make it non-batch

			case '0':

			case NULL:

				$batchPeriod = 'as it happens';

				break;

			default:

				$batchPeriod = 'every ' . $batchPeriod . ' minute(s)';

			}

		} else // alert mode is not a batch alert mode

			$batchPeriod = 'as it happens';

		$query = $this -> db -> getQuery(TRUE);

		$query -> select('name');

		$query -> from('#__openaire_alert_modes');

		$query -> where('id = ' . $this -> db -> quote($alertMode));

		$this -> db -> setQuery($query);

		$alertModeName = $this -> db -> loadResult();

		if ($alertModeName === NULL)

			throw new Exception($this -> db -> getErrorMsg() . ' (' . $this -> db -> getErrorNum() . ')');

		return array($alertModeName, $batchPeriod);

	}

	private function getFullTopicName($templateId, $notificationService, $queryId, $resultId) {

		$query = $this -> db -> getQuery(TRUE);

		$query -> select('parent, name');

		$query -> from('#__openaire_topic_hierarchy');

		$query -> where('templateId = ' . $this -> db -> quote($templateId));

		$query -> where('notificationService = ' . $this -> db -> quote($notificationService));

		$query -> where('queryId = ' . $this -> db -> quote($queryId));

		$query -> where('resultId = ' . $this -> db -> quote($resultId));

		$this -> db -> setQuery($query);

		$topic = $this -> db -> loadObject();

		if ($topic === NULL)

			throw new Exception($this -> db -> getErrorMsg() . ' (' . $this -> db -> getErrorNum() . ')');

		return ($topic -> parent == NULL) ? $topic -> name : ($this -> getTopicNameById($topic -> parent) . ' ' . $topic -> name);

	}

	private function getTopicNameById($id) {

		$query = $this -> db -> getQuery(TRUE);

		$query -> select('parent, name');

		$query -> from('#__openaire_topic_hierarchy');

		$query -> where('id = ' . intval($id));

		$this -> db -> setQuery($query);

		$topic = $this -> db -> loadObject();		

		if ($topic === NULL)

			throw new Exception($this -> db -> getErrorMsg() . ' (' . $this -> db -> getErrorNum() . ')');

		return ($topic -> parent == NULL) ? $topic -> name : ($this -> getTopicNameById($topic -> parent) . ' ' . $topic -> name);

	}

}

<?php

defined('_JEXEC') or die('Access denied');

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

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

jimport('joomla.base.object');

jimport('joomla.cache.cache');

jimport('joomla.log.log');

$GLOBALS['THRIFT_ROOT'] = dirname(__FILE__) . 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 . 'OpenAIREConnector' . DS . 'OpenAIREConnector.php');

// This model manages statistics.

class OpenAireModelStatistics extends JModelItem {

	const STATISTICS_CACHE_ID = 'statistics';

	const PUBLICATIONS_BY_PROGRAMME_CACHE_ID = 'publications.programme';

	const PUBLICATIONS_BY_SCIENTIFIC_AREA_CACHE_ID = 'publications.scientific.area';

	const PUBLICATIONS_BY_COUNTRY_CACHE_ID = 'publications.country';

	const PUBLICATIONS_BY_INSTITUTION_CACHE_ID = 'publications.institution';

	const CACHE_GROUP = 'openaire.statistics';

	const LOG = 'openaire';

	private $transport;

	private $client;

	private $cache;

	// Construct a new OpenAireModelStatistics.

	// $configuration the configuration to use

	public function __construct($configuration) {

		parent :: __construct($configuration);

		$parameters = JComponentHelper :: getParams('com_openaire');

		$socket = new TSocket($parameters -> get('thriftHost'), intval($parameters -> get('thriftPort')));

		$socket -> setRecvTimeout(intval($parameters -> get('thriftTimeout')));

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

		$this -> client = new OpenAIREConnectorClient(new TBinaryProtocol($this -> transport));

		$this -> cache = JCache :: getInstance();

		$this -> transport -> open();

	}

	// Close Thrift transport.

	public function __destruct() {

		$this -> transport -> close();

	}

	// Retrieve statistics using cache if enabled.

	// return statistics (object)

	public function getStatistics() {

/*

		if ($this -> cache -> getCaching()) {

			$statistics = $this -> cache -> get(self :: STATISTICS_CACHE_ID, self :: CACHE_GROUP);

			if ($statistics === NULL) {

				$statistics = $this -> _getStatistics();

				$this -> cache -> store($statistics, self :: STATISTICS_CACHE_ID, self :: CACHE_GROUP);

			}

		} else

*/

			$statistics = $this -> _getStatistics();

		return $statistics;

	}

	// Retrieve publications by access mode using cache if enabled.

	// return publications by access mode (array)

	public function getPublicationsByAccessMode() {

/*

		if ($this -> cache -> getCaching()) {

			$publicationsByAccessMode = $this -> cache -> get(self :: PUBLICATIONS_BY_ACCESS_MODE_CACHE_ID, self :: CACHE_GROUP);

			if ($publications === NULL) {

				$publicationsByAccessMode = $this -> _getPublicationsByAccessMode();

				$this -> cache -> store($publicationsByAccessMode, self :: PUBLICATIONS_BY_ACCESS_MODE_CACHE_ID, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByAccessMode = $this -> _getPublicationsByAccessMode();

		return $publicationsByAccessMode;

	}

	// Retrieve publications by programme using cache if enabled.

	// limit the maximum number of programmes to retrieve

	// return publications by programme (array)

	public function getPublicationsByProgramme($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_PROGRAMME_CACHE_ID . '.' . $limit;

			$publicationsByProgramme = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByProgramme === NULL) {

				$publicationsByProgramme = $this -> _getPublicationsByProgramme($limit);

				$this -> cache -> store($publicationsByProgramme, $id, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByProgramme = $this -> _getPublicationsByProgramme($limit);

		return $publicationsByProgramme;

	}

	// Retrieve publications by scientific area using cache if enabled.

	// limit the maximum number of scientific areas to retrieve

	// return publications by scientific area (array)

	public function getPublicationsByScientificArea($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_SCIENTIFIC_AREA_CACHE_ID . '.' . $limit;

			$publicationsByScientificArea = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByScientificArea === NULL) {

				$publicationsByScientificArea = $this -> _getPublicationsByScientificArea($limit);

				$this -> cache -> store($publicationsByScientificArea, $limit, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByScientificArea = $this -> _getPublicationsByScientificArea($limit);

		return $publicationsByScientificArea;

	}

	// Retrieve publications by country using cache if enabled.

	// limit the maximum number of countries to retrieve

	// return publications by country (array)

	public function getPublicationsByCountry($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_COUNTRY_CACHE_ID . '.' . $limit;

			$publicationsByCountry = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByCountry === NULL) {

				$publicationsByCountry = $this -> _getPublicationsByCountry($limit);

				$this -> cache -> store($publicationsByCountry, $id, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByCountry = $this -> _getPublicationsByCountry($limit);

		return $publicationsByCountry;

	}

	// Retrieve publications by institution using cache if enabled.

	// limit the maximum number of institutions to retrieve

	// return publications by institution (array)

	public function getPublicationsByInstitution($limit) {

/*

		if ($this -> cache -> getCaching()) {

			$id = self :: PUBLICATIONS_BY_INSTITUTION_CACHE_ID . '.' . $limit;

			$publicationsByInstitution = $this -> cache -> get($id, self :: CACHE_GROUP);

			if ($publicationsByInstitution === NULL) {

				$publicationsByInstitution = $this -> _getPublicationsByInstitution($limit);

				$this -> cache -> store($publicationsByInstitution, $id, self :: CACHE_GROUP);

			}

		} else

*/

			$publicationsByInstitution = $this -> _getPublicationsByInstitution($limit);

		return $publicationsByInstitution;

	}

	// Retrieve statistics.

	// return the statistics (object) or NULL if any errors occur

	private function _getStatistics() {

		try {

			$time = microtime(TRUE);

			$statistics = $this -> client -> getStatistics();

			JLog :: add('Retrieved statistics in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			return $statistics;

		} catch (Exception $e) {

			JLog :: add('Error retrieving statistics: ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by access mode.

	// return publications by access mode (array) or NULL if any errors occur

	private function _getPublicationsByAccessMode() {

		try {

			$time = microtime(TRUE);

			$publicationsByAccessMode = $this -> client -> getPublicationsByAccessMode();

			JLog :: add('Retrieved ' . count($publicationsByAccessMode) . ' publications by access mode entries in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			return $publicationsByAccessMode;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by acces mode: ' . $e -> getMessage());

			return NULL;

		}

	}

	// Retrieve publications by programme.

	// limit the maximum number of programmes to retrieve

	// return publications by programme (array) or NULL if any errors occur

	private function _getPublicationsByProgramme($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByProgramme = $this -> client -> getPublicationsByProgramme($limit);

			JLog :: add('Retrieved ' . count($publicationsByProgramme) . ' publications by programme entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByProgramme;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by programme (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by scientific area.

	// limit the maximum number of scientific areas to retrieve

	// return publications by scientific area (array) or NULL if any errors occur

	private function _getPublicationsByScientificArea($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByScientificArea = $this -> client -> getPublicationsByScientificArea($limit);

			JLog :: add('Retrieved ' . count($publicationsByScientificArea) . ' publications by scientific area entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByScientificArea;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by scientific area (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by country.

	// limit the maximum number of countries to retrieve

	// return publications by country (array) or NULL if any errors occur

	private function _getPublicationsByCountry($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByCountry = $this -> client -> getPublicationsByCountry($limit);

			JLog :: add('Retrieved ' . count($publicationsByCountry) . ' publications by country entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByCountry;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by country (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	// Retrieve publications by institution.

	// limit the maximum number of institutions to retrieve

	// return publications by institution (array) or NULL if any errors occur

	private function _getPublicationsByInstitution($limit) {

		try {

			$time = microtime(TRUE);

			$publicationsByInstitution = $this -> client -> getPublicationsByInstitution($limit);

			JLog :: add('Retrieved ' . count($publicationsByInstitution) . ' publications by institution entries in ' . (microtime(TRUE) - $time) . ' s (limit: ' . $limit . ')', JLog :: INFO, self :: LOG);

			return $publicationsByInstitution;

		} catch (Exception $e) {

			JLog :: add('Error retrieving publications by institution (limit: ' . $limit . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

}

link ../../../thrift/

<?php

defined('_JEXEC') or die('Access denied');

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

jimport('joomla.http.http');

jimport('joomla.log.log');

// This model manages claims.

class OpenAireModelClaimSearch extends JModelItem {

    const SELECTED_PROJECTS = 'selectedProjects';

	const SELECTED_CONCEPTS = 'selectedConcepts';

	const SELECTED_PUBLICATIONS = 'selectedPublications';

	const SEARCH_DOI_CACHE_ID = 'search.doi';

	const SEARCH_DATASET_CACHE_ID = 'search.datacite';

	const SEARCH_ORCID_CACHE_ID = 'search.orcid';

	const CLAIMED_PUBLICATIONS_CACHE_ID = 'claimed.publications';

	const CACHE_GROUP = 'openaire.claim';

	const CROSSREF_URL = 'http://www.crossref.org/openurl?noredirect=true&pid=antleb%40di.uoa.gr&format=unixref&id=';

	const CROSSREF_API_DOI = 'http://api.crossref.org/works/';

	const CROSSREF_API_KEYWORD = 'http://api.crossref.org/works?query=';

	const DOI_SCHEME = 'doi:';

	const DATACITE_URL = 'http://data.datacite.org/application/rdf+xml/';

	const DATACITE_URL_KEYWORD = 'http://search.datacite.org/api?q=';

	const DATACITE_URL_KEYWORD_REST = '&fl=doi,title,creator,publisher,created&wt=xml';

	const DOI_URL = 'http://dx.doi.org/';

	const ORCID_URL_PREFIX = 'http://pub.orcid.org/';

	const ORCID_URL_PUBLICATIONS_SUFFIX = '/orcid-works';

	const ORCID_URL_AUTHOR_SUFFIX = '/orcid-bio';

	const HTTP_OK = 200;

	const HTTP_NOT_FOUND = 404;

	const DOI = 'doi';

	const ORCID = 'orcid';

	const DATACITE = 'datacite';

	const RELATION = 'rels2actions';

	const DMF = 'dmf2actions';

	const UNDETERMINED = 'Undetermined';

	const LOG = 'openaire';

	//claim modes

	const CLAIM = 'claim';

	const CLAIMINLINE = 'claiminline';

	const CLAIMINLINE2 = 'claiminline2';

	private $cache;

	private $http;

        // Construct a new OpenAireModelClaimSearch.

	// $configuration the configuration to use

	public function __construct($configuration) {

		parent :: __construct($configuration);

		$this -> cache = JCache :: getInstance();

		$this -> http = new JHttp();

	}

        private function _parseMultipleJsonDOIs($message){

            $publications=array();

            if(isset($message -> items)){

	 		foreach ($message -> items as $item) {

                            $publication= $this ->_parseJsonDOI($item);

                            if($publication!==null){

                             $publications[]=$publication;   

                            }

                        }

            }

            return $publications;

        }

	private function _parseJsonDOI($message) {

		$publication = new JObject();

		$publication -> id = isset($message -> DOI)?$message -> DOI:NULL;

		$publication -> source = self :: DOI;

		$publication -> url = isset($message -> URL)?$message -> URL:NULL;

		$publication -> accessMode = NULL;

		$publication -> datasources = array();

		$publication -> title = (isset($message -> title) && isset($message -> title[0]))?$message -> title[0]:NULL;

		$publication -> authors =  array();	

		if(isset($message -> author)){

	 		foreach ($message -> author as $author_item) {

	 				$author = new JObject();

					$author -> id = NULL;

					$author -> lastName = isset($author_item-> family) ?   trim($author_item -> family):NULL;

					$author -> firstName = isset($author_item  -> given) ?  trim($author_item -> given):NULL;

					$author -> fullName = NULL;

					if (($author -> id != NULL) || ($author -> lastName != NULL) || ($author-> firstName != NULL) || ($author -> fullName != NULL))

						$publication -> authors[] = $author;

			}

		}

		$publication -> publisher =isset($message -> publisher)?$message -> publisher:NULL;

		$publication -> year = (isset($message -> issued )&&isset($message -> issued -> date_parts[0]))?

		((isset($message -> issued -> date_parts[0][0]))?$message -> issued -> date_parts[0][0]:NULL):NULL;	

 		$publication -> language = NULL;

		$publication -> projects = array();

		$publication -> embargoEndDate = NULL;

		$publication -> description = NULL;

		if (($publication -> id != NULL)&&( ($publication -> url != NULL) || ($publication -> title != NULL) || ($publication -> authors != NULL) || ($publication -> year != NULL))) {

			return $publication; 

		}

		return NULL; 

	}

	// Search for a dataset DOI using caching if enabled.

	// $doi the dataset DOI to search for

	// return a result (object) containing datasets and total

	private function _searchDataCiteWithDoi($doi) {

		try {

			$request = self :: DATACITE_URL . urlencode(trim($doi));

			JLog :: add('Requesting ' . $request, JLog :: INFO, self :: LOG);

			$time = microtime(TRUE);

			$response = $this -> http -> get($request);

			JLog :: add('Received response in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			if ($response== NULL)

				throw new Exception('no HTTP response');

			/*if ($response -> code == self :: HTTP_NOT_FOUND) { // no dataset found; just return empty result

				$result = new JObject();

				$result -> datasets = array();

				$result -> totalDatasets = 0;

				JLog :: add('Retrieved 0 DataCite records in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

				return $result;

			}*/

			if ($response -> code != self :: HTTP_OK)

				throw new Exception('HTTP response code ' . $response -> code);

			$document = new DOMDocument();

			$document -> recover = TRUE;

			if ($document -> loadXML(trim($response -> body)) == FALSE)

				throw new Exception('invalid XML response');

			$xpath = new DOMXPath($document);

			if ((($descriptionNodes = $xpath -> query('/rdf:RDF/rdf:Description')) == FALSE) || (($descriptionNode = $descriptionNodes -> item(0)) == NULL))

				throw new Exception('error parsing DataCite record');

			if (($idNodes = $xpath -> query('./j.0:identifier', $descriptionNode)) == FALSE)

				throw new Exception('error parsing DataCite record');

			if (($titleNodes = $xpath -> query('./j.0:title', $descriptionNode)) == FALSE)

				throw new Exception('error parsing DataCite record');

			if (($authorNodes = $xpath -> query('./j.0:creator', $descriptionNode)) == FALSE)

				throw new Exception('error parsing DataCite record');

			if (($yearNodes = $xpath -> query('./j.0:date', $descriptionNode)) == FALSE)

				throw new Exception('error parsing DataCite record');

			if (($publisherNodes = $xpath -> query('./j.0:publisher', $descriptionNode)) == FALSE)

				throw new Exception('error parsing DataCite record');

			$dataset = new JObject();

			$dataset -> id = (($idNode = $idNodes -> item(0)) == NULL) ? NULL : trim($idNode -> nodeValue);

			$dataset -> source = self :: DATACITE;

			$dataset -> url = self :: DOI_URL . urlencode(trim($doi));

			$dataset -> accessMode = NULL;

			$dataset -> datasources = array();

			$dataset -> title = (($titleNode = $titleNodes -> item(0)) == NULL) ? NULL : trim($titleNode -> nodeValue);

			$dataset -> authors = array();

			$dataset -> publisher = (($publisherNode = $publisherNodes -> item(0)) == NULL) ? NULL : trim($publisherNode -> nodeValue);

			$dataset -> year = (($yearNode = $yearNodes -> item(0)) == NULL) ? NULL : intval(trim($yearNode -> nodeValue));

			$dataset -> language = NULL;

			$dataset -> projects = array();

			$dataset -> embargoEndDate = NULL;

			$dataset -> description = NULL;

			foreach ($authorNodes as $authorNode) {

				$author = new JObject();

				$author -> id = NULL;

				$author -> lastName = NULL;

				$author -> firstName = NULL;

				$author -> fullName = trim($authorNode -> nodeValue);

				if ($author -> fullName != NULL)

					$dataset -> authors[] = $author;

			}

			/*$result = new JObject();

			$result -> datasets = array();

			$result -> totalDatasets = 0;

			if (($dataset -> id != NULL) || ($dataset -> url != NULL) || ($dataset -> title != NULL) || ($dataset -> authors != NULL) || ($dataset -> year != NULL)) {

				$result -> datasets[] = $dataset;

				$result -> totalDatasets = 1;

			}*/

			JLog :: add('Retrieved DataCite record in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			return $dataset;

		} catch (Exception $e) {

			JLog :: add('Error performing DataCite search (doi: ' . $doi . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			return NULL;

		}

	}

	private function _searchDataCite($doi, $page, $size) {

            $result = new JObject();

            $result->datasets = array();

            $result->totalPublications = 0;

            $result->totalDatasets = 0;

            try {

                $dois = explode(" ", preg_replace('/\s+/', ' ',$doi));   

                $unique_dois =array_slice( array_unique($dois),0,10);

                $pattern1 = '#\b(10[.][0-9]{4,}(?:[.][0-9]+)*/(?:(?!["&\'<>])\S)+)\b#';

                $pattern2 = '#\b(10[.][0-9]{4,}(?:[.][0-9]+)*/(?:(?!["&\'<>])[[:graph:]])+)\b#';

                if (preg_match($pattern1, $unique_dois[0]) || preg_match($pattern2, $unique_dois[0])) {

                    if(count($dois)>10){

                       $result = new JObject();

                       $result->datasets = array();

                       $result->totalPublications = 0;

                       $result->totalDatasets = '-';

                       $result->maxDoisExceeded = true;

                       return $result;

                    }

                    JLog :: add('It;s a dataset  DOI!!!!!!!!! ' . $dois[0], JLog :: INFO, self :: LOG);

                    JLog :: add('Searching for DOIs in Datacite', JLog :: INFO, self :: LOG);

                    foreach ($unique_dois as $doi_) {

                        JLog :: add('DOI::: ' . $doi_, JLog :: INFO, self :: LOG);

                        $dataset = $this->_searchDataCiteWithDoi($doi_);

                        if ($dataset != null) {

                            $result->datasets[] = $dataset;

                        }

                    }

                }else{

                    JLog :: add('It;sNOOOOOOOT a dataset  DOI!!!!!!!!! ' . $dois[0], JLog :: INFO, self :: LOG);

                }

                $result->totalDatasets = count($result->datasets);

                if($result->totalDatasets!==0){

                    return $result;

                }

			$request = self :: DATACITE_URL_KEYWORD. urlencode(trim($doi)).self :: DATACITE_URL_KEYWORD_REST."&rows=".$size."&start=".($page-1)*$size;

			JLog :: add('Requesting ' . $request, JLog :: INFO, self :: LOG);

			$time = microtime(TRUE);

			$response = $this -> http -> get($request);

			JLog :: add('Received response in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			if ($response== NULL)

				throw new Exception('no HTTP response');

			if ($response -> code == self :: HTTP_NOT_FOUND) { // no dataset found; just return empty result

				$result = new JObject();

				//$result -> datasets = array();

				$result -> totalDatasets = 0;

				$result -> totalPublications = 0;

				JLog :: add('Retrieved 0 DataCite records in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

				return $result;

			}

			if ($response -> code != self :: HTTP_OK)

				throw new Exception('HTTP response code ' . $response -> code);

			$document = new DOMDocument();

			$document -> recover = TRUE;

			if ($document -> loadXML(trim($response -> body)) == FALSE)

				throw new Exception('invalid XML response');

			$xpath = new DOMXPath($document);

  			if ((($numFoundNodes = $xpath -> query('/response/result[@name = "response"]/@numFound')) == FALSE) || (($numFoundNode = $numFoundNodes -> item(0)) == NULL))

				throw new Exception('error parsing DataCite record');

			$numFound=((($numFoundNode)) == NULL) ? NULL : trim($numFoundNode -> nodeValue);

  			if ((($resultNodes = $xpath -> query('/response/result/doc')) == FALSE) || (($resultNode = $resultNodes -> item(0)) == NULL))

				throw new Exception('error parsing DataCite record');                

			foreach ($resultNodes as $resultNode) {				 

				if (($idNodes = $xpath -> query('./str[@name = "doi"]/text()', $resultNode)) == FALSE)

					throw new Exception('error parsing DataCite record');

				if (($titleNodes = $xpath -> query('./arr[@name="title"]/str/text()', $resultNode)) == FALSE)

					throw new Exception('error parsing DataCite record');

				if (($authorNodes = $xpath -> query('./arr[@name = "creator"]/str/text()', $resultNode)) == FALSE)

					throw new Exception('error parsing DataCite record');

				if (($publisherNodes = $xpath -> query('./str[@name = "publisher"]/text()', $resultNode)) == FALSE)

					throw new Exception('error parsing DataCite record');  

				if (($yearNodes = $xpath -> query('./date[@name = "created"]/text()', $resultNode)) == FALSE)

					throw new Exception('error parsing DataCite record');  

				$dataset = new JObject();

				$dataset -> id = (($idNode = $idNodes -> item(0)) == NULL) ? NULL : trim($idNode -> nodeValue);

				$dataset -> source = self :: DATACITE;

				$dataset -> url = self :: DOI_URL . urlencode(trim($dataset -> id));

				$dataset -> accessMode = NULL;

				$dataset -> datasources = array();

				$dataset -> title = (($titleNode = $titleNodes -> item(0)) == NULL) ? NULL : trim($titleNode -> nodeValue);

				$dataset -> authors = array();

				$dataset -> publisher = (($publisherNode = $publisherNodes -> item(0)) == NULL) ? NULL : trim($publisherNode -> nodeValue);

				$dataset -> year = (($yearNode = $yearNodes -> item(0)) == NULL) ? NULL : substr(trim($yearNode -> nodeValue),0,4);

				$dataset -> language = NULL;

				$dataset -> projects = array();

				$dataset -> embargoEndDate = NULL;

				$dataset -> description = NULL;				

				foreach ($authorNodes as $authorNode) {

					$authorName= $authorNode -> nodeValue;	

					$author = new JObject();

					$author -> id = NULL;

					$author -> lastName = NULL;

					$author -> firstName = NULL;

					$author -> fullName = trim($authorName );

					if ($author -> fullName != NULL)

						$dataset -> authors[] = $author;

				}

				if (($dataset -> id != NULL) || ($dataset -> url != NULL) || ($dataset -> title != NULL) || ($dataset -> authors != NULL) || ($dataset -> year != NULL)) {

					$result -> datasets[] = $dataset;

				}

			}

			//

			$result -> totalDatasets =$numFound ;

		/*	if(isset($size)&&isset($page)){

				$result -> datasets = array_slice($result -> datasets, ($page - 1) * $size, $size);

			}*/

			JLog :: add('Retrieved DataCite '.count($result -> datasets).' records in ' . (microtime(TRUE) - $time) . ' s', JLog :: INFO, self :: LOG);

			$result -> totalPublications = 0;

			return $result;

		} catch (Exception $e) {

			JLog :: add('Error performing DataCite search (doi: ' . $doi . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			$result = new JObject();

			//$result -> datasets = array();

			$result -> totalPublications = 0;

			$result -> totalDatasets = 0;

			return $result;

		}

	}

	// Parse a journal out of a DOI record.

	// $doi the DOI of the record

	// $xpath the DOMXPath to parse

	// $journalNode the journal node to start from

	// return a result (object) containing publications and total

	private function parseJournal($doi, $xpath, $journalNode) {

		if (($resourceNodes = $xpath -> query('./journal_article/doi_data/resource', $journalNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($titleNodes = $xpath -> query('./journal_article/titles/title', $journalNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($contributorNodes = $xpath -> query('./journal_article/contributors', $journalNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($yearNodes = $xpath -> query('./journal_article/publication_date/year', $journalNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		$publication = new JObject();

		$publication -> id = $doi;

		$publication -> source = self :: DOI;

		$publication -> url = (($resourceNode = $resourceNodes -> item(0)) == NULL) ? NULL : trim($resourceNode -> nodeValue);

		$publication -> accessMode = NULL;

		$publication -> datasources = array();

		$publication -> title = (($titleNode = $titleNodes -> item(0)) == NULL) ? NULL : trim($titleNode -> nodeValue);

		$publication -> authors = $this -> parseContributors($xpath, $contributorNodes);

		$publication -> publisher = NULL;

		$publication -> year = (($yearNode = $yearNodes -> item(0)) == NULL) ? NULL : intval(trim($yearNode -> nodeValue));

		$publication -> language = NULL;

		$publication -> projects = array();

		$publication -> embargoEndDate = NULL;

		$publication -> description = NULL;

		$result = new JObject();

		$result -> publications = array();

		$result -> totalPublications = 0;

		if (($publication -> id != NULL) || ($publication -> url != NULL) || ($publication -> title != NULL) || ($publication -> authors != NULL) || ($publication -> year != NULL)) {

			$result -> publications[] = $publication;

			$result -> totalPublications = 1;

		}

		return $result;

	}

	// Parse a book out of a DOI record.

	// $doi the DOI of the record

	// $xpath the DOMXPath to parse

	// $bookNode the book node to start from

	// return a result (object) containing publications and total	

	private function parseBook($doi, $xpath, $bookNode) {

		if (($bookMetadataNodes = $xpath -> query('./book_metadata', $bookNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($bookSeriesMetadataNodes = $xpath -> query('./book_series_metadata', $bookNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($bookSetMetadataNodes = $xpath -> query('./book_set_metadata', $bookNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if ((($metadataNode = $bookMetadataNodes -> item(0)) == NULL) && (($metadataNode = $bookSeriesMetadataNodes -> item(0)) == NULL) && (($metadataNode = $bookSetMetadataNodes -> item(0)) == NULL))

			throw new Exception('error parsing DOI record');

		if (($resourceNodes = $xpath -> query('./doi_data/resource', $metadataNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($titleNodes = $xpath -> query('./titles/title', $metadataNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($contributorNodes = $xpath -> query('./contributors', $metadataNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($yearNodes = $xpath -> query('./publication_date/year', $metadataNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		$publication = new JObject();

		$publication -> id = $doi;

		$publication -> source = self :: DOI;

		$publication -> url = (($resourceNode = $resourceNodes -> item(0)) == NULL) ? NULL : trim($resourceNode -> nodeValue);

		$publication -> accessMode = NULL;

		$publication -> datasources = array();

		$publication -> title = (($titleNode = $titleNodes -> item(0)) == NULL) ? NULL : trim($titleNode -> nodeValue);

		$publication -> authors = $this -> parseContributors($xpath, $contributorNodes);

		$publication -> publisher = NULL;

		$publication -> year = (($yearNode = $yearNodes -> item(0)) == NULL) ? NULL : intval(trim($yearNode -> nodeValue));

		$publication -> language = NULL;

		$publication -> projects = array();

		$publication -> embargoEndDate = NULL;

		$publication -> description = NULL;

		$result = new JObject();

		$result -> publications = array();

		$result -> totalPublications = 0;

		if (($publication -> id != NULL) || ($publication -> url != NULL) || ($publication -> title != NULL) || ($publication -> authors != NULL) || ($publication -> year != NULL)) {

			$result -> publications[] = $publication;

			$result -> totalPublications = 1;

		}

		return $result;

	}

	// Parse a Conference out of a DOI record.

	// $doi the DOI of the record

	// $xpath the DOMXPath to parse

	// $conferenceNode the book node to start from

	// return a result (object) containing publications and total	

	private function parseConference($doi, $xpath, $conferenceNode) {

		if (($eventMetadata = $xpath -> query('./event_metadata', $conferenceNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($proceedingsMetadata = $xpath -> query('./proceedings_metadata', $conferenceNode)) == FALSE)

			throw new Exception('error parsing DOI record');	

		if (($conferencePaperNodes = $xpath -> query('./conference_paper', $conferenceNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($resourceNodes = $xpath -> query('./conference_paper/doi_data/resource', $conferenceNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($titleNodes = $xpath -> query('./conference_paper/titles/title', $conferenceNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($contributorNodes = $xpath -> query('./conference_paper/contributors', $conferenceNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		if (($yearNodes = $xpath -> query('./conference_paper/publication_date/year', $conferenceNode)) == FALSE)

			throw new Exception('error parsing DOI record');

		$publication = new JObject();

		$publication -> id = $doi;

		$publication -> source = self :: DOI;

		$publication -> url = (($resourceNode = $resourceNodes -> item(0)) == NULL) ? NULL : trim($resourceNode -> nodeValue);

		$publication -> accessMode = NULL;

		$publication -> datasources = array();

		$publication -> title = (($titleNode = $titleNodes -> item(0)) == NULL) ? NULL : trim($titleNode -> nodeValue);

		$publication -> authors = $this -> parseContributors($xpath, $contributorNodes);

		$publication -> publisher = NULL;

		$publication -> year = (($yearNode = $yearNodes -> item(0)) == NULL) ? NULL : intval(trim($yearNode -> nodeValue));

		$publication -> language = NULL;

		$publication -> projects = array();

		$publication -> embargoEndDate = NULL;

		$publication -> description = NULL;

		$result = new JObject();

		$result -> publications = array();

		$result -> totalPublications = 0;

		if (($publication -> id != NULL) || ($publication -> url != NULL) || ($publication -> title != NULL) || ($publication -> authors != NULL) || ($publication -> year != NULL)) {

			$result -> publications[] = $publication;

			$result -> totalPublications = 1;

		}

		return $result;

	}

	// Parse contributor metadata out of a DOI record.

	// $doi the DOI of the record

	// $xpath the DOMXPath to parse

	// $contributorNodes the contributor nodes to start from

	// return authors (array)

	private function parseContributors($xpath, $contributorNodes) {

		$authors = array();

		foreach ($contributorNodes as $contributorNode) {

			if (($personNameNodes = $xpath -> query('./person_name', $contributorNode)) == FALSE)

				throw new Exception('error parsing DOI record');

			if (($organizationNodes = $xpath -> query('./organization', $contributorNode)) == FALSE)

				throw new Exception('error parsing DOI record');

			foreach ($personNameNodes as $personNameNode) {

				if (($surnameNodes = $xpath -> query('./surname', $personNameNode)) == FALSE)

					throw new Exception('error parsing DOI record');

				if (($givenNameNodes = $xpath -> query('./given_name', $personNameNode)) == FALSE)

					throw new Exception('error parsing DOI record');

				$author = new JObject();

				$author -> id = NULL;

				$author -> lastName = (($surnameNode = $surnameNodes -> item(0)) == NULL) ? NULL : trim($surnameNode -> nodeValue);

				$author -> firstName = (($givenNameNode = $givenNameNodes -> item(0)) == NULL) ? NULL : trim($givenNameNode -> nodeValue);

				$author -> fullName = NULL;

				if (($author -> id != NULL) || ($author -> lastName != NULL) || ($author -> firstName != NULL) || ($author -> fullName != NULL))

					$authors[] = $author;

			}

			foreach ($organizationNodes as $organizationNode) {

				$author = new JObject();

				$author -> id = NULL;

				$author -> lastName = NULL;

				$author -> firstName = NULL;

				$author -> fullName = trim($organizationNode -> nodeValue);

				if (($author -> id != NULL) || ($author -> lastName != NULL) || ($author -> firstName != NULL) || ($author -> fullName != NULL))

					$authors[] = $author;

			}

		}

		return $authors;

	}    

	private function _searchORCID($orcid, $page, $size) {

		try {

			$time = microtime(TRUE);

			$authorRequest = self :: ORCID_URL_PREFIX . trim($orcid) . self :: ORCID_URL_AUTHOR_SUFFIX;

			JLog :: add('Requesting ' . $authorRequest, JLog :: INFO, self :: LOG);

			$authorResponse = $this -> http -> get($authorRequest);

			JLog :: add('Received response in ' . (microtime(TRUE) - $time) . ' s');

			$author = new JObject();	

			$result = new JObject();

			if ($authorResponse != NULL&&$authorResponse -> code===self :: HTTP_OK){				

				/*if ($authorResponse -> code != self :: HTTP_OK)

					throw new Exception('HTTP response code ' . $authorResponse -> code);*/					

				$authorDocument = new DOMDocument();

				$authorDocument -> recover = TRUE;

				if ($authorDocument -> loadXML(trim($authorResponse -> body)) == FALSE)

					throw new Exception('invalid XML response');

				$authorXpath = new DOMXPath($authorDocument);

				if ($authorXpath -> registerNamespace('orcid', $authorDocument -> lookupNamespaceUri(NULL)) == FALSE)

					throw new Exception('error parsing ORCID bio record');

				if (($familyNameNodes = $authorXpath -> query('/orcid:orcid-message/orcid:orcid-profile/orcid:orcid-bio/orcid:personal-details/orcid:family-name')) == FALSE)

					throw new Exception('error parsing ORCID bio record');				

				if (($givenNamesNodes = $authorXpath -> query('/orcid:orcid-message/orcid:orcid-profile/orcid:orcid-bio/orcid:personal-details/orcid:given-names')) == FALSE)

					throw new Exception('error parsing ORCID bio record');

				$author -> id = $orcid;

				$author -> lastName = (($familyNameNode = $familyNameNodes -> item(0)) == NULL) ? NULL : trim($familyNameNode -> nodeValue);

				$author -> firstName = (($givenNamesNode = $givenNamesNodes ->item(0)) == NULL) ? NULL : trim($givenNamesNode -> nodeValue);

				$author -> fullName = NULL;

			}else{

				$time = microtime(TRUE);

				$orcid=str_replace(" ","+",$orcid);

				//$authorRequest = 'http://pub.orcid.org/search/orcid-bio?q='. trim($orcid);                                

                                $authorRequest = 'http://pub.orcid.org/search/orcid-bio?defType=edismax&q='. trim($orcid)."&qf=given-name^1.0+family-name^2.0+other-names^1.0+credit-name^1.0&start=0&rows=10";

				JLog :: add('Requesting ' . $authorRequest, JLog :: INFO, self :: LOG);

				$authorResponse = $this -> http -> get($authorRequest);

				JLog :: add('Received response in ' . (microtime(TRUE) - $time) . ' s');

				if ($authorResponse -> code != self :: HTTP_OK)

					throw new Exception('HTTP response code ' . $authorResponse -> code);

				$authorDocument = new DOMDocument();

				$authorDocument -> recover = TRUE;

				if ($authorDocument -> loadXML(trim($authorResponse -> body)) == FALSE)

					throw new Exception('invalid XML response');

				$authorXpath = new DOMXPath($authorDocument);

				if ($authorXpath -> registerNamespace('orcid', $authorDocument -> lookupNamespaceUri(NULL)) == FALSE)

					throw new Exception('error parsing ORCID bio record');

				if (($resultNodes = $authorXpath -> query('/orcid:orcid-message/orcid:orcid-search-results/orcid:orcid-search-result')) == FALSE)

					throw new Exception('error parsing ORCID bio record');		

				$authors = array();		

				foreach ($resultNodes as $resultNode) {					

					if (($familyNameNodes = $authorXpath -> query('./orcid:orcid-profile/orcid:orcid-bio/orcid:personal-details/orcid:family-name',$resultNode)) == FALSE)

						throw new Exception('error parsing ORCID bio record');				

					if (($givenNamesNodes = $authorXpath -> query('./orcid:orcid-profile/orcid:orcid-bio/orcid:personal-details/orcid:given-names',$resultNode)) == FALSE)

						throw new Exception('error parsing ORCID bio record');

					if (($idNodes = $authorXpath -> query('./orcid:orcid-profile/orcid:orcid-identifier/orcid:path',$resultNode)) == FALSE)

						throw new Exception('error parsing ORCID bio record');

					if (($relevanceNodes = $authorXpath -> query('./orcid:relevancy-score',$resultNode)) == FALSE)

						throw new Exception('error parsing ORCID bio record');

					$tempAuthor = new JObject();

					$tempAuthor -> id = (($idNode = $idNodes -> item(0)) == NULL) ? NULL : trim($idNode -> nodeValue);

					$tempAuthor -> lastName = (($familyNameNode = $familyNameNodes -> item(0)) == NULL) ? NULL : trim($familyNameNode -> nodeValue);

					$tempAuthor -> firstName = (($givenNamesNode = $givenNamesNodes ->item(0)) == NULL) ? NULL : trim($givenNamesNode -> nodeValue);

					$tempAuthor -> fullName = NULL;

					$relevance = (($relevanceNode = $relevanceNodes ->item(0)) == NULL) ? NULL : trim($relevanceNode -> nodeValue);

					$authors[] = $tempAuthor;

				}

				$author= $authors[0];

				$authors = array_slice($authors, 0, 10);

                                $result ->alternativeAuthors =NULL;

                                if($page===1){

                                    $result ->alternativeAuthors =$authors;

                                }

			}

			$publicationsRequest = self :: ORCID_URL_PREFIX . trim(((isset($author -> id)&&$author -> id!=null)?$author -> id:$orcid)) . self :: ORCID_URL_PUBLICATIONS_SUFFIX;

			JLog :: add('Requesting ' . $publicationsRequest, JLog :: INFO, self :: LOG);

			if (($publicationsResponse = $this -> http -> get($publicationsRequest)) == NULL)

				throw new Exception('no HTTP response');

			if ($publicationsResponse -> code != self :: HTTP_OK)

				throw new Exception('HTTP response code ' . $publicationsResponse -> code);

			$publicationsDocument = new DOMDocument();

			$publicationsDocument -> recover = TRUE;

			if ($publicationsDocument -> loadXML(trim($publicationsResponse -> body)) == FALSE)

				throw new Exception('invalid XML response');

			$publicationsXpath = new DOMXPath($publicationsDocument);

			if ($publicationsXpath -> registerNamespace('orcid', $publicationsDocument -> lookupNamespaceUri(NULL)) == FALSE)

				throw new Exception('error parsing ORCID works record');

			if (($orcidWorkNodes = $publicationsXpath -> query('/orcid:orcid-message/orcid:orcid-profile/orcid:orcid-activities/orcid:orcid-works/orcid:orcid-work')) == FALSE)

				throw new Exception('error ORCID works record');

			$result -> publications = array();      

                        $dois = array();      

                        $i=0;

			foreach ($orcidWorkNodes as $orcidWorkNode) { 

                            $i++;

                            if($i>=($page-1)*$size +1 && $i<=$page*$size ){

				if (($putCodeNodes = $publicationsXpath -> query('./@put-code', $orcidWorkNode)) == FALSE)

					throw new Exception('error ORCID works record');

				if (($urlNodes = $publicationsXpath -> query('./orcid:url', $orcidWorkNode)) == FALSE)

					throw new Exception('error ORCID works record');

				if (($titleNodes = $publicationsXpath -> query('./orcid:work-title/orcid:title', $orcidWorkNode)) == FALSE)

					throw new Exception('error ORCID works record');

				if (($yearNodes = $publicationsXpath -> query('./orcid:publication-date/orcid:year', $orcidWorkNode)) == FALSE)

					throw new Exception('error ORCID works record');

				if (($shortDescriptionNodes = $publicationsXpath -> query('./orcid:short-description', $orcidWorkNode)) == FALSE)

					throw new Exception('error ORCID works record');

				if (($doiNodes = $publicationsXpath -> query('./orcid:work-external-identifiers/orcid:work-external-identifier[orcid:work-external-identifier-type = "doi"]/orcid:work-external-identifier-id', $orcidWorkNode)) == FALSE)

					throw new Exception('error ORCID works record');

				$publication = new JObject();

				$publication -> id = (($putCodeNode = $putCodeNodes -> item(0)) == NULL) ? NULL : ($author -> id . '-' . trim($putCodeNode -> nodeValue));

				$publication -> source = self :: ORCID;

				$publication -> url = (($urlNode = $urlNodes -> item(0)) == NULL) ? NULL : trim($urlNode -> nodeValue);

				$publication -> accessMode = NULL;

				$publication -> datasources = array();

				$publication -> title = (($titleNode = $titleNodes -> item(0)) == NULL) ? NULL : trim($titleNode -> nodeValue);

				$publication -> authors = array();

				$publication -> publisher = NULL;

				$publication -> year = (($yearNode = $yearNodes -> item(0)) == NULL) ? NULL : intval(trim($yearNode -> nodeValue));

				$publication -> language = NULL;

				$publication -> projects = array();

				$publication -> embargoEndDate = NULL;

				$publication -> description = (($shortDescriptionNode = $shortDescriptionNodes -> item(0)) == NULL) ? NULL : trim($shortDescriptionNode -> nodeValue);

				if (($author -> lastName != NULL) || ($author -> firstName != NULL))

					$publication -> authors[] = $author;

				if ((($doiNode = $doiNodes -> item(0)) != NULL) && (($doiResult = $this -> searchSingleDOI(trim($doiNode -> nodeValue))) != NULL)) { // resolve via DOI

					if ($publication -> url == NULL) // set URL if missing

						$publication -> url = $doiResult -> url;

					if ($publication -> title == NULL) // set title if missing

						$publication -> title = $doiResult -> title;

					foreach ($doiResult -> authors as $doiAuthor) { // merge authors

						if ((count($publication -> authors) == 0) || ($doiAuthor -> id != $publication -> authors[0] -> id) || ($doiAuthor -> lastName != $publication -> authors[0] -> lastName) || ($doiAuthor -> firstName != $publication -> authors[0] -> firstName) || ($doiAuthor -> fullName != $publication -> authors[0] -> fullName))

							$publication -> authors[] = $doiAuthor;

					}

					if ($publication -> year == NULL) // set year if missing

						$publication -> year = $doiResult  -> year;

				}				

				if (($publication -> id != NULL) || ($publication -> title != NULL) || ($publication -> authors != NULL) || ($publication -> year != NULL) || ($publication -> description != NULL)){

                                    if ((($doiNode = $doiNodes -> item(0)) != NULL)) { // resolve via DOI

                                        $doi=trim($doiNode -> nodeValue);

                                         if((strpos($doi,"DOI: ") !== false)){

                                             $doi=explode("DOI: ", $doi)[1];                                        

                                         }

                                        $dois[$publication -> id]=$doi;                                        

                                    }

                                    $result -> publications[$publication -> id] = $publication;

                                }

                            }

			}

                        // request to crossref via DOI

                        $resultsFromDois=$this->_searchMultipleDOIs($dois);

                        foreach ($result -> publications as $publication){

                            $doi=$dois[$publication -> id];

                            if($doi!=null&&$resultsFromDois[$doi]!=null){

                                $doiResult=$resultsFromDois[$doi];

                                    if ($publication -> url == NULL) // set URL if missing                                    

                                        $publication -> url = $doiResult -> url;

                                    if ($publication -> title == NULL) // set title if missing

					$publication -> title = $doiResult -> title;					

                                    foreach ($doiResult -> authors as $doiAuthor) { // merge authors

					if ((count($publication -> authors) == 0) || ($doiAuthor -> id != $publication -> authors[0] -> id) || ($doiAuthor -> lastName != $publication -> authors[0] -> lastName) || ($doiAuthor -> firstName != $publication -> authors[0] -> firstName) || ($doiAuthor -> fullName != $publication -> authors[0] -> fullName))

						$publication -> authors[] = $doiAuthor;

                                    }

                                    if ($publication -> year == NULL) // set year if missing

                        		$publication -> year = $doiResult  -> year;

                            }

                        }

                        $result -> totalPublications = $i; 

			$result -> totalDatasets = 0;

			$result -> author = $author;

			JLog :: add('ORCID search retrieved ' . count($result -> publications) . ' publications in ' . (microtime(TRUE) - $time) . ' s (ORCID: ' . $orcid . ', page: ' . $page . ', size: ' . $size . ')', JLog :: INFO, self :: LOG);

			return $result;

		} catch (Exception $e) {

			JLog :: add('Error performing ORCID search (ORCID: ' . $orcid . ', page: ' . $page . ', size: ' . $size . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			$result = new JObject();

			$result -> totalPublications = 0;

			$result -> totalDatasets = 0;

			$result -> author = $author;

			return $result;

		}

	}    

	private function _searchDOI($doi, $page, $size) {

		try {

                        $result = new JObject();

                        $result -> publications = array();

                        $result -> totalPublications = 0;

                        $result -> totalDatasets = 0;	

                        $dois = explode(" ", preg_replace('/\s+/', ' ',$doi));                  

                        $unique_dois =array_slice( array_unique($dois),0,10);

                        $pattern1 ='#\b(10[.][0-9]{4,}(?:[.][0-9]+)*/(?:(?!["&\'<>])\S)+)\b#';

                        $pattern2 ='#\b(10[.][0-9]{4,}(?:[.][0-9]+)*/(?:(?!["&\'<>])[[:graph:]])+)\b#';                        

                         if (preg_match($pattern1,$unique_dois[0])||preg_match($pattern2,$unique_dois[0])){

                              if(count($dois)>10){

                                $result = new JObject();

                                $result->publications = array();

                                $result->totalPublications = '-';

                                $result->totalDatasets = 0;

                                $result->maxDoisExceeded = true;

                                return $result;

                             }

                            JLog :: add('Searching for DOIs ' , JLog :: INFO, self :: LOG);                                              

                            /*foreach($unique_dois as $doi_){

                                JLog :: add('DOI::: '.$doi_ , JLog :: INFO, self :: LOG);

                                $publication = $this->_searchSingleDOI($doi_);

                                if ($publication != null) {

                                    $result->publications[] = $publication;

                                }

                            }*/

                            $result->publications= $this->_searchMultipleDOIs($unique_dois);

                         }

                        $result -> totalPublications = count( $result -> publications);

			if($result -> totalPublications ===0){

				//.'&rows='.$size.'&offset='.$page

				$request = "http://api.crossref.org/works?query=" . urlencode( trim($doi))."&rows=".$size."&offset=".($page-1)*$size;

				JLog :: add('Requesting ' . $request, JLog :: INFO, self :: LOG);

				$time = microtime(TRUE);

				$response = $this -> http -> get($request);

				JLog :: add('Received response in ' . (microtime(TRUE)  - $time) . ' s', JLog :: INFO, self :: LOG);

				if ($response == NULL)

					throw new Exception('no HTTP response');

				if ($response -> code != self :: HTTP_OK)

					throw new Exception('HTTP response code ' . $response -> code);

				$res = array();

                                $response= $response -> body;

                                $response=str_replace("date-parts", "date_parts",$response-> body);

                                $response=str_replace("total-results", "total_results",$response);

				//$res = json_decode(str_replace("-", "_", $response -> body));

                                $res = json_decode($response);

				if(isset($res -> status)&&$res -> status === "ok" && isset($res -> message)){

					foreach($res ->message -> items as $item){

						$publication = $this -> _parseJsonDOI($item);

						if($publication!=null){

							$result -> publications[] = $publication;

						}	

					}

					$result -> totalPublications = $res -> message ->total_results;

					/*if(isset($size)&&isset($page)){

						$result -> publications = array_slice($result -> publications, ($page - 1) * $size, $size);

					}*/

			}

		}

 				return $result;

		} catch (Exception $e) {

			JLog :: add('Error performing DOI search (doi: ' . $doi . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			$result = new JObject();

				$result -> publications = array();

				$result -> totalPublications = 0;

				$result -> totalDatasets = 0;

				JLog :: add('error parsing DOI record', JLog :: INFO, self :: LOG);

				return $result;

		}

	}

        public function searchSingleDOI($doi) {

		if ($this -> cache -> getCaching()) {

			$cacheId = self :: SEARCH_DOI_CACHE_ID . '.' . $doi;

			$results = $this -> cache -> get($cacheId, self :: CACHE_GROUP);

			if ($results === FALSE) {

				$results = $this -> _searchSingleDOI($doi);

				if ($results !== NULL)

					$this -> cache -> store($results, $cacheId, self :: CACHE_GROUP);

			}

		} else

			$results = $this -> _searchSingleDOI($doi);

		return $results;

	}

        private function _searchSingleDOI($doi) {

		try {                           

			$request = self :: CROSSREF_API_DOI . urlencode( trim($doi));

			JLog :: add('Requesting ' . $request, JLog :: INFO, self :: LOG);

			$time = microtime(TRUE);

			$response = $this -> http -> get($request);

			JLog :: add('Received response in ' . (microtime(TRUE)  - $time) . ' s', JLog :: INFO, self :: LOG);

			if ($response == NULL)

				throw new Exception('no HTTP response');

			if ($response -> code != self :: HTTP_OK)

				throw new Exception('HTTP response code ' . $response -> code);

			$res = array();

                        $response= $response -> body;

                        $response=str_replace("date-parts", "date_parts",$response-> body);

                        $response=str_replace("total-results", "total_results",$response);

			//$res = json_decode(str_replace("-", "_", $response -> body));

                        $res = json_decode($response);				

			if(isset($res -> status) && $res -> status === "ok" && isset($res -> message)){				

                            $publication = $this -> _parseJsonDOI($res -> message);

                            return $publication;					 

			}

		} catch (Exception $e) {

			JLog :: add('Error performing DOI search (doi: ' . $doi . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			$result = new JObject();

				$result -> publications = array();

				$result -> totalPublications = 0;

				$result -> totalDatasets = 0;

				JLog :: add('error parsing DOI record', JLog :: INFO, self :: LOG);

				return null;

		}

	}

	private function _searchMultipleDOIs($dois){

            try {                           

			$request ="http://api.crossref.org/works"."?filter=";

                        foreach($dois as $doi){

                            $request.="doi:".urlencode( trim($doi)).",";

                        }

			JLog :: add('Requesting ' . $request, JLog :: INFO, self :: LOG);

			$time = microtime(TRUE);

			$response = $this -> http -> get($request);

			JLog :: add('Received response in ' . (microtime(TRUE)  - $time) . ' s', JLog :: INFO, self :: LOG);

			if ($response == NULL)

				throw new Exception('no HTTP response');

			if ($response -> code != self :: HTTP_OK)

				throw new Exception('HTTP response code ' . $response -> code);

			$res = array();

                        $response=str_replace("date-parts", "date_parts",$response-> body);

                        $response=str_replace("total-results", "total_results",$response);

                        $res = json_decode($response);	

			//$res = json_decode(str_replace("-", "_", $response -> body));				

			if(isset($res -> status) && $res -> status === "ok" && isset($res -> message)){				

                            $publications = $this ->_parseMultipleJsonDOIs($res -> message);

                            return $publications;					 

			}

		} catch (Exception $e) {

			JLog :: add('Error performing DOI search (doi: ' . $doi . '): ' . $e -> getMessage(), JLog :: ERROR, self :: LOG);

			$result = new JObject();

				$result -> publications = array();

				$result -> totalPublications = 0;

				$result -> totalDatasets = 0;

				JLog :: add('error parsing DOI record', JLog :: INFO, self :: LOG);

				return null;

		}

        }

	// Search for a publication DOI using caching if enabled.

	// $doi the publication DOI to search for

	// return an array of results

	public function searchDOI($doi, $page, $size) {

		if ($this -> cache -> getCaching()) {

			$cacheId = self :: SEARCH_DOI_CACHE_ID . '.' . $doi;

			$results = $this -> cache -> get($cacheId, self :: CACHE_GROUP);

			if ($results === FALSE) {

				$results = $this -> _searchDOI($doi, $page, $size);

				if ($results !== NULL)

					$this -> cache -> store($results, $cacheId, self :: CACHE_GROUP);

			}

		} else

			$results = $this -> _searchDOI($doi, $page, $size);

		return $results;

	}

	// Search for a dataset DOI using caching if enabled.

	// $doi the dataset DOI to search for

	// return a result (object) containing publications and total

	public function searchDataCite($doi, $page, $size) {

		if ($this -> cache -> getCaching()) {

			$cacheId = self :: SEARCH_DATASET_CACHE_ID . '.' . $doi;

			$results = $this -> cache -> get($cacheId, self :: CACHE_GROUP);

			if ($results === FALSE) {

				$results = $this -> _searchDataCite($doi, $page, $size);

				if ($results !== NULL)

					$this -> cache -> store($results, $cacheId, self :: CACHE_GROUP);

			}

		} else

			$results = $this -> _searchDataCite($doi, $page, $size);

		return $results;

	}

	// Search for publications in ORCID using caching if enabled.

	// $doi the ORCID id to search for

	// $page the result page to retrieve

	// $size the result page size to use

	// return a result (object) containing datasets and total

	public function searchORCID($orcid, $page, $size) {

		if ($this -> cache -> getCaching()) {

			$cacheId = self :: SEARCH_ORCID_CACHE_ID . '.' . $orcid . '.' . $page . '.' . $size;

			$results = $this -> cache -> get($cacheId, self :: CACHE_GROUP);

			if ($results === FALSE) {

				$results = $this -> _searchORCID($orcid, $page, $size);

				if ($results !== NULL)

					$this -> cache -> store($results, $cacheId, self :: CACHE_GROUP);

			}

		} else

			$results = $this -> _searchORCID($orcid, $page, $size);

		return $results;

	}

}

?>

<?php

/**

 * Script for tracking direct downloads with Piwik-powered web analytics.

 * 2013-02-27, by Amenel VOGLOZIN @ khalemy.com

 * All (my) rights abandoned: my work is public domain and this entire script package comes with absolutely NO WARRANTY.

 *