New Import

2 files changed, 509 insertions, 0 deletions

diff --git a/play/index.php b/play/index.php
new file mode 100644
index 00000000..0091db10
--- /dev/null
+++ b/play/index.php
@@ -0,0 +1,282 @@
+<?php
+/*
+
+ Copyright (c) 2001 - 2005 Ampache.org
+ All rights reserved.  
+
+ This program is free software; you can redistribute it and/or
+ modify it under the terms of the GNU General Public License
+ as published by the Free Software Foundation; either version 2
+ of the License, or (at your option) any later version.
+
+ This program is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ GNU General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with this program; if not, write to the Free Software
+ Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+
+*/
+/*
+
+ This is the wrapper for opening music streams from this server.  This script
+   will play the local version or redirect to the remote server if that be
+   the case.  Also this will update local statistics for songs as well.
+
+*/
+
+$no_session = true;
+require_once('../modules/init.php');
+require_once(conf('prefix') . '/lib/Browser.php');
+
+
+/* These parameters has better come on the url. */
+$uid = htmlspecialchars($_REQUEST['uid']);
+$song_id = htmlspecialchars($_REQUEST['song']);
+$sid = htmlspecialchars($_REQUEST['sid']);
+
+/* Misc Housework */
+$dbh = dbh();
+$user = new User(0,$uid);
+
+if (conf('require_session') && !conf('xml_rpc')) { 
+	if(!session_exists($sid)) {	
+    		die(_("Session Expired: please log in again at") . " " . conf('web_path') . "/login.php");
+	}
+
+	// Now that we've confirmed the session is valid
+	// extend it
+	extend_session($sid);
+}
+
+/* If we are in demo mode.. die here */
+if (conf('demo_mode') || !$user->has_access('25')) {
+	if (conf('debug')) { 
+		log_event($user->usrename,' access_denied ', "Streaming Access Denied, " . conf('demo_mode') . "is the value of demo_mode. Current user level is $user->access");
+	}
+//	access_denied();
+}
+
+/* 
+   If they are using access lists let's make sure 
+   that they have enough access to play this mojo
+*/
+if (conf('access_control')) { 
+
+	$access = new Access(0);
+	if (!$access->check("25", $_SERVER['REMOTE_ADDR'])) { 
+		if (conf('debug')) { 
+			log_event($user->username,' access_denied ', "Streaming Access Denied, " . $_SERVER['REMOTE_ADDR'] . " does not have stream level access");
+		}
+		access_denied();
+	}
+
+} // access_control is enabled
+
+
+// require a uid and valid song
+if ( isset( $uid ) ) {
+	$song = new Song($song_id);
+	$song->format_song();
+
+	// Create the user object if possible
+
+	if (!$song->file OR ( !is_readable($song->file) AND $catalog->catalog_type != 'remote' ) ) { 
+		if (conf('debug')) { 
+			log_event($user->username,' file_not_found ',"Error song ($song->title) does not have a valid filename specified");
+		}
+		echo "Error: No Song"; 
+		exit; 
+	}
+	if ($song->status === 'disabled') { 
+		exit;
+	}
+	if ($user->access === 'disabled') {
+		if (conf('debug')) { 
+			log_event($user->username,' user_disabled ',"Error $user->username is currently disabled, stream access denied");
+		}
+		echo "Error: User Disabled"; 
+		exit; 
+	}
+	if (!$user->id && !$user->is_xmlrpc()) { 
+		if (conf('debug')) { 
+			log_event($user->username,' user_not_found ',"Error $user->id not found, stream access denied");
+		}
+		echo "Error: No User Found"; 
+		exit; 
+	}
+
+}
+else {
+	if (conf('debug')) { 
+		log_event("Unknown", ' user_not_found ',"Error no UID passed with URL, stream access denied");
+	}
+	echo "Error: No UID specified";
+	exit;
+}
+
+$catalog = new Catalog($song->catalog);
+
+if ( $catalog->catalog_type == 'remote' ) {
+	// redirect to the remote host's play path
+	header("Location: $song->file");
+}
+else {
+	if ($user->prefs['play_type'] == 'downsample') { 
+		$ds = $user->prefs['sample_rate']; 
+	}
+
+	// Update the users last seen
+	$user->update_last_seen();
+
+	// Garbage collection for stale entries in the now_playing table
+	$time = time();
+	$expire = $time - 900;  // 86400 seconds = 1 day
+	$sql = "DELETE FROM now_playing WHERE start_time < $expire";
+	$db_result = mysql_query($sql, $dbh);
+
+	// If we are running in Legalize mode, don't play songs already playing
+	if (conf('lock_songs') == 'true') {
+		$sql = "SELECT COUNT(*) FROM now_playing" .
+			" WHERE song_id = '$song_id'";
+		$db_result = mysql_query($sql, $dbh);
+		while ($r = mysql_fetch_row($db_result)) {
+			if ($r[0] == 1) {
+				// Song is already playing, so exit without returning song
+				exit;
+			}
+		}
+	}
+
+	// Put this song in the now_playing table
+	$end_time = time() - $song->time;
+	$sql = "INSERT INTO now_playing (`song_id`, `user_id`, `start_time`)" .
+		" VALUES ('$song_id', '$uid', '$end_time')";
+	$db_result = mysql_query($sql, $dbh);
+	$lastid = mysql_insert_id($dbh);
+
+	// make fread binary safe
+	set_magic_quotes_runtime(0);
+
+	// don't abort the script if user skips this song because we need to update now_playing
+	ignore_user_abort(TRUE);
+
+	/* Format the Song Name */
+	if (conf('stream_name_format')) {
+		$song_name = conf('stream_name_format');
+		$song_name = str_replace("%basename",basename($song->file),$song_name);
+		$song_name = str_replace("%filename",$song->file,$song_name);
+		$song_name = str_replace("%type",$song->type,$song_name);
+		$song_name = str_replace("%catalog",$catalog->name,$song_name);
+		$song_name = str_replace("%A",$song->f_album_full,$song_name); // this and next could be truncated version
+		$song_name = str_replace("%a",$song->f_artist_full,$song_name);
+		$song_name = str_replace("%C",$catalog->path,$song_name);
+		$song_name = str_replace("%c",$song->comment,$song_name);
+		$song_name = str_replace("%g",$song->f_genre,$song_name);
+		$song_name = str_replace("%T",$song->track,$song_name);
+		$song_name = str_replace("%t",$song->title,$song_name);
+		$song_name = str_replace("%y",$song->year,$song_name);
+	} 
+	else {
+		$song_name = $song->f_artist_full . " - " . $song->title . "." . $song->type;
+	}
+
+	
+
+	// Send file, possible at a byte offset
+	$fp = @fopen($song->file, 'r');
+
+	if (!is_resource($fp)) { 
+		if (conf('debug')) { 
+			log_event($user->username,' file_read_error ',"Error: Unable to open $song->file for reading");
+		}
+		cleanup_and_exit($lastid);
+	}
+
+	$startArray = sscanf( $_SERVER[ "HTTP_RANGE" ], "bytes=%d-" );
+	$start = $startArray[0];
+
+	// Generate browser class for sending headers
+	$browser = new Browser();
+	header("Accept-Ranges: bytes" );
+	header("Content-Length: " . $song->size);
+
+	// Prevent the script from timing out
+	set_time_limit(0);			
+	
+	if ($ds) { 
+		$ds = $user->prefs['sample_rate'];          
+		$dsratio = $ds/$song->bitrate*1024;
+		$browser->downloadHeaders($song_name, $song->mime, false,$dsratio*$song->size);
+
+		/* Get Offset */
+		$offset = ( $start*$song->time )/( $dsratio*$song->size );
+		$offsetmm = floor($offset/60);
+		$offsetss = floor($offset-$offsetmm*60);
+		$offset   = sprintf("%02d.%02d",$offsetmm,$offsetss);
+	
+		/* Get EOF */
+		$eofmm	= floor($song->time/60);
+		$eofss	= floor($song->time-$eofmm*60);
+		$eof	= sprintf("%02d.%02d",$eofmm,$eofss);
+		
+		/* Replace Variables */
+		$downsample_command = conf('downsample_cmd');
+		$downsample_command = str_replace("%FILE%",$song->file,$downsample_command);
+		$downsample_command = str_replace("%OFFSET%",$offset,$downsample_command);
+		$downsample_command = str_replace("%EOF%",$eof,$downsample_command);
+		$downsample_command = str_replace("%SAMPLE%",$ds,$downsample_command);
+		
+		// If we are debugging log this event
+		if (conf('debug')) { 
+			$message = "Exec: $downsample_command";
+			log_event($user->username,'downsample',$message);
+		} // if debug	
+
+		$fp = @popen($downsample_command, 'r');
+	} // if downsampling
+
+	elseif ($start) {
+		$browser->downloadHeaders($song_name, $song->mime, false, $song->size);
+		fseek( $fp, $start );
+		$range = $start ."-". $song->size . "/" . $song->size;
+		header("HTTP/1.1 206 Partial Content");
+		header("Content-Range: bytes=$range");
+	}
+	/* Last but not least pump em out */
+	else {
+		$browser->downloadHeaders($song_name, $song->mime, false, $song->size);
+	}
+	
+
+	while (!feof($fp) && (connection_status() == 0)) {
+		print(fread($fp, 8192));
+	}
+
+	if ( ! $start ) {
+		$user->update_stats($song_id);
+	}
+
+	// If the played flag isn't set, set it
+	if (!$song->played) { 
+		$sql = "UPDATE song SET played='1' WHERE id='$song->id'";
+		$db_results = mysql_query($sql, $dbh);
+	}
+
+	// Remove the song from the now_playing table
+	$sql = "DELETE FROM now_playing WHERE id = '$lastid'";
+	$db_result = mysql_query($sql, $dbh);
+
+	/* Clean up any open ends */
+	if ($ds) { 
+		@pclose($fp);
+	} 
+	else { 
+		@fclose($fp);
+	}
+
+}
+
+?>
diff --git a/play/pupload.php b/play/pupload.php
new file mode 100644
index 00000000..2cc73f10
--- /dev/null
+++ b/play/pupload.php
@@ -0,0 +1,227 @@
+<?php

