diff --git a/dashboard-ui/apiclient/fileupload.js b/dashboard-ui/apiclient/fileupload.js index d8e77aa17b..36c2f995f6 100644 --- a/dashboard-ui/apiclient/fileupload.js +++ b/dashboard-ui/apiclient/fileupload.js @@ -4,7 +4,7 @@ var self = this; - self.upload = function (file, mimeType, name, url) { + self.upload = function (file, name, url) { var deferred = DeferredBuilder.Deferred(); diff --git a/dashboard-ui/apiclient/localassetmanager.js b/dashboard-ui/apiclient/localassetmanager.js index acb4e05502..de0641c045 100644 --- a/dashboard-ui/apiclient/localassetmanager.js +++ b/dashboard-ui/apiclient/localassetmanager.js @@ -12,6 +12,12 @@ return deferred.promise(); } + function deleteOfflineUser(id) { + var deferred = DeferredBuilder.Deferred(); + deferred.resolve(); + return deferred.promise(); + } + function getCameraPhotos() { var deferred = DeferredBuilder.Deferred(); deferred.resolveWith(null, [[]]); @@ -24,6 +30,12 @@ return deferred.promise(); } + function deleteOfflineActions(actions) { + var deferred = DeferredBuilder.Deferred(); + deferred.resolveWith(null, [[]]); + return deferred.promise(); + } + function getServerItemIds(serverId) { var deferred = DeferredBuilder.Deferred(); deferred.resolveWith(null, [[]]); @@ -86,8 +98,10 @@ window.LocalAssetManager = { getLocalMediaSource: getLocalMediaSource, saveOfflineUser: saveOfflineUser, + deleteOfflineUser: deleteOfflineUser, getCameraPhotos: getCameraPhotos, getOfflineActions: getOfflineActions, + deleteOfflineActions: deleteOfflineActions, getServerItemIds: getServerItemIds, removeLocalItem: removeLocalItem, getLocalItem: getLocalItem, diff --git a/dashboard-ui/apiclient/sync/contentuploader.js b/dashboard-ui/apiclient/sync/contentuploader.js index 80c9d63785..f11559e5c9 100644 --- a/dashboard-ui/apiclient/sync/contentuploader.js +++ b/dashboard-ui/apiclient/sync/contentuploader.js @@ -113,10 +113,7 @@ Logger.log('Uploading file to ' + url); - // TODO: Need to get this from cordova file api instead of trying to infer the content type from the path - var mimeType = file.toLowerCase().indexOf('mp4') != -1 || file.toLowerCase().indexOf('m4v') != -1 ? 'video/mp4' : (file.toLowerCase().indexOf('png') != -1 ? 'image/png' : 'image/jpg'); - - new MediaBrowser.FileUpload().upload(file, mimeType, name, url).done(function () { + new MediaBrowser.FileUpload().upload(file, name, url).done(function () { Logger.log('File upload succeeded'); deferred.resolve(); diff --git a/dashboard-ui/apiclient/sync/mediasync.js b/dashboard-ui/apiclient/sync/mediasync.js index 51c54f3bf0..1ba0b81b4d 100644 --- a/dashboard-ui/apiclient/sync/mediasync.js +++ b/dashboard-ui/apiclient/sync/mediasync.js @@ -49,7 +49,11 @@ apiClient.reportOfflineActions(actions).done(function () { - deferred.resolve(); + LocalAssetManager.deleteOfflineActions(actions).done(function () { + + deferred.resolve(); + + }).fail(getOnFail(deferred)); }).fail(getOnFail(deferred)); @@ -235,9 +239,9 @@ Logger.log('Downloading media. Url: ' + url + '. Local path: ' + localPath); - localAssetManager.downloadFile(url, localPath).done(function () { + LocalAssetManager.downloadFile(url, localPath).done(function () { - localAssetManager.addOrUpdateLocalItem(localItem).done(function () { + LocalAssetManager.addOrUpdateLocalItem(localItem).done(function () { deferred.resolve(); @@ -324,7 +328,7 @@ require(['localassetmanager'], function () { - localAssetManager.hasImage(serverId, itemId, imageTag).done(function (hasImage) { + LocalAssetManager.hasImage(serverId, itemId, imageTag).done(function (hasImage) { if (hasImage) { deferred.resolve(); @@ -336,7 +340,7 @@ ImageType: imageType }); - localAssetManager.downloadImage(imageUrl, serverId, itemId, imageTag).done(function () { + LocalAssetManager.downloadImage(imageUrl, serverId, itemId, imageTag).done(function () { deferred.resolve(); @@ -418,7 +422,7 @@ LocalAssetManager.downloadSubtitles(url, localItem, subtitleStream).done(function (subtitlePath) { subtitleStream.Path = subtitlePath; - localAssetManager.addOrUpdateLocalItem(localItem).done(function () { + LocalAssetManager.addOrUpdateLocalItem(localItem).done(function () { deferred.resolve(); }).fail(getOnFail(deferred)); @@ -479,7 +483,7 @@ else { localItem.UserIdsWithAccess = userIdsWithAccess; - localAssetManager.addOrUpdateLocalItem(localItem).done(function () { + LocalAssetManager.addOrUpdateLocalItem(localItem).done(function () { deferred.resolve(); }).fail(getOnFail(deferred)); } diff --git a/dashboard-ui/apiclient/sync/offlineusersync.js b/dashboard-ui/apiclient/sync/offlineusersync.js index 8102d6db93..63ee8e135e 100644 --- a/dashboard-ui/apiclient/sync/offlineusersync.js +++ b/dashboard-ui/apiclient/sync/offlineusersync.js @@ -48,7 +48,17 @@ }); }).fail(function () { - deferred.reject(); + + // TODO: We should only delete if there's a 401 response + + require(['localassetmanager'], function () { + + LocalAssetManager.deleteOfflineUser(user.Id).done(function () { + deferred.resolve(); + }).fail(function () { + deferred.resolve(); + }); + }); }); return deferred.promise(); diff --git a/dashboard-ui/cordova/android/androidcredentials.js b/dashboard-ui/cordova/android/androidcredentials.js index 8c4233a24c..0310c2b558 100644 --- a/dashboard-ui/cordova/android/androidcredentials.js +++ b/dashboard-ui/cordova/android/androidcredentials.js @@ -27,7 +27,7 @@ ApiClientBridge.init(AppInfo.appName, AppInfo.appVersion, AppInfo.deviceId, AppInfo.deviceName, JSON.stringify(capabilities)); - initAjax(); + //initAjax(); } var baseAjaxMethod; diff --git a/dashboard-ui/cordova/fileupload.js b/dashboard-ui/cordova/fileupload.js index 8be134113a..772e85bf52 100644 --- a/dashboard-ui/cordova/fileupload.js +++ b/dashboard-ui/cordova/fileupload.js @@ -4,32 +4,51 @@ var self = this; - self.upload = function (file, mimeType, name, url) { + self.upload = function (path, name, url) { var deferred = DeferredBuilder.Deferred(); - var onSuccess = function (r) { - console.log("Code = " + r.responseCode); - console.log("Response = " + r.response); - console.log("Sent = " + r.bytesSent); - deferred.resolve(); - } + resolveLocalFileSystemURL(path, function (fileEntry) { - var onFail = function (error) { - console.log("upload error source " + error.source); - console.log("upload error target " + error.target); + fileEntry.file(function (file) { + + var mimeType = file.type; + + Logger.log('mimeType for file ' + path + ' is ' + file); + + var onSuccess = function (r) { + console.log("Code = " + r.responseCode); + console.log("Response = " + r.response); + console.log("Sent = " + r.bytesSent); + deferred.resolve(); + } + + var onFail = function (error) { + console.log("upload error source " + error.source); + console.log("upload error target " + error.target); + deferred.reject(); + } + + var options = new FileUploadOptions(); + options.fileKey = "file"; + options.fileName = name; + options.mimeType = mimeType; + + var params = {}; + options.params = params; + + new FileTransfer().upload(file, url, onSuccess, onFail, options); + + }, function () { + Logger.log('File upload failed. fileEntry.file returned an error'); + deferred.reject(); + }); + + }, function () { + + Logger.log('File upload failed. resolveLocalFileSystemURL returned an error'); deferred.reject(); - } - - var options = new FileUploadOptions(); - options.fileKey = "file"; - options.fileName = name; - options.mimeType = mimeType; - - var params = {}; - options.params = params; - - new FileTransfer().upload(file, url, onSuccess, onFail, options); + }); return deferred.promise(); }; diff --git a/dashboard-ui/cordova/ios/vlcplayer.js b/dashboard-ui/cordova/ios/vlcplayer.js index 898f4efd3c..adbeba4760 100644 --- a/dashboard-ui/cordova/ios/vlcplayer.js +++ b/dashboard-ui/cordova/ios/vlcplayer.js @@ -110,12 +110,13 @@ return self.playerState.volume; }; - self.setCurrentSrc = function (val, item, mediaSource, tracks) { + self.setCurrentSrc = function (streamInfo, item, mediaSource, tracks) { - if (!val) { + if (!streamInfo) { return; } + var val = streamInfo.url; var tIndex = val.indexOf('#t='); var startPosMs = 0; @@ -127,8 +128,6 @@ if (options.type == 'audio') { - // TODO - //AndroidVlcPlayer.playAudioVlc(val, JSON.stringify(item), JSON.stringify(mediaSource), options.poster); var artist = item.ArtistItems && item.ArtistItems.length ? item.ArtistItems[0].Name : null; window.audioplayer.playstream(successHandler, function () { diff --git a/dashboard-ui/cordova/localassetmanager.js b/dashboard-ui/cordova/localassetmanager.js index b12424f939..30ef01d0f2 100644 --- a/dashboard-ui/cordova/localassetmanager.js +++ b/dashboard-ui/cordova/localassetmanager.js @@ -68,46 +68,300 @@ 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) { - // TODO var deferred = DeferredBuilder.Deferred(); - deferred.resolve(); + + 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) { - // TODO + var deferred = DeferredBuilder.Deferred(); - deferred.resolveWith(null, [[]]); + + 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) { - // TODO - var deferred = DeferredBuilder.Deferred(); - deferred.resolveWith(null, [[]]); - return deferred.promise(); - } - function removeLocalItem(itemId, serverId) { - // TODO var deferred = DeferredBuilder.Deferred(); - deferred.resolveWith(null, []); + + 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) { - // TODO + var deferred = DeferredBuilder.Deferred(); - deferred.resolveWith(null, []); + + 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(localItem) { - // TODO + function addOrUpdateLocalItem(item) { + var deferred = DeferredBuilder.Deferred(); - deferred.resolveWith(null, [null]); + + 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(); } @@ -122,15 +376,15 @@ getFileSystem().done(function (fileSystem) { - var localPath = fileSystem.root.toURL() + "/" + path.join('/'); + 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.setPath(localPath); - mediaSource.setProtocol(MediaProtocol.File); + mediaSource.Path = localPath; + mediaSource.Protocol = 'File'; } item.ServerId = serverInfo.Id; @@ -143,9 +397,23 @@ return deferred.promise(); } - function getDirectoryPath(item, serverInfo) { + 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") { @@ -186,7 +454,7 @@ var filename = originalFileName || libraryItem.Name; - return fileRepository.getValidFileName(filename); + return getValidFileName(filename); } function getValidFileName(filename) { @@ -306,7 +574,7 @@ var deferred = DeferredBuilder.Deferred(); getFileSystem().done(function (fileSystem) { - var path = fileSystem.root.toURL() + "/emby/images/" + serverId + "/" + itemId + "/" + imageTag; + var path = trimEnd(fileSystem.root.toURL()) + "/emby/images/" + serverId + "/" + itemId + "/" + imageTag; deferred.resolveWith(null, [path]); }); @@ -357,8 +625,10 @@ window.LocalAssetManager = { getLocalMediaSource: getLocalMediaSource, saveOfflineUser: saveOfflineUser, + deleteOfflineUser: deleteOfflineUser, getCameraPhotos: getCameraPhotos, getOfflineActions: getOfflineActions, + deleteOfflineActions: deleteOfflineActions, getServerItemIds: getServerItemIds, removeLocalItem: removeLocalItem, getLocalItem: getLocalItem, diff --git a/dashboard-ui/edititemmetadata.html b/dashboard-ui/edititemmetadata.html index a620a74078..6ce8eeafdc 100644 --- a/dashboard-ui/edititemmetadata.html +++ b/dashboard-ui/edititemmetadata.html @@ -4,7 +4,7 @@