43 Commits

Author SHA1 Message Date
Jonas F
d9087e2fe5 Remove proxy environment variables from compose 2024-09-06 20:46:50 +02:00
pcjones
bdd77e11f8 Merge branch 'develop' of https://github.com/PCJones/UmlautAdaptarr into develop 2024-09-05 14:24:48 +02:00
pcjones
54fe1c0f89 Remove proxy support 2024-09-05 14:24:42 +02:00
Jonas F
706199074d Update README.md 2024-09-04 20:04:42 +02:00
pcjones
b8575831bd Fix appsettings.json example 2024-09-04 19:40:02 +02:00
pcjones
370e3ca06b Fix warnings 2024-09-04 19:39:15 +02:00
pcjones
238bd9cc60 Code cleanup 2024-09-04 19:30:31 +02:00
Jonas F
4db26e374f Update README.md 2024-09-04 19:17:13 +02:00
Jonas F
ce74044b9b Update README.md 2024-09-04 19:16:37 +02:00
Jonas F
202c09c739 Merge pull request #32 from PCJones/master
Update README.md
2024-09-04 19:16:04 +02:00
Jonas F
c5440fd6c5 Merge pull request #23 from xpsony/multiInstance_serilog
Multi *Arr Instance Support , Add Serilog for better logging, Add Fluent Validator
2024-09-04 19:14:53 +02:00
pcjones
f886b17164 Add FixBadReleaseNaming base concept 2024-09-04 19:00:58 +02:00
Jonas F
40f2131196 Update README.md 2024-09-04 18:31:03 +02:00
pcjones
fd6a8581d8 Also search for "GERMAN" if title ends with "Germany" and also match for title without "Germany" 2024-09-04 18:06:51 +02:00
Felix Glang
74104c300e Create IpInfo.cs
Move To Model
2024-06-09 13:40:47 +02:00
Felix Glang
42554d255e Add IP Infos in Startup
Now User can simply see , if his VPN is working correctly
2024-06-09 13:38:06 +02:00
Felix Glang
c7b92974f4 Update GlobalInstanceOptionsValidator.cs
Add Max Timeout
2024-06-09 12:34:55 +02:00
Felix Glang
265c098630 Fix BeReachable 2024-06-09 12:27:26 +02:00
xpsony
d892f9014e Merge branch 'PCJones:master' into multiInstance_serilog 2024-05-23 09:49:35 +02:00
pcjones
759e276311 Merge branch 'develop' of https://github.com/PCJones/UmlautAdaptarr into develop 2024-05-15 20:40:22 +02:00
pcjones
b44c294782 Fix NoSpecialCharactersExceptHyphenAndUmlautsRegex not matching any special characters 2024-05-15 20:40:18 +02:00
Jonas F
26b030808f Merge pull request #25 from PCJones/PCJones-patch-1
Fix readme link
2024-05-12 13:34:08 +02:00
Jonas F
b5fa4308ea Merge pull request #24 from PCJones/PCJones-patch-1
Fix readme link
2024-05-12 13:33:42 +02:00
Jonas F
dea00feaee Update README.md 2024-05-12 13:33:04 +02:00
Felix Glang
ef7182888b Update GlobalInstanceOptionsValidator.cs
Cleanup Code
2024-04-29 20:35:18 +02:00
Felix Glang
5931fd6a8a Fix Bug
If UmlautAdaparr was started before the *Arr. The BeReachable test failed, although the config was correct. Now it is tested every 15 seconds for 3 minutes whether the corresponding application can be reached. Before the test fails
2024-04-29 20:21:46 +02:00
Felix Glang
c788e0ed76 Fix Log 2024-04-28 13:21:48 +02:00
Felix Glang
0bb480b1d0 Add Config Validator + Bug Fixing 2024-04-28 12:59:44 +02:00
Felix Glang
f73b3b5578 Fix in IOptions Copy Section 2024-04-27 21:53:12 +02:00
Felix Glang
e6173ae683 Add Example for Name 2024-04-27 21:29:23 +02:00
Felix Glang
52acb5ff6e Fix named IOption Bug
Fix  named IOption Bug
2024-04-27 21:27:04 +02:00
xpsony
1a32cc325c Merge branch 'PCJones:master' into multiInstance_serilog 2024-04-27 18:50:41 +02:00
Felix Glang
f06a866a2f Add Multi Instance Support , Serilog , little Hotfixes 2024-04-27 18:48:43 +02:00
Jonas F
90c849de52 Merge pull request #20 from PCJones/develop
Add port mapping
2024-04-25 15:30:14 +02:00
Jonas F
176b0a74a6 Update port mapping comment 2024-04-24 15:24:14 +02:00
Jonas F
ffcc8fddcd Add port mapping 2024-04-24 15:21:12 +02:00
Jonas F
81dae8c237 Merge pull request #19 from PCJones/develop
v0.5 release
2024-04-23 22:01:41 +02:00
Jonas F
aa70c91a87 Update README.md 2024-04-23 21:38:13 +02:00
Jonas F
3d2ec82e0f Merge pull request #18 from Br33ce/patch-1
Update Readme
2024-04-23 17:16:00 +02:00
Br33ce
9c9c1583f7 Update README.md 2024-04-23 17:12:14 +02:00
Br33ce
f9a02ae487 Update README.md 2024-04-23 14:42:43 +02:00
Jonas F
0cc0ca98e1 Update README.md 2024-04-22 14:33:50 +02:00
pcjones
a4abb31ea1 Check for known hosts before logging https warning 2024-04-15 19:25:53 +02:00
36 changed files with 1487 additions and 941 deletions

View File

@@ -2,36 +2,22 @@
## English description coming soon ## English description coming soon
## Erste Testversion ## Beschreibung
Wer möchte kann den UmlautAdaptarr jetzt gerne testen! Über Feedback würde ich mich sehr freuen! Wer möchte kann den UmlautAdaptarr jetzt gerne testen! Über Feedback würde ich mich sehr freuen!
Es sollte mit allen *arrs funktionieren, hat aber nur bei Sonarr, Readarr und Lidarr schon Auswirkungen (abgesehen vom Caching). Es sollte mit allen *arrs funktionieren, hat aber nur bei Sonarr, Readarr und Lidarr schon Auswirkungen (abgesehen vom Caching).
Momentan ist docker dafür nötig, wer kein Docker nutzt muss sich noch etwas gedulden.
[Link zum Docker Image](https://hub.docker.com/r/pcjones/umlautadaptarr)
Zusätzlich müsst ihr in Sonarr oder Prowlarr einen neuen Indexer hinzufügen (für jeden Indexer, bei dem UmlautAdapdarr greifen soll).
Am Beispiel von sceneNZBs:
![grafik](https://github.com/PCJones/UmlautAdaptarr/assets/377223/07c7ca45-e0e5-4a82-af63-365bb23c55c9)
Also alles wie immer, nur dass ihr als API-URL nicht direkt z.B. `https://scenenzbs.com` eingebt, sondern
`http://localhost:5005/_/scenenzbs.com`
Den API-Key müsst ihr natürlich auch ganz normal setzen.
## Was macht UmlautAdaptarr überhaupt?
UmlautAdaptarr löst mehrere Probleme: UmlautAdaptarr löst mehrere Probleme:
- Releases mit Umlauten werden grundsätzlich nicht korrekt von den *Arrs importiert - Releases mit Umlauten werden grundsätzlich nicht korrekt von den *Arrs importiert
- Releases mit Umlauten werden oft nicht korrekt gefunden (*Arrs suchen nach "o" statt "ö" & es fehlt häufig die korrekte Zuordnung zur Serie/zum Film beim Indexer) - Releases mit Umlauten werden oft nicht korrekt gefunden (*Arrs suchen nach "o" statt "ö" & es fehlt häufig die korrekte Zuordnung zur Serie/zum Film beim Indexer)
- Sonarr & Radarr erwarten immer den englischen Titel von https://thetvdb.com/ bzw. https://www.themoviedb.org/. Das führt bei deutschen Produktionen oder deutschen Übersetzungen oft zu Problemen - falls die *arrs schon mal etwas mit der Meldung `Found matching series/movie via grab history, but release was matched to series by ID. Automatic import is not possible/` nicht importiert haben, dann war das der Grund. - Sonarr & Radarr erwarten immer den englischen Titel von https://thetvdb.com/ bzw. https://www.themoviedb.org/. Das führt bei deutschen Produktionen oder deutschen Übersetzungen oft zu Problemen - falls die *arrs schon mal etwas mit der Meldung `Found matching series/movie via grab history, but release was matched to series by ID. Automatic import is not possible/` nicht importiert haben, dann war das der Grund.
- Releases mit schlechtem Naming (z.B. von der Group TvR die kein "GERMAN" in den Releasename tun) werden korrigiert, so dass Sonarr&Radarr diese korrekt erkennen (optional)
- Zusätzlich werden einige andere Fehler behoben, die häufig dazu führen, dass Titel nicht erfolgreich gefunden, geladen oder importiert werden.
# Wie macht UmlautAdaptarr das? ## Wie macht UmlautAdaptarr das?
UmlautAdaptarr tut so, als wäre es ein Indexer. In Wahrheit schaltet sich UmlautAdaptarr aber nur zwischen die *arrs und den echten Indexer und kann somit die Suchen sowie die Ergebnisse abfangen und bearbeiten. UmlautAdaptarr tut so, als wäre es ein Indexer. In Wahrheit schaltet sich UmlautAdaptarr aber nur zwischen die *arrs und den echten Indexer und kann somit die Suchen sowie die Ergebnisse abfangen und bearbeiten.
Am Ende werden die gefundenen Releases immer so umbenannt, dass die Arrs sie einwandfrei erkennen. Am Ende werden die gefundenen Releases immer so umbenannt, dass die Arrs sie einwandfrei erkennen.
Einige Beispiele findet ihr unter Features. Einige Beispiele finden sich [weiter unten](https://github.com/PCJones/UmlautAdaptarr?tab=readme-ov-file#beispiel-funktionalit%C3%A4t).
## Features ## Features
@@ -45,14 +31,61 @@ Einige Beispiele findet ihr unter Features.
| Releases mit deutschem Titel werden erkannt | ✓ | | Releases mit deutschem Titel werden erkannt | ✓ |
| Releases mit TVDB-Alias Titel werden erkannt | ✓ | | Releases mit TVDB-Alias Titel werden erkannt | ✓ |
| Korrekte Suche und Erkennung von Titel mit Umlauten | ✓ | | Korrekte Suche und Erkennung von Titel mit Umlauten | ✓ |
| Anfragen-Caching für 5 Minuten zur Reduzierung der API-Zugriffe | ✓ | | Anfragen-Caching für 12 Minuten zur Reduzierung der API-Zugriffe | ✓ |
| Usenet (newznab) Support |✓| | Usenet (newznab) Support |✓|
| Torrent (torznab) Support |✓| | Torrent (torznab) Support |✓|
| Radarr Support | Geplant | | Support von mehreren *arr-Instanzen des gleichen Typs (z.B. 2x Sonarr) |
| Releases mit mit schlechtem Naming werden korrekt umbenannt (optional) | in Arbeit |
| Radarr Support | in Arbeit |
| Webinterface | Geplant |
| Prowlarr Unterstützung für "DE" SceneNZBs Kategorien | Geplant | | Prowlarr Unterstützung für "DE" SceneNZBs Kategorien | Geplant |
| Unterstützung weiterer Sprachen neben Deutsch | Geplant | | Unterstützung weiterer Sprachen neben Deutsch | Geplant |
| Wünsche? | Vorschläge? | | Wünsche? | Vorschläge? |
## Installation
Momentan ist Docker dafür nötig, wer kein Docker nutzt muss sich noch etwas gedulden. Eine Unraid-App gibt es auch, einfach nach `umlautadaptarr` suchen.
[Link zum Docker Image](https://hub.docker.com/r/pcjones/umlautadaptarr)
Nicht benötigte Umgebungsvariablen, z.B. wenn Readarr oder Lidarr nicht benötigt werden, können entfernt werden.
### Konfiguration in Prowlarr (**empfohlen**)
Das ist die **empfohlene** Methode um den UmlautAdaptarr einzurichten. Sie hat den Vorteil, dass es, sofern man mehrere Indexer nutzt, keinen Geschwindigkeitsverlust bei der Suche geben sollte.
1) In Prowlarr: Settings>Indexers bzw. Einstellungen>Indexer öffnen
2) Lege einen neuen HTTP-Proxy an:
![Image](https://github.com/PCJones/UmlautAdaptarr/assets/377223/b97418d8-d972-4e3c-9d2f-3a830a5ac0a3)
- Name: UmlautAdaptarr HTTP Proxy (Beispiel)
- Port: `5006` (Port beachten!)
- Tag: `umlautadaptarr`
- Host: Je nachdem, wie deine Docker-Konfiguration ist, kann es sein, dass du entweder `umlautadaptarr` oder `localhost`, oder ggf. die IP des Host setzen musst. Probiere es sonst einfach aus, indem du auf Test klickst.
- Die Username- und Passwort-Felder können leergelassen werden.
3) Gehe zur Indexer-Übersichtsseite
4) Für alle Indexer/Tracker, die den UmlautAdaptarr nutzen sollen:
![grafik](https://github.com/PCJones/UmlautAdaptarr/assets/377223/3daea3f1-7c7b-4982-84e2-ea6a42d90fba)
- Füge den `umlautadaptarr` Tag hinzu
- **Wichtig:** Ändere die URL von `https` zu `http`. (Dies ist erforderlich, damit der UmlautAdaptarr die Anfragen **lokal** abfangen kann. **Ausgehende** Anfragen an den Indexer verwenden natürlich weiterhin https).
5) Klicke danach auf `Test All Indexers` bzw `Alle Indexer Testen`. Falls du irgendwo noch `https` statt `http` stehen hast, sollte in den UmlautAdaptarr logs eine Warnung auftauchen. Mindestens solltest du aber noch ein zweites Mal alle Indexer durchgehen und überprüfen, ob überall `http` eingestellt ist - Indexer, bei denen noch `https` steht, werden nämlich einwandfrei funktionieren - allerdings ohne, dass der UmlautAdaptarr bei diesen wirken kann.
### Konfiguration in Sonarr/Radarr oder Prowlarr ohne Proxy
Falls du kein Prowlarr nutzt oder nur 1-3 Indexer nutzt, kannst du diese alternative Konfigurationsmöglichkeit nutzen.
Dafür musst du einfach nur alle Indexer, bei denen der UmlautAdaptarr greifen soll, bearbeiten:
Am Beispiel von sceneNZBs:
![grafik](https://github.com/PCJones/UmlautAdaptarr/assets/377223/07c7ca45-e0e5-4a82-af63-365bb23c55c9)
Also alles wie immer, nur dass als API-URL nicht direkt z.B. `https://scenenzbs.com` gesetzt wird, sondern
`http://localhost:5005/_/scenenzbs.com`
Der API-Key muss natürlich auch ganz normal gesetzt werden.
## Beispiel-Funktionalität ## Beispiel-Funktionalität
In den Klammern am Ende des Releasenamens (Bild 2 & 4) steht zu Anschauungszwecken der deutsche Titel der vorher nicht gefunden bzw. akzeptiert wurde. Das bleibt natürlich nicht so ;) In den Klammern am Ende des Releasenamens (Bild 2 & 4) steht zu Anschauungszwecken der deutsche Titel der vorher nicht gefunden bzw. akzeptiert wurde. Das bleibt natürlich nicht so ;)
@@ -66,7 +99,7 @@ In den Klammern am Ende des Releasenamens (Bild 2 & 4) steht zu Anschauungszweck
**Vorher:** Es werden nur Releases mit dem englischen Titel der Serie gefunden **Vorher:** Es werden nur Releases mit dem englischen Titel der Serie gefunden
![Vorherige Suche, englische Titel](https://github.com/PCJones/UmlautAdaptarr/assets/377223/ed7ca0fa-ac36-4584-87ac-b29f32dd9ace) ![Vorherige Suche, englische Titel](https://github.com/PCJones/UmlautAdaptarr/assets/377223/ed7ca0fa-ac36-4584-87ac-b29f32dd9ace)
**Jetzt:** Es werden auch Titel mit dem deutschen Namen gefunden :D (haben nicht alle Suchergebnisse auf den Screenshot gepasst) **Jetzt:** Es werden auch Titel mit dem deutschen Namen gefunden :D
![Jetzige Suche, deutsche und englische Titel](https://github.com/PCJones/UmlautAdaptarr/assets/377223/1c2dbe1a-5943-4fc4-91ef-29708082900e) ![Jetzige Suche, deutsche und englische Titel](https://github.com/PCJones/UmlautAdaptarr/assets/377223/1c2dbe1a-5943-4fc4-91ef-29708082900e)

View File

@@ -23,7 +23,7 @@ namespace UmlautAdaptarr.Controllers
return NotFound($"{domain} is not a valid URL."); return NotFound($"{domain} is not a valid URL.");
} }
var initialSearchResult = await PerformSingleSearchRequest(domain, queryParameters) as ContentResult; ContentResult? initialSearchResult = await PerformSingleSearchRequest(domain, queryParameters) as ContentResult;
if (initialSearchResult == null) if (initialSearchResult == null)
{ {
return null; return null;

View File

@@ -0,0 +1,10 @@
using UmlautAdaptarr.Models;
namespace UmlautAdaptarr.Interfaces;
public interface IArrApplication
{
Task<IEnumerable<SearchItem>> FetchAllItemsAsync();
Task<SearchItem?> FetchItemByExternalIdAsync(string externalId);
Task<SearchItem?> FetchItemByTitleAsync(string title);
}

View File

@@ -0,0 +1,33 @@
using System.Text.Json.Serialization;
namespace UmlautAdaptarr.Utilities;
public class IpInfo
{
[JsonPropertyName("ip")]
public string? Ip { get; set; }
[JsonPropertyName("hostname")]
public string? Hostname { get; set; }
[JsonPropertyName("city")]
public string? City { get; set; }
[JsonPropertyName("region")]
public string? Region { get; set; }
[JsonPropertyName("country")]
public string? Country { get; set; }
[JsonPropertyName("loc")]
public string? Loc { get; set; }
[JsonPropertyName("org")]
public string? Org { get; set; }
[JsonPropertyName("postal")]
public string? Postal { get; set; }
[JsonPropertyName("timezone")]
public string? Timezone { get; set; }
}

View File

@@ -108,6 +108,20 @@ namespace UmlautAdaptarr.Models
} }
// if a german title ends with "Germany" (e.g. Good Luck Guys Germany) also add a search string that replaces Germany with GERMAN
// (e.g. Good Luck Guys GERMAN). This is because reality shows often have different formats in different countries with the same
// name. // also add a matching title without GERMAN
if (germanTitle?.EndsWith("germany", StringComparison.OrdinalIgnoreCase) ?? false)
{
TitleSearchVariations = [.. TitleSearchVariations,
..
GenerateVariations(
(germanTitle[..^7] + "GERMAN").RemoveExtraWhitespaces(),
mediaType)];
allTitleVariations.AddRange(GenerateVariations(germanTitle[..^8].Trim(), mediaType));
}
// If title contains ":" also match for "-" // If title contains ":" also match for "-"
if (germanTitle?.Contains(':') ?? false) if (germanTitle?.Contains(':') ?? false)
{ {
@@ -152,7 +166,7 @@ namespace UmlautAdaptarr.Models
} }
} }
private IEnumerable<string> GenerateVariations(string? title, string mediaType) private static IEnumerable<string> GenerateVariations(string? title, string mediaType)
{ {
if (title == null) if (title == null)
{ {

View File

@@ -1,15 +1,17 @@
namespace UmlautAdaptarr.Options.ArrOptions namespace UmlautAdaptarr.Options.ArrOptions.InstanceOptions
{ {
/// <summary> public class GlobalInstanceOptions
/// Base Options for ARR applications
/// </summary>
public class ArrApplicationBaseOptions
{ {
/// <summary> /// <summary>
/// Indicates whether the Arr application is enabled. /// Indicates whether the Arr application is enabled.
/// </summary> /// </summary>
public bool Enabled { get; set; } public bool Enabled { get; set; }
/// <summary>
/// Name of the Instance
/// </summary>
public string Name { get; set; }
/// <summary> /// <summary>
/// The host of the ARR application. /// The host of the ARR application.
/// </summary> /// </summary>

View File

@@ -0,0 +1,6 @@
namespace UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
public class LidarrInstanceOptions : GlobalInstanceOptions
{
}

View File

@@ -0,0 +1,6 @@
namespace UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
public class ReadarrInstanceOptions : GlobalInstanceOptions
{
}

View File

@@ -0,0 +1,6 @@
namespace UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
public class SonarrInstanceOptions : GlobalInstanceOptions
{
}

View File

@@ -1,9 +0,0 @@
namespace UmlautAdaptarr.Options.ArrOptions
{
/// <summary>
/// Lidarr Options
/// </summary>
public class LidarrInstanceOptions : ArrApplicationBaseOptions
{
}
}

View File

@@ -1,9 +0,0 @@
namespace UmlautAdaptarr.Options.ArrOptions
{
/// <summary>
/// Readarr Options
/// </summary>
public class ReadarrInstanceOptions : ArrApplicationBaseOptions
{
}
}

View File

@@ -1,9 +0,0 @@
namespace UmlautAdaptarr.Options.ArrOptions
{
/// <summary>
/// Sonarr Options
/// </summary>
public class SonarrInstanceOptions : ArrApplicationBaseOptions
{
}
}

View File

@@ -1,27 +0,0 @@
namespace UmlautAdaptarr.Options;
/// <summary>
/// Represents options for proxy configuration.
/// </summary>
public class Proxy
{
/// <summary>
/// Gets or sets a value indicating whether to use a proxy.
/// </summary>
public bool Enabled { get; set; }
/// <summary>
/// Gets or sets the address of the proxy.
/// </summary>
public string? Address { get; set; }
/// <summary>
/// Gets or sets the username for proxy authentication.
/// </summary>
public string? Username { get; set; }
/// <summary>
/// Gets or sets the password for proxy authentication.
/// </summary>
public string? Password { get; set; }
}

View File

@@ -1,32 +0,0 @@
namespace UmlautAdaptarr.Options;
/// <summary>
/// Represents options for proxy configuration.
/// </summary>
public class ProxyOptions
{
/// <summary>
/// Gets or sets a value indicating whether to use a proxy.
/// </summary>
public bool Enabled { get; set; }
/// <summary>
/// Gets or sets the address of the proxy.
/// </summary>
public string? Address { get; set; }
/// <summary>
/// Gets or sets the username for proxy authentication.
/// </summary>
public string? Username { get; set; }
/// <summary>
/// Gets or sets the password for proxy authentication.
/// </summary>
public string? Password { get; set; }
/// <summary>
/// Bypass Local Ip Addresses , Proxy will ignore local Ip Addresses
/// </summary>
public bool BypassOnLocal { get; set; }
}

View File

@@ -1,31 +1,44 @@
using System.Net; using System.Net;
using Serilog;
using Serilog.Filters;
using UmlautAdaptarr.Options; using UmlautAdaptarr.Options;
using UmlautAdaptarr.Routing; using UmlautAdaptarr.Routing;
using UmlautAdaptarr.Services; using UmlautAdaptarr.Services;
using UmlautAdaptarr.Services.Factory;
using UmlautAdaptarr.Utilities; using UmlautAdaptarr.Utilities;
internal class Program internal class Program
{ {
private static void Main(string[] args) private static void Main(string[] args)
{ {
Helper.ShowLogo();
Helper.ShowInformation();
// TODO: // TODO:
// add option to sort by nzb age // add option to sort by nzb age
var builder = WebApplication.CreateBuilder(args); var builder = WebApplication.CreateBuilder(args);
var configuration = builder.Configuration; var configuration = builder.Configuration;
// TODO workaround to not log api keys
Log.Logger = new LoggerConfiguration()
.ReadFrom.Configuration(configuration)
.WriteTo.Console(outputTemplate: "[{Timestamp:yyyy-MM-dd HH:mm:ss} {Level:u3}] {Message:lj}{NewLine}{Exception}")
.Filter.ByExcluding(Matching.FromSource("System.Net.Http.HttpClient"))
.Filter.ByExcluding(Matching.FromSource("Microsoft.Extensions.Http.DefaultHttpClientFactory"))
//.Enrich.With(new ApiKeyMaskingEnricher("appsettings.json")) // TODO - Not working currently
.CreateLogger();
builder.Services.AddSerilog();
// Add services to the container. // Add services to the container.
builder.Services.AddHttpClient("HttpClient").ConfigurePrimaryHttpMessageHandler(() => builder.Services.AddHttpClient("HttpClient").ConfigurePrimaryHttpMessageHandler(() =>
{ {
var handler = new HttpClientHandler var handler = new HttpClientHandler
{ {
AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate | DecompressionMethods.Brotli AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate |
DecompressionMethods.Brotli
}; };
var proxyOptions = configuration.GetSection("Proxy").Get<ProxyOptions>();
handler.ConfigureProxy(proxyOptions);
return handler; return handler;
}); });
@@ -35,20 +48,8 @@ internal class Program
//options.SizeLimit = 20000; //options.SizeLimit = 20000;
}); });
builder.Services.AllowResolvingKeyedServicesAsDictionary();
// TODO workaround to not log api keys
builder.Logging.AddFilter((category, level) =>
{
// Prevent logging of HTTP request and response if the category is HttpClient
if (category.Contains("System.Net.Http.HttpClient") || category.Contains("Microsoft.Extensions.Http.DefaultHttpClientFactory"))
{
return false;
}
return true;
});
builder.Services.AddControllers(); builder.Services.AddControllers();
builder.Services.AddHostedService<ArrSyncBackgroundService>();
builder.AddTitleLookupService(); builder.AddTitleLookupService();
builder.Services.AddSingleton<SearchItemLookupService>(); builder.Services.AddSingleton<SearchItemLookupService>();
builder.Services.AddSingleton<TitleMatchingService>(); builder.Services.AddSingleton<TitleMatchingService>();
@@ -57,6 +58,8 @@ internal class Program
builder.AddReadarrSupport(); builder.AddReadarrSupport();
builder.Services.AddSingleton<CacheService>(); builder.Services.AddSingleton<CacheService>();
builder.Services.AddSingleton<ProxyRequestService>(); builder.Services.AddSingleton<ProxyRequestService>();
builder.Services.AddSingleton<ArrApplicationFactory>();
builder.Services.AddHostedService<ArrSyncBackgroundService>();
builder.Services.AddSingleton<IHostedService, HttpProxyService>(); builder.Services.AddSingleton<IHostedService, HttpProxyService>();
var app = builder.Build(); var app = builder.Build();
@@ -65,36 +68,35 @@ internal class Program
app.UseHttpsRedirection(); app.UseHttpsRedirection();
app.UseAuthorization(); app.UseAuthorization();
app.MapControllerRoute(name: "caps", app.MapControllerRoute("caps",
pattern: "{options}/{*domain}", "{options}/{*domain}",
defaults: new { controller = "Caps", action = "Caps" }, new { controller = "Caps", action = "Caps" },
constraints: new { t = new TRouteConstraint("caps") }); new { t = new TRouteConstraint("caps") });
app.MapControllerRoute(name: "movie-search", app.MapControllerRoute("movie-search",
pattern: "{options}/{*domain}", "{options}/{*domain}",
defaults: new { controller = "Search", action = "MovieSearch" }, new { controller = "Search", action = "MovieSearch" },
constraints: new { t = new TRouteConstraint("movie") }); new { t = new TRouteConstraint("movie") });
app.MapControllerRoute(name: "tv-search", app.MapControllerRoute("tv-search",
pattern: "{options}/{*domain}", "{options}/{*domain}",
defaults: new { controller = "Search", action = "TVSearch" }, new { controller = "Search", action = "TVSearch" },
constraints: new { t = new TRouteConstraint("tvsearch") }); new { t = new TRouteConstraint("tvsearch") });
app.MapControllerRoute(name: "music-search", app.MapControllerRoute("music-search",
pattern: "{options}/{*domain}", "{options}/{*domain}",
defaults: new { controller = "Search", action = "MusicSearch" }, new { controller = "Search", action = "MusicSearch" },
constraints: new { t = new TRouteConstraint("music") }); new { t = new TRouteConstraint("music") });
app.MapControllerRoute(name: "book-search", app.MapControllerRoute("book-search",
pattern: "{options}/{*domain}", "{options}/{*domain}",
defaults: new { controller = "Search", action = "BookSearch" }, new { controller = "Search", action = "BookSearch" },
constraints: new { t = new TRouteConstraint("book") }); new { t = new TRouteConstraint("book") });
app.MapControllerRoute(name: "generic-search",
pattern: "{options}/{*domain}",
defaults: new { controller = "Search", action = "GenericSearch" },
constraints: new { t = new TRouteConstraint("search") });
app.MapControllerRoute("generic-search",
"{options}/{*domain}",
new { controller = "Search", action = "GenericSearch" },
new { t = new TRouteConstraint("search") });
app.Run(); app.Run();
} }
} }

View File

@@ -1,13 +1,14 @@
using Microsoft.Extensions.Caching.Memory; using UmlautAdaptarr.Interfaces;
using UmlautAdaptarr.Models; using UmlautAdaptarr.Models;
using UmlautAdaptarr.Services;
namespace UmlautAdaptarr.Providers namespace UmlautAdaptarr.Providers;
{
public abstract class ArrClientBase() public abstract class ArrClientBase : IArrApplication
{ {
#pragma warning disable CS8618 // Ein Non-Nullable-Feld muss beim Beenden des Konstruktors einen Wert ungleich NULL enthalten. Erwägen Sie die Deklaration als Nullable.
public string InstanceName;
#pragma warning restore CS8618 // Ein Non-Nullable-Feld muss beim Beenden des Konstruktors einen Wert ungleich NULL enthalten. Erwägen Sie die Deklaration als Nullable.
public abstract Task<IEnumerable<SearchItem>> FetchAllItemsAsync(); public abstract Task<IEnumerable<SearchItem>> FetchAllItemsAsync();
public abstract Task<SearchItem?> FetchItemByExternalIdAsync(string externalId); public abstract Task<SearchItem?> FetchItemByExternalIdAsync(string externalId);
public abstract Task<SearchItem?> FetchItemByTitleAsync(string title); public abstract Task<SearchItem?> FetchItemByTitleAsync(string title);
} }
}

View File

@@ -1,17 +0,0 @@
namespace UmlautAdaptarr.Providers
{
public static class ArrClientFactory
{
// TODO, still uses old IConfiguration
// TODO not used yet
public static IEnumerable<TClient> CreateClients<TClient>(
Func<string, TClient> constructor, IConfiguration configuration, string configKey) where TClient : ArrClientBase
{
var hosts = configuration.GetValue<string>(configKey)?.Split(',') ?? throw new ArgumentException($"{configKey} environment variable must be set if the app is enabled");
foreach (var host in hosts)
{
yield return constructor(host.Trim());
}
}
}
}

View File

@@ -1,46 +1,64 @@
using Microsoft.Extensions.Caching.Memory; using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.Options; using Microsoft.Extensions.Options;
using Newtonsoft.Json; using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using UmlautAdaptarr.Models; using UmlautAdaptarr.Models;
using UmlautAdaptarr.Options.ArrOptions; using UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
using UmlautAdaptarr.Services; using UmlautAdaptarr.Services;
using UmlautAdaptarr.Utilities; using UmlautAdaptarr.Utilities;
namespace UmlautAdaptarr.Providers namespace UmlautAdaptarr.Providers;
public class LidarrClient : ArrClientBase
{ {
public class LidarrClient( private readonly IMemoryCache _cache;
private readonly CacheService _cacheService;
private readonly IHttpClientFactory _clientFactory;
private readonly ILogger<LidarrClient> _logger;
private readonly string _mediaType = "audio";
public LidarrClient([ServiceKey] string instanceName,
IHttpClientFactory clientFactory, IHttpClientFactory clientFactory,
CacheService cacheService, CacheService cacheService,
IMemoryCache cache, IMemoryCache cache, IOptionsMonitor<LidarrInstanceOptions> options,
ILogger<LidarrClient> logger, IOptions<LidarrInstanceOptions> options) : ArrClientBase() ILogger<LidarrClient> logger)
{ {
public LidarrInstanceOptions LidarrOptions { get; } = options.Value; _clientFactory = clientFactory;
private readonly string _mediaType = "audio"; _cacheService = cacheService;
_cache = cache;
_logger = logger;
InstanceName = instanceName;
Options = options.Get(InstanceName);
_logger.LogInformation($"Init Lidarr ({InstanceName})");
}
public LidarrInstanceOptions Options { get; init; }
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync() public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
{ {
var httpClient = clientFactory.CreateClient(); var httpClient = _clientFactory.CreateClient();
var items = new List<SearchItem>(); var items = new List<SearchItem>();
try try
{ {
var lidarrArtistsUrl = $"{LidarrOptions.Host}/api/v1/artist?apikey={LidarrOptions.ApiKey}"; var lidarrArtistsUrl = $"{Options.Host}/api/v1/artist?apikey={Options.ApiKey}";
logger.LogInformation($"Fetching all artists from Lidarr: {UrlUtilities.RedactApiKey(lidarrArtistsUrl)}"); _logger.LogInformation(
$"Fetching all artists from Lidarr ({InstanceName}) : {UrlUtilities.RedactApiKey(lidarrArtistsUrl)}");
var artistsApiResponse = await httpClient.GetStringAsync(lidarrArtistsUrl); var artistsApiResponse = await httpClient.GetStringAsync(lidarrArtistsUrl);
var artists = JsonConvert.DeserializeObject<List<dynamic>>(artistsApiResponse); var artists = JsonConvert.DeserializeObject<List<dynamic>>(artistsApiResponse);
if (artists == null) if (artists == null)
{ {
logger.LogError($"Lidarr artists API request resulted in null"); _logger.LogError($"Lidarr ({InstanceName}) artists API request resulted in null");
return items; return items;
} }
logger.LogInformation($"Successfully fetched {artists.Count} artists from Lidarr.");
_logger.LogInformation($"Successfully fetched {artists.Count} artists from Lidarr ({InstanceName}).");
foreach (var artist in artists) foreach (var artist in artists)
{ {
var artistId = (int)artist.id; var artistId = (int)artist.id;
var lidarrAlbumUrl = $"{LidarrOptions.Host}/api/v1/album?artistId={artistId}&apikey={LidarrOptions.ApiKey}"; var lidarrAlbumUrl = $"{Options.Host}/api/v1/album?artistId={artistId}&apikey={Options.ApiKey}";
// TODO add caching here // TODO add caching here
// Disable cache for now as it can result in problems when adding new albums that aren't displayed on the artists page initially // Disable cache for now as it can result in problems when adding new albums that aren't displayed on the artists page initially
@@ -50,21 +68,24 @@ namespace UmlautAdaptarr.Providers
//} //}
//else //else
//{ //{
logger.LogInformation($"Fetching all albums from artistId {artistId} from Lidarr: {UrlUtilities.RedactApiKey(lidarrAlbumUrl)}"); _logger.LogInformation(
$"Fetching all albums from artistId {artistId} from Lidarr ({InstanceName}) : {UrlUtilities.RedactApiKey(lidarrAlbumUrl)}");
var albumApiResponse = await httpClient.GetStringAsync(lidarrAlbumUrl); var albumApiResponse = await httpClient.GetStringAsync(lidarrAlbumUrl);
var albums = JsonConvert.DeserializeObject<List<dynamic>>(albumApiResponse); var albums = JsonConvert.DeserializeObject<List<dynamic>>(albumApiResponse);
//} //}
if (albums == null) if (albums == null)
{ {
logger.LogWarning($"Lidarr album API request for artistId {artistId} resulted in null"); _logger.LogWarning(
$"Lidarr ({InstanceName}) album API request for artistId {artistId} resulted in null");
continue; continue;
} }
logger.LogInformation($"Successfully fetched {albums.Count} albums for artistId {artistId} from Lidarr."); _logger.LogInformation(
$"Successfully fetched {albums.Count} albums for artistId {artistId} from Lidarr ({InstanceName}).");
// Cache albums for 3 minutes // Cache albums for 3 minutes
cache.Set(lidarrAlbumUrl, albums, TimeSpan.FromMinutes(3)); _cache.Set(lidarrAlbumUrl, albums, TimeSpan.FromMinutes(3));
foreach (var album in albums) foreach (var album in albums)
{ {
@@ -80,11 +101,11 @@ namespace UmlautAdaptarr.Providers
var searchItem = new SearchItem var searchItem = new SearchItem
( (
arrId: artistId, artistId,
externalId: externalId, externalId,
title: albumTitle, albumTitle,
expectedTitle: albumTitle, albumTitle,
germanTitle: null, null,
aliases: aliases, aliases: aliases,
mediaType: _mediaType, mediaType: _mediaType,
expectedAuthor: artistName expectedAuthor: artistName
@@ -94,11 +115,11 @@ namespace UmlautAdaptarr.Providers
} }
} }
logger.LogInformation($"Finished fetching all items from Lidarr"); _logger.LogInformation($"Finished fetching all items from Lidarr ({InstanceName})");
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching all artists from Lidarr: {ex.Message}"); _logger.LogError($"Error fetching all artists from Lidarr ({InstanceName}) : {ex.Message}");
} }
return items; return items;
@@ -112,20 +133,19 @@ namespace UmlautAdaptarr.Providers
// TODO if possible look at the author in search query and only update for author // TODO if possible look at the author in search query and only update for author
var searchItems = await FetchAllItemsAsync(); var searchItems = await FetchAllItemsAsync();
foreach (var searchItem in searchItems ?? []) foreach (var searchItem in searchItems ?? [])
{
try try
{ {
cacheService.CacheSearchItem(searchItem); _cacheService.CacheSearchItem(searchItem);
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError(ex, $"An error occurred while caching search item with ID {searchItem.ArrId}."); _logger.LogError(ex,
} $"An error occurred while caching search item with ID {searchItem.ArrId} in Lidarr ({InstanceName}).");
} }
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching single artist from Lidarr: {ex.Message}"); _logger.LogError($"Error fetching single artist from Lidarr ({InstanceName}) : {ex.Message}");
} }
return null; return null;
@@ -140,10 +160,9 @@ namespace UmlautAdaptarr.Providers
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching single artist from Lidarr: {ex.Message}"); _logger.LogError($"Error fetching single artist from Lidarr ({InstanceName}): {ex.Message}");
} }
return null; return null;
} }
} }
}

View File

@@ -1,64 +1,82 @@
using Microsoft.Extensions.Caching.Memory; using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.Options; using Microsoft.Extensions.Options;
using Newtonsoft.Json; using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using UmlautAdaptarr.Models; using UmlautAdaptarr.Models;
using UmlautAdaptarr.Options.ArrOptions; using UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
using UmlautAdaptarr.Services; using UmlautAdaptarr.Services;
using UmlautAdaptarr.Utilities; using UmlautAdaptarr.Utilities;
namespace UmlautAdaptarr.Providers namespace UmlautAdaptarr.Providers;
public class ReadarrClient : ArrClientBase
{ {
public class ReadarrClient( private readonly IMemoryCache _cache;
IHttpClientFactory clientFactory, private readonly CacheService _cacheService;
private readonly IHttpClientFactory _clientFactory;
private readonly ILogger<ReadarrClient> _logger;
private readonly string _mediaType = "book";
public ReadarrClient([ServiceKey] string instanceName, IHttpClientFactory clientFactory,
CacheService cacheService, CacheService cacheService,
IMemoryCache cache, IMemoryCache cache,
IOptions<ReadarrInstanceOptions> options, IOptionsMonitor<ReadarrInstanceOptions> options,
ILogger<ReadarrClient> logger) : ArrClientBase() ILogger<ReadarrClient> logger)
{ {
_clientFactory = clientFactory;
_cacheService = cacheService;
_cache = cache;
_logger = logger;
InstanceName = instanceName;
Options = options.Get(InstanceName);
_logger.LogInformation($"Init ReadarrClient ({InstanceName})");
}
public ReadarrInstanceOptions ReadarrOptions { get; } = options.Value; public ReadarrInstanceOptions Options { get; init; }
private readonly string _mediaType = "book";
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync() public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
{ {
var httpClient = clientFactory.CreateClient(); var httpClient = _clientFactory.CreateClient();
var items = new List<SearchItem>(); var items = new List<SearchItem>();
try try
{ {
var readarrAuthorUrl = $"{ReadarrOptions.Host}/api/v1/author?apikey={ReadarrOptions.ApiKey}"; var readarrAuthorUrl = $"{Options.Host}/api/v1/author?apikey={Options.ApiKey}";
logger.LogInformation($"Fetching all authors from Readarr: {UrlUtilities.RedactApiKey(readarrAuthorUrl)}"); _logger.LogInformation(
$"Fetching all authors from Readarr ({InstanceName}) : {UrlUtilities.RedactApiKey(readarrAuthorUrl)}");
var authorApiResponse = await httpClient.GetStringAsync(readarrAuthorUrl); var authorApiResponse = await httpClient.GetStringAsync(readarrAuthorUrl);
var authors = JsonConvert.DeserializeObject<List<dynamic>>(authorApiResponse); var authors = JsonConvert.DeserializeObject<List<dynamic>>(authorApiResponse);
if (authors == null) if (authors == null)
{ {
logger.LogError($"Readarr authors API request resulted in null"); _logger.LogError($"Readarr ({InstanceName}) authors API request resulted in null");
return items; return items;
} }
logger.LogInformation($"Successfully fetched {authors.Count} authors from Readarr.");
_logger.LogInformation($"Successfully fetched {authors.Count} authors from Readarr ({InstanceName}).");
foreach (var author in authors) foreach (var author in authors)
{ {
var authorId = (int)author.id; var authorId = (int)author.id;
var readarrBookUrl = $"{ReadarrOptions.Host}/api/v1/book?authorId={authorId}&apikey={ReadarrOptions.ApiKey}"; var readarrBookUrl = $"{Options.Host}/api/v1/book?authorId={authorId}&apikey={Options.ApiKey}";
// TODO add caching here // TODO add caching here
logger.LogInformation($"Fetching all books from authorId {authorId} from Readarr: {UrlUtilities.RedactApiKey(readarrBookUrl)}"); _logger.LogInformation(
$"Fetching all books from authorId {authorId} from Readarr ({InstanceName}) : {UrlUtilities.RedactApiKey(readarrBookUrl)}");
var bookApiResponse = await httpClient.GetStringAsync(readarrBookUrl); var bookApiResponse = await httpClient.GetStringAsync(readarrBookUrl);
var books = JsonConvert.DeserializeObject<List<dynamic>>(bookApiResponse); var books = JsonConvert.DeserializeObject<List<dynamic>>(bookApiResponse);
if (books == null) if (books == null)
{ {
logger.LogWarning($"Readarr book API request for authorId {authorId} resulted in null"); _logger.LogWarning(
$"Readarr ({InstanceName}) book API request for authorId {authorId} resulted in null");
continue; continue;
} }
logger.LogInformation($"Successfully fetched {books.Count} books for authorId {authorId} from Readarr."); _logger.LogInformation(
$"Successfully fetched {books.Count} books for authorId {authorId} from Readarr ({InstanceName}) .");
// Cache books for 3 minutes // Cache books for 3 minutes
cache.Set(readarrBookUrl, books, TimeSpan.FromMinutes(3)); _cache.Set(readarrBookUrl, books, TimeSpan.FromMinutes(3));
foreach (var book in books) foreach (var book in books)
{ {
@@ -75,11 +93,11 @@ namespace UmlautAdaptarr.Providers
var searchItem = new SearchItem var searchItem = new SearchItem
( (
arrId: authorId, authorId,
externalId: externalId, externalId,
title: bookTitle, bookTitle,
expectedTitle: bookTitle, bookTitle,
germanTitle: null, null,
aliases: aliases, aliases: aliases,
mediaType: _mediaType, mediaType: _mediaType,
expectedAuthor: authorName expectedAuthor: authorName
@@ -89,11 +107,11 @@ namespace UmlautAdaptarr.Providers
} }
} }
logger.LogInformation($"Finished fetching all items from Readarr"); _logger.LogInformation($"Finished fetching all items from Readarr ({InstanceName})");
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching all authors from Readarr: {ex.Message}"); _logger.LogError($"Error fetching all authors from Readarr ({InstanceName}): {ex.Message}");
} }
return items; return items;
@@ -104,21 +122,18 @@ namespace UmlautAdaptarr.Providers
{ {
// Remove author prefix from title if present, e.g., "Tom Clancy: Ghost Protocol" // Remove author prefix from title if present, e.g., "Tom Clancy: Ghost Protocol"
if (!string.IsNullOrEmpty(authorName) && bookTitle.StartsWith($"{authorName}:")) if (!string.IsNullOrEmpty(authorName) && bookTitle.StartsWith($"{authorName}:"))
{
bookTitle = bookTitle[(authorName.Length + 1)..].Trim(); bookTitle = bookTitle[(authorName.Length + 1)..].Trim();
}
// Remove subtitles or additional info enclosed in parentheses or following a colon, if any // Remove subtitles or additional info enclosed in parentheses or following a colon, if any
int firstParenthesisIndex = bookTitle.IndexOf('('); var firstParenthesisIndex = bookTitle.IndexOf('(');
int firstColonIndex = bookTitle.IndexOf(':'); var firstColonIndex = bookTitle.IndexOf(':');
if (firstParenthesisIndex > -1) if (firstParenthesisIndex > -1)
{ {
int endParenthesisIndex = bookTitle.IndexOf(')', firstParenthesisIndex); var endParenthesisIndex = bookTitle.IndexOf(')', firstParenthesisIndex);
if (endParenthesisIndex > -1 && bookTitle.Substring(firstParenthesisIndex + 1, endParenthesisIndex - firstParenthesisIndex - 1).Contains(' ')) if (endParenthesisIndex > -1 && bookTitle
{ .Substring(firstParenthesisIndex + 1, endParenthesisIndex - firstParenthesisIndex - 1)
bookTitle = bookTitle[..firstParenthesisIndex].Trim(); .Contains(' ')) bookTitle = bookTitle[..firstParenthesisIndex].Trim();
}
} }
else if (firstColonIndex > -1) else if (firstColonIndex > -1)
{ {
@@ -137,20 +152,18 @@ namespace UmlautAdaptarr.Providers
// TODO if possible look at the author in search query and only update for author // TODO if possible look at the author in search query and only update for author
var searchItems = await FetchAllItemsAsync(); var searchItems = await FetchAllItemsAsync();
foreach (var searchItem in searchItems ?? []) foreach (var searchItem in searchItems ?? [])
{
try try
{ {
cacheService.CacheSearchItem(searchItem); _cacheService.CacheSearchItem(searchItem);
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError(ex, $"An error occurred while caching search item with ID {searchItem.ArrId}."); _logger.LogError(ex, $"An error occurred while caching search item with ID {searchItem.ArrId}.");
}
} }
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching single author from Readarr: {ex.Message}"); _logger.LogError($"Error fetching single author from Readarr ({InstanceName}) : {ex.Message}");
} }
return null; return null;
@@ -165,10 +178,9 @@ namespace UmlautAdaptarr.Providers
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching single author from Readarr: {ex.Message}"); _logger.LogError($"Error fetching single author from Readarr ({InstanceName}) : {ex.Message}");
} }
return null; return null;
} }
} }
}

View File

@@ -1,53 +1,71 @@
using Microsoft.Extensions.Options; using Microsoft.Extensions.Options;
using Newtonsoft.Json; using Newtonsoft.Json;
using UmlautAdaptarr.Models; using UmlautAdaptarr.Models;
using UmlautAdaptarr.Options.ArrOptions; using UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
using UmlautAdaptarr.Services; using UmlautAdaptarr.Services;
using UmlautAdaptarr.Utilities; using UmlautAdaptarr.Utilities;
namespace UmlautAdaptarr.Providers namespace UmlautAdaptarr.Providers;
public class SonarrClient : ArrClientBase
{ {
public class SonarrClient( private readonly IHttpClientFactory _clientFactory;
private readonly ILogger<SonarrClient> _logger;
private readonly string _mediaType = "tv";
private readonly TitleApiService _titleService;
public SonarrClient([ServiceKey] string instanceName,
IHttpClientFactory clientFactory, IHttpClientFactory clientFactory,
TitleApiService titleService, TitleApiService titleService,
IOptions<SonarrInstanceOptions> options, IOptionsMonitor<SonarrInstanceOptions> options,
ILogger<SonarrClient> logger) : ArrClientBase() ILogger<SonarrClient> logger)
{ {
public SonarrInstanceOptions SonarrOptions { get; } = options.Value; _clientFactory = clientFactory;
private readonly string _mediaType = "tv"; _titleService = titleService;
_logger = logger;
InstanceName = instanceName;
Options = options.Get(InstanceName);
_logger.LogInformation($"Init SonarrClient ({InstanceName})");
}
public SonarrInstanceOptions Options { get; init; }
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync() public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
{ {
var httpClient = clientFactory.CreateClient(); var httpClient = _clientFactory.CreateClient();
var items = new List<SearchItem>(); var items = new List<SearchItem>();
try try
{ {
var sonarrUrl = $"{SonarrOptions.Host}/api/v3/series?includeSeasonImages=false&apikey={SonarrOptions.ApiKey}"; var sonarrUrl = $"{Options.Host}/api/v3/series?includeSeasonImages=false&apikey={Options.ApiKey}";
logger.LogInformation($"Fetching all items from Sonarr: {UrlUtilities.RedactApiKey(sonarrUrl)}"); _logger.LogInformation($"Fetching all items from Sonarr: {UrlUtilities.RedactApiKey(sonarrUrl)}");
var response = await httpClient.GetStringAsync(sonarrUrl); var response = await httpClient.GetStringAsync(sonarrUrl);
var shows = JsonConvert.DeserializeObject<List<dynamic>>(response); var shows = JsonConvert.DeserializeObject<List<dynamic>>(response);
if (shows != null) if (shows != null)
{ {
logger.LogInformation($"Successfully fetched {shows.Count} items from Sonarr."); _logger.LogInformation($"Successfully fetched {shows.Count} items from Sonarr ({InstanceName}).");
foreach (var show in shows) foreach (var show in shows)
{ {
var tvdbId = (string)show.tvdbId; var tvdbId = (string)show.tvdbId;
if (tvdbId == null) if (tvdbId == null)
{ {
logger.LogWarning($"Sonarr Show {show.id} doesn't have a tvdbId."); _logger.LogWarning($"Sonarr ({InstanceName}) Show {show.id} doesn't have a tvdbId.");
continue; continue;
} }
(var germanTitle, var aliases) = await titleService.FetchGermanTitleAndAliasesByExternalIdAsync(_mediaType, tvdbId); var (germanTitle, aliases) =
await _titleService.FetchGermanTitleAndAliasesByExternalIdAsync(_mediaType, tvdbId);
var searchItem = new SearchItem var searchItem = new SearchItem
( (
arrId: (int)show.id, (int)show.id,
externalId: tvdbId, tvdbId,
title: (string)show.title, (string)show.title,
expectedTitle: (string)show.title, (string)show.title,
germanTitle: germanTitle, germanTitle,
aliases: aliases, aliases: aliases,
mediaType: _mediaType mediaType: _mediaType
); );
@@ -56,11 +74,11 @@ namespace UmlautAdaptarr.Providers
} }
} }
logger.LogInformation($"Finished fetching all items from Sonarr"); _logger.LogInformation($"Finished fetching all items from Sonarr ({InstanceName})");
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching all shows from Sonarr: {ex.Message}"); _logger.LogError($"Error fetching all shows from Sonarr ({InstanceName}) : {ex.Message}");
} }
return items; return items;
@@ -68,12 +86,14 @@ namespace UmlautAdaptarr.Providers
public override async Task<SearchItem?> FetchItemByExternalIdAsync(string externalId) public override async Task<SearchItem?> FetchItemByExternalIdAsync(string externalId)
{ {
var httpClient = clientFactory.CreateClient(); var httpClient = _clientFactory.CreateClient();
try try
{ {
var sonarrUrl = $"{SonarrOptions.Host}/api/v3/series?tvdbId={externalId}&includeSeasonImages=false&apikey={SonarrOptions.ApiKey}"; var sonarrUrl =
logger.LogInformation($"Fetching item by external ID from Sonarr: {UrlUtilities.RedactApiKey(sonarrUrl)}"); $"{Options.Host}/api/v3/series?tvdbId={externalId}&includeSeasonImages=false&apikey={Options.ApiKey}";
_logger.LogInformation(
$"Fetching item by external ID from Sonarr ({InstanceName}): {UrlUtilities.RedactApiKey(sonarrUrl)}");
var response = await httpClient.GetStringAsync(sonarrUrl); var response = await httpClient.GetStringAsync(sonarrUrl);
var shows = JsonConvert.DeserializeObject<dynamic>(response); var shows = JsonConvert.DeserializeObject<dynamic>(response);
var show = shows?[0]; var show = shows?[0];
@@ -83,29 +103,31 @@ namespace UmlautAdaptarr.Providers
var tvdbId = (string)show.tvdbId; var tvdbId = (string)show.tvdbId;
if (tvdbId == null) if (tvdbId == null)
{ {
logger.LogWarning($"Sonarr Show {show.id} doesn't have a tvdbId."); _logger.LogWarning($"Sonarr ({InstanceName}) Show {show.id} doesn't have a tvdbId.");
return null; return null;
} }
(var germanTitle, var aliases) = await titleService.FetchGermanTitleAndAliasesByExternalIdAsync(_mediaType, tvdbId);
var (germanTitle, aliases) =
await _titleService.FetchGermanTitleAndAliasesByExternalIdAsync(_mediaType, tvdbId);
var searchItem = new SearchItem var searchItem = new SearchItem
( (
arrId: (int)show.id, (int)show.id,
externalId: tvdbId, tvdbId,
title: (string)show.title, (string)show.title,
expectedTitle: (string)show.title, (string)show.title,
germanTitle: germanTitle, germanTitle,
aliases: aliases, aliases: aliases,
mediaType: _mediaType mediaType: _mediaType
); );
logger.LogInformation($"Successfully fetched show {searchItem.Title} from Sonarr."); _logger.LogInformation($"Successfully fetched show {searchItem.Title} from Sonarr ({InstanceName}).");
return searchItem; return searchItem;
} }
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching single show from Sonarr: {ex.Message}"); _logger.LogError($"Error fetching single show from Sonarr ({InstanceName}): {ex.Message}");
} }
return null; return null;
@@ -113,59 +135,58 @@ namespace UmlautAdaptarr.Providers
public override async Task<SearchItem?> FetchItemByTitleAsync(string title) public override async Task<SearchItem?> FetchItemByTitleAsync(string title)
{ {
var httpClient = clientFactory.CreateClient(); var httpClient = _clientFactory.CreateClient();
try try
{ {
(string? germanTitle, string? tvdbId, string[]? aliases) = await titleService.FetchGermanTitleAndExternalIdAndAliasesByTitle(_mediaType, title); var (germanTitle, tvdbId, aliases) =
await _titleService.FetchGermanTitleAndExternalIdAndAliasesByTitle(_mediaType, title);
if (tvdbId == null) if (tvdbId == null) return null;
{
return null;
}
var sonarrUrl = $"{SonarrOptions.Host}/api/v3/series?tvdbId={tvdbId}&includeSeasonImages=false&apikey={SonarrOptions.ApiKey}"; var sonarrUrl =
$"{Options.Host}/api/v3/series?tvdbId={tvdbId}&includeSeasonImages=false&apikey={Options.ApiKey}";
var sonarrApiResponse = await httpClient.GetStringAsync(sonarrUrl); var sonarrApiResponse = await httpClient.GetStringAsync(sonarrUrl);
var shows = JsonConvert.DeserializeObject<dynamic>(sonarrApiResponse); var shows = JsonConvert.DeserializeObject<dynamic>(sonarrApiResponse);
if (shows == null) if (shows == null)
{ {
logger.LogError($"Parsing Sonarr API response for TVDB ID {tvdbId} resulted in null"); _logger.LogError($"Parsing Sonarr ({InstanceName}) API response for TVDB ID {tvdbId} resulted in null");
return null; return null;
} }
else if (shows.Count == 0)
if (shows.Count == 0)
{ {
logger.LogWarning($"No results found for TVDB ID {tvdbId}"); _logger.LogWarning($"No results found for TVDB ID {tvdbId}");
return null; return null;
} }
var expectedTitle = (string)shows[0].title; var expectedTitle = (string)shows[0].title;
if (expectedTitle == null) if (expectedTitle == null)
{ {
logger.LogError($"Sonarr Title for TVDB ID {tvdbId} is null"); _logger.LogError($"Sonarr ({InstanceName}) : Title for TVDB ID {tvdbId} is null");
return null; return null;
} }
var searchItem = new SearchItem var searchItem = new SearchItem
( (
arrId: (int)shows[0].id, (int)shows[0].id,
externalId: tvdbId, tvdbId,
title: (string)shows[0].title, (string)shows[0].title,
expectedTitle: (string)shows[0].title, (string)shows[0].title,
germanTitle: germanTitle, germanTitle,
aliases: aliases, aliases: aliases,
mediaType: _mediaType mediaType: _mediaType
); );
logger.LogInformation($"Successfully fetched show {searchItem.Title} from Sonarr."); _logger.LogInformation($"Successfully fetched show {searchItem.Title} from Sonarr ({InstanceName}).");
return searchItem; return searchItem;
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError($"Error fetching single show from Sonarr: {ex.Message}"); _logger.LogError($"Error fetching single show from Sonarr ({InstanceName}) : {ex.Message}");
} }
return null; return null;
} }
} }
}

View File

@@ -1,27 +1,21 @@
using Microsoft.Extensions.Caching.Memory; using UmlautAdaptarr.Models;
using Microsoft.Extensions.DependencyInjection; using UmlautAdaptarr.Services.Factory;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging; namespace UmlautAdaptarr.Services;
using Newtonsoft.Json;
using System;
using System.Threading;
using System.Threading.Tasks;
using UmlautAdaptarr.Models;
using UmlautAdaptarr.Providers;
namespace UmlautAdaptarr.Services
{
public class ArrSyncBackgroundService( public class ArrSyncBackgroundService(
SonarrClient sonarrClient, ArrApplicationFactory arrApplicationFactory,
LidarrClient lidarrClient,
ReadarrClient readarrClient,
CacheService cacheService, CacheService cacheService,
ILogger<ArrSyncBackgroundService> logger) : BackgroundService ILogger<ArrSyncBackgroundService> logger)
: BackgroundService
{ {
public ArrApplicationFactory ArrApplicationFactory { get; } = arrApplicationFactory;
protected override async Task ExecuteAsync(CancellationToken stoppingToken) protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{ {
logger.LogInformation("ArrSyncBackgroundService is starting."); logger.LogInformation("ArrSyncBackgroundService is starting.");
bool lastRunSuccess = true; var lastRunSuccess = true;
while (!stoppingToken.IsCancellationRequested) while (!stoppingToken.IsCancellationRequested)
{ {
@@ -39,12 +33,14 @@ namespace UmlautAdaptarr.Services
if (lastRunSuccess) if (lastRunSuccess)
{ {
lastRunSuccess = false; lastRunSuccess = false;
logger.LogInformation("ArrSyncBackgroundService is trying again in 2 minutes because not all syncs were successful."); logger.LogInformation(
"ArrSyncBackgroundService is trying again in 2 minutes because not all syncs were successful.");
await Task.Delay(TimeSpan.FromMinutes(2), stoppingToken); await Task.Delay(TimeSpan.FromMinutes(2), stoppingToken);
} }
else else
{ {
logger.LogInformation("ArrSyncBackgroundService is trying again in one hour only because not all syncs were successful twice in a row."); logger.LogInformation(
"ArrSyncBackgroundService is trying again in one hour only because not all syncs were successful twice in a row.");
await Task.Delay(TimeSpan.FromHours(1), stoppingToken); await Task.Delay(TimeSpan.FromHours(1), stoppingToken);
} }
} }
@@ -58,27 +54,34 @@ namespace UmlautAdaptarr.Services
try try
{ {
var success = true; var success = true;
if (readarrClient.ReadarrOptions.Enabled)
{
var syncSuccess = await FetchItemsFromReadarrAsync(); if (ArrApplicationFactory.SonarrInstances.Any())
success = success && syncSuccess;
}
if (sonarrClient.SonarrOptions.Enabled)
{ {
var syncSuccess = await FetchItemsFromSonarrAsync(); var syncSuccess = await FetchItemsFromSonarrAsync();
success = success && syncSuccess; success = success && syncSuccess;
} }
if (lidarrClient.LidarrOptions.Enabled)
if (ArrApplicationFactory.ReadarrInstances.Any())
{
var syncSuccess = await FetchItemsFromReadarrAsync();
success = success && syncSuccess;
}
if (ArrApplicationFactory.ReadarrInstances.Any())
{ {
var syncSuccess = await FetchItemsFromLidarrAsync(); var syncSuccess = await FetchItemsFromLidarrAsync();
success = success && syncSuccess; success = success && syncSuccess;
} }
return success; return success;
} }
catch (Exception ex) catch (Exception ex)
{ {
logger.LogError(ex, "An error occurred while fetching items from the Arrs."); logger.LogError(ex, "An error occurred while fetching items from the Arrs.");
} }
return false; return false;
} }
@@ -86,7 +89,15 @@ namespace UmlautAdaptarr.Services
{ {
try try
{ {
var items = await sonarrClient.FetchAllItemsAsync(); var items = new List<SearchItem>();
foreach (var sonarrClient in ArrApplicationFactory.SonarrInstances)
{
var result = await sonarrClient.FetchAllItemsAsync();
items = items.Union(result).ToList();
}
UpdateSearchItems(items); UpdateSearchItems(items);
return items?.Any() ?? false; return items?.Any() ?? false;
} }
@@ -94,6 +105,7 @@ namespace UmlautAdaptarr.Services
{ {
logger.LogError(ex, "An error occurred while updating search item from Sonarr."); logger.LogError(ex, "An error occurred while updating search item from Sonarr.");
} }
return false; return false;
} }
@@ -101,7 +113,14 @@ namespace UmlautAdaptarr.Services
{ {
try try
{ {
var items = await lidarrClient.FetchAllItemsAsync(); var items = new List<SearchItem>();
foreach (var lidarrClient in ArrApplicationFactory.LidarrInstances)
{
var result = await lidarrClient.FetchAllItemsAsync();
items = items.Union(result).ToList();
}
UpdateSearchItems(items); UpdateSearchItems(items);
return items?.Any() ?? false; return items?.Any() ?? false;
} }
@@ -109,6 +128,7 @@ namespace UmlautAdaptarr.Services
{ {
logger.LogError(ex, "An error occurred while updating search item from Lidarr."); logger.LogError(ex, "An error occurred while updating search item from Lidarr.");
} }
return false; return false;
} }
@@ -116,7 +136,14 @@ namespace UmlautAdaptarr.Services
{ {
try try
{ {
var items = await readarrClient.FetchAllItemsAsync(); var items = new List<SearchItem>();
foreach (var readarrClient in ArrApplicationFactory.ReadarrInstances)
{
var result = await readarrClient.FetchAllItemsAsync();
items = items.Union(result).ToList();
}
UpdateSearchItems(items); UpdateSearchItems(items);
return items?.Any() ?? false; return items?.Any() ?? false;
} }
@@ -124,13 +151,13 @@ namespace UmlautAdaptarr.Services
{ {
logger.LogError(ex, "An error occurred while updating search item from Lidarr."); logger.LogError(ex, "An error occurred while updating search item from Lidarr.");
} }
return false; return false;
} }
private void UpdateSearchItems(IEnumerable<SearchItem>? searchItems) private void UpdateSearchItems(IEnumerable<SearchItem>? searchItems)
{ {
foreach (var searchItem in searchItems ?? []) foreach (var searchItem in searchItems ?? [])
{
try try
{ {
cacheService.CacheSearchItem(searchItem); cacheService.CacheSearchItem(searchItem);
@@ -141,5 +168,3 @@ namespace UmlautAdaptarr.Services
} }
} }
} }
}
}

View File

@@ -0,0 +1,77 @@
using UmlautAdaptarr.Interfaces;
using UmlautAdaptarr.Providers;
namespace UmlautAdaptarr.Services.Factory
{
/// <summary>
/// Factory for creating RrApplication instances.
/// </summary>
public class ArrApplicationFactory
{
private readonly ILogger<ArrApplicationFactory> _logger;
/// <summary>
/// Get all IArrApplication instances.
/// </summary>
public IDictionary<string, IArrApplication> AllInstances { get; init; }
/// <summary>
/// Get all SonarrClient instances.
/// </summary>
public IEnumerable<SonarrClient> SonarrInstances { get; init; }
/// <summary>
/// Get all LidarrClient instances.
/// </summary>
public IEnumerable<LidarrClient> LidarrInstances { get; init; }
/// <summary>
/// Get all ReadarrClient instances.
/// </summary>
public IEnumerable<ReadarrClient> ReadarrInstances { get; init; }
/// <summary>
/// Constructor for the ArrApplicationFactory.
/// </summary>
/// <param name="rrArrApplications">A dictionary of IArrApplication instances.</param>
/// <param name="logger">Logger Instanz</param>
public ArrApplicationFactory(IDictionary<string, IArrApplication> rrArrApplications, ILogger<ArrApplicationFactory> logger)
{
_logger = logger;
try
{
SonarrInstances = rrArrApplications.Values.OfType<SonarrClient>();
LidarrInstances = rrArrApplications.Values.OfType<LidarrClient>();
ReadarrInstances = rrArrApplications.Values.OfType<ReadarrClient>();
AllInstances = rrArrApplications;
if (!AllInstances.Values.Any())
{
throw new Exception("No RrApplication could be successfully initialized. This could be due to a faulty configuration");
}
}
catch (Exception e)
{
_logger.LogError("Error while Register ArrFactory. This might be a Config Problem", e.Message);
throw;
}
}
/// <summary>
/// Returns an IArrApplication instance that matches the given name.
/// </summary>
/// <param name="nameOfArrInstance">The name of the IArrApplication instance being sought.</param>
/// <returns>The IArrApplication instance that matches the given name.</returns>
/// <exception cref="ArgumentException">Thrown when no IArrApplication instance with the given name can be found.</exception>
public IArrApplication GetArrInstanceByName(string nameOfArrInstance)
{
var instance = AllInstances.FirstOrDefault(up => up.Key.Equals(nameOfArrInstance)).Value;
if (instance == null)
{
throw new ArgumentException($"No ArrService with the name {nameOfArrInstance} could be found");
}
return instance;
}
}
}

View File

@@ -10,11 +10,15 @@ namespace UmlautAdaptarr.Services
private readonly ILogger<HttpProxyService> _logger; private readonly ILogger<HttpProxyService> _logger;
private readonly int _proxyPort = 5006; // TODO move to appsettings.json private readonly int _proxyPort = 5006; // TODO move to appsettings.json
private readonly IHttpClientFactory _clientFactory; private readonly IHttpClientFactory _clientFactory;
private readonly HashSet<string> _knownHosts = [];
private readonly object _hostsLock = new();
private static readonly string[] newLineSeparator = ["\r\n"];
public HttpProxyService(ILogger<HttpProxyService> logger, IHttpClientFactory clientFactory) public HttpProxyService(ILogger<HttpProxyService> logger, IHttpClientFactory clientFactory)
{ {
_logger = logger; _logger = logger;
_clientFactory = clientFactory; _clientFactory = clientFactory;
_knownHosts.Add("prowlarr.servarr.com");
} }
private async Task HandleRequests(CancellationToken stoppingToken) private async Task HandleRequests(CancellationToken stoppingToken)
@@ -30,7 +34,7 @@ namespace UmlautAdaptarr.Services
{ {
using var clientStream = new NetworkStream(clientSocket, ownsSocket: true); using var clientStream = new NetworkStream(clientSocket, ownsSocket: true);
var buffer = new byte[8192]; var buffer = new byte[8192];
var bytesRead = await clientStream.ReadAsync(buffer, 0, buffer.Length); var bytesRead = await clientStream.ReadAsync(buffer);
var requestString = Encoding.ASCII.GetString(buffer, 0, bytesRead); var requestString = Encoding.ASCII.GetString(buffer, 0, bytesRead);
if (requestString.StartsWith("CONNECT")) if (requestString.StartsWith("CONNECT"))
@@ -47,16 +51,18 @@ namespace UmlautAdaptarr.Services
private async Task HandleHttpsConnect(string requestString, NetworkStream clientStream, Socket clientSocket) private async Task HandleHttpsConnect(string requestString, NetworkStream clientStream, Socket clientSocket)
{ {
var targetInfo = ParseTargetInfo(requestString); var (host, port) = ParseTargetInfo(requestString);
if (targetInfo.host != "prowlarr.servarr.com")
// Prowlarr will send grab requests via https which cannot be changed
if (!_knownHosts.Contains(host))
{ {
_logger.LogWarning($"IMPORTANT! {Environment.NewLine} Indexer {targetInfo.host} needs to be set to http:// instead of https:// {Environment.NewLine}" + _logger.LogWarning($"IMPORTANT! {Environment.NewLine} Indexer {host} needs to be set to http:// instead of https:// {Environment.NewLine}" +
$"UmlautAdaptarr will not work for {targetInfo.host}!"); $"UmlautAdaptarr will not work for {host}!");
} }
using var targetSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); using var targetSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try try
{ {
await targetSocket.ConnectAsync(targetInfo.host, targetInfo.port); await targetSocket.ConnectAsync(host, port);
await clientStream.WriteAsync(Encoding.ASCII.GetBytes("HTTP/1.1 200 Connection Established\r\n\r\n")); await clientStream.WriteAsync(Encoding.ASCII.GetBytes("HTTP/1.1 200 Connection Established\r\n\r\n"));
using var targetStream = new NetworkStream(targetSocket, ownsSocket: true); using var targetStream = new NetworkStream(targetSocket, ownsSocket: true);
await RelayTraffic(clientStream, targetStream); await RelayTraffic(clientStream, targetStream);
@@ -74,8 +80,17 @@ namespace UmlautAdaptarr.Services
{ {
var headers = ParseHeaders(buffer, bytesRead); var headers = ParseHeaders(buffer, bytesRead);
string userAgent = headers.FirstOrDefault(h => h.Key == "User-Agent").Value; string userAgent = headers.FirstOrDefault(h => h.Key == "User-Agent").Value;
var uri = new Uri(requestString.Split(' ')[1]); var uri = new Uri(requestString.Split(' ')[1]);
// Add to known hosts if not already present
lock (_hostsLock)
{
if (!_knownHosts.Contains(uri.Host))
{
_knownHosts.Add(uri.Host);
}
}
var modifiedUri = $"http://localhost:5005/_/{uri.Host}{uri.PathAndQuery}"; // TODO read port from appsettings? var modifiedUri = $"http://localhost:5005/_/{uri.Host}{uri.PathAndQuery}"; // TODO read port from appsettings?
using var client = _clientFactory.CreateClient(); using var client = _clientFactory.CreateClient();
var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, modifiedUri); var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, modifiedUri);
@@ -108,21 +123,21 @@ namespace UmlautAdaptarr.Services
{ {
var headers = new Dictionary<string, string>(); var headers = new Dictionary<string, string>();
var headerString = Encoding.ASCII.GetString(buffer, 0, length); var headerString = Encoding.ASCII.GetString(buffer, 0, length);
var lines = headerString.Split(new string[] { "\r\n" }, StringSplitOptions.RemoveEmptyEntries); var lines = headerString.Split(newLineSeparator, StringSplitOptions.RemoveEmptyEntries);
foreach (var line in lines.Skip(1)) // Skip the request line foreach (var line in lines.Skip(1)) // Skip the request line
{ {
var colonIndex = line.IndexOf(':'); var colonIndex = line.IndexOf(':');
if (colonIndex > 0) if (colonIndex > 0)
{ {
var key = line.Substring(0, colonIndex).Trim(); var key = line[..colonIndex].Trim();
var value = line.Substring(colonIndex + 1).Trim(); var value = line[(colonIndex + 1)..].Trim();
headers[key] = value; headers[key] = value;
} }
} }
return headers; return headers;
} }
private (string host, int port) ParseTargetInfo(string requestLine) private static (string host, int port) ParseTargetInfo(string requestLine)
{ {
var parts = requestLine.Split(' ')[1].Split(':'); var parts = requestLine.Split(' ')[1].Split(':');
return (parts[0], int.Parse(parts[1])); return (parts[0], int.Parse(parts[1]));
@@ -135,7 +150,7 @@ namespace UmlautAdaptarr.Services
await Task.WhenAll(clientToTargetTask, targetToClientTask); await Task.WhenAll(clientToTargetTask, targetToClientTask);
} }
private async Task RelayStream(NetworkStream input, NetworkStream output) private static async Task RelayStream(NetworkStream input, NetworkStream output)
{ {
byte[] buffer = new byte[8192]; byte[] buffer = new byte[8192];
int bytesRead; int bytesRead;

View File

@@ -1,12 +1,11 @@
using UmlautAdaptarr.Models; using UmlautAdaptarr.Models;
using UmlautAdaptarr.Providers; using UmlautAdaptarr.Providers;
using UmlautAdaptarr.Services.Factory;
namespace UmlautAdaptarr.Services namespace UmlautAdaptarr.Services
{ {
public class SearchItemLookupService(CacheService cacheService, public class SearchItemLookupService(CacheService cacheService,
SonarrClient sonarrClient, ArrApplicationFactory arrApplicationFactory)
ReadarrClient readarrClient,
LidarrClient lidarrClient)
{ {
public async Task<SearchItem?> GetOrFetchSearchItemByExternalId(string mediaType, string externalId) public async Task<SearchItem?> GetOrFetchSearchItemByExternalId(string mediaType, string externalId)
{ {
@@ -22,24 +21,41 @@ namespace UmlautAdaptarr.Services
switch (mediaType) switch (mediaType)
{ {
case "tv": case "tv":
if (sonarrClient.SonarrOptions.Enabled)
var sonarrInstances = arrApplicationFactory.SonarrInstances;
if (sonarrInstances.Any())
{
foreach (var sonarrClient in sonarrInstances)
{ {
fetchedItem = await sonarrClient.FetchItemByExternalIdAsync(externalId); fetchedItem = await sonarrClient.FetchItemByExternalIdAsync(externalId);
} }
}
break; break;
case "audio": case "audio":
if (lidarrClient.LidarrOptions.Enabled)
var lidarrInstances = arrApplicationFactory.LidarrInstances;
if (lidarrInstances.Any())
{
foreach (var lidarrClient in lidarrInstances)
{ {
await lidarrClient.FetchItemByExternalIdAsync(externalId); await lidarrClient.FetchItemByExternalIdAsync(externalId);
fetchedItem = cacheService.GetSearchItemByExternalId(mediaType, externalId); fetchedItem = cacheService.GetSearchItemByExternalId(mediaType, externalId);
} }
}
break; break;
case "book": case "book":
if (readarrClient.ReadarrOptions.Enabled)
var readarrInstances = arrApplicationFactory.ReadarrInstances;
if (readarrInstances.Any())
{
foreach (var readarrClient in readarrInstances)
{ {
await readarrClient.FetchItemByExternalIdAsync(externalId); await readarrClient.FetchItemByExternalIdAsync(externalId);
fetchedItem = cacheService.GetSearchItemByExternalId(mediaType, externalId); fetchedItem = cacheService.GetSearchItemByExternalId(mediaType, externalId);
} }
}
break; break;
} }
@@ -66,7 +82,9 @@ namespace UmlautAdaptarr.Services
switch (mediaType) switch (mediaType)
{ {
case "tv": case "tv":
if (sonarrClient.SonarrOptions.Enabled)
var sonarrInstances = arrApplicationFactory.SonarrInstances;
foreach (var sonarrClient in sonarrInstances)
{ {
fetchedItem = await sonarrClient.FetchItemByTitleAsync(title); fetchedItem = await sonarrClient.FetchItemByTitleAsync(title);
} }

View File

@@ -69,11 +69,11 @@ namespace UmlautAdaptarr.Services
public void FindAndReplaceForBooksAndAudio(SearchItem searchItem, XElement? titleElement, string originalTitle) public void FindAndReplaceForBooksAndAudio(SearchItem searchItem, XElement? titleElement, string originalTitle)
{ {
var authorMatch = FindBestMatch(searchItem.AuthorMatchVariations, originalTitle.NormalizeForComparison(), originalTitle); var authorMatch = FindBestMatch(searchItem.AuthorMatchVariations, originalTitle.NormalizeForComparison(), originalTitle);
var titleMatch = FindBestMatch(searchItem.TitleMatchVariations, originalTitle.NormalizeForComparison(), originalTitle); var (foundMatch, bestStart, bestEndInOriginal) = FindBestMatch(searchItem.TitleMatchVariations, originalTitle.NormalizeForComparison(), originalTitle);
if (authorMatch.foundMatch && titleMatch.foundMatch) if (authorMatch.foundMatch && foundMatch)
{ {
int matchEndPositionInOriginal = Math.Max(authorMatch.bestEndInOriginal, titleMatch.bestEndInOriginal); int matchEndPositionInOriginal = Math.Max(authorMatch.bestEndInOriginal, bestEndInOriginal);
// Check and adjust for immediate following delimiter // Check and adjust for immediate following delimiter
char[] delimiters = [' ', '-', '_', '.']; char[] delimiters = [' ', '-', '_', '.'];
@@ -103,7 +103,7 @@ namespace UmlautAdaptarr.Services
} }
private (bool foundMatch, int bestStart, int bestEndInOriginal) FindBestMatch(string[] variations, string normalizedOriginal, string originalTitle) private static (bool foundMatch, int bestStart, int bestEndInOriginal) FindBestMatch(string[] variations, string normalizedOriginal, string originalTitle)
{ {
bool found = false; bool found = false;
int bestStart = int.MaxValue; int bestStart = int.MaxValue;
@@ -131,7 +131,7 @@ namespace UmlautAdaptarr.Services
} }
// Maps an index from the normalized string back to a corresponding index in the original string // Maps an index from the normalized string back to a corresponding index in the original string
private int MapNormalizedIndexToOriginal(string normalizedOriginal, string originalTitle, int normalizedIndex) private static int MapNormalizedIndexToOriginal(string normalizedOriginal, string originalTitle, int normalizedIndex)
{ {
// Count non-special characters up to the given index in the normalized string // Count non-special characters up to the given index in the normalized string
int nonSpecialCharCount = 0; int nonSpecialCharCount = 0;
@@ -209,16 +209,8 @@ namespace UmlautAdaptarr.Services
// Clean up any leading separator from the suffix // Clean up any leading separator from the suffix
suffix = Regex.Replace(suffix, "^ +", ""); suffix = Regex.Replace(suffix, "^ +", "");
// TODO EVALUTE! definitely make this optional - this adds GERMAN to the title is the title is german to make sure it's recognized as german // TODO add this when radarr is implemented
// can lead to problems with shows such as "dark" that have international dubs // FixBadReleaseNaming
/*
// Check if "german" is not in the original title, ignoring case
if (!Regex.IsMatch(originalTitle, "german", RegexOptions.IgnoreCase))
{
// Insert "GERMAN" after the newTitlePrefix
newTitlePrefix += separator + "GERMAN";
}
*/
// Construct the new title with the original suffix // Construct the new title with the original suffix
var newTitle = newTitlePrefix + (string.IsNullOrEmpty(suffix) ? "" : suffix.StartsWith(separator) ? suffix : $"{separator}{suffix}"); var newTitle = newTitlePrefix + (string.IsNullOrEmpty(suffix) ? "" : suffix.StartsWith(separator) ? suffix : $"{separator}{suffix}");
@@ -233,6 +225,50 @@ namespace UmlautAdaptarr.Services
} }
} }
private static readonly string[] MissingGermanTagReleaseGroups = ["tvr"];
private static readonly string[] HEVCInsteadOfx265TagReleaseGroups = ["eisbaer"];
private static readonly string[] WrongTagsReleaseGroups = ["eisbaer"];
private static string FixBadReleaseNaming(string title, string seperator, ILogger<TitleMatchingService> logger)
{
var releaseGroup = GetReleaseGroup(title);
if (MissingGermanTagReleaseGroups.Contains(releaseGroup))
{
// Check if "german" is not in the title, ignoring case
if (!Regex.IsMatch(title, "german", RegexOptions.IgnoreCase))
{
logger.LogInformation($"FixBadReleaseNaming - found missing GERMAN tag for {title}");
// TODO not finished
// Insert "GERMAN" after the newTitlePrefix
//newTitlePrefix += separator + "GERMAN";
}
}
if (HEVCInsteadOfx265TagReleaseGroups.Contains(releaseGroup))
{
if (!title.Contains("REMUX", StringComparison.InvariantCultureIgnoreCase))
{
logger.LogInformation($"FixBadReleaseNaming - found HEVC instead of x265 for {title}");
title = title.Replace("HEVC", "x265");
}
}
if (WrongTagsReleaseGroups.Contains(releaseGroup))
{
if (title.Contains($"{seperator}RM{seperator}"))
{
logger.LogInformation($"FixBadReleaseNaming - found bad Tag RM instead of REMASTERED for {title}");
title = title.Replace($"{seperator}RM{seperator}", $"{seperator}REMASTERED{seperator}");
}
}
return "";
}
private static string? GetReleaseGroup(string title)
{
return title.Contains('-') ? title[(title.LastIndexOf('-') + 1)..].Trim() : null;
}
private static string ReplaceSeperatorsWithSpace(string title) private static string ReplaceSeperatorsWithSpace(string title)
{ {
// Replace all known separators with space for normalization // Replace all known separators with space for normalization

View File

@@ -9,10 +9,13 @@
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="FluentValidation.DependencyInjectionExtensions" Version="11.9.2" />
<PackageReference Include="IL.FluentValidation.Extensions.Options" Version="11.0.2" />
<PackageReference Include="Microsoft.Extensions.Options" Version="8.0.2" /> <PackageReference Include="Microsoft.Extensions.Options" Version="8.0.2" />
<PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="8.0.0" /> <PackageReference Include="Microsoft.Extensions.Options.ConfigurationExtensions" Version="8.0.0" />
<PackageReference Include="Newtonsoft.Json" Version="13.0.3" /> <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" /> <PackageReference Include="Serilog.AspNetCore" Version="8.0.2" />
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.7.3" />
</ItemGroup> </ItemGroup>
</Project> </Project>

View File

@@ -0,0 +1,69 @@
using System.Collections;
using System.Text.RegularExpressions;
using Serilog.Core;
using Serilog.Events;
namespace UmlautAdaptarr.Utilities;
public class ApiKeyMaskingEnricher : ILogEventEnricher
{
private readonly List<string> apiKeys = new();
public ApiKeyMaskingEnricher(string appsetting)
{
ExtractApiKeysFromAppSettings(appsetting);
ExtractApiKeysFromEnvironmentVariables();
apiKeys = new List<string>(apiKeys.Distinct());
}
public void Enrich(LogEvent logEvent, ILogEventPropertyFactory propertyFactory)
{
//if (logEvent.Properties.TryGetValue("apikey", out var value) && value is ScalarValue scalarValue)
//{
var maskedValue = new ScalarValue("**Hidden Api Key**");
foreach (var apikey in apiKeys) logEvent.AddOrUpdateProperty(new LogEventProperty(apikey, maskedValue));
// }
}
/// <summary>
/// Scan all Env Variabels for known Apikeys
/// </summary>
/// <returns>List of all Apikeys</returns>
public List<string> ExtractApiKeysFromEnvironmentVariables()
{
var envVariables = Environment.GetEnvironmentVariables();
foreach (DictionaryEntry envVariable in envVariables)
if (envVariable.Key.ToString()!.Contains("ApiKey"))
apiKeys.Add(envVariable.Value.ToString());
return apiKeys;
}
public List<string> ExtractApiKeysFromAppSettings(string filePath)
{
try
{
if (File.Exists(filePath))
{
var fileContent = File.ReadAllText(filePath);
var pattern = "\"ApiKey\": \"(.*?)\"";
var regex = new Regex(pattern);
var matches = regex.Matches(fileContent);
foreach (Match match in matches) apiKeys.Add(match.Groups[1].Value);
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
return apiKeys;
}
}

View File

@@ -99,7 +99,7 @@ namespace UmlautAdaptarr.Utilities
{ {
if (removeUmlauts) if (removeUmlauts)
{ {
return NoSpecialCharactersExceptHypenRegex().Replace(text, ""); return NoSpecialCharactersExceptHyphenRegex().Replace(text, "");
} }
else else
{ {
@@ -157,9 +157,9 @@ namespace UmlautAdaptarr.Utilities
} }
[GeneratedRegex("[^a-zA-Z0-9 -]+", RegexOptions.Compiled)] [GeneratedRegex("[^a-zA-Z0-9 -]+", RegexOptions.Compiled)]
private static partial Regex NoSpecialCharactersExceptHypenRegex(); private static partial Regex NoSpecialCharactersExceptHyphenRegex();
[GeneratedRegex("[^a-zA-Z0-9 -öäüßÖÄÜß]+", RegexOptions.Compiled)] [GeneratedRegex("[^a-zA-Z0-9 öäüßÖÄÜß-]+", RegexOptions.Compiled)]
private static partial Regex NoSpecialCharactersExceptHyphenAndUmlautsRegex(); private static partial Regex NoSpecialCharactersExceptHyphenAndUmlautsRegex();
[GeneratedRegex(@"\s+")] [GeneratedRegex(@"\s+")]

View File

@@ -0,0 +1,56 @@
using System.Text.Json;
using System.Text.Json.Serialization;
namespace UmlautAdaptarr.Utilities;
public static class Helper
{
public static void ShowLogo()
{
Console.WriteLine(
"\r\n _ _ _ _ ___ _ _ \r\n| | | | | | | | / _ \\ | | | | \r\n| | | |_ __ ___ | | __ _ _ _| |_/ /_\\ \\ __| | __ _ _ __ | |_ __ _ _ __ _ __ \r\n| | | | '_ ` _ \\| |/ _` | | | | __| _ |/ _` |/ _` | '_ \\| __/ _` | '__| '__|\r\n| |_| | | | | | | | (_| | |_| | |_| | | | (_| | (_| | |_) | || (_| | | | | \r\n \\___/|_| |_| |_|_|\\__,_|\\__,_|\\__\\_| |_/\\__,_|\\__,_| .__/ \\__\\__,_|_| |_| \r\n | | \r\n |_| \r\n");
}
public static void ShowInformation()
{
Console.WriteLine("--------------------------[IP Leak Test]-----------------------------");
var ipInfo = GetPublicIpAddressInfoAsync().GetAwaiter().GetResult();
if (ipInfo != null)
{
Console.WriteLine($"Your Public IP Address is '{ipInfo.Ip}'");
Console.WriteLine($"Hostname: {ipInfo.Hostname}");
Console.WriteLine($"City: {ipInfo.City}");
Console.WriteLine($"Region: {ipInfo.Region}");
Console.WriteLine($"Country: {ipInfo.Country}");
Console.WriteLine($"Provider: {ipInfo.Org}");
}
else
{
Console.ForegroundColor = ConsoleColor.Red;
Console.WriteLine("Error: Could not retrieve public IP information.");
Console.ResetColor();
}
Console.WriteLine("--------------------------------------------------------------------");
}
private static async Task<IpInfo?> GetPublicIpAddressInfoAsync()
{
using var client = new HttpClient();
client.Timeout = TimeSpan.FromSeconds(10);
try
{
var response = await client.GetAsync("https://ipinfo.io/json");
response.EnsureSuccessStatusCode();
var content = await response.Content.ReadAsStringAsync();
return JsonSerializer.Deserialize<IpInfo>(content);
}
catch
{
return null;
}
}
}

View File

@@ -0,0 +1,74 @@
using System.Collections;
using System.Collections.ObjectModel;
namespace UmlautAdaptarr.Utilities
{
// License: This code is published under the MIT license.
// Source: https://stackoverflow.com/questions/77559201/
public static class KeyedServiceExtensions
{
public static void AllowResolvingKeyedServicesAsDictionary(
this IServiceCollection sc)
{
// KeyedServiceCache caches all the keys of a given type for a
// specific service type. By making it a singleton we only have
// determine the keys once, which makes resolving the dict very fast.
sc.AddSingleton(typeof(KeyedServiceCache<,>));
// KeyedServiceCache depends on the IServiceCollection to get
// the list of keys. That's why we register that here as well, as it
// is not registered by default in MS.DI.
sc.AddSingleton(sc);
// Last we make the registration for the dictionary itself, which maps
// to our custom type below. This registration must be transient, as
// the containing services could have any lifetime and this registration
// should by itself not cause Captive Dependencies.
sc.AddTransient(typeof(IDictionary<,>), typeof(KeyedServiceDictionary<,>));
// For completeness, let's also allow IReadOnlyDictionary to be resolved.
sc.AddTransient(
typeof(IReadOnlyDictionary<,>), typeof(KeyedServiceDictionary<,>));
}
// We inherit from ReadOnlyDictionary, to disallow consumers from changing
// the wrapped dependencies while reusing all its functionality. This way
// we don't have to implement IDictionary<T,V> ourselves; too much work.
private sealed class KeyedServiceDictionary<TKey, TService>(
KeyedServiceCache<TKey, TService> keys, IServiceProvider provider)
: ReadOnlyDictionary<TKey, TService>(Create(keys, provider))
where TKey : notnull
where TService : notnull
{
private static Dictionary<TKey, TService> Create(
KeyedServiceCache<TKey, TService> keys, IServiceProvider provider)
{
var dict = new Dictionary<TKey, TService>(capacity: keys.Keys.Length);
foreach (TKey key in keys.Keys)
{
dict[key] = provider.GetRequiredKeyedService<TService>(key);
}
return dict;
}
}
private sealed class KeyedServiceCache<TKey, TService>(IServiceCollection sc)
where TKey : notnull
where TService : notnull
{
// Once this class is resolved, all registrations are guaranteed to be
// made, so we can, at that point, safely iterate the collection to get
// the keys for the service type.
public TKey[] Keys { get; } = (
from service in sc
where service.ServiceKey != null
where service.ServiceKey!.GetType() == typeof(TKey)
where service.ServiceType == typeof(TService)
select (TKey)service.ServiceKey!)
.ToArray();
}
}
}

View File

@@ -1,53 +0,0 @@
using System;
using System.Net;
using UmlautAdaptarr.Options;
namespace UmlautAdaptarr.Utilities
{
/// <summary>
/// Extension methods for configuring proxies.
/// </summary>
public static class ProxyExtension
{
/// <summary>
/// Logger instance for logging proxy configurations.
/// </summary>
private static ILogger Logger = GlobalStaticLogger.Logger;
/// <summary>
/// Configures the proxy settings for the provided HttpClientHandler instance.
/// </summary>
/// <param name="handler">The HttpClientHandler instance to configure.</param>
/// <param name="proxyOptions">ProxyOptions options to be used for configuration.</param>
/// <returns>The configured HttpClientHandler instance.</returns>
public static HttpClientHandler ConfigureProxy(this HttpClientHandler handler, ProxyOptions? proxyOptions)
{
try
{
if (proxyOptions != null && proxyOptions.Enabled)
{
Logger.LogInformation("Use Proxy {0}", proxyOptions.Address);
handler.UseProxy = true;
handler.Proxy = new WebProxy(proxyOptions.Address, proxyOptions.BypassOnLocal);
if (!string.IsNullOrEmpty(proxyOptions.Username) && !string.IsNullOrEmpty(proxyOptions.Password))
{
Logger.LogInformation("Use Proxy Credentials from User {0}", proxyOptions.Username);
handler.DefaultProxyCredentials =
new NetworkCredential(proxyOptions.Username, proxyOptions.Password);
}
}
else
{
Logger.LogDebug("No proxy was set");
}
}
catch (Exception ex)
{
Logger.LogError(ex, "Error occurred while configuring proxy, no Proxy will be used!");
}
return handler;
}
}
}

View File

@@ -1,16 +1,120 @@
using UmlautAdaptarr.Options; using FluentValidation;
using UmlautAdaptarr.Options.ArrOptions; using System.Linq.Expressions;
using UmlautAdaptarr.Interfaces;
using UmlautAdaptarr.Options;
using UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
using UmlautAdaptarr.Providers; using UmlautAdaptarr.Providers;
using UmlautAdaptarr.Services; using UmlautAdaptarr.Services;
using UmlautAdaptarr.Validator;
namespace UmlautAdaptarr.Utilities;
namespace UmlautAdaptarr.Utilities
{
/// <summary> /// <summary>
/// Extension methods for configuring services related to ARR Applications /// Extension methods for configuring services related to ARR Applications
/// </summary> /// </summary>
public static class ServicesExtensions public static class ServicesExtensions
{ {
/// <summary>
/// Logger instance for logging proxy configurations.
/// </summary>
private static ILogger Logger = GlobalStaticLogger.Logger;
/// <summary>
/// Adds a service with specified options and service to the service collection.
/// </summary>
/// <typeparam name="TOptions">The options type for the service.</typeparam>
/// <typeparam name="TService">The service type for the service.</typeparam>
/// <typeparam name="TInterface">The Interface of the service type</typeparam>
/// <param name="builder">The <see cref="WebApplicationBuilder" /> to configure the service collection.</param>
/// <param name="sectionName">The name of the configuration section containing service options.</param>
/// <returns>The configured <see cref="WebApplicationBuilder" />.</returns>
private static WebApplicationBuilder AddServicesWithOptions<TOptions, TService, TInterface>(
this WebApplicationBuilder builder, string sectionName)
where TOptions : class, new()
where TService : class, TInterface
where TInterface : class
{
try
{
if (builder.Services == null) throw new ArgumentNullException(nameof(builder), "Service collection is null.");
var singleInstance = builder.Configuration.GetSection(sectionName).Get<TOptions>();
var singleHost = (string?)typeof(TOptions).GetProperty("Host")?.GetValue(singleInstance, null);
// If we have no Single Instance, we try to parse for an Array
var optionsArray = singleHost == null
? builder.Configuration.GetSection(sectionName).Get<TOptions[]>()
:
[
singleInstance
];
if (optionsArray == null || !optionsArray.Any())
throw new InvalidOperationException(
$"{typeof(TService).Name} options could not be loaded from Configuration or ENV Variable.");
foreach (var option in optionsArray)
{
GlobalInstanceOptionsValidator validator = new GlobalInstanceOptionsValidator();
var results = validator.Validate(option as GlobalInstanceOptions);
if (!results.IsValid)
{
foreach (var failure in results.Errors)
{
Console.WriteLine(($"Property {failure.PropertyName } failed validation. Error was: {failure.ErrorMessage}"));
}
throw new Exception("Please fix first you config and then Start UmlautAdaptarr again");
}
var instanceState = (bool)(typeof(TOptions).GetProperty("Enabled")?.GetValue(option, null) ?? false);
// We only want to create instances that are enabled in the Configs
if (instanceState)
{
// User can give the Instance a readable Name otherwise we use the Host Property
var instanceName = (string)(typeof(TOptions).GetProperty("Name")?.GetValue(option, null) ??
(string)typeof(TOptions).GetProperty("Host")?.GetValue(option, null)!);
// Dark Magic , we don't know the Property's of TOptions , and we won't cast them for each Options
// Todo eventuell schönere Lösung finden
var paraexpression = Expression.Parameter(Type.GetType(option.GetType().FullName), "x");
foreach (var prop in option.GetType().GetProperties())
{
var val = Expression.Constant(prop.GetValue(option));
var memberexpression = Expression.PropertyOrField(paraexpression, prop.Name);
if (prop.PropertyType == typeof(int) || prop.PropertyType == typeof(string) || prop.PropertyType == typeof(bool))
{
var assign = Expression.Assign(memberexpression, Expression.Convert(val, prop.PropertyType));
var exp = Expression.Lambda<Action<TOptions>>(assign, paraexpression);
builder.Services.Configure(instanceName, exp.Compile());
}
else
{
Logger.LogWarning(prop.PropertyType + "No Support");
}
}
builder.Services.AddKeyedSingleton<TInterface, TService>(instanceName);
}
}
return builder;
}
catch (Exception ex)
{
Console.WriteLine($"Error in AddServicesWithOptions: {ex.Message}");
throw;
}
}
/// <summary> /// <summary>
/// Adds a service with specified options and service to the service collection. /// Adds a service with specified options and service to the service collection.
/// </summary> /// </summary>
@@ -19,23 +123,18 @@ namespace UmlautAdaptarr.Utilities
/// <param name="builder">The <see cref="WebApplicationBuilder" /> to configure the service collection.</param> /// <param name="builder">The <see cref="WebApplicationBuilder" /> to configure the service collection.</param>
/// <param name="sectionName">The name of the configuration section containing service options.</param> /// <param name="sectionName">The name of the configuration section containing service options.</param>
/// <returns>The configured <see cref="WebApplicationBuilder" />.</returns> /// <returns>The configured <see cref="WebApplicationBuilder" />.</returns>
private static WebApplicationBuilder AddServiceWithOptions<TOptions, TService>(this WebApplicationBuilder builder, string sectionName) private static WebApplicationBuilder AddServiceWithOptions<TOptions, TService>(this WebApplicationBuilder builder,
string sectionName)
where TOptions : class where TOptions : class
where TService : class where TService : class
{ {
if (builder.Services == null) if (builder.Services == null) throw new ArgumentNullException(nameof(builder), "Service collection is null.");
{
throw new ArgumentNullException(nameof(builder), "Service collection is null.");
}
var options = builder.Configuration.GetSection(sectionName).Get<TOptions>();
if (options == null)
{
throw new InvalidOperationException($"{typeof(TService).Name} options could not be loaded from Configuration or ENV Variable.");
}
var options = builder.Configuration.GetSection(sectionName).Get<TOptions>() ?? throw new InvalidOperationException(
$"{typeof(TService).Name} options could not be loaded from Configuration or ENV Variable.");
builder.Services.Configure<TOptions>(builder.Configuration.GetSection(sectionName)); builder.Services.Configure<TOptions>(builder.Configuration.GetSection(sectionName));
builder.Services.AddSingleton<TService>(); builder.Services.AddSingleton<TService>();
return builder; return builder;
} }
@@ -46,7 +145,8 @@ namespace UmlautAdaptarr.Utilities
/// <returns>The configured <see cref="WebApplicationBuilder" />.</returns> /// <returns>The configured <see cref="WebApplicationBuilder" />.</returns>
public static WebApplicationBuilder AddSonarrSupport(this WebApplicationBuilder builder) public static WebApplicationBuilder AddSonarrSupport(this WebApplicationBuilder builder)
{ {
return builder.AddServiceWithOptions<SonarrInstanceOptions, SonarrClient>("Sonarr"); // builder.Serviceses.AddSingleton<IOptionsMonitoSonarrInstanceOptionsns>, OptionsMonitoSonarrInstanceOptionsns>>();
return builder.AddServicesWithOptions<SonarrInstanceOptions, SonarrClient, IArrApplication>("Sonarr");
} }
/// <summary> /// <summary>
@@ -56,7 +156,7 @@ namespace UmlautAdaptarr.Utilities
/// <returns>The configured <see cref="WebApplicationBuilder" />.</returns> /// <returns>The configured <see cref="WebApplicationBuilder" />.</returns>
public static WebApplicationBuilder AddLidarrSupport(this WebApplicationBuilder builder) public static WebApplicationBuilder AddLidarrSupport(this WebApplicationBuilder builder)
{ {
return builder.AddServiceWithOptions<LidarrInstanceOptions, LidarrClient>("Lidarr"); return builder.AddServicesWithOptions<LidarrInstanceOptions, LidarrClient, IArrApplication>("Lidarr");
} }
/// <summary> /// <summary>
@@ -66,7 +166,7 @@ namespace UmlautAdaptarr.Utilities
/// <returns>The configured <see cref="WebApplicationBuilder" />.</returns> /// <returns>The configured <see cref="WebApplicationBuilder" />.</returns>
public static WebApplicationBuilder AddReadarrSupport(this WebApplicationBuilder builder) public static WebApplicationBuilder AddReadarrSupport(this WebApplicationBuilder builder)
{ {
return builder.AddServiceWithOptions<ReadarrInstanceOptions, ReadarrClient>("Readarr"); return builder.AddServicesWithOptions<ReadarrInstanceOptions, ReadarrClient, IArrApplication>("Readarr");
} }
/// <summary> /// <summary>
@@ -89,4 +189,3 @@ namespace UmlautAdaptarr.Utilities
return builder.AddServiceWithOptions<GlobalOptions, ProxyRequestService>("Settings"); return builder.AddServiceWithOptions<GlobalOptions, ProxyRequestService>("Settings");
} }
} }
}

View File

@@ -0,0 +1,61 @@
using System.Net;
using FluentValidation;
using UmlautAdaptarr.Options.ArrOptions.InstanceOptions;
namespace UmlautAdaptarr.Validator;
public class GlobalInstanceOptionsValidator : AbstractValidator<GlobalInstanceOptions>
{
public GlobalInstanceOptionsValidator()
{
RuleFor(x => x.Enabled).NotNull();
When(x => x.Enabled, () =>
{
RuleFor(x => x.Host)
.NotEmpty().WithMessage("Host is required when Enabled is true.")
.Must(BeAValidUrl).WithMessage("Host/Url must start with http:// or https:// and be a valid address.")
.Must(BeReachable)
.WithMessage("Host/Url is not reachable. Please check your Host or your UmlautAdaptrr Settings");
RuleFor(x => x.ApiKey)
.NotEmpty().WithMessage("ApiKey is required when Enabled is true.");
});
}
private bool BeAValidUrl(string url)
{
return Uri.TryCreate(url, UriKind.Absolute, out var uriResult)
&& (uriResult.Scheme == Uri.UriSchemeHttp || uriResult.Scheme == Uri.UriSchemeHttps);
}
private static bool BeReachable(string url)
{
var endTime = DateTime.Now.AddMinutes(3);
var reachable = false;
while (DateTime.Now < endTime)
{
try
{
var request = WebRequest.Create(url);
request.Timeout = 3000;
using var response = (HttpWebResponse)request.GetResponse();
reachable = response.StatusCode == HttpStatusCode.OK;
if (reachable)
break;
}
catch
{
}
// Wait for 15 seconds for next try
Console.WriteLine($"The URL \"{url}\" is not reachable. Next attempt in 15 seconds...");
Thread.Sleep(15000);
}
return reachable;
}
}

View File

@@ -22,20 +22,36 @@
"UserAgent": "UmlautAdaptarr/1.0", "UserAgent": "UmlautAdaptarr/1.0",
"UmlautAdaptarrApiHost": "https://umlautadaptarr.pcjones.de/api/v1" "UmlautAdaptarrApiHost": "https://umlautadaptarr.pcjones.de/api/v1"
}, },
"Sonarr": { "Sonarr": [
{
// Docker Environment Variables: // Docker Environment Variables:
// - Sonarr__Enabled: true (set to false to disable) // - Sonarr__0__Enabled: true (set to false to disable)
// - Sonarr__Host: your_sonarr_host_url // - Sonarr__0__Name: Name of the Instance (Optional)
// - Sonarr__ApiKey: your_sonarr_api_key // - Sonarr__0__Host: your_sonarr_host_url
// - Sonarr__0__ApiKey: your_sonarr_api_key
"Enabled": false, "Enabled": false,
"Name": "Sonarr",
"Host": "your_sonarr_host_url", "Host": "your_sonarr_host_url",
"ApiKey": "your_sonarr_api_key" "ApiKey": "your_sonarr_api_key"
}, },
"Lidarr": { {
// Docker Environment Variables:
// - Sonarr__1__Enabled: true (set to false to disable)
// - Sonarr__1__Name: Name of the Instance (Optional)
// - Sonarr__1__Host: your_sonarr_host_url
// - Sonarr__1__ApiKey: your_sonarr_api_key
"Enabled": false,
"Name": "Sonarr 4k",
"Host": "your_other_sonarr_host_url",
"ApiKey": "your_other_sonarr_api_key"
}
],
"Lidarr":
// Docker Environment Variables: // Docker Environment Variables:
// - Lidarr__Enabled: true (set to false to disable) // - Lidarr__Enabled: true (set to false to disable)
// - Lidarr__Host: your_lidarr_host_url // - Lidarr__Host: your_lidarr_host_url
// - Lidarr__ApiKey: your_lidarr_api_key // - Lidarr__ApiKey: your_lidarr_api_key
{
"Enabled": false, "Enabled": false,
"Host": "your_lidarr_host_url", "Host": "your_lidarr_host_url",
"ApiKey": "your_lidarr_api_key" "ApiKey": "your_lidarr_api_key"
@@ -48,19 +64,5 @@
"Enabled": false, "Enabled": false,
"Host": "your_readarr_host_url", "Host": "your_readarr_host_url",
"ApiKey": "your_readarr_api_key" "ApiKey": "your_readarr_api_key"
},
// Docker Environment Variables:
// - Proxy__Enabled: true (set to false to disable)
// - Proxy__Address: http://yourproxyaddress:port
// - Proxy__Username: your_proxy_username
// - Proxy__Password: your_proxy_password
// - Proxy__BypassOnLocal: true (set to false to not bypass local IP addresses)
"Proxy": {
"Enabled": false,
"Address": "http://yourproxyaddress:port",
"Username": "your_proxy_username",
"Password": "your_proxy_password",
"BypassOnLocal": true
} }
} }

4
build_linux.bat Normal file
View File

@@ -0,0 +1,4 @@
@echo off
dotnet publish -c Release -r linux-x64 --self-contained
'dotnet publish -c Release -r linux-x64 --self-contained -p:PublishSingleFile=true -p:IncludeAllContentForSelfExtract=true
pause

View File

@@ -6,6 +6,9 @@ services:
build: https://github.com/PCJones/UmlautAdaptarr.git#master build: https://github.com/PCJones/UmlautAdaptarr.git#master
image: umlautadaptarr image: umlautadaptarr
restart: unless-stopped restart: unless-stopped
ports:
- "5005:5005" # can be removed if you use the recommended prowlarr+proxy configuration
- "5006:5006" # can be removed if you use the alternative, non-proxy configuration
environment: environment:
- TZ=Europe/Berlin - TZ=Europe/Berlin
- SONARR__ENABLED=false - SONARR__ENABLED=false
@@ -20,8 +23,3 @@ services:
- LIDARR__ENABLED=false - LIDARR__ENABLED=false
- LIDARR__HOST=http://localhost:8686 - LIDARR__HOST=http://localhost:8686
- LIDARR__APIKEY=APIKEY - LIDARR__APIKEY=APIKEY
#- Proxy__Enabled: false
#- Proxy__Address: http://yourproxyaddress:port
#- Proxy__Username: your_proxy_username
#- Proxy__Password: your_proxy_password
#- Proxy__BypassOnLocal: true (set to false to not bypass local IP addresses)