1
0
Fork 0
mirror of https://github.com/Yetangitu/ampache synced 2025-10-05 10:49:37 +02:00

Add Plex edition on missing library items

This commit is contained in:
Afterster 2014-08-05 02:10:23 +02:00
parent 9e06675a15
commit 034a6341fb
20 changed files with 717 additions and 291 deletions

View file

@ -69,6 +69,10 @@ class Album extends database_object implements library_item
*/ */
public $release_type; public $release_type;
/**
* @var int $catalog_id
*/
public $catalog_id;
/** /**
* @var int $song_count * @var int $song_count
*/ */
@ -680,6 +684,17 @@ class Album extends database_object implements library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array($this->catalog_id);
}
/** /**
* Get item's owner. * Get item's owner.
* @return int|null * @return int|null
@ -735,8 +750,8 @@ class Album extends database_object implements library_item
public function update(array $data) public function update(array $data)
{ {
$year = $data['year'] ?: $this->year; $year = $data['year'] ?: $this->year;
$artist = intval($data['artist']); $artist = $data['artist'] ? intval($data['artist']) : $this->artist;
$album_artist = intval($data['album_artist']); $album_artist = $data['album_artist'] ? intval($data['album_artist']) : $this->album_artist;
$name = $data['name'] ?: $this->name; $name = $data['name'] ?: $this->name;
$disk = $data['disk'] ?: $this->disk; $disk = $data['disk'] ?: $this->disk;
$mbid = $data['mbid'] ?: $this->mbid; $mbid = $data['mbid'] ?: $this->mbid;
@ -802,7 +817,9 @@ class Album extends database_object implements library_item
if ($data['apply_childs'] == 'checked') { if ($data['apply_childs'] == 'checked') {
$override_songs = true; $override_songs = true;
} }
$this->update_tags($data['edit_tags'], $override_songs, $current_id); if (isset($data['edit_tags'])) {
$this->update_tags($data['edit_tags'], $override_songs, $current_id);
}
return $current_id; return $current_id;

View file

@ -315,7 +315,7 @@ class Art extends database_object
* @param string $mime * @param string $mime
* @return boolean * @return boolean
*/ */
public function insert($source, $mime) public function insert($source, $mime = '')
{ {
// Disabled in demo mode cause people suck and upload porn // Disabled in demo mode cause people suck and upload porn
if (AmpConfig::get('demo_mode')) { return false; } if (AmpConfig::get('demo_mode')) { return false; }

View file

@ -369,7 +369,7 @@ class Artist extends database_object implements library_item
$row = parent::get_from_cache('artist_extra',$this->id); $row = parent::get_from_cache('artist_extra',$this->id);
} else { } else {
$uid = Dba::escape($this->id); $uid = Dba::escape($this->id);
$sql = "SELECT `song`.`artist`,COUNT(DISTINCT `song`.`id`) AS `song_count`, COUNT(DISTINCT `song`.`album`) AS `album_count`, SUM(`song`.`time`) AS `time` FROM `song` LEFT JOIN `catalog` ON `catalog`.`id` = `song`.`catalog` " . $sql = "SELECT `song`.`artist`,COUNT(DISTINCT `song`.`id`) AS `song_count`, COUNT(DISTINCT `song`.`album`) AS `album_count`, SUM(`song`.`time`) AS `time`, `song`.`catalog` as `catalog_id` FROM `song` LEFT JOIN `catalog` ON `catalog`.`id` = `song`.`catalog` " .
"WHERE (`song`.`artist`='$uid' || `song`.`album_artist`='$uid') "; "WHERE (`song`.`artist`='$uid' || `song`.`album_artist`='$uid') ";
if ($catalog) { if ($catalog) {
$sql .= "AND (`song`.`catalog` = '$catalog') "; $sql .= "AND (`song`.`catalog` = '$catalog') ";
@ -392,6 +392,7 @@ class Artist extends database_object implements library_item
$this->songs = $row['song_count']; $this->songs = $row['song_count'];
$this->albums = $row['album_count']; $this->albums = $row['album_count'];
$this->time = $row['time']; $this->time = $row['time'];
$this->catalog_id = $row['catalog_id'];
return $row; return $row;
@ -514,6 +515,17 @@ class Artist extends database_object implements library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array($this->catalog_id);
}
/** /**
* Get item's owner. * Get item's owner.
* @return int|null * @return int|null
@ -633,7 +645,7 @@ class Artist extends database_object implements library_item
// Save our current ID // Save our current ID
$name = $data['name'] ?: $this->name; $name = $data['name'] ?: $this->name;
$mbid = $data['mbid'] ?: $this->mbid; $mbid = $data['mbid'] ?: $this->mbid;
$current_id = $this->id; $current_id = $this->id;
// Check if name is different than current name // Check if name is different than current name
@ -674,7 +686,7 @@ class Artist extends database_object implements library_item
$sql = 'UPDATE `artist` SET `name` = ? WHERE `id` = ?'; $sql = 'UPDATE `artist` SET `name` = ? WHERE `id` = ?';
Dba::write($sql, array($name, $current_id)); Dba::write($sql, array($name, $current_id));
} }
$this->name = $name; $this->name = $name;
$this->mbid = $mbid; $this->mbid = $mbid;
@ -682,7 +694,9 @@ class Artist extends database_object implements library_item
if ($data['apply_childs'] == 'checked') { if ($data['apply_childs'] == 'checked') {
$override_childs = true; $override_childs = true;
} }
$this->update_tags($data['edit_tags'], $override_childs, $current_id); if (isset($data['edit_tags'])) {
$this->update_tags($data['edit_tags'], $override_childs, $current_id);
}
return $current_id; return $current_id;

View file

@ -234,6 +234,17 @@ class Broadcast extends database_object implements library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array();
}
/** /**
* Get item's owner. * Get item's owner.
* @return int|null * @return int|null

View file

@ -430,6 +430,17 @@ class Channel extends database_object implements media, library_item
return $chunk; return $chunk;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array();
}
public static function play_url($oid, $additional_params='', $local=false) public static function play_url($oid, $additional_params='', $local=false)
{ {
$channel = new Channel($oid); $channel = new Channel($oid);

View file

@ -108,6 +108,17 @@ class Live_Stream extends database_object implements media, library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array($this->catalog);
}
public function get_user_owner() public function get_user_owner()
{ {
return null; return null;

View file

@ -86,12 +86,24 @@ class Movie extends Video
{ {
parent::update($data); parent::update($data);
$trimmed = Catalog::trim_prefix(trim($data['original_name'])); if (isset($data['original_name'])) {
$name = $trimmed['string']; $trimmed = Catalog::trim_prefix(trim($data['original_name']));
$prefix = $trimmed['prefix']; $name = $trimmed['string'];
$prefix = $trimmed['prefix'];
} else {
$name = $this->original_name;
$prefix = $this->prefix;
}
$summary = $data['summary'] ?: $this->summary;
$year = $data['year'] ?: $this->year;
$sql = "UPDATE `movie` SET `original_name` = ?, `prefix` = ?, `summary` = ?, `year` = ? WHERE `id` = ?"; $sql = "UPDATE `movie` SET `original_name` = ?, `prefix` = ?, `summary` = ?, `year` = ? WHERE `id` = ?";
Dba::write($sql, array($name, $prefix, $data['summary'], $data['year'], $this->id)); Dba::write($sql, array($name, $prefix, $summary, $year, $this->id));
$this->original_name = $name;
$this->prefix = $prefix;
$this->summary = $summary;
$this->year = $year;
return $this->id; return $this->id;

View file

@ -63,4 +63,12 @@ interface playable_item
*/ */
public function get_medias($filter_type = null); public function get_medias($filter_type = null);
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs();
} // end interface } // end interface

View file

@ -274,10 +274,10 @@ class Playlist extends playlist_object
*/ */
public function update(array $data) public function update(array $data)
{ {
if ($data['name'] != $this->name) { if (isset($data['name']) && $data['name'] != $this->name) {
$this->update_name($data['name']); $this->update_name($data['name']);
} }
if ($data['pl_type'] != $this->type) { if (isset($data['pl_type']) && $data['pl_type'] != $this->type) {
$this->update_type($data['pl_type']); $this->update_type($data['pl_type']);
} }
@ -354,6 +354,19 @@ class Playlist extends playlist_object
* This takes an array of song_ids and then adds it to the playlist * This takes an array of song_ids and then adds it to the playlist
*/ */
public function add_songs($song_ids=array(),$ordered=false) public function add_songs($song_ids=array(),$ordered=false)
{
$medias = array();
foreach ($song_ids as $song_id) {
$medias[] = array(
'object_type' => 'song',
'object_id' => $song_id,
);
}
$this->add_medias($medias);
} // add_songs
public function add_medias($medias)
{ {
/* We need to pull the current 'end' track and then use that to /* We need to pull the current 'end' track and then use that to
* append, rather then integrate take end track # and add it to * append, rather then integrate take end track # and add it to
@ -363,31 +376,29 @@ class Playlist extends playlist_object
$db_results = Dba::read($sql, array($this->id)); $db_results = Dba::read($sql, array($this->id));
$data = Dba::fetch_assoc($db_results); $data = Dba::fetch_assoc($db_results);
$base_track = $data['track']; $base_track = $data['track'];
debug_event('add_songs', 'Track number: '.$base_track, '5'); debug_event('add_medias', 'Track number: '.$base_track, '5');
$i = 0; $i = 0;
foreach ($song_ids as $song_id) { foreach ($medias as $data) {
/* We need the songs track */ $media = new $data['object_type']($data['object_id']);
$song = new Song($song_id);
// Based on the ordered prop we use track + base or just $i++ // Based on the ordered prop we use track + base or just $i++
if (!$ordered) { if (!$ordered && $data['object_type'] == 'song') {
$track = $song->track + $base_track; $track = $media->track + $base_track;
} else { } else {
$i++; $i++;
$track = $base_track + $i; $track = $base_track + $i;
} }
/* Don't insert dead songs */ /* Don't insert dead media */
if ($song->id) { if ($media->id) {
$sql = "INSERT INTO `playlist_data` (`playlist`,`object_id`,`object_type`,`track`) " . $sql = "INSERT INTO `playlist_data` (`playlist`,`object_id`,`object_type`,`track`) " .
" VALUES (?, ?, 'song', ?)"; " VALUES (?, ?, ?, ?)";
Dba::write($sql, array($this->id, $song->id, $track)); Dba::write($sql, array($this->id, $data['object_id'], $data['object_type'], $track));
} // if valid id } // if valid id
} // end foreach songs } // end foreach medias
}
} // add_songs
/** /**
* create * create

View file

@ -126,5 +126,15 @@ abstract class playlist_object extends database_object implements library_item
return 'default'; return 'default';
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array();
}
} // end playlist_object } // end playlist_object

View file

@ -203,7 +203,7 @@ class Plex_Api
$GLOBALS['user']->access = 50; $GLOBALS['user']->access = 50;
} }
} }
if (($GLOBALS['user']->access < $level || AmpConfig::get('demo_mode'))) { if (($GLOBALS['user']->access < $level || AmpConfig::get('demo_mode'))) {
debug_event('plex', 'User ' . $GLOBALS['user']->username . ' is unauthorized to complete the action.', '3'); debug_event('plex', 'User ' . $GLOBALS['user']->username . ' is unauthorized to complete the action.', '3');
self::createError(401); self::createError(401);
@ -774,33 +774,62 @@ class Plex_Api
$view = $params[1]; $view = $params[1];
$gtypes = $catalog->get_gather_types(); $gtypes = $catalog->get_gather_types();
if ($gtypes[0] == 'music') { if ($gtypes[0] == 'music') {
$type = 'artist';
if ($_GET['type']) {
$type = Plex_XML_Data::getAmpacheType($_GET['type']);
}
if ($view == "all") { if ($view == "all") {
Plex_XML_Data::setSectionAll_Artists($r, $catalog); switch ($type) {
case 'artist':
Plex_XML_Data::setSectionAll_Artists($r, $catalog);
break;
case 'album':
Plex_XML_Data::setSectionAll_Albums($r, $catalog);
break;
}
} elseif ($view == "albums") { } elseif ($view == "albums") {
Plex_XML_Data::setSectionAlbums($r, $catalog); Plex_XML_Data::setSectionAlbums($r, $catalog);
} elseif ($view == "recentlyadded") { } elseif ($view == "recentlyadded") {
Plex_XML_Data::setCustomSectionView($r, $catalog, Stats::get_recent('album', 25, $key)); Plex_XML_Data::setCustomSectionView($r, $catalog, Stats::get_recent('album', 25, $key));
} elseif ($view == "genre") { } elseif ($view == "genre") {
$type = Plex_XML_Data::getAmpacheType($_GET['type']); Plex_XML_Data::setSectionTags($r, $catalog, 'song');
Plex_XML_Data::setSectionTags($r, $catalog, $type);
} }
} elseif ($gtypes[0] == "tvshow") { } elseif ($gtypes[0] == "tvshow") {
$type = 'tvshow';
if ($_GET['type']) {
$type = Plex_XML_Data::getAmpacheType($_GET['type']);
}
if ($view == "all") { if ($view == "all") {
Plex_XML_Data::setSectionAll_TVShows($r, $catalog); switch ($type) {
case 'tvshow':
Plex_XML_Data::setSectionAll_TVShows($r, $catalog);
break;
case 'season':
Plex_XML_Data::setSectionAll_Seasons($r, $catalog);
break;
case 'episode':
Plex_XML_Data::setSectionAll_Episodes($r, $catalog);
break;
}
} elseif ($view == "recentlyadded") { } elseif ($view == "recentlyadded") {
Plex_XML_Data::setCustomSectionView($r, $catalog, Stats::get_recent('tvshow_episode', 25, $key)); Plex_XML_Data::setCustomSectionView($r, $catalog, Stats::get_recent('tvshow_episode', 25, $key));
} elseif ($view == "genre") { } elseif ($view == "genre") {
$type = Plex_XML_Data::getAmpacheType($_GET['type']); Plex_XML_Data::setSectionTags($r, $catalog, 'video');
Plex_XML_Data::setSectionTags($r, $catalog, $type);
} }
} elseif ($gtypes[0] == "movie") { } elseif ($gtypes[0] == "movie") {
$type = 'tvshow';
if ($_GET['type']) {
$type = Plex_XML_Data::getAmpacheType($_GET['type']);
}
if ($view == "all") { if ($view == "all") {
Plex_XML_Data::setSectionAll_Movies($r, $catalog); Plex_XML_Data::setSectionAll_Movies($r, $catalog);
} elseif ($view == "recentlyadded") { } elseif ($view == "recentlyadded") {
Plex_XML_Data::setCustomSectionView($r, $catalog, Stats::get_recent('movie', 25, $key)); Plex_XML_Data::setCustomSectionView($r, $catalog, Stats::get_recent('movie', 25, $key));
} elseif ($view == "genre") { } elseif ($view == "genre") {
$type = Plex_XML_Data::getAmpacheType($_GET['type']); Plex_XML_Data::setSectionTags($r, $catalog, 'video');
Plex_XML_Data::setSectionTags($r, $catalog, $type);
} }
} }
} }
@ -814,121 +843,163 @@ class Plex_Api
{ {
$r = Plex_XML_Data::createLibContainer(); $r = Plex_XML_Data::createLibContainer();
$n = count($params); $n = count($params);
$litem = null;
$createMode = ($_SERVER['REQUEST_METHOD'] == 'POST');
$editMode = ($_SERVER['REQUEST_METHOD'] == 'PUT');
if ($n > 0) { if ($n > 0) {
$key = $params[0]; $key = $params[0];
$id = Plex_XML_Data::getAmpacheId($key); $id = Plex_XML_Data::getAmpacheId($key);
$editMode = ($_SERVER['REQUEST_METHOD'] == 'PUT');
if ($editMode) { if ($editMode) {
self::check_access(50); self::check_access(50);
} }
if ($n == 1) { if ($n == 1) {
// Should we check that files still exists here? // Should we check that files still exists here?
$checkFiles = $_REQUEST['checkFiles']; $checkFiles = $_REQUEST['checkFiles'];
$extra = $_REQUEST['includeExtra'];
if (Plex_XML_Data::isArtist($key)) { if (Plex_XML_Data::isArtist($key)) {
$artist = new Artist($id); $litem = new Artist($id);
$artist->format(); $litem->format();
if ($editMode) { if ($editMode) {
$dmap = array( $dmap = array(
'title' => 'name', 'title' => 'name',
'summary' => null, 'summary' => null,
); );
$artist->update(self::get_data_from_map($dmap)); $litem->update(self::get_data_from_map($dmap));
} }
Plex_XML_Data::addArtist($r, $artist); Plex_XML_Data::addArtist($r, $litem);
} elseif (Plex_XML_Data::isAlbum($key)) { } elseif (Plex_XML_Data::isAlbum($key)) {
$album = new Album($id); $litem = new Album($id);
$album->format(); $litem->format();
if ($editMode) { if ($editMode) {
$dmap = array( $dmap = array(
'title' => 'name', 'title' => 'name',
'year' => null, 'year' => null,
); );
$album->update(self::get_data_from_map($dmap)); $litem->update(self::get_data_from_map($dmap));
} }
Plex_XML_Data::addAlbum($r, $album); Plex_XML_Data::addAlbum($r, $litem);
} elseif (Plex_XML_Data::isTrack($key)) { } elseif (Plex_XML_Data::isTrack($key)) {
$song = new Song($id); $litem = new Song($id);
$song->format(); $litem->format();
if ($editMode) { if ($editMode) {
$dmap = array( $dmap = array(
'title' => null, 'title' => null,
); );
$song->update(self::get_data_from_map($dmap)); $litem->update(self::get_data_from_map($dmap));
} }
Plex_XML_Data::addSong($r, $song); Plex_XML_Data::addSong($r, $litem);
} elseif (Plex_XML_Data::isTVShow($key)) { } elseif (Plex_XML_Data::isTVShow($key)) {
$tvshow = new TVShow($id); $litem = new TVShow($id);
$tvshow->format(); $litem->format();
Plex_XML_Data::addTVShow($r, $tvshow); if ($editMode) {
$dmap = array(
'title' => 'name',
'year' => null,
'summary' => null,
);
$litem->update(self::get_data_from_map($dmap));
}
Plex_XML_Data::addTVShow($r, $litem);
} elseif (Plex_XML_Data::isTVShowSeason($key)) { } elseif (Plex_XML_Data::isTVShowSeason($key)) {
$season = new TVShow_Season($id); $litem = new TVShow_Season($id);
$season->format(); $litem->format();
Plex_XML_Data::addTVShowSeason($r, $season); Plex_XML_Data::addTVShowSeason($r, $litem);
} elseif (Plex_XML_Data::isVideo($key)) { } elseif (Plex_XML_Data::isVideo($key)) {
$video = Video::create_from_id($id); $litem = Video::create_from_id($id);
$video->format();
$subtype = strtolower(get_class($video)); if ($editMode) {
$dmap = array(
'title' => null,
'year' => null,
'originallyAvailableAt' => 'release_date',
'originalTitle' => 'original_name',
'summary' => null,
);
$litem->update(self::get_data_from_map($dmap));
}
$litem->format();
$subtype = strtolower(get_class($litem));
if ($subtype == 'tvshow_episode') { if ($subtype == 'tvshow_episode') {
Plex_XML_Data::addEpisode($r, $video, true); Plex_XML_Data::addEpisode($r, $litem, true);
} elseif ($subtype == 'movie') { } elseif ($subtype == 'movie') {
Plex_XML_Data::addMovie($r, $video, true); Plex_XML_Data::addMovie($r, $litem, true);
} }
} elseif (Plex_XML_Data::isPlaylist($key)) { } elseif (Plex_XML_Data::isPlaylist($key)) {
$playlist = new Playlist($id); $litem = new Playlist($id);
$playlist->format(); $litem->format();
if ($editMode) { if ($editMode) {
$dmap = array( $dmap = array(
'title' => 'name', 'title' => 'name',
); );
$playlist->update(self::get_data_from_map($dmap)); $litem->update(self::get_data_from_map($dmap));
} }
Plex_XML_Data::addPlaylist($r, $playlist); Plex_XML_Data::addPlaylist($r, $litem);
} }
} else { } else {
$subact = $params[1]; $subact = $params[1];
if ($subact == "children") { if ($subact == "children") {
if (Plex_XML_Data::isArtist($key)) { if (Plex_XML_Data::isArtist($key)) {
$artist = new Artist($id); $litem = new Artist($id);
$artist->format(); $litem->format();
Plex_XML_Data::setArtistRoot($r, $artist); Plex_XML_Data::setArtistRoot($r, $litem);
} else if (Plex_XML_Data::isAlbum($key)) { } else if (Plex_XML_Data::isAlbum($key)) {
$album = new Album($id); $litem = new Album($id);
$album->format(); $litem->format();
Plex_XML_Data::setAlbumRoot($r, $album); Plex_XML_Data::setAlbumRoot($r, $litem);
} else if (Plex_XML_Data::isTVShow($key)) { } else if (Plex_XML_Data::isTVShow($key)) {
$tvshow = new TVShow($id); $litem = new TVShow($id);
$tvshow->format(); $litem->format();
Plex_XML_Data::setTVShowRoot($r, $tvshow); Plex_XML_Data::setTVShowRoot($r, $litem);
} else if (Plex_XML_Data::isTVShowSeason($key)) { } else if (Plex_XML_Data::isTVShowSeason($key)) {
$season = new TVShow_Season($id); $litem = new TVShow_Season($id);
$season->format(); $litem->format();
Plex_XML_Data::setTVShowSeasonRoot($r, $season); Plex_XML_Data::setTVShowSeasonRoot($r, $litem);
} }
} elseif ($subaction == "posters") { } elseif ($subact == "thumbs" || $subact == "posters" || $subact == "arts" || $subact == 'backgrounds') {
if ($editMode) { $kind = Plex_XML_Data::getPhotoKind($subact);
// Upload art here if ($createMode) {
// Upload art
$litem = Plex_XML_Data::createLibraryItem($key);
$uri = Plex_XML_Data::getMetadataUri($key) . '/' . Plex_XML_Data::getPhotoPlexKind($kind) . '/' . $key;
if (is_a($litem, 'video')) {
$type = 'video';
} else {
$type = get_class($litem);
}
debug_event('aaaaaaaa', $type, 5);
$art = new Art($litem->id, $type, $kind);
$raw = file_get_contents("php://input");
$art->insert($raw);
header('Content-Type: text/html');
echo $uri;
exit;
} }
// Get arts list here Plex_XML_Data::addPhotos($r, $key, $kind);
} elseif ($subact == "thumb" || $subact == "art" || $subact == "background") { } elseif ($subact == "thumb" || $subact == "poster" || $subact == "art" || $subact == "background") {
if ($n == 3) { if ($n == 3) {
// Ignore art id and type as we can only have 1 thumb $kind = Plex_XML_Data::getPhotoKind($subact);
// Ignore art id as we can only have 1 thumb
$art = null; $art = null;
if (Plex_XML_Data::isArtist($key)) { if (Plex_XML_Data::isArtist($key)) {
$art = new Art($id, "artist"); $art = new Art($id, "artist", $kind);
} else if (Plex_XML_Data::isAlbum($key)) { } else if (Plex_XML_Data::isAlbum($key)) {
$art = new Art($id, "album"); $art = new Art($id, "album", $kind);
} else if (Plex_XML_Data::isTrack($key)) { } else if (Plex_XML_Data::isTrack($key)) {
$art = new Art($id, "song"); $art = new Art($id, "song", $kind);
} else if (Plex_XML_Data::isTVShow($key)) { } else if (Plex_XML_Data::isTVShow($key)) {
$art = new Art($id, "tvshow"); $art = new Art($id, "tvshow", $kind);
} else if (Plex_XML_Data::isTVShowSeason($key)) { } else if (Plex_XML_Data::isTVShowSeason($key)) {
$art = new Art($id, "tvshow_season"); $art = new Art($id, "tvshow_season", $kind);
} else if (Plex_XML_Data::isVideo($key)) { } else if (Plex_XML_Data::isVideo($key)) {
$art = new Art($id, "video"); $art = new Art($id, "video", $kind);
} }
if ($art != null) { if ($art != null) {
@ -952,6 +1023,15 @@ class Plex_Api
} }
} }
} }
if ($litem != null) {
$catalog_ids = $litem->get_catalogs();
if (count($catalog_ids) > 0) {
$catalog = Catalog::create_from_id($catalog_ids[0]);
Plex_XML_Data::addCatalogIdentity($r, $catalog);
}
}
Plex_XML_Data::setContainerSize($r); Plex_XML_Data::setContainerSize($r);
self::apiOutputXml($r->asXML()); self::apiOutputXml($r->asXML());
} }
@ -1128,12 +1208,11 @@ class Plex_Api
public static function system_scanners($params) public static function system_scanners($params)
{ {
if (count($params) > 0) { if (count($params) > 0) {
if ($params[0] == '8' || $params[0] == '9') { $type = $params[0];
$r = Plex_XML_Data::createSysContainer(); $r = Plex_XML_Data::createSysContainer();
Plex_XML_Data::setMusicScanners($r); Plex_XML_Data::setScanners($r, $type);
Plex_XML_Data::setContainerSize($r); Plex_XML_Data::setContainerSize($r);
self::apiOutputXml($r->asXML()); self::apiOutputXml($r->asXML());
}
} else { } else {
self::createError(404); self::createError(404);
} }
@ -1305,29 +1384,58 @@ class Plex_Api
public static function playlists($params) public static function playlists($params)
{ {
$r = Plex_XML_Data::createContainer();
$n = count($params); $n = count($params);
$createMode = ($_SERVER['REQUEST_METHOD'] == 'POST');
$editMode = ($_SERVER['REQUEST_METHOD'] == 'PUT'); $editMode = ($_SERVER['REQUEST_METHOD'] == 'PUT');
$delMode = ($_SERVER['REQUEST_METHOD'] == 'DELETE'); $delMode = ($_SERVER['REQUEST_METHOD'] == 'DELETE');
if ($editMode || $delMode) { if ($createMode || $editMode || $delMode) {
self::check_access(50); self::check_access(50);
} }
if ($n == 0 || ($n == 1 && $params[0] == "all")) { if ($n <= 1) {
$r = Plex_XML_Data::createContainer(); $plid = 0;
Plex_XML_Data::setPlaylists($r); if ($n == 0 && $createMode) {
Plex_XML_Data::setContainerSize($r); // Create a new playlist
self::apiOutputXml($r->asXML()); //$type = $_GET['type'];
} elseif ($n == 1) { $title = $_GET['title'];
$plid = $params[0]; //$smart = $_GET['smart'];
if (Plex_XML_Data::isPlaylist($plid)) { //$summary = $_GET['summary'];
$playlist = new Playlist(Plex_XML_Data::getAmpacheId($plid)); $uri = $_GET['uri'];
if ($playlist->id) {
$r = Plex_XML_Data::createContainer(); $plid = Playlist::create($title, 'public');
Plex_XML_Data::addPlaylist($r, $playlist); $playlist = new Playlist($plid);
Plex_XML_Data::setContainerSize($r); $key = Plex_XML_Data::getKeyFromFullUri($uri);
self::apiOutputXml($r->asXML()); $id = Plex_XML_Data::getKeyFromMetadataUri($key);
if ($id) {
$item = Plex_XML_Data::createLibraryItem($id);
$medias = $item->get_medias();
$playlist->add_medias($medias);
} }
$plid = Plex_XML_Data::getPlaylistId($plid);
} else {
if ($n == 1 && $params[0] != "all") {
$plid = $params[0];
}
}
if ($plid) {
if (Plex_XML_Data::isPlaylist($plid)) {
$playlist = new Playlist(Plex_XML_Data::getAmpacheId($plid));
if ($playlist->id) {
if ($delMode) {
// Delete playlist
$playlist->delete();
} else {
// Display playlist information
Plex_XML_Data::addPlaylist($r, $playlist);
}
}
}
} else {
// List all playlists
Plex_XML_Data::setPlaylists($r);
} }
} elseif ($n >= 2) { } elseif ($n >= 2) {
$plid = $params[0]; $plid = $params[0];
@ -1335,20 +1443,34 @@ class Plex_Api
$playlist = new Playlist(Plex_XML_Data::getAmpacheId($plid)); $playlist = new Playlist(Plex_XML_Data::getAmpacheId($plid));
if ($playlist->id) { if ($playlist->id) {
if ($n == 2) { if ($n == 2) {
$r = Plex_XML_Data::createContainer(); if ($editMode) {
Plex_XML_Data::setPlaylistItems($r, $playlist); // Add a new item to playlist
Plex_XML_Data::setContainerSize($r); $uri = $_GET['uri'];
self::apiOutputXml($r->asXML()); $key = Plex_XML_Data::getKeyFromFullUri($uri);
$id = Plex_XML_Data::getKeyFromMetadataUri($key);
if ($id) {
$item = Plex_XML_Data::createLibraryItem($id);
$medias = $item->get_medias();
$playlist->add_medias($medias);
Plex_XML_Data::addPlaylist($r, $playlist);
}
} else {
Plex_XML_Data::setPlaylistItems($r, $playlist);
}
} elseif ($n == 3) { } elseif ($n == 3) {
$index = intval($params[2]); $index = intval($params[2]);
if ($delMode) { if ($delMode) {
$playlist->delete_track_number($index); $playlist->delete_track_number($index);
$playlist->regenerate_track_numbers(); $playlist->regenerate_track_numbers();
exit;
} }
} }
} }
} }
} }
Plex_XML_Data::setContainerSize($r);
self::apiOutputXml($r->asXML());
} }
public static function playqueues($params) public static function playqueues($params)
@ -1372,21 +1494,25 @@ class Plex_Api
Plex_XML_Data::setContainerSize($r); Plex_XML_Data::setContainerSize($r);
self::apiOutputXml($r->asXML()); self::apiOutputXml($r->asXML());
} }
private static function get_data_from_map($dmap) private static function get_data_from_map($dmap)
{ {
$data = array(); $data = array();
foreach ($dmap as $key=>$value) { foreach ($dmap as $key=>$value) {
if (isset($_GET[$key])) { if (isset($_GET[$key])) {
if ($value == null) { if ($value == null) {
$value = $key; $value = $key;
} }
$data[$value] = $_GET[$key]; $data[$value] = $_GET[$key];
} }
} }
if (isset($_GET['genre'])) {
$data['edit_tags'] = implode(',', $_GET['genre']);
}
return $data; return $data;
} }
} }

View file

@ -44,6 +44,8 @@ class Plex_XML_Data
const PLEX_ARTIST = 8; const PLEX_ARTIST = 8;
const PLEX_ALBUM = 9; const PLEX_ALBUM = 9;
const PLEX_TVSHOW = 2; const PLEX_TVSHOW = 2;
const PLEX_SEASON = 3;
const PLEX_EPISODE = 4;
const PLEX_MOVIE = 1; const PLEX_MOVIE = 1;
const PLEX_PLAYLIST = 15; const PLEX_PLAYLIST = 15;
@ -173,6 +175,37 @@ class Plex_XML_Data
return ($id >= Plex_XML_Data::AMPACHEID_PART); return ($id >= Plex_XML_Data::AMPACHEID_PART);
} }
public static function createLibraryItem($id)
{
$item = null;
$oid = self::getAmpacheId($id);
if (self::isArtist($id)) {
$item = new Artist($oid);
} elseif (self::isAlbum($id)) {
$item = new Album($oid);
} elseif (self::isSong($id) || self::isTrack($id)) {
$item = new Song($oid);
} elseif (self::isTVShow($id)) {
$item = new TVShow($oid);
} elseif (self::isTVShowSeason($id)) {
$item = new TVShow_Season($oid);
} elseif (self::isVideo($id)) {
$item = Video::create_from_id($oid);
} elseif (self::isPlaylist($id)) {
$item = new Playlist($oid);
}
if ($item != null) {
if ($item->id) {
$item->format();
} else {
$item = null;
}
}
return $item;
}
public static function getPlexVersion() public static function getPlexVersion()
{ {
return "0.9.9.13.525-197d5ed"; return "0.9.9.13.525-197d5ed";
@ -296,6 +329,22 @@ class Plex_XML_Data
return substr($uri, strlen($up)); return substr($uri, strlen($up));
} }
public static function getKeyFromFullUri($uri)
{
$key = '';
$puri = parse_url($uri);
if ($puri['scheme'] == 'library') {
// We ignore library uuid (= $puri['host'])
$ppath = explode('/', $puri['path']);
if (count($ppath) == 3) {
if ($ppath['1'] == 'item') {
$key = rawurldecode($ppath[2]);
}
}
}
return $key;
}
public static function getSectionUri($key) public static function getSectionUri($key)
{ {
return '/library/sections/' . $key; return '/library/sections/' . $key;
@ -480,18 +529,18 @@ class Plex_XML_Data
case 'movie': case 'movie':
$dir->addAttribute('type', 'movie'); $dir->addAttribute('type', 'movie');
$dir->addAttribute('agent', 'com.plexapp.agents.imdb'); $dir->addAttribute('agent', 'com.plexapp.agents.imdb');
$dir->addAttribute('scanner', 'Plex Movie Scanner'); $dir->addAttribute('scanner', 'Ampache Movie Scanner');
break; break;
case 'tvshow': case 'tvshow':
$dir->addAttribute('type', 'show'); $dir->addAttribute('type', 'show');
$dir->addAttribute('agent', 'com.plexapp.agents.thetvdb'); $dir->addAttribute('agent', 'com.plexapp.agents.thetvdb');
$dir->addAttribute('scanner', 'Plex Series Scanner'); $dir->addAttribute('scanner', 'Ampache Series Scanner');
break; break;
case 'music': case 'music':
default: default:
$dir->addAttribute('type', 'artist'); $dir->addAttribute('type', 'artist');
$dir->addAttribute('agent', 'com.plexapp.agents.none'); // com.plexapp.agents.lastfm $dir->addAttribute('agent', 'com.plexapp.agents.none'); // com.plexapp.agents.lastfm
$dir->addAttribute('scanner', 'Plex Music Scanner'); $dir->addAttribute('scanner', 'Ampache Music Scanner');
break; break;
} }
$dir->addAttribute('language', 'en'); $dir->addAttribute('language', 'en');
@ -601,8 +650,7 @@ class Plex_XML_Data
$xml->addAttribute('nocache', '1'); $xml->addAttribute('nocache', '1');
$xml->addAttribute('viewGroup', $viewGroup); $xml->addAttribute('viewGroup', $viewGroup);
$xml->addAttribute('viewMode', '65592'); $xml->addAttribute('viewMode', '65592');
$xml->addAttribute('librarySectionID', $catalog->id); self::addCatalogIdentity($xml, $catalog);
$xml->addAttribute('librarySectionUUID', self::uuidFromSubKey($catalog->id));
} }
public static function setSectionAll_Artists(SimpleXMLElement $xml, Catalog $catalog) public static function setSectionAll_Artists(SimpleXMLElement $xml, Catalog $catalog)
@ -615,6 +663,18 @@ class Plex_XML_Data
} }
} }
public static function setSectionAll_Albums(SimpleXMLElement $xml, Catalog $catalog)
{
self::setSectionAllAttributes($xml, $catalog, 'All Albums', 'album');
$albums_ids = Catalog::get_albums(0, 0, array($catalog->id));
foreach ($albums_ids as $album_id) {
$album = new Album($album_id);
$album->format();
self::addAlbum($xml, $album);
}
}
public static function setSectionAll_TVShows(SimpleXMLElement $xml, Catalog $catalog) public static function setSectionAll_TVShows(SimpleXMLElement $xml, Catalog $catalog)
{ {
self::setSectionAllAttributes($xml, $catalog, 'All Shows', 'show'); self::setSectionAllAttributes($xml, $catalog, 'All Shows', 'show');
@ -626,6 +686,36 @@ class Plex_XML_Data
} }
} }
public static function setSectionAll_Seasons(SimpleXMLElement $xml, Catalog $catalog)
{
self::setSectionAllAttributes($xml, $catalog, 'All Seasons', 'season');
$shows = Catalog::get_tvshows(array($catalog->id));
foreach ($shows as $show) {
$seasons = $show->get_seasons();
foreach ($seasons as $season_id) {
$season = new TVShow_Season($season_id);
$season->format();
self::addTVShowSeason($xml, $season);
}
}
}
public static function setSectionAll_Episodes(SimpleXMLElement $xml, Catalog $catalog)
{
self::setSectionAllAttributes($xml, $catalog, 'All Episodes', 'episode');
$shows = Catalog::get_tvshows(array($catalog->id));
foreach ($shows as $show) {
$episodes = $show->get_episodes();
foreach ($episodes as $episode_id) {
$episode = new TVShow_Episode($episode_id);
$episode->format();
self::addEpisode($xml, $episode);
}
}
}
public static function setSectionAll_Movies(SimpleXMLElement $xml, Catalog $catalog) public static function setSectionAll_Movies(SimpleXMLElement $xml, Catalog $catalog)
{ {
self::setSectionAllAttributes($xml, $catalog, 'All Movies', 'movie'); self::setSectionAllAttributes($xml, $catalog, 'All Movies', 'movie');
@ -665,8 +755,7 @@ class Plex_XML_Data
$xml->addAttribute('mixedParents', '1'); $xml->addAttribute('mixedParents', '1');
$xml->addAttribute('viewGroup', 'album'); $xml->addAttribute('viewGroup', 'album');
$xml->addAttribute('viewMode', '65592'); $xml->addAttribute('viewMode', '65592');
$xml->addAttribute('librarySectionID', $catalog->id); self::addCatalogIdentity($xml, $catalog);
$xml->addAttribute('librarySectionUUID', self::uuidFromSubKey($catalog->id));
self::setSectionXContent($xml, $catalog); self::setSectionXContent($xml, $catalog);
$data = array(); $data = array();
@ -799,10 +888,9 @@ class Plex_XML_Data
$tags = Tag::get_top_tags('album', $album->id); $tags = Tag::get_top_tags('album', $album->id);
if (is_array($tags)) { if (is_array($tags)) {
foreach ($tags as $tag_id=>$value) { foreach ($tags as $tag_id=>$tag) {
$tag = new Tag($tag_id);
$xgenre = $xdir->addChild('Genre'); $xgenre = $xdir->addChild('Genre');
$xgenre->addAttribute('tag', $tag->name); $xgenre->addAttribute('tag', $tag['name']);
} }
} }
} }
@ -811,8 +899,6 @@ class Plex_XML_Data
{ {
$id = self::getAlbumId($album->id); $id = self::getAlbumId($album->id);
$xml->addAttribute('allowSync', '1'); $xml->addAttribute('allowSync', '1');
$xml->addAttribute('librarySectionID', $album->catalog_id);
$xml->addAttribute('librarySectionUUID', self::uuidFromkey($album->catalog_id));
$xml->addAttribute('type', 'album'); $xml->addAttribute('type', 'album');
$xml->addAttribute('summary', ''); $xml->addAttribute('summary', '');
$xml->addAttribute('index', '1'); $xml->addAttribute('index', '1');
@ -845,7 +931,9 @@ class Plex_XML_Data
if ($rating_value > 0) { if ($rating_value > 0) {
$xdir->addAttribute('rating', intval($rating_value * 2)); $xdir->addAttribute('rating', intval($rating_value * 2));
} }
$xdir->addAttribute('year', $tvshow->year); if ($tvshow->year) {
$xdir->addAttribute('year', $tvshow->year);
}
//$xdir->addAttribute('duration', ''); //$xdir->addAttribute('duration', '');
//$xdir->addAttribute('originallyAvailableAt', ''); //$xdir->addAttribute('originallyAvailableAt', '');
$xdir->addAttribute('leafCount', $tvshow->episodes); $xdir->addAttribute('leafCount', $tvshow->episodes);
@ -1024,12 +1112,22 @@ class Plex_XML_Data
self::addSongMeta($xdir, $song); self::addSongMeta($xdir, $song);
$time = $song->time * 1000; $time = $song->time * 1000;
$xdir->addAttribute('title', $song->title); $xdir->addAttribute('title', $song->title);
$id = self::getAlbumId($song->id);
$albumid = self::getAlbumId($song->album); $albumid = self::getAlbumId($song->album);
$artistid = self::getAlbumId($song->artist);
$album = new Album($song->album); $album = new Album($song->album);
$xdir->addAttribute('grandparentRatingKey', $artistid);
$xdir->addAttribute('parentRatingKey', $albumid); $xdir->addAttribute('parentRatingKey', $albumid);
$xdir->addAttribute('grandparentKey', self::getMetadataUri($albumid));
$xdir->addAttribute('parentKey', self::getMetadataUri($albumid)); $xdir->addAttribute('parentKey', self::getMetadataUri($albumid));
$xdir->addAttribute('originalTitle', $album->f_name); $xdir->addAttribute('grandparentTitle', $song->f_artist);
$xdir->addAttribute('parentTitle', $song->f_album);
$xdir->addAttribute('originalTitle', $song->f_artist);
$xdir->addAttribute('summary', ''); $xdir->addAttribute('summary', '');
$xdir->addAttribute('art', self::getMetadataUri($id) . '/art/' . $id);
$xdir->addAttribute('grandparentThumb', self::getMetadataUri($artistid) . '/thumb/' . $artistid);
$xdir->addAttribute('parentThumb', self::getMetadataUri($albumid) . '/thumb/' . $albumid);
$xdir->addAttribute('thumb', self::getMetadataUri($albumid) . '/thumb/' . $albumid); // No song art, set album art
$xdir->addAttribute('index', $song->track); $xdir->addAttribute('index', $song->track);
$xdir->addAttribute('duration', $time); $xdir->addAttribute('duration', $time);
$xdir->addAttribute('type', 'track'); $xdir->addAttribute('type', 'track');
@ -1078,10 +1176,13 @@ class Plex_XML_Data
$xvid = self::addVideo($xml, $movie, $details); $xvid = self::addVideo($xml, $movie, $details);
$xvid->addAttribute('type', 'movie'); $xvid->addAttribute('type', 'movie');
$xvid->addAttribute('summary', $movie->summary); $xvid->addAttribute('summary', $movie->summary);
if (isset($xml['year'])) { $xvid->addAttribute('originalTitle', $movie->original_name);
$xml['year'] = $movie->year; if ($movie->year) {
} else { if (isset($xml['year'])) {
$xvid->addAttribute('year', $movie->year); $xml['year'] = $movie->year;
} else {
$xvid->addAttribute('year', $movie->year);
}
} }
return $xvid; return $xvid;
} }
@ -1119,7 +1220,10 @@ class Plex_XML_Data
$xvid->addAttribute('key', self::getMetadataUri($id)); $xvid->addAttribute('key', self::getMetadataUri($id));
$xvid->addAttribute('title', $video->f_title); $xvid->addAttribute('title', $video->f_title);
if ($video->release_date) { if ($video->release_date) {
$xvid->addAttribute('year', date('Y', $video->release_date)); $year = date('Y', $video->release_date);
if ($year) {
$xvid->addAttribute('year', $year);
}
$xvid->addAttribute('originallyAvailableAt', $video->f_release_date); $xvid->addAttribute('originallyAvailableAt', $video->f_release_date);
} }
$rating = new Rating($video->id, "video"); $rating = new Rating($video->id, "video");
@ -1164,6 +1268,15 @@ class Plex_XML_Data
<Director tag="Terry McDonough" /> <Director tag="Terry McDonough" />
*/ */
$tags = Tag::get_top_tags('video', $video->id);
if (is_array($tags)) {
foreach ($tags as $tag_id=>$tag) {
$xgenre = $xvid->addChild('Genre');
$xgenre->addAttribute('id', $tag['id']);
$xgenre->addAttribute('tag', $tag['name']);
}
}
if ($details) { if ($details) {
// Subtitles // Subtitles
$subtitles = $video->get_subtitles(); $subtitles = $video->get_subtitles();
@ -1225,18 +1338,23 @@ class Plex_XML_Data
self::addPlaylistsItems($xml, $items); self::addPlaylistsItems($xml, $items);
} }
private static function addPlaylistsItems(SimpleXMLElement $xml, $items, $attr = array()) private static function addPlaylistsItems(SimpleXMLElement $xml, $items, $itemIDName = 'playlistItemID')
{ {
foreach ($items as $item) { foreach ($items as $item) {
$xitem = null;
if ($item['object_type'] == 'song') { if ($item['object_type'] == 'song') {
$song = new Song($item['object_id']); $media = new Song($item['object_id']);
$song->format(); $media->format();
$xitem = self::addSong($xml, $song); $xitem = self::addSong($xml, $media);
if (isset($item['track'])) { } elseif ($item['object_type'] == 'video') {
$xitem->addAttribute('playlistItemID', $item['track']); $media = Video::create_from_id($item['object_id']);
} $media->format();
foreach ($attr as $key => $value) { $xitem = self::addVideoExt($xml, $media);
$xitem->addAttribute($key, $value); }
if ($xitem != null) {
if (isset($item['track_id'])) {
$xitem->addAttribute($itemIDName, $item['track_id']);
} }
} }
} }
@ -1244,108 +1362,23 @@ class Plex_XML_Data
public static function setPlayQueue(SimpleXMLElement $xml, $type, $playlistID, $uri, $key, $shuffle) public static function setPlayQueue(SimpleXMLElement $xml, $type, $playlistID, $uri, $key, $shuffle)
{ {
// We don't really support the queue and only have one item, always
$xml->addAttribute('playQueueID', '1');
$xml->addAttribute('playQueueSelectedItemID', '1');
$xml->addAttribute('playQueueSelectedItemOffset', '0');
$xml->addAttribute('playQueueVersion', '1');
$c = 0;
$GLOBALS['user']->playlist->clear(); $GLOBALS['user']->playlist->clear();
$id = 0; $id = 0;
if (!empty($key)) { if (!empty($key)) {
$id = self::getKeyFromMetadataUri($key); $id = self::getKeyFromMetadataUri($key);
} elseif (!empty($uri)) { } elseif (!empty($uri)) {
$puri = parse_url($uri); $key = self::getKeyFromFullUri($uri);
if ($puri['scheme'] == 'library') { $id = self::getKeyFromMetadataUri($key);
// We ignore library uuid (= $puri['host'])
$ppath = explode('/', $puri['path']);
if (count($ppath) == 3) {
if ($ppath['1'] == 'item') {
$key = rawurldecode($ppath[2]);
$id = self::getKeyFromMetadataUri($key);
}
}
}
} }
$plmedias = array(); $plmedias = array();
if ($id) { if ($id) {
if ($type == 'audio') { if ($type == 'audio' || $type == 'video') {
if (self::isSong($id) || self::isTrack($id)) { $item = self::createLibraryItem($id);
$media = new Song(self::getAmpacheId($id)); if ($item != null) {
if ($media->id) { $plmedias = $item->get_medias();
$media->format();
$plmedias[] = array('object_type' => 'song', 'object_id' => $media->id);
$xitem = self::addSong($xml, $media);
$xitem->addAttribute('playQueueItemID', '1');
$c++;
}
} elseif (self::isAlbum($id)) {
$album = new Album(self::getAmpacheId($id));
if ($album->id) {
$song_ids = $album->get_songs();
foreach ($song_ids as $song_id) {
$media = new Song($song_id);
$media->format();
$plmedias[] = array('object_type' => 'song', 'object_id' => $media->id);
$xitem = self::addSong($xml, $media);
$xitem->addAttribute('playQueueItemID', '1');
$c++;
}
}
} elseif (self::isArtist($id)) {
$artist = new Artist(self::getAmpacheId($id));
if ($artist->id) {
$song_ids = $artist->get_songs();
foreach ($song_ids as $song_id) {
$media = new Song($song_id);
$media->format();
$plmedias[] = array('object_type' => 'song', 'object_id' => $media->id);
$xitem = self::addSong($xml, $media);
$xitem->addAttribute('playQueueItemID', '1');
$c++;
}
}
}
} elseif ($type == 'video') {
if (self::isVideo($id)) {
$media = Video::create_from_id(self::getAmpacheId($id));
if ($media->id) {
$media->format();
$plmedias[] = array('object_type' => 'video', 'object_id' => $media->id);
$xitem = self::addVideoExt($xml, $media);
$xitem->addAttribute('playQueueItemID', '1');
$c++;
}
} elseif (self::isTVShow($id)) {
$tvshow = new TVShow(self::getAmpacheId($id));
if ($tvshow->id) {
$medias = $tvshow->get_medias();
$plmedias = array_merge($plmedias, $items);
foreach ($medias as $mediad) {
$media = Video::create_from_id($mediad['object_id']);
$media->format();
$xitem = self::addVideoExt($xml, $media);
$xitem->addAttribute('playQueueItemID', '1');
$c++;
}
}
} elseif (self::isTVShowSeason($id)) {
$season = new TVShow_Season(self::getAmpacheId($id));
if ($season->id) {
$medias = $season->get_medias();
$plmedias = array_merge($plmedias, $items);
foreach ($medias as $mediad) {
$media = Video::create_from_id($mediad['object_id']);
$media->format();
$xitem = self::addVideoExt($xml, $media);
$xitem->addAttribute('playQueueItemID', '1');
$c++;
}
}
} }
} }
} else { } else {
@ -1353,50 +1386,39 @@ class Plex_XML_Data
if (self::isPlaylist($playlistID)) { if (self::isPlaylist($playlistID)) {
$playlist = new Playlist(self::getAmpacheId($playlistID)); $playlist = new Playlist(self::getAmpacheId($playlistID));
if ($shuffle) { if ($shuffle) {
$items = $playlist->get_random_items(); $plmedias = $playlist->get_random_items();
} else { } else {
$items = $playlist->get_items(); $plmedias = $playlist->get_items();
} }
$plmedias = array_merge($plmedias, $items);
$c = count($items);
self::addPlaylistsItems($xml, $items, array('playQueueItemID' => '1'));
} }
} }
if (count($plmedias)) { $GLOBALS['user']->playlist->add_medias($plmedias);
$GLOBALS['user']->playlist->add_medias($plmedias); self::setTmpPlayQueue($xml, 1);
}
$xml->addAttribute('playQueueTotalCount', $c);
} }
public static function setTmpPlayQueue(SimpleXMLElement $xml, $playlistID) public static function setTmpPlayQueue(SimpleXMLElement $xml, $playlistID)
{ {
// We only support one queue at time
if ($playlistID != 1) { if ($playlistID != 1) {
debug_event('plex', 'Unsupported playlist, it should be 1.', 3); debug_event('plex', 'Unsupported playlist, it should be 1.', 3);
} else { } else {
$xml->addAttribute('playQueueID', '1'); $xml->addAttribute('playQueueID', '1');
$xml->addAttribute('playQueueSelectedItemID', '1');
$xml->addAttribute('playQueueSelectedItemOffset', '0');
$xml->addAttribute('playQueueVersion', '1'); $xml->addAttribute('playQueueVersion', '1');
$c = 0;
$items = $GLOBALS['user']->playlist->get_items(); $items = $GLOBALS['user']->playlist->get_items();
print_r($items); $c = count($items);
foreach ($items as $key => $item) { if ($c > 0) {
if ($item['object_type'] == 'song') { self::addPlaylistsItems($xml, $items, 'playQueueItemID');
$media = new Song($item['object_id']);
$media->format(); // TODO: This should be the real selected item.
$xitem = self::addSong($xml, $media); // But we're missing this information in Ampache playlist
$xitem->addAttribute('playQueueItemID', $key); $currentIndex = 0;
$c++; $currentItem = $items[$currentIndex];
} else { if (isset($currentItem['track_id'])) {
$media = Video::create_from_id($item['object_id']); $xml->addAttribute('playQueueSelectedItemID', $currentItem['track_id']);
$media->format();
$xitem = self::addVideoExt($xml, $media);
$xitem->addAttribute('playQueueItemID', $key);
$c++;
} }
$xml->addAttribute('playQueueSelectedItemOffset', $currentIndex);
} }
$xml->addAttribute('playQueueTotalCount', $c); $xml->addAttribute('playQueueTotalCount', $c);
@ -1500,16 +1522,12 @@ class Plex_XML_Data
public static function setSysMovieAgents(SimpleXMLElement $xml) public static function setSysMovieAgents(SimpleXMLElement $xml)
{ {
self::addNoneAgent($xml, 'Personal Media'); self::addNoneAgent($xml, 'Ampache Media Movies');
// We should check plug-in availability and allow configuration here
self::addAgent($xml, "The Movie Database", false, "com.plexapp.agents.themoviedb", true, "en,cs,da,de,el,es,fi,fr,he,hr,hu,it,lv,nl,no,pl,pt,ru,sk,sv,th,tr,vi,zh,ko");
} }
public static function setSysTVShowAgents(SimpleXMLElement $xml) public static function setSysTVShowAgents(SimpleXMLElement $xml)
{ {
self::addNoneAgent($xml, 'Personal Media Shows'); self::addNoneAgent($xml, 'Ampache Media Series');
// We should check plug-in availability and allow configuration here
self::addAgent($xml, "TheTVDB", false, "com.plexapp.agents.thetvdb", true, "en,fr,zh,sv,no,da,fi,nl,de,it,es,pl,hu,el,tr,ru,he,ja,pt,cs,ko,sl");
} }
public static function setSysPhotoAgents(SimpleXMLElement $xml) public static function setSysPhotoAgents(SimpleXMLElement $xml)
@ -1519,7 +1537,7 @@ class Plex_XML_Data
public static function setSysMusicAgents($xml, $category = 'Artists') public static function setSysMusicAgents($xml, $category = 'Artists')
{ {
self::addNoneAgent($xml, 'Personal Media ' . $category); self::addNoneAgent($xml, 'Ampache Media ' . $category);
//self::addAgent($xml, 'Last.fm', '1', 'com.plexapp.agents.lastfm', 'true', 'en,sv,fr,es,de,pl,it,pt,ja,tr,ru,zh'); //self::addAgent($xml, 'Last.fm', '1', 'com.plexapp.agents.lastfm', 'true', 'en,sv,fr,es,de,pl,it,pt,ja,tr,ru,zh');
} }
@ -1530,6 +1548,10 @@ class Plex_XML_Data
return 'movie'; return 'movie';
case Plex_XML_Data::PLEX_TVSHOW: case Plex_XML_Data::PLEX_TVSHOW:
return 'tvshow'; return 'tvshow';
case Plex_XML_Data::PLEX_SEASON:
return 'season';
case Plex_XML_Data::PLEX_EPISODE:
return 'episode';
case Plex_XML_Data::PLEX_ARTIST: case Plex_XML_Data::PLEX_ARTIST:
return 'artist'; return 'artist';
case Plex_XML_Data::PLEX_ALBUM: case Plex_XML_Data::PLEX_ALBUM:
@ -1623,10 +1645,23 @@ class Plex_XML_Data
$setting->addAttribute('group', $group); $setting->addAttribute('group', $group);
} }
public static function setMusicScanners(SimpleXMLElement $xml) public static function setScanners(SimpleXMLElement $xml, $type)
{ {
$scanner = $xml->addChild('Scanner'); $scanner = $xml->addChild('Scanner');
$scanner->addAttribute('name', 'Plex Music Scanner'); switch ($type) {
case self::PLEX_ALBUM:
case self::PLEX_ARTIST:
$scanner->addAttribute('name', 'Ampache Music Scanner');
break;
case self::PLEX_TVSHOW:
case self::PLEX_SEASON:
case self::PLEX_EPISODE:
$scanner->addAttribute('name', 'Ampache Series Scanner');
break;
case self::PLEX_MOVIE:
$scanner->addAttribute('name', 'Ampache Movie Scanner');
break;
}
} }
public static function createAppStore() public static function createAppStore()
@ -1724,4 +1759,59 @@ class Plex_XML_Data
$dir->addAttribute('title', $title); $dir->addAttribute('title', $title);
$dir->addAttribute('path', $path); $dir->addAttribute('path', $path);
} }
public static function addCatalogIdentity(SimpleXMLElement $xml, Catalog $catalog)
{
$xml->addAttribute('librarySectionID', $catalog->id);
$xml->addAttribute('librarySectionTitle', $catalog->name);
$xml->addAttribute('librarySectionUUID', self::uuidFromkey($catalog->id));
}
public static function getPhotoKind($type)
{
switch ($type) {
case 'thumb':
case 'thumbs':
return 'preview';
case 'art':
case 'arts':
return 'art';
case 'background':
case 'backgrounds':
return 'background';
case 'poster':
case 'posters':
default:
return 'default';
}
}
public static function getPhotoPlexKind($type)
{
switch ($type) {
case 'preview':
return 'thumb';
case 'art':
return 'art';
case 'background':
return 'background';
case 'default':
default:
return 'poster';
}
}
public static function addPhotos(SimpleXMLElement $xml, $id, $kind = 'default')
{
self::addPhoto($xml, $id, $kind);
}
public static function addPhoto(SimpleXMLElement $xml, $id, $kind = 'default')
{
$xart = $xml->addChild('Photo');
$uri = self::getMetadataUri($id) . '/' . self::getPhotoPlexKind($kind) . '/' . $id;
$xart->addAttribute('key', $uri);
$xart->addAttribute('ratingKey', $uri);
$xart->addAttribute('thumb', $uri);
}
} }

View file

@ -1368,6 +1368,17 @@ class Song extends database_object implements media, library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array($this->catalog);
}
/** /**
* Get item's owner. * Get item's owner.
* @return int|null * @return int|null

View file

@ -248,6 +248,17 @@ class Song_Preview extends database_object implements media, playable_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array();
}
/** /**
* play_url * play_url
* This function takes all the song information and correctly formats a * This function takes all the song information and correctly formats a

View file

@ -669,6 +669,17 @@ class Tag extends database_object implements library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array();
}
public function get_user_owner() public function get_user_owner()
{ {
return null; return null;

View file

@ -146,11 +146,13 @@ class Tmp_Playlist extends database_object
/* Define the array */ /* Define the array */
$items = array(); $items = array();
$i = 1;
while ($results = Dba::fetch_assoc($db_results)) { while ($results = Dba::fetch_assoc($db_results)) {
$key = $results['id']; $items[] = array(
$items[$key] = array(
'object_type' => $results['object_type'], 'object_type' => $results['object_type'],
'object_id' => $results['object_id'] 'object_id' => $results['object_id'],
'track_id' => $results['id'],
'track' => $i++,
); );
} }

View file

@ -29,6 +29,7 @@ class TVShow extends database_object implements library_item
public $summary; public $summary;
public $year; public $year;
public $catalog_id;
public $tags; public $tags;
public $f_tags; public $f_tags;
public $episodes; public $episodes;
@ -118,7 +119,7 @@ class TVShow extends database_object implements library_item
$sql .= "LEFT JOIN `video` ON `video`.`id` = `tvshow_episode`.`id` "; $sql .= "LEFT JOIN `video` ON `video`.`id` = `tvshow_episode`.`id` ";
$sql .= "LEFT JOIN `catalog` ON `catalog`.`id` = `video`.`catalog` "; $sql .= "LEFT JOIN `catalog` ON `catalog`.`id` = `video`.`catalog` ";
} }
$sql .= "LEFT JOIN `tvshow_season` ON `tvshow_season`.`tvshow` = `tvshow_episode`.`season` "; $sql .= "LEFT JOIN `tvshow_season` ON `tvshow_season`.`id` = `tvshow_episode`.`season` ";
$sql .= "WHERE `tvshow_season`.`tvshow`='" . Dba::escape($this->id) . "' "; $sql .= "WHERE `tvshow_season`.`tvshow`='" . Dba::escape($this->id) . "' ";
if (AmpConfig::get('catalog_disable')) { if (AmpConfig::get('catalog_disable')) {
$sql .= "AND `catalog`.`enabled` = '1' "; $sql .= "AND `catalog`.`enabled` = '1' ";
@ -145,8 +146,9 @@ class TVShow extends database_object implements library_item
if (parent::is_cached('tvshow_extra', $this->id) ) { if (parent::is_cached('tvshow_extra', $this->id) ) {
$row = parent::get_from_cache('tvshow_extra', $this->id); $row = parent::get_from_cache('tvshow_extra', $this->id);
} else { } else {
$sql = "SELECT COUNT(`tvshow_episode`.`id`) AS `episode_count` FROM `tvshow_season` " . $sql = "SELECT COUNT(`tvshow_episode`.`id`) AS `episode_count`, `video`.`catalog` as `catalog_id` FROM `tvshow_season` " .
"LEFT JOIN `tvshow_episode` ON `tvshow_episode`.`season` = `tvshow_season`.`id` " . "LEFT JOIN `tvshow_episode` ON `tvshow_episode`.`season` = `tvshow_season`.`id` " .
"LEFT JOIN `video` ON `video`.`id` = `tvshow_episode`.`id` " .
"WHERE `tvshow_season`.`tvshow` = ?"; "WHERE `tvshow_season`.`tvshow` = ?";
$db_results = Dba::read($sql, array($this->id)); $db_results = Dba::read($sql, array($this->id));
$row = Dba::fetch_assoc($db_results); $row = Dba::fetch_assoc($db_results);
@ -163,6 +165,7 @@ class TVShow extends database_object implements library_item
/* Set Object Vars */ /* Set Object Vars */
$this->episodes = $row['episode_count']; $this->episodes = $row['episode_count'];
$this->seasons = $row['season_count']; $this->seasons = $row['season_count'];
$this->catalog_id = $row['catalog_id'];
return $row; return $row;
@ -229,6 +232,17 @@ class TVShow extends database_object implements library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array($this->catalog_id);
}
public function get_user_owner() public function get_user_owner()
{ {
return null; return null;
@ -305,10 +319,13 @@ class TVShow extends database_object implements library_item
{ {
// Save our current ID // Save our current ID
$current_id = $this->id; $current_id = $this->id;
$name = $data['name'] ?: $this->name;
$year = $data['year'] ?: $this->year;
$summary = $data['summary'] ?: $this->summary;
// Check if name is different than current name // Check if name is different than current name
if ($this->name != $data['name'] || $this->year != $data['year']) { if ($this->name != $name || $this->year != $year) {
$tvshow_id = self::check($data['name'], $data['year'], true); $tvshow_id = self::check($name, $year, true);
// If it's changed we need to update // If it's changed we need to update
if ($tvshow_id != $this->id && $tvshow_id != null) { if ($tvshow_id != $this->id && $tvshow_id != null) {
@ -321,18 +338,25 @@ class TVShow extends database_object implements library_item
} // end if it changed } // end if it changed
} }
$trimmed = Catalog::trim_prefix(trim($data['name'])); $trimmed = Catalog::trim_prefix(trim($name));
$name = $trimmed['string']; $name = $trimmed['string'];
$prefix = $trimmed['prefix']; $prefix = $trimmed['prefix'];
$sql = 'UPDATE `tvshow` SET `name` = ?, `prefix` = ?, `year` = ?, `summary` = ? WHERE `id` = ?'; $sql = 'UPDATE `tvshow` SET `name` = ?, `prefix` = ?, `year` = ?, `summary` = ? WHERE `id` = ?';
Dba::write($sql, array($name, $prefix, $data['year'], $data['summary'], $current_id)); Dba::write($sql, array($name, $prefix, $year, $summary, $current_id));
$this->name = $name;
$this->prefix = $prefix;
$this->year = $year;
$this->summary = $summary;
$override_childs = false; $override_childs = false;
if ($data['apply_childs'] == 'checked') { if ($data['apply_childs'] == 'checked') {
$override_childs = true; $override_childs = true;
} }
$this->update_tags($data['edit_tags'], $override_childs, $current_id); if (isset($data['edit_tags'])) {
$this->update_tags($data['edit_tags'], $override_childs, $current_id);
}
return $current_id; return $current_id;

View file

@ -122,10 +122,19 @@ class TVShow_Episode extends Video
public function update(array $data) public function update(array $data)
{ {
parent::update($data); parent::update($data);
$sql = "UPDATE `tvshow_episode` SET `original_name` = ?, `season` = ?, `episode_number` = ?, `summary` = ? WHERE `id` = ?";
Dba::write($sql, array($data['original_name'], $data['tvshow_season'], $data['tvshow_episode'], $data['summary'], $this->id));
Tag::update_tag_list($data['edit_tags'], 'episode', $this->id); $original_name = $data['original_name'] ?: $this->original_name;
$tvshow_season = $data['tvshow_season'] ?: $this->season;
$tvshow_episode = $data['tvshow_episode'] ?: $this->episode_number;
$summary = $data['summary'] ?: $summary;
$sql = "UPDATE `tvshow_episode` SET `original_name` = ?, `season` = ?, `episode_number` = ?, `summary` = ? WHERE `id` = ?";
Dba::write($sql, array($original_name, $tvshow_season, $tvshow_episode, $summary, $this->id));
$this->original_name = $originale_name;
$this->tvshow_season = $tvshow_season;
$this->tvshow_episode = $tvshow_episode;
$this->summary = $summary;
return $this->id; return $this->id;

View file

@ -27,6 +27,7 @@ class TVShow_Season extends database_object implements library_item
public $season_number; public $season_number;
public $tvshow; public $tvshow;
public $catalog_id;
public $episodes; public $episodes;
public $f_name; public $f_name;
public $f_tvshow; public $f_tvshow;
@ -107,7 +108,8 @@ class TVShow_Season extends database_object implements library_item
if (parent::is_cached('tvshow_extra', $this->id) ) { if (parent::is_cached('tvshow_extra', $this->id) ) {
$row = parent::get_from_cache('tvshow_extra', $this->id); $row = parent::get_from_cache('tvshow_extra', $this->id);
} else { } else {
$sql = "SELECT COUNT(`tvshow_episode`.`id`) AS `episode_count` FROM `tvshow_episode` " . $sql = "SELECT COUNT(`tvshow_episode`.`id`) AS `episode_count`, `video`.`catalog` as `catalog_id` FROM `tvshow_episode` " .
"LEFT JOIN `video` ON `video`.`id` = `tvshow_episode`.`id` " .
"WHERE `tvshow_episode`.`season` = ?"; "WHERE `tvshow_episode`.`season` = ?";
$db_results = Dba::read($sql, array($this->id)); $db_results = Dba::read($sql, array($this->id));
@ -117,6 +119,7 @@ class TVShow_Season extends database_object implements library_item
/* Set Object Vars */ /* Set Object Vars */
$this->episodes = $row['episode_count']; $this->episodes = $row['episode_count'];
$this->catalog_id = $row['catalog_id'];
return $row; return $row;
@ -190,6 +193,17 @@ class TVShow_Season extends database_object implements library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array($this->catalog_id);
}
public function get_user_owner() public function get_user_owner()
{ {
return null; return null;

View file

@ -344,6 +344,17 @@ class Video extends database_object implements media, library_item
return $medias; return $medias;
} }
/**
* get_catalogs
*
* Get all catalog ids related to this item.
* @return int[]
*/
public function get_catalogs()
{
return array($this->catalog);
}
/** /**
* Get item's owner. * Get item's owner.
* @return int|null * @return int|null
@ -576,11 +587,23 @@ class Video extends database_object implements media, library_item
*/ */
public function update(array $data) public function update(array $data)
{ {
$f_release_date = $data['release_date']; if (isset($data['release_date'])) {
$release_date = strtotime($f_release_date); $f_release_date = $data['release_date'];
$release_date = strtotime($f_release_date);
} else {
$release_date = $this->release_date;
}
$title = $data['title'] ?: $this->title;
$sql = "UPDATE `video` SET `title` = ?, `release_date` = ? WHERE `id` = ?"; $sql = "UPDATE `video` SET `title` = ?, `release_date` = ? WHERE `id` = ?";
Dba::write($sql, array($data['title'], $release_date, $this->id)); Dba::write($sql, array($title, $release_date, $this->id));
if (isset($data['edit_tags'])) {
Tag::update_tag_list($data['edit_tags'], 'video', $this->id);
}
$this->title = $title;
$this->release_date = $release_date;
return $this->id; return $this->id;