Congegni
/
sintonia
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

CC-4291: Adding webstreams: Need ability to parse webstreams from .m3u and .xspf urls 

-fixed
This commit is contained in:
Martin Konecny 2012-08-24 19:25:19 -04:00
parent afe5d2e2cf
commit 3fb0fbd73f
2 changed files with 70 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
airtime_mvc/application/controllers/WebstreamController.php
View File

@ -28,7 +28,7 @@ class WebstreamController extends Zend_Controller_Action
$webstream->setDbName("Untitled Webstream");
$webstream->setDbDescription("");
$webstream->setDbUrl("http://");
$webstream->setDbLength("00:00:00");
$webstream->setDbLength("00:30:00");
$webstream->setDbName("Untitled Webstream");
$webstream->setDbCreatorId($userInfo->id);
$webstream->setDbUtime(new DateTime("now", new DateTimeZone('UTC')));
@ -139,10 +139,10 @@ class WebstreamController extends Zend_Controller_Action
}
list($analysis, $mime, $di) = Application_Model_Webstream::analyzeFormData($parameters);
list($analysis, $mime, $mediaUrl, $di) = Application_Model_Webstream::analyzeFormData($parameters);
try {
if (Application_Model_Webstream::isValid($analysis)) {
$streamId = Application_Model_Webstream::save($parameters, $mime, $di);
$streamId = Application_Model_Webstream::save($parameters, $mime, $mediaUrl, $di);
Application_Model_Library::changePlaylist($streamId, "stream");

80
airtime_mvc/application/models/Webstream.php
View File

@ -143,7 +143,16 @@ class Application_Model_Webstream implements Application_Model_LibraryEditable
} else {
try {
$mime = Application_Model_Webstream::discoverStreamMime($url);
list($mime, $content_length_found) = self::discoverStreamMime($url);
if (is_null($mime)) {
throw new Exception("No MIME type found for webstream.");
}
//TODO: return url
$mediaUrl = self::getMediaUrl($url, $mime, $content_length_found);
if (preg_match("/xspf\+xml/", $mime)) {
list($mime, $content_length_found) = self::discoverStreamMime($mediaUrl);
}
} catch (Exception $e) {
$valid['url'][0] = false;
$valid['url'][1] = $e->getMessage();
@ -158,7 +167,7 @@ class Application_Model_Webstream implements Application_Model_LibraryEditable
$id = $parameters["id"];
return array($valid, $mime, $di);
return array($valid, $mime, $mediaUrl, $di);
}
public static function isValid($analysis)
@ -182,36 +191,81 @@ class Application_Model_Webstream implements Application_Model_LibraryEditable
{
}
private static function getXspfUrl($url)
{
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_HEADER, 0);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
// grab URL and pass it to the browser
//TODO: What if invalid url?
$content = curl_exec($ch);
Logging::info($content);
// close cURL resource, and free up system resources
curl_close($ch);
$dom = new DOMDocument;
//TODO: What if invalid xml?
$dom->loadXML($content);
$tracks = $dom->getElementsByTagName('track');
foreach ($tracks as $track) {
$locations = $track->getElementsByTagName('location');
foreach ($locations as $loc) {
return $loc->nodeValue;
}
}
throw new Exception("Could not parse XSPF playlist");
}
private static function getMediaUrl($url, $mime, $content_length_found)
{
if (preg_match("/(mpeg|ogg)/", $mime)) {
if ($content_length_found) {
throw new Exception("Invalid webstream - This appears to be a file download.");
}
$media_url = $url;
} else if (preg_match("/x-mpegurl/", $mime)) {
$media_url = $url;
} else if (preg_match("/xspf\+xml/", $mime)) {
$media_url = self::getXspfUrl($url);
} else {
throw new Exception("Unrecognized stream type: $mime");
}
return $media_url;
}
private static function discoverStreamMime($url)
{
//TODO: What if invalid URL?
$headers = get_headers($url);
$mime = null;
$content_length_found = false;
foreach ($headers as $h) {
if (preg_match("/^content-type:/i", $h)) {
list(, $value) = explode(":", $h, 2);
$mime = trim($value);
}
if (preg_match("/^content-length:/i", $h)) {
$content_length_found = true;
//if content-length appears, this is not a web stream!!!!
//Aborting the save process.
throw new Exception("Invalid webstream - This appears to be a file download.");
}
}
if (is_null($mime)) {
throw new Exception("No MIME type found for webstream.");
} else {
if (!preg_match("/(mpeg|ogg)/", $mime)) {
throw new Exception("Unrecognized stream type: $mime");
}
}
return $mime;
return array($mime, $content_length_found);
}
public static function save($parameters, $mime, $di)
public static function save($parameters, $mime, $mediaUrl, $di)
{
$userInfo = Zend_Auth::getInstance()->getStorage()->read();
@ -224,7 +278,7 @@ class Application_Model_Webstream implements Application_Model_LibraryEditable
$webstream->setDbName($parameters["name"]);
$webstream->setDbDescription($parameters["description"]);
$webstream->setDbUrl($parameters["url"]);
$webstream->setDbUrl($mediaUrl);
$dblength = $di->format("%H:%I");
$webstream->setDbLength($dblength);