<?php

class Server
{
    protected $server_id = 0;
    protected static $table_name = 'server';
    protected static $cache_expiration = 120;
    public $loaded = false;
    
    protected $mountpoint_id;
    protected $sid;
    protected $current_song;
    protected $listen_url;
    protected $listeners;
    protected $last_touched_at;
    protected $last_touched_from;
    protected $checked;
    
    public function __construct($server_id, $force_reload = false, $no_load = false)
    {
        if (!is_numeric($server_id) || $server_id < 0)
        {
            throw new BadIdException($mountpoint_id);
        }
        $this->server_id = intval($server_id);
        
        if (!$no_load)
        {
            if ($force_reload)
            {
                $this->loadFromDb();
            }
            else
            {
                if (!$this->loadFromCache())
                {
                    $this->loadFromDb();
                }
            }
        }
    }
    
    /**
     * Saves the server data both into the database and into the cache.
     * 
     * @return boolean
     */
    public function save()
    {
        $mp_id = $this->saveIntoDb();
        $this->saveIntoCache();
        
        return $mp_id;
    }
    
    /**
     * Retrieves the server from either the db or the cache.
     * 
     * @return Server or false if an error occured.
     */
    public static function retrieveByPk($pk, $force_reload = false)
    {
        $s = new Server($pk, $force_reload);
        
        return ($s->loaded ? $s : false);
    }
    
    /**
     * Retrieves the server from the db.
     * 
     * @return Server or false if an error occured.
     */
    public static function retrieveBySID($sid, $force_reload = false)
    {
        // MySQL Connection
		$db = DirXiphOrgDBC::getInstance();
		
		try
		{
		    $sql = "SELECT `id` FROM `%s` WHERE `sid` = '%s';";
		    $sql = sprintf($sql, self::$table_name, mysql_real_escape_string($sid));
		    $res = $db->singleQuery($sql);
	    }
	    catch (SQLNoResultException $e)
		{
		    return false;
		}
		
		return self::retrieveByPk(intval($res->current('id')), $force_reload);
    }
    
    /**
     * Retrieves the server from the db.
     * 
     * @return Server or false if an error occured.
     */
    public static function retrieveByListenUrl($url)
    {
        // MySQL Connection
		$db = DirXiphOrgDBC::getInstance();
		
		try
		{
		    $sql = "SELECT `id` FROM `%s` WHERE `listen_url` = '%s';";
		    $sql = sprintf($sql, self::$table_name, mysql_real_escape_string($url));
		    $res = $db->singleQuery($sql);
	    }
	    catch (SQLNoResultException $e)
		{
		    return false;
		}
		
		return self::retrieveByPk(intval($res->current('id')));
    }
    
    /**
     * Retrieves servers by mountpoint_id.
     * 
     * @param int $mp_id
     * @param bool $load_servers If set to true, will return only a list of IDs.
     * @return array
     */
    public static function retrieveByMountpointId($mp_id, $load_servers = true)
    {
        // MySQL Connection
        $db = DirXiphOrgDBC::getInstance();

        // Memcache connection
        $mc = DirXiphOrgMCC::getInstance();

        // Try to get from cache
        $key = self::getListCacheKey('serversbympid_'.$mp_id);
        $servers = $mc->get($key);
        if (!$servers)
        {
            // Cache miss, hit the database
            try
            {
                $sql = "SELECT `id` FROM `%s` WHERE `mountpoint_id` = %d;";
                $sql = sprintf($sql, self::$table_name, $mp_id);
                $res = $db->selectQuery($sql);

                $servers = array();
                while (!$res->endOf())
                {
                    $servers[] = intval($res->current('id'));
                    $res->next();
                }

               // Save into cache
                $mc->set($key, $servers, false, self::$cache_expiration);
            }
            catch (SQLNoResultException $e)
            {
                return false;
            }
        }

        // If we've been asked to load the servers data, do it
        $data = array();
        if ($load_servers)
        {
            foreach ($servers as $s)
            {
                $server = self::retrieveByPk($s);
                if ($server instanceOf Server)
                $data[] = $server;
            }
        }
        else
        {
            $data =& $servers;
        }

        return $data;
    }
    
