mirror of
https://github.com/jellyfin/jellyfin-web.git
synced 2024-11-18 03:18:19 -07:00
643 lines
17 KiB
JavaScript
643 lines
17 KiB
JavaScript
(function () {
|
|
|
|
function getLocalMediaSource(serverId, itemId) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
// android
|
|
if (window.ApiClientBridge) {
|
|
var json = ApiClientBridge.getLocalMediaSource(serverId, itemId);
|
|
|
|
if (json) {
|
|
deferred.resolveWith(null, [JSON.parse(json)]);
|
|
}
|
|
else {
|
|
deferred.resolveWith(null, [null]);
|
|
}
|
|
return deferred.promise();
|
|
}
|
|
|
|
getLocalItem(itemId, serverId).done(function (localItem) {
|
|
|
|
if (localItem && localItem.MediaSources.length) {
|
|
|
|
var mediaSource = localItem.MediaSources[0];
|
|
|
|
fileExists(mediaSource.Path).done(function (exists) {
|
|
|
|
if (exists) {
|
|
deferred.resolveWith(null, [mediaSource]);
|
|
}
|
|
else {
|
|
deferred.resolveWith(null, [null]);
|
|
}
|
|
|
|
}).fail(getOnFail(deferred));
|
|
return;
|
|
}
|
|
|
|
deferred.resolveWith(null, [null]);
|
|
|
|
}).fail(getOnFail(deferred));
|
|
return deferred.promise();
|
|
}
|
|
|
|
function getCameraPhotos() {
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
if (window.CameraRoll) {
|
|
|
|
var photos = [];
|
|
|
|
CameraRoll.getPhotos(function (result) {
|
|
photos.push(result);
|
|
});
|
|
|
|
setTimeout(function () {
|
|
|
|
// clone the array in case the callback is still getting called
|
|
Logger.log('Found ' + photos.length + ' in camera roll');
|
|
|
|
deferred.resolveWith(null, [photos]);
|
|
|
|
}, 2000);
|
|
|
|
} else {
|
|
deferred.resolveWith(null, [[]]);
|
|
}
|
|
return deferred.promise();
|
|
}
|
|
|
|
var offlineUserDatabase;
|
|
function getOfflineUserdb(callback) {
|
|
|
|
if (offlineUserDatabase) {
|
|
callback(offlineUserDatabase);
|
|
return;
|
|
}
|
|
|
|
// Create/open database
|
|
offlineUserDatabase = window.sqlitePlugin.openDatabase({ name: "offlineusers.db" });
|
|
|
|
offlineUserDatabase.transaction(function (tx) {
|
|
|
|
tx.executeSql('CREATE TABLE IF NOT EXISTS users (id text primary key, data text)');
|
|
tx.executeSql('create index if not exists idx_users on users(id)');
|
|
|
|
callback(offlineUserDatabase);
|
|
});
|
|
}
|
|
|
|
function saveOfflineUser(user) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getOfflineUserdb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
tx.executeSql("REPLACE INTO offlineusers (id, data) VALUES (?,?)", [user.Id, JSON.stringify(user)], function (tx, res) {
|
|
|
|
deferred.resolve();
|
|
}, function (e) {
|
|
deferred.reject();
|
|
});
|
|
});
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function deleteOfflineUser(id) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getOfflineUserdb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
tx.executeSql("DELETE from offlineusers where id=?", [user.Id], function (tx, res) {
|
|
|
|
deferred.resolve();
|
|
}, function (e) {
|
|
deferred.reject();
|
|
});
|
|
});
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
var offlineActionsDatabase;
|
|
function getOfflineActionsDb(callback) {
|
|
|
|
if (offlineActionsDatabase) {
|
|
callback(offlineActionsDatabase);
|
|
return;
|
|
}
|
|
|
|
// Create/open database
|
|
offlineActionsDatabase = window.sqlitePlugin.openDatabase({ name: "offlineactions.db" });
|
|
|
|
offlineActionsDatabase.transaction(function (tx) {
|
|
|
|
tx.executeSql('CREATE TABLE IF NOT EXISTS offlineactions (Id text primary key, ServerId text not null, Json text not null)');
|
|
tx.executeSql('create index if not exists idx_offlineactions on offlineactions(id)');
|
|
|
|
callback(offlineActionsDatabase);
|
|
});
|
|
}
|
|
|
|
function getOfflineActions(serverId) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getOfflineActionsDb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
tx.executeSql("SELECT json from offlineactions where ServerId=?", [serverId], function (tx, res) {
|
|
|
|
var actions = [];
|
|
for (var i = 0, length = res.rows.length; i < length; i++) {
|
|
actions.push(JSON.parse(res.rows.item(i).json));
|
|
}
|
|
|
|
deferred.resolveWith(null, [actions]);
|
|
|
|
}, function (e) {
|
|
deferred.reject();
|
|
});
|
|
});
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function deleteOfflineActions(actions) {
|
|
|
|
var ids = actions.map(function (a) { return "'" + a.Id + "'"; }).join(',');
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getOfflineActionsDb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
tx.executeSql("DELETE from offlineactions where Id in (" + ids + ")", [], function (tx, res) {
|
|
|
|
deferred.resolve();
|
|
|
|
}, function (e) {
|
|
deferred.reject();
|
|
});
|
|
});
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
var offlineItemsDatabase;
|
|
function getOfflineItemsDb(callback) {
|
|
|
|
if (offlineItemsDatabase) {
|
|
callback(offlineItemsDatabase);
|
|
return;
|
|
}
|
|
|
|
// Create/open database
|
|
offlineItemsDatabase = window.sqlitePlugin.openDatabase({ name: "offlineitems.db" });
|
|
|
|
offlineItemsDatabase.transaction(function (tx) {
|
|
|
|
tx.executeSql('CREATE TABLE IF NOT EXISTS Items ( Id text primary key, ItemId text not null, ItemType text not null, MediaType text, ServerId text not null, LocalPath text not null, UserIdsWithAccess text, AlbumId text, AlbumName text, SeriesId text, SeriesName text, Json text not null)');
|
|
tx.executeSql('create index if not exists idx_items on Items(Id)');
|
|
|
|
tx.executeSql('CREATE TABLE IF NOT EXISTS AlbumArtists ( Id text not null, Name text not null, ItemId text not null)');
|
|
tx.executeSql('create index if not exists idx_AlbumArtists on AlbumArtists(id)');
|
|
|
|
callback(offlineItemsDatabase);
|
|
});
|
|
}
|
|
|
|
function getServerItemIds(serverId) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getOfflineItemsDb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
tx.executeSql("SELECT ItemId from Items where ServerId=?", [serverId], function (tx, res) {
|
|
|
|
var itemIds = [];
|
|
for (var i = 0, length = res.rows.length; i < length; i++) {
|
|
itemIds.push(res.rows.item(i).ItemId);
|
|
}
|
|
|
|
deferred.resolveWith(null, [itemIds]);
|
|
|
|
}, function (e) {
|
|
deferred.reject();
|
|
});
|
|
});
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function getLocalItem(itemId, serverId) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getOfflineItemsDb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
tx.executeSql("SELECT Json from Items where itemId=? AND serverId=?", [itemId, serverId], function (tx, res) {
|
|
|
|
if (res.rows.length) {
|
|
|
|
var localItem = JSON.parse(res.rows.item(0).Json);
|
|
|
|
deferred.resolveWith(null, [item]);
|
|
}
|
|
else {
|
|
deferred.resolveWith(null, [null]);
|
|
}
|
|
|
|
}, function (e) {
|
|
deferred.reject();
|
|
});
|
|
});
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function addOrUpdateLocalItem(item) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getOfflineItemsDb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
var values = [item.Id, item.ItemId, item.Item.Type, item.Item.MediaType, item.ServerId, item.LocalPath, item.UserIdsWithAccess.join(','), item.Item.AlbumId, item.Item.AlbumName, item.Item.SeriesId, item.Item.SeriesName, JSON.stringify(item)];
|
|
tx.executeSql("REPLACE INTO Items (Id, ItemId, ItemType, MediaType, ServerId, LocalPath, UserIdsWithAccess, AlbumId, AlbumName, SeriesId, SeriesName, Json) VALUES (?,?,?,?,?,?,?,?,?,?,?,?)", values);
|
|
});
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function removeLocalItem(itemId, serverId) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getLocalItem(itemId, serverId).done(function (item) {
|
|
|
|
getOfflineItemsDb(function (db) {
|
|
|
|
db.transaction(function (tx) {
|
|
|
|
tx.executeSql("DELETE from Items where itemId=? AND serverId=?", [itemId, serverId]);
|
|
|
|
var files = item.AdditionalFiles || [];
|
|
files.push(item.LocalPath);
|
|
|
|
deleteFiles(files).done(function () {
|
|
|
|
deferred.resolve();
|
|
|
|
}).fail(getOnFail(deferred));
|
|
|
|
});
|
|
});
|
|
|
|
}).fail(getOnFail(deferred));
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function deleteFiles(files) {
|
|
var deferred = DeferredBuilder.Deferred();
|
|
deleteNextFile(files, 0, deferred);
|
|
return deferred.promise();
|
|
}
|
|
|
|
function deleteNextFile(files, index, deferred) {
|
|
|
|
if (index >= files.length) {
|
|
deferred.resolve();
|
|
return;
|
|
}
|
|
|
|
deleteFile(file).done(function () {
|
|
deleteNextFile(files, index + 1, deferred);
|
|
}).fail(function () {
|
|
deleteNextFile(files, index + 1, deferred);
|
|
});
|
|
}
|
|
|
|
function deleteFile(path) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
Logger.log('Deleting ' + path);
|
|
resolveLocalFileSystemURL(path, function (fileEntry) {
|
|
|
|
fileEntry.remove(function () {
|
|
Logger.log('Deleted ' + path);
|
|
deferred.resolve();
|
|
}, function () {
|
|
|
|
Logger.log('Error deleting ' + path);
|
|
deferred.reject();
|
|
});
|
|
|
|
}, function () {
|
|
|
|
Logger.log('Skipping deletion because file does not exist: ' + path);
|
|
deferred.resolve();
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function createLocalItem(libraryItem, serverInfo, originalFileName) {
|
|
|
|
var path = getDirectoryPath(libraryItem, serverInfo);
|
|
path.push(getLocalFileName(libraryItem, originalFileName));
|
|
|
|
var item = {};
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getFileSystem().done(function (fileSystem) {
|
|
|
|
var localPath = trimEnd(fileSystem.root.toURL()) + "/" + path.join('/');
|
|
|
|
item.LocalPath = localPath;
|
|
|
|
for (var i = 0, length = libraryItem.MediaSources.length; i < length; i++) {
|
|
|
|
var mediaSource = libraryItem.MediaSources[i];
|
|
mediaSource.Path = localPath;
|
|
mediaSource.Protocol = 'File';
|
|
}
|
|
|
|
item.ServerId = serverInfo.Id;
|
|
item.Item = libraryItem;
|
|
item.ItemId = libraryItem.Id;
|
|
item.Id = getLocalId(item.ServerId, item.ItemId);
|
|
deferred.resolveWith(null, [item]);
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function trimEnd(str) {
|
|
|
|
var charEnd = '/';
|
|
|
|
if (str.charAt(str.length - 1) == charEnd) {
|
|
|
|
str = str.substring(0, str.length - 1);
|
|
}
|
|
|
|
return str;
|
|
}
|
|
|
|
function getDirectoryPath(item, server) {
|
|
|
|
var parts = [];
|
|
parts.push("emby");
|
|
parts.push("sync");
|
|
parts.push(server.Name);
|
|
|
|
if (item.Type == "Episode") {
|
|
parts.push("TV");
|
|
parts.push(item.SeriesName);
|
|
|
|
if (item.SeasonName) {
|
|
parts.push(item.SeasonName);
|
|
}
|
|
}
|
|
else if (item.MediaType == 'Video') {
|
|
parts.push("Videos");
|
|
parts.push(item.Name);
|
|
}
|
|
else if (item.MediaType == 'Audio') {
|
|
parts.push("Music");
|
|
|
|
if (item.AlbumArtist) {
|
|
parts.push(item.AlbumArtist);
|
|
}
|
|
|
|
if (item.Album) {
|
|
parts.push(item.Album);
|
|
}
|
|
}
|
|
else if (item.MediaType == 'Photo') {
|
|
parts.push("Photos");
|
|
|
|
if (item.Album) {
|
|
parts.push(item.Album);
|
|
}
|
|
}
|
|
|
|
return parts.map(getValidFileName);
|
|
}
|
|
|
|
function getLocalFileName(libraryItem, originalFileName) {
|
|
|
|
var filename = originalFileName || libraryItem.Name;
|
|
|
|
return getValidFileName(filename);
|
|
}
|
|
|
|
function getValidFileName(filename) {
|
|
// TODO
|
|
return filename;
|
|
}
|
|
|
|
function downloadFile(url, localPath) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
Logger.log('downloading: ' + url + ' to ' + localPath);
|
|
var ft = new FileTransfer();
|
|
ft.download(url, localPath, function (entry) {
|
|
|
|
var localUrl = normalizeReturnUrl(entry.toURL());
|
|
|
|
Logger.log('Downloaded local url: ' + localUrl);
|
|
deferred.resolveWith(null, [localUrl]);
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function downloadSubtitles(url, localItem, subtitleStream) {
|
|
|
|
var path = item.LocalPath;
|
|
|
|
var filename = getSubtitleSaveFileName(item, subtitleStream.Language, subtitleStream.IsForced) + "." + subtitleStream.Codec.toLowerCase();
|
|
|
|
var parentPath = getParentDirectoryPath(path);
|
|
|
|
path = combinePaths(parentPath, filename);
|
|
|
|
return downloadFile(url, path);
|
|
}
|
|
|
|
function getSubtitleSaveFileName(item, language, isForced) {
|
|
|
|
var path = item.LocalPath;
|
|
|
|
var name = getNameWithoutExtension(path);
|
|
|
|
if (language) {
|
|
name += "." + language.toLowerCase();
|
|
}
|
|
|
|
if (isForced) {
|
|
name += ".foreign";
|
|
}
|
|
|
|
return name;
|
|
}
|
|
|
|
function getNameWithoutExtension(path) {
|
|
|
|
var parts = path.split('/');
|
|
var name = parts[parts.length - 1];
|
|
|
|
var index = name.lastIndexOf('.');
|
|
|
|
if (index != -1) {
|
|
name = name.substring(0, index);
|
|
}
|
|
|
|
return name;
|
|
}
|
|
|
|
function getParentDirectoryPath(path) {
|
|
|
|
var parts = path.split('/');
|
|
parts.length--;
|
|
|
|
return parts.join('/');
|
|
}
|
|
|
|
function combinePaths(path1, path2) {
|
|
|
|
return path1 + path2;
|
|
}
|
|
|
|
function getLocalId(serverId, itemId) {
|
|
|
|
}
|
|
|
|
function hasImage(serverId, itemId, imageTag) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
getImageLocalPath(serverId, itemId, imageTag).done(function (localPath) {
|
|
|
|
fileExists(localPath).done(function (exists) {
|
|
|
|
deferred.resolveWith(null, [exists]);
|
|
|
|
}).fail(getOnFail(deferred));
|
|
|
|
}).fail(getOnFail(deferred));
|
|
return deferred.promise();
|
|
}
|
|
|
|
function downloadImage(url, serverId, itemId, imageTag) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
getImageLocalPath(serverId, itemId, imageTag).done(function (localPath) {
|
|
|
|
downloadFile(url, localPath).done(function () {
|
|
|
|
deferred.resolve();
|
|
|
|
}).fail(getOnFail(deferred));
|
|
|
|
}).fail(getOnFail(deferred));
|
|
return deferred.promise();
|
|
}
|
|
|
|
function getImageLocalPath(serverId, itemId, imageTag) {
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
getFileSystem().done(function (fileSystem) {
|
|
var path = trimEnd(fileSystem.root.toURL()) + "/emby/images/" + serverId + "/" + itemId + "/" + imageTag;
|
|
|
|
deferred.resolveWith(null, [path]);
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function fileExists(path) {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
resolveLocalFileSystemURL(path, function (fileEntry) {
|
|
|
|
deferred.resolveWith(null, [true]);
|
|
|
|
}, function () {
|
|
|
|
deferred.resolveWith(null, [false]);
|
|
});
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
var fileSystem;
|
|
function getFileSystem() {
|
|
|
|
var deferred = DeferredBuilder.Deferred();
|
|
|
|
if (fileSystem) {
|
|
deferred.resolveWith(null, [fileSystem]);
|
|
} else {
|
|
requestFileSystem(PERSISTENT, 0, function (fs) {
|
|
fileSystem = fs;
|
|
deferred.resolveWith(null, [fileSystem]);
|
|
});
|
|
}
|
|
|
|
return deferred.promise();
|
|
}
|
|
|
|
function getOnFail(deferred) {
|
|
return function () {
|
|
|
|
deferred.reject();
|
|
};
|
|
}
|
|
|
|
window.LocalAssetManager = {
|
|
getLocalMediaSource: getLocalMediaSource,
|
|
saveOfflineUser: saveOfflineUser,
|
|
deleteOfflineUser: deleteOfflineUser,
|
|
getCameraPhotos: getCameraPhotos,
|
|
getOfflineActions: getOfflineActions,
|
|
deleteOfflineActions: deleteOfflineActions,
|
|
getServerItemIds: getServerItemIds,
|
|
removeLocalItem: removeLocalItem,
|
|
getLocalItem: getLocalItem,
|
|
addOrUpdateLocalItem: addOrUpdateLocalItem,
|
|
createLocalItem: createLocalItem,
|
|
downloadFile: downloadFile,
|
|
downloadSubtitles: downloadSubtitles,
|
|
hasImage: hasImage,
|
|
downloadImage: downloadImage
|
|
};
|
|
|
|
})(); |