mirror of
https://github.com/Ombi-app/Ombi.git
synced 2025-08-19 21:03:17 -07:00
A bit more logging for #32
This commit is contained in:
tidusjar
parent
13ee1efd86
commit
a686832e3f
1 changed files with 169 additions and 162 deletions
|
|
@ -1,165 +1,172 @@
|
||||||
#region Copyright
|
#region Copyright
|
||||||
// /************************************************************************
|
// /************************************************************************
|
||||||
// Copyright (c) 2016 Jamie Rees
|
// Copyright (c) 2016 Jamie Rees
|
||||||
// File: HeadphonesSender.cs
|
// File: HeadphonesSender.cs
|
||||||
// Created By: Jamie Rees
|
// Created By: Jamie Rees
|
||||||
//
|
//
|
||||||
// Permission is hereby granted, free of charge, to any person obtaining
|
// Permission is hereby granted, free of charge, to any person obtaining
|
||||||
// a copy of this software and associated documentation files (the
|
// a copy of this software and associated documentation files (the
|
||||||
// "Software"), to deal in the Software without restriction, including
|
// "Software"), to deal in the Software without restriction, including
|
||||||
// without limitation the rights to use, copy, modify, merge, publish,
|
// without limitation the rights to use, copy, modify, merge, publish,
|
||||||
// distribute, sublicense, and/or sell copies of the Software, and to
|
// distribute, sublicense, and/or sell copies of the Software, and to
|
||||||
// permit persons to whom the Software is furnished to do so, subject to
|
// permit persons to whom the Software is furnished to do so, subject to
|
||||||
// the following conditions:
|
// the following conditions:
|
||||||
//
|
//
|
||||||
// The above copyright notice and this permission notice shall be
|
// The above copyright notice and this permission notice shall be
|
||||||
// included in all copies or substantial portions of the Software.
|
// included in all copies or substantial portions of the Software.
|
||||||
//
|
//
|
||||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
||||||
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
||||||
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
||||||
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
|
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
|
||||||
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
|
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
|
||||||
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
|
||||||
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||||
// ************************************************************************/
|
// ************************************************************************/
|
||||||
#endregion
|
#endregion
|
||||||
|
using System.Linq;
|
||||||
using System;
|
using System.Threading;
|
||||||
using System.Linq;
|
using System.Threading.Tasks;
|
||||||
using System.Security.Cryptography.X509Certificates;
|
|
||||||
using System.Threading;
|
using NLog;
|
||||||
using System.Threading.Tasks;
|
|
||||||
|
using PlexRequests.Api.Interfaces;
|
||||||
using NLog;
|
using PlexRequests.Core;
|
||||||
|
using PlexRequests.Core.SettingModels;
|
||||||
using PlexRequests.Api.Interfaces;
|
using PlexRequests.Store;
|
||||||
using PlexRequests.Core;
|
|
||||||
using PlexRequests.Core.SettingModels;
|
namespace PlexRequests.UI.Helpers
|
||||||
using PlexRequests.Store;
|
{
|
||||||
|
public class HeadphonesSender
|
||||||
namespace PlexRequests.UI.Helpers
|
{
|
||||||
{
|
public HeadphonesSender(IHeadphonesApi api, HeadphonesSettings settings, IRequestService request)
|
||||||
public class HeadphonesSender
|
{
|
||||||
{
|
Api = api;
|
||||||
public HeadphonesSender(IHeadphonesApi api, HeadphonesSettings settings, IRequestService request)
|
Settings = settings;
|
||||||
{
|
RequestService = request;
|
||||||
Api = api;
|
}
|
||||||
Settings = settings;
|
|
||||||
RequestService = request;
|
private int WaitTime => 2000;
|
||||||
}
|
private int CounterMax => 60;
|
||||||
|
|
||||||
private int WaitTime => 2000;
|
private static readonly Logger Log = LogManager.GetCurrentClassLogger();
|
||||||
private int CounterMax => 60;
|
private IHeadphonesApi Api { get; }
|
||||||
|
private IRequestService RequestService { get; }
|
||||||
private static readonly Logger Log = LogManager.GetCurrentClassLogger();
|
private HeadphonesSettings Settings { get; }
|
||||||
private IHeadphonesApi Api { get; }
|
|
||||||
private IRequestService RequestService { get; }
|
public async Task<bool> AddAlbum(RequestedModel request)
|
||||||
private HeadphonesSettings Settings { get; }
|
{
|
||||||
|
var addArtistResult = await AddArtist(request);
|
||||||
public async Task<bool> AddAlbum(RequestedModel request)
|
if (!addArtistResult)
|
||||||
{
|
{
|
||||||
var addArtistResult = await AddArtist(request);
|
return false;
|
||||||
if (!addArtistResult)
|
}
|
||||||
{
|
|
||||||
return false;
|
// Artist is now active
|
||||||
}
|
// Add album
|
||||||
|
var albumResult = await Api.AddAlbum(Settings.ApiKey, Settings.FullUri, request.MusicBrainzId);
|
||||||
// Artist is now active
|
if (!albumResult)
|
||||||
// Add album
|
{
|
||||||
var albumResult = await Api.AddAlbum(Settings.ApiKey, Settings.FullUri, request.MusicBrainzId);
|
Log.Error("Couldn't add the album to headphones");
|
||||||
if (!albumResult)
|
}
|
||||||
{
|
|
||||||
Log.Error("Couldn't add the album to headphones");
|
// Set the status to wanted and search
|
||||||
}
|
var status = await SetAlbumStatus(request);
|
||||||
|
if (!status)
|
||||||
// Set the status to wanted and search
|
{
|
||||||
var status = await SetAlbumStatus(request);
|
return false;
|
||||||
if (!status)
|
}
|
||||||
{
|
|
||||||
return false;
|
// Approve it
|
||||||
}
|
request.Approved = true;
|
||||||
|
|
||||||
// Approve it
|
// Update the record
|
||||||
request.Approved = true;
|
var updated = RequestService.UpdateRequest(request);
|
||||||
|
|
||||||
// Update the record
|
return updated;
|
||||||
var updated = RequestService.UpdateRequest(request);
|
}
|
||||||
|
|
||||||
return updated;
|
private async Task<bool> AddArtist(RequestedModel request)
|
||||||
}
|
{
|
||||||
|
var index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
||||||
private async Task<bool> AddArtist(RequestedModel request)
|
var artistExists = index.Any(x => x.ArtistID == request.ArtistId);
|
||||||
{
|
if (!artistExists)
|
||||||
var index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
{
|
||||||
var artistExists = index.Any(x => x.ArtistID == request.ArtistId);
|
var artistAdd = Api.AddArtist(Settings.ApiKey, Settings.FullUri, request.ArtistId);
|
||||||
if (!artistExists)
|
Log.Info("Artist add result : {0}", artistAdd);
|
||||||
{
|
}
|
||||||
var artistAdd = Api.AddArtist(Settings.ApiKey, Settings.FullUri, request.ArtistId);
|
|
||||||
Log.Info("Artist add result : {0}", artistAdd);
|
var counter = 0;
|
||||||
}
|
while (index.All(x => x.ArtistID != request.ArtistId))
|
||||||
|
{
|
||||||
var counter = 0;
|
Thread.Sleep(WaitTime);
|
||||||
while (index.All(x => x.ArtistID != request.ArtistId))
|
counter++;
|
||||||
{
|
Log.Trace("Artist is still not present in the index. Counter = {0}", counter);
|
||||||
Thread.Sleep(WaitTime);
|
index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
||||||
counter++;
|
|
||||||
Log.Trace("Artist is still not present in the index. Counter = {0}", counter);
|
if (counter > CounterMax)
|
||||||
index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
{
|
||||||
//Fetch failed name
|
Log.Trace("Artist is still not present in the index. Counter = {0}. Returning false", counter);
|
||||||
if (counter > CounterMax)
|
Log.Warn("We have tried adding the artist but it seems they are still not in headphones.");
|
||||||
{
|
return false;
|
||||||
Log.Trace("Artist is still not present in the index. Counter = {0}. Returning false", counter);
|
}
|
||||||
return false;
|
}
|
||||||
}
|
var addedArtist = index.FirstOrDefault(x => x.ArtistID == request.ArtistId);
|
||||||
}
|
var artistName = addedArtist?.ArtistName ?? string.Empty;
|
||||||
var addedArtist = index.FirstOrDefault(x => x.ArtistID == request.ArtistId);
|
while (artistName.Contains("Fetch failed"))
|
||||||
var artistName = addedArtist?.ArtistName ?? string.Empty;
|
{
|
||||||
while (artistName.Contains("Fetch failed"))
|
Thread.Sleep(WaitTime);
|
||||||
{
|
|
||||||
await Api.RefreshArtist(Settings.ApiKey, Settings.FullUri, request.ArtistId);
|
await Api.RefreshArtist(Settings.ApiKey, Settings.FullUri, request.ArtistId);
|
||||||
|
|
||||||
index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
||||||
|
|
||||||
artistName = index?.FirstOrDefault(x => x.ArtistID == request.ArtistId)?.ArtistName ?? string.Empty;
|
artistName = index?.FirstOrDefault(x => x.ArtistID == request.ArtistId)?.ArtistName ?? string.Empty;
|
||||||
}
|
if (counter > CounterMax)
|
||||||
|
{
|
||||||
counter = 0;
|
Log.Trace("Artist fetch has failed. Counter = {0}. Returning false", counter);
|
||||||
var artistStatus = index.Where(x => x.ArtistID == request.ArtistId).Select(x => x.Status).FirstOrDefault();
|
Log.Warn("Artist in headphones fetch has failed, we have tried refreshing the artist but no luck.");
|
||||||
while (artistStatus != "Active")
|
return false;
|
||||||
{
|
}
|
||||||
Thread.Sleep(WaitTime);
|
}
|
||||||
counter++;
|
|
||||||
Log.Trace("Artist status {1}. Counter = {0}", counter, artistStatus);
|
counter = 0;
|
||||||
index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
var artistStatus = index.Where(x => x.ArtistID == request.ArtistId).Select(x => x.Status).FirstOrDefault();
|
||||||
artistStatus = index.Where(x => x.ArtistID == request.ArtistId).Select(x => x.Status).FirstOrDefault();
|
while (artistStatus != "Active")
|
||||||
if (counter > CounterMax)
|
{
|
||||||
{
|
Thread.Sleep(WaitTime);
|
||||||
Log.Trace("Artist status is still not active. Counter = {0}. Returning false", counter);
|
counter++;
|
||||||
return false;
|
Log.Trace("Artist status {1}. Counter = {0}", counter, artistStatus);
|
||||||
}
|
index = await Api.GetIndex(Settings.ApiKey, Settings.FullUri);
|
||||||
}
|
artistStatus = index.Where(x => x.ArtistID == request.ArtistId).Select(x => x.Status).FirstOrDefault();
|
||||||
return true;
|
if (counter > CounterMax)
|
||||||
}
|
{
|
||||||
|
Log.Trace("Artist status is still not active. Counter = {0}. Returning false", counter);
|
||||||
private async Task<bool> SetAlbumStatus(RequestedModel request)
|
Log.Warn("The artist status is still not Active. We have waited long enough, seems to be a big delay in headphones.");
|
||||||
{
|
return false;
|
||||||
var counter = 0;
|
}
|
||||||
var setStatus = await Api.QueueAlbum(Settings.ApiKey, Settings.FullUri, request.MusicBrainzId);
|
}
|
||||||
|
return true;
|
||||||
while (!setStatus)
|
}
|
||||||
{
|
|
||||||
Thread.Sleep(WaitTime);
|
private async Task<bool> SetAlbumStatus(RequestedModel request)
|
||||||
counter++;
|
{
|
||||||
Log.Trace("Setting Album status. Counter = {0}", counter);
|
var counter = 0;
|
||||||
setStatus = await Api.QueueAlbum(Settings.ApiKey, Settings.FullUri, request.MusicBrainzId);
|
var setStatus = await Api.QueueAlbum(Settings.ApiKey, Settings.FullUri, request.MusicBrainzId);
|
||||||
if (counter > CounterMax)
|
|
||||||
{
|
while (!setStatus)
|
||||||
Log.Trace("Album status is still not active. Counter = {0}. Returning false", counter);
|
{
|
||||||
return false;
|
Thread.Sleep(WaitTime);
|
||||||
}
|
counter++;
|
||||||
}
|
Log.Trace("Setting Album status. Counter = {0}", counter);
|
||||||
return true;
|
setStatus = await Api.QueueAlbum(Settings.ApiKey, Settings.FullUri, request.MusicBrainzId);
|
||||||
}
|
if (counter > CounterMax)
|
||||||
}
|
{
|
||||||
|
Log.Trace("Album status is still not active. Counter = {0}. Returning false", counter);
|
||||||
|
Log.Warn("We tried to se the status for the album but headphones didn't want to snatch it.");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
Loading…
Add table
Add a link
Reference in a new issue