TrustedReport.proxy.data

<?php
/* File: TrustedReport.proxy
 * Purpose: aggregates data from TrustedReport.data calls so that all the servers show up in the report.
 */

header('Content-Type: application/json');

$monLibrary= dirname(__FILE__) . "/../library";
$sharedLibrary= dirname(__FILE__) . "/../../shared/library";
require_once("$monLibrary/cu_top.i");
require_once("$monLibrary/ck_hticket.i");
require_once("$sharedLibrary/cutrusted.i");

  if (!CheckPerm($link, $Hu, basename($_SERVER['SCRIPT_NAME']), $_SERVER['REMOTE_ADDR'])) {
    // ** Permissions failed
    // ** redirect to new page
    header("Location: /hcuadm/hcu_noperm.prg");
    exit;
  }

$dbh= $link;
$dms_ok = array('action'=>'string', 'trustid'=>'string', 'cu'=>'string');

dms_import($dms_ok);

switch($action)
{
    case "read_master":
        readMaster($dbh);
    break;
  case "read_masterDef":
    readMasterDetails($dbh, $trustid);
    break;
    case "read_clients":
        clientAggregation($trustid);
    break;
  case "export_clients":
        exportClients($dbh, $trustid);
        break;
    default:
    print json_encode(array("homecuErrors" => array("Unexpected action: {$action}")));
}

/* Function copied from TrustedReport.data.
 * The difference is it is always getting from monitor.
 */
function readMaster($dbh) {
    if (strpos($_SERVER["SERVER_NAME"], "www4") !== false) // Will need to get from monitor
    {
      print runCurl("www", array("action" => "read_master"), true);
      return;
    }

    $parms = array();
    $return = cutm_list($dbh, $parms);

    $aryResult = array();
    if (is_array($return['data'])) {
        foreach ($return['data'] as $key => $val) {
            $thisprop = array();
            if (is_array($val['fields'])) {
                foreach ($val['fields'] as $vk => $vv) {
                    if (is_array($vv)) {
                        $thisprop[] = array('vname' => $vk, 'vtype' => $vv['Type'], 'vdefault' => $vv['Default']);
                    }
                }
            }
            $thisun = array(
                'trustedid' => $val['trustedid'],
                'trustedvendor' => $val['trustedvendor'],
                'trustedtype' => $val['trustedtype'],
                'trustedprops' => array_values($thisprop));
            $return['data'][$key] = $thisun;
        }
    }
    $aryResult=(is_array($return['data']) ? array_values($return['data']) : '[]');

  if ($aryResult == '[]') {
    $aryReply["homecuData"]=null;
    $aryReply["homecuCount"] = 0;
  } else {
    $aryReply["homecuData"] = $aryResult;
    $aryReply["homecuCount"] = count($aryResult);
  }

  print json_encode($aryReply);
}

/* This function queries the cuinfo table to see what servers it needs to pull from and calls the TrustedReport.data file from each server.
 * PARAMETERS: trustedid-- the trustedId to pull data for.
 */
function clientAggregation($trustid, $sendas = 'JSON') {

      global $link, $SYS_TYPE_WEBONLY, $SYS_TYPE_CLOSED;
      $errors= array();
    $serversUsed= array();
      $cuServerLookup= array();

    $sql= "select lower(user_name) as cu, www_server from cuinfo where system_options & $SYS_TYPE_WEBONLY = 0 and system_options & $SYS_TYPE_CLOSED = 0";
    $sth = db_query($sql,$link);

    $i = 0;

    while($dRecord = db_fetch_assoc($sth, $i++))
    {
      $cu= trim($dRecord["cu"]);
      $server= trim($dRecord["www_server"]);
      $cuServerLookup[$cu] = $server;

      if ($server != "" ) {
        $serversUsed[$server]= true;
      }
    }
    db_free_result($sth);

    $dataArray= array();
    $parameters= array("action" => "read_clients", "trustid" => $trustid);
    $data= array();
    foreach ($serversUsed as $server => $unused)
    {
      $dataArray[$server]= json_decode(runCurl($server, $parameters), true);
    }

    foreach($dataArray as $server => $serverResults)
    {
        if (is_array($serverResults["homecuData"]))
        {
            foreach($serverResults["homecuData"] as $record)
            {
          $cu = strtolower(trim($record["cu"]));
          $correctServer= HCU_array_key_value($cu, $cuServerLookup);
                if (isset($correctServer) && $correctServer == $server) // Checks to see the data is in the right server for the CU.
                {
                    $record["server"]= $server;
                    $data[]= $record;
                }
            }

            if (HCU_array_key_exists("homecuErrors", $serverResults) && is_array($serverResults["homecuErrors"])) {
                $errors= array_merge($errors, $serverResults["homecuErrors"]);
        }
        }
        else
            $errors[] = "$server did not get appropriate results.";
    }

    if ($sendas == 'JSON') {
      print json_encode(array("homecuCount" => count($data), "homecuData" => $data, "homecuErrors" => $errors));
    } else {
      return (array("homecuCount" => count($data), "homecuData" => $data, "homecuErrors" => $errors));
    }
}

/* Calls TrustedReport.data or TrustedReport.proxy for data.
 * PARAMETERS:  $server-- server to call i.e. www4,
 *              $parameters-- array of parameters for the particular call
 *              $useProxy-- if true, calls TrustedReport.proxy, if false calls TrustedReport.data.
 */
