<?php

require dirname(dirname(__FILE__)) . '/include/init.php';
require INC_ROOT . '/include/class.statsparser.php';
require INC_ROOT . '/include/class.useragent.php';
require INC_ROOT . '/include/class.searchengines.php';

if (in_array('--daemon', $_SERVER['argv']))
    define('DAEMON_MODE', true);
else
    define('DAEMON_MODE', false);

if (in_array('--debug', $_SERVER['argv']))
    define('DEBUG', true);
else
    define('DEBUG', false);

DB::startMultipleQueries();
$run = true;

while ($run)
{
    if (!file_exists(QUEUE_PATH . '/.current'))
    {
        if (DAEMON_MODE)
        {
            if(DEBUG) echo "No current queue, waiting...\n";
            sleep(30);
            continue;
        }
        else
        {
            if(DEBUG) echo "No current queue, exiting...\n";
            DB::endMultipleQueries();
            exit;
        }
    }

    $server_current = file_get_contents(QUEUE_PATH . '/.current');

    $files = scandir(QUEUE_PATH);

    foreach ($files as $file)
    {
        $file = trim($file);

        if ($file[0] == '.' || $file[0] == '_')
            continue;

        // Don't process the file currently being filled
        if ($server_current == $file)
            continue;

        if(DEBUG) echo "Processing $file...\n";

        // Rename so that another instance does not parse the file
        rename(QUEUE_PATH . '/' . $file, QUEUE_PATH . '/_' . $file);

        // Update current file so that we can find and delete old crashed
        // unprocessed files
        touch(QUEUE_PATH . '/_' . $file);

        $fp = fopen(QUEUE_PATH . '/_' . $file, 'r');

        while (!feof($fp))
        {
            // Parse file as csv
            $line = fgetcsv($fp, 4096, "\t", '"');
            if (empty($line))
                continue;

            $row = array(
                'site'      =>  $line[0],
                'marqueur'  =>  $line[1],
                'ip'        =>  $line[2],
                'ua'        =>  $line[3],
                'screen'    =>  $line[4],
                'plugins'   =>  $line[5],
                'langs'     =>  $line[6],
                'uri'       =>  $line[7],
                'page'      =>  $line[8],
                'referrer'  =>  $line[9],
                'loadTime'  =>  $line[10],
                'time'      =>  $line[11],
            );
            unset($line);

            // Add content to DB (all the magic goes there)
            StatsParser::add($row);
            if (DEBUG) print_r($row);
        }

        fclose($fp);
        unlink(QUEUE_PATH . '/_' . $file);
    }

    if (!DAEMON_MODE)
        $run = false;
    else
        sleep(2);
}

DB::endMultipleQueries();

?>