mirror of
https://github.com/Radarr/Radarr.git
synced 2024-09-11 03:52:33 +02:00
114 lines
3.4 KiB
C#
114 lines
3.4 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using NzbDrone.Api.ClientSchema;
|
|
using NzbDrone.Api.REST;
|
|
using NzbDrone.Core.Indexers;
|
|
using Omu.ValueInjecter;
|
|
using FluentValidation;
|
|
using NzbDrone.Api.Extensions;
|
|
using NzbDrone.Api.Mapping;
|
|
|
|
namespace NzbDrone.Api.Indexers
|
|
{
|
|
public class IndexerModule : NzbDroneRestModule<IndexerResource>
|
|
{
|
|
private readonly IIndexerService _indexerService;
|
|
|
|
public IndexerModule(IIndexerService indexerService)
|
|
{
|
|
_indexerService = indexerService;
|
|
GetResourceAll = GetAll;
|
|
GetResourceById = GetIndexer;
|
|
CreateResource = CreateIndexer;
|
|
UpdateResource = UpdateIndexer;
|
|
DeleteResource = DeleteIndexer;
|
|
|
|
|
|
SharedValidator.RuleFor(c => c.Name).NotEmpty();
|
|
SharedValidator.RuleFor(c => c.Implementation).NotEmpty();
|
|
|
|
PostValidator.RuleFor(c => c.Fields).NotEmpty();
|
|
}
|
|
|
|
private IndexerResource GetIndexer(int id)
|
|
{
|
|
return _indexerService.Get(id).InjectTo<IndexerResource>();
|
|
}
|
|
|
|
private List<IndexerResource> GetAll()
|
|
{
|
|
var indexers = _indexerService.All();
|
|
|
|
var result = new List<IndexerResource>(indexers.Count);
|
|
|
|
foreach (var indexer in indexers)
|
|
{
|
|
var indexerResource = new IndexerResource();
|
|
indexerResource.InjectFrom(indexer);
|
|
indexerResource.Fields = SchemaBuilder.GenerateSchema(indexer.Settings);
|
|
|
|
result.Add(indexerResource);
|
|
}
|
|
|
|
return result;
|
|
}
|
|
|
|
private int CreateIndexer(IndexerResource indexerResource)
|
|
{
|
|
var indexer = GetIndexer(indexerResource);
|
|
indexer = _indexerService.Create(indexer);
|
|
return indexer.Id;
|
|
}
|
|
|
|
private void UpdateIndexer(IndexerResource indexerResource)
|
|
{
|
|
var indexer = _indexerService.Get(indexerResource.Id);
|
|
indexer.InjectFrom(indexerResource);
|
|
indexer.Settings = SchemaDeserializer.DeserializeSchema(indexer.Settings, indexerResource.Fields);
|
|
|
|
ValidateIndexer(indexer);
|
|
|
|
_indexerService.Update(indexer);
|
|
}
|
|
|
|
|
|
private static void ValidateIndexer(Indexer indexer)
|
|
{
|
|
if (indexer.Enable)
|
|
{
|
|
var validationResult = indexer.Settings.Validate();
|
|
|
|
if (!validationResult.IsValid)
|
|
{
|
|
throw new ValidationException(validationResult.Errors);
|
|
}
|
|
}
|
|
}
|
|
|
|
private Indexer GetIndexer(IndexerResource indexerResource)
|
|
{
|
|
var indexer = _indexerService.Schema()
|
|
.SingleOrDefault(i =>
|
|
i.Implementation.Equals(indexerResource.Implementation,
|
|
StringComparison.InvariantCultureIgnoreCase));
|
|
|
|
if (indexer == null)
|
|
{
|
|
throw new BadRequestException("Invalid Indexer Implementation");
|
|
}
|
|
|
|
indexer.InjectFrom(indexerResource);
|
|
indexer.Settings = SchemaDeserializer.DeserializeSchema(indexer.Settings, indexerResource.Fields);
|
|
|
|
ValidateIndexer(indexer);
|
|
|
|
return indexer;
|
|
}
|
|
|
|
private void DeleteIndexer(int id)
|
|
{
|
|
_indexerService.Delete(id);
|
|
}
|
|
}
|
|
} |