From 411e945b3a204df55faf08edb485814a86b645c3 Mon Sep 17 00:00:00 2001 From: shamoon <4887959+shamoon@users.noreply.github.com> Date: Wed, 8 Jul 2026 12:40:28 -0700 Subject: [PATCH] Tasks service --- src-ui/src/app/services/tasks.service.ts | 24 ++++++++---------------- 1 file changed, 8 insertions(+), 16 deletions(-) diff --git a/src-ui/src/app/services/tasks.service.ts b/src-ui/src/app/services/tasks.service.ts index de358513a..8a425ac72 100644 --- a/src-ui/src/app/services/tasks.service.ts +++ b/src-ui/src/app/services/tasks.service.ts @@ -23,52 +23,44 @@ export class TasksService { public loading: boolean = false - private fileTasksSignal = signal([]) + private readonly fileTasks = signal([]) private unsubscribeNotifer: Subject = new Subject() - private get fileTasks(): PaperlessTask[] { - return this.fileTasksSignal() - } - - private set fileTasks(tasks: PaperlessTask[]) { - this.fileTasksSignal.set(tasks) - } - public get total(): number { return this.fileTasks.length } public get allFileTasks(): PaperlessTask[] { - return this.fileTasks.slice(0) + return this.fileTasks().slice(0) } public get queuedFileTasks(): PaperlessTask[] { - return this.fileTasks.filter( + return this.fileTasks().filter( (t) => t.status === PaperlessTaskStatus.Pending ) } public get startedFileTasks(): PaperlessTask[] { - return this.fileTasks.filter( + return this.fileTasks().filter( (t) => t.status === PaperlessTaskStatus.Started ) } public get completedFileTasks(): PaperlessTask[] { - return this.fileTasks.filter( + return this.fileTasks().filter( (t) => t.status === PaperlessTaskStatus.Success ) } public get failedFileTasks(): PaperlessTask[] { - return this.fileTasks.filter( + return this.fileTasks().filter( (t) => t.status === PaperlessTaskStatus.Failure ) } public get needsAttentionTasks(): PaperlessTask[] { - return this.fileTasks.filter((t) => + return this.fileTasks().filter((t) => [PaperlessTaskStatus.Failure, PaperlessTaskStatus.Revoked].includes( t.status ) @@ -89,7 +81,7 @@ export class TasksService { .pipe(map((r) => r.results)) .pipe(takeUntil(this.unsubscribeNotifer), first()) .subscribe((r) => { - this.fileTasks = r + this.fileTasks.set(r) this.loading = false }) }