+/*

+

+ Copyright (c) 2001 - 2005 Ampache.org

+ All rights reserved.

+

+ This program is free software; you can redistribute it and/or

+ modify it under the terms of the GNU General Public License

+ as published by the Free Software Foundation; either version 2

+ of the License, or (at your option) any later version.

+

+ This program is distributed in the hope that it will be useful,

+ but WITHOUT ANY WARRANTY; without even the implied warranty of

+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

+ GNU General Public License for more details.

+

+ You should have received a copy of the GNU General Public License

+ along with this program; if not, write to the Free Software

+ Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.

+

+*/

+/*

+

+ This is the wrapper for opening music streams from this server.  This script

+   will play the local version or redirect to the remote server if that be

+   the case.  Also this will update local statistics for songs as well.

+

+*/

+

+$no_session = true;

+require_once('../modules/init.php');

+require_once(conf('prefix') . '/lib/Browser.php');

+

+$browser = new Browser();

+

+$dbh = setup_sess_db("song",

+                     libglue_param('mysql_host'),

+                     libglue_param('mysql_db'),

+                     libglue_param('mysql_user'),

+                     libglue_param('mysql_pass')

+                     );

+

+/* These parameters has better come on the url. */

+$song = htmlspecialchars($_REQUEST['song']);

+$song_nm = htmlspecialchars($_REQUEST['song']);

