github/Ombi
1
0
Fork 0
mirror of https://github.com/Ombi-app/Ombi.git synced 2025-07-11 07:46:05 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #772 from tidusjar/dev

Browse source 
Fixed #769
This commit is contained in:
Jamie 2016-12-13 09:50:45 +00:00 • committed by GitHub
commit f7eec8bead
2 changed files with 25 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

31
PlexRequests.Core.Migration/MigrationRunner.cs
View file

@ -4,6 +4,7 @@ using System.Data.Common;
using System.Linq;
using System.Reflection;
using Ninject;
using NLog;
using PlexRequests.Store;
namespace PlexRequests.Core.Migration
@ -18,6 +19,7 @@ namespace PlexRequests.Core.Migration
private IKernel Kernel { get; }
private ISqliteConfiguration Db { get; }
private static Logger _log = LogManager.GetCurrentClassLogger();
public void MigrateToLatest()
{
@ -25,25 +27,34 @@ namespace PlexRequests.Core.Migration
var versions = GetMigrations();
var dbVersion = con.GetVersionInfo().OrderByDescending(x => x.Version).FirstOrDefault() ??
new TableCreation.VersionInfo { Version = 0 };
new TableCreation.VersionInfo {Version = 0};
foreach (var v in versions)
{
#if !DEBUG
if (v.Value.Version > dbVersion.Version)
{
#endif
// Assuming only one constructor
var ctor = v.Key.GetConstructors().FirstOrDefault();
var dependencies = ctor.GetParameters().Select(param => Kernel.Get(param.ParameterType)).ToList();
var method = v.Key.GetMethod("Start");
if (method != null)
try
{
var classInstance = Activator.CreateInstance(v.Key, dependencies.Any() ? dependencies.ToArray() : null);
var parametersArray = new object[] { Db.DbConnection() };
// Assuming only one constructor
var ctor = v.Key.GetConstructors().FirstOrDefault();
var dependencies = ctor.GetParameters().Select(param => Kernel.Get(param.ParameterType)).ToList();
method.Invoke(classInstance, parametersArray);
var method = v.Key.GetMethod("Start");
if (method != null)
{
var classInstance = Activator.CreateInstance(v.Key, dependencies.Any() ? dependencies.ToArray() : null);
var parametersArray = new object[] { Db.DbConnection() };
method.Invoke(classInstance, parametersArray);
}
}
catch (Exception e)
{
_log.Fatal("Error when migrating");
_log.Fatal(e);
}
#if !DEBUG
}
#endif

4
PlexRequests.Core.Migration/Migrations/Version1100.cs
View file

@ -246,6 +246,10 @@ namespace PlexRequests.Core.Migration.Migrations
var requestedModels = allRequests.ToList();
foreach (var req in requestedModels)
{
if (string.IsNullOrEmpty(req.PosterPath))
{
continue;
}
if (req.PosterPath.Contains("https://image.tmdb.org/t/p/w150/"))
{
var newImg = req.PosterPath.Replace("https://image.tmdb.org/t/p/w150/", string.Empty);