2010-09-28 21:32:19 +02:00
|
|
|
|
using System;
|
2011-05-27 08:03:57 +02:00
|
|
|
|
using System.Collections.Generic;
|
2013-04-11 06:30:51 +02:00
|
|
|
|
using System.IO;
|
2010-09-23 05:19:47 +02:00
|
|
|
|
using System.Linq;
|
2013-04-11 06:30:51 +02:00
|
|
|
|
using Marr.Data;
|
2010-10-02 21:01:43 +02:00
|
|
|
|
using NLog;
|
2013-04-11 06:30:51 +02:00
|
|
|
|
using NzbDrone.Common;
|
2013-02-20 03:05:15 +01:00
|
|
|
|
using NzbDrone.Common.EnsureThat;
|
2013-02-23 21:34:51 +01:00
|
|
|
|
using NzbDrone.Common.Eventing;
|
2013-02-24 07:48:52 +01:00
|
|
|
|
using NzbDrone.Core.Configuration;
|
2013-03-04 06:53:02 +01:00
|
|
|
|
using NzbDrone.Core.MetadataSource;
|
2012-01-24 07:29:32 +01:00
|
|
|
|
using NzbDrone.Core.Model;
|
2013-04-11 06:30:51 +02:00
|
|
|
|
using NzbDrone.Core.Organizer;
|
|
|
|
|
using NzbDrone.Core.RootFolders;
|
2013-02-23 21:34:51 +01:00
|
|
|
|
using NzbDrone.Core.Tv.Events;
|
2010-09-23 05:19:47 +02:00
|
|
|
|
|
2013-02-19 07:01:03 +01:00
|
|
|
|
namespace NzbDrone.Core.Tv
|
2010-09-23 05:19:47 +02:00
|
|
|
|
{
|
2013-02-20 03:05:15 +01:00
|
|
|
|
public interface ISeriesService
|
|
|
|
|
{
|
|
|
|
|
bool IsMonitored(int id);
|
|
|
|
|
Series UpdateSeriesInfo(int seriesId);
|
2013-04-07 09:30:37 +02:00
|
|
|
|
Series GetSeries(int seriesId);
|
2013-03-31 23:45:16 +02:00
|
|
|
|
void AddSeries(Series newSeries);
|
2013-02-20 03:05:15 +01:00
|
|
|
|
void UpdateFromSeriesEditor(IList<Series> editedSeries);
|
2013-03-02 19:25:39 +01:00
|
|
|
|
Series FindByTvdbId(int tvdbId);
|
2013-03-04 06:53:02 +01:00
|
|
|
|
void SetSeriesType(int seriesId, SeriesTypes seriesTypes);
|
2013-03-05 20:49:34 +01:00
|
|
|
|
void DeleteSeries(int seriesId, bool deleteFiles);
|
2013-02-20 03:05:15 +01:00
|
|
|
|
}
|
|
|
|
|
|
2013-03-30 22:56:34 +01:00
|
|
|
|
public class SeriesService : ISeriesService, IHandleAsync<SeriesAddedEvent>
|
2010-09-23 05:19:47 +02:00
|
|
|
|
{
|
2013-02-19 07:56:02 +01:00
|
|
|
|
private readonly ISeriesRepository _seriesRepository;
|
2013-02-24 07:48:52 +01:00
|
|
|
|
private readonly IConfigService _configService;
|
2013-03-31 22:25:39 +02:00
|
|
|
|
private readonly IProvideSeriesInfo _seriesInfoProxy;
|
2013-02-23 21:34:51 +01:00
|
|
|
|
private readonly IEventAggregator _eventAggregator;
|
2013-04-11 06:30:51 +02:00
|
|
|
|
private readonly DiskProvider _diskProvider;
|
2013-03-28 07:49:38 +01:00
|
|
|
|
private readonly Logger _logger;
|
2012-12-20 07:17:18 +01:00
|
|
|
|
|
2013-04-11 06:30:51 +02:00
|
|
|
|
public SeriesService(ISeriesRepository seriesRepository, IConfigService configServiceService,
|
|
|
|
|
IProvideSeriesInfo seriesInfoProxy, IEventAggregator eventAggregator,
|
|
|
|
|
DiskProvider diskProvider, Logger logger)
|
2010-09-23 05:19:47 +02:00
|
|
|
|
{
|
2013-02-19 07:56:02 +01:00
|
|
|
|
_seriesRepository = seriesRepository;
|
2013-02-24 07:48:52 +01:00
|
|
|
|
_configService = configServiceService;
|
2013-03-31 22:25:39 +02:00
|
|
|
|
_seriesInfoProxy = seriesInfoProxy;
|
2013-02-23 21:34:51 +01:00
|
|
|
|
_eventAggregator = eventAggregator;
|
2013-04-11 06:30:51 +02:00
|
|
|
|
_diskProvider = diskProvider;
|
2013-03-28 07:49:38 +01:00
|
|
|
|
_logger = logger;
|
2010-09-23 05:19:47 +02:00
|
|
|
|
}
|
|
|
|
|
|
2011-04-10 02:14:51 +02:00
|
|
|
|
|
2013-02-19 07:56:02 +01:00
|
|
|
|
public bool IsMonitored(int id)
|
2010-09-23 05:19:47 +02:00
|
|
|
|
{
|
2013-02-19 07:56:02 +01:00
|
|
|
|
return _seriesRepository.Get(id).Monitored;
|
2010-09-28 22:44:33 +02:00
|
|
|
|
}
|
|
|
|
|
|
2013-02-20 03:05:15 +01:00
|
|
|
|
|
|
|
|
|
public Series UpdateSeriesInfo(int seriesId)
|
2011-03-10 08:49:59 +01:00
|
|
|
|
{
|
2013-02-19 07:56:02 +01:00
|
|
|
|
var series = _seriesRepository.Get(seriesId);
|
2013-03-31 22:25:39 +02:00
|
|
|
|
var tvDbSeries = _seriesInfoProxy.GetSeriesInfo(series.TvDbId);
|
2013-02-24 20:57:33 +01:00
|
|
|
|
|
2013-03-02 20:32:55 +01:00
|
|
|
|
series.Title = tvDbSeries.Title;
|
|
|
|
|
series.AirTime = tvDbSeries.AirTime;
|
2011-04-01 08:36:34 +02:00
|
|
|
|
series.Overview = tvDbSeries.Overview;
|
|
|
|
|
series.Status = tvDbSeries.Status;
|
2013-03-31 23:45:16 +02:00
|
|
|
|
series.CleanTitle = Parser.NormalizeTitle(tvDbSeries.Title);
|
2011-04-01 08:36:34 +02:00
|
|
|
|
series.LastInfoSync = DateTime.Now;
|
2013-03-02 20:32:55 +01:00
|
|
|
|
series.Runtime = tvDbSeries.Runtime;
|
2013-03-31 22:25:39 +02:00
|
|
|
|
series.Images = tvDbSeries.Images;
|
2012-02-29 08:20:40 +01:00
|
|
|
|
series.Network = tvDbSeries.Network;
|
2013-03-02 20:32:55 +01:00
|
|
|
|
series.FirstAired = tvDbSeries.FirstAired;
|
2013-02-19 07:56:02 +01:00
|
|
|
|
_seriesRepository.Update(series);
|
2012-07-12 20:30:43 +02:00
|
|
|
|
|
2013-03-04 06:53:02 +01:00
|
|
|
|
_eventAggregator.Publish(new SeriesUpdatedEvent(series));
|
|
|
|
|
|
2011-04-01 08:36:34 +02:00
|
|
|
|
return series;
|
2011-03-10 08:49:59 +01:00
|
|
|
|
}
|
|
|
|
|
|
2013-02-20 03:05:15 +01:00
|
|
|
|
|
2013-04-07 09:30:37 +02:00
|
|
|
|
public Series GetSeries(int seriesId)
|
|
|
|
|
{
|
|
|
|
|
return _seriesRepository.Get(seriesId);
|
|
|
|
|
}
|
|
|
|
|
|
2013-03-31 23:45:16 +02:00
|
|
|
|
public void AddSeries(Series newSeries)
|
2013-02-20 03:05:15 +01:00
|
|
|
|
{
|
2013-03-31 23:45:16 +02:00
|
|
|
|
Ensure.That(() => newSeries).IsNotNull();
|
2013-02-20 03:05:15 +01:00
|
|
|
|
|
2013-04-11 06:30:51 +02:00
|
|
|
|
//Todo: If Path is null we need to create the path
|
|
|
|
|
if(String.IsNullOrWhiteSpace(newSeries.Folder))
|
|
|
|
|
{
|
|
|
|
|
newSeries.Folder = FileNameBuilder.CleanFilename(newSeries.Title);
|
|
|
|
|
_diskProvider.CreateDirectory(Path.Combine(newSeries.RootFolder.Value.Path, newSeries.Folder));
|
|
|
|
|
}
|
|
|
|
|
|
2013-03-31 23:45:16 +02:00
|
|
|
|
_logger.Info("Adding Series [{0}] Path: [{1}]", newSeries.Title, newSeries.Path);
|
2013-02-20 03:05:15 +01:00
|
|
|
|
|
2013-03-31 23:45:16 +02:00
|
|
|
|
newSeries.Monitored = true;
|
|
|
|
|
newSeries.CleanTitle = Parser.NormalizeTitle(newSeries.Title);
|
|
|
|
|
if (newSeries.QualityProfileId == 0)
|
|
|
|
|
newSeries.QualityProfileId = _configService.DefaultQualityProfile;
|
2011-02-25 08:20:24 +01:00
|
|
|
|
|
2013-03-31 23:45:16 +02:00
|
|
|
|
newSeries.SeasonFolder = _configService.UseSeasonFolder;
|
|
|
|
|
newSeries.BacklogSetting = BacklogSettingType.Inherit;
|
2011-02-25 08:20:24 +01:00
|
|
|
|
|
2013-03-31 23:45:16 +02:00
|
|
|
|
_seriesRepository.Insert(newSeries);
|
|
|
|
|
_eventAggregator.Publish(new SeriesAddedEvent(newSeries));
|
2011-02-18 03:50:40 +01:00
|
|
|
|
}
|
|
|
|
|
|
2013-02-20 03:05:15 +01:00
|
|
|
|
public void UpdateFromSeriesEditor(IList<Series> editedSeries)
|
2012-01-20 08:50:45 +01:00
|
|
|
|
{
|
2013-02-19 07:56:02 +01:00
|
|
|
|
var allSeries = _seriesRepository.All();
|
2012-01-20 08:50:45 +01:00
|
|
|
|
|
2013-02-19 07:56:02 +01:00
|
|
|
|
foreach (var series in allSeries)
|
2012-01-20 08:50:45 +01:00
|
|
|
|
{
|
|
|
|
|
//Only update parameters that can be changed in MassEdit
|
2013-04-01 08:22:16 +02:00
|
|
|
|
var edited = editedSeries.Single(s => s.Id == series.Id);
|
2012-01-20 08:50:45 +01:00
|
|
|
|
series.QualityProfileId = edited.QualityProfileId;
|
|
|
|
|
series.Monitored = edited.Monitored;
|
|
|
|
|
series.SeasonFolder = edited.SeasonFolder;
|
2012-01-26 02:02:21 +01:00
|
|
|
|
series.BacklogSetting = edited.BacklogSetting;
|
2012-01-20 08:50:45 +01:00
|
|
|
|
series.Path = edited.Path;
|
2012-09-20 17:37:40 +02:00
|
|
|
|
series.CustomStartDate = edited.CustomStartDate;
|
2013-02-19 07:56:02 +01:00
|
|
|
|
|
|
|
|
|
_seriesRepository.Update(series);
|
2012-01-20 08:50:45 +01:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
2013-03-31 22:25:39 +02:00
|
|
|
|
public void SetTvRageId(int seriesId, int tvRageId)
|
|
|
|
|
{
|
|
|
|
|
_seriesRepository.SetTvRageId(seriesId, tvRageId);
|
|
|
|
|
}
|
|
|
|
|
|
2013-03-02 19:25:39 +01:00
|
|
|
|
public Series FindByTvdbId(int tvdbId)
|
|
|
|
|
{
|
|
|
|
|
return _seriesRepository.FindByTvdbId(tvdbId);
|
|
|
|
|
}
|
|
|
|
|
|
2013-03-04 06:53:02 +01:00
|
|
|
|
public void SetSeriesType(int seriesId, SeriesTypes seriesTypes)
|
2013-03-02 19:25:39 +01:00
|
|
|
|
{
|
2013-03-04 06:53:02 +01:00
|
|
|
|
_seriesRepository.SetSeriesType(seriesId, seriesTypes);
|
2013-03-02 19:25:39 +01:00
|
|
|
|
}
|
|
|
|
|
|
2013-03-05 20:49:34 +01:00
|
|
|
|
public void DeleteSeries(int seriesId, bool deleteFiles)
|
2013-03-05 20:35:33 +01:00
|
|
|
|
{
|
|
|
|
|
var series = _seriesRepository.Get(seriesId);
|
|
|
|
|
_seriesRepository.Delete(seriesId);
|
2013-03-05 20:49:34 +01:00
|
|
|
|
_eventAggregator.Publish(new SeriesDeletedEvent(series, deleteFiles));
|
2013-03-05 20:35:33 +01:00
|
|
|
|
}
|
2013-03-30 22:56:34 +01:00
|
|
|
|
|
|
|
|
|
public void HandleAsync(SeriesAddedEvent message)
|
|
|
|
|
{
|
|
|
|
|
UpdateSeriesInfo(message.Series.Id);
|
|
|
|
|
}
|
2010-09-23 05:19:47 +02:00
|
|
|
|
}
|
2013-03-01 08:03:41 +01:00
|
|
|
|
}
|