sportarchive / CloudProcessingEngine

client_example/ClientCommander.php

#!/usr/bin/php

<?php

/**
 * This is an example of client application that send commands to the CPE stack
 * Your application initiate new workflows
 * Using the CpeClientSdk it's easy to send the proper SQS message to the CPE stack
 * You message will be read by the CPE Stack InputPoller process
 * The InputPoller will read your message and initiate the proper actions
 * Such as: Start a new workflow
 **/

require __DIR__ . "/vendor/autoload.php";

function start_job($args)
{
    global $CpeClientSdk;
    global $clientInfo;

    if (count($args) != 2)
    {
        print("[ERROR] Invalid args! Please provide a filename after the command! (try again if you used [tab] to find your file. It fails somehow.)\n");
        return;
    }
    if (!file_exists($args[1]))
    {
        print("[ERROR] The file provided doesn't exists!\n");
        return;
    }
    if (!($content = file_get_contents($args[1])))
    {
        print("[ERROR] Unable to read file '$args[1]'!\n");
        return;
    }
    
    try {
        print("[INFO] Starting a new job!\n");
        // You must JSON decode it
        $decodedClient = json_decode($clientInfo);
        
        $CpeClientSdk->start_job($decodedClient, $content);
    }
    catch (Exception $e) {
        print("[ERROR] " . $e->getMessage() . "\n");
    }
}


/**
 * CLIENT COMMANDER
 */

$help = <<<EOF
Use the following commands to send messages to the stack.

Commands:
start_job <filepath>: Start a new job. Pass a JSON file containing the instruction (see: input_samples folder)

EOF;

    
function check_input_parameters()

This function seems to be duplicated in your project.

{
    global $region;
    global $secret;
    global $key;
    global $debug;
    global $clientInfo;
    global $argv;
        
    // Handle input parameters
    if (!($options = getopt("c:k::s::r::hd")))
        usage();
    if (isset($options['h']))
        usage();
    
    if (isset($options['d']))
        $debug = true;
  
    if (isset($options['c']))
    {
        $clientConfFile = $options['c'];
        if (!file_exists($clientConfFile))
            throw new Exception("The client config file is not valid!");
        if (!($clientInfo = file_get_contents($clientConfFile)))
            throw new Exception("Unable to read the file");
    }
    else
        throw new Exception("Please provide the client config file!");

    if (isset($options['k']))
        $key = $options['k'];
    else
        $key = getenv("AWS_ACCESS_KEY_ID");
    
    if (isset($options['s']))
        $secret = $options['s'];
    else
        $secret = getenv("AWS_SECRET_KEY");

    if (isset($options['r']))
        $region = $options['r'];
    else 
        $region = getenv("AWS_DEFAULT_REGION");
    if (!$region)
        throw new Exception("Please provide your AWS region as parameter or using AWS_DEFAULT_REGION env var !");
}

    function usage()
    {
        global $help;
    
        echo("Usage: php ". basename(__FILE__) . " -c configFile [-h] [-k <key>] [-s <secret>] [-r <region>]\n");
        echo("-h: Print this help\n");
        echo("-d: Debug mode\n");
        echo("-c: configFile\n");
        echo("-k <AWS key>: Optional. Will use env variables by default\n");
        echo("-s <AWS secret>: Optional. Will use env variables by default\n");
        echo("-r <AWS region>: Optional. Will use env variables by default\n\n");
        echo($help);
        exit(0);
    }
    

try {
    check_input_parameters();
} 
catch (Exception $e) {
    print "[ERROR] " . $e->getMessage() . "\n";
    exit(2);
}

// Instanciate ComSDK to communicate with the stack
try {
    $CpeClientSdk = new SA\CpeClientSdk($key, $secret, $region, $debug);
} catch (Exception $e) {
    exit($e->getMessage());
  }

// Commands mapping
$commandMap = [
    "start_job" => "start_job",
];

// Look for input commands
print($help);
while (42)
{
    // Prompt (<3 php)
    $line = readline("Command [enter]: ");
    if (!$line)
        continue;
    readline_add_history($line);

    // Process user input
    $args = explode(" ", $line);
    if (!isset($commandMap[$args[0]]))
        print "[ERROR] Command not found!\n";
    else 
        $commandMap[$args[0]]($args);
}