type = $type;
$this->media = $media_ids;
$this->user_id = $GLOBALS['user']->id;
if (!is_array($this->media)) { settype($this->media,'array'); }
} // Constructor
/**
* start
*runs this and depending on the type passed it will
*call the correct function
*/
public function start() {
if (!count($this->media) AND !count($this->urls)) {
debug_event('stream','Error: No Songs Passed on ' . $this->type . ' stream','2');
return false;
}
// We're starting insert the session into session_stream
if (!self::get_session()) {
debug_event('stream','Session Insertion failure, aborting','3');
return false;
}
$methods = get_class_methods('Stream');
$create_function = "create_" . $this->type;
// If in the class, call it
if (in_array($create_function,$methods)) {
$this->{$create_function}();
}
// Assume M3u incase they've pooched the type
else {
$this->create_m3u();
}
} // start
/**
* add_urls
* Add an array of urls, it may be a single one who knows, this
* is used for things that aren't coming from media objects
*/
public function add_urls($urls=array()) {
if (!is_array($urls)) { return false; }
$this->urls = array_merge($urls,$this->urls);
} // manual_url_add
/**
* get_session
* This returns the current stream session
*/
public static function get_session() {
if (!self::$session_inserted) {
self::insert_session(self::$session);
}
return self::$session;
} // get_session
/**
* set_session
* This overrides the normal session value, without adding
* an additional session into the database, should be called
* with care
*/
public static function set_session($sid) {
self::$session_inserted = true;
self::$session=$sid;
} // set_session
/**
* insert_session
* This inserts a row into the session_stream table
*/
public static function insert_session($sid='',$uid='') {
$sid = $sid ? Dba::escape($sid) : Dba::escape(self::$session);
$uid = $uid ? Dba::escape($uid) : Dba::escape($GLOBALS['user']->id);
$expire = time() + Config::get('stream_length');
$sql = "INSERT INTO `session_stream` (`id`,`expire`,`user`) " .
"VALUES('$sid','$expire','$uid')";
$db_results = Dba::query($sql);
if (!$db_results) { return false; }
self::$session_inserted = true;
return true;
} // insert_session
/**
* session_exists
* This checks to see if the passed stream session exists and is valid
*/
public static function session_exists($sid) {
$sid = Dba::escape($sid);
$time = time();
$sql = "SELECT * FROM `session_stream` WHERE `id`='$sid' AND `expire` > '$time'";
$db_results = Dba::query($sql);
if ($row = Dba::fetch_assoc($db_results)) {
return true;
}
return false;
} // session_exists
/**
* gc_session
* This function performes the garbage collection stuff, run on extend and on now playing refresh
* There is an array of agents that we will never GC because of their nature, MPD being the best example
*/
public static function gc_session($ip='',$agent='',$uid='',$sid='') {
$append_array = array('MPD');
$time = time();
$sql = "DELETE FROM `session_stream` WHERE `expire` < '$time'";
$db_results = Dba::query($sql);
foreach ($append_array as $append_agent) {
if (strstr(strtoupper($agent),$append_agent)) {
// We're done here jump ship!
return true;
}
} // end foreach
// We need all of this to run this query
if ($ip AND $agent AND $uid AND $sid) {
$sql = "DELETE FROM `session_stream` WHERE `ip`='$ip' AND `agent`='$agent' AND `user`='$uid' AND `id` != '$sid'";
$db_results = Dba::query($sql);
}
} // gc_session
/**
* extend_session
* This takes the passed sid and does a replace into also setting the user
* agent and IP also do a little GC in this function
*/
public static function extend_session($sid,$uid) {
$expire = time() + Config::get('stream_length');
$sid = Dba::escape($sid);
$agent = Dba::escape($_SERVER['HTTP_USER_AGENT']);
$ip = Dba::escape(inet_pton($_SERVER['REMOTE_ADDR']));
$uid = Dba::escape($uid);
$sql = "UPDATE `session_stream` SET `expire`='$expire', `agent`='$agent', `ip`='$ip' " .
"WHERE `id`='$sid'";
$db_results = Dba::query($sql);
self::gc_session($ip,$agent,$uid,$sid);
return true;
} // extend_session
/**
* create_simplem3u
* this creates a simple m3u without any of the extended information
*/
public function create_simple_m3u() {
header("Cache-control: public");
header("Content-Disposition: filename=ampache_playlist.m3u");
header("Content-Type: audio/x-mpegurl;");
// Flip for the poping!
asort($this->urls);
/* Foreach songs */
foreach ($this->media as $element) {
$type = array_shift($element);
echo call_user_func(array($type,'play_url'),array_shift($element)) . "\n";
} // end foreach
/* Foreach the additional URLs */
foreach ($this->urls as $url) {
echo "$url\n";
}
} // simple_m3u
/**
* create_m3u
* creates an m3u file, this includes the EXTINFO and as such can be
* large with very long playlsits
*/
public function create_m3u() {
// Send the client an m3u playlist
header("Cache-control: public");
header("Content-Disposition: filename=ampache_playlist.m3u");
header("Content-Type: audio/x-mpegurl;");
echo "#EXTM3U\n";
// Foreach the songs in this stream object
foreach ($this->media as $element) {
$type = array_shift($element);
$media = new $type(array_shift($element));
$media->format();
switch ($type) {
case 'song':
echo "#EXTINF:$media->time," . $media->f_artist_full . " - " . $media->title . "\n";
break;
case 'video':
echo "#EXTINF: Video - $media->title\n";
break;
case 'radio':
echo "#EXTINF: Radio - $media->name [$media->frequency] ($media->site_url)\n";
break;
case 'random':
echo "#EXTINF:Random URL\n";
break;
default:
echo "#EXTINF:URL-Add\n";
break;
}
echo call_user_func(array($type,'play_url'),$media->id) . "\n";
} // end foreach
/* Foreach URLS */
foreach ($this->urls as $url) {
echo "#EXTINF: URL-Add\n";
echo $url . "\n";
}
} // create_m3u
/**
* create_pls
* This creates a new pls file from an array of songs and
* urls, exciting I know
*/
public function create_pls() {
/* Count entries */
$total_entries = count($this->media) + count($this->urls);
// Send the client a pls playlist
header("Cache-control: public");
header("Content-Disposition: filename=ampache_playlist.pls");
header("Content-Type: audio/x-scpls;");
echo "[Playlist]\n";
echo "NumberOfEntries=$total_entries\n";
foreach ($this->media as $element) {
$i++;
$type = array_shift($element);
$media = new $type(array_shift($element));
$media->format();
switch ($type) {
case 'song':
$name = $media->f_artist_full . " - " . $media->title . "." . $media->type;
$length = $media->time;
break;
default:
$name = 'URL-Add';
$length='-1';
break;
}
$url = call_user_func(array($type,'play_url'),$media->id);
echo "File" . $i . "=$url\n";
echo "Title" . $i . "=$name\n";
echo "Length" . $i . "=$length\n";
} // end foreach songs
/* Foreach Additional URLs */
foreach ($this->urls as $url) {
$i++;
echo "File" . $i ."=$url\n";
echo "Title". $i . "=AddedURL\n";
echo "Length" . $i . "=-1\n";
} // end foreach urls
echo "Version=2\n";
} // create_pls
/**
* create_asx
* creates an ASX playlist (Thx Samir Kuthiala) This should really only be used
* if all of the content is ASF files.
*/
public function create_asx() {
header("Cache-control: public");
header("Content-Disposition: filename=ampache_playlist.asx");
header("Content-Type: video/x-ms-wmv;");
echo "\n";
echo "Ampache ASX Playlist";
foreach ($this->media as $element) {
$type = array_shift($element);
$media = new $type(array_shift($element));
$media->format();
switch ($type) {
case 'song':
$name = $media->f_album_full . " - " . $media->title . "." . $media->type;
$author = $media->f_artist_full;
break;
default:
$author = 'Ampache';
$name = 'URL-Add';
break;
} // end switch
$url = call_user_func(array($type,'play_url'),$media->id);
echo "\n";
echo "$name\n";
echo "$author\n";
echo "\t\t".$media->year."\n";
echo "\t\ttime."\" />\n";
echo "\t\tf_album_full."\" />\n";
echo "\t\tget_genre_name()."\" />\n";
echo "\t\tf_artist_full."\" />\n";
echo "\t\t\n";
echo "