sintonia/airtime_mvc/build/airtime-setup/load.php

<?php

define("RMQ_INI_SECTION", "rabbitmq");
require_once dirname(dirname( __DIR__)) . '/library/php-amqplib/amqp.inc';

function booleanReduce($a, $b) {
    return $a && $b;
}

/**
 * Check to see if Airtime is properly configured.
 *
 * @return boolean true if all Airtime dependencies and services are
 *                 properly configured and running
 */
function checkConfiguration() {
    $r1 = array_reduce(checkPhpDependencies(), "booleanReduce", true);
    $r2 = array_reduce(checkExternalServices(), "booleanReduce", true);
    return $r1 && $r2;
}

/**
 * Check for Airtime's PHP dependencies and return an associative
 * array with the results
 *
 * @return array associative array of dependency check results
 */
function checkPhpDependencies() {
    return array(
        "zend" => checkZendDependencies(),
        "postgres" => checkDatabaseDependencies()
    );
}

/**
 * Check that the Zend framework libraries are installed
 *
 * @return boolean true if Zend exists in /usr/share/php
 */
function checkZendDependencies() {
    return file_exists('/usr/share/php/libzend-framework-php')
        || file_exists('/usr/share/php/zendframework'); // Debian version
}

/**
 * Check that the PHP dependencies for the database exist
 *
 * @return boolean true if the database dependencies exist
 */
function checkDatabaseDependencies() {
    global $extensions;
    // Check the PHP extension list for the Postgres db extensions
    return (in_array('pdo_pgsql', $extensions)
        && in_array('pgsql', $extensions));
}

/**
 * Check that all external services are configured correctly and return an associative
 * array with the results
 * 
 * @return array associative array of external service check results
 */
function checkExternalServices() {
    return array(
            "database" => checkDatabaseConfiguration(),
            "media-monitor" => checkMediaMonitorService(),
            "pypo" => checkPlayoutService(),
            "liquidsoap" => checkLiquidsoapService(),
            "rabbitmq" => checkRMQConnection()
    );
}

/**
 * Check the database configuration by fetching a connection from Propel
 *
 * @return boolean true if a connection is made to the database
 */
function checkDatabaseConfiguration() {
    configureDatabase();

    try {
        // Try to establish a database connection. If something goes
        // wrong, the database is improperly configured
        Propel::getConnection();
        Propel::close();
    } catch (Exception $e) {
        return false;
    }

    return true;
}

/**
 * Initialize Propel to configure the Airtime database
 */
function configureDatabase() {
    Propel::init(CONFIG_PATH . 'airtime-conf-production.php');
}

/**
 * Check that we can connect to RabbitMQ
 * 
 * @return true if the RabbitMQ connection can be established
 */
function checkRMQConnection() {
    // Check for airtime.conf in /etc/airtime/ first, then check in the build directory,
    if (file_exists(AIRTIME_CONFIG_STOR . AIRTIME_CONFIG)) {
        $ini = parse_ini_file(AIRTIME_CONFIG_STOR . AIRTIME_CONFIG, true);
    } else {
        $ini = parse_ini_file(BUILD_PATH . "airtime.example.conf", true);
    }

    $conn = new AMQPConnection($ini[RMQ_INI_SECTION]["host"],
                               $ini[RMQ_INI_SECTION]["port"],
                               $ini[RMQ_INI_SECTION]["user"],
                               $ini[RMQ_INI_SECTION]["password"],
                               $ini[RMQ_INI_SECTION]["vhost"]);
    return isset($conn);
}

/**
 * Check if airtime-media-monitor is currently running
 * 
 * @return boolean true if airtime-media-monitor is running
 */
function checkMediaMonitorService() {
    exec("pgrep -fx 'python /usr/lib/airtime/media-monitor/media_monitor.py'", $out, $status);
    return $status == 0;
}

/**
 * Check if airtime-playout is currently running
 * 
 * @return boolean true if airtime-playout is running
 */
function checkPlayoutService() {
    exec("pgrep -fx 'python /usr/lib/airtime/pypo/bin/pypocli.py'", $out, $status);
    return $status == 0;
}

/**
 * Check if airtime-liquidsoap is currently running
 * 
 * @return boolean true if airtime-liquidsoap is running
 */
function checkLiquidsoapService() {
    exec("pgrep -fx '/usr/bin/airtime-liquidsoap --verbose -f /usr/lib/airtime/pypo/bin/liquidsoap_scripts/ls_script.liq'", $out, $status);
    return $status == 0;
}