Services.php

Go to the documentation of this file.

<?php

namespace Rsi\Fred;

class Services extends Component{

  protected $_endpointKey = 'services-endpoint'; //!< Key for the last successful endpoint URL in the cache.
  protected $_endpointTtl = 86400; //!< Default TTL for the endpoint URL to be stored in the cache.
  protected $_endpoints = ['' => []]; //!< Available endpoints (key = URL, value = params: username, password, timeout, ttl =
    // endpoint specific cache TTL, weight = relative chance to be choosen from the endpoints; main endpoint: high TTL, high
    // weight, backup endpoint: low TTL, low weight; all optional).
  protected $_endpointUrl = null;
  protected $_endpoint = null;

  protected function endpointParam($key,$default = null){
    return \Rsi\Record::get($this->_endpoints[$this->_endpointUrl],$key,$default);
  }

  protected function getEndpoint(){
    if($this->_endpoint === null){
      $cache = $this->component('cache');
      $this->_endpointUrl = $cache->_fetch($this->_endpointKey);
      if(($this->_endpointUrl === false) || !array_key_exists($this->_endpointUrl,$this->_endpoints)){
        $endpoints = [];
        foreach($this->_endpoints as $endpoint => $params)
          $endpoints = array_merge($endpoints,array_fill(0,\Rsi\Record::get($params,'weight',1),$endpoint));
        $this->_endpointUrl = $endpoints[rand(0,count($endpoints) - 1)];
        $cache->_save($this->_endpointKey,$this->_endpointUrl,$this->endpointParam('ttl',$this->_endpointTtl));
      }
      $this->component('log')->debug(__CLASS__ . "->endpointUrl = '{$this->_endpointUrl}'",__FILE__,__LINE__);
      $this->_endpoint = new \Rsi\Services($this->endpointParam('username'),$this->endpointParam('password'),$this->_endpointUrl,$this->endpointParam('timeout'));
    }
    return $this->_endpoint;
  }

  protected function getResponse(){
    return $this->_endpoint ? $this->_endpoint->response : false;
  }

  public function __call($func_name,$params){
    $log = $this->component('log');
    $log->debug(__CLASS__ . "::$func_name(...)",__FILE__,__LINE__);
    while($this->_endpoints) try{
      return call_user_func_array([$this->endpoint,$func_name],$params);
    }
    catch(\Rsi\Services\Exception $e){
      $log->error('Endpoint error: ' . $e->getMessage(),__FILE__,__LINE__);
      unset($this->_endpoints[$this->_endpointUrl]);
      $this->_endpoint = null;
    }
    throw new Exception('No (more) endpoints');
  }

}