source: genapp/languages/html5/sys/sys_jobmonitor.php @ 487

#!/usr/local/bin/php
<?php

$_REQUEST = json_decode( $argv[ 1 ], true );

__~debug:filemanager{error_log( print_r( $_REQUEST, true ) , 3, "/tmp/mylog" );}

$results = [];

if ( !sizeof( $_REQUEST ) ) {
    $results[ 'error' ] = "PHP code received no \$_REQUEST?";
    echo (json_encode($results));
    exit();
}

if ( !isset( $_REQUEST[ '_uuid' ] ) ) {
    $results[ "error" ] = "No _uuid specified in the request";
    echo (json_encode($results));
    exit();
}

if ( !isset( $_REQUEST[ '_logon' ] ) ) {
    $results[ "error" ] = "No _logon specified in the request";
    echo (json_encode($results));
    exit();
}

if ( !isset( $_REQUEST[ 'interval' ] ) ) {
    $results[ "error" ] = "Insufficient request data";
    echo (json_encode($results));
    exit();
}

$appconfig = json_decode( file_get_contents( "__appconfig__" ) );

if ( !isset( $appconfig->messaging->zmqhostip ) ||
     !isset( $appconfig->messaging->zmqport )   || 
     !isset( $appconfig->admin ) ) {
    $results[ "error" ] = "appconfig.json missing zmq or admin info";
    echo (json_encode($results));
    exit();
}    

if ( !in_array( $_REQUEST[ '_logon' ], $appconfig->admin ) ) {
    $results[ "error" ] = "not an administrator";
    echo (json_encode($results));
    exit();
}    

date_default_timezone_set("UTC");

$context = new ZMQContext();
$zmq_socket = $context->getSocket(ZMQ::SOCKET_PUSH, '__application__ udp pusher');
$zmq_socket->connect("tcp://" . $appconfig->messaging->zmqhostip . ":" . $appconfig->messaging->zmqport );

function db_connect( $error_json_exit = false ) {
   global $use_db;
   global $db_errors;

   if ( !isset( $use_db ) ) {
      try {
         $use_db = new MongoClient();
      } catch ( Exception $e ) {
         $db_errors = "Could not connect to the db " . $e->getMessage();
         if ( $error_json_exit )
         {
            $results = array( "error" => $db_errors );
            $results[ '_status' ] = 'complete';
            echo (json_encode($results));
            exit();
         }
         return false;
      }
   }

   return true;
}

// get_runinfo populates runinfo array with job info
// to get more data => add it to the runinfo

function get_runinfo( $error_json_exit = false ) {
   global $use_db;
   global $db_errors;
   global $appconfig;
   global $runinfo;

   $runinfo = [];

   if ( !db_connect( $error_json_exit ) )
   {
       return false;
   }

   $runs = $use_db->__application__->running->find();

   foreach ( $runs as $v ) {
       $uuid = $v['_id'];
       $job = $use_db->__application__->jobs->findOne( array( "_id" => $uuid ) );
       $pids = $v['pid'];

       $resources = [];

       foreach ( $pids as $k2 => $v2 ) {
           $resources[ $v2['where'] ] = true;
           // later get pid info
           // echo "   where: " . $v2['where'] . " pid: " . $v2['pid'] . " what: " . $v2['what'] . "\n";
           // $cmd = $appconfig->resources->{ $v2['where'] } . " ps --ppid " . $v2['pid'];
           // echo " cmd $cmd\n";
       }

       $runinfo[] = 
           array( 
               "module"    => $job[ 'module' ]
               ,"user"      => $job[ 'user' ]
#               "pids"      => $v  [ 'pid' ]
               ,"started"   => date( "Y M d H:i:s T",$job["start"]->sec )
               ,"resources" => implode( ",", array_keys( $resources ) )
               ,"id"        => $uuid
           );
   }
   return true;
}

function get_html_runinfo( $error_json_exit = false ) {
    global $runinfo;
    global $html_runinfo;

    $html_runinfo = "No jobs running";
    
    if ( !get_runinfo( $error_json_exit ) ) {
        return false;
    }

    if ( !count( $runinfo ) ) {
        return true;
    }
    
    $html_runinfo = "<table><tr><th>" . implode( "</th><th>", array_keys( $runinfo[ 0 ] ) ) . "</th></tr>";

    foreach ( $runinfo as $k => $v ) {
        $html_runinfo .= "<tr><td>" . implode( "</td><td>",  $v ) . "</td></tr>";
    }        

    $html_runinfo .= "</table>";
}

$results = [];
$results[ '_uuid' ] = $_REQUEST[ '_uuid' ];

// run until cancelled
do {
    get_html_runinfo( true );

    $results[ "monitordata" ] = "<p>Last refreshed " . date( "Y M d H:i:s T", time() ) . "</p>" .  $html_runinfo;

    $zmq_socket->send( json_encode( $results ) );
    sleep( $_REQUEST[ 'interval' ] );
} while(1);

?>