diff options
Diffstat (limited to 'MediaBrowser.Api')
| -rw-r--r-- | MediaBrowser.Api/MediaBrowser.Api.csproj | 4 | ||||
| -rw-r--r-- | MediaBrowser.Api/Playback/Progressive/AudioService.cs | 1 | ||||
| -rw-r--r-- | MediaBrowser.Api/Sync/SyncHelper.cs | 85 | ||||
| -rw-r--r-- | MediaBrowser.Api/Sync/SyncJobWebSocketListener.cs | 120 | ||||
| -rw-r--r-- | MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs | 101 | ||||
| -rw-r--r-- | MediaBrowser.Api/Sync/SyncService.cs | 396 |
6 files changed, 1 insertions, 706 deletions
diff --git a/MediaBrowser.Api/MediaBrowser.Api.csproj b/MediaBrowser.Api/MediaBrowser.Api.csproj index 55ef65311..c2c8d1102 100644 --- a/MediaBrowser.Api/MediaBrowser.Api.csproj +++ b/MediaBrowser.Api/MediaBrowser.Api.csproj @@ -134,10 +134,6 @@ <Compile Include="SearchService.cs" /> <Compile Include="Session\SessionsService.cs" /> <Compile Include="SimilarItemsHelper.cs" /> - <Compile Include="Sync\SyncHelper.cs" /> - <Compile Include="Sync\SyncJobWebSocketListener.cs" /> - <Compile Include="Sync\SyncJobsWebSocketListener.cs" /> - <Compile Include="Sync\SyncService.cs" /> <Compile Include="System\ActivityLogService.cs" /> <Compile Include="System\ActivityLogWebSocketListener.cs" /> <Compile Include="System\SystemService.cs" /> diff --git a/MediaBrowser.Api/Playback/Progressive/AudioService.cs b/MediaBrowser.Api/Playback/Progressive/AudioService.cs index 04825c7a5..56d48baea 100644 --- a/MediaBrowser.Api/Playback/Progressive/AudioService.cs +++ b/MediaBrowser.Api/Playback/Progressive/AudioService.cs @@ -31,6 +31,7 @@ namespace MediaBrowser.Api.Playback.Progressive /// <summary> /// Class AudioService /// </summary> + [Authenticated] public class AudioService : BaseProgressiveStreamingService { /// <summary> diff --git a/MediaBrowser.Api/Sync/SyncHelper.cs b/MediaBrowser.Api/Sync/SyncHelper.cs deleted file mode 100644 index 116cd8060..000000000 --- a/MediaBrowser.Api/Sync/SyncHelper.cs +++ /dev/null @@ -1,85 +0,0 @@ -using MediaBrowser.Model.Dto; -using MediaBrowser.Model.Sync; -using System.Collections.Generic; - -namespace MediaBrowser.Api.Sync -{ - public static class SyncHelper - { - public static List<SyncJobOption> GetSyncOptions(List<BaseItemDto> items) - { - List<SyncJobOption> options = new List<SyncJobOption>(); - - foreach (BaseItemDto item in items) - { - if (item.SupportsSync ?? false) - { - if (item.IsVideo) - { - options.Add(SyncJobOption.Quality); - options.Add(SyncJobOption.Profile); - if (items.Count > 1) - { - options.Add(SyncJobOption.UnwatchedOnly); - } - break; - } - if (item.IsAudio) - { - options.Add(SyncJobOption.Quality); - options.Add(SyncJobOption.Profile); - break; - } - if (item.IsMusicGenre || item.IsArtist|| item.IsType("musicalbum")) - { - options.Add(SyncJobOption.Quality); - options.Add(SyncJobOption.Profile); - options.Add(SyncJobOption.ItemLimit); - break; - } - if ((item.IsFolder ?? false) && !item.IsMusicGenre && !item.IsArtist && !item.IsType("musicalbum") && !item.IsGameGenre) - { - options.Add(SyncJobOption.Quality); - options.Add(SyncJobOption.Profile); - options.Add(SyncJobOption.UnwatchedOnly); - break; - } - if (item.IsGenre) - { - options.Add(SyncJobOption.SyncNewContent); - options.Add(SyncJobOption.ItemLimit); - break; - } - } - } - - foreach (BaseItemDto item in items) - { - if (item.SupportsSync ?? false) - { - if ((item.IsFolder ?? false) || item.IsGameGenre || item.IsMusicGenre || item.IsGenre || item.IsArtist || item.IsStudio || item.IsPerson) - { - options.Add(SyncJobOption.SyncNewContent); - options.Add(SyncJobOption.ItemLimit); - break; - } - } - } - - return options; - } - - public static List<SyncJobOption> GetSyncOptions(SyncCategory category) - { - List<SyncJobOption> options = new List<SyncJobOption>(); - - options.Add(SyncJobOption.Quality); - options.Add(SyncJobOption.Profile); - options.Add(SyncJobOption.UnwatchedOnly); - options.Add(SyncJobOption.SyncNewContent); - options.Add(SyncJobOption.ItemLimit); - - return options; - } - } -} diff --git a/MediaBrowser.Api/Sync/SyncJobWebSocketListener.cs b/MediaBrowser.Api/Sync/SyncJobWebSocketListener.cs deleted file mode 100644 index ac9749a6d..000000000 --- a/MediaBrowser.Api/Sync/SyncJobWebSocketListener.cs +++ /dev/null @@ -1,120 +0,0 @@ -using MediaBrowser.Controller.Sync; -using MediaBrowser.Model.Events; -using MediaBrowser.Model.Logging; -using MediaBrowser.Model.Sync; -using System; -using System.Linq; -using System.Threading.Tasks; -using MediaBrowser.Model.Threading; - -namespace MediaBrowser.Api.Sync -{ - /// <summary> - /// Class SessionInfoWebSocketListener - /// </summary> - class SyncJobWebSocketListener : BasePeriodicWebSocketListener<CompleteSyncJobInfo, WebSocketListenerState> - { - /// <summary> - /// Gets the name. - /// </summary> - /// <value>The name.</value> - protected override string Name - { - get { return "SyncJob"; } - } - - private readonly ISyncManager _syncManager; - private string _jobId; - - public SyncJobWebSocketListener(ILogger logger, ISyncManager syncManager, ITimerFactory timerFactory) - : base(logger, timerFactory) - { - _syncManager = syncManager; - _syncManager.SyncJobCancelled += _syncManager_SyncJobCancelled; - _syncManager.SyncJobUpdated += _syncManager_SyncJobUpdated; - _syncManager.SyncJobItemCreated += _syncManager_SyncJobItemCreated; - _syncManager.SyncJobItemUpdated += _syncManager_SyncJobItemUpdated; - } - - void _syncManager_SyncJobItemUpdated(object sender, GenericEventArgs<SyncJobItem> e) - { - if (string.Equals(e.Argument.Id, _jobId, StringComparison.Ordinal)) - { - SendData(false); - } - } - - void _syncManager_SyncJobItemCreated(object sender, GenericEventArgs<SyncJobItem> e) - { - if (string.Equals(e.Argument.Id, _jobId, StringComparison.Ordinal)) - { - SendData(true); - } - } - - protected override void ParseMessageParams(string[] values) - { - base.ParseMessageParams(values); - - if (values.Length > 0) - { - _jobId = values[0]; - } - } - - void _syncManager_SyncJobUpdated(object sender, GenericEventArgs<SyncJob> e) - { - if (string.Equals(e.Argument.Id, _jobId, StringComparison.Ordinal)) - { - SendData(false); - } - } - - void _syncManager_SyncJobCancelled(object sender, GenericEventArgs<SyncJob> e) - { - if (string.Equals(e.Argument.Id, _jobId, StringComparison.Ordinal)) - { - SendData(true); - } - } - - /// <summary> - /// Gets the data to send. - /// </summary> - /// <param name="state">The state.</param> - /// <returns>Task{SystemInfo}.</returns> - protected override Task<CompleteSyncJobInfo> GetDataToSend(WebSocketListenerState state) - { - var job = _syncManager.GetJob(_jobId); - var items = _syncManager.GetJobItems(new SyncJobItemQuery - { - AddMetadata = true, - JobId = _jobId - }); - - var info = new CompleteSyncJobInfo - { - Job = job, - JobItems = items.Items.ToList() - }; - - return Task.FromResult(info); - } - - protected override bool SendOnTimer - { - get - { - return false; - } - } - - protected override void Dispose(bool dispose) - { - _syncManager.SyncJobCancelled -= _syncManager_SyncJobCancelled; - _syncManager.SyncJobUpdated -= _syncManager_SyncJobUpdated; - - base.Dispose(dispose); - } - } -} diff --git a/MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs b/MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs deleted file mode 100644 index 5f9d1ff0e..000000000 --- a/MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs +++ /dev/null @@ -1,101 +0,0 @@ -using MediaBrowser.Controller.Sync; -using MediaBrowser.Model.Logging; -using MediaBrowser.Model.Sync; -using System.Collections.Generic; -using System.Threading.Tasks; -using MediaBrowser.Model.Threading; - -namespace MediaBrowser.Api.Sync -{ - /// <summary> - /// Class SessionInfoWebSocketListener - /// </summary> - class SyncJobsWebSocketListener : BasePeriodicWebSocketListener<IEnumerable<SyncJob>, WebSocketListenerState> - { - /// <summary> - /// Gets the name. - /// </summary> - /// <value>The name.</value> - protected override string Name - { - get { return "SyncJobs"; } - } - - private readonly ISyncManager _syncManager; - private string _userId; - private string _targetId; - - public SyncJobsWebSocketListener(ILogger logger, ISyncManager syncManager, ITimerFactory timerFactory) - : base(logger, timerFactory) - { - _syncManager = syncManager; - _syncManager.SyncJobCancelled += _syncManager_SyncJobCancelled; - _syncManager.SyncJobCreated += _syncManager_SyncJobCreated; - _syncManager.SyncJobUpdated += _syncManager_SyncJobUpdated; - } - - protected override void ParseMessageParams(string[] values) - { - base.ParseMessageParams(values); - - if (values.Length > 0) - { - _userId = values[0]; - } - - if (values.Length > 1) - { - _targetId = values[1]; - } - } - - void _syncManager_SyncJobUpdated(object sender, Model.Events.GenericEventArgs<SyncJob> e) - { - SendData(false); - } - - void _syncManager_SyncJobCreated(object sender, Model.Events.GenericEventArgs<SyncJobCreationResult> e) - { - SendData(true); - } - - void _syncManager_SyncJobCancelled(object sender, Model.Events.GenericEventArgs<SyncJob> e) - { - SendData(true); - } - - /// <summary> - /// Gets the data to send. - /// </summary> - /// <param name="state">The state.</param> - /// <returns>Task{SystemInfo}.</returns> - protected override async Task<IEnumerable<SyncJob>> GetDataToSend(WebSocketListenerState state) - { - var jobs = await _syncManager.GetJobs(new SyncJobQuery - { - UserId = _userId, - TargetId = _targetId - - }).ConfigureAwait(false); - - return jobs.Items; - } - - protected override bool SendOnTimer - { - get - { - return false; - } - } - - protected override void Dispose(bool dispose) - { - _syncManager.SyncJobCancelled -= _syncManager_SyncJobCancelled; - _syncManager.SyncJobCreated -= _syncManager_SyncJobCreated; - _syncManager.SyncJobUpdated -= _syncManager_SyncJobUpdated; - - base.Dispose(dispose); - } - } -} 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); - } - } -} |