sportarchive / CloudProcessingEngine

client_example/ClientPoller.php

#!/usr/bin/php

<?php

/**
 * This is an example of a client application listening for SQS messages
 * The CPE stack sends output message back to the client using the "output" SQS queue
 * The application needs to listen to this output queue to get updates 
 * Using the CpeClientSdk you can easily listen to the SQS
 */

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

function poll_SQS_queues($CpeClientSdk, $decodedClient)
{
    try {
        // Will poll for 2 seconds
        if ($msg = $CpeClientSdk->receive_message($decodedClient, 10))
        {
            if (!($decoded = json_decode($msg['Body']))) {
                throw new Exception("JSON output data is invalid!");
            } else {
                handle_output($decoded);
            }
        }
    } catch (Exception $e) {
        print("[ERROR] " . $e->getMessage() . "\n");
    }
                    
    // Message polled. We delete it from SQS
    if (isset($msg) && $msg != "") {
        $CpeClientSdk->delete_message($decodedClient, $msg);
    }
}

function handle_output($output)
{
    global $debug;
    
    if ($debug) {
        print_r($output);
    }
}

/**
 * CLIENT POLLER START
 */

$debug  = false;
$region = getenv("AWS_DEFAULT_REGION");
$key    = getenv("AWS_ACCESS_KEY_ID");
$secret = getenv("AWS_SECRET_KEY");

function usage()

This function seems to be duplicated in your project.

The function usage() has been defined more than once; this definition is ignored, only the first definition in client_example/ClientCommander.php (L110-123) is considered.

{
    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");
    exit(0);
}

function check_input_parameters()

This function seems to be duplicated in your project.

The function check_input_parameters() has been defined more than once; this definition is ignored, only the first definition in client_example/ClientCommander.php (L63-108) is considered.

{
    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!\n");
    }
  
    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 !");
    }
}

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

// You must JSON decode it
$decodedClient = json_decode($clientInfo);

// Keep polling for output messages!
while (42) {
    poll_SQS_queues($CpeClientSdk, $decodedClient);
}