open-source-mirrors
/
Ombi
mirror of https://github.com/Ombi-app/Ombi
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'dev' of https://github.com/tidusjar/PlexRequests.Net.git

Browse Source
pull/140/head
tidusjar 9 years ago
parent acb39b56f8 96fde83488
commit 9d9fc3daf8
5 changed files with 286 additions and 256 deletions
Show Stats Download Patch File Download Diff File

9
PlexRequests.Core/Models/StatusModel.cs
Unescape View File

@ -25,11 +25,20 @@
// ************************************************************************/ // ************************************************************************/
#endregion #endregion
using System.Text.RegularExpressions;
namespace PlexRequests.Core.Models namespace PlexRequests.Core.Models
{ {
public class StatusModel public class StatusModel
{ {
public string Version { get; set; } public string Version { get; set; }
public int DBVersion {
get
{
string trimStatus = new Regex("[^0-9]", RegexOptions.Compiled).Replace(Version, string.Empty).PadRight(4, '0');
return int.Parse(trimStatus);
}
}
public bool UpdateAvailable { get; set; } public bool UpdateAvailable { get; set; }
public string UpdateUri { get; set; } public string UpdateUri { get; set; }
public string DownloadUri { get; set; } public string DownloadUri { get; set; }

30
PlexRequests.Core/Setup.cs
Unescape View File

@ -36,13 +36,12 @@ using PlexRequests.Core.SettingModels;
using PlexRequests.Helpers; using PlexRequests.Helpers;
using PlexRequests.Store; using PlexRequests.Store;
using PlexRequests.Store.Repository; using PlexRequests.Store.Repository;
using System.Text.RegularExpressions;
namespace PlexRequests.Core namespace PlexRequests.Core
{ {
public class Setup public class Setup
{ {
public const int SchemaVersion = 1;
private static Logger Log = LogManager.GetCurrentClassLogger(); private static Logger Log = LogManager.GetCurrentClassLogger();
private static DbConfiguration Db { get; set; } private static DbConfiguration Db { get; set; }
public string SetupDb() public string SetupDb()
@ -56,28 +55,38 @@ namespace PlexRequests.Core
CreateDefaultSettingsPage(); CreateDefaultSettingsPage();
} }
MigrateDb(); var version = CheckSchema();
CheckSchema(); if (version > 0)
{
if (version > 1300 && version <= 1699)
{
MigrateDbFrom1300();
}
}
return Db.DbConnection().ConnectionString; return Db.DbConnection().ConnectionString;
} }
public static string ConnectionString => Db.DbConnection().ConnectionString; public static string ConnectionString => Db.DbConnection().ConnectionString;
private void CheckSchema() private int CheckSchema()
{ {
var checker = new StatusChecker();
var status = checker.GetStatus();
var connection = Db.DbConnection(); var connection = Db.DbConnection();
var schema = connection.GetSchemaVersion(); var schema = connection.GetSchemaVersion();
if (schema == null) if (schema == null)
{ {
connection.CreateSchema(); // Set the default. connection.CreateSchema(status.DBVersion); // Set the default.
schema = connection.GetSchemaVersion(); schema = connection.GetSchemaVersion();
} }
var version = schema.SchemaVersion; var version = schema.SchemaVersion;
if (version == 0) if (version == 0)
{ {
connection.UpdateSchemaVersion(SchemaVersion); connection.UpdateSchemaVersion(status.DBVersion);
try try
{ {
TableCreation.AlterTable(Db.DbConnection(), "RequestBlobs", "ADD COLUMN", "MusicId", false, "TEXT"); TableCreation.AlterTable(Db.DbConnection(), "RequestBlobs", "ADD COLUMN", "MusicId", false, "TEXT");
@ -86,9 +95,10 @@ namespace PlexRequests.Core
{ {
Log.Error("Tried updating the schema to version 1"); Log.Error("Tried updating the schema to version 1");
Log.Error(e); Log.Error(e);
return -1;
} }
return;
} }
return version;
} }
private void CreateDefaultSettingsPage() private void CreateDefaultSettingsPage()
@ -105,7 +115,7 @@ namespace PlexRequests.Core
s.SaveSettings(defaultSettings); s.SaveSettings(defaultSettings);
} }
private void MigrateDb() // TODO: Remove in v1.7 private void MigrateDbFrom1300() // TODO: Remove in v1.7
{ {
var result = new List<long>(); var result = new List<long>();
@ -147,7 +157,7 @@ namespace PlexRequests.Core
Issues = r.Issues, Issues = r.Issues,
OtherMessage = r.OtherMessage, OtherMessage = r.OtherMessage,
Overview = show.summary.RemoveHtml(), Overview = show.summary.RemoveHtml(),
RequestedBy = r.RequestedBy, RequestedUsers = r.AllUsers, // should pull in the RequestedBy property and merge with RequestedUsers
RequestedDate = r.ReleaseDate, RequestedDate = r.ReleaseDate,
Status = show.status Status = show.status
}; };

4
PlexRequests.Store/TableCreation.cs
Unescape View File

@ -80,10 +80,10 @@ namespace PlexRequests.Store
con.Close(); con.Close();
} }
public static void CreateSchema(this IDbConnection con) public static void CreateSchema(this IDbConnection con, int version)
{ {
con.Open(); con.Open();
con.Query("INSERT INTO DBInfo (SchemaVersion) values (0)"); con.Query(string.Format("INSERT INTO DBInfo (SchemaVersion) values ({0})", version));
con.Close(); con.Close();
} }

121
PlexRequests.UI/Content/search.js
Unescape View File

@ -5,44 +5,53 @@
return opts.inverse(this); return opts.inverse(this);
}); });
var searchSource = $("#search-template").html(); $(function () {
var musicSource = $("#music-template").html();
var searchTemplate = Handlebars.compile(searchSource);
var musicTemplate = Handlebars.compile(musicSource);
var searchTimer = 0; var searchSource = $("#search-template").html();
var musicSource = $("#music-template").html();
var searchTemplate = Handlebars.compile(searchSource);
var musicTemplate = Handlebars.compile(musicSource);
// Type in movie search var searchTimer = 0;
$("#movieSearchContent").on("input", function () {
// fix for selecting a default tab
var $tabs = $('#nav-tabs').children('li');
if ($tabs.filter(function (li) { return $(li).hasClass('active') }).length <= 0) {
$tabs.first().children('a:first-child').tab('show');
}
// Type in movie search
$("#movieSearchContent").on("input", function () {
if (searchTimer) { if (searchTimer) {
clearTimeout(searchTimer); clearTimeout(searchTimer);
} }
$('#movieSearchButton').attr("class","fa fa-spinner fa-spin"); $('#movieSearchButton').attr("class", "fa fa-spinner fa-spin");
searchTimer = setTimeout(movieSearch, 400); searchTimer = setTimeout(movieSearch, 400);
}); });
$('#moviesComingSoon').on('click', function (e) { $('#moviesComingSoon').on('click', function (e) {
e.preventDefault(); e.preventDefault();
moviesComingSoon(); moviesComingSoon();
}); });
$('#moviesInTheaters').on('click', function (e) { $('#moviesInTheaters').on('click', function (e) {
e.preventDefault(); e.preventDefault();
moviesInTheaters(); moviesInTheaters();
}); });
// Type in TV search // Type in TV search
$("#tvSearchContent").on("input", function () { $("#tvSearchContent").on("input", function () {
if (searchTimer) { if (searchTimer) {
clearTimeout(searchTimer); clearTimeout(searchTimer);
} }
$('#tvSearchButton').attr("class", "fa fa-spinner fa-spin"); $('#tvSearchButton').attr("class", "fa fa-spinner fa-spin");
searchTimer = setTimeout(tvSearch, 400); searchTimer = setTimeout(tvSearch, 400);
}); });
// Click TV dropdown option // Click TV dropdown option
$(document).on("click", ".dropdownTv", function (e) { $(document).on("click", ".dropdownTv", function (e) {
e.preventDefault(); e.preventDefault();
var buttonId = e.target.id; var buttonId = e.target.id;
if ($("#" + buttonId).attr('disabled')) { if ($("#" + buttonId).attr('disabled')) {
@ -70,20 +79,20 @@ $(document).on("click", ".dropdownTv", function (e) {
var url = $form.prop('action'); var url = $form.prop('action');
sendRequestAjax(data, type, url, buttonId); sendRequestAjax(data, type, url, buttonId);
}); });
// Search Music // Search Music
$("#musicSearchContent").on("input", function () { $("#musicSearchContent").on("input", function () {
if (searchTimer) { if (searchTimer) {
clearTimeout(searchTimer); clearTimeout(searchTimer);
} }
$('#musicSearchButton').attr("class", "fa fa-spinner fa-spin"); $('#musicSearchButton').attr("class", "fa fa-spinner fa-spin");
searchTimer = setTimeout(musicSearch, 400); searchTimer = setTimeout(musicSearch, 400);
}); });
// Click Request for movie // Click Request for movie
$(document).on("click", ".requestMovie", function (e) { $(document).on("click", ".requestMovie", function (e) {
e.preventDefault(); e.preventDefault();
var buttonId = e.target.id; var buttonId = e.target.id;
if ($("#" + buttonId).attr('disabled')) { if ($("#" + buttonId).attr('disabled')) {
@ -102,10 +111,10 @@ $(document).on("click", ".requestMovie", function (e) {
sendRequestAjax(data, type, url, buttonId); sendRequestAjax(data, type, url, buttonId);
}); });
// Click Request for album // Click Request for album
$(document).on("click", ".requestAlbum", function (e) { $(document).on("click", ".requestAlbum", function (e) {
e.preventDefault(); e.preventDefault();
var buttonId = e.target.id; var buttonId = e.target.id;
if ($("#" + buttonId).attr('disabled')) { if ($("#" + buttonId).attr('disabled')) {
@ -124,9 +133,9 @@ $(document).on("click", ".requestAlbum", function (e) {
sendRequestAjax(data, type, url, buttonId); sendRequestAjax(data, type, url, buttonId);
}); });
function sendRequestAjax(data, type, url, buttonId) { function sendRequestAjax(data, type, url, buttonId) {
$.ajax({ $.ajax({
type: type, type: type,
url: url, url: url,
@ -153,28 +162,28 @@ function sendRequestAjax(data, type, url, buttonId) {
generateNotify("Something went wrong!", "danger"); generateNotify("Something went wrong!", "danger");
} }
}); });
} }
function movieSearch() { function movieSearch() {
var query = $("#movieSearchContent").val(); var query = $("#movieSearchContent").val();
getMovies("/search/movie/" + query); getMovies("/search/movie/" + query);
} }
function moviesComingSoon() { function moviesComingSoon() {
getMovies("/search/movie/upcoming"); getMovies("/search/movie/upcoming");
} }
function moviesInTheaters() { function moviesInTheaters() {
getMovies("/search/movie/playing"); getMovies("/search/movie/playing");
} }
function getMovies(url) { function getMovies(url) {
$("#movieList").html(""); $("#movieList").html("");
$.ajax(url).success(function (results) { $.ajax(url).success(function (results) {
if (results.length > 0) { if (results.length > 0) {
results.forEach(function(result) { results.forEach(function (result) {
var context = buildMovieContext(result); var context = buildMovieContext(result);
var html = searchTemplate(context); var html = searchTemplate(context);
@ -184,21 +193,21 @@ function getMovies(url) {
else { else {
$("#movieList").html(noResultsHtml); $("#movieList").html(noResultsHtml);
} }
$('#movieSearchButton').attr("class","fa fa-search"); $('#movieSearchButton').attr("class", "fa fa-search");
}); });
}; };
function tvSearch() { function tvSearch() {
var query = $("#tvSearchContent").val(); var query = $("#tvSearchContent").val();
getTvShows("/search/tv/" + query); getTvShows("/search/tv/" + query);
} }
function getTvShows(url) { function getTvShows(url) {
$("#tvList").html(""); $("#tvList").html("");
$.ajax(url).success(function (results) { $.ajax(url).success(function (results) {
if (results.length > 0) { if (results.length > 0) {
results.forEach(function(result) { results.forEach(function (result) {
var context = buildTvShowContext(result); var context = buildTvShowContext(result);
var html = searchTemplate(context); var html = searchTemplate(context);
$("#tvList").append(html); $("#tvList").append(html);
@ -209,14 +218,14 @@ function getTvShows(url) {
} }
$('#tvSearchButton').attr("class", "fa fa-search"); $('#tvSearchButton').attr("class", "fa fa-search");
}); });
}; };
function musicSearch() { function musicSearch() {
var query = $("#musicSearchContent").val(); var query = $("#musicSearchContent").val();
getMusic("/search/music/" + query); getMusic("/search/music/" + query);
} }
function getMusic(url) { function getMusic(url) {
$("#musicList").html(""); $("#musicList").html("");
$.ajax(url).success(function (results) { $.ajax(url).success(function (results) {
@ -233,9 +242,9 @@ function getMusic(url) {
} }
$('#musicSearchButton').attr("class", "fa fa-search"); $('#musicSearchButton').attr("class", "fa fa-search");
}); });
}; };
function buildMovieContext(result) { function buildMovieContext(result) {
var date = new Date(result.releaseDate); var date = new Date(result.releaseDate);
var year = date.getFullYear(); var year = date.getFullYear();
var context = { var context = {
@ -251,9 +260,9 @@ function buildMovieContext(result) {
}; };
return context; return context;
} }
function buildTvShowContext(result) { function buildTvShowContext(result) {
var date = new Date(result.firstAired); var date = new Date(result.firstAired);
var year = date.getFullYear(); var year = date.getFullYear();
var context = { var context = {
@ -266,9 +275,9 @@ function buildTvShowContext(result) {
imdb: result.imdbId imdb: result.imdbId
}; };
return context; return context;
} }
function buildMusicContext(result) { function buildMusicContext(result) {
var context = { var context = {
id: result.id, id: result.id,
@ -284,4 +293,6 @@ function buildMusicContext(result) {
}; };
return context; return context;
} }
});

12
PlexRequests.UI/Modules/SearchModule.cs
Unescape View File

@ -282,7 +282,7 @@ namespace PlexRequests.UI.Modules
var notificationModel = new NotificationModel var notificationModel = new NotificationModel
{ {
Title = model.Title, Title = model.Title,
User = model.RequestedBy, User = Username,
DateTime = DateTime.Now, DateTime = DateTime.Now,
NotificationType = NotificationType.NewRequest NotificationType = NotificationType.NewRequest
}; };
@ -307,7 +307,7 @@ namespace PlexRequests.UI.Modules
var notificationModel = new NotificationModel var notificationModel = new NotificationModel
{ {
Title = model.Title, Title = model.Title,
User = model.RequestedBy, User = Username,
DateTime = DateTime.Now, DateTime = DateTime.Now,
NotificationType = NotificationType.NewRequest NotificationType = NotificationType.NewRequest
}; };
@ -322,7 +322,7 @@ namespace PlexRequests.UI.Modules
Log.Debug("Adding movie to database requests"); Log.Debug("Adding movie to database requests");
var id = RequestService.AddRequest(model); var id = RequestService.AddRequest(model);
var notificationModel = new NotificationModel { Title = model.Title, User = model.RequestedBy, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest }; var notificationModel = new NotificationModel { Title = model.Title, User = Username, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest };
NotificationService.Publish(notificationModel); NotificationService.Publish(notificationModel);
return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullMovieName} was successfully added!" }); return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullMovieName} was successfully added!" });
@ -427,7 +427,7 @@ namespace PlexRequests.UI.Modules
model.Approved = true; model.Approved = true;
Log.Debug("Adding tv to database requests (No approval required & Sonarr)"); Log.Debug("Adding tv to database requests (No approval required & Sonarr)");
RequestService.AddRequest(model); RequestService.AddRequest(model);
var notify1 = new NotificationModel { Title = model.Title, User = model.RequestedBy, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest }; var notify1 = new NotificationModel { Title = model.Title, User = Username, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest };
NotificationService.Publish(notify1); NotificationService.Publish(notify1);
return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullShowName} was successfully added!" }); return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullShowName} was successfully added!" });
@ -448,7 +448,7 @@ namespace PlexRequests.UI.Modules
Log.Debug("Adding tv to database requests (No approval required & SickRage)"); Log.Debug("Adding tv to database requests (No approval required & SickRage)");
RequestService.AddRequest(model); RequestService.AddRequest(model);
var notify2 = new NotificationModel { Title = model.Title, User = model.RequestedBy, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest }; var notify2 = new NotificationModel { Title = model.Title, User = Username, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest };
NotificationService.Publish(notify2); NotificationService.Publish(notify2);
return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullShowName} was successfully added!" }); return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullShowName} was successfully added!" });
@ -462,7 +462,7 @@ namespace PlexRequests.UI.Modules
RequestService.AddRequest(model); RequestService.AddRequest(model);
var notificationModel = new NotificationModel { Title = model.Title, User = model.RequestedBy, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest }; var notificationModel = new NotificationModel { Title = model.Title, User = Username, DateTime = DateTime.Now, NotificationType = NotificationType.NewRequest };
NotificationService.Publish(notificationModel); NotificationService.Publish(notificationModel);
return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullShowName} was successfully added!" }); return Response.AsJson(new JsonResponseModel { Result = true, Message = $"{fullShowName} was successfully added!" });

Write Preview
Loading…
Cancel
Save