getcus.prg

<?php
  // vim: tabstop=2 expandtab syn=php
   
require_once 'logging.i';
require_once 'hcuEnv.i';
require_once 'hcuCommon.i';
// require_once(dirname(__FILE__) . '/../../shared/library/hcuCommon.i');

$logger = new ColorStandardLogger('getcus');
$env = LoadSystemEnv('version');

if ($env['devmode']) {
  $env['logger']->warning("Showing /getcus info - DEVMODE.");
  $myhostname = "localhost:80";
  $getcustatusvalues = array("stage.homecu.io", "http://" . $myhostname . "/cumaps/getcustatus.prg");
} else {
  $myhostname = "my.homecu.net";
  $getcustatusvalues = array("my.homecu.net", "https://" . $myhostname . "/cumaps/getcustatus.prg");
}
// $env['logger']->warning("myhostname " . $myhostname);
// $env['logger']->warning("getcustatus " . $getcustatusurl);
$HB_ENV = LoadSystemEnv("banking");
$db = $HB_ENV['db'];

$connect_to = sprintf('host=%s port=%d dbname=%s', $db['host'],
                      $db['port'], $db['dbname']);
if (!is_null($db['user'])) {
    $connect_to .= ' user=' . $db['user'];
}
if (!is_null($db['connect_timeout'])) {
    $connect_to .= ' connect_timeout=' . $db['connect_timeout'];
}
if (!is_null($db['password'])) {
    $connect_to .= ' password=' . $db['password'];
}
$r = pg_connect($connect_to);

if (!$r) {
    throw new Exception('DB connect error');
}
if (pg_connection_status($r) !== PGSQL_CONNECTION_OK) {
    throw new Exception('DB status error');
}
if (!pg_ping($r)) {
    throw new Exception('DB ping error');
}

//culist from cuinfo table
$result = pg_query($r, "select user_name, name, vendor, geo_lat, geo_long, dec_31_assets, dec_31_mem, www_server, system_options from cuinfo where ((system_options & 64) = 0)  order by user_name");

$res = array();   //gather the result that will be output
$fields = array( "name", "cuname", "vendor", "lat", "lng", "assets", "members", "www_server" );

while ($row = pg_fetch_row($result)) {
  $row[0] = trim($row[0]);
  $entry = array();
  $name = $row[0];     //data for each of the cu's
  for ($i=0; $i<count($fields); $i++){
    $entry[$fields[$i]] = trim($row[$i]);    //match the values to field names
  };
  $res[$name] = $entry;               //store the values for this cu
};

//get status data from each server
//results return in the form:
//  {
//    "cruisecu":{"livebatch":"L","offlinestat":""},
//    "scrubcu":{"livebatch":"B","offlinestat":"N"}
//  } 
foreach( array(
  array("www5", 'https://nobody:no1home@www5.homecu.net/hcuadm/getcustatus'),    
  array("www3", 'https://nobody:no1home@www3.homecu.net/hcuadm/getcustatus'), 
  array("www6", 'https://nobody:no1home@www6.homecu.net/hcuadm/getcustatus'),
  // array("www4", 'https://nobody:no1home@www4.homecu.net/hcuadm/getcustatus'),   //development
  $getcustatusvalues,
  ) as $locations){

  list($server, $url) = $locations;  
  //$resp = json_decode(file_get_contents($url),true);   //request status and decode json in to array
  $ch = curl_init();
  curl_setopt($ch, CURLOPT_URL, $url);
  curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); 
  $output = curl_exec($ch);
  $resp = json_decode($output, true);
  curl_close($ch);
  // $env['logger']->warning("getcustatus response " . json_encode($resp));

  foreach( $resp as $name => $values ){
    if ($env['devmode']) {
      $env['logger']->warning("cuname " . $name . " values " . json_encode($values));
    }
    if(HCU_array_key_exists($name, $res)){                //if there is an entry for this cu
      if( $res[$name]["www_server"] == $server){          //and the server name must match the "www_server" of the $res[$name]
        foreach( array("livebatch", "offlinestat") as $field ) {
          $res[$name][$field] = $values[$field];          //add the status values to the cu entry
        };
      };
    };
  };
};

header('Content-Type: application/json');
echo json_encode($res);               //output everything
   
/* sample output
{
  cruisecu: {
    name: "cruisecu",
    cuname: "Cruise DC Development",
    vendor: "CRUISE",
    lat: "",
    lng: "",
    assets: "0.0",
    members: "0",
    www_server: "stage.homecu.io",
    livebatch: "L",
    offlinestat: ""
  },
  scrubcu: {
    name: "scrubcu",
    cuname: "Scrubs Live",
    vendor: "CRUISE",
    lat: "",
    lng: "",
    assets: "1.0",
    members: "14",
    www_server: "stage.homecu.io",
    livebatch: "B",
    offlinestat: "N"
  }
}
*/

?>