    /**
     * Deletes the server from both the database and the cache.
     * 
     * @return bool
     */
    public function remove()
    {
        $res0 = $this->removeFromDb();
        $this->removeFromCache();
        
        return $res0;
    }
    
    /**
     * Saves the server into the database.
     * 
     * @return integer
     */
    protected function saveIntoDb()
    {
        // MySQL Connection
		$db = DirXiphOrgDBC::getInstance();
		
		// Query
		$query = '';
		if ($this->server_id == 0)
		{
            $query = 'INSERT INTO `%1$s` (`mountpoint_id`, `sid`, '
                    .'`current_song`, `listen_url`, `listeners`, '
                    .'`last_touched_at`, `last_touched_from`, `last_touched_ua`, `checked`) '
	    		    .'VALUES (%2$d, "%3$s", %4$s, "%5$s", %6$d, %7$s, '
	    		    .'INET_ATON("%8$s"), "%9$s", %10$d);';
	    }
	    else
	    {
    		$query = 'UPDATE `%1$s` SET `mountpoint_id` = %2$d, `sid` = "%3$s", '
    		        .'`current_song` = %4$s, `listen_url` = "%5$s", '
    		        .'`listeners` = %6$d, `last_touched_at` = %7$s, '
    		        .'`last_touched_from` = INET_ATON("%8$s"), `last_touched_ua` = "%9$s", '
    		        .'`checked` = %10$d WHERE `id` = %11$d;';
        }
	    $query = sprintf($query, self::$table_name,
	                             $this->mountpoint_id,
							     mysql_real_escape_string($this->sid),
							     ($this->current_song != null) ? '"'.mysql_real_escape_string($this->current_song).'"' : 'NULL',
							     mysql_real_escape_string($this->listen_url),
							     ($this->listeners != null) ? $this->listeners : 0,
							     ($this->last_touched_at != null) ? '"'.mysql_real_escape_string($this->last_touched_at).'"' : 'NOW()',
							     mysql_real_escape_string($this->last_touched_from),
							     mysql_real_escape_string($this->last_touched_ua),
							     ($this->checked != null) ? $this->checked : 0,
							     intval($this->server_id));
	    
		if ($this->server_id == 0)
		{
	        $server_id = $db->insertQuery($query);
	        if ($server_id !== false)
	        {
	            $this->server_id = $server_id;
	        }
        }
        else
        {
            $server_id = $db->noReturnQuery($query);
        }
	    
	    return $server_id;
    }
    
    /**
     * Loads the data from the database.
     * 
     * @return boolean
     */
    protected function loadFromDb()
    {
        // MySQL Connection
		$db = DirXiphOrgDBC::getInstance();
		
		// Query
		try
		{
            $query = "SELECT `mountpoint_id`, `sid`, `current_song`, `listen_url`, `listeners`, `last_touched_at`, INET_NTOA(`last_touched_from`) AS `last_touched_from`, `checked` FROM `%s` WHERE `id` = %d;";
            $query = sprintf($query, self::$table_name, $this->server_id);
            $m = $db->singleQuery($query);
            
            $this->loadFromArray($m->array_data[0]);
            
            return true;
        }
        catch (SQLNoResultException $e)
        {
            return false;
        }
    }
    
    /**
     * Remove the data from the database.
     * 
     * @return boolean
     */
    protected function removeFromDb()
    {
        // MySQL Connection
		$db = DirXiphOrgDBC::getInstance();
		
		// Query
        $query = 'DELETE FROM `%s` WHERE `id` = %d;';
	    $query = sprintf($query, self::$table_name,
	                             $this->server_id);
	    $res = $db->noReturnQuery($query);
	    
	    return (bool) $res;
    }
    
    /**
     * Saves the data into the cache.
     * 
     * @return boolean
     */
    protected function saveIntoCache()
    {
        // Memcache connection
        $cache = DirXiphOrgMCC::getInstance();
        
        $a = $this->__toArray();
        
        return $cache->set($this->getCacheKey(), $a, false, self::$cache_expiration);
    }
    
    /**
     * Loads the data from the cache.
     * 
     * @return boolean
     */
    protected function loadFromCache()
    {
        // Memcache connection
        $cache = DirXiphOrgMCC::getInstance();
        
        $a = $cache->get($this->getCacheKey());
        if ($a === false)
        {
            return false;
        }
        
        return $this->loadFromArray($a);
    }
    
