drce.php

Go to the documentation of this file.

#!/usr/bin/php
<?php
//Set default timezone if not set in host environment
@date_default_timezone_set(@date_default_timezone_get());

require_once '../inc/hce_node_api.inc.php';
require_once '../inc/drce.ini.php';

if($REQUEST_TYPE==HCE_DRCE_REQUEST_TYPE_SET)

$hce_connection=hce_connection_create(array('host'=>$Connection_host, 'port'=>$Connection_port, 'type'=>HCE_CONNECTION_TYPE_ROUTER, 'identity'=>$Client_Identity));

if(!$hce_connection['error']){
  if($LOG_MODE!=3){
    echo 'Client ['.$Client_Identity.'] conected, start to send '.$MAX_QUERIES.' message requests...'.PHP_EOL.PHP_EOL;
  }

  $t=time();
  $Timedout=0;

  for($i=1; $i<=$MAX_QUERIES; $i++){
    $Request_Id=hce_unique_message_id(1, $i.'-'.date('H:i:s').'-');
    $msg_fields=array('id'=>$Request_Id, 'body'=>$Request_body, 'route'=>$Route);
    hce_message_send($hce_connection, $msg_fields);
    
    if($LOG_MODE!=3){
      echo 'request message '.$i.' ['.$Request_Id.'] sent...'.PHP_EOL;
    }
    
    $hce_responses=hce_message_receive($hce_connection, $RESPONSE_TIMEOUT);
    if($hce_responses['error']===0){
      foreach($hce_responses['messages'] as $hce_message){
        //var_dump($hce_message);
        if($LOG_MODE==3){
          if($strip_cover==0){
            $rjson=json_decode($hce_message['body'], true);
            if(isset($rjson['data'])){
              $hce_message['body']=cli_prettyPrintJson(json_encode(json_decode($rjson['data'], true)), '  ');
            }
          }
          echo $hce_message['body'];
        }else{
          if($LOG_MODE!=0){
            echo PHP_EOL.'Raw response:'.PHP_EOL.var_export($hce_message).PHP_EOL.'msg_id=['.$hce_message['id'].']'.PHP_EOL.'msg_body=['.$hce_message['body'].']'.PHP_EOL.PHP_EOL;
          }
          $rjson=hce_drce_exec_parse_response_json($hce_message['body']);
          if($LOG_MODE>3){
            echo 'Data field of cover:'.json_decode($hce_message['body'], true)['data'].PHP_EOL;
            foreach($rjson['Data'] as $key=>$val){
              $rjson['Data'][$key]['stdout']=base64_decode($rjson['Data'][$key]['stdout']);
              $rjson['Data'][$key]['stderror']=base64_decode($rjson['Data'][$key]['stderror']);
            }
            echo 'Response decoded:'.PHP_EOL.var_export($rjson, true).PHP_EOL;
          }
          echo 'Results:'.count($rjson).PHP_EOL;
        }
      }
    }else{
      if($hce_responses['error']==HCE_PROTOCOL_ERROR_TIMEOUT){
        $Timedout++;
        if($LOG_MODE!=3){
          echo 'request timeout'.PHP_EOL;
        }
      }else{
        if($LOG_MODE!=3){
          echo 'request unknown error'.PHP_EOL;
        }
      }
    }
  }
  hce_connection_delete($hce_connection);

  if($LOG_MODE!=3){
    echo PHP_EOL.'Finished '.$MAX_QUERIES.' queries, '.(time()-$t).' sec, '.floor($MAX_QUERIES/(time()-$t+0.00001)).' rps, '.$Timedout.' timedout'.PHP_EOL;
  }
}else{
  if($LOG_MODE!=3){
    echo 'Connection create error '.$hce_connection['error'].PHP_EOL;
  }
}

exit();

?>