Compare commits
51 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
81dae8c237 | ||
|
|
aa70c91a87 | ||
|
|
3d2ec82e0f | ||
|
|
9c9c1583f7 | ||
|
|
f9a02ae487 | ||
|
|
0cc0ca98e1 | ||
|
|
a4abb31ea1 | ||
|
|
530cbed2d3 | ||
|
|
94e62cf4dd | ||
|
|
c4069e0732 | ||
|
|
6f743eca01 | ||
|
|
45bc7baa4a | ||
|
|
43717d5fc4 | ||
|
|
08e13db32d | ||
|
|
f3684d24d3 | ||
|
|
cee3c12daa | ||
|
|
e888a10366 | ||
|
|
660c245069 | ||
|
|
49193ef12f | ||
|
|
881f3b7281 | ||
|
|
d098d1fd10 | ||
|
|
6cf87620c3 | ||
|
|
389d685e95 | ||
|
|
12d9217964 | ||
|
|
5cd90b7b20 | ||
|
|
93990dbf52 | ||
|
|
49565be191 | ||
|
|
24d5cb83a4 | ||
|
|
f02547c0e3 | ||
|
|
61e93b5b24 | ||
|
|
f88daf4955 | ||
|
|
93c667422f | ||
|
|
e1978d869c | ||
|
|
cfdfa89009 | ||
|
|
9bee42d7dd | ||
|
|
797ff2b97e | ||
|
|
a67d5c2d1e | ||
|
|
d1d05f8264 | ||
|
|
939b902be3 | ||
|
|
f56d071642 | ||
|
|
7513e7d227 | ||
|
|
7a791dab23 | ||
|
|
402a4deba3 | ||
|
|
d31508fef3 | ||
|
|
1c329e886d | ||
|
|
6932c4b2f8 | ||
|
|
ff051569ca | ||
|
|
dbac09bf36 | ||
|
|
0bde5d5d24 | ||
|
|
99af842fc6 | ||
|
|
fbfbeadb3e |
83
README.md
83
README.md
@@ -2,36 +2,21 @@
|
|||||||
|
|
||||||
## 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 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:
|
|
||||||
|
|
||||||

|
|
||||||
|
|
||||||
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.
|
||||||
|
- 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, das 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/edit/develop/README.md#beispiel-funktionalit%C3%A4t).
|
||||||
|
|
||||||
|
|
||||||
## Features
|
## Features
|
||||||
@@ -45,12 +30,58 @@ 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 |✓|
|
||||||
|
| Torrent (torznab) Support |✓|
|
||||||
| Radarr Support | Geplant |
|
| Radarr Support | 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:
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
- 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:
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
- 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:
|
||||||
|
|
||||||
|

|
||||||
|
|
||||||
|
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 ;)
|
||||||
|
|
||||||
@@ -64,7 +95,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
|
||||||

|

|
||||||
|
|
||||||
**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
|
||||||

|

