stats.php

<?php

$DEBUG = false;
date_default_timezone_set("Europe/Rome");

if (isset($argv[1]) && strtolower($argv[1]) == "debug") {
    $DEBUG = true;
}

$fileCompletePath = dirname(__FILE__) . '/config.json';
if (file_exists($fileCompletePath)) {
    $json = file_get_contents($fileCompletePath);
    $config = json_decode($json, true);
} else {
    die("no config.json file found in the root of this project, please provide ones writtens like this:"
            . "{
  \"dbConfig\": {
    \"servername\": \"<DB-HOST>\",
    \"username\": \"<DB-USERNAME>\",
    \"password\": \"<DB-PASSWORD>\",
    \"dbname\": \"<DB-TABLE-FOR-LISTNER>\"
  },
  \"scheduleUrl\":\"https://www.myradio.com/show-schedule-api\",
  \"radios\": {
    \"<RADIO-NUMBER-1>\": {
      \"url\": \"<WEBRADIO-SERVER-URL1>\",
      \"protocol\": \"shout\",
      \"isMyRadio\":true
    },
    \"<RADIO-NUMBER-2>\": {
      \"url\": \"<WEBRADIO-SERVER-URL2>\",
      \"protocol\": \"ice\",
      \"position\": 9
    },
    \"<RADIO-NUMBER-3>\": {
      \"url\": \"<WEBRADIO-SERVER-URL3>\",
      \"protocol\": \"ice\",
      \"position\": 2
    }
  }
}
protocol can be: shout, shout2, ice
for protocol ice, position is the ordinal number of the streaming, for multiple streaming mount point");
}

function getDom($url) {
    $curl = curl_init($url);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
    curl_setopt($curl, CURLOPT_CONNECTTIMEOUT, 0);
    curl_setopt($curl, CURLOPT_TIMEOUT, 5);
    curl_setopt($curl, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows; U; Windows NT 6.1; en-US) AppleWebKit/534.10 (KHTML, like Gecko) Chrome/8.0.552.224 Safari/534.10');
    $html = curl_exec($curl);
    curl_close($curl);

    $dom = new DOMDocument();
    if ($html != null && $html != "") {
        @$dom->loadHTML($html);
        $dom->preserveWhiteSpace = false;
    } else if ($GLOBALS['DEBUG']) {
        echo $url;
    }

    return $dom;
}

function getshoutcastlistner($dom) {
    $xpath = new DOMXPath($dom);
    $elements = $xpath->query("/html/body/table");
    if (isset($elements[2]) && isset($elements[2]->nodeValue)) {
        preg_match('/ with (.+?) of .+? listeners/', $elements[2]->nodeValue, $m);
        $res = $m[1];
    } else {
        $res = 0;
    }
    return $res;
}

function getshoutcast2listner($dom) {
    preg_match('/ with (.+?) of .+? listeners/', $dom->textContent, $m);
    return @$m[1];
}

function geticecastlistner($dom, $position) {
    $xpath = new DOMXPath($dom);
    $elements = $xpath->query("//td[@class='streamstats']");
    if (isset($elements[$position])) {
        $res = @$elements[$position]->nodeValue;
    } else {
        $res = 0;
    }
    return $res;
}

function getProgramIdFromObject($cacheFielObj) {
    $temp = explode(":", date("G:i"));
    $minuteFromMidnight = intval($temp[0]) * 60 + intval($temp[1]);
    $prevDiff = 1440;
    $r = null;
    foreach ($cacheFielObj as $key => $progId) {
        $currentDiff = $minuteFromMidnight - intval($key);
        if ($currentDiff >= 0 && $currentDiff < $prevDiff) {
            $r = $progId;
            $prevDiff = $currentDiff;
        }
    }
    return $r;
}

function getProgramId($url) {
    $cacheShowScheduleDayFile = __DIR__ . "/" . date("Ymd") . ".chc";
    if (!file_exists($cacheShowScheduleDayFile)) {
        $dayOfTheWeek=date("w");
        array_map('unlink', array_filter((array) glob(__DIR__ . "/" . "*.chc")));
        $json = file_get_contents($url);
        $resp = json_decode($json);
        $cacheFielObj = array();
        foreach ($resp as $show) {
            if ($show->day == $dayOfTheWeek) {
                $temp = explode(":", $show->start);
                $key = intval($temp[0]) * 60 + intval($temp[1]);
                $cacheFielObj[$key] = $show->program_id;
            }
        }
        ksort($cacheFielObj);
        $objData = serialize($cacheFielObj);
        $fp = fopen($cacheShowScheduleDayFile, "w");
        fwrite($fp, $objData);
        fclose($fp);
    } else {
        $objData = file_get_contents($cacheShowScheduleDayFile);
        $cacheFielObj = unserialize($objData);
    }
    $r = getProgramIdFromObject($cacheFielObj);
    return $r;
}

function insertListner($radioListner, $dbConfig) {
    try {
        $conn = new mysqli($dbConfig["servername"], $dbConfig["username"], $dbConfig["password"], $dbConfig["dbname"]);
    } catch (Exception $e) {
        $error = $e->getMessage();
        if ($GLOBALS['DEBUG']) {
            echo "mysqli error: " . $error;
        }
        die();
    }
    $date = date("Y-m-d H:i:s");
    $sql = "INSERT INTO `other_radio` (`date`, `listner`, `name`, `trasmission_id`) VALUES ";
    foreach ($radioListner as $radioName => $listner) {
        if ($listner['listner'] != null && $listner['listner'] != "" && is_numeric($listner['listner'])) {
            $number = $listner['listner'];
            $pId = @$listner['programId'];
            if (isset($pId)) {
                $sql .= "('$date', $number,'$radioName',$pId),";
            } else {
                $sql .= "('$date', $number,'$radioName',NULL),";
            }
        }
    }
    $sql = substr($sql, 0, -1);
    if (isset($conn)) {
        if ($conn->query($sql) !== TRUE && $GLOBALS['DEBUG']) {
            echo "Error executing query: " . $sql . "<br>" . $conn->error;
        }
        $conn->close();
    }
}

foreach ($config["radios"] as $radioName => $data) {
    $dom = getDom($data['url']);
    $listner = 0;
    if (is_object($dom) && $dom->textContent != "") {
        switch ($data['protocol']) {
            case "shout":
                $listner = getshoutcastlistner($dom);
                break;
            case "shout2":
                $listner = getshoutcast2listner($dom);
                break;
            case "ice":
                $listner = geticecastlistner($dom, $data['position']);
                break;
            default:
                die("protocol " . $data['protocol'] . " not supported");
                break;
        }
    }
    if (isset($data['isMyRadio']) && isset($config["scheduleUrl"]) && $data['isMyRadio']) {
        $progId = getProgramId($config["scheduleUrl"]);
        if ($progId != null) {
            $res[$radioName]['programId'] = $progId;
        }
    }
    $res[$radioName]['listner'] = $listner;
}
if ($GLOBALS['DEBUG']) {
    print_r($res);
}
insertListner($res, $config["dbConfig"]);