+$action = htmlspecialchars($_REQUEST['action']);

+$uid = htmlspecialchars($_REQUEST['uid']);

+$web_path = conf('web_path');

+

+

+/* If we are in demo mode.. die here */

+if (conf('demo_mode')) { 

+	exit();

+}

+

+/* 

+   If they are using access lists let's make sure 

+   that they have enough access to play this mojo

+*/

+if (conf('access_control') == "true") { 

+

+	$access = new Access(0);

+	if (!$access->check("25", $_SERVER['REMOTE_ADDR'])) { 

+		echo "Error: Access Denied, Invalid Source ADDR"; 

+		exit();

+	}

+

+} // access_control is enabled

+

+// Get site preferences

+$site = new User(0);

+$site->get_preferences();

+

+

+// require a uid and valid song

+if ( isset( $uid ) ) {

+	// Create the user object if possible

+	$user = new User(0,$uid);

+

+	$song = $site->prefs['upload_dir'] . $song;

+

+	if (!file_exists ( $song )) { echo "Error: No Song"; exit; }

+	if ($user->access === 'disabled') { echo "Error: User Disabled"; exit; }

+	if (!$user->id && !$user->is_xmlrpc()) { echo "Error: No User Found"; exit; }

+

+}

+else {

+	exit;

+}

+

+/* Get file info  */

+$audio_info = new Audioinfo();

+$results = $audio_info->Info($song);

+

+$order = conf('id3tag_order');

+

+// set the $key to the first found tag style (according to their prefs)

+foreach($order as $key) {

+	if ($results[$key]) { break; }

+}

+

+// Fetch Song Info

+$artist_name = addslashes($results[$key]['artist']);

+$album_name = addslashes($results[$key]['album']);

+$title = addslashes($results[$key]['title']);

