jellyfin-server/MediaBrowser.Api/Sync/SyncService.cs

393 lines
14 KiB
C#
Raw Normal View History

2015-04-28 13:56:57 +00:00
using MediaBrowser.Common.Extensions;
using MediaBrowser.Controller.Dto;
2014-12-17 05:30:31 +00:00
using MediaBrowser.Controller.Library;
using MediaBrowser.Controller.Net;
2014-07-17 22:21:35 +00:00
using MediaBrowser.Controller.Sync;
using MediaBrowser.Model.Querying;
using MediaBrowser.Model.Sync;
2014-12-26 17:45:06 +00:00
using MediaBrowser.Model.Users;
2014-07-17 22:21:35 +00:00
using ServiceStack;
2014-12-17 05:30:31 +00:00
using System;
2014-07-22 16:36:34 +00:00
using System.Collections.Generic;
2014-12-17 05:30:31 +00:00
using System.Linq;
2014-07-17 22:21:35 +00:00
using System.Threading.Tasks;
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; }
}
2014-12-31 06:24:49 +00:00
[Route("/Sync/Jobs/{Id}", "POST", Summary = "Updates a sync job.")]
public class UpdateSyncJob : SyncJob, IReturnVoid
{
}
2014-12-17 05:52:34 +00:00
[Route("/Sync/JobItems", "GET", Summary = "Gets sync job items.")]
public class GetSyncJobItems : SyncJobItemQuery, IReturn<QueryResult<SyncJobItem>>
{
}
2015-01-21 03:54:45 +00:00
[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; }
}
2015-01-21 04:56:00 +00:00
[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; }
}
2015-01-21 03:54:45 +00:00
[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; }
}
2015-04-04 01:24:49 +00:00
[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; }
}
2014-07-17 22:21:35 +00:00
[Route("/Sync/Jobs", "GET", Summary = "Gets sync jobs.")]
2014-12-17 05:52:34 +00:00
public class GetSyncJobs : SyncJobQuery, IReturn<QueryResult<SyncJob>>
2014-07-17 22:21:35 +00:00
{
}
[Route("/Sync/Jobs", "POST", Summary = "Gets sync jobs.")]
2014-07-26 17:30:15 +00:00
public class CreateSyncJob : SyncJobRequest, IReturn<SyncJobCreationResult>
{
}
2014-07-22 16:36:34 +00:00
[Route("/Sync/Targets", "GET", Summary = "Gets a list of available sync targets.")]
2014-12-16 05:01:57 +00:00
public class GetSyncTargets : IReturn<List<SyncTarget>>
{
2014-07-22 16:36:34 +00:00
[ApiMember(Name = "UserId", Description = "UserId", IsRequired = true, DataType = "string", ParameterType = "query", Verb = "GET")]
public string UserId { get; set; }
}
2014-12-17 05:30:31 +00:00
[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; }
2014-12-19 04:20:07 +00:00
[ApiMember(Name = "ItemIds", Description = "ItemIds", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
2014-12-17 05:30:31 +00:00
public string ItemIds { get; set; }
2014-12-19 04:20:07 +00:00
[ApiMember(Name = "ParentId", Description = "ParentId", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string ParentId { get; set; }
2014-12-26 17:45:06 +00:00
2015-03-08 04:44:31 +00:00
[ApiMember(Name = "TargetId", Description = "TargetId", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public string TargetId { get; set; }
2014-12-19 04:20:07 +00:00
[ApiMember(Name = "Category", Description = "Category", IsRequired = false, DataType = "string", ParameterType = "query", Verb = "GET")]
public SyncCategory? Category { get; set; }
2014-12-17 05:30:31 +00:00
}
[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; }
}
2015-01-17 04:29:53 +00:00
[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; }
}
2014-12-26 17:45:06 +00:00
[Route("/Sync/OfflineActions", "POST", Summary = "Reports an action that occurred while offline.")]
public class ReportOfflineActions : List<UserAction>, IReturnVoid
{
}
2014-12-27 22:52:41 +00:00
[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; }
}
2014-12-29 05:56:55 +00:00
[Route("/Sync/Data", "POST", Summary = "Syncs data between device and server")]
public class SyncData : SyncDataRequest, IReturn<SyncDataResponse>
{
}
2014-07-17 22:21:35 +00:00
[Authenticated]
public class SyncService : BaseApiService
{
private readonly ISyncManager _syncManager;
2014-12-17 05:30:31 +00:00
private readonly IDtoService _dtoService;
private readonly ILibraryManager _libraryManager;
2015-02-17 03:49:47 +00:00
private readonly IUserManager _userManager;
2014-07-17 22:21:35 +00:00
2015-02-17 03:49:47 +00:00
public SyncService(ISyncManager syncManager, IDtoService dtoService, ILibraryManager libraryManager, IUserManager userManager)
2014-07-17 22:21:35 +00:00
{
_syncManager = syncManager;
2014-12-17 05:30:31 +00:00
_dtoService = dtoService;
_libraryManager = libraryManager;
2015-02-17 03:49:47 +00:00
_userManager = userManager;
2014-07-17 22:21:35 +00:00
}
2014-12-16 05:01:57 +00:00
public object Get(GetSyncTargets request)
2014-07-22 16:36:34 +00:00
{
var result = _syncManager.GetSyncTargets(request.UserId);
return ToOptimizedResult(result);
}
2014-12-31 06:24:49 +00:00
public async Task<object> Get(GetSyncJobs request)
2014-07-17 22:21:35 +00:00
{
2014-12-31 06:24:49 +00:00
var result = await _syncManager.GetJobs(request).ConfigureAwait(false);
2014-12-17 05:52:34 +00:00
return ToOptimizedResult(result);
}
public object Get(GetSyncJobItems request)
{
var result = _syncManager.GetJobItems(request);
2014-07-17 22:21:35 +00:00
return ToOptimizedResult(result);
}
public object Get(GetSyncJob request)
{
var result = _syncManager.GetJob(request.Id);
return ToOptimizedResult(result);
}
2014-08-18 14:20:02 +00:00
public void Delete(CancelSyncJob request)
2014-07-17 22:21:35 +00:00
{
2014-08-18 14:20:02 +00:00
var task = _syncManager.CancelJob(request.Id);
Task.WaitAll(task);
2014-07-17 22:21:35 +00:00
}
2014-08-17 05:38:13 +00:00
public async Task<object> Post(CreateSyncJob request)
2014-07-17 22:21:35 +00:00
{
2014-08-17 05:38:13 +00:00
var result = await _syncManager.CreateJob(request).ConfigureAwait(false);
2014-07-17 22:21:35 +00:00
2014-07-26 17:30:15 +00:00
return ToOptimizedResult(result);
}
2014-12-17 05:30:31 +00:00
2015-04-04 01:24:49 +00:00
public void Delete(CancelItems request)
{
var itemIds = request.ItemIds.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
var task = _syncManager.CancelItems(request.TargetId, itemIds);
Task.WaitAll(task);
}
2014-12-17 05:30:31 +00:00
public void Post(ReportSyncJobItemTransferred request)
{
var task = _syncManager.ReportSyncJobItemTransferred(request.Id);
Task.WaitAll(task);
}
2016-06-19 06:18:29 +00:00
public async Task<object> Get(GetSyncJobItemFile request)
2014-12-17 05:30:31 +00:00
{
var jobItem = _syncManager.GetJobItem(request.Id);
2015-04-28 13:56:57 +00:00
if (jobItem == null)
{
throw new ResourceNotFoundException();
}
2015-02-05 03:01:37 +00:00
if (jobItem.Status < SyncJobItemStatus.ReadyToTransfer)
2014-12-17 05:30:31 +00:00
{
throw new ArgumentException("The job item is not yet ready for transfer.");
}
2016-06-19 06:18:29 +00:00
await _syncManager.ReportSyncJobItemTransferBeginning(request.Id).ConfigureAwait(false);
2015-02-05 05:29:37 +00:00
2016-06-20 17:07:34 +00:00
return await ResultFactory.GetStaticFileResult(Request, new StaticFileResultOptions
2015-10-02 18:30:27 +00:00
{
Path = jobItem.OutputPath,
OnError = () =>
{
var failedTask = _syncManager.ReportSyncJobItemTransferFailed(request.Id);
Task.WaitAll(failedTask);
}
2016-06-20 17:07:34 +00:00
}).ConfigureAwait(false);
2014-12-17 05:30:31 +00:00
}
2015-03-12 04:47:16 +00:00
2016-06-19 06:18:29 +00:00
public async Task<object> Get(GetSyncDialogOptions request)
2014-12-17 05:30:31 +00:00
{
var result = new SyncDialogOptions();
result.Targets = _syncManager.GetSyncTargets(request.UserId)
.ToList();
2015-04-05 15:01:57 +00:00
var auth = AuthorizationContext.GetAuthorizationInfo(Request);
var authenticatedUser = _userManager.GetUserById(auth.UserId);
2015-03-08 04:44:31 +00:00
if (!string.IsNullOrWhiteSpace(request.TargetId))
{
result.Targets = result.Targets
.Where(i => string.Equals(i.Id, request.TargetId, StringComparison.OrdinalIgnoreCase))
.ToList();
2015-03-12 04:47:16 +00:00
result.QualityOptions = _syncManager
2015-04-05 15:01:57 +00:00
.GetQualityOptions(request.TargetId, authenticatedUser)
2015-03-12 04:47:16 +00:00
.ToList();
2015-03-15 01:42:09 +00:00
result.ProfileOptions = _syncManager
2015-04-05 15:01:57 +00:00
.GetProfileOptions(request.TargetId, authenticatedUser)
2015-03-15 01:42:09 +00:00
.ToList();
2015-03-08 04:44:31 +00:00
}
2014-12-19 04:20:07 +00:00
if (request.Category.HasValue)
{
result.Options = SyncHelper.GetSyncOptions(request.Category.Value);
}
else
{
2014-12-27 05:08:39 +00:00
var dtoOptions = new DtoOptions
{
Fields = new List<ItemFields>
{
ItemFields.SyncInfo
}
};
2015-02-05 05:29:37 +00:00
var items = request.ItemIds.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries)
2014-12-19 04:20:07 +00:00
.Select(_libraryManager.GetItemById)
2015-01-24 19:03:55 +00:00
.Where(i => i != null);
2016-06-19 06:18:29 +00:00
var dtos = (await _dtoService.GetBaseItemDtos(items, dtoOptions, authenticatedUser).ConfigureAwait(false));
2014-12-17 05:30:31 +00:00
2014-12-19 04:20:07 +00:00
result.Options = SyncHelper.GetSyncOptions(dtos);
}
2014-12-17 05:30:31 +00:00
return ToOptimizedResult(result);
}
2014-12-26 17:45:06 +00:00
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);
}
}
2014-12-27 22:52:41 +00:00
2015-02-19 17:46:18 +00:00
public async Task<object> Get(GetReadySyncItems request)
2014-12-27 22:52:41 +00:00
{
2015-02-19 17:46:18 +00:00
var result = await _syncManager.GetReadySyncItems(request.TargetId).ConfigureAwait(false);
return ToOptimizedResult(result);
2014-12-27 22:52:41 +00:00
}
2014-12-29 05:56:55 +00:00
public async Task<object> Post(SyncData request)
{
var response = await _syncManager.SyncData(request).ConfigureAwait(false);
return ToOptimizedResult(response);
}
2014-12-31 06:24:49 +00:00
public void Post(UpdateSyncJob request)
{
var task = _syncManager.UpdateJob(request);
Task.WaitAll(task);
}
2015-01-17 04:29:53 +00:00
2016-06-19 06:18:29 +00:00
public Task<object> Get(GetSyncJobItemAdditionalFile request)
2015-01-17 04:29:53 +00:00
{
var jobItem = _syncManager.GetJobItem(request.Id);
2015-02-05 03:01:37 +00:00
if (jobItem.Status < SyncJobItemStatus.ReadyToTransfer)
2015-01-17 04:29:53 +00:00
{
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.");
}
2016-06-19 06:18:29 +00:00
return ResultFactory.GetStaticFileResult(Request, file.Path);
2015-01-17 04:29:53 +00:00
}
2015-01-21 03:54:45 +00:00
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);
}
2015-01-21 04:56:00 +00:00
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);
}
2014-07-17 22:21:35 +00:00
}
}