Compare commits
No commits in common. "2d848843d071198a0eea899dda17484c4b72206f" and "001a37b8eff5ebaf46d1ea00fd0e3e532a6ee7f1" have entirely different histories.
2d848843d0
...
001a37b8ef
@ -47,16 +47,37 @@ internal sealed class TrangaCli : Command<TrangaCli.Settings>
|
|||||||
string? logFolderPath = settings.fileLoggerPath ?? "";
|
string? logFolderPath = settings.fileLoggerPath ?? "";
|
||||||
Logger logger = new(enabledLoggers.ToArray(), Console.Out, Console.OutputEncoding, logFolderPath);
|
Logger logger = new(enabledLoggers.ToArray(), Console.Out, Console.OutputEncoding, logFolderPath);
|
||||||
|
|
||||||
if(settings.workingDirectory is not null)
|
TrangaSettings? trangaSettings = null;
|
||||||
TrangaSettings.LoadFromWorkingDirectory(settings.workingDirectory);
|
|
||||||
if(settings.downloadLocation is not null)
|
if (settings.downloadLocation is not null && settings.workingDirectory is not null)
|
||||||
TrangaSettings.CreateOrUpdate(downloadDirectory: settings.downloadLocation);
|
{
|
||||||
|
trangaSettings = new TrangaSettings(settings.downloadLocation, settings.workingDirectory);
|
||||||
|
}else if (settings.downloadLocation is not null)
|
||||||
|
{
|
||||||
|
if (trangaSettings is null)
|
||||||
|
trangaSettings = new TrangaSettings(downloadLocation: settings.downloadLocation);
|
||||||
|
else
|
||||||
|
trangaSettings = new TrangaSettings(downloadLocation: settings.downloadLocation, settings.workingDirectory);
|
||||||
|
}else if (settings.workingDirectory is not null)
|
||||||
|
{
|
||||||
|
if (trangaSettings is null)
|
||||||
|
trangaSettings = new TrangaSettings(downloadLocation: settings.workingDirectory);
|
||||||
|
else
|
||||||
|
trangaSettings = new TrangaSettings(settings.downloadLocation, settings.workingDirectory);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
trangaSettings = new TrangaSettings();
|
||||||
|
}
|
||||||
|
|
||||||
|
Directory.CreateDirectory(trangaSettings.downloadLocation);
|
||||||
|
Directory.CreateDirectory(trangaSettings.workingDirectory);
|
||||||
|
|
||||||
Tranga.Tranga? api = null;
|
Tranga.Tranga? api = null;
|
||||||
|
|
||||||
Thread trangaApi = new Thread(() =>
|
Thread trangaApi = new Thread(() =>
|
||||||
{
|
{
|
||||||
api = new(logger);
|
api = new(logger, trangaSettings);
|
||||||
});
|
});
|
||||||
trangaApi.Start();
|
trangaApi.Start();
|
||||||
|
|
||||||
@ -99,7 +120,7 @@ internal sealed class TrangaCli : Command<TrangaCli.Settings>
|
|||||||
parameters.Add(new ValueTuple<string, string>(name, value));
|
parameters.Add(new ValueTuple<string, string>(name, value));
|
||||||
}
|
}
|
||||||
|
|
||||||
string requestString = $"http://localhost:{TrangaSettings.apiPortNumber}/{requestPath}";
|
string requestString = $"http://localhost:{trangaSettings.apiPortNumber}/{requestPath}";
|
||||||
if (parameters.Any())
|
if (parameters.Any())
|
||||||
{
|
{
|
||||||
requestString += "?";
|
requestString += "?";
|
||||||
|
@ -87,15 +87,15 @@ public readonly struct Chapter : IComparable
|
|||||||
/// Checks if a chapter-archive is already present
|
/// Checks if a chapter-archive is already present
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <returns>true if chapter is present</returns>
|
/// <returns>true if chapter is present</returns>
|
||||||
internal bool CheckChapterIsDownloaded()
|
internal bool CheckChapterIsDownloaded(string downloadLocation)
|
||||||
{
|
{
|
||||||
if (!Directory.Exists(Path.Join(TrangaSettings.downloadLocation, parentManga.folderName)))
|
if (!Directory.Exists(Path.Join(downloadLocation, parentManga.folderName)))
|
||||||
return false;
|
return false;
|
||||||
FileInfo[] archives = new DirectoryInfo(Path.Join(TrangaSettings.downloadLocation, parentManga.folderName)).GetFiles().Where(file => file.Name.Split('.')[^1] == "cbz").ToArray();
|
FileInfo[] archives = new DirectoryInfo(Path.Join(downloadLocation, parentManga.folderName)).GetFiles().Where(file => file.Name.Split('.')[^1] == "cbz").ToArray();
|
||||||
Regex volChRex = new(@"(?:Vol(?:ume)?\.([0-9]+)\D*)?Ch(?:apter)?\.([0-9]+(?:\.[0-9]+)*)");
|
Regex volChRex = new(@"(?:Vol(?:ume)?\.([0-9]+)\D*)?Ch(?:apter)?\.([0-9]+(?:\.[0-9]+)*)");
|
||||||
|
|
||||||
Chapter t = this;
|
Chapter t = this;
|
||||||
string thisPath = GetArchiveFilePath();
|
string thisPath = GetArchiveFilePath(downloadLocation);
|
||||||
FileInfo? archive = archives.FirstOrDefault(archive =>
|
FileInfo? archive = archives.FirstOrDefault(archive =>
|
||||||
{
|
{
|
||||||
Match m = volChRex.Match(archive.Name);
|
Match m = volChRex.Match(archive.Name);
|
||||||
@ -112,9 +112,9 @@ public readonly struct Chapter : IComparable
|
|||||||
/// Creates full file path of chapter-archive
|
/// Creates full file path of chapter-archive
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <returns>Filepath</returns>
|
/// <returns>Filepath</returns>
|
||||||
internal string GetArchiveFilePath()
|
internal string GetArchiveFilePath(string downloadLocation)
|
||||||
{
|
{
|
||||||
return Path.Join(TrangaSettings.downloadLocation, parentManga.folderName, $"{parentManga.folderName} - {this.fileName}.cbz");
|
return Path.Join(downloadLocation, parentManga.folderName, $"{parentManga.folderName} - {this.fileName}.cbz");
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
@ -11,6 +11,7 @@ public abstract class GlobalBase
|
|||||||
{
|
{
|
||||||
[JsonIgnore]
|
[JsonIgnore]
|
||||||
public Logger? logger { get; init; }
|
public Logger? logger { get; init; }
|
||||||
|
protected TrangaSettings settings { get; init; }
|
||||||
protected HashSet<NotificationConnector> notificationConnectors { get; init; }
|
protected HashSet<NotificationConnector> notificationConnectors { get; init; }
|
||||||
protected HashSet<LibraryConnector> libraryConnectors { get; init; }
|
protected HashSet<LibraryConnector> libraryConnectors { get; init; }
|
||||||
private Dictionary<string, Manga> cachedPublications { get; init; }
|
private Dictionary<string, Manga> cachedPublications { get; init; }
|
||||||
@ -20,16 +21,18 @@ public abstract class GlobalBase
|
|||||||
protected GlobalBase(GlobalBase clone)
|
protected GlobalBase(GlobalBase clone)
|
||||||
{
|
{
|
||||||
this.logger = clone.logger;
|
this.logger = clone.logger;
|
||||||
|
this.settings = clone.settings;
|
||||||
this.notificationConnectors = clone.notificationConnectors;
|
this.notificationConnectors = clone.notificationConnectors;
|
||||||
this.libraryConnectors = clone.libraryConnectors;
|
this.libraryConnectors = clone.libraryConnectors;
|
||||||
this.cachedPublications = clone.cachedPublications;
|
this.cachedPublications = clone.cachedPublications;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected GlobalBase(Logger? logger)
|
protected GlobalBase(Logger? logger, TrangaSettings settings)
|
||||||
{
|
{
|
||||||
this.logger = logger;
|
this.logger = logger;
|
||||||
this.notificationConnectors = TrangaSettings.LoadNotificationConnectors(this);
|
this.settings = settings;
|
||||||
this.libraryConnectors = TrangaSettings.LoadLibraryConnectors(this);
|
this.notificationConnectors = settings.LoadNotificationConnectors(this);
|
||||||
|
this.libraryConnectors = settings.LoadLibraryConnectors(this);
|
||||||
this.cachedPublications = new();
|
this.cachedPublications = new();
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -78,20 +81,20 @@ public abstract class GlobalBase
|
|||||||
notificationConnectors.RemoveWhere(nc => nc.notificationConnectorType == notificationConnector.notificationConnectorType);
|
notificationConnectors.RemoveWhere(nc => nc.notificationConnectorType == notificationConnector.notificationConnectorType);
|
||||||
notificationConnectors.Add(notificationConnector);
|
notificationConnectors.Add(notificationConnector);
|
||||||
|
|
||||||
while(IsFileInUse(TrangaSettings.notificationConnectorsFilePath))
|
while(IsFileInUse(settings.notificationConnectorsFilePath))
|
||||||
Thread.Sleep(100);
|
Thread.Sleep(100);
|
||||||
Log("Exporting notificationConnectors");
|
Log("Exporting notificationConnectors");
|
||||||
File.WriteAllText(TrangaSettings.notificationConnectorsFilePath, JsonConvert.SerializeObject(notificationConnectors));
|
File.WriteAllText(settings.notificationConnectorsFilePath, JsonConvert.SerializeObject(notificationConnectors));
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void DeleteNotificationConnector(NotificationConnector.NotificationConnectorType notificationConnectorType)
|
protected void DeleteNotificationConnector(NotificationConnector.NotificationConnectorType notificationConnectorType)
|
||||||
{
|
{
|
||||||
Log($"Removing {notificationConnectorType}");
|
Log($"Removing {notificationConnectorType}");
|
||||||
notificationConnectors.RemoveWhere(nc => nc.notificationConnectorType == notificationConnectorType);
|
notificationConnectors.RemoveWhere(nc => nc.notificationConnectorType == notificationConnectorType);
|
||||||
while(IsFileInUse(TrangaSettings.notificationConnectorsFilePath))
|
while(IsFileInUse(settings.notificationConnectorsFilePath))
|
||||||
Thread.Sleep(100);
|
Thread.Sleep(100);
|
||||||
Log("Exporting notificationConnectors");
|
Log("Exporting notificationConnectors");
|
||||||
File.WriteAllText(TrangaSettings.notificationConnectorsFilePath, JsonConvert.SerializeObject(notificationConnectors));
|
File.WriteAllText(settings.notificationConnectorsFilePath, JsonConvert.SerializeObject(notificationConnectors));
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void UpdateLibraries()
|
protected void UpdateLibraries()
|
||||||
@ -106,20 +109,20 @@ public abstract class GlobalBase
|
|||||||
libraryConnectors.RemoveWhere(lc => lc.libraryType == libraryConnector.libraryType);
|
libraryConnectors.RemoveWhere(lc => lc.libraryType == libraryConnector.libraryType);
|
||||||
libraryConnectors.Add(libraryConnector);
|
libraryConnectors.Add(libraryConnector);
|
||||||
|
|
||||||
while(IsFileInUse(TrangaSettings.libraryConnectorsFilePath))
|
while(IsFileInUse(settings.libraryConnectorsFilePath))
|
||||||
Thread.Sleep(100);
|
Thread.Sleep(100);
|
||||||
Log("Exporting libraryConnectors");
|
Log("Exporting libraryConnectors");
|
||||||
File.WriteAllText(TrangaSettings.libraryConnectorsFilePath, JsonConvert.SerializeObject(libraryConnectors, Formatting.Indented));
|
File.WriteAllText(settings.libraryConnectorsFilePath, JsonConvert.SerializeObject(libraryConnectors, Formatting.Indented));
|
||||||
}
|
}
|
||||||
|
|
||||||
protected void DeleteLibraryConnector(LibraryConnector.LibraryType libraryType)
|
protected void DeleteLibraryConnector(LibraryConnector.LibraryType libraryType)
|
||||||
{
|
{
|
||||||
Log($"Removing {libraryType}");
|
Log($"Removing {libraryType}");
|
||||||
libraryConnectors.RemoveWhere(lc => lc.libraryType == libraryType);
|
libraryConnectors.RemoveWhere(lc => lc.libraryType == libraryType);
|
||||||
while(IsFileInUse(TrangaSettings.libraryConnectorsFilePath))
|
while(IsFileInUse(settings.libraryConnectorsFilePath))
|
||||||
Thread.Sleep(100);
|
Thread.Sleep(100);
|
||||||
Log("Exporting libraryConnectors");
|
Log("Exporting libraryConnectors");
|
||||||
File.WriteAllText(TrangaSettings.libraryConnectorsFilePath, JsonConvert.SerializeObject(libraryConnectors, Formatting.Indented));
|
File.WriteAllText(settings.libraryConnectorsFilePath, JsonConvert.SerializeObject(libraryConnectors, Formatting.Indented));
|
||||||
}
|
}
|
||||||
|
|
||||||
protected bool IsFileInUse(string filePath) => IsFileInUse(filePath, this.logger);
|
protected bool IsFileInUse(string filePath) => IsFileInUse(filePath, this.logger);
|
||||||
|
@ -33,7 +33,7 @@ public class DownloadNewChapters : Job
|
|||||||
|
|
||||||
protected override IEnumerable<Job> ExecuteReturnSubTasksInternal(JobBoss jobBoss)
|
protected override IEnumerable<Job> ExecuteReturnSubTasksInternal(JobBoss jobBoss)
|
||||||
{
|
{
|
||||||
manga.SaveSeriesInfoJson();
|
manga.SaveSeriesInfoJson(settings.downloadLocation);
|
||||||
Chapter[] chapters = mangaConnector.GetNewChapters(manga, this.translatedLanguage);
|
Chapter[] chapters = mangaConnector.GetNewChapters(manga, this.translatedLanguage);
|
||||||
this.progressToken.increments = chapters.Length;
|
this.progressToken.increments = chapters.Length;
|
||||||
List<Job> jobs = new();
|
List<Job> jobs = new();
|
||||||
|
@ -140,15 +140,15 @@ public class JobBoss : GlobalBase
|
|||||||
|
|
||||||
private void LoadJobsList(HashSet<MangaConnector> connectors)
|
private void LoadJobsList(HashSet<MangaConnector> connectors)
|
||||||
{
|
{
|
||||||
if (!Directory.Exists(TrangaSettings.jobsFolderPath)) //No jobs to load
|
if (!Directory.Exists(settings.jobsFolderPath)) //No jobs to load
|
||||||
{
|
{
|
||||||
Directory.CreateDirectory(TrangaSettings.jobsFolderPath);
|
Directory.CreateDirectory(settings.jobsFolderPath);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
Regex idRex = new (@"(.*)\.json");
|
Regex idRex = new (@"(.*)\.json");
|
||||||
|
|
||||||
//Load json-job-files
|
//Load json-job-files
|
||||||
foreach (FileInfo file in new DirectoryInfo(TrangaSettings.jobsFolderPath).EnumerateFiles().Where(fileInfo => idRex.IsMatch(fileInfo.Name)))
|
foreach (FileInfo file in new DirectoryInfo(settings.jobsFolderPath).EnumerateFiles().Where(fileInfo => idRex.IsMatch(fileInfo.Name)))
|
||||||
{
|
{
|
||||||
Log($"Adding {file.Name}");
|
Log($"Adding {file.Name}");
|
||||||
Job? job = JsonConvert.DeserializeObject<Job>(File.ReadAllText(file.FullName),
|
Job? job = JsonConvert.DeserializeObject<Job>(File.ReadAllText(file.FullName),
|
||||||
@ -180,14 +180,14 @@ public class JobBoss : GlobalBase
|
|||||||
AddMangaToCache(dncJob.manga);
|
AddMangaToCache(dncJob.manga);
|
||||||
}
|
}
|
||||||
|
|
||||||
string[] coverFiles = Directory.GetFiles(TrangaSettings.coverImageCache);
|
string[] coverFiles = Directory.GetFiles(settings.coverImageCache);
|
||||||
foreach(string fileName in coverFiles.Where(fileName => !GetAllCachedManga().Any(manga => manga.coverFileNameInCache == fileName)))
|
foreach(string fileName in coverFiles.Where(fileName => !GetAllCachedManga().Any(manga => manga.coverFileNameInCache == fileName)))
|
||||||
File.Delete(fileName);
|
File.Delete(fileName);
|
||||||
}
|
}
|
||||||
|
|
||||||
internal void UpdateJobFile(Job job, string? oldFile = null)
|
internal void UpdateJobFile(Job job, string? oldFile = null)
|
||||||
{
|
{
|
||||||
string newJobFilePath = Path.Join(TrangaSettings.jobsFolderPath, $"{job.id}.json");
|
string newJobFilePath = Path.Join(settings.jobsFolderPath, $"{job.id}.json");
|
||||||
|
|
||||||
if (!this.jobs.Any(jjob => jjob.id == job.id))
|
if (!this.jobs.Any(jjob => jjob.id == job.id))
|
||||||
{
|
{
|
||||||
@ -234,7 +234,7 @@ public class JobBoss : GlobalBase
|
|||||||
|
|
||||||
//Remove files with jobs not in this.jobs-list
|
//Remove files with jobs not in this.jobs-list
|
||||||
Regex idRex = new (@"(.*)\.json");
|
Regex idRex = new (@"(.*)\.json");
|
||||||
foreach (FileInfo file in new DirectoryInfo(TrangaSettings.jobsFolderPath).EnumerateFiles())
|
foreach (FileInfo file in new DirectoryInfo(settings.jobsFolderPath).EnumerateFiles())
|
||||||
{
|
{
|
||||||
if (idRex.IsMatch(file.Name))
|
if (idRex.IsMatch(file.Name))
|
||||||
{
|
{
|
||||||
|
@ -34,7 +34,7 @@ public class UpdateMetadata : Job
|
|||||||
}
|
}
|
||||||
|
|
||||||
this.manga = manga.WithMetadata(updatedManga);
|
this.manga = manga.WithMetadata(updatedManga);
|
||||||
this.manga.SaveSeriesInfoJson(true);
|
this.manga.SaveSeriesInfoJson(settings.downloadLocation, true);
|
||||||
this.mangaConnector.CopyCoverFromCacheToDownloadLocation(manga);
|
this.mangaConnector.CopyCoverFromCacheToDownloadLocation(manga);
|
||||||
foreach (Job job in jobBoss.GetJobsLike(publication: this.manga))
|
foreach (Job job in jobBoss.GetJobsLike(publication: this.manga))
|
||||||
{
|
{
|
||||||
|
@ -140,9 +140,9 @@ public struct Manga
|
|||||||
latestChapterDownloaded = latestChapterDownloaded < chapterNumber ? chapterNumber : latestChapterDownloaded;
|
latestChapterDownloaded = latestChapterDownloaded < chapterNumber ? chapterNumber : latestChapterDownloaded;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void SaveSeriesInfoJson(bool overwrite = false)
|
public void SaveSeriesInfoJson(string downloadDirectory, bool overwrite = false)
|
||||||
{
|
{
|
||||||
string publicationFolder = CreatePublicationFolder(TrangaSettings.downloadLocation);
|
string publicationFolder = CreatePublicationFolder(downloadDirectory);
|
||||||
string seriesInfoPath = Path.Join(publicationFolder, "series.json");
|
string seriesInfoPath = Path.Join(publicationFolder, "series.json");
|
||||||
if(overwrite || (!overwrite && !File.Exists(seriesInfoPath)))
|
if(overwrite || (!overwrite && !File.Exists(seriesInfoPath)))
|
||||||
File.WriteAllText(seriesInfoPath,this.GetSeriesInfoJson());
|
File.WriteAllText(seriesInfoPath,this.GetSeriesInfoJson());
|
||||||
|
@ -193,7 +193,7 @@ public class Bato : MangaConnector
|
|||||||
string comicInfoPath = Path.GetTempFileName();
|
string comicInfoPath = Path.GetTempFileName();
|
||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, "https://mangakatana.com/", progressToken:progressToken);
|
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, "https://mangakatana.com/", progressToken:progressToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
private string[] ParseImageUrlsFromHtml(string mangaUrl)
|
private string[] ParseImageUrlsFromHtml(string mangaUrl)
|
||||||
|
@ -14,15 +14,15 @@ internal abstract class DownloadClient : GlobalBase
|
|||||||
|
|
||||||
public RequestResult MakeRequest(string url, RequestType requestType, string? referrer = null, string? clickButton = null)
|
public RequestResult MakeRequest(string url, RequestType requestType, string? referrer = null, string? clickButton = null)
|
||||||
{
|
{
|
||||||
if (!TrangaSettings.requestLimits.ContainsKey(requestType))
|
if (!settings.requestLimits.ContainsKey(requestType))
|
||||||
{
|
{
|
||||||
Log("RequestType not configured for rate-limit.");
|
Log("RequestType not configured for rate-limit.");
|
||||||
return new RequestResult(HttpStatusCode.NotAcceptable, null, Stream.Null);
|
return new RequestResult(HttpStatusCode.NotAcceptable, null, Stream.Null);
|
||||||
}
|
}
|
||||||
|
|
||||||
int rateLimit = TrangaSettings.userAgent == TrangaSettings.DefaultUserAgent
|
int rateLimit = settings.userAgent == TrangaSettings.DefaultUserAgent
|
||||||
? TrangaSettings.DefaultRequestLimits[requestType]
|
? TrangaSettings.DefaultRequestLimits[requestType]
|
||||||
: TrangaSettings.requestLimits[requestType];
|
: settings.requestLimits[requestType];
|
||||||
|
|
||||||
TimeSpan timeBetweenRequests = TimeSpan.FromMinutes(1).Divide(rateLimit);
|
TimeSpan timeBetweenRequests = TimeSpan.FromMinutes(1).Divide(rateLimit);
|
||||||
_lastExecutedRateLimit.TryAdd(requestType, DateTime.Now.Subtract(timeBetweenRequests));
|
_lastExecutedRateLimit.TryAdd(requestType, DateTime.Now.Subtract(timeBetweenRequests));
|
||||||
|
@ -13,7 +13,7 @@ internal class HttpDownloadClient : DownloadClient
|
|||||||
|
|
||||||
public HttpDownloadClient(GlobalBase clone) : base(clone)
|
public HttpDownloadClient(GlobalBase clone) : base(clone)
|
||||||
{
|
{
|
||||||
Client.DefaultRequestHeaders.TryAddWithoutValidation("User-Agent", TrangaSettings.userAgent);
|
Client.DefaultRequestHeaders.TryAddWithoutValidation("User-Agent", settings.userAgent);
|
||||||
}
|
}
|
||||||
|
|
||||||
internal override RequestResult MakeRequestInternal(string url, string? referrer = null, string? clickButton = null)
|
internal override RequestResult MakeRequestInternal(string url, string? referrer = null, string? clickButton = null)
|
||||||
|
@ -23,7 +23,7 @@ public abstract class MangaConnector : GlobalBase
|
|||||||
protected MangaConnector(GlobalBase clone, string name) : base(clone)
|
protected MangaConnector(GlobalBase clone, string name) : base(clone)
|
||||||
{
|
{
|
||||||
this.name = name;
|
this.name = name;
|
||||||
Directory.CreateDirectory(TrangaSettings.coverImageCache);
|
Directory.CreateDirectory(settings.coverImageCache);
|
||||||
}
|
}
|
||||||
|
|
||||||
public string name { get; } //Name of the Connector (e.g. Website)
|
public string name { get; } //Name of the Connector (e.g. Website)
|
||||||
@ -65,7 +65,7 @@ public abstract class MangaConnector : GlobalBase
|
|||||||
Log($"Checking for duplicates {manga}");
|
Log($"Checking for duplicates {manga}");
|
||||||
List<Chapter> newChaptersList = allChapters.Where(nChapter => float.TryParse(nChapter.chapterNumber, numberFormatDecimalPoint, out float chapterNumber)
|
List<Chapter> newChaptersList = allChapters.Where(nChapter => float.TryParse(nChapter.chapterNumber, numberFormatDecimalPoint, out float chapterNumber)
|
||||||
&& chapterNumber > manga.ignoreChaptersBelow
|
&& chapterNumber > manga.ignoreChaptersBelow
|
||||||
&& !nChapter.CheckChapterIsDownloaded()).ToList();
|
&& !nChapter.CheckChapterIsDownloaded(settings.downloadLocation)).ToList();
|
||||||
Log($"{newChaptersList.Count} new chapters. {manga}");
|
Log($"{newChaptersList.Count} new chapters. {manga}");
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
@ -167,7 +167,7 @@ public abstract class MangaConnector : GlobalBase
|
|||||||
{
|
{
|
||||||
Log($"Copy cover {manga}");
|
Log($"Copy cover {manga}");
|
||||||
//Check if Publication already has a Folder and cover
|
//Check if Publication already has a Folder and cover
|
||||||
string publicationFolder = manga.CreatePublicationFolder(TrangaSettings.downloadLocation);
|
string publicationFolder = manga.CreatePublicationFolder(settings.downloadLocation);
|
||||||
DirectoryInfo dirInfo = new (publicationFolder);
|
DirectoryInfo dirInfo = new (publicationFolder);
|
||||||
if (dirInfo.EnumerateFiles().Any(info => info.Name.Contains("cover", StringComparison.InvariantCultureIgnoreCase)))
|
if (dirInfo.EnumerateFiles().Any(info => info.Name.Contains("cover", StringComparison.InvariantCultureIgnoreCase)))
|
||||||
{
|
{
|
||||||
@ -291,7 +291,7 @@ public abstract class MangaConnector : GlobalBase
|
|||||||
//https?:\/\/[a-zA-Z0-9-]+\.([a-zA-Z0-9-]+\.[a-zA-Z0-9]+)\/(?:.+\/)*(.+\.([a-zA-Z]+)) for only second level domains
|
//https?:\/\/[a-zA-Z0-9-]+\.([a-zA-Z0-9-]+\.[a-zA-Z0-9]+)\/(?:.+\/)*(.+\.([a-zA-Z]+)) for only second level domains
|
||||||
Match match = urlRex.Match(url);
|
Match match = urlRex.Match(url);
|
||||||
string filename = $"{match.Groups[1].Value}-{mangaInternalId}.{match.Groups[3].Value}";
|
string filename = $"{match.Groups[1].Value}-{mangaInternalId}.{match.Groups[3].Value}";
|
||||||
string saveImagePath = Path.Join(TrangaSettings.coverImageCache, filename);
|
string saveImagePath = Path.Join(settings.coverImageCache, filename);
|
||||||
|
|
||||||
if (File.Exists(saveImagePath))
|
if (File.Exists(saveImagePath))
|
||||||
return saveImagePath;
|
return saveImagePath;
|
||||||
@ -299,7 +299,7 @@ public abstract class MangaConnector : GlobalBase
|
|||||||
RequestResult coverResult = downloadClient.MakeRequest(url, requestType);
|
RequestResult coverResult = downloadClient.MakeRequest(url, requestType);
|
||||||
using MemoryStream ms = new();
|
using MemoryStream ms = new();
|
||||||
coverResult.result.CopyTo(ms);
|
coverResult.result.CopyTo(ms);
|
||||||
Directory.CreateDirectory(TrangaSettings.coverImageCache);
|
Directory.CreateDirectory(settings.coverImageCache);
|
||||||
File.WriteAllBytes(saveImagePath, ms.ToArray());
|
File.WriteAllBytes(saveImagePath, ms.ToArray());
|
||||||
Log($"Saving cover to {saveImagePath}");
|
Log($"Saving cover to {saveImagePath}");
|
||||||
return saveImagePath;
|
return saveImagePath;
|
||||||
|
@ -290,6 +290,6 @@ public class MangaDex : MangaConnector
|
|||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
//Download Chapter-Images
|
//Download Chapter-Images
|
||||||
return DownloadChapterImages(imageUrls.ToArray(), chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
return DownloadChapterImages(imageUrls.ToArray(), chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -186,7 +186,7 @@ public class MangaHere : MangaConnector
|
|||||||
|
|
||||||
if (progressToken is not null)
|
if (progressToken is not null)
|
||||||
progressToken.increments = images;//we blip to normal length, in downloadchapterimages it is increasaed by the amount of urls again
|
progressToken.increments = images;//we blip to normal length, in downloadchapterimages it is increasaed by the amount of urls again
|
||||||
return DownloadChapterImages(imageUrls.ToArray(), chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
return DownloadChapterImages(imageUrls.ToArray(), chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
private string[] ParseImageUrlsFromHtml(HtmlDocument document)
|
private string[] ParseImageUrlsFromHtml(HtmlDocument document)
|
||||||
|
@ -217,7 +217,7 @@ public class MangaKatana : MangaConnector
|
|||||||
string comicInfoPath = Path.GetTempFileName();
|
string comicInfoPath = Path.GetTempFileName();
|
||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, "https://mangakatana.com/", progressToken:progressToken);
|
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, "https://mangakatana.com/", progressToken:progressToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
private string[] ParseImageUrlsFromHtml(string mangaUrl)
|
private string[] ParseImageUrlsFromHtml(string mangaUrl)
|
||||||
|
@ -194,6 +194,6 @@ public class MangaLife : MangaConnector
|
|||||||
string comicInfoPath = Path.GetTempFileName();
|
string comicInfoPath = Path.GetTempFileName();
|
||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
return DownloadChapterImages(urls.ToArray(), chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
return DownloadChapterImages(urls.ToArray(), chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -209,7 +209,7 @@ public class Manganato : MangaConnector
|
|||||||
string comicInfoPath = Path.GetTempFileName();
|
string comicInfoPath = Path.GetTempFileName();
|
||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, "https://chapmanganato.com/", progressToken:progressToken);
|
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, "https://chapmanganato.com/", progressToken:progressToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
private string[] ParseImageUrlsFromHtml(HtmlDocument document)
|
private string[] ParseImageUrlsFromHtml(HtmlDocument document)
|
||||||
|
@ -225,6 +225,6 @@ public class Mangasee : MangaConnector
|
|||||||
string comicInfoPath = Path.GetTempFileName();
|
string comicInfoPath = Path.GetTempFileName();
|
||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
return DownloadChapterImages(urls.ToArray(), chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
return DownloadChapterImages(urls.ToArray(), chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -209,7 +209,7 @@ public class Mangaworld: MangaConnector
|
|||||||
string comicInfoPath = Path.GetTempFileName();
|
string comicInfoPath = Path.GetTempFileName();
|
||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, "https://www.mangaworld.bz/", progressToken:progressToken);
|
return DownloadChapterImages(imageUrls, chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, "https://www.mangaworld.bz/", progressToken:progressToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
private string[] ParseImageUrlsFromHtml(HtmlDocument document)
|
private string[] ParseImageUrlsFromHtml(HtmlDocument document)
|
||||||
|
@ -179,6 +179,6 @@ public class ManhuaPlus : MangaConnector
|
|||||||
string comicInfoPath = Path.GetTempFileName();
|
string comicInfoPath = Path.GetTempFileName();
|
||||||
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
File.WriteAllText(comicInfoPath, chapter.GetComicInfoXmlString());
|
||||||
|
|
||||||
return DownloadChapterImages(urls.ToArray(), chapter.GetArchiveFilePath(), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
return DownloadChapterImages(urls.ToArray(), chapter.GetArchiveFilePath(settings.downloadLocation), RequestType.MangaImage, comicInfoPath, progressToken:progressToken);
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -19,9 +19,9 @@ public class Server : GlobalBase
|
|||||||
{
|
{
|
||||||
this._parent = parent;
|
this._parent = parent;
|
||||||
if(RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
if(RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
||||||
this._listener.Prefixes.Add($"http://*:{TrangaSettings.apiPortNumber}/");
|
this._listener.Prefixes.Add($"http://*:{settings.apiPortNumber}/");
|
||||||
else
|
else
|
||||||
this._listener.Prefixes.Add($"http://localhost:{TrangaSettings.apiPortNumber}/");
|
this._listener.Prefixes.Add($"http://localhost:{settings.apiPortNumber}/");
|
||||||
Thread listenThread = new (Listen);
|
Thread listenThread = new (Listen);
|
||||||
listenThread.Start();
|
listenThread.Start();
|
||||||
Thread watchThread = new(WatchRunning);
|
Thread watchThread = new(WatchRunning);
|
||||||
@ -198,16 +198,16 @@ public class Server : GlobalBase
|
|||||||
SendResponse(HttpStatusCode.OK, response, _parent.jobBoss.jobs.Where(jjob => jjob is DownloadNewChapters).OrderBy(jjob => ((DownloadNewChapters)jjob).manga.sortName));
|
SendResponse(HttpStatusCode.OK, response, _parent.jobBoss.jobs.Where(jjob => jjob is DownloadNewChapters).OrderBy(jjob => ((DownloadNewChapters)jjob).manga.sortName));
|
||||||
break;
|
break;
|
||||||
case "Settings":
|
case "Settings":
|
||||||
SendResponse(HttpStatusCode.OK, response, TrangaSettings.Serialize());
|
SendResponse(HttpStatusCode.OK, response, settings);
|
||||||
break;
|
break;
|
||||||
case "Settings/userAgent":
|
case "Settings/userAgent":
|
||||||
SendResponse(HttpStatusCode.OK, response, TrangaSettings.userAgent);
|
SendResponse(HttpStatusCode.OK, response, settings.userAgent);
|
||||||
break;
|
break;
|
||||||
case "Settings/customRequestLimit":
|
case "Settings/customRequestLimit":
|
||||||
SendResponse(HttpStatusCode.OK, response, TrangaSettings.requestLimits);
|
SendResponse(HttpStatusCode.OK, response, settings.requestLimits);
|
||||||
break;
|
break;
|
||||||
case "Settings/AprilFoolsMode":
|
case "Settings/AprilFoolsMode":
|
||||||
SendResponse(HttpStatusCode.OK, response, TrangaSettings.aprilFoolsMode);
|
SendResponse(HttpStatusCode.OK, response, settings.aprilFoolsMode);
|
||||||
break;
|
break;
|
||||||
case "NotificationConnectors":
|
case "NotificationConnectors":
|
||||||
SendResponse(HttpStatusCode.OK, response, notificationConnectors);
|
SendResponse(HttpStatusCode.OK, response, notificationConnectors);
|
||||||
@ -314,7 +314,7 @@ public class Server : GlobalBase
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (requestVariables.TryGetValue("customFolderName", out customFolderName))
|
if (requestVariables.TryGetValue("customFolderName", out customFolderName))
|
||||||
manga.MovePublicationFolder(TrangaSettings.downloadLocation, customFolderName);
|
manga.MovePublicationFolder(settings.downloadLocation, customFolderName);
|
||||||
requestVariables.TryGetValue("translatedLanguage", out translatedLanguage);
|
requestVariables.TryGetValue("translatedLanguage", out translatedLanguage);
|
||||||
|
|
||||||
_parent.jobBoss.AddJob(new DownloadNewChapters(this, connector!, manga, true, interval, translatedLanguage: translatedLanguage??"en"));
|
_parent.jobBoss.AddJob(new DownloadNewChapters(this, connector!, manga, true, interval, translatedLanguage: translatedLanguage??"en"));
|
||||||
@ -343,7 +343,7 @@ public class Server : GlobalBase
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (requestVariables.TryGetValue("customFolderName", out customFolderName))
|
if (requestVariables.TryGetValue("customFolderName", out customFolderName))
|
||||||
manga.MovePublicationFolder(TrangaSettings.downloadLocation, customFolderName);
|
manga.MovePublicationFolder(settings.downloadLocation, customFolderName);
|
||||||
requestVariables.TryGetValue("translatedLanguage", out translatedLanguage);
|
requestVariables.TryGetValue("translatedLanguage", out translatedLanguage);
|
||||||
|
|
||||||
_parent.jobBoss.AddJob(new DownloadNewChapters(this, connector!, manga, false, translatedLanguage: translatedLanguage??"en"));
|
_parent.jobBoss.AddJob(new DownloadNewChapters(this, connector!, manga, false, translatedLanguage: translatedLanguage??"en"));
|
||||||
@ -405,7 +405,7 @@ public class Server : GlobalBase
|
|||||||
SendResponse(HttpStatusCode.BadRequest, response);
|
SendResponse(HttpStatusCode.BadRequest, response);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
TrangaSettings.UpdateDownloadLocation(downloadLocation, moveFiles);
|
settings.UpdateDownloadLocation(downloadLocation, moveFiles);
|
||||||
SendResponse(HttpStatusCode.Accepted, response);
|
SendResponse(HttpStatusCode.Accepted, response);
|
||||||
break;
|
break;
|
||||||
case "Settings/AprilFoolsMode":
|
case "Settings/AprilFoolsMode":
|
||||||
@ -415,7 +415,7 @@ public class Server : GlobalBase
|
|||||||
SendResponse(HttpStatusCode.BadRequest, response);
|
SendResponse(HttpStatusCode.BadRequest, response);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
TrangaSettings.UpdateAprilFoolsMode(aprilFoolsModeEnabled);
|
settings.UpdateAprilFoolsMode(aprilFoolsModeEnabled);
|
||||||
SendResponse(HttpStatusCode.Accepted, response);
|
SendResponse(HttpStatusCode.Accepted, response);
|
||||||
break;
|
break;
|
||||||
/*case "Settings/UpdateWorkingDirectory":
|
/*case "Settings/UpdateWorkingDirectory":
|
||||||
@ -433,11 +433,11 @@ public class Server : GlobalBase
|
|||||||
SendResponse(HttpStatusCode.BadRequest, response);
|
SendResponse(HttpStatusCode.BadRequest, response);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
TrangaSettings.UpdateUserAgent(customUserAgent);
|
settings.UpdateUserAgent(customUserAgent);
|
||||||
SendResponse(HttpStatusCode.Accepted, response);
|
SendResponse(HttpStatusCode.Accepted, response);
|
||||||
break;
|
break;
|
||||||
case "Settings/userAgent/Reset":
|
case "Settings/userAgent/Reset":
|
||||||
TrangaSettings.UpdateUserAgent(null);
|
settings.UpdateUserAgent(null);
|
||||||
SendResponse(HttpStatusCode.Accepted, response);
|
SendResponse(HttpStatusCode.Accepted, response);
|
||||||
break;
|
break;
|
||||||
case "Settings/customRequestLimit":
|
case "Settings/customRequestLimit":
|
||||||
@ -450,11 +450,17 @@ public class Server : GlobalBase
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
TrangaSettings.UpdateRateLimit(requestType, requestsPerMinute);
|
if (settings.requestLimits.ContainsKey(requestType))
|
||||||
|
{
|
||||||
|
settings.requestLimits[requestType] = requestsPerMinute;
|
||||||
SendResponse(HttpStatusCode.Accepted, response);
|
SendResponse(HttpStatusCode.Accepted, response);
|
||||||
|
}else
|
||||||
|
SendResponse(HttpStatusCode.BadRequest, response);
|
||||||
|
settings.ExportSettings();
|
||||||
break;
|
break;
|
||||||
case "Settings/customRequestLimit/Reset":
|
case "Settings/customRequestLimit/Reset":
|
||||||
TrangaSettings.ResetRateLimits();
|
settings.requestLimits = TrangaSettings.DefaultRequestLimits;
|
||||||
|
settings.ExportSettings();
|
||||||
break;
|
break;
|
||||||
case "NotificationConnectors/Update":
|
case "NotificationConnectors/Update":
|
||||||
if (!requestVariables.TryGetValue("notificationConnector", out notificationConnectorStr) ||
|
if (!requestVariables.TryGetValue("notificationConnector", out notificationConnectorStr) ||
|
||||||
|
@ -11,9 +11,10 @@ public partial class Tranga : GlobalBase
|
|||||||
private Server _server;
|
private Server _server;
|
||||||
private HashSet<MangaConnector> _connectors;
|
private HashSet<MangaConnector> _connectors;
|
||||||
|
|
||||||
public Tranga(Logger? logger) : base(logger)
|
public Tranga(Logger? logger, TrangaSettings settings) : base(logger, settings)
|
||||||
{
|
{
|
||||||
Log("\n\n _______ \n|_ _|.----..---.-..-----..-----..---.-.\n | | | _|| _ || || _ || _ |\n |___| |__| |___._||__|__||___ ||___._|\n |_____| \n\n");
|
Log("\n\n _______ \n|_ _|.----..---.-..-----..-----..---.-.\n | | | _|| _ || || _ || _ |\n |___| |__| |___._||__|__||___ ||___._|\n |_____| \n\n");
|
||||||
|
Log(settings.ToString());
|
||||||
keepRunning = true;
|
keepRunning = true;
|
||||||
_connectors = new HashSet<MangaConnector>()
|
_connectors = new HashSet<MangaConnector>()
|
||||||
{
|
{
|
||||||
@ -69,7 +70,7 @@ public partial class Tranga : GlobalBase
|
|||||||
{
|
{
|
||||||
while (keepRunning)
|
while (keepRunning)
|
||||||
{
|
{
|
||||||
if(!TrangaSettings.aprilFoolsMode || !IsAprilFirst())
|
if(!settings.aprilFoolsMode || !IsAprilFirst())
|
||||||
jobBoss.CheckJobs();
|
jobBoss.CheckJobs();
|
||||||
else
|
else
|
||||||
Log("April Fools Mode in Effect");
|
Log("April Fools Mode in Effect");
|
||||||
|
@ -36,14 +36,34 @@ public partial class Tranga : GlobalBase
|
|||||||
enabledLoggers.Add(Logger.LoggerType.FileLogger);
|
enabledLoggers.Add(Logger.LoggerType.FileLogger);
|
||||||
Logger logger = new(enabledLoggers.ToArray(), Console.Out, Console.OutputEncoding, directoryPath);
|
Logger logger = new(enabledLoggers.ToArray(), Console.Out, Console.OutputEncoding, directoryPath);
|
||||||
|
|
||||||
|
TrangaSettings? settings = null;
|
||||||
bool dlp = fetched.TryGetValue(downloadLocation, out string[]? downloadLocationPath);
|
bool dlp = fetched.TryGetValue(downloadLocation, out string[]? downloadLocationPath);
|
||||||
bool wdp = fetched.TryGetValue(workingDirectory, out string[]? workingDirectoryPath);
|
bool wdp = fetched.TryGetValue(downloadLocation, out string[]? workingDirectoryPath);
|
||||||
|
|
||||||
if (wdp)
|
if (dlp && wdp)
|
||||||
TrangaSettings.LoadFromWorkingDirectory(workingDirectoryPath![0]);
|
{
|
||||||
if(dlp)
|
settings = new TrangaSettings(downloadLocationPath![0], workingDirectoryPath![0]);
|
||||||
TrangaSettings.CreateOrUpdate(downloadDirectory: downloadLocationPath![0]);
|
}else if (dlp)
|
||||||
|
{
|
||||||
|
if (settings is null)
|
||||||
|
settings = new TrangaSettings(downloadLocation: downloadLocationPath![0]);
|
||||||
|
else
|
||||||
|
settings = new TrangaSettings(downloadLocation: downloadLocationPath![0], settings.workingDirectory);
|
||||||
|
}else if (wdp)
|
||||||
|
{
|
||||||
|
if (settings is null)
|
||||||
|
settings = new TrangaSettings(downloadLocation: workingDirectoryPath![0]);
|
||||||
|
else
|
||||||
|
settings = new TrangaSettings(settings.downloadLocation, workingDirectoryPath![0]);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
settings = new TrangaSettings();
|
||||||
|
}
|
||||||
|
|
||||||
Tranga _ = new (logger);
|
Directory.CreateDirectory(settings.downloadLocation);//TODO validate path
|
||||||
|
Directory.CreateDirectory(settings.workingDirectory);//TODO validate path
|
||||||
|
|
||||||
|
Tranga _ = new (logger, settings);
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -1,6 +1,7 @@
|
|||||||
using System.Runtime.InteropServices;
|
using System.Runtime.InteropServices;
|
||||||
|
using System.Text.Json.Nodes;
|
||||||
|
using System.Text.RegularExpressions;
|
||||||
using Newtonsoft.Json;
|
using Newtonsoft.Json;
|
||||||
using Newtonsoft.Json.Linq;
|
|
||||||
using Tranga.LibraryConnectors;
|
using Tranga.LibraryConnectors;
|
||||||
using Tranga.MangaConnectors;
|
using Tranga.MangaConnectors;
|
||||||
using Tranga.NotificationConnectors;
|
using Tranga.NotificationConnectors;
|
||||||
@ -8,20 +9,20 @@ using static System.IO.UnixFileMode;
|
|||||||
|
|
||||||
namespace Tranga;
|
namespace Tranga;
|
||||||
|
|
||||||
public static class TrangaSettings
|
public class TrangaSettings
|
||||||
{
|
{
|
||||||
|
public string downloadLocation { get; private set; }
|
||||||
|
public string workingDirectory { get; private set; }
|
||||||
|
public int apiPortNumber { get; init; }
|
||||||
|
public string userAgent { get; private set; } = DefaultUserAgent;
|
||||||
|
[JsonIgnore] public string settingsFilePath => Path.Join(workingDirectory, "settings.json");
|
||||||
|
[JsonIgnore] public string libraryConnectorsFilePath => Path.Join(workingDirectory, "libraryConnectors.json");
|
||||||
|
[JsonIgnore] public string notificationConnectorsFilePath => Path.Join(workingDirectory, "notificationConnectors.json");
|
||||||
|
[JsonIgnore] public string jobsFolderPath => Path.Join(workingDirectory, "jobs");
|
||||||
|
[JsonIgnore] public string coverImageCache => Path.Join(workingDirectory, "imageCache");
|
||||||
[JsonIgnore] internal static readonly string DefaultUserAgent = $"Tranga ({Enum.GetName(Environment.OSVersion.Platform)}; {(Environment.Is64BitOperatingSystem ? "x64" : "")}) / 1.0";
|
[JsonIgnore] internal static readonly string DefaultUserAgent = $"Tranga ({Enum.GetName(Environment.OSVersion.Platform)}; {(Environment.Is64BitOperatingSystem ? "x64" : "")}) / 1.0";
|
||||||
public static string downloadLocation { get; private set; } = (RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/Manga" : Path.Join(Directory.GetCurrentDirectory(), "Downloads"));
|
public ushort? version { get; } = 2;
|
||||||
public static string workingDirectory { get; private set; } = Path.Join(RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/usr/share" : Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "tranga-api");
|
public bool aprilFoolsMode { get; private set; } = true;
|
||||||
public static int apiPortNumber { get; private set; } = 6531;
|
|
||||||
public static string userAgent { get; private set; } = DefaultUserAgent;
|
|
||||||
[JsonIgnore] public static string settingsFilePath => Path.Join(workingDirectory, "settings.json");
|
|
||||||
[JsonIgnore] public static string libraryConnectorsFilePath => Path.Join(workingDirectory, "libraryConnectors.json");
|
|
||||||
[JsonIgnore] public static string notificationConnectorsFilePath => Path.Join(workingDirectory, "notificationConnectors.json");
|
|
||||||
[JsonIgnore] public static string jobsFolderPath => Path.Join(workingDirectory, "jobs");
|
|
||||||
[JsonIgnore] public static string coverImageCache => Path.Join(workingDirectory, "imageCache");
|
|
||||||
public static ushort? version { get; } = 2;
|
|
||||||
public static bool aprilFoolsMode { get; private set; } = true;
|
|
||||||
[JsonIgnore]internal static readonly Dictionary<RequestType, int> DefaultRequestLimits = new ()
|
[JsonIgnore]internal static readonly Dictionary<RequestType, int> DefaultRequestLimits = new ()
|
||||||
{
|
{
|
||||||
{RequestType.MangaInfo, 250},
|
{RequestType.MangaInfo, 250},
|
||||||
@ -32,38 +33,50 @@ public static class TrangaSettings
|
|||||||
{RequestType.Default, 60}
|
{RequestType.Default, 60}
|
||||||
};
|
};
|
||||||
|
|
||||||
public static Dictionary<RequestType, int> requestLimits { get; set; } = DefaultRequestLimits;
|
public Dictionary<RequestType, int> requestLimits { get; set; } = DefaultRequestLimits;
|
||||||
|
|
||||||
public static void LoadFromWorkingDirectory(string directory)
|
public TrangaSettings(string? downloadLocation = null, string? workingDirectory = null, int? apiPortNumber = null)
|
||||||
{
|
{
|
||||||
TrangaSettings.workingDirectory = directory;
|
string wd = workingDirectory ?? Path.Join(RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/usr/share" : Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "tranga-api");
|
||||||
if (!File.Exists(settingsFilePath))
|
string sfp = Path.Join(wd, "settings.json");
|
||||||
{
|
|
||||||
return;
|
string lockFilePath = $"{sfp}.lock";
|
||||||
|
if (File.Exists(sfp) && !File.Exists(lockFilePath))
|
||||||
|
{//Load from settings file
|
||||||
|
FileStream lockFile = File.Create(lockFilePath,0, FileOptions.DeleteOnClose); //lock settingsfile
|
||||||
|
string settingsStr = File.ReadAllText(sfp);
|
||||||
|
settingsStr = Regex.Replace(settingsStr, @"""MangaDexAuthor"": [0-9]+,", "");//https://github.com/C9Glax/tranga/pull/161 Remove sometime in the future :3
|
||||||
|
TrangaSettings settings = JsonConvert.DeserializeObject<TrangaSettings>(settingsStr)!;
|
||||||
|
this.requestLimits = settings.requestLimits;
|
||||||
|
this.userAgent = settings.userAgent;
|
||||||
|
this.downloadLocation = downloadLocation ?? settings.downloadLocation;
|
||||||
|
this.workingDirectory = workingDirectory ?? settings.workingDirectory;
|
||||||
|
this.apiPortNumber = apiPortNumber ?? settings.apiPortNumber;
|
||||||
|
lockFile.Close(); //unlock settingsfile
|
||||||
|
}
|
||||||
|
else if(!File.Exists(sfp))
|
||||||
|
{//No settings file exists
|
||||||
|
if (downloadLocation?.Length < 1 || workingDirectory?.Length < 1)
|
||||||
|
throw new ArgumentException("Download-location and working-directory paths can not be empty!");
|
||||||
|
this.requestLimits = DefaultRequestLimits;
|
||||||
|
this.userAgent = DefaultUserAgent;
|
||||||
|
this.apiPortNumber = apiPortNumber ?? 6531;
|
||||||
|
this.downloadLocation = downloadLocation ?? (RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/Manga" : Path.Join(Directory.GetCurrentDirectory(), "Downloads"));
|
||||||
|
this.workingDirectory = workingDirectory ?? Path.Join(RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/usr/share" : Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "tranga-api");
|
||||||
|
ExportSettings();
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{//Settingsfile is locked
|
||||||
Deserialize(File.ReadAllText(settingsFilePath));
|
this.requestLimits = DefaultRequestLimits;
|
||||||
|
this.userAgent = DefaultUserAgent;
|
||||||
|
this.apiPortNumber = apiPortNumber!.Value;
|
||||||
|
this.downloadLocation = downloadLocation!;
|
||||||
|
this.workingDirectory = workingDirectory!;
|
||||||
|
}
|
||||||
|
UpdateDownloadLocation(this.downloadLocation, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
Directory.CreateDirectory(downloadLocation);
|
public HashSet<LibraryConnector> LoadLibraryConnectors(GlobalBase clone)
|
||||||
Directory.CreateDirectory(workingDirectory);
|
|
||||||
ExportSettings();
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void CreateOrUpdate(string? downloadDirectory = null, string? pWorkingDirectory = null, int? pApiPortNumber = null, string? pUserAgent = null, bool? pAprilFoolsMode = null)
|
|
||||||
{
|
|
||||||
TrangaSettings.downloadLocation = downloadDirectory ?? TrangaSettings.downloadLocation;
|
|
||||||
TrangaSettings.workingDirectory = pWorkingDirectory ?? TrangaSettings.workingDirectory;
|
|
||||||
TrangaSettings.apiPortNumber = pApiPortNumber ?? TrangaSettings.apiPortNumber;
|
|
||||||
TrangaSettings.userAgent = pUserAgent ?? TrangaSettings.userAgent;
|
|
||||||
TrangaSettings.aprilFoolsMode = pAprilFoolsMode ?? TrangaSettings.aprilFoolsMode;
|
|
||||||
Directory.CreateDirectory(downloadLocation);
|
|
||||||
Directory.CreateDirectory(workingDirectory);
|
|
||||||
ExportSettings();
|
|
||||||
}
|
|
||||||
|
|
||||||
public static HashSet<LibraryConnector> LoadLibraryConnectors(GlobalBase clone)
|
|
||||||
{
|
{
|
||||||
if (!File.Exists(libraryConnectorsFilePath))
|
if (!File.Exists(libraryConnectorsFilePath))
|
||||||
return new HashSet<LibraryConnector>();
|
return new HashSet<LibraryConnector>();
|
||||||
@ -77,7 +90,7 @@ public static class TrangaSettings
|
|||||||
})!;
|
})!;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static HashSet<NotificationConnector> LoadNotificationConnectors(GlobalBase clone)
|
public HashSet<NotificationConnector> LoadNotificationConnectors(GlobalBase clone)
|
||||||
{
|
{
|
||||||
if (!File.Exists(notificationConnectorsFilePath))
|
if (!File.Exists(notificationConnectorsFilePath))
|
||||||
return new HashSet<NotificationConnector>();
|
return new HashSet<NotificationConnector>();
|
||||||
@ -91,13 +104,13 @@ public static class TrangaSettings
|
|||||||
})!;
|
})!;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void UpdateAprilFoolsMode(bool enabled)
|
public void UpdateAprilFoolsMode(bool enabled)
|
||||||
{
|
{
|
||||||
TrangaSettings.aprilFoolsMode = enabled;
|
this.aprilFoolsMode = enabled;
|
||||||
ExportSettings();
|
ExportSettings();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void UpdateDownloadLocation(string newPath, bool moveFiles = true)
|
public void UpdateDownloadLocation(string newPath, bool moveFiles = true)
|
||||||
{
|
{
|
||||||
if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
||||||
Directory.CreateDirectory(newPath,
|
Directory.CreateDirectory(newPath,
|
||||||
@ -105,44 +118,32 @@ public static class TrangaSettings
|
|||||||
else
|
else
|
||||||
Directory.CreateDirectory(newPath);
|
Directory.CreateDirectory(newPath);
|
||||||
|
|
||||||
if (moveFiles && Directory.Exists(TrangaSettings.downloadLocation))
|
if (moveFiles && Directory.Exists(this.downloadLocation))
|
||||||
Directory.Move(TrangaSettings.downloadLocation, newPath);
|
Directory.Move(this.downloadLocation, newPath);
|
||||||
|
|
||||||
TrangaSettings.downloadLocation = newPath;
|
this.downloadLocation = newPath;
|
||||||
ExportSettings();
|
ExportSettings();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void UpdateWorkingDirectory(string newPath)
|
public void UpdateWorkingDirectory(string newPath)
|
||||||
{
|
{
|
||||||
if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
|
||||||
Directory.CreateDirectory(newPath,
|
Directory.CreateDirectory(newPath,
|
||||||
GroupRead | GroupWrite | None | OtherRead | OtherWrite | UserRead | UserWrite);
|
GroupRead | GroupWrite | None | OtherRead | OtherWrite | UserRead | UserWrite);
|
||||||
else
|
else
|
||||||
Directory.CreateDirectory(newPath);
|
Directory.CreateDirectory(newPath);
|
||||||
Directory.Move(TrangaSettings.workingDirectory, newPath);
|
Directory.Move(this.workingDirectory, newPath);
|
||||||
TrangaSettings.workingDirectory = newPath;
|
this.workingDirectory = newPath;
|
||||||
ExportSettings();
|
ExportSettings();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void UpdateUserAgent(string? customUserAgent)
|
public void UpdateUserAgent(string? customUserAgent)
|
||||||
{
|
{
|
||||||
TrangaSettings.userAgent = customUserAgent ?? DefaultUserAgent;
|
this.userAgent = customUserAgent ?? DefaultUserAgent;
|
||||||
ExportSettings();
|
ExportSettings();
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void UpdateRateLimit(RequestType requestType, int newLimit)
|
public void ExportSettings()
|
||||||
{
|
|
||||||
TrangaSettings.requestLimits[requestType] = newLimit;
|
|
||||||
ExportSettings();
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void ResetRateLimits()
|
|
||||||
{
|
|
||||||
TrangaSettings.requestLimits = DefaultRequestLimits;
|
|
||||||
ExportSettings();
|
|
||||||
}
|
|
||||||
|
|
||||||
public static void ExportSettings()
|
|
||||||
{
|
{
|
||||||
if (File.Exists(settingsFilePath))
|
if (File.Exists(settingsFilePath))
|
||||||
{
|
{
|
||||||
@ -151,36 +152,22 @@ public static class TrangaSettings
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
Directory.CreateDirectory(new FileInfo(settingsFilePath).DirectoryName!);
|
Directory.CreateDirectory(new FileInfo(settingsFilePath).DirectoryName!);
|
||||||
File.WriteAllText(settingsFilePath, Serialize());
|
File.WriteAllText(settingsFilePath, JsonConvert.SerializeObject(this, Formatting.Indented));
|
||||||
}
|
}
|
||||||
|
|
||||||
public static string Serialize()
|
public string GetFullCoverPath(Manga manga)
|
||||||
{
|
{
|
||||||
JObject jobj = new JObject();
|
return Path.Join(this.coverImageCache, manga.coverFileNameInCache);
|
||||||
jobj.Add("downloadLocation", JToken.FromObject(TrangaSettings.downloadLocation));
|
|
||||||
jobj.Add("workingDirectory", JToken.FromObject(TrangaSettings.workingDirectory));
|
|
||||||
jobj.Add("apiPortNumber", JToken.FromObject(TrangaSettings.apiPortNumber));
|
|
||||||
jobj.Add("userAgent", JToken.FromObject(TrangaSettings.userAgent));
|
|
||||||
jobj.Add("aprilFoolsMode", JToken.FromObject(TrangaSettings.aprilFoolsMode));
|
|
||||||
jobj.Add("version", JToken.FromObject(TrangaSettings.version));
|
|
||||||
jobj.Add("requestLimits", JToken.FromObject(TrangaSettings.requestLimits));
|
|
||||||
return jobj.ToString();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void Deserialize(string serialized)
|
public override string ToString()
|
||||||
{
|
{
|
||||||
JObject jobj = JObject.Parse(serialized);
|
return $"TrangaSettings:\n" +
|
||||||
if (jobj.TryGetValue("downloadLocation", out JToken? dl))
|
$"\tDownloadLocation: {downloadLocation}\n" +
|
||||||
TrangaSettings.downloadLocation = dl.Value<string>()!;
|
$"\tworkingDirectory: {workingDirectory}\n" +
|
||||||
if (jobj.TryGetValue("workingDirectory", out JToken? wd))
|
$"\tjobsFolderPath: {jobsFolderPath}\n" +
|
||||||
TrangaSettings.workingDirectory = wd.Value<string>()!;
|
$"\tsettingsFilePath: {settingsFilePath}\n" +
|
||||||
if (jobj.TryGetValue("apiPortNumber", out JToken? apn))
|
$"\t\tnotificationConnectors: {notificationConnectorsFilePath}\n" +
|
||||||
TrangaSettings.apiPortNumber = apn.Value<int>();
|
$"\t\tlibraryConnectors: {libraryConnectorsFilePath}\n";
|
||||||
if (jobj.TryGetValue("userAgent", out JToken? ua))
|
|
||||||
TrangaSettings.userAgent = ua.Value<string>()!;
|
|
||||||
if (jobj.TryGetValue("aprilFoolsMode", out JToken? afm))
|
|
||||||
TrangaSettings.aprilFoolsMode = afm.Value<bool>()!;
|
|
||||||
if (jobj.TryGetValue("requestLimits", out JToken? rl))
|
|
||||||
TrangaSettings.requestLimits = rl.ToObject<Dictionary<RequestType, int>>()!;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue
Block a user