function runCurl($server, $parameters, $useProxy = false) {

  $cmd = "";
  $curlcookies = "HCUTicket={$_COOKIE['HCUTicket']}";
  $mammothServers = array('www3','www4','www5','www6','www');
  if (in_array($server, $mammothServers)) {
    $cmd = "https://${server}.homecu.net/hcuadm/TrustedReport." . ($useProxy ? "proxy.data" : "data");
  } else {

    if ($server == "localhost") {
      $cmd = "http://${server}/hcuadm/TrustedReport." . ($useProxy ? "proxy.data" : "data");
    } else {
      $cmd = "https://${server}/hcuadm/TrustedReport." . ($useProxy ? "proxy.data" : "data");
      $curlcookies .= ";homecu_dev_oauth2_proxy={$_COOKIE['homecu_dev_oauth2_proxy']}";
    }
  }

  $ch=curl_init($cmd);

  curl_setopt($ch,CURLOPT_COOKIE, $curlcookies);
  curl_setopt($ch,CURLOPT_USERPWD,"nobody:no1home");
  curl_setopt($ch,CURLOPT_RETURNTRANSFER,1); # get response as string
  curl_setopt($ch,CURLOPT_POST, true);
  curl_setopt($ch,CURLOPT_POSTFIELDS, $parameters);

  $rawresp=curl_exec($ch);

  return $rawresp;
}

function exportClients($dbh, $trustid) {

  $fields = array(
      'trustid' => $trustid,
      'cu' => ''
    );

    //getting the master list of trusted details for a given vendor
    $masterList = readMasterDetails( $dbh, $trustid, 'noJSON' );

    //create new array of master trusted details for the vendor
    $masterElem = array();

    if( HCU_array_key_exists( 'trustedfields', $masterList['homecuData'] ) ) {
        $masterElem = array_keys( $masterList['homecuData']['trustedfields'] );
      }

    //getting list of clients and their trusted details for a specific vendor
    $clientList = clientAggregation($trustid, 'noJSON');

     if (!count($clientList['homecuData']) ) {
      //error occured, no records to report
      $errorList = $clientList['homecuErrors'];

      //creating the csv file to export
      $fileName = 'Errors.csv';
      ob_clean();
      header('Pragma: public');
      header('Expires: 0');
      header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
      header('Cache-Control: private', false);
      header('Content-Type: text/csv');
      header('Content-Disposition: attachment;filename=' . $fileName);

      if (isset( $errorList ) ) {
        $fp = fopen('php://output', 'w');
        fputcsv($fp, $errorList);
      }
      ob_flush();

    } else {

    //create new array for csv client data
    $outputElem = array();
    // put into a consistent structure
    $output = array();

    if ( isset( $clientList['homecuData'] ) ) {
      $clientDetails = $clientList['homecuData'];

        foreach ( $clientDetails as $innerArray ) {
          $outputElem['trustedid'] = $innerArray['trustedid'];
          $outputElem['cu'] = $innerArray['cu'];
          $outputElem['server'] = $innerArray['server'];
          if ( HCU_array_key_exists( 'trustedprops', $innerArray ) ) {
            $clientFields = array();
            foreach ($innerArray['trustedprops'] as $prop) {
                $clientFields[$prop['propname']] = $prop['propval'];
            }
            foreach ( $masterElem as $melem => $mpropname ) {
              //if property exist for client
              if ( HCU_array_key_exists ( $mpropname, $clientFields ) ) {
                $outputElem[$mpropname] = $clientFields[$mpropname];
              } else {
                $outputElem[$mpropname] = "";
              }
            }
          }
          $output[] = $outputElem;
        }
    }

    //creating the csv file to export
    $fileName = 'Export.csv';
    ob_clean();
    header('Pragma: public');
    header('Expires: 0');
    header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
    header('Cache-Control: private', false);
    header('Content-Type: text/csv');
    header('Content-Disposition: attachment;filename=' . $fileName);

    if(isset($output['0'])){
      $fp = fopen('php://output', 'w');
      fputcsv($fp, array_keys($output['0']));
      foreach($output as $values){
          fputcsv($fp, $values);
      }
    }
    ob_flush();
    }

}

/* This function will return the master list of trusted details
 * for a given vendor. This is used for the trusted detail export,
 * so it is not needed in JSON format.
 * PARAMETERS: dbh - database handle, parms - must contain the
 *  vendor to pull data for, CU is optional
 * RETURNS: master detail array - NOT in JSON format
 */
function readMasterDetails( $dbh, $trustid, $sendas='JSON' ) {
  if ( strpos( $_SERVER["SERVER_NAME"], "www4") !== false ) {
    // Master list for www4 comes from monitor server www instead
    // because www4 has a lot of testing garbage.
    // So get this from monitor server as well, to be consistent
    $response = json_decode(runCurl( "www", array("action" => "read_masterDef", "trustid" => $trustid), true), true);
    return $response;
  }

  $parms = array();
  $parms['trustedid'] = $trustid;

  $return = cutm_read( $dbh, $parms );
  $aryResult = array();

  $aryResult = ( isset( $return['data'] ) ? ( $return['data'] ) : '[]' );

  if ( $aryResult == '[]' ) {
    $aryReply["homecuData"]=null;
    $aryReply["homecuCount"] = 0;
  } else {
    $aryReply["homecuData"] = $aryResult;
    $aryReply["homecuCount"] = count($aryResult);
  }

  if ($sendas == 'JSON') {
    print json_encode($aryReply);
  } else {
    return $aryReply;
  }

}