Function process_alerts

helpers/process_alerts.php:15–150

* Process Alerts * @param array integration_output */

( array $integration_output)

 * @param array integration_output
 */
function process_alerts( array $integration_output) {

    // Let's log our process for the CLI.
    update_scan_log("\n\n\n> Processing alerts...");
    $time_pre = microtime(true);

    // From the previous process, we should have
    // the following data that we'll use.
    $processed_urls = $integration_output[
        'processed_urls'
    ];
    $processed_sites = $integration_output[
        'processed_sites'
    ];

    // We don't know where helpers are being called, so 
    // we must set the directory if it isn't already set.
    if(!defined('__ROOT__'))
        define('__ROOT__', dirname(dirname(__FILE__)));

    // We'll use the directory to include required files.
    require_once(__ROOT__.'/config.php');
    require_once(__ROOT__.'/models/db.php');

    // Now let's get our existing alerts, filtered to the
    // pages we're interested in.
    $urls_to_filter = array();
    foreach ( $processed_urls as $url){
        array_push($urls_to_filter, array(
            'name'     => 'url',
            'value'    => $url,
            'condition'=> 'OR'
        ));
    };
    $existing_alert_filters = array(
        array(
            'name'  => 'archived',
            'value' => 0
        ),
        array(
            'name'  => 'url',
            'value' => $urls_to_filter
        )
    );
    $existing_alerts = DataAccess::get_db_rows(
        'alerts', $existing_alert_filters, 1, 1000000
    )['content'];
    if(empty($existing_alerts))
        $existing_alerts = array();

    // Let's find equalified alerts.
    $equalified_alerts =  DataAccess::get_joined_db(
        'equalified_alerts', $processed_sites
    );

    // Let's mark the status of these alerts "Equalified".
    if(!empty($equalified_alerts)){