+$song_time = intval($results['playing_time']);

+$size = filesize($song);

+preg_match('/\.([A-Za-z0-9]+)$/', $song,$results);

+

+$type = $results[1];

+

+switch ($type) { 

+	case "ogg":

+		$mime = "application/x-ogg";

+		break;

+	case "mp3":

+	case "mpeg3":

+		$mime = "audio/mpeg";

+	case "rm":

+		$mime = "audio/x-realaudio";

+	break;

+}

+

+

+if ( $_REQUEST['action'] == 'm3u' ) {

+

+    if($temp_user->prefs['play_type'] == 'local_play') {

+		// Play the song locally using local play configuration

+		$song_name = $artist . " - " . $title . "." . $type;;

+		$sess = $_COOKIE[libglue_param('sess_name')];

+		//echo "Song Name: $song_name<BR>\n";

+		$url = escapeshellarg("$web_path/play/pupload.php?song=$song_nm&uid=$user->id&sid=$sess");

+		$localplay_add = conf('localplay_add');

+		$localplay_add = str_replace("%URL%", $url, $localplay_add);

+		//echo "Executing: $localplay_add<BR>";

+		exec($localplay_add);

+		header("Location: $web_path");

+

+    }

+    else

+    {

+

+		if (conf('force_http_play')) { 

+			$http_port = conf('http_port');

+			$web_path = preg_replace("/https/","http",$web_path);

+			$web_path = preg_replace("/:\d+/",":$http_port",$web_path);

+		}

+

+		// Send the client an m3u playlist

+		header("Cache-control: public");

+		header("Content-Disposition: filename=playlist.m3u");

+		header("Content-Type: audio/x-mpegurl;");

+		echo "#EXTM3U\n";

+

+		$song_name = $song . " - " . $title . "." . $type;

+		$song_name = $artist . " - " . $title . "." . $song->type;;

+		echo "#EXTINF:$song_time,$title\n";

+		$sess = $_COOKIE[libglue_param('sess_name')];

+					if($temp_user->prefs['down-sample'] == 'true')

+						$ds = $temp_user->prefs['sample_rate'];

+		echo "$web_path/play/pupload.php?song=" . rawurlencode($song_nm) . "&uid=$user->id&sid=$sess";

+

+    }

+	exit;

+}

+else

+{

+	// Check to see if we should be downsampling

+	$user->get_preferences();

+

+	if ($user->prefs['play_type'] == 'downsample') { 

+		$ds = $user->prefs['sample_rate']; 

+	}

+

+	// make fread binary safe

+	set_magic_quotes_runtime(0);

+

+	// don't abort the script if user skips this song because we need to update now_playing

+	ignore_user_abort(TRUE);

+

+	// Build the Song Name

+	$song_name = $artist_name . " - " . $title . "." . $type;

+

+	// Send headers

+	$browser->downloadHeaders($song_name, $mime, false, $size );

+	header("Accept-Ranges: bytes" );

+

+	// Send file, possible at a byte offset

+	$fp = fopen($song, 'r');

+

+	$startArray = sscanf( $_SERVER[ "HTTP_RANGE" ], "bytes=%d-" );

+	$start = $startArray[0];

+

+	// Prevent the script from timing out

+	set_time_limit(0);			

+	

+	if ($ds) { 

+		// FIXME:: $dsratio needs to be set

+		$ds = $user->prefs['sample_rate'];                 //ds hack

+		$dsratio = $ds/$song->bitrate*1000; //resample hack

+		$browser->downloadHeaders($song_name, $mime, false,$dsratio*$size);

+		$offset = ( $start*$song_time )/( $dsratio*$size );

+		$offsetmm = floor($offset/60);

+		$offsetss = floor($offset-$offsetmm*60);

+		$offset   = sprintf("%02d.%02d",$offsetmm,$offsetss);

+		$cmd = "mp3splt -qnf \"$song->file\" $offset EOF -o - | lame --mp3input -q 3 -b $ds -S - -";

+		if (!$handle = fopen('/tmp/ampache.log', 'a'));

+		fwrite($handle,"$offset |");

+		fclose($handle);

+		$fp = popen($cmd, 'r');

+		$close='pclose';

+	} // if downsampling

+

+	elseif ($start) {

+		fseek( $fp, $start );

+		header("Content-Range: bytes=$start-$size/$song");

+	}

+

+	while (!feof($fp) && (connection_status() == 0)) {

+		print(fread($fp, 8192));

+	}

+

+	fclose($fp);

+

+}

+

+?>