1
0
mirror of https://github.com/Radarr/Radarr.git synced 2024-09-20 00:11:46 +02:00
Radarr/NzbDrone.Core/MediaFiles/DiskScanService.cs

79 lines
3.0 KiB
C#
Raw Normal View History

2011-06-20 03:59:31 +02:00
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using NLog;
2011-11-13 05:07:06 +01:00
using NzbDrone.Common;
using NzbDrone.Common.Messaging;
using NzbDrone.Core.MediaFiles.Commands;
using NzbDrone.Core.MediaFiles.EpisodeImport;
using NzbDrone.Core.Tv;
using NzbDrone.Core.Tv.Events;
2011-06-20 03:59:31 +02:00
namespace NzbDrone.Core.MediaFiles
2011-06-20 03:59:31 +02:00
{
2013-04-15 07:27:32 +02:00
public interface IDiskScanService
{
string[] GetVideoFiles(string path, bool allDirectories = true);
}
public class DiskScanService :
IDiskScanService,
IHandle<SeriesUpdatedEvent>
2011-06-20 03:59:31 +02:00
{
private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
private static readonly string[] MediaExtensions = new[] { ".mkv", ".avi", ".wmv", ".mp4", ".mpg", ".mpeg", ".xvid", ".flv", ".mov", ".rm", ".rmvb", ".divx", ".dvr-ms", ".ts", ".ogm", ".m4v", ".strm" };
2013-05-11 01:53:50 +02:00
private readonly IDiskProvider _diskProvider;
private readonly ISeriesService _seriesService;
private readonly IMakeImportDecision _importDecisionMaker;
private readonly IImportApprovedEpisodes _importApprovedEpisodes;
private readonly IMessageAggregator _messageAggregator;
2011-06-20 03:59:31 +02:00
public DiskScanService(IDiskProvider diskProvider,
ISeriesService seriesService,
IMakeImportDecision importDecisionMaker,
IImportApprovedEpisodes importApprovedEpisodes,
IMessageAggregator messageAggregator)
2011-06-20 03:59:31 +02:00
{
_diskProvider = diskProvider;
_seriesService = seriesService;
_importDecisionMaker = importDecisionMaker;
_importApprovedEpisodes = importApprovedEpisodes;
_messageAggregator = messageAggregator;
2011-06-20 03:59:31 +02:00
}
private void Scan(Series series)
2011-06-20 03:59:31 +02:00
{
_messageAggregator.PublishCommand(new CleanMediaFileDb(series.Id));
if (!_diskProvider.FolderExists(series.Path))
{
2013-07-12 07:57:24 +02:00
Logger.Debug("Series folder doesn't exist: {0}", series.Path);
return;
2011-06-20 03:59:31 +02:00
}
var mediaFileList = GetVideoFiles(series.Path);
2011-06-20 03:59:31 +02:00
var decisions = _importDecisionMaker.GetImportDecisions(mediaFileList, series);
_importApprovedEpisodes.Import(decisions);
2011-06-20 03:59:31 +02:00
}
public string[] GetVideoFiles(string path, bool allDirectories = true)
2011-06-20 03:59:31 +02:00
{
Logger.Debug("Scanning '{0}' for video files", path);
2011-06-20 03:59:31 +02:00
var searchOption = allDirectories ? SearchOption.AllDirectories : SearchOption.TopDirectoryOnly;
var filesOnDisk = _diskProvider.GetFiles(path, searchOption);
2011-06-20 03:59:31 +02:00
var mediaFileList = filesOnDisk.Where(c => MediaExtensions.Contains(Path.GetExtension(c).ToLower())).ToList();
2011-06-20 03:59:31 +02:00
2011-06-22 08:34:33 +02:00
Logger.Trace("{0} video files were found in {1}", mediaFileList.Count, path);
return mediaFileList.ToArray();
2011-06-20 03:59:31 +02:00
}
public void Handle(SeriesUpdatedEvent message)
{
Scan(message.Series);
}
2011-06-20 03:59:31 +02:00
}
2011-06-20 05:25:04 +02:00
}