vantages_report.html

<?php
require_once 'php/vendor/autoload.php';
require_once 'php/login.php';

//parse command line parameters
if (isset($_GET['duration'])) $duration=$_GET['duration'];
else $duration=1;

$timestamp = time() - ($duration * 24 * 60 * 60);

//open driver manager and geoip reader
$manager = new MongoDB\Driver\Manager(
    $mongodbConnectionString,
    [
        'ssl' => TRUE,
        'username' => $mongodbUsername,
        'password' => $mongodbPassword,
        'authSource' => $mongodbAuthSource
    ],
    [
        'ca_file' => $mongodbSslCaCert,
        'pem_file' => $mongodbSslPem
    ]
);
$reader = new GeoIp2\Database\Reader('/usr/local/share/GeoLite2/GeoLite2-City.mmdb');

//query for distinct vantages
$cursor = $manager->executeCommand(
    'proddle',
    new MongoDB\Driver\Command(
        [
            'aggregate' => 'measurements',
            'pipeline' => [
                ['$match' => ['timestamp' => ['$gte' => $timestamp]]],
                [
                    '$group' => [
                        '_id' => [
                            'vantage_hostname' => '$vantage_hostname',
                            'vantage_ip_address' => '$vantage_ip_address',
                            'measurement_class' => '$measurement_class'
                        ],
                        'count' => ['$sum' => 1]
                    ]
                ],
                ['$sort' => ['vantage_hostname' => 1, 'vantage_ip_address' => 1, 'measurement_class' => 1]]
            ]
        ]
    )
);

//geolocate vantage
$array = $cursor->toArray()[0];
$coordinates = [];
for ($i=0; $i < count($array->result); ++$i) {
    $result = $array->result[$i];
    $coordinate = (object) array();

    if (isset($result->_id->vantage_ip_address)) {
        $coordinate->vantage = (object) array();
        $record = $reader->city($result->_id->vantage_ip_address);
        $coordinate->vantage->latitude = $record->location->latitude;
        $coordinate->vantage->longitude = $record->location->longitude;
    }

    $coordinates[$i] = $coordinate;
}

$array->coordinates = $coordinates;

echo MongoDB\BSON\toJSON(MongoDB\BSON\fromPHP($array));

/*$array = $cursor->toArray()[0]->result;
for ($i=0; $i < count($array); ++$i) {
    $vantage = $array[$i];

    echo ($i != 0 ? ',' : '') . '{';
    echo '"hostname":"' . $vantage->_id->hostname . '"';
    echo ',"ip_address":"' . $vantage->_id->ip_address . '"';

    //geolocate ip address
    $record = $reader->city($vantage->_id->ip_address);
    echo ',"latitude":' . $record->location->latitude . ',"longitude":' . $record->location->longitude;

    echo ',"measurement":"' . $vantage->_id->measurement . '"';
    echo ',"count":' . $vantage->count;
    echo '}';
}

echo ']}';*/
?>