aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Server.Implementations/Sync/SyncManager.cs
diff options
context:
space:
mode:
authorLuke <luke.pulverenti@gmail.com>2014-12-17 17:42:31 -0500
committerLuke <luke.pulverenti@gmail.com>2014-12-17 17:42:31 -0500
commita7f2bc5fda526e227e0dbdd23e0d408ed627da14 (patch)
tree9d3ca8e950bc8a0aae88fad7005971ec937f9e5a /MediaBrowser.Server.Implementations/Sync/SyncManager.cs
parent999f2e03f4cbd70bb5f253fd7d4c9bc11bf9c963 (diff)
parente3484bdcc204ae39e0bfdf08e758012a048d539c (diff)
Merge pull request #956 from MediaBrowser/dev
3.0.5464.40000
Diffstat (limited to 'MediaBrowser.Server.Implementations/Sync/SyncManager.cs')
-rw-r--r--MediaBrowser.Server.Implementations/Sync/SyncManager.cs26
1 files changed, 25 insertions, 1 deletions
diff --git a/MediaBrowser.Server.Implementations/Sync/SyncManager.cs b/MediaBrowser.Server.Implementations/Sync/SyncManager.cs
index c2f004f0b..664ec4038 100644
--- a/MediaBrowser.Server.Implementations/Sync/SyncManager.cs
+++ b/MediaBrowser.Server.Implementations/Sync/SyncManager.cs
@@ -49,7 +49,7 @@ namespace MediaBrowser.Server.Implementations.Sync
var user = _userManager.GetUserById(request.UserId);
var items = processor
- .GetItemsForSync(request.ItemIds, user)
+ .GetItemsForSync(request.ItemIds, user, request.UnwatchedOnly)
.ToList();
if (items.Any(i => !SupportsSync(i)))
@@ -265,5 +265,29 @@ namespace MediaBrowser.Server.Implementations.Sync
return null;
}
+
+ public async Task ReportSyncJobItemTransferred(string id)
+ {
+ var jobItem = _repo.GetJobItem(id);
+
+ jobItem.Status = SyncJobItemStatus.Completed;
+ jobItem.Progress = 100;
+
+ await _repo.Update(jobItem).ConfigureAwait(false);
+
+ var processor = new SyncJobProcessor(_libraryManager, _repo, this, _logger, _userManager);
+
+ await processor.UpdateJobStatus(jobItem.JobId).ConfigureAwait(false);
+ }
+
+ public SyncJobItem GetJobItem(string id)
+ {
+ return _repo.GetJobItem(id);
+ }
+
+ public QueryResult<SyncJobItem> GetJobItems(SyncJobItemQuery query)
+ {
+ return _repo.GetJobItems(query);
+ }
}
}