EDIT

<?php

/**

 * @file

 * Functions which are required or useful when accessing and processing CDM Data Store Webservices

 * 

 * Naming conventions:

 * ----------------------

 * 

 *  - all webservice access methods are prefixed with cdm_ws

 * Copyright (C) 2007 EDIT

 * European Distributed Institute of Taxonomy 

 * http://www.e-taxonomy.eu

 */

require_once ('xml2json.php');

  $requirements['cdm_api'] = array(

    'title' => t('CDM API')

  );

  if( function_exists('curl_init') ){

    $requirements['cdm_api']['description'] = ''; // description below title is not jet in use 

    $requirements['cdm_api']['value'] =  'CURL php extension is available.';

  } else {

    $requirements['cdm_api']['value'] =  'CURL php extension is missing.';

  }

  //FIXME: once _get_content_fsockopen is implemented change  severity to  REQUIREMENT_WARNING,

  $requirements['cdm_api']['severity'] =  (function_exists('curl_init') ? REQUIREMENT_OK : REQUIREMENT_ERROR);

  return $requirements;

  $items = array();

  if ($may_cache) {

   $items[] = array(

      'callback' => 'proxy_content',

      'access' => true,

      'type' => MENU_CALLBACK,

      );

  return $items;

   $form['cdm_webservice'] = array(

      '#type' => 'fieldset',

      '#title' => t('CDM Web Service'),

      '#collapsible' => FALSE,

      '#collapsed' => FALSE,

  );

  $form['cdm_webservice']['cdm_webservice_url'] =  array(

    '#type' => 'textfield',

    '#title'         => t('CDM Web Service URL'),

    '#description'   => t('The URL of CDM Webservice which delivers the data to be published.'),

    '#default_value' => variable_get('cdm_webservice_url', 'http://dev.e-taxonomy.eu/svn/trunk/drupal/modules/cdm_dataportal/cdm_api/ws_stub/'),

  );

  $form['cdm_webservice']['cdm_webservice_isStub'] =  array(

    '#type' => 'checkbox',

    '#title'         => t('Use Web Service Stub'),

    '#default_value' => variable_get('cdm_webservice_isStub', 1),

    '#description'   => t('Use a static web service stub. Only for development. For further information please refer to the ')

  .l('ws_stub/README.txt', 'http://dev.e-taxonomy.eu/svn/trunk/drupal/modules/cdm_dataportal/cdm/ws_stub/README.txt', array('target'=>'_blank')),

  );

  $form['cdm_webservice']['cdm_webservice_type'] =  array(

    '#default_value' => variable_get('cdm_webservice_type', 'json'),

            'xml'  => t('XML'),

            'json' => t('JSON'),

    '#description'   => t('The response data type of the web service.'),

  );

  $form['cdm_webservice']['cdm_webservice_cache'] =  array(

    '#type' => 'checkbox',

    '#title'         => t('Enable Caching'),

    '#default_value' => variable_get('cdm_webservice_cache', 1),

      .'that is requests which only have one parameter generally a UUID or a concatenation of UUIDs')

  $form['cdm_webservice']['proxy'] = array(

      '#type' => 'fieldset',

      '#title' => t('Proxy'),

      '#collapsible' => TRUE,

      '#collapsed' => TRUE

  );

  $form['cdm_webservice']['proxy']['cdm_webservice_proxy_url'] =  array(

    '#type' => 'textfield',

    '#title'         => t('Proxy URL'),

    '#description'   => t('If this proxy url is set the cdm api tries 

    to connect the web service over the given proxy server. 

    Otherwise proxy usage is deactivated.'),

    '#default_value' => variable_get('cdm_webservice_proxy_url', false),

  );

  $form['cdm_webservice']['proxy']['cdm_webservice_proxy_port'] =  array(

    '#type' => 'textfield',

    '#title'         => t('Proxy Port'),

    '#default_value' => variable_get('cdm_webservice_proxy_port', '80'),

  );

  $form['cdm_webservice']['proxy']['cdm_webservice_proxy_usr'] =  array(

    '#type' => 'textfield',

    '#title'         => t('Login'),

    '#default_value' => variable_get('cdm_webservice_proxy_usr', false),

  );

  $form['cdm_webservice']['proxy']['cdm_webservice_proxy_pwd'] =  array(

    '#type' => 'textfield',

    '#title'         => t('Password'),

    '#default_value' => variable_get('cdm_webservice_proxy_pwd', false),

  );

  $form['cdm_webservice']['cdm_webservice_debug'] =  array(

    '#type' => 'checkbox',

    '#title'         => t('Debug CDM Web Service'),

    '#default_value' => variable_get('cdm_webservice_debug', 1),

    '#description'   => t('Enable CDM Web Service debugging messages')

  );

  return $form;

}

 * Implementation of hook_cron().

 *

 * Expire outdated cache entries

 */

function cdm_api_cron() {

  cache_clear_all(NULL, 'cache_cdm_ws');

}

// ----------------------------------------------------------- //

/**

 * Converts an array of TagedText items into a sequence of corresponding html tags whereas 

 * each item will provided with a class attribute which set to the key of the TaggedText item.

 * 

 * @param array $taggedtxt

 * @param String $tag

 * @param String $glue the string by which the chained text tokens are concatenated together. 

 *       Default is a blak character

 * @return String of HTML 

 */

   $i = 0;

      $out .= (strlen($out) > 0 && ++$i < count($taggedtxt)? $glue : '').'<'.$tag.' class="'.$tt->type.'">'.$tt->text.'</'.$tag.'>';

   return $out;

}

