You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
395 lines
14 KiB
395 lines
14 KiB
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 ServiceStack;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
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; }
|
|
}
|
|
|
|
[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;
|
|
|
|
public SyncService(ISyncManager syncManager, IDtoService dtoService, ILibraryManager libraryManager, IUserManager userManager)
|
|
{
|
|
_syncManager = syncManager;
|
|
_dtoService = dtoService;
|
|
_libraryManager = libraryManager;
|
|
_userManager = userManager;
|
|
}
|
|
|
|
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 = AuthorizationContext.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);
|
|
}
|
|
}
|
|
}
|