Sonarr/NzbDrone.Update/Providers/UpdateProvider.cs

120 lines
4.1 KiB
C#
Raw Normal View History

2011-10-23 18:31:17 +00:00
using System;
using System.Collections.Generic;
2011-10-23 18:31:17 +00:00
using System.IO;
using System.Linq;
using NLog;
using NzbDrone.Common;
namespace NzbDrone.Update.Providers
{
public class UpdateProvider
{
private readonly DiskProvider _diskProvider;
private readonly ServiceProvider _serviceProvider;
2011-10-23 18:31:17 +00:00
private readonly ProcessProvider _processProvider;
2011-11-13 07:27:16 +00:00
private readonly EnviromentProvider _enviromentProvider;
private readonly IISProvider _iisProvider;
2011-11-13 04:16:54 +00:00
private static readonly Logger logger = LogManager.GetCurrentClassLogger();
2011-11-13 20:31:02 +00:00
public UpdateProvider(DiskProvider diskProvider, ServiceProvider serviceProvider,
ProcessProvider processProvider, EnviromentProvider enviromentProvider, IISProvider iisProvider)
{
_diskProvider = diskProvider;
_serviceProvider = serviceProvider;
2011-10-23 18:31:17 +00:00
_processProvider = processProvider;
2011-11-13 07:27:16 +00:00
_enviromentProvider = enviromentProvider;
_iisProvider = iisProvider;
}
2011-11-13 20:31:02 +00:00
public UpdateProvider()
{
}
private void Verify(string targetFolder)
{
2011-11-13 04:16:54 +00:00
logger.Info("Verifying requirements before update...");
2011-10-23 18:31:17 +00:00
if (String.IsNullOrWhiteSpace(targetFolder))
2011-10-23 18:31:17 +00:00
throw new ArgumentException("Target folder can not be null or empty");
if (!_diskProvider.FolderExists(targetFolder))
throw new DirectoryNotFoundException("Target folder doesn't exist " + targetFolder);
2011-11-13 04:16:54 +00:00
logger.Info("Verifying Update Folder");
2011-11-13 07:27:16 +00:00
if (!_diskProvider.FolderExists(_enviromentProvider.GetUpdatePackageFolder()))
throw new DirectoryNotFoundException("Update folder doesn't exist " + _enviromentProvider.GetUpdatePackageFolder());
2011-10-23 18:31:17 +00:00
}
2011-11-13 20:31:02 +00:00
public virtual void Start(string targetFolder)
2011-10-23 18:31:17 +00:00
{
2011-11-13 04:07:06 +00:00
Verify(targetFolder);
bool isService = false;
2011-11-13 04:16:54 +00:00
logger.Info("Stopping all running services");
if (_serviceProvider.ServiceExist(ServiceProvider.NZBDRONE_SERVICE_NAME)
&& _serviceProvider.IsServiceRunning(ServiceProvider.NZBDRONE_SERVICE_NAME))
{
isService = true;
_serviceProvider.Stop(ServiceProvider.NZBDRONE_SERVICE_NAME);
}
2011-11-13 04:16:54 +00:00
logger.Info("Killing all running processes");
2011-10-23 18:31:17 +00:00
var processes = _processProvider.GetProcessByName(ProcessProvider.NzbDroneProccessName);
foreach (var processInfo in processes)
{
_processProvider.Kill(processInfo.Id);
}
logger.Info("Killing all orphan IISExpress processes");
_iisProvider.StopServer();
2011-11-13 04:16:54 +00:00
logger.Info("Creating backup of existing installation");
2011-11-13 07:27:16 +00:00
_diskProvider.CopyDirectory(targetFolder, _enviromentProvider.GetUpdateBackUpFolder());
2011-11-13 04:07:06 +00:00
logger.Info("Moving update package to target");
2011-11-13 04:07:06 +00:00
try
{
_diskProvider.CopyDirectory(_enviromentProvider.GetUpdatePackageFolder(), targetFolder);
2011-11-13 04:07:06 +00:00
}
catch (Exception e)
{
RollBack(targetFolder);
foreach (var key in e.Data.Keys)
{
logger.Trace("Key: {0}, Value: {1}", key, e.Data[key]);
}
logger.FatalException("Failed to copy upgrade package to target folder.", e);
2011-11-13 04:07:06 +00:00
}
finally
{
StartNzbDrone(isService, targetFolder);
}
}
2011-11-13 04:07:06 +00:00
private void RollBack(string targetFolder)
{
2011-11-13 04:16:54 +00:00
logger.Info("Attempting to rollback upgrade");
2011-11-13 07:27:16 +00:00
_diskProvider.CopyDirectory(_enviromentProvider.GetUpdateBackUpFolder(), targetFolder);
2011-11-13 04:07:06 +00:00
}
2011-11-13 04:07:06 +00:00
private void StartNzbDrone(bool isService, string targetFolder)
{
if (isService)
{
_serviceProvider.Start(ServiceProvider.NZBDRONE_SERVICE_NAME);
}
else
{
_processProvider.Start(Path.Combine(targetFolder, "nzbdrone.exe"));
}
}
}
}