    /**
     * Remove the data from the cache.
     * 
     * @return boolean.
     */
    protected function removeFromCache()
    {
        // Memcache connection
        $cache = DirXiphOrgMCC::getInstance();
        
        $a = $cache->delete($this->getCacheKey());
        return ($a === true);
    }
    
    /**
     * Builds a cache key for this server.
     * 
     * @return string
     */
    protected function getCacheKey()
    {
        if (!defined('ENVIRONMENT'))
        {
            throw new EnvironmentUndefinedException();
        }
        
        return sprintf("%s_server_%d", ENVIRONMENT, $this->server_id);
    }
    
    /**
     * Builds a cache key for a list of servers.
     * 
     * @return string
     */
    protected static function getListCacheKey($list_id)
    {
        if (!defined('ENVIRONMENT'))
        {
            throw new EnvironmentUndefinedException();
        }
        
        return sprintf("%s_serverlist_%s", ENVIRONMENT, jenkins_hash_hex($list_id));
    }
    
    /**
     * Serializes the data into an array
     * 
     * @return array
     */
    protected function saveIntoArray()
    {
        return $this->__toArray();
    }
    
    /**
     * Loads the data from an array.
     * 
     * @return boolean
     */
    protected function loadFromArray($a)
    {
        $this->mountpoint_id = $a['mountpoint_id'];
        $this->sid = $a['sid'];
        $this->current_song = $a['current_song'];
        $this->listen_url = $a['listen_url'];
        $this->listeners = intval($a['listeners']);
        $this->last_touched_at = $a['last_touched_at'];
        $this->last_touched_from = $a['last_touched_from'];
        $this->last_touched_ua = $a['last_touched_ua'];
        $this->checked = $a['checked'];
        
        $this->loaded = true;
        
        return true;
    }
    
    /**
     * Packs the object contents into an array.
     * 
     * @return array
     */
    protected function __toArray()
    {
        $a = array();
        
        $a['mountpoint_id'] = $this->mountpoint_id;
        $a['sid'] = $this->sid;
        $a['current_song'] = $this->current_song;
        $a['listen_url'] = $this->listen_url;
        $a['listeners'] = intval($this->listeners);
        $a['last_touched_at'] = $this->last_touched_at;
        $a['last_touched_from'] = $this->last_touched_from;
        $a['last_touched_ua'] = $this->last_touched_ua;
        $a['checked'] = $this->checked;
        
        return $a;
    }
    
    public function getId()
    {
        return $this->server_id;
    }
    
    public function setMountpointId($mp_id)
    {
        $this->mountpoint_id = $mp_id;
    }
    
    public function getMountpointId()
    {
        return $this->mountpoint_id;
    }
    
    public function setSid($s)
    {
        $this->sid = $s;
    }
    
    public function getSid()
    {
        return $this->sid;
    }
    
    public function setCurrentSong($cs)
    {
        $this->current_song = $cs;
    }
    
    public function getCurrentSong()
    {
        return $this->current_song;
    }
    
    public function setListenUrl($u)
    {
        $this->listen_url = $u;
    }
    
    public function getListenUrl()
    {
        return $this->listen_url;
    }
    
    public function setListeners($l)
    {
        $this->listeners = $l;
    }
    
    public function getListeners()
    {
        return $this->listeners;
    }
    
    public function setLastTouchedAt($at = null)
    {
        if ($at === null)
        {
            $at = date('Y-m-d H:i:s');
        }
        
        $this->last_touched_at = $at;
    }
    
    public function getLastTouchedAt()
    {
        return $this->last_touched_at;
    }
    
    public function setLastTouchedFrom($f)
    {
        $this->last_touched_from = $f;
    }
    
    public function getLastTouchedFrom()
    {
        return $this->last_touched_from;
    }

    public function setLastTouchedUA($f)
    {
        $this->last_touched_ua = $f;
    }
    
    public function getLastTouchedUA()
    {
        return $this->last_touched_ua;
    }
    
    public function setChecked($c)
    {
        $this->checked = intval($c);
    }
    
    /**
     * @return int
     */
    public function getChecked()
    {
        return $this->checked;
    }
    
    /**
     * @return bool
     */
    public function isChecked()
    {
        return (bool) $this->checked;
    }
}

?>