diff options
| author | Luke Pulverenti <luke.pulverenti@gmail.com> | 2015-02-22 14:05:38 -0500 |
|---|---|---|
| committer | Luke Pulverenti <luke.pulverenti@gmail.com> | 2015-02-22 14:05:38 -0500 |
| commit | 084df0a20eebb54b79910d0201779fce2dab4b5f (patch) | |
| tree | c1c94eae7268d954d8d7273da4fe7b6e3d6dc4c9 /MediaBrowser.Server.Implementations/Sync | |
| parent | 20ceca1479f6d76dd78d961793056edccb7b05e6 (diff) | |
cloud sync progress
Diffstat (limited to 'MediaBrowser.Server.Implementations/Sync')
| -rw-r--r-- | MediaBrowser.Server.Implementations/Sync/CloudSyncProvider.cs | 11 | ||||
| -rw-r--r-- | MediaBrowser.Server.Implementations/Sync/MediaSync.cs | 20 |
2 files changed, 23 insertions, 8 deletions
diff --git a/MediaBrowser.Server.Implementations/Sync/CloudSyncProvider.cs b/MediaBrowser.Server.Implementations/Sync/CloudSyncProvider.cs index 59713b138..37caa561e 100644 --- a/MediaBrowser.Server.Implementations/Sync/CloudSyncProvider.cs +++ b/MediaBrowser.Server.Implementations/Sync/CloudSyncProvider.cs @@ -34,6 +34,11 @@ namespace MediaBrowser.Server.Implementations.Sync get { return "Cloud Sync"; } } + private ICloudSyncProvider GetProvider(SyncTarget target) + { + return null; + } + public Task<List<string>> GetServerItemIds(string serverId, SyncTarget target, CancellationToken cancellationToken) { throw new NotImplementedException(); @@ -44,9 +49,11 @@ namespace MediaBrowser.Server.Implementations.Sync throw new NotImplementedException(); } - public Task TransferItemFile(string serverId, string itemId, string[] pathParts, string name, ItemFileType fileType, SyncTarget target, CancellationToken cancellationToken) + public Task TransferItemFile(string serverId, string itemId, string inputFile, string[] pathParts, SyncTarget target, CancellationToken cancellationToken) { - throw new NotImplementedException(); + var provider = GetProvider(target); + + return provider.TransferItemFile(serverId, itemId, inputFile, pathParts, target, cancellationToken); } } } diff --git a/MediaBrowser.Server.Implementations/Sync/MediaSync.cs b/MediaBrowser.Server.Implementations/Sync/MediaSync.cs index 099e45a6e..349e6aa1d 100644 --- a/MediaBrowser.Server.Implementations/Sync/MediaSync.cs +++ b/MediaBrowser.Server.Implementations/Sync/MediaSync.cs @@ -1,6 +1,7 @@ using MediaBrowser.Common.Progress; using MediaBrowser.Controller; using MediaBrowser.Controller.Sync; +using MediaBrowser.Model.Dto; using MediaBrowser.Model.Logging; using MediaBrowser.Model.Sync; using System; @@ -30,10 +31,6 @@ namespace MediaBrowser.Server.Implementations.Sync var serverId = _appHost.SystemId; await SyncData(provider, serverId, target, cancellationToken).ConfigureAwait(false); - progress.Report(2); - - // Do the data sync twice so the server knows what was removed from the device - await SyncData(provider, serverId, target, cancellationToken).ConfigureAwait(false); progress.Report(3); var innerProgress = new ActionableProgress<double>(); @@ -44,6 +41,10 @@ namespace MediaBrowser.Server.Implementations.Sync progress.Report(totalProgress); }); await GetNewMedia(provider, target, serverId, innerProgress, cancellationToken); + + // Do the data sync twice so the server knows what was removed from the device + await SyncData(provider, serverId, target, cancellationToken).ConfigureAwait(false); + progress.Report(100); } @@ -135,8 +136,10 @@ namespace MediaBrowser.Server.Implementations.Sync try { - //await provider.TransferItemFile(serverId, libraryItem.Id, internalSyncJobItem.OutputPath, target, cancellationToken) - // .ConfigureAwait(false); + string[] pathParts = GetPathParts(serverId, libraryItem); + + await provider.TransferItemFile(serverId, libraryItem.Id, internalSyncJobItem.OutputPath, pathParts, target, cancellationToken) + .ConfigureAwait(false); progress.Report(92); @@ -170,5 +173,10 @@ namespace MediaBrowser.Server.Implementations.Sync { return provider.DeleteItem(serverId, itemId, target, cancellationToken); } + + private string[] GetPathParts(string serverId, BaseItemDto item) + { + return null; + } } } |