/**

 * Finds the text tagged with $$tag_type in an array of taggedText instances

 *

 * @param array $taggedtxt

 * @param string $tag_type

 * @return the text mapped by $tag_type or an empty string

 */

function cdm_taggedtext_value(array &$taggedtxt = array(), $tag_type){

  foreach($taggedtxt as $tagtxt){

    if($tagtxt->type == $tag_type)

    return $tagtxt->text;

  }

  return '';

}

 * Produces a path to a static web service stub out of a cdm web service path. 

 * These stubs are object serialisations stored in files whereas the filename

 * consists of the service name and of a 

 * encoded version of the request query parameters

 *

 * @param string $path

 */

  }

  $path_params = '';

  if(!is_array($parameters)){

     // add to path

     $path_params .= '/'.( is_string($parameters) ? urlencode($parameters) : $parameters);

  }else{

    foreach($parameters as $key=>$value){

      if(is_numeric($key)){

        // add to path

        $path_params .= '/'.( is_string($value) ? urlencode($value) : $value);

      } else {

        // add to parameters

        $request_params .= ( strlen($request_params) == 0 ? '?' : '&').$key.'='.( is_string($value) ? urlencode($value) : $value);

      }

    }

  if(variable_get('cdm_webservice_isStub', 0)){

}

  $args = func_get_args();

  $theme = array_shift($args);

    array_unshift($args, $theme, $obj);

}

