mirror of https://github.com/Ombi-app/Ombi
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
301 lines
12 KiB
301 lines
12 KiB
#region Copyright
|
|
// /************************************************************************
|
|
// Copyright (c) 2016 Jamie Rees
|
|
// File: Setup.cs
|
|
// Created By: Jamie Rees
|
|
//
|
|
// Permission is hereby granted, free of charge, to any person obtaining
|
|
// a copy of this software and associated documentation files (the
|
|
// "Software"), to deal in the Software without restriction, including
|
|
// without limitation the rights to use, copy, modify, merge, publish,
|
|
// distribute, sublicense, and/or sell copies of the Software, and to
|
|
// permit persons to whom the Software is furnished to do so, subject to
|
|
// the following conditions:
|
|
//
|
|
// The above copyright notice and this permission notice shall be
|
|
// included in all copies or substantial portions of the Software.
|
|
//
|
|
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
|
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
|
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
|
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
|
|
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
|
|
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
|
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
|
// ************************************************************************/
|
|
#endregion
|
|
|
|
using System;
|
|
using System.Linq;
|
|
using System.Text.RegularExpressions;
|
|
|
|
using Mono.Data.Sqlite;
|
|
using NLog;
|
|
using PlexRequests.Api;
|
|
using PlexRequests.Core.SettingModels;
|
|
using PlexRequests.Helpers;
|
|
using PlexRequests.Store;
|
|
using PlexRequests.Store.Repository;
|
|
using System.Threading.Tasks;
|
|
using Quartz;
|
|
|
|
namespace PlexRequests.Core
|
|
{
|
|
public class Setup
|
|
{
|
|
private static Logger Log = LogManager.GetCurrentClassLogger();
|
|
private static DbConfiguration Db { get; set; }
|
|
public string SetupDb(string urlBase)
|
|
{
|
|
Db = new DbConfiguration(new SqliteFactory());
|
|
var created = Db.CheckDb();
|
|
TableCreation.CreateTables(Db.DbConnection());
|
|
|
|
if (created)
|
|
{
|
|
CreateDefaultSettingsPage(urlBase);
|
|
}
|
|
else
|
|
{
|
|
// Shrink DB
|
|
TableCreation.Vacuum(Db.DbConnection());
|
|
}
|
|
|
|
|
|
// The below code is obsolete, we should use PlexRequests.Core.Migrations.MigrationRunner
|
|
var version = CheckSchema();
|
|
if (version > 0)
|
|
{
|
|
if (version > 1899 && version <= 1900)
|
|
{
|
|
MigrateToVersion1900();
|
|
}
|
|
|
|
if(version > 1899 && version <= 1910)
|
|
{
|
|
MigrateToVersion1910();
|
|
}
|
|
}
|
|
|
|
return Db.DbConnection().ConnectionString;
|
|
}
|
|
|
|
public static string ConnectionString => Db.DbConnection().ConnectionString;
|
|
|
|
|
|
private int CheckSchema()
|
|
{
|
|
var productVersion = AssemblyHelper.GetProductVersion();
|
|
var trimStatus = new Regex("[^0-9]", RegexOptions.Compiled).Replace(productVersion, string.Empty).PadRight(4, '0');
|
|
var version = int.Parse(trimStatus);
|
|
|
|
var connection = Db.DbConnection();
|
|
var schema = connection.GetSchemaVersion();
|
|
if (schema == null)
|
|
{
|
|
connection.CreateSchema(version); // Set the default.
|
|
schema = connection.GetSchemaVersion();
|
|
}
|
|
if (version > schema.SchemaVersion)
|
|
{
|
|
Db.DbConnection().UpdateSchemaVersion(version);
|
|
schema = connection.GetSchemaVersion();
|
|
}
|
|
version = schema.SchemaVersion;
|
|
|
|
return version;
|
|
}
|
|
|
|
private void CreateDefaultSettingsPage(string baseUrl)
|
|
{
|
|
var defaultSettings = new PlexRequestSettings
|
|
{
|
|
RequireTvShowApproval = true,
|
|
RequireMovieApproval = true,
|
|
SearchForMovies = true,
|
|
SearchForTvShows = true,
|
|
BaseUrl = baseUrl ?? string.Empty,
|
|
CollectAnalyticData = true,
|
|
};
|
|
var s = new SettingsServiceV2<PlexRequestSettings>(new SettingsJsonRepository(new DbConfiguration(new SqliteFactory()), new MemoryCacheProvider()));
|
|
s.SaveSettings(defaultSettings);
|
|
|
|
|
|
var cron = (Quartz.Impl.Triggers.CronTriggerImpl)CronScheduleBuilder.WeeklyOnDayAndHourAndMinute(DayOfWeek.Friday, 7, 0).Build();
|
|
var scheduled = new ScheduledJobsSettings
|
|
{
|
|
PlexAvailabilityChecker = 60,
|
|
SickRageCacher = 60,
|
|
SonarrCacher = 60,
|
|
CouchPotatoCacher = 60,
|
|
StoreBackup = 24,
|
|
StoreCleanup = 24,
|
|
UserRequestLimitResetter = 12,
|
|
PlexEpisodeCacher = 12,
|
|
RecentlyAddedCron = cron.CronExpressionString, // Weekly CRON at 7 am on Mondays
|
|
};
|
|
|
|
var scheduledSettings = new SettingsServiceV2<ScheduledJobsSettings>(new SettingsJsonRepository(new DbConfiguration(new SqliteFactory()), new MemoryCacheProvider()));
|
|
scheduledSettings.SaveSettings(scheduled);
|
|
}
|
|
|
|
public void CacheQualityProfiles()
|
|
{
|
|
var mc = new MemoryCacheProvider();
|
|
|
|
try
|
|
{
|
|
Task.Run(() => { CacheSonarrQualityProfiles(mc); });
|
|
Task.Run(() => { CacheCouchPotatoQualityProfiles(mc); });
|
|
// we don't need to cache sickrage profiles, those are static
|
|
// TODO: cache headphones profiles?
|
|
}
|
|
catch (Exception)
|
|
{
|
|
Log.Error("Failed to cache quality profiles on startup!");
|
|
}
|
|
}
|
|
|
|
private void CacheSonarrQualityProfiles(MemoryCacheProvider cacheProvider)
|
|
{
|
|
try
|
|
{
|
|
Log.Info("Executing GetSettings call to Sonarr for quality profiles");
|
|
var sonarrSettingsService = new SettingsServiceV2<SonarrSettings>(new SettingsJsonRepository(new DbConfiguration(new SqliteFactory()), new MemoryCacheProvider()));
|
|
var sonarrSettings = sonarrSettingsService.GetSettings();
|
|
if (sonarrSettings.Enabled)
|
|
{
|
|
Log.Info("Begin executing GetProfiles call to Sonarr for quality profiles");
|
|
SonarrApi sonarrApi = new SonarrApi();
|
|
var profiles = sonarrApi.GetProfiles(sonarrSettings.ApiKey, sonarrSettings.FullUri);
|
|
cacheProvider.Set(CacheKeys.SonarrQualityProfiles, profiles);
|
|
Log.Info("Finished executing GetProfiles call to Sonarr for quality profiles");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Log.Error(ex, "Failed to cache Sonarr quality profiles!");
|
|
}
|
|
}
|
|
|
|
private void CacheCouchPotatoQualityProfiles(MemoryCacheProvider cacheProvider)
|
|
{
|
|
try
|
|
{
|
|
Log.Info("Executing GetSettings call to CouchPotato for quality profiles");
|
|
var cpSettingsService = new SettingsServiceV2<CouchPotatoSettings>(new SettingsJsonRepository(new DbConfiguration(new SqliteFactory()), new MemoryCacheProvider()));
|
|
var cpSettings = cpSettingsService.GetSettings();
|
|
if (cpSettings.Enabled)
|
|
{
|
|
Log.Info("Begin executing GetProfiles call to CouchPotato for quality profiles");
|
|
CouchPotatoApi cpApi = new CouchPotatoApi();
|
|
var profiles = cpApi.GetProfiles(cpSettings.FullUri, cpSettings.ApiKey);
|
|
cacheProvider.Set(CacheKeys.CouchPotatoQualityProfiles, profiles);
|
|
Log.Info("Finished executing GetProfiles call to CouchPotato for quality profiles");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
Log.Error(ex, "Failed to cache CouchPotato quality profiles!");
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// Migrates to version 1.9.
|
|
/// Move the Plex auth token to the new field.
|
|
/// Reconfigure the log level
|
|
/// Set the wizard flag to true if we already have settings
|
|
/// </summary>
|
|
public void MigrateToVersion1900()
|
|
{
|
|
// Need to change the Plex Token location
|
|
var authSettings = new SettingsServiceV2<AuthenticationSettings>(new SettingsJsonRepository(Db, new MemoryCacheProvider()));
|
|
var auth = authSettings.GetSettings();
|
|
var plexSettings = new SettingsServiceV2<PlexSettings>(new SettingsJsonRepository(Db, new MemoryCacheProvider()));
|
|
|
|
if (auth != null)
|
|
{
|
|
//If we have an authToken we do not need to go through the setup
|
|
if (!string.IsNullOrEmpty(auth.OldPlexAuthToken))
|
|
{
|
|
var prServuce = new SettingsServiceV2<PlexRequestSettings>(new SettingsJsonRepository(Db, new MemoryCacheProvider()));
|
|
var settings = prServuce.GetSettings();
|
|
settings.Wizard = true;
|
|
prServuce.SaveSettings(settings);
|
|
}
|
|
|
|
// Clear out the old token and save it to the new field
|
|
var currentSettings = plexSettings.GetSettings();
|
|
if (!string.IsNullOrEmpty(auth.OldPlexAuthToken))
|
|
{
|
|
currentSettings.PlexAuthToken = auth.OldPlexAuthToken;
|
|
plexSettings.SaveSettings(currentSettings);
|
|
|
|
// Clear out the old value
|
|
auth.OldPlexAuthToken = string.Empty;
|
|
authSettings.SaveSettings(auth);
|
|
}
|
|
|
|
}
|
|
|
|
|
|
// Set the log level
|
|
try
|
|
{
|
|
var settingsService = new SettingsServiceV2<LogSettings>(new SettingsJsonRepository(Db, new MemoryCacheProvider()));
|
|
var logSettings = settingsService.GetSettings();
|
|
logSettings.Level = LogLevel.Error.Ordinal;
|
|
settingsService.SaveSettings(logSettings);
|
|
|
|
LoggingHelper.ReconfigureLogLevel(LogLevel.FromOrdinal(logSettings.Level));
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Log.Error(e);
|
|
}
|
|
|
|
|
|
// Enable analytics;
|
|
try
|
|
{
|
|
|
|
var prSettings = new SettingsServiceV2<PlexRequestSettings>(new SettingsJsonRepository(Db, new MemoryCacheProvider()));
|
|
var settings = prSettings.GetSettings();
|
|
settings.CollectAnalyticData = true;
|
|
var updated = prSettings.SaveSettings(settings);
|
|
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Log.Error(e);
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Migrates to version1910.
|
|
/// </summary>
|
|
public void MigrateToVersion1910()
|
|
{
|
|
try
|
|
{
|
|
// Get the new machine Identifier
|
|
var settings = new SettingsServiceV2<PlexSettings>(new SettingsJsonRepository(Db, new MemoryCacheProvider()));
|
|
var plex = settings.GetSettings();
|
|
if (!string.IsNullOrEmpty(plex.PlexAuthToken))
|
|
{
|
|
var api = new PlexApi(new ApiRequest());
|
|
var server = api.GetServer(plex.PlexAuthToken); // Get the server info
|
|
plex.MachineIdentifier = server.Server.FirstOrDefault(x => x.AccessToken == plex.PlexAuthToken)?.MachineIdentifier;
|
|
|
|
settings.SaveSettings(plex); // Save the new settings
|
|
}
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Log.Error(e);
|
|
}
|
|
}
|
|
}
|
|
}
|