External.php

Go to the documentation of this file.

<?php
 
namespace Rsi\Fred;
 
/**
 *  External call wrapper.
 */
class External extends Component{
 
  public $countPeriod = 3600; //!< Default count period (seconds).
  public $countMax = null; //!< Default maximum number of open calls in a period (empty = no maximum).
  public $errorPeriod = 3600; //!< Default error period (seconds).
  public $errorMax = 10; //!< Default maximum number of errors in a period.
  public $functions = []; //!< Function (key) specific configurations (array).
  public $logPrio = Log::INFO; //!< Prio for call results.
 
  protected $_path = null;
  protected $_ext = '.cnt';
  protected $_garbageChance = 100;
 
  protected function filename($func_name,$type,$period){
    return $this->_path . "/$func_name-$type-" . round(time() / $period) . $this->_ext;
  }
 
  protected function inc($func_name,$type,$period){
    file_put_contents($this->filename($func_name,$type,$period),chr(65 + time() % 26),FILE_APPEND);
  }
 
  protected function count($func_name,$type,$period){
    return \Rsi\File::size($this->filename($func_name,$type,$period));
  }
 
  protected function garbage(){
    $period = max($this->countPeriod,$this->errorPeriod);
    foreach($this->functions as $function) $period = max($period,$function['countPeriod'] ?? 0,$function['errorPeriod'] ?? 0);
    foreach(\Rsi\File::find($this->_path,[
      \Rsi\File::FIND_FILTER_NAME . '-*' => $this->_ext,
      \Rsi\File::FIND_FILTER_TIME . '<' => time() - $period
    ]) as $filename => $info) \Rsi\File::unlink($filename);
  }
 
  public function __call($func_name,$params){
    $config = $this->functions[$func_name] ?? [];
    $count_period = $config['countPeriod'] ?? $this->countPeriod;
    $error_period = $config['errorPeriod'] ?? $this->errorPeriod;
    $callback = array_shift($params);
    $result = $params ? array_shift($params) : false;
 
    if(
      !$this->_path ||
      ($this->count($func_name,'error',$error_period) > ($config['errorMax'] ?? $this->errorMax)) || //too many errors
      (
        ($count_max = $config['countMax'] ?? $this->countMax) &&
        (($this->count($func_name,'start',$count_period) - $this->count($func_name,'stop',$count_period)) > $count_max) //too many open calls
      )
    ) return $result;
 
    if(!rand(0,$this->_garbageChance)) $this->garbage();
    $log = $this->component('log');
    $id = $log->start(Log::DEBUG,$message = "External call to '$func_name'",__FILE__,__LINE__,$config);
    $this->inc($func_name,'start',$count_period);
    $retry = $config['retryCount'] ?? 0;
    do{
      $time = microtime(true);
      $error = null;
      try{
        $result = call_user_func($callback);
        $time = microtime(true) - $time;
        $retry = 0;
      }
      catch(\Exception $e){
        $time = microtime(true) - $time;
        $this->inc($func_name,'error',$error_period);
        $log->warning($e);
        $error = $e->getMessage() . ' (' . $e->getFile() . ':' . $e->getLine() . ')';
        if($retry > 0) usleep(($config['retryInterval'] ?? 100) * 1000);
      }
      $log->add($this->logPrio,$message,__FILE__,__LINE__,['funcName' => $func_name,'time' => $time,'error' => $error]);
    }
    while($retry-- > 0);
    $log->stop($id);
    $this->inc($func_name,'stop',$count_period);
    return $result;
  }
 
}