/**

 *

 * @param unknown_type $method

 * @param $parameters may be an array or a single variable

 * @return unknown

  /*$args = func_get_args();

  $method = array_shift($args);

  */  

  /*if(isset($args[0]) && is_array($args[0])){

    $url = cdm_compose_url_parametrised($method, $args[0]);

  } else {

 */    

  $url = cdm_compose_url($method, $parameters);

  //}

  return cdm_ws_load($url, (is_array($parameters)));

 * The XML is turned into a object which is returned.

 * 

 * @param String $url the relative url of the web service call. 

 *        Relative means relative to the web service base url which is stored in cdm_webservice_url

 * @return An object or false

  $cache_entry = false;

    // try to get object from cache 

    $cache_entry = cache_get($url, 'cache_cdm_ws');

  }

    // load fresh data from webservice

      $storef =  urlencode($url);

      drupal_set_message($storef);

      file_save_data($datastr, $storef, FILE_EXISTS_REPLACE);

    }*/

    $time_parse_start = microtime(true);

      watchdog('CDM', 'cdm_ws_load() - URL: '.$url, WATCHDOG_ERROR);

    } else if($do_cache) {

      // store fresh data in cache

      cache_set($url, 'cache_cdm_ws', serialize($obj), CACHE_TEMPORARY);

    }

    $datastr = xml2json::transformXmlStringToJson($datastr);  

  }

  if($use_stub){

    $json_pear = new Services_JSON();

    $obj = $json_pear->decode($datastr);

  } else {

    // --- generally use the fast php json lib --- //

    $obj = json_decode($datastr);

  }

    var_dump($obj);

    $obj_dump = ob_get_contents();

    ob_clean();

    watchdog('CDM', 'cdm_load_obj() - invalid object: '.$obj_dump, WATCHDOG_ERROR);

    return false;

  }

    $arr = (array)$obj;

    $obj = array_pop($arr);

  }

  return $obj;

  global $locale;  // drupal variable containing the current locale i.e. language

  static $header;

    $header = array();

    $header[] = 'Accept: '.(variable_get('cdm_webservice_type', 'json') == 'json' ? 'application/json' : 'text/xml');    

    $header[] = 'Accept-Language: '.$locale;

    $header[] = 'Accept-Encoding: UTF8';

  }

  if(function_exists('curl_init')){

    // use the CURL lib if installed it is supposed to be 20x faster

    return _get_content_curl($url, $header);

  } else {

    return _get_content_fsockopen($url, $header);

function _get_content_fsockopen($url, $header = array()){

  //FIXME implement get_content_fsockopen($url);

   watchdog('CDM_API', '_get_content_fsockopen - UNIMPLEMENTED', WATCHDOG_ERROR);

   return false;

 * 

 * @param string $url

 * @return string

 * 

 * @author Luiz Miguel Axcar (lmaxcar@yahoo.com.br)

*/

function _get_content_curl($url, $header = array())

{

    $ch = curl_init();

    curl_setopt ($ch, CURLOPT_URL, $url);

    // set proxy settings

    if(variable_get('cdm_webservice_proxy_url', false)){

      curl_setopt($ch, CURLOPT_PROXY, variable_get('cdm_webservice_proxy_url', ''));

      curl_setopt($ch, CURLOPT_PROXYPORT, variable_get('cdm_webservice_proxy_port', '80'));

      if(variable_get('cdm_webservice_proxy_usr', false)){

        curl_setopt ($ch, CURLOPT_PROXYUSERPWD, variable_get('cdm_webservice_proxy_usr', '').':'.variable_get('cdm_webservice_proxy_pwd', '')); 

      }

    }

    // set headers

    curl_setopt ($ch, CURLOPT_HTTPHEADER, $header);

    ob_start();

    curl_exec ($ch);

    if(curl_errno($ch)){

      watchdog('CDM_API', '_get_content_curl() - '.curl_error($ch).' URL: '.$url, WATCHDOG_ERROR);

        if(variable_get('cdm_webservice_debug', 1)){

          drupal_set_message('_get_content_curl() - '.curl_error($ch).' URL: '.$url, 'error');

        }

    }

    curl_close ($ch);

    $string = ob_get_contents();

    ob_end_clean();

    return $string;    

  global $secref_cache;

  if(!is_array($secref_cache)){

    $secref_cache = array();

  }

  $uniqueUuids = array_unique($secUuids);

  $i = 0;

  $param = '';

  while($i++ < count($uniqueUuids)){

    $param .= $secUuids[$i].',';

    if(strlen($param) + 37 > 2000){

     _cdm_api_secref_cache_add($param);

      $param = '';

    }

  }

  if($param){

     _cdm_api_secref_cache_add($param);

  }

}

function cdm_api_secref_cache_get($secUuid){

  global $secref_cache;

  if(!is_array($secref_cache)){

    $secref_cache = array();

  }

  if(!array_key_exists($secUuid, $secref_cache)){

    _cdm_api_secref_cache_add($secUuid);

  }

  return $secref_cache[$secUuid]; 

}

function cdm_api_secref_cache_clear(){

  global $secref_cache;

  $secref_cache = array();

}

function _cdm_api_secref_cache_add($secUuidsStr){

  global $secref_cache;

  $refSTOs = cdm_ws_get(CDM_WS_SIMPLE_REFERENCE, $secUuidsStr);

  $assocRefSTOs = array();

    foreach($refSTOs as $ref){

      $assocRefSTOs[$ref->uuid] = $ref;

    }

    $secref_cache = array_merge($secref_cache, $assocRefSTOs);

}

 * Web Service Arguments: {Uuid}

 * 

 * i.e. DTO class name and simplename & cdm class name and simplename of the instance referenced by the $uuid parameter. 

 * 

 *   - 'cdmName':       name of the cdm class as returned by Class.getName(), e.g. eu.etaxonomy.cdm.model.taxon.Taxon

 *   - 'cdmSimpleName': simple name of the cdm class as returned by Class.getSimpleName(), e.g. Taxon

 *   - 'dtoName':       name of the DTO class as returned by Class.getName(), e.g. eu.etaxonomy.cdm.dto.TaxonTO

 *   - 'dtoSimpleName': simple name of the TDO class as returned by Class.getSimpleName(), e.g. TaxonTO

 */

/**

/**

 * -  sec : the uuid of the concept reference

 * -  higherTaxa : list of taxon uuid, if higherTaxa are defined only taxa which are includet in one these taxa are taken in to account 

 * -  matchAnywhere : false (default) match the querystring to the beginning of names, if set to true any matching substring is taken as a hit.

 * -  onlyAccepted : return only taxa which are accepted in the sence of the concept reference as given by parameter sec

 * -  pagesize : maximum number of iteme per result page

 * -  page: the number of page to be returned

 * 

 * returns ResultPageSTO

 * Web Service Arguments: {taxonUuid}

 */

define('CDM_WS_TAXON', 'taxon');

/**

 * 

 * returns a list of TaxonSTO

define('CDM_WS_SIMPLE_TAXON', 'simple/taxon');

 * Web Service Arguments: {nameUuid}

 * returns a set of type designation which are assigned to the name given

 * as parameter. The Set may contain {@link NameTypeDesignationSTO}

 * and {@link SpecimenTypeDesignationSTO}

 * Web Service Arguments: {taxonUuid}

 * returns the taxon which is the accepted synonym for the taxon given as

 * parameter taxonUuid. If the taxon specified by taxonUuid is itself the

 * accepted taxon, this one will be returned.

 * 

 * Gets the root nodes of the taxonomic concept tree for the concept

 * reference specified by the secUuid parameter.

 * stub: treenode_root

/**

 * 

 * from the taxon which is referenced by the parameter taxonUuid down to its

 * root. The reference taxon will also be included into the returned set of

 * TreeNode instances.

 * stub: treenode_parents

 * Web Service Arguments: {taxonUuid}

 * returns the children of the taxon referenced by the parameter

 * taxonUuid.

 * stub: treenode_children