Streamer.php

<?php

require_once dirname(__FILE__) . '/Configuration.php';

class Streamer extends ObjectYPT {

    protected $id, $siteURL, $user, $pass, $priority, $isAdmin, $created, $modified;

    static function getSearchFieldsNames() {
        return array('siteURL');
    }

    static function getTableName() {
        return 'streamers';
    }

    private static function get($user, $siteURL) {
        global $global;
        $sql = "SELECT * FROM  " . static::getTableName() . " WHERE user = '{$user}' AND lower(siteURL) = lower('{$siteURL}') LIMIT 1";
        //echo $sql;exit;
        $res = $global['mysqli']->query($sql);
        if ($res) {
            return $res->fetch_assoc();
        } else {
            die($sql . '\nError : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error);
        }
        return false;
    }

    private static function getFirst() {
        global $global;
        $sql = "SELECT * FROM  " . static::getTableName() . " LIMIT 1";

        $res = $global['mysqli']->query($sql);
        if ($res) {
            return $res->fetch_assoc();
        } else {
            die($sql . '\nError : (' . $global['mysqli']->errno . ') ' . $global['mysqli']->error);
        }
        return false;
    }

    static function getFirstURL() {
        $row = static::getFirst();
        return $row['siteURL'];
    }

    static function createIfNotExists($user, $pass, $siteURL, $encodedPass = false) {
        if (!$encodedPass || $encodedPass === 'false') {
            $pass = md5($pass);
        }
        if (substr($siteURL, -1) !== '/') {
            $siteURL .= "/";
        }
        if ($row = static::get($user, $siteURL)) {
            if (!empty($row['id'])) {
                return $row['id'];
            }
        }

        if (static::isURLAllowed($siteURL)) {
            $config = new Configuration();
            $s = new Streamer('');
            $s->setUser($user);
            $s->setPass($pass);
            $s->setSiteURL($siteURL);
            $s->setIsAdmin(0);
            $s->setPriority($config->getDefaultPriority());
            return $s->save();
        } else {
            return false;
        }
    }
    
    function verify(){
        $url = $this->getSiteURL();
        $cacheFile = "/tmp/".md5($url)."_verify.log";
        $lifetime = 3600;//1 hour
        error_log("Verification Start {$url}");
        $verifyURL = "";
        if(!file_exists($cacheFile) || (((time() - $lifetime) <= filemtime($cacheFile)))){
            error_log("Verification Creating the Cache {$url}");
            $verifyURL = "https://search.youphptube.com/verify.php?url=". urlencode($url);
            $result = url_get_contents($verifyURL);
            file_put_contents($cacheFile, $result);
        }else{
            error_log("Verification GetFrom Cache {$url}");
            $result = file_get_contents($cacheFile);
        }
        error_log("Verification Response ($verifyURL): {$result}");
        return json_decode($result);
    }

    static function isURLAllowed($siteURL) {
        if (substr($siteURL, -1) !== '/') {
            $siteURL .= "/";
        }
        $config = new Configuration();
        $urls = $config->getAllowedStreamersURL();
        if (empty($urls)) {
            return true;
        }
        $allowed = explode(PHP_EOL, $urls);
        $return = false;
        if (empty($allowed)) {
            $return = true;
        } else {
            foreach ($allowed as $value) {
                if (empty($value)) {
                    continue;
                }
                $value = trim($value);
                if (substr($value, -1) !== '/') {
                    $value .= "/";
                }
                //var_dump($siteURL,$value);
                error_log("$siteURL == $value");
                if ($siteURL == $value) {
                    $return = true;
                    break;
                }
            }
        }
        return $return;
    }

    function getId() {
        return $this->id;
    }

    function getSiteURL() {
        return $this->siteURL;
    }

    function getUser() {
        return $this->user;
    }

    function getPass() {
        return $this->pass;
    }

    function getCreated() {
        return $this->created;
    }

    function getModified() {
        return $this->modified;
    }

    function setId($id) {
        $this->id = $id;
    }

    function setSiteURL($siteURL) {
        if (!empty($siteURL) && substr($siteURL, -1) !== '/') {
            $siteURL .= "/";
        }
        $this->siteURL = $siteURL;
    }

    function setUser($user) {
        $this->user = $user;
    }

    function setPass($pass) {
        $this->pass = $pass;
    }

    function setCreated($created) {
        $this->created = $created;
    }

    function setModified($modified) {
        $this->modified = $modified;
    }

    function getPriority() {
        return $this->priority;
    }

    function setPriority($priority) {
        $this->priority = $priority;
    }

    function getIsAdmin() {
        return $this->isAdmin;
    }

    function setIsAdmin($isAdmin) {
        $this->isAdmin = $isAdmin;
    }

}