glax/Tranga
2
0
Fork 0
Code

Delete old jobfiles.

Browse Source
This commit is contained in:
Glax 2024-04-25 21:24:11 +02:00
parent ec9290f41f
commit d52213002e
2 changed files with 29 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
Tranga/Jobs/JobBoss.cs
View File

@ -171,18 +171,18 @@ public class JobBoss : GlobalBase
} }
} }
internal void UpdateJobFile(Job job) internal void UpdateJobFile(Job job, string? oldFile = null)
{ {
string jobFilePath = Path.Join(settings.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))
{ {
try try
{ {
Log($"Deleting Job-file {jobFilePath}"); Log($"Deleting Job-file {newJobFilePath}");
while(IsFileInUse(jobFilePath)) while(IsFileInUse(newJobFilePath))
Thread.Sleep(10); Thread.Sleep(10);
File.Delete(jobFilePath); File.Delete(newJobFilePath);
} }
catch (Exception e) catch (Exception e)
{ {
@ -191,12 +191,25 @@ public class JobBoss : GlobalBase
} }
else else
{ {
Log($"Exporting Job {jobFilePath}"); Log($"Exporting Job {newJobFilePath}");
string jobStr = JsonConvert.SerializeObject(job); string jobStr = JsonConvert.SerializeObject(job);
while(IsFileInUse(jobFilePath)) while(IsFileInUse(newJobFilePath))
Thread.Sleep(10); Thread.Sleep(10);
File.WriteAllText(jobFilePath, jobStr); File.WriteAllText(newJobFilePath, jobStr);
} }
if(oldFile is not null)
try
{
Log($"Deleting old Job-file {oldFile}");
while(IsFileInUse(oldFile))
Thread.Sleep(10);
File.Delete(oldFile);
}
catch (Exception e)
{
Log(e.ToString());
}
} }
private void UpdateAllJobFiles() private void UpdateAllJobFiles()

9
Tranga/Jobs/UpdateMetadata.cs
View File

@ -38,13 +38,20 @@ public class UpdateMetadata : Job
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))
{ {
string oldFile;
if (job is DownloadNewChapters dc) if (job is DownloadNewChapters dc)
{
oldFile = dc.id;
dc.manga = this.manga; dc.manga = this.manga;
}
else if (job is UpdateMetadata um) else if (job is UpdateMetadata um)
{
oldFile = um.id;
um.manga = this.manga; um.manga = this.manga;
}
else else
continue; continue;
jobBoss.UpdateJobFile(job); jobBoss.UpdateJobFile(job, oldFile);
} }
this.progressToken.Complete(); this.progressToken.Complete();
} }