|
||||||
|
|
||||||
|
|
||||||
@@ -87,6 +118,12 @@ Sonarr erwartet immer den Englischen Namen, der hier natürlich nicht gegeben is
|
|||||||
- [Telegram](https://t.me/pc_jones)
|
- [Telegram](https://t.me/pc_jones)
|
||||||
- Discord: pcjones1 - oder komm in den UsenetDE Discord Server: [https://discord.gg/pZrrMcJMQM](https://discord.gg/pZrrMcJMQM)
|
- Discord: pcjones1 - oder komm in den UsenetDE Discord Server: [https://discord.gg/pZrrMcJMQM](https://discord.gg/pZrrMcJMQM)
|
||||||
|
|
||||||
|
## Spenden
|
||||||
|
Über eine Spende freue ich mich natürlich immer :D
|
||||||
|
PayPal: https://paypal.me/pcjones1
|
||||||
|
|
||||||
|
Für andere Spendenmöglichkeiten gerne auf Discord oder Telegram melden - danke!
|
||||||
|
|
||||||
### Licenses & Metadata source
|
### Licenses & Metadata source
|
||||||
- TV Metadata source: https://thetvdb.com
|
- TV Metadata source: https://thetvdb.com
|
||||||
- Movie Metadata source: https://themoviedb.org
|
- Movie Metadata source: https://themoviedb.org
|
||||||
|
|||||||
@@ -6,9 +6,9 @@ using UmlautAdaptarr.Utilities;
|
|||||||
|
|
||||||
namespace UmlautAdaptarr.Controllers
|
namespace UmlautAdaptarr.Controllers
|
||||||
{
|
{
|
||||||
public class CapsController(ProxyService proxyService) : ControllerBase
|
public class CapsController(ProxyRequestService proxyRequestService) : ControllerBase
|
||||||
{
|
{
|
||||||
private readonly ProxyService _proxyService = proxyService;
|
private readonly ProxyRequestService _proxyRequestService = proxyRequestService;
|
||||||
|
|
||||||
[HttpGet]
|
[HttpGet]
|
||||||
public async Task<IActionResult> Caps([FromRoute] string options, [FromRoute] string domain, [FromQuery] string? apikey)
|
public async Task<IActionResult> Caps([FromRoute] string options, [FromRoute] string domain, [FromQuery] string? apikey)
|
||||||
@@ -20,7 +20,7 @@ namespace UmlautAdaptarr.Controllers
|
|||||||
|
|
||||||
var requestUrl = UrlUtilities.BuildUrl(domain, "caps", apikey);
|
var requestUrl = UrlUtilities.BuildUrl(domain, "caps", apikey);
|
||||||
|
|
||||||
var responseMessage = await _proxyService.ProxyRequestAsync(HttpContext, requestUrl);
|
var responseMessage = await _proxyRequestService.ProxyRequestAsync(HttpContext, requestUrl);
|
||||||
|
|
||||||
var content = await responseMessage.Content.ReadAsStringAsync();
|
var content = await responseMessage.Content.ReadAsStringAsync();
|
||||||
var encoding = responseMessage.Content.Headers.ContentType?.CharSet != null ?
|
var encoding = responseMessage.Content.Headers.ContentType?.CharSet != null ?
|
||||||
|
|||||||
@@ -6,9 +6,10 @@ using UmlautAdaptarr.Utilities;
|
|||||||
|
|
||||||
namespace UmlautAdaptarr.Controllers
|
namespace UmlautAdaptarr.Controllers
|
||||||
{
|
{
|
||||||
public abstract class SearchControllerBase(ProxyService proxyService, TitleMatchingService titleMatchingService) : ControllerBase
|
public abstract class SearchControllerBase(ProxyRequestService proxyRequestService, TitleMatchingService titleMatchingService) : ControllerBase
|
||||||
{
|
{
|
||||||
private readonly bool TODO_FORCE_TEXT_SEARCH_ORIGINAL_TITLE = false;
|
// TODO evaluate if this should be set to true by default
|
||||||
|
private readonly bool TODO_FORCE_TEXT_SEARCH_ORIGINAL_TITLE = true;
|
||||||
private readonly bool TODO_FORCE_TEXT_SEARCH_GERMAN_TITLE = false;
|
private readonly bool TODO_FORCE_TEXT_SEARCH_GERMAN_TITLE = false;
|
||||||
protected async Task<IActionResult> BaseSearch(string options,
|
protected async Task<IActionResult> BaseSearch(string options,
|
||||||
string domain,
|
string domain,
|
||||||
@@ -52,7 +53,7 @@ namespace UmlautAdaptarr.Controllers
|
|||||||
|
|
||||||
var titleSearchVariations = new List<string>(searchItem?.TitleSearchVariations);
|
var titleSearchVariations = new List<string>(searchItem?.TitleSearchVariations);
|
||||||
|
|
||||||
string searchQuery = string.Empty;
|
var searchQuery = string.Empty;
|
||||||
if (queryParameters.TryGetValue("q", out string? q))
|
if (queryParameters.TryGetValue("q", out string? q))
|
||||||
{
|
{
|
||||||
searchQuery = q ?? string.Empty;
|
searchQuery = q ?? string.Empty;
|
||||||
@@ -95,7 +96,7 @@ namespace UmlautAdaptarr.Controllers
|
|||||||
private async Task<IActionResult> PerformSingleSearchRequest(string domain, IDictionary<string, string> queryParameters)
|
private async Task<IActionResult> PerformSingleSearchRequest(string domain, IDictionary<string, string> queryParameters)
|
||||||
{
|
{
|
||||||
var requestUrl = UrlUtilities.BuildUrl(domain, queryParameters);
|
var requestUrl = UrlUtilities.BuildUrl(domain, queryParameters);
|
||||||
var responseMessage = await proxyService.ProxyRequestAsync(HttpContext, requestUrl);
|
var responseMessage = await proxyRequestService.ProxyRequestAsync(HttpContext, requestUrl);
|
||||||
var content = await responseMessage.Content.ReadAsStringAsync();
|
var content = await responseMessage.Content.ReadAsStringAsync();
|
||||||
|
|
||||||
var encoding = responseMessage.Content.Headers.ContentType?.CharSet != null ?
|
var encoding = responseMessage.Content.Headers.ContentType?.CharSet != null ?
|
||||||
@@ -129,7 +130,7 @@ namespace UmlautAdaptarr.Controllers
|
|||||||
{
|
{
|
||||||
queryParameters["q"] = titleVariation; // Replace the "q" parameter for each variation
|
queryParameters["q"] = titleVariation; // Replace the "q" parameter for each variation
|
||||||
var requestUrl = UrlUtilities.BuildUrl(domain, queryParameters);
|
var requestUrl = UrlUtilities.BuildUrl(domain, queryParameters);
|
||||||
var responseMessage = await proxyService.ProxyRequestAsync(HttpContext, requestUrl);
|
var responseMessage = await proxyRequestService.ProxyRequestAsync(HttpContext, requestUrl);
|
||||||
var content = await responseMessage.Content.ReadAsStringAsync();
|
var content = await responseMessage.Content.ReadAsStringAsync();
|
||||||
|
|
||||||
// Only update encoding from the first response
|
// Only update encoding from the first response
|
||||||
@@ -151,9 +152,9 @@ namespace UmlautAdaptarr.Controllers
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public class SearchController(ProxyService proxyService,
|
public class SearchController(ProxyRequestService proxyRequestService,
|
||||||
TitleMatchingService titleMatchingService,
|
TitleMatchingService titleMatchingService,
|
||||||
SearchItemLookupService searchItemLookupService) : SearchControllerBase(proxyService, titleMatchingService)
|
SearchItemLookupService searchItemLookupService) : SearchControllerBase(proxyRequestService, titleMatchingService)
|
||||||
{
|
{
|
||||||
public readonly string[] LIDARR_CATEGORY_IDS = ["3000", "3010", "3020", "3040", "3050"];
|
public readonly string[] LIDARR_CATEGORY_IDS = ["3000", "3010", "3020", "3040", "3050"];
|
||||||
public readonly string[] READARR_CATEGORY_IDS = ["3030", "3130", "7000", "7010", "7020", "7030", "7100", "7110", "7120", "7130"];
|
public readonly string[] READARR_CATEGORY_IDS = ["3030", "3130", "7000", "7010", "7020", "7030", "7100", "7110", "7120", "7130"];
|
||||||
|
|||||||
@@ -43,7 +43,30 @@ namespace UmlautAdaptarr.Models
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
GenerateVariationsForTV(germanTitle, mediaType, aliases);
|
// if mediatype is movie/tv and the Expected Title ends with a year but the german title doesn't then append the year to the german title and to aliases
|
||||||
|
// example: https://thetvdb.com/series/385925-avatar-the-last-airbender -> german Title is without 2024
|
||||||
|
var yearAtEndOfTitleMatch = YearAtEndOfTitleRegex().Match(expectedTitle);
|
||||||
|
if (yearAtEndOfTitleMatch.Success)
|
||||||
|
{
|
||||||
|
string year = yearAtEndOfTitleMatch.Value[1..^1];
|
||||||
|
if (GermanTitle != null && !GermanTitle.Contains(year))
|
||||||
|
{
|
||||||
|
GermanTitle = $"{germanTitle} {year}";
|
||||||
|
}
|
||||||
|
|
||||||
|
if (aliases != null)
|
||||||
|
{
|
||||||
|
for (int i = 0; i < aliases.Length; i++)
|
||||||
|
{
|
||||||
|
if (!aliases[i].Contains(year))
|
||||||
|
{
|
||||||
|
aliases[i] = $"{aliases[i]} {year}";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
GenerateVariationsForTV(GermanTitle, mediaType, aliases);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -60,6 +83,12 @@ namespace UmlautAdaptarr.Models
|
|||||||
foreach (var alias in aliases)
|
foreach (var alias in aliases)
|
||||||
{
|
{
|
||||||
allTitleVariations.AddRange(GenerateVariations(alias, mediaType));
|
allTitleVariations.AddRange(GenerateVariations(alias, mediaType));
|
||||||
|
|
||||||
|
// If title contains ":" also match for "-"
|
||||||
|
if (alias.Contains(':'))
|
||||||
|
{
|
||||||
|
allTitleVariations.Add(alias.Replace(":", " -"));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -79,6 +108,12 @@ namespace UmlautAdaptarr.Models
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// If title contains ":" also match for "-"
|
||||||
|
if (germanTitle?.Contains(':') ?? false)
|
||||||
|
{
|
||||||
|
allTitleVariations.Add(germanTitle.Replace(":", " -"));
|
||||||
|
}
|
||||||
|
|
||||||
TitleMatchVariations = allTitleVariations.Distinct(StringComparer.InvariantCultureIgnoreCase).ToArray();
|
TitleMatchVariations = allTitleVariations.Distinct(StringComparer.InvariantCultureIgnoreCase).ToArray();
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -123,6 +158,7 @@ namespace UmlautAdaptarr.Models
|
|||||||
{
|
{
|
||||||
return [];
|
return [];
|
||||||
}
|
}
|
||||||
|
|
||||||
var cleanTitle = title.GetCleanTitle();
|
var cleanTitle = title.GetCleanTitle();
|
||||||
|
|
||||||
if (cleanTitle?.Length == 0)
|
if (cleanTitle?.Length == 0)
|
||||||
@@ -180,5 +216,8 @@ namespace UmlautAdaptarr.Models
|
|||||||
|
|
||||||
return cleanedVariations.Distinct();
|
return cleanedVariations.Distinct();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
[GeneratedRegex(@"\(\d{4}\)$")]
|
||||||
|
private static partial Regex YearAtEndOfTitleRegex();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,23 @@
|
|||||||
|
namespace UmlautAdaptarr.Options.ArrOptions
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Base Options for ARR applications
|
||||||
|
/// </summary>
|
||||||
|
public class ArrApplicationBaseOptions
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Indicates whether the Arr application is enabled.
|
||||||
|
/// </summary>
|
||||||
|
public bool Enabled { get; set; }
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// The host of the ARR application.
|
||||||
|
/// </summary>
|
||||||
|
public string Host { get; set; }
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// The API key of the ARR application.
|
||||||
|
/// </summary>
|
||||||
|
public string ApiKey { get; set; }
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
namespace UmlautAdaptarr.Options.ArrOptions
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Lidarr Options
|
||||||
|
/// </summary>
|
||||||
|
public class LidarrInstanceOptions : ArrApplicationBaseOptions
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
namespace UmlautAdaptarr.Options.ArrOptions
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Readarr Options
|
||||||
|
/// </summary>
|
||||||
|
public class ReadarrInstanceOptions : ArrApplicationBaseOptions
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
namespace UmlautAdaptarr.Options.ArrOptions
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Sonarr Options
|
||||||
|
/// </summary>
|
||||||
|
public class SonarrInstanceOptions : ArrApplicationBaseOptions
|
||||||
|
{
|
||||||
|
}
|
||||||
|
}
|
||||||
18
UmlautAdaptarr/Options/GlobalOptions.cs
Normal file
18
UmlautAdaptarr/Options/GlobalOptions.cs
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
namespace UmlautAdaptarr.Options
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Global options for the UmlautAdaptarr application.
|
||||||
|
/// </summary>
|
||||||
|
public class GlobalOptions
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// The host of the UmlautAdaptarr API.
|
||||||
|
/// </summary>
|
||||||
|
public string UmlautAdaptarrApiHost { get; set; }
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// The User-Agent string used in HTTP requests.
|
||||||
|
/// </summary>
|
||||||
|
public string UserAgent { get; set; }
|
||||||
|
}
|
||||||
|
}
|
||||||
27
UmlautAdaptarr/Options/Proxy.cs
Normal file
27
UmlautAdaptarr/Options/Proxy.cs
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
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; }
|
||||||
|
}
|
||||||
32
UmlautAdaptarr/Options/ProxyOptions.cs
Normal file
32
UmlautAdaptarr/Options/ProxyOptions.cs
Normal file
@@ -0,0 +1,32 @@
|
|||||||
|
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; }
|
||||||
|
}
|
||||||
@@ -1,8 +1,8 @@
|
|||||||
using Microsoft.Extensions.Configuration;
|
|
||||||
using System.Net;
|
using System.Net;
|
||||||
using UmlautAdaptarr.Providers;
|
using UmlautAdaptarr.Options;
|
||||||
using UmlautAdaptarr.Routing;
|
using UmlautAdaptarr.Routing;
|
||||||
using UmlautAdaptarr.Services;
|
using UmlautAdaptarr.Services;
|
||||||
|
using UmlautAdaptarr.Utilities;
|
||||||
|
|
||||||
internal class Program
|
internal class Program
|
||||||
{
|
{
|
||||||
@@ -24,11 +24,14 @@ internal class Program
|
|||||||
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;
|
||||||
});
|
});
|
||||||
|
|
||||||
builder.Services.AddMemoryCache(options =>
|
builder.Services.AddMemoryCache(options =>
|
||||||
{
|
{
|
||||||
|
// TODO cache size limit? option?
|
||||||
//options.SizeLimit = 20000;
|
//options.SizeLimit = 20000;
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -46,19 +49,20 @@ internal class Program
|
|||||||
|
|
||||||
builder.Services.AddControllers();
|
builder.Services.AddControllers();
|
||||||
builder.Services.AddHostedService<ArrSyncBackgroundService>();
|
builder.Services.AddHostedService<ArrSyncBackgroundService>();
|
||||||
builder.Services.AddSingleton<TitleApiService>();
|
builder.AddTitleLookupService();
|
||||||
builder.Services.AddSingleton<SearchItemLookupService>();
|
builder.Services.AddSingleton<SearchItemLookupService>();
|
||||||
builder.Services.AddSingleton<TitleMatchingService>();
|
builder.Services.AddSingleton<TitleMatchingService>();
|
||||||
builder.Services.AddSingleton<SonarrClient>();
|
builder.AddSonarrSupport();
|
||||||
builder.Services.AddSingleton<LidarrClient>();
|
builder.AddLidarrSupport();
|
||||||
builder.Services.AddSingleton<ReadarrClient>();
|
builder.AddReadarrSupport();
|
||||||
builder.Services.AddSingleton<CacheService>();
|
builder.Services.AddSingleton<CacheService>();
|
||||||
builder.Services.AddSingleton<ProxyService>();
|
builder.Services.AddSingleton<ProxyRequestService>();
|
||||||
|
builder.Services.AddSingleton<IHostedService, HttpProxyService>();
|
||||||
|
|
||||||
var app = builder.Build();
|
var app = builder.Build();
|
||||||
|
|
||||||
|
GlobalStaticLogger.Initialize(app.Services.GetService<ILoggerFactory>()!);
|
||||||
app.UseHttpsRedirection();
|
app.UseHttpsRedirection();
|
||||||
|
|
||||||
app.UseAuthorization();
|
app.UseAuthorization();
|
||||||
|
|
||||||
app.MapControllerRoute(name: "caps",
|
app.MapControllerRoute(name: "caps",
|
||||||
|
|||||||
17
UmlautAdaptarr/Providers/ArrClientFactory.cs
Normal file
17
UmlautAdaptarr/Providers/ArrClientFactory.cs
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
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());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,7 +1,9 @@
|
|||||||
using Microsoft.Extensions.Caching.Memory;
|
using Microsoft.Extensions.Caching.Memory;
|
||||||
|
using Microsoft.Extensions.Options;
|
||||||
using Newtonsoft.Json;
|
using Newtonsoft.Json;
|
||||||
using Newtonsoft.Json.Linq;
|
using Newtonsoft.Json.Linq;
|
||||||
using UmlautAdaptarr.Models;
|
using UmlautAdaptarr.Models;
|
||||||
|
using UmlautAdaptarr.Options.ArrOptions;
|
||||||
using UmlautAdaptarr.Services;
|
using UmlautAdaptarr.Services;
|
||||||
using UmlautAdaptarr.Utilities;
|
using UmlautAdaptarr.Utilities;
|
||||||
|
|
||||||
@@ -9,13 +11,11 @@ namespace UmlautAdaptarr.Providers
|
|||||||
{
|
{
|
||||||
public class LidarrClient(
|
public class LidarrClient(
|
||||||
IHttpClientFactory clientFactory,
|
IHttpClientFactory clientFactory,
|
||||||
IConfiguration configuration,
|
|
||||||
CacheService cacheService,
|
CacheService cacheService,
|
||||||
IMemoryCache cache,
|
IMemoryCache cache,
|
||||||
ILogger<LidarrClient> logger) : ArrClientBase()
|
ILogger<LidarrClient> logger, IOptions<LidarrInstanceOptions> options) : ArrClientBase()
|
||||||
{
|
{
|
||||||
private readonly string _lidarrHost = configuration.GetValue<string>("LIDARR_HOST") ?? throw new ArgumentException("LIDARR_HOST environment variable must be set");
|
public LidarrInstanceOptions LidarrOptions { get; } = options.Value;
|
||||||
private readonly string _lidarrApiKey = configuration.GetValue<string>("LIDARR_API_KEY") ?? throw new ArgumentException("LIDARR_API_KEY environment variable must be set");
|
|
||||||
private readonly string _mediaType = "audio";
|
private readonly string _mediaType = "audio";
|
||||||
|
|
||||||
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
|
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
|
||||||
@@ -25,7 +25,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
var lidarrArtistsUrl = $"{_lidarrHost}/api/v1/artist?apikey={_lidarrApiKey}";
|
var lidarrArtistsUrl = $"{LidarrOptions.Host}/api/v1/artist?apikey={LidarrOptions.ApiKey}";
|
||||||
logger.LogInformation($"Fetching all artists from Lidarr: {UrlUtilities.RedactApiKey(lidarrArtistsUrl)}");
|
logger.LogInformation($"Fetching all artists from Lidarr: {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);
|
||||||
@@ -40,7 +40,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
{
|
{
|
||||||
var artistId = (int)artist.id;
|
var artistId = (int)artist.id;
|
||||||
|
|
||||||
var lidarrAlbumUrl = $"{_lidarrHost}/api/v1/album?artistId={artistId}&apikey={_lidarrApiKey}";
|
var lidarrAlbumUrl = $"{LidarrOptions.Host}/api/v1/album?artistId={artistId}&apikey={LidarrOptions.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
|
||||||
@@ -135,7 +135,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
// this should never be called at the moment
|
// this should never be called at the moment
|
||||||
throw new NotImplementedException();
|
throw new NotImplementedException();
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
|
|||||||
@@ -1,7 +1,9 @@
|
|||||||
using Microsoft.Extensions.Caching.Memory;
|
using Microsoft.Extensions.Caching.Memory;
|
||||||
|
using Microsoft.Extensions.Options;
|
||||||
using Newtonsoft.Json;
|
using Newtonsoft.Json;
|
||||||
using Newtonsoft.Json.Linq;
|
using Newtonsoft.Json.Linq;
|
||||||
using UmlautAdaptarr.Models;
|
using UmlautAdaptarr.Models;
|
||||||
|
using UmlautAdaptarr.Options.ArrOptions;
|
||||||
using UmlautAdaptarr.Services;
|
using UmlautAdaptarr.Services;
|
||||||
using UmlautAdaptarr.Utilities;
|
using UmlautAdaptarr.Utilities;
|
||||||
|
|
||||||
@@ -9,13 +11,13 @@ namespace UmlautAdaptarr.Providers
|
|||||||
{
|
{
|
||||||
public class ReadarrClient(
|
public class ReadarrClient(
|
||||||
IHttpClientFactory clientFactory,
|
IHttpClientFactory clientFactory,
|
||||||
IConfiguration configuration,
|
|
||||||
CacheService cacheService,
|
CacheService cacheService,
|
||||||
IMemoryCache cache,
|
IMemoryCache cache,
|
||||||
|
IOptions<ReadarrInstanceOptions> options,
|
||||||
ILogger<ReadarrClient> logger) : ArrClientBase()
|
ILogger<ReadarrClient> logger) : ArrClientBase()
|
||||||
{
|
{
|
||||||
private readonly string _readarrHost = configuration.GetValue<string>("READARR_HOST") ?? throw new ArgumentException("READARR_HOST environment variable must be set");
|
|
||||||
private readonly string _readarrApiKey = configuration.GetValue<string>("READARR_API_KEY") ?? throw new ArgumentException("READARR_API_KEY environment variable must be set");
|
public ReadarrInstanceOptions ReadarrOptions { get; } = options.Value;
|
||||||
private readonly string _mediaType = "book";
|
private readonly string _mediaType = "book";
|
||||||
|
|
||||||
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
|
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
|
||||||
@@ -25,7 +27,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
var readarrAuthorUrl = $"{_readarrHost}/api/v1/author?apikey={_readarrApiKey}";
|
var readarrAuthorUrl = $"{ReadarrOptions.Host}/api/v1/author?apikey={ReadarrOptions.ApiKey}";
|
||||||
logger.LogInformation($"Fetching all authors from Readarr: {UrlUtilities.RedactApiKey(readarrAuthorUrl)}");
|
logger.LogInformation($"Fetching all authors from Readarr: {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);
|
||||||
@@ -40,7 +42,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
{
|
{
|
||||||
var authorId = (int)author.id;
|
var authorId = (int)author.id;
|
||||||
|
|
||||||
var readarrBookUrl = $"{_readarrHost}/api/v1/book?authorId={authorId}&apikey={_readarrApiKey}";
|
var readarrBookUrl = $"{ReadarrOptions.Host}/api/v1/book?authorId={authorId}&apikey={ReadarrOptions.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: {UrlUtilities.RedactApiKey(readarrBookUrl)}");
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
using Newtonsoft.Json;
|
using Microsoft.Extensions.Options;
|
||||||
|
using Newtonsoft.Json;
|
||||||
using UmlautAdaptarr.Models;
|
using UmlautAdaptarr.Models;
|
||||||
|
using UmlautAdaptarr.Options.ArrOptions;
|
||||||
using UmlautAdaptarr.Services;
|
using UmlautAdaptarr.Services;
|
||||||
using UmlautAdaptarr.Utilities;
|
using UmlautAdaptarr.Utilities;
|
||||||
|
|
||||||
@@ -7,12 +9,11 @@ namespace UmlautAdaptarr.Providers
|
|||||||
{
|
{
|
||||||
public class SonarrClient(
|
public class SonarrClient(
|
||||||
IHttpClientFactory clientFactory,
|
IHttpClientFactory clientFactory,
|
||||||
IConfiguration configuration,
|
|
||||||
TitleApiService titleService,
|
TitleApiService titleService,
|
||||||
|
IOptions<SonarrInstanceOptions> options,
|
||||||
ILogger<SonarrClient> logger) : ArrClientBase()
|
ILogger<SonarrClient> logger) : ArrClientBase()
|
||||||
{
|
{
|
||||||
private readonly string _sonarrHost = configuration.GetValue<string>("SONARR_HOST") ?? throw new ArgumentException("SONARR_HOST environment variable must be set");
|
public SonarrInstanceOptions SonarrOptions { get; } = options.Value;
|
||||||
private readonly string _sonarrApiKey = configuration.GetValue<string>("SONARR_API_KEY") ?? throw new ArgumentException("SONARR_API_KEY environment variable must be set");
|
|
||||||
private readonly string _mediaType = "tv";
|
private readonly string _mediaType = "tv";
|
||||||
|
|
||||||
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
|
public override async Task<IEnumerable<SearchItem>> FetchAllItemsAsync()
|
||||||
@@ -22,7 +23,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
var sonarrUrl = $"{_sonarrHost}/api/v3/series?includeSeasonImages=false&apikey={_sonarrApiKey}";
|
var sonarrUrl = $"{SonarrOptions.Host}/api/v3/series?includeSeasonImages=false&apikey={SonarrOptions.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);
|
||||||
@@ -71,7 +72,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
var sonarrUrl = $"{_sonarrHost}/api/v3/series?tvdbId={externalId}&includeSeasonImages=false&apikey={_sonarrApiKey}";
|
var sonarrUrl = $"{SonarrOptions.Host}/api/v3/series?tvdbId={externalId}&includeSeasonImages=false&apikey={SonarrOptions.ApiKey}";
|
||||||
logger.LogInformation($"Fetching item by external ID from Sonarr: {UrlUtilities.RedactApiKey(sonarrUrl)}");
|
logger.LogInformation($"Fetching item by external ID from Sonarr: {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);
|
||||||
@@ -98,7 +99,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
mediaType: _mediaType
|
mediaType: _mediaType
|
||||||
);
|
);
|
||||||
|
|
||||||
logger.LogInformation($"Successfully fetched show {searchItem} from Sonarr.");
|
logger.LogInformation($"Successfully fetched show {searchItem.Title} from Sonarr.");
|
||||||
return searchItem;
|
return searchItem;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -123,7 +124,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
var sonarrUrl = $"{_sonarrHost}/api/v3/series?tvdbId={tvdbId}&includeSeasonImages=false&apikey={_sonarrApiKey}";
|
var sonarrUrl = $"{SonarrOptions.Host}/api/v3/series?tvdbId={tvdbId}&includeSeasonImages=false&apikey={SonarrOptions.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);
|
||||||
|
|
||||||
@@ -156,7 +157,7 @@ namespace UmlautAdaptarr.Providers
|
|||||||
mediaType: _mediaType
|
mediaType: _mediaType
|
||||||
);
|
);
|
||||||
|
|
||||||
logger.LogInformation($"Successfully fetched show {searchItem} from Sonarr.");
|
logger.LogInformation($"Successfully fetched show {searchItem.Title} from Sonarr.");
|
||||||
return searchItem;
|
return searchItem;
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
|
|||||||
@@ -16,12 +16,8 @@ namespace UmlautAdaptarr.Services
|
|||||||
LidarrClient lidarrClient,
|
LidarrClient lidarrClient,
|
||||||
ReadarrClient readarrClient,
|
ReadarrClient readarrClient,
|
||||||
CacheService cacheService,
|
CacheService cacheService,
|
||||||
IConfiguration configuration,
|
|
||||||
ILogger<ArrSyncBackgroundService> logger) : BackgroundService
|
ILogger<ArrSyncBackgroundService> logger) : BackgroundService
|
||||||
{
|
{
|
||||||
private readonly bool _sonarrEnabled = configuration.GetValue<bool>("SONARR_ENABLED");
|
|
||||||
private readonly bool _lidarrEnabled = configuration.GetValue<bool>("LIDARR_ENABLED");
|
|
||||||
private readonly bool _readarrEnabled = configuration.GetValue<bool>("READARR_ENABLED");
|
|
||||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||||
{
|
{
|
||||||
logger.LogInformation("ArrSyncBackgroundService is starting.");
|
logger.LogInformation("ArrSyncBackgroundService is starting.");
|
||||||
@@ -62,17 +58,20 @@ namespace UmlautAdaptarr.Services
|
|||||||
try
|
try
|
||||||
{
|
{
|
||||||
var success = true;
|
var success = true;
|
||||||
if (_readarrEnabled)
|
if (readarrClient.ReadarrOptions.Enabled)
|
||||||
{
|
{
|
||||||
success = success && await FetchItemsFromReadarrAsync();
|
var syncSuccess = await FetchItemsFromReadarrAsync();
|
||||||
|
success = success && syncSuccess;
|
||||||
}
|
}
|
||||||
if (_sonarrEnabled)
|
if (sonarrClient.SonarrOptions.Enabled)
|
||||||
{
|
{
|
||||||
success = success && await FetchItemsFromSonarrAsync();
|
var syncSuccess = await FetchItemsFromSonarrAsync();
|
||||||
|
success = success && syncSuccess;
|
||||||
}
|
}
|
||||||
if (_lidarrEnabled)
|
if (lidarrClient.LidarrOptions.Enabled)
|
||||||
{
|
{
|
||||||
success = success && await FetchItemsFromLidarrAsync();
|
var syncSuccess = await FetchItemsFromLidarrAsync();
|
||||||
|
success = success && syncSuccess;
|
||||||
}
|
}
|
||||||
return success;
|
return success;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -96,30 +96,51 @@ namespace UmlautAdaptarr.Services
|
|||||||
// Use the first few characters of the normalized title for cache prefix search
|
// Use the first few characters of the normalized title for cache prefix search
|
||||||
var cacheSearchPrefix = normalizedTitle[..Math.Min(VARIATION_LOOKUP_CACHE_LENGTH, normalizedTitle.Length)];
|
var cacheSearchPrefix = normalizedTitle[..Math.Min(VARIATION_LOOKUP_CACHE_LENGTH, normalizedTitle.Length)];
|
||||||
|
|
||||||
|
SearchItem? bestSearchItemMatch = null;
|
||||||
|
var bestVariationMatchLength = 0;
|
||||||
|
HashSet<string> checkedSearchItems = [];
|
||||||
|
|
||||||
if (VariationIndex.TryGetValue(cacheSearchPrefix, out var cacheKeys))
|
if (VariationIndex.TryGetValue(cacheSearchPrefix, out var cacheKeys))
|
||||||
{
|
{
|
||||||
foreach (var cacheKey in cacheKeys)
|
foreach (var cacheKey in cacheKeys)
|
||||||
{
|
{
|
||||||
if (cache.TryGetValue(cacheKey, out SearchItem? item))
|
if (cache.TryGetValue(cacheKey, out SearchItem? item))
|
||||||
{
|
{
|
||||||
if (item?.MediaType != mediaType)
|
if (item == null || item.MediaType != mediaType)
|
||||||
{
|
{
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var searchItemIdentifier = $"{item.MediaType}_{item.ExternalId}";
|
||||||
|
|
||||||
|
if (checkedSearchItems.Contains(searchItemIdentifier))
|
||||||
|
{
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
checkedSearchItems.Add(searchItemIdentifier);
|
||||||
|
}
|
||||||
|
|
||||||
// After finding a potential item, compare normalizedTitle with each German title variation
|
// After finding a potential item, compare normalizedTitle with each German title variation
|
||||||
foreach (var variation in item?.TitleMatchVariations ?? [])
|
foreach (var variation in item.TitleMatchVariations ?? [])
|
||||||
{
|
{
|
||||||
var normalizedVariation = variation.RemoveAccentButKeepGermanUmlauts().ToLower();
|
var normalizedVariation = variation.RemoveAccentButKeepGermanUmlauts().ToLower();
|
||||||
if (normalizedTitle.StartsWith(variation, StringComparison.OrdinalIgnoreCase))
|
if (normalizedTitle.StartsWith(variation, StringComparison.OrdinalIgnoreCase))
|
||||||
{
|
{
|
||||||
return item;
|
// If we find a variation match that is "longer" then most likely that one is correct and the earlier match was wrong (if it was from another searchItem)
|
||||||
|
if (variation.Length > bestVariationMatchLength)
|
||||||
|
{
|
||||||
|
bestSearchItemMatch = item;
|
||||||
|
bestVariationMatchLength = variation.Length;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return null;
|
return bestSearchItemMatch;
|
||||||
}
|
}
|
||||||
|
|
||||||
public SearchItem? GetSearchItemByExternalId(string mediaType, string externalId)
|
public SearchItem? GetSearchItemByExternalId(string mediaType, string externalId)
|
||||||
|
|||||||
178
UmlautAdaptarr/Services/HttpProxyService.cs
Normal file
178
UmlautAdaptarr/Services/HttpProxyService.cs
Normal file
@@ -0,0 +1,178 @@
|
|||||||
|
using System.Net;
|
||||||
|
using System.Net.Sockets;
|
||||||
|
using System.Text;
|
||||||
|
|
||||||
|
namespace UmlautAdaptarr.Services
|
||||||
|
{
|
||||||
|
public class HttpProxyService : IHostedService
|
||||||
|
{
|
||||||
|
private TcpListener _listener;
|
||||||
|
private readonly ILogger<HttpProxyService> _logger;
|
||||||
|
private readonly int _proxyPort = 5006; // TODO move to appsettings.json
|
||||||
|
private readonly IHttpClientFactory _clientFactory;
|
||||||
|
private HashSet<string> _knownHosts = [];
|
||||||
|
private readonly object _hostsLock = new object();
|
||||||
|
|
||||||
|
|
||||||
|
public HttpProxyService(ILogger<HttpProxyService> logger, IHttpClientFactory clientFactory)
|
||||||
|
{
|
||||||
|
_logger = logger;
|
||||||
|
_clientFactory = clientFactory;
|
||||||
|
_knownHosts.Add("prowlarr.servarr.com");
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task HandleRequests(CancellationToken stoppingToken)
|
||||||
|
{
|
||||||
|
while (!stoppingToken.IsCancellationRequested)
|
||||||
|
{
|
||||||
|
var clientSocket = await _listener.AcceptSocketAsync();
|
||||||
|
_ = Task.Run(() => ProcessRequest(clientSocket), stoppingToken);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task ProcessRequest(Socket clientSocket)
|
||||||
|
{
|
||||||
|
using var clientStream = new NetworkStream(clientSocket, ownsSocket: true);
|
||||||
|
var buffer = new byte[8192];
|
||||||
|
var bytesRead = await clientStream.ReadAsync(buffer, 0, buffer.Length);
|
||||||
|
var requestString = Encoding.ASCII.GetString(buffer, 0, bytesRead);
|
||||||
|
|
||||||
|
if (requestString.StartsWith("CONNECT"))
|
||||||
|
{
|
||||||
|
// Handle HTTPS CONNECT request
|
||||||
|
await HandleHttpsConnect(requestString, clientStream, clientSocket);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
// Handle HTTP request
|
||||||
|
await HandleHttp(requestString, clientStream, clientSocket, buffer, bytesRead);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task HandleHttpsConnect(string requestString, NetworkStream clientStream, Socket clientSocket)
|
||||||
|
{
|
||||||
|
var (host, port) = ParseTargetInfo(requestString);
|
||||||
|
|
||||||
|
// Prowlarr will send grab requests via https which cannot be changed
|
||||||
|
if (!_knownHosts.Contains(host))
|
||||||
|
{
|
||||||
|
_logger.LogWarning($"IMPORTANT! {Environment.NewLine} Indexer {host} needs to be set to http:// instead of https:// {Environment.NewLine}" +
|
||||||
|
$"UmlautAdaptarr will not work for {host}!");
|
||||||
|
}
|
||||||
|
using var targetSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||||||
|
try
|
||||||
|
{
|
||||||
|
await targetSocket.ConnectAsync(host, port);
|
||||||
|
await clientStream.WriteAsync(Encoding.ASCII.GetBytes("HTTP/1.1 200 Connection Established\r\n\r\n"));
|
||||||
|
using var targetStream = new NetworkStream(targetSocket, ownsSocket: true);
|
||||||
|
await RelayTraffic(clientStream, targetStream);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
_logger.LogError($"Failed to connect to target: {ex.Message}");
|
||||||
|
clientSocket.Close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task HandleHttp(string requestString, NetworkStream clientStream, Socket clientSocket, byte[] buffer, int bytesRead)
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
var headers = ParseHeaders(buffer, bytesRead);
|
||||||
|
string userAgent = headers.FirstOrDefault(h => h.Key == "User-Agent").Value;
|
||||||
|
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?
|
||||||
|
using var client = _clientFactory.CreateClient();
|
||||||
|
var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, modifiedUri);
|
||||||
|
httpRequestMessage.Headers.Add("User-Agent", userAgent);
|
||||||
|
var result = await client.SendAsync(httpRequestMessage);
|
||||||
|
|
||||||
|
if (result.IsSuccessStatusCode)
|
||||||
|
{
|
||||||
|
var responseData = await result.Content.ReadAsByteArrayAsync();
|
||||||
|
await clientStream.WriteAsync(Encoding.ASCII.GetBytes($"HTTP/1.1 200 OK\r\nContent-Length: {responseData.Length}\r\n\r\n"));
|
||||||
|
await clientStream.WriteAsync(responseData);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
await clientStream.WriteAsync(Encoding.ASCII.GetBytes($"HTTP/1.1 {result.StatusCode}\r\n\r\n"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
_logger.LogError($"HTTP Proxy error: {ex.Message}");
|
||||||
|
await clientStream.WriteAsync(Encoding.ASCII.GetBytes("HTTP/1.1 500 Internal Server Error\r\n\r\n"));
|
||||||
|
}
|
||||||
|
finally
|
||||||
|
{
|
||||||
|
clientSocket.Close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private Dictionary<string, string> ParseHeaders(byte[] buffer, int length)
|
||||||
|
{
|
||||||
|
var headers = new Dictionary<string, string>();
|
||||||
|
var headerString = Encoding.ASCII.GetString(buffer, 0, length);
|
||||||
|
var lines = headerString.Split(new string[] { "\r\n" }, StringSplitOptions.RemoveEmptyEntries);
|
||||||
|
foreach (var line in lines.Skip(1)) // Skip the request line
|
||||||
|
{
|
||||||
|
var colonIndex = line.IndexOf(':');
|
||||||
|
if (colonIndex > 0)
|
||||||
|
{
|
||||||
|
var key = line.Substring(0, colonIndex).Trim();
|
||||||
|
var value = line.Substring(colonIndex + 1).Trim();
|
||||||
|
headers[key] = value;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return headers;
|
||||||
|
}
|
||||||
|
|
||||||
|
private (string host, int port) ParseTargetInfo(string requestLine)
|
||||||
|
{
|
||||||
|
var parts = requestLine.Split(' ')[1].Split(':');
|
||||||
|
return (parts[0], int.Parse(parts[1]));
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task RelayTraffic(NetworkStream clientStream, NetworkStream targetStream)
|
||||||
|
{
|
||||||
|
var clientToTargetTask = RelayStream(clientStream, targetStream);
|
||||||
|
var targetToClientTask = RelayStream(targetStream, clientStream);
|
||||||
|
await Task.WhenAll(clientToTargetTask, targetToClientTask);
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task RelayStream(NetworkStream input, NetworkStream output)
|
||||||
|
{
|
||||||
|
byte[] buffer = new byte[8192];
|
||||||
|
int bytesRead;
|
||||||
|
while ((bytesRead = await input.ReadAsync(buffer.AsMemory(0, buffer.Length))) > 0)
|
||||||
|
{
|
||||||
|
await output.WriteAsync(buffer.AsMemory(0, bytesRead));
|
||||||
|
await output.FlushAsync();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public Task StartAsync(CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
_listener = new TcpListener(IPAddress.Any, _proxyPort);
|
||||||
|
_listener.Start();
|
||||||
|
Task.Run(() => HandleRequests(cancellationToken), cancellationToken);
|
||||||
|
return Task.CompletedTask;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Task StopAsync(CancellationToken cancellationToken)
|
||||||
|
{
|
||||||
|
_listener.Stop();
|
||||||
|
return Task.CompletedTask;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,21 +1,26 @@
|
|||||||
using Microsoft.Extensions.Caching.Memory;
|
using Microsoft.Extensions.Caching.Memory;
|
||||||
using System.Collections.Concurrent;
|
using System.Collections.Concurrent;
|
||||||
|
using Microsoft.Extensions.Options;
|
||||||
|
using UmlautAdaptarr.Options;
|
||||||
using UmlautAdaptarr.Utilities;
|
using UmlautAdaptarr.Utilities;
|
||||||
|
|
||||||
namespace UmlautAdaptarr.Services
|
namespace UmlautAdaptarr.Services
|
||||||
{
|
{
|
||||||
public class ProxyService
|
public class ProxyRequestService
|
||||||
{
|
{
|
||||||
private readonly HttpClient _httpClient;
|
private readonly HttpClient _httpClient;
|
||||||
private readonly string _userAgent;
|
private readonly string _userAgent;
|
||||||
private readonly ILogger<ProxyService> _logger;
|
private readonly ILogger<ProxyRequestService> _logger;
|
||||||
private readonly IMemoryCache _cache;
|
private readonly IMemoryCache _cache;
|
||||||
|
private readonly GlobalOptions _options;
|
||||||
private static readonly ConcurrentDictionary<string, DateTimeOffset> _lastRequestTimes = new();
|
private static readonly ConcurrentDictionary<string, DateTimeOffset> _lastRequestTimes = new();
|
||||||
|
private static readonly TimeSpan MINIMUM_DELAY_FOR_SAME_HOST = new(0, 0, 0, 1);
|
||||||
|
|
||||||
public ProxyService(IHttpClientFactory clientFactory, IConfiguration configuration, ILogger<ProxyService> logger, IMemoryCache cache)
|
public ProxyRequestService(IHttpClientFactory clientFactory, ILogger<ProxyRequestService> logger, IMemoryCache cache, IOptions<GlobalOptions> options)
|
||||||
{
|
{
|
||||||
|
_options = options.Value;
|
||||||
_httpClient = clientFactory.CreateClient("HttpClient") ?? throw new ArgumentNullException(nameof(clientFactory));
|
_httpClient = clientFactory.CreateClient("HttpClient") ?? throw new ArgumentNullException(nameof(clientFactory));
|
||||||
_userAgent = configuration["Settings:UserAgent"] ?? throw new ArgumentException("UserAgent must be set in appsettings.json");
|
_userAgent = _options.UserAgent ?? throw new ArgumentException("UserAgent must be set in appsettings.json");
|
||||||
_logger = logger;
|
_logger = logger;
|
||||||
_cache = cache;
|
_cache = cache;
|
||||||
}
|
}
|
||||||
@@ -26,9 +31,9 @@ namespace UmlautAdaptarr.Services
|
|||||||
if (_lastRequestTimes.TryGetValue(host, out var lastRequestTime))
|
if (_lastRequestTimes.TryGetValue(host, out var lastRequestTime))
|
||||||
{
|
{
|
||||||
var timeSinceLastRequest = DateTimeOffset.Now - lastRequestTime;
|
var timeSinceLastRequest = DateTimeOffset.Now - lastRequestTime;
|
||||||
if (timeSinceLastRequest < TimeSpan.FromMilliseconds(1500))
|
if (timeSinceLastRequest < MINIMUM_DELAY_FOR_SAME_HOST)
|
||||||
{
|
{
|
||||||
await Task.Delay(TimeSpan.FromMilliseconds(1500) - timeSinceLastRequest);
|
await Task.Delay(MINIMUM_DELAY_FOR_SAME_HOST - timeSinceLastRequest);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
_lastRequestTimes[host] = DateTimeOffset.Now;
|
_lastRequestTimes[host] = DateTimeOffset.Now;
|
||||||
@@ -71,12 +76,12 @@ namespace UmlautAdaptarr.Services
|
|||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
_logger.LogInformation($"ProxyService GET {UrlUtilities.RedactApiKey(targetUri)}");
|
_logger.LogInformation($"ProxyRequestService GET {UrlUtilities.RedactApiKey(targetUri)}");
|
||||||
var responseMessage = await _httpClient.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead, context.RequestAborted);
|
var responseMessage = await _httpClient.SendAsync(requestMessage, HttpCompletionOption.ResponseHeadersRead, context.RequestAborted);
|
||||||
|
|
||||||
if (responseMessage.IsSuccessStatusCode)
|
if (responseMessage.IsSuccessStatusCode)
|
||||||
{
|
{
|
||||||
_cache.Set(targetUri, responseMessage, TimeSpan.FromMinutes(5));
|
_cache.Set(targetUri, responseMessage, TimeSpan.FromMinutes(12));
|
||||||
}
|
}
|
||||||
|
|
||||||
return responseMessage;
|
return responseMessage;
|
||||||
@@ -85,7 +90,6 @@ namespace UmlautAdaptarr.Services
|
|||||||
{
|
{
|
||||||
_logger.LogError(ex, $"Error proxying request: {UrlUtilities.RedactApiKey(targetUri)}. Error: {ex.Message}");
|
_logger.LogError(ex, $"Error proxying request: {UrlUtilities.RedactApiKey(targetUri)}. Error: {ex.Message}");
|
||||||
|
|
||||||
// Create a response message indicating an internal server error
|
|
||||||
var errorResponse = new HttpResponseMessage(System.Net.HttpStatusCode.InternalServerError)
|
var errorResponse = new HttpResponseMessage(System.Net.HttpStatusCode.InternalServerError)
|
||||||
{
|
{
|
||||||
Content = new StringContent($"An error occurred while processing your request: {ex.Message}")
|
Content = new StringContent($"An error occurred while processing your request: {ex.Message}")
|
||||||
@@ -6,12 +6,8 @@ namespace UmlautAdaptarr.Services
|
|||||||
public class SearchItemLookupService(CacheService cacheService,
|
public class SearchItemLookupService(CacheService cacheService,
|
||||||
SonarrClient sonarrClient,
|
SonarrClient sonarrClient,
|
||||||
ReadarrClient readarrClient,
|
ReadarrClient readarrClient,
|
||||||
LidarrClient lidarrClient,
|
LidarrClient lidarrClient)
|
||||||
IConfiguration configuration)
|
|
||||||
{
|
{
|
||||||
private readonly bool _sonarrEnabled = configuration.GetValue<bool>("SONARR_ENABLED");
|
|
||||||
private readonly bool _lidarrEnabled = configuration.GetValue<bool>("LIDARR_ENABLED");
|
|
||||||
private readonly bool _readarrEnabled = configuration.GetValue<bool>("READARR_ENABLED");
|
|
||||||
public async Task<SearchItem?> GetOrFetchSearchItemByExternalId(string mediaType, string externalId)
|
public async Task<SearchItem?> GetOrFetchSearchItemByExternalId(string mediaType, string externalId)
|
||||||
{
|
{
|
||||||
// Attempt to get the item from the cache first
|
// Attempt to get the item from the cache first
|
||||||
@@ -26,20 +22,20 @@ namespace UmlautAdaptarr.Services
|
|||||||
switch (mediaType)
|
switch (mediaType)
|
||||||
{
|
{
|
||||||
case "tv":
|
case "tv":
|
||||||
if (_sonarrEnabled)
|
if (sonarrClient.SonarrOptions.Enabled)
|
||||||
{
|
{
|
||||||
fetchedItem = await sonarrClient.FetchItemByExternalIdAsync(externalId);
|
fetchedItem = await sonarrClient.FetchItemByExternalIdAsync(externalId);
|
||||||
}
|
}
|
||||||
break;
|
break;
|
||||||
case "audio":
|
case "audio":
|
||||||
if (_lidarrEnabled)
|
if (lidarrClient.LidarrOptions.Enabled)
|
||||||
{
|
{
|
||||||
fetchedItem = 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 (_readarrEnabled)
|
if (readarrClient.ReadarrOptions.Enabled)
|
||||||
{
|
{
|
||||||
await readarrClient.FetchItemByExternalIdAsync(externalId);
|
await readarrClient.FetchItemByExternalIdAsync(externalId);
|
||||||
fetchedItem = cacheService.GetSearchItemByExternalId(mediaType, externalId);
|
fetchedItem = cacheService.GetSearchItemByExternalId(mediaType, externalId);
|
||||||
@@ -70,7 +66,7 @@ namespace UmlautAdaptarr.Services
|
|||||||
switch (mediaType)
|
switch (mediaType)
|
||||||
{
|
{
|
||||||
case "tv":
|
case "tv":
|
||||||
if (_sonarrEnabled)
|
if (sonarrClient.SonarrOptions.Enabled)
|
||||||
{
|
{
|
||||||
fetchedItem = await sonarrClient.FetchItemByTitleAsync(title);
|
fetchedItem = await sonarrClient.FetchItemByTitleAsync(title);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,13 +1,15 @@
|
|||||||
using Newtonsoft.Json;
|
using Microsoft.Extensions.Options;
|
||||||
|
using Newtonsoft.Json;
|
||||||
using Newtonsoft.Json.Linq;
|
using Newtonsoft.Json.Linq;
|
||||||
|
using UmlautAdaptarr.Options;
|
||||||
using UmlautAdaptarr.Utilities;
|
using UmlautAdaptarr.Utilities;
|
||||||
|
|
||||||
namespace UmlautAdaptarr.Services
|
namespace UmlautAdaptarr.Services
|
||||||
{
|
{
|
||||||
public class TitleApiService(IHttpClientFactory clientFactory, IConfiguration configuration, ILogger<TitleApiService> logger)
|
public class TitleApiService(IHttpClientFactory clientFactory, ILogger<TitleApiService> logger, IOptions<GlobalOptions> options)
|
||||||
{
|
{
|
||||||
private readonly string _umlautAdaptarrApiHost = configuration["Settings:UmlautAdaptarrApiHost"]
|
public GlobalOptions Options { get; } = options.Value;
|
||||||
?? throw new ArgumentException("UmlautAdaptarrApiHost must be set in appsettings.json");
|
|
||||||
private DateTime lastRequestTime = DateTime.MinValue;
|
private DateTime lastRequestTime = DateTime.MinValue;
|
||||||
|
|
||||||
private async Task EnsureMinimumDelayAsync()
|
private async Task EnsureMinimumDelayAsync()
|
||||||
@@ -28,7 +30,7 @@ namespace UmlautAdaptarr.Services
|
|||||||
await EnsureMinimumDelayAsync();
|
await EnsureMinimumDelayAsync();
|
||||||
|
|
||||||
var httpClient = clientFactory.CreateClient();
|
var httpClient = clientFactory.CreateClient();
|
||||||
var titleApiUrl = $"{_umlautAdaptarrApiHost}/tvshow_german.php?tvdbid={externalId}";
|
var titleApiUrl = $"{Options.UmlautAdaptarrApiHost}/tvshow_german.php?tvdbid={externalId}";
|
||||||
logger.LogInformation($"TitleApiService GET {UrlUtilities.RedactApiKey(titleApiUrl)}");
|
logger.LogInformation($"TitleApiService GET {UrlUtilities.RedactApiKey(titleApiUrl)}");
|
||||||
var response = await httpClient.GetStringAsync(titleApiUrl);
|
var response = await httpClient.GetStringAsync(titleApiUrl);
|
||||||
var titleApiResponseData = JsonConvert.DeserializeObject<dynamic>(response);
|
var titleApiResponseData = JsonConvert.DeserializeObject<dynamic>(response);
|
||||||
@@ -74,7 +76,7 @@ namespace UmlautAdaptarr.Services
|
|||||||
|
|
||||||
var httpClient = clientFactory.CreateClient();
|
var httpClient = clientFactory.CreateClient();
|
||||||
var tvdbCleanTitle = title.Replace("ß", "ss");
|
var tvdbCleanTitle = title.Replace("ß", "ss");
|
||||||
var titleApiUrl = $"{_umlautAdaptarrApiHost}/tvshow_german.php?title={tvdbCleanTitle}";
|
var titleApiUrl = $"{Options.UmlautAdaptarrApiHost}/tvshow_german.php?title={tvdbCleanTitle}";
|
||||||
logger.LogInformation($"TitleApiService GET {UrlUtilities.RedactApiKey(titleApiUrl)}");
|
logger.LogInformation($"TitleApiService GET {UrlUtilities.RedactApiKey(titleApiUrl)}");
|
||||||
var titleApiResponse = await httpClient.GetStringAsync(titleApiUrl);
|
var titleApiResponse = await httpClient.GetStringAsync(titleApiUrl);
|
||||||
var titleApiResponseData = JsonConvert.DeserializeObject<dynamic>(titleApiResponse);
|
var titleApiResponseData = JsonConvert.DeserializeObject<dynamic>(titleApiResponse);
|
||||||
|
|||||||
@@ -221,14 +221,14 @@ namespace UmlautAdaptarr.Services
|
|||||||
*/
|
*/
|
||||||
|
|
||||||
// Construct the new title with the original suffix
|
// Construct the new title with the original suffix
|
||||||
var newTitle = newTitlePrefix + (string.IsNullOrEmpty(suffix) ? "" : separator + suffix);
|
var newTitle = newTitlePrefix + (string.IsNullOrEmpty(suffix) ? "" : suffix.StartsWith(separator) ? suffix : $"{separator}{suffix}");
|
||||||
|
|
||||||
// Update the title element's value with the new title
|
// Update the title element's value with the new title
|
||||||
//titleElement.Value = newTitle + $"({originalTitle.Substring(0, variationLength)})";
|
//titleElement.Value = newTitle + $"({originalTitle.Substring(0, variationLength)})";
|
||||||
titleElement.Value = newTitle;
|
titleElement.Value = newTitle;
|
||||||
|
|
||||||
logger.LogInformation($"TitleMatchingService - Title changed: '{originalTitle}' to '{newTitle}'");
|
logger.LogInformation($"TitleMatchingService - Title changed: '{originalTitle}' to '{newTitle}'");
|
||||||
break; // Break after the first successful match and modification
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -242,7 +242,7 @@ namespace UmlautAdaptarr.Services
|
|||||||
private static char FindFirstSeparator(string title)
|
private static char FindFirstSeparator(string title)
|
||||||
{
|
{
|
||||||
var match = WordSeperationCharRegex().Match(title);
|
var match = WordSeperationCharRegex().Match(title);
|
||||||
return match.Success ? match.Value.First() : ' '; // Default to space if no separator found
|
return match.Success ? match.Value.First() : ' ';
|
||||||
}
|
}
|
||||||
|
|
||||||
private static string ReconstructTitleWithSeparator(string title, char separator)
|
private static string ReconstructTitleWithSeparator(string title, char separator)
|
||||||
@@ -262,23 +262,23 @@ namespace UmlautAdaptarr.Services
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (category.StartsWith("EBook", StringComparison.OrdinalIgnoreCase) || category.StartsWith("Book", StringComparison.OrdinalIgnoreCase))
|
if (category == "7000" || category.StartsWith("EBook", StringComparison.OrdinalIgnoreCase) || category.StartsWith("Book", StringComparison.OrdinalIgnoreCase))
|
||||||
{
|
{
|
||||||
return "book";
|
return "book";
|
||||||
}
|
}
|
||||||
else if (category.StartsWith("Movies", StringComparison.OrdinalIgnoreCase))
|
else if (category == "2000" || category.StartsWith("Movies", StringComparison.OrdinalIgnoreCase))
|
||||||
{
|
{
|
||||||
return "movies";
|
return "movies";
|
||||||
}
|
}
|
||||||
else if (category.StartsWith("TV", StringComparison.OrdinalIgnoreCase))
|
else if (category == "5000" || category.StartsWith("TV", StringComparison.OrdinalIgnoreCase))
|
||||||
{
|
{
|
||||||
return "tv";
|
return "tv";
|
||||||
}
|
}
|
||||||
else if (category.Contains("Audiobook", StringComparison.OrdinalIgnoreCase))
|
else if (category == "3030" || category.Contains("Audiobook", StringComparison.OrdinalIgnoreCase))
|
||||||
{
|
{
|
||||||
return "book";
|
return "book";
|
||||||
}
|
}
|
||||||
else if (category.StartsWith("Audio"))
|
else if (category == "3000" || category.StartsWith("Audio"))
|
||||||
{
|
{
|
||||||
return "audio";
|
return "audio";
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,162 +0,0 @@
|
|||||||
using Microsoft.Extensions.Caching.Memory;
|
|
||||||
using Newtonsoft.Json;
|
|
||||||
using UmlautAdaptarr.Models;
|
|
||||||
using UmlautAdaptarr.Providers;
|
|
||||||
using UmlautAdaptarr.Utilities;
|
|
||||||
|
|
||||||
namespace UmlautAdaptarr.Services
|
|
||||||
{
|
|
||||||
public class TitleQueryServiceLegacy(
|
|
||||||
IMemoryCache memoryCache,
|
|
||||||
ILogger<TitleQueryServiceLegacy> logger,
|
|
||||||
IConfiguration configuration,
|
|
||||||
IHttpClientFactory clientFactory,
|
|
||||||
SonarrClient sonarrClient)
|
|
||||||
{
|
|
||||||
private readonly HttpClient _httpClient = clientFactory.CreateClient("HttpClient") ?? throw new ArgumentNullException();
|
|
||||||
private readonly string _sonarrHost = configuration.GetValue<string>("SONARR_HOST") ?? throw new ArgumentException("SONARR_HOST environment variable must be set");
|
|
||||||
private readonly string _sonarrApiKey = configuration.GetValue<string>("SONARR_API_KEY") ?? throw new ArgumentException("SONARR_API_KEY environment variable must be set");
|
|
||||||
private readonly string _umlautAdaptarrApiHost = configuration["Settings:UmlautAdaptarrApiHost"] ?? throw new ArgumentException("UmlautAdaptarrApiHost must be set in appsettings.json");
|
|
||||||
|
|
||||||
/*public async Task<(bool hasGermanUmlaut, string? GermanTitle, string ExpectedTitle)> QueryGermanShowTitleByTVDBId(string tvdbId)
|
|
||||||
{
|
|
||||||
var sonarrCacheKey = $"SearchItem_Sonarr_{tvdbId}";
|
|
||||||
|
|
||||||
if (memoryCache.TryGetValue(sonarrCacheKey, out SearchItem? cachedItem))
|
|
||||||
{
|
|
||||||
return (cachedItem?.HasGermanUmlaut ?? false, cachedItem?.GermanTitle, cachedItem?.ExpectedTitle ?? string.Empty);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
var sonarrUrl = $"{_sonarrHost}/api/v3/series?tvdbId={tvdbId}&includeSeasonImages=false&apikey={_sonarrApiKey}";
|
|
||||||
var sonarrApiResponse = await _httpClient.GetStringAsync(sonarrUrl);
|
|
||||||
var shows = JsonConvert.DeserializeObject<dynamic>(sonarrApiResponse);
|
|
||||||
|
|
||||||
if (shows == null)
|
|
||||||
{
|
|
||||||
logger.LogError($"Parsing Sonarr API response for TVDB ID {tvdbId} resulted in null");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
else if (shows.Count == 0)
|
|
||||||
{
|
|
||||||
logger.LogWarning($"No results found for TVDB ID {tvdbId}");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
var expectedTitle = (string)shows[0].title;
|
|
||||||
if (expectedTitle == null)
|
|
||||||
{
|
|
||||||
logger.LogError($"Sonarr Title for TVDB ID {tvdbId} is null");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
string? germanTitle = null;
|
|
||||||
var hasGermanTitle = false;
|
|
||||||
|
|
||||||
var titleApiUrl = $"{_umlautAdaptarrApiHost}/tvshow_german.php?tvdbid={tvdbId}";
|
|
||||||
var titleApiResponse = await _httpClient.GetStringAsync(titleApiUrl);
|
|
||||||
var titleApiResponseData = JsonConvert.DeserializeObject<dynamic>(titleApiResponse);
|
|
||||||
|
|
||||||
if (titleApiResponseData == null)
|
|
||||||
{
|
|
||||||
logger.LogError($"Parsing UmlautAdaptarr TitleQuery API response for TVDB ID {tvdbId} resulted in null");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (titleApiResponseData.status == "success" && !string.IsNullOrEmpty((string)titleApiResponseData.germanTitle))
|
|
||||||
{
|
|
||||||
germanTitle = titleApiResponseData.germanTitle;
|
|
||||||
hasGermanTitle = true;
|
|
||||||
}
|
|
||||||
|
|
||||||
var hasGermanUmlaut = germanTitle?.HasGermanUmlauts() ?? false;
|
|
||||||
|
|
||||||
var result = (hasGermanUmlaut, germanTitle, expectedTitle);
|
|
||||||
memoryCache.Set(showCacheKey, result, new MemoryCacheEntryOptions
|
|
||||||
{
|
|
||||||
Size = 1,
|
|
||||||
SlidingExpiration = hasGermanTitle ? TimeSpan.FromDays(30) : TimeSpan.FromDays(7)
|
|
||||||
});
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
}*/
|
|
||||||
|
|
||||||
// This method is being used if the *arrs do a search with the "q" parameter (text search)
|
|
||||||
public async Task<(bool hasGermanUmlaut, string? GermanTitle, string ExpectedTitle)> QueryGermanShowTitleByTitle(string title)
|
|
||||||
{
|
|
||||||
// TVDB doesn't use ß - TODO: Determine if this is true
|
|
||||||
var tvdbCleanTitle = title.Replace("ß", "ss");
|
|
||||||
|
|
||||||
var cacheKey = $"show_{tvdbCleanTitle}";
|
|
||||||
if (memoryCache.TryGetValue(cacheKey, out (bool hasGermanUmlaut, string? GermanTitle, string ExpectedTitle) cachedResult))
|
|
||||||
{
|
|
||||||
return cachedResult;
|
|
||||||
}
|
|
||||||
|
|
||||||
var titleApiUrl = $"{_umlautAdaptarrApiHost}/tvshow_german.php?title={tvdbCleanTitle}";
|
|
||||||
var titleApiResponse = await _httpClient.GetStringAsync(titleApiUrl);
|
|
||||||
var titleApiResponseData = JsonConvert.DeserializeObject<dynamic>(titleApiResponse);
|
|
||||||
|
|
||||||
if (titleApiResponseData == null)
|
|
||||||
{
|
|
||||||
logger.LogError($"Parsing UmlautAdaptarr TitleQuery API response for title {title} resulted in null");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (titleApiResponseData.status == "success" && !string.IsNullOrEmpty((string)titleApiResponseData.germanTitle))
|
|
||||||
{
|
|
||||||
var tvdbId = (string)titleApiResponseData.tvdbId;
|
|
||||||
if (tvdbId == null)
|
|
||||||
{
|
|
||||||
logger.LogError($"Parsing UmlautAdaptarr TitleQuery API response tvdbId {titleApiResponseData} resulted in null");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
var sonarrUrl = $"{_sonarrHost}/api/v3/series?tvdbId={tvdbId}&includeSeasonImages=false&apikey={_sonarrApiKey}";
|
|
||||||
var sonarrApiResponse = await _httpClient.GetStringAsync(sonarrUrl);
|
|
||||||
var shows = JsonConvert.DeserializeObject<dynamic>(sonarrApiResponse);
|
|
||||||
|
|
||||||
if (shows == null)
|
|
||||||
{
|
|
||||||
logger.LogError($"Parsing Sonarr API response for TVDB ID {tvdbId} resulted in null");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
else if (shows.Count == 0)
|
|
||||||
{
|
|
||||||
logger.LogWarning($"No results found for TVDB ID {tvdbId}");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
var expectedTitle = (string)shows[0].title;
|
|
||||||
if (expectedTitle == null)
|
|
||||||
{
|
|
||||||
logger.LogError($"Sonarr Title for TVDB ID {tvdbId} is null");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
|
|
||||||
string germanTitle ;
|
|
||||||
bool hasGermanTitle;
|
|
||||||
|
|
||||||
germanTitle = titleApiResponseData.germanTitle;
|
|
||||||
hasGermanTitle = true;
|
|
||||||
|
|
||||||
var hasGermanUmlaut = germanTitle?.HasUmlauts() ?? false;
|
|
||||||
|
|
||||||
var result = (hasGermanUmlaut, germanTitle, expectedTitle);
|
|
||||||
memoryCache.Set(cacheKey, result, new MemoryCacheEntryOptions
|
|
||||||
{
|
|
||||||
Size = 1,
|
|
||||||
SlidingExpiration = hasGermanTitle ? TimeSpan.FromDays(30) : TimeSpan.FromDays(7)
|
|
||||||
});
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
logger.LogWarning($"UmlautAdaptarr TitleQuery {titleApiUrl} didn't succeed.");
|
|
||||||
return (false, null, string.Empty);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -9,6 +9,8 @@
|
|||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
|
<PackageReference Include="Microsoft.Extensions.Options" Version="8.0.2" />
|
||||||
|
<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="Swashbuckle.AspNetCore" Version="6.5.0" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|||||||
19
UmlautAdaptarr/Utilities/GlobalStaticLogger.cs
Normal file
19
UmlautAdaptarr/Utilities/GlobalStaticLogger.cs
Normal file
@@ -0,0 +1,19 @@
|
|||||||
|
namespace UmlautAdaptarr.Utilities
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Service for providing a static logger to log errors and information.
|
||||||
|
/// The GlobalStaticLogger is designed to provide a static logger that can be used to log errors and information.
|
||||||
|
/// It facilitates logging for both static classes and extension methods.
|
||||||
|
/// </summary>
|
||||||
|
public static class GlobalStaticLogger
|
||||||
|
{
|
||||||
|
|
||||||
|
public static ILogger Logger;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Initializes the GlobalStaticLogger with the provided logger factory.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="loggerFactory">The ILoggerFactory instance used to create loggers.</param>
|
||||||
|
public static void Initialize(ILoggerFactory loggerFactory) => Logger = loggerFactory.CreateLogger("GlobalStaticLogger");
|
||||||
|
}
|
||||||
|
}
|
||||||
53
UmlautAdaptarr/Utilities/ProxyExtension.cs
Normal file
53
UmlautAdaptarr/Utilities/ProxyExtension.cs
Normal file
@@ -0,0 +1,53 @@
|
|||||||
|
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;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
92
UmlautAdaptarr/Utilities/ServicesExtensions.cs
Normal file
92
UmlautAdaptarr/Utilities/ServicesExtensions.cs
Normal file
@@ -0,0 +1,92 @@
|
|||||||
|
using UmlautAdaptarr.Options;
|
||||||
|
using UmlautAdaptarr.Options.ArrOptions;
|
||||||
|
using UmlautAdaptarr.Providers;
|
||||||
|
using UmlautAdaptarr.Services;
|
||||||
|
|
||||||
|
namespace UmlautAdaptarr.Utilities
|
||||||
|
{
|
||||||
|
/// <summary>
|
||||||
|
/// Extension methods for configuring services related to ARR Applications
|
||||||
|
/// </summary>
|
||||||
|
public static class ServicesExtensions
|
||||||
|
{
|
||||||
|
|
||||||
|
/// <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>
|
||||||
|
/// <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 AddServiceWithOptions<TOptions, TService>(this WebApplicationBuilder builder, string sectionName)
|
||||||
|
where TOptions : class
|
||||||
|
where TService : class
|
||||||
|
{
|
||||||
|
if (builder.Services == 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.");
|
||||||
|
}
|
||||||
|
|
||||||
|
builder.Services.Configure<TOptions>(builder.Configuration.GetSection(sectionName));
|
||||||
|
builder.Services.AddSingleton<TService>();
|
||||||
|
return builder;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Adds support for Sonarr with default options and client.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="builder">The <see cref="WebApplicationBuilder"/> to configure the service collection.</param>
|
||||||
|
/// <returns>The configured <see cref="WebApplicationBuilder"/>.</returns>
|
||||||
|
public static WebApplicationBuilder AddSonarrSupport(this WebApplicationBuilder builder)
|
||||||
|
{
|
||||||
|
return builder.AddServiceWithOptions<SonarrInstanceOptions, SonarrClient>("Sonarr");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Adds support for Lidarr with default options and client.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="builder">The <see cref="WebApplicationBuilder"/> to configure the service collection.</param>
|
||||||
|
/// <returns>The configured <see cref="WebApplicationBuilder"/>.</returns>
|
||||||
|
public static WebApplicationBuilder AddLidarrSupport(this WebApplicationBuilder builder)
|
||||||
|
{
|
||||||
|
return builder.AddServiceWithOptions<LidarrInstanceOptions, LidarrClient>("Lidarr");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Adds support for Readarr with default options and client.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="builder">The <see cref="WebApplicationBuilder"/> to configure the service collection.</param>
|
||||||
|
/// <returns>The configured <see cref="WebApplicationBuilder"/>.</returns>
|
||||||
|
public static WebApplicationBuilder AddReadarrSupport(this WebApplicationBuilder builder)
|
||||||
|
{
|
||||||
|
return builder.AddServiceWithOptions<ReadarrInstanceOptions, ReadarrClient>("Readarr");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Adds a title lookup service to the service collection.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="builder">The <see cref="WebApplicationBuilder"/> to configure the service collection.</param>
|
||||||
|
/// <returns>The configured <see cref="WebApplicationBuilder"/>.</returns>
|
||||||
|
public static WebApplicationBuilder AddTitleLookupService(this WebApplicationBuilder builder)
|
||||||
|
{
|
||||||
|
return builder.AddServiceWithOptions<GlobalOptions, TitleApiService>("Settings");
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Adds a proxy request service to the service collection.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="builder">The <see cref="WebApplicationBuilder"/> to configure the service collection.</param>
|
||||||
|
/// <returns>The configured <see cref="WebApplicationBuilder"/>.</returns>
|
||||||
|
public static WebApplicationBuilder AddProxyRequestService(this WebApplicationBuilder builder)
|
||||||
|
{
|
||||||
|
return builder.AddServiceWithOptions<GlobalOptions, ProxyRequestService>("Settings");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -12,7 +12,7 @@ namespace UmlautAdaptarr.Utilities
|
|||||||
// RegEx für eine einfache URL-Validierung ohne http:// und ohne abschließenden Schrägstrich
|
// RegEx für eine einfache URL-Validierung ohne http:// und ohne abschließenden Schrägstrich
|
||||||
// Erlaubt optionale Subdomains, Domainnamen und TLDs, aber keine Pfade oder Protokolle
|
// Erlaubt optionale Subdomains, Domainnamen und TLDs, aber keine Pfade oder Protokolle
|
||||||
var regex = UrlMatchingRegex();
|
var regex = UrlMatchingRegex();
|
||||||
return regex.IsMatch(domain) && !domain.EndsWith("/");
|
return regex.IsMatch(domain);
|
||||||
}
|
}
|
||||||
|
|
||||||
public static string BuildUrl(string domain, IDictionary<string, string> queryParameters)
|
public static string BuildUrl(string domain, IDictionary<string, string> queryParameters)
|
||||||
|
|||||||
@@ -3,18 +3,64 @@
|
|||||||
"LogLevel": {
|
"LogLevel": {
|
||||||
"Default": "Information",
|
"Default": "Information",
|
||||||
"Microsoft.AspNetCore": "Warning"
|
"Microsoft.AspNetCore": "Warning"
|
||||||
|
},
|
||||||
|
"Console": {
|
||||||
|
"TimestampFormat": "yyyy-MM-dd HH:mm:ss::"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"AllowedHosts": "*",
|
"AllowedHosts": "*",
|
||||||
"Kestrel": {
|
"Kestrel": {
|
||||||
"Endpoints": {
|
"Endpoints": {
|
||||||
"Http": {
|
"Http": {
|
||||||
"Url": "http://*:5005"
|
"Url": "http://[::]:5005"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
// Settings__UserAgent=UmlautAdaptarr/1.0
|
||||||
|
// Settings__UmlautAdaptarrApiHost=https://umlautadaptarr.pcjones.de/api/v1
|
||||||
"Settings": {
|
"Settings": {
|
||||||
"UserAgent": "UmlautAdaptarr/1.0",
|
"UserAgent": "UmlautAdaptarr/1.0",
|
||||||
"UmlautAdaptarrApiHost": "https://umlautadaptarr.pcjones.de/api/v1"
|
"UmlautAdaptarrApiHost": "https://umlautadaptarr.pcjones.de/api/v1"
|
||||||
|
},
|
||||||
|
"Sonarr": {
|
||||||
|
// Docker Environment Variables:
|
||||||
|
// - Sonarr__Enabled: true (set to false to disable)
|
||||||
|
// - Sonarr__Host: your_sonarr_host_url
|
||||||
|
// - Sonarr__ApiKey: your_sonarr_api_key
|
||||||
|
"Enabled": false,
|
||||||
|
"Host": "your_sonarr_host_url",
|
||||||
|
"ApiKey": "your_sonarr_api_key"
|
||||||
|
},
|
||||||
|
"Lidarr": {
|
||||||
|
// Docker Environment Variables:
|
||||||
|
// - Lidarr__Enabled: true (set to false to disable)
|
||||||
|
// - Lidarr__Host: your_lidarr_host_url
|
||||||
|
// - Lidarr__ApiKey: your_lidarr_api_key
|
||||||
|
"Enabled": false,
|
||||||
|
"Host": "your_lidarr_host_url",
|
||||||
|
"ApiKey": "your_lidarr_api_key"
|
||||||
|
},
|
||||||
|
"Readarr": {
|
||||||
|
// Docker Environment Variables:
|
||||||
|
// - Readarr__Enabled: true (set to false to disable)
|
||||||
|
// - Readarr__Host: your_readarr_host_url
|
||||||
|
// - Readarr__ApiKey: your_readarr_api_key
|
||||||
|
"Enabled": false,
|
||||||
|
"Host": "your_readarr_host_url",
|
||||||
|
"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
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,11 +0,0 @@
|
|||||||
{
|
|
||||||
"SONARR_ENABLED": false,
|
|
||||||
"SONARR_HOST": "http://localhost:8989",
|
|
||||||
"SONARR_API_KEY": "",
|
|
||||||
"LIDARR_ENABLED": false,
|
|
||||||
"LIDARR_HOST": "http://localhost:8686",
|
|
||||||
"LIDARR_API_KEY": "",
|
|
||||||
"READARR_ENABLED": false,
|
|
||||||
"READARR_HOST": "http://localhost:8787",
|
|
||||||
"READARR_API_KEY": ""
|
|
||||||
}
|
|
||||||
@@ -8,17 +8,20 @@ services:
|
|||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
environment:
|
environment:
|
||||||
- TZ=Europe/Berlin
|
- TZ=Europe/Berlin
|
||||||
- SONARR_ENABLED=false
|
- SONARR__ENABLED=false
|
||||||
- SONARR_HOST=http://localhost:8989
|
- SONARR__HOST=http://localhost:8989
|
||||||
- SONARR_API_KEY=API_KEY
|
- SONARR__APIKEY=APIKEY
|
||||||
- RADARR_ENABLED=false
|
- RADARR__ENABLED=false
|
||||||
- RADARR_HOST=http://localhost:7878
|
- RADARR__HOST=http://localhost:7878
|
||||||
- RADARR_API_KEY=API_KEY
|
- RADARR__APIKEY=APIKEY
|
||||||
- READARR_ENABLED=false
|
- READARR__ENABLED=false
|
||||||
- READARR_HOST=http://localhost:8787
|
- READARR__HOST=http://localhost:8787
|
||||||
- READARR_API_KEY=API_KEY
|
- READARR__APIKEY=APIKEY
|
||||||
- LIDARR_ENABLED=false
|
- LIDARR__ENABLED=false
|
||||||
- LIDARR_HOST=http://localhost:8686
|
- LIDARR__HOST=http://localhost:8686
|
||||||
- LIDARR_API_KEY=API_KEY
|
- LIDARR__APIKEY=APIKEY
|
||||||
ports:
|
#- Proxy__Enabled: false
|
||||||
- "5005":"5005"
|
#- 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)
|
||||||
Reference in New Issue
Block a user