diff options
Diffstat (limited to 'MediaBrowser.Api/Sync/SyncService.cs')
| -rw-r--r-- | MediaBrowser.Api/Sync/SyncService.cs | 396 |
1 files changed, 0 insertions, 396 deletions
diff --git a/MediaBrowser.Api/Sync/SyncService.cs b/MediaBrowser.Api/Sync/SyncService.cs deleted file mode 100644 index e50d2b77f..000000000 --- a/MediaBrowser.Api/Sync/SyncService.cs +++ /dev/null @@ -1,396 +0,0 @@ -using MediaBrowser.Common.Extensions; -using MediaBrowser.Controller.Dto; -using MediaBrowser.Controller.Library; -using MediaBrowser.Controller.Net; -using MediaBrowser.Controller.Sync; -using MediaBrowser.Model.Querying; -using MediaBrowser.Model.Sync; -using MediaBrowser.Model.Users; -using System; -using System.Collections.Generic; -using System.Linq; -using System.Threading.Tasks; -using MediaBrowser.Model.Services; - -namespace MediaBrowser.Api.Sync -{ - [Route("/Sync/Jobs/{Id}", "DELETE", Summary = "Cancels a sync job.")] - public class CancelSyncJob : IReturnVoid - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")] - public string Id { get; set; } - } - - [Route("/Sync/Jobs/{Id}", "GET", Summary = "Gets a sync job.")] - public class GetSyncJob : IReturn<SyncJob> - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")] - public string Id { get; set; } - } - - [Route("/Sync/Jobs/{Id}", "POST", Summary = "Updates a sync job.")] - public class UpdateSyncJob : SyncJob, IReturnVoid - { - } - - [Route("/Sync/JobItems", "GET", Summary = "Gets sync job items.")] - public class GetSyncJobItems : SyncJobItemQuery, IReturn<QueryResult<SyncJobItem>> - { - } - - [Route("/Sync/JobItems/{Id}/Enable", "POST", Summary = "Enables a cancelled or queued sync job item")] - public class EnableSyncJobItem : IReturnVoid - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string Id { get; set; } - } - - [Route("/Sync/JobItems/{Id}/MarkForRemoval", "POST", Summary = "Marks a job item for removal")] - public class MarkJobItemForRemoval : IReturnVoid - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string Id { get; set; } - } - - [Route("/Sync/JobItems/{Id}/UnmarkForRemoval", "POST", Summary = "Unmarks a job item for removal")] - public class UnmarkJobItemForRemoval : IReturnVoid - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string Id { get; set; } - } - - [Route("/Sync/JobItems/{Id}", "DELETE", Summary = "Cancels a sync job item")] - public class CancelSyncJobItem : IReturnVoid - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "DELETE")] - public string Id { get; set; } - } - - [Route("/Sync/Items/Cancel", "POST", Summary = "Cancels items from a sync target")] - [Route("/Sync/{TargetId}/Items", "DELETE", Summary = "Cancels items from a sync target")] - public class CancelItems : IReturnVoid - { - [ApiMember(Name = "TargetId", Description = "TargetId", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "Items")] - public string TargetId { get; set; } - - [ApiMember(Name = "ItemIds", Description = "ItemIds", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "Items")] - public string ItemIds { get; set; } - } - - [Route("/Sync/Jobs", "GET", Summary = "Gets sync jobs.")] - public class GetSyncJobs : SyncJobQuery, IReturn<QueryResult<SyncJob>> - { - } - - [Route("/Sync/Jobs", "POST", Summary = "Gets sync jobs.")] - public class CreateSyncJob : SyncJobRequest, IReturn<SyncJobCreationResult> - { - } - - [Route("/Sync/Targets", "GET", Summary = "Gets a list of available sync targets.")] - public class GetSyncTargets : IReturn<List<SyncTarget>> - { - [ApiMember(Name = "UserId", Description = "UserId", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")] - public string UserId { get; set; } - } - - [Route("/Sync/Options", "GET", Summary = "Gets a list of available sync targets.")] - public class GetSyncDialogOptions : IReturn<SyncDialogOptions> - { - [ApiMember(Name = "UserId", Description = "UserId", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")] - public string UserId { get; set; } - - [ApiMember(Name = "ItemIds", Description = "ItemIds", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")] - public string ItemIds { get; set; } - - [ApiMember(Name = "ParentId", Description = "ParentId", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")] - public string ParentId { get; set; } - - [ApiMember(Name = "TargetId", Description = "TargetId", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")] - public string TargetId { get; set; } - - [ApiMember(Name = "Category", Description = "Category", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")] - public SyncCategory? Category { get; set; } - } - - [Route("/Sync/JobItems/{Id}/Transferred", "POST", Summary = "Reports that a sync job item has successfully been transferred.")] - public class ReportSyncJobItemTransferred : IReturnVoid - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "POST")] - public string Id { get; set; } - } - - [Route("/Sync/JobItems/{Id}/File", "GET", Summary = "Gets a sync job item file")] - public class GetSyncJobItemFile - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")] - public string Id { get; set; } - } - - [Route("/Sync/JobItems/{Id}/AdditionalFiles", "GET", Summary = "Gets a sync job item file")] - public class GetSyncJobItemAdditionalFile - { - [ApiMember(Name = "Id", Description = "Id", IsRequired = true, DataType = "string", ParameterType = "path", Verb = "GET")] - public string Id { get; set; } - - [ApiMember(Name = "Name", Description = "Name", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")] - public string Name { get; set; } - } - - [Route("/Sync/OfflineActions", "POST", Summary = "Reports an action that occurred while offline.")] - public class ReportOfflineActions : List<UserAction>, IReturnVoid - { - } - - [Route("/Sync/Items/Ready", "GET", Summary = "Gets ready to download sync items.")] - public class GetReadySyncItems : IReturn<List<SyncedItem>> - { - [ApiMember(Name = "TargetId", Description = "TargetId", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")] - public string TargetId { get; set; } - } - - [Route("/Sync/Data", "POST", Summary = "Syncs data between device and server")] - public class SyncData : SyncDataRequest, IReturn<SyncDataResponse> - { - } - - [Authenticated] - public class SyncService : BaseApiService - { - private readonly ISyncManager _syncManager; - private readonly IDtoService _dtoService; - private readonly ILibraryManager _libraryManager; - private readonly IUserManager _userManager; - private readonly IAuthorizationContext _authContext; - - public SyncService(ISyncManager syncManager, IDtoService dtoService, ILibraryManager libraryManager, IUserManager userManager, IAuthorizationContext authContext) - { - _syncManager = syncManager; - _dtoService = dtoService; - _libraryManager = libraryManager; - _userManager = userManager; - _authContext = authContext; - } - - public object Get(GetSyncTargets request) - { - var result = _syncManager.GetSyncTargets(request.UserId); - - return ToOptimizedResult(result); - } - - public async Task<object> Get(GetSyncJobs request) - { - var result = await _syncManager.GetJobs(request).ConfigureAwait(false); - - return ToOptimizedResult(result); - } - - public object Get(GetSyncJobItems request) - { - var result = _syncManager.GetJobItems(request); - - return ToOptimizedResult(result); - } - - public object Get(GetSyncJob request) - { - var result = _syncManager.GetJob(request.Id); - - return ToOptimizedResult(result); - } - - public void Delete(CancelSyncJob request) - { - var task = _syncManager.CancelJob(request.Id); - - Task.WaitAll(task); - } - - public async Task<object> Post(CreateSyncJob request) - { - var result = await _syncManager.CreateJob(request).ConfigureAwait(false); - - return ToOptimizedResult(result); - } - - public void Any(CancelItems request) - { - var itemIds = request.ItemIds.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries); - - var task = _syncManager.CancelItems(request.TargetId, itemIds); - - Task.WaitAll(task); - } - - public void Post(ReportSyncJobItemTransferred request) - { - var task = _syncManager.ReportSyncJobItemTransferred(request.Id); - - Task.WaitAll(task); - } - - public async Task<object> Get(GetSyncJobItemFile request) - { - var jobItem = _syncManager.GetJobItem(request.Id); - - if (jobItem == null) - { - throw new ResourceNotFoundException(); - } - - if (jobItem.Status < SyncJobItemStatus.ReadyToTransfer) - { - throw new ArgumentException("The job item is not yet ready for transfer."); - } - - await _syncManager.ReportSyncJobItemTransferBeginning(request.Id).ConfigureAwait(false); - - return await ResultFactory.GetStaticFileResult(Request, new StaticFileResultOptions - { - Path = jobItem.OutputPath, - OnError = () => - { - var failedTask = _syncManager.ReportSyncJobItemTransferFailed(request.Id); - Task.WaitAll(failedTask); - } - - }).ConfigureAwait(false); - } - - public async Task<object> Get(GetSyncDialogOptions request) - { - var result = new SyncDialogOptions(); - - result.Targets = _syncManager.GetSyncTargets(request.UserId) - .ToList(); - - var auth = _authContext.GetAuthorizationInfo(Request); - var authenticatedUser = _userManager.GetUserById(auth.UserId); - - if (!string.IsNullOrWhiteSpace(request.TargetId)) - { - result.Targets = result.Targets - .Where(i => string.Equals(i.Id, request.TargetId, StringComparison.OrdinalIgnoreCase)) - .ToList(); - - result.QualityOptions = _syncManager - .GetQualityOptions(request.TargetId, authenticatedUser) - .ToList(); - - result.ProfileOptions = _syncManager - .GetProfileOptions(request.TargetId, authenticatedUser) - .ToList(); - } - - if (request.Category.HasValue) - { - result.Options = SyncHelper.GetSyncOptions(request.Category.Value); - } - else - { - var dtoOptions = new DtoOptions - { - Fields = new List<ItemFields> - { - ItemFields.SyncInfo, - ItemFields.BasicSyncInfo - } - }; - - var items = request.ItemIds.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries) - .Select(_libraryManager.GetItemById) - .Where(i => i != null); - - var dtos = (await _dtoService.GetBaseItemDtos(items, dtoOptions, authenticatedUser).ConfigureAwait(false)); - - result.Options = SyncHelper.GetSyncOptions(dtos); - } - - return ToOptimizedResult(result); - } - - public void Post(ReportOfflineActions request) - { - var task = PostAsync(request); - - Task.WaitAll(task); - } - - public async Task PostAsync(ReportOfflineActions request) - { - foreach (var action in request) - { - await _syncManager.ReportOfflineAction(action).ConfigureAwait(false); - } - } - - public async Task<object> Get(GetReadySyncItems request) - { - var result = await _syncManager.GetReadySyncItems(request.TargetId).ConfigureAwait(false); - - return ToOptimizedResult(result); - } - - public async Task<object> Post(SyncData request) - { - var response = await _syncManager.SyncData(request).ConfigureAwait(false); - - return ToOptimizedResult(response); - } - - public void Post(UpdateSyncJob request) - { - var task = _syncManager.UpdateJob(request); - - Task.WaitAll(task); - } - - public Task<object> Get(GetSyncJobItemAdditionalFile request) - { - var jobItem = _syncManager.GetJobItem(request.Id); - - if (jobItem.Status < SyncJobItemStatus.ReadyToTransfer) - { - throw new ArgumentException("The job item is not yet ready for transfer."); - } - - var file = jobItem.AdditionalFiles.FirstOrDefault(i => string.Equals(i.Name, request.Name, StringComparison.OrdinalIgnoreCase)); - - if (file == null) - { - throw new ArgumentException("Sync job additional file not found."); - } - - return ResultFactory.GetStaticFileResult(Request, file.Path); - } - - public void Post(EnableSyncJobItem request) - { - var task = _syncManager.ReEnableJobItem(request.Id); - - Task.WaitAll(task); - } - - public void Delete(CancelSyncJobItem request) - { - var task = _syncManager.CancelJobItem(request.Id); - - Task.WaitAll(task); - } - - public void Post(MarkJobItemForRemoval request) - { - var task = _syncManager.MarkJobItemForRemoval(request.Id); - - Task.WaitAll(task); - } - - public void Post(UnmarkJobItemForRemoval request) - { - var task = _syncManager.UnmarkJobItemForRemoval(request.Id); - - Task.WaitAll(task); - } - } -} |
