Merge branch 'feature-frontend-task-queue' of github.com:paperless-ngx/paperless-ngx into feature-frontend-task-queue

src-ui/src/app/components/manage/tasks/tasks.component.html

@@ -1,24 +1,12 @@
 <app-page-header title="File Tasks" i18n-title>
-  <div class="btn-toolbar col col-md-auto">
-    <button class="btn btn-sm btn-outline-secondary me-2" (click)="clearSelection()" [hidden]="selectedTasks.size == 0">
-      <svg class="sidebaricon" fill="currentColor">
-        <use xlink:href="assets/bootstrap-icons.svg#x"/>
-      </svg>&nbsp;<ng-container i18n>Clear selection</ng-container>
-    </button>
-    <button class="btn btn-sm btn-outline-primary me-4" (click)="dismissTasks()" [disabled]="tasksService.total == 0">
-      <svg class="sidebaricon" fill="currentColor">
-        <use xlink:href="assets/bootstrap-icons.svg#check2-all"/>
-      </svg>&nbsp;<ng-container i18n>{{dismissButtonText}}</ng-container>
-    </button>
   <button class="btn btn-sm btn-outline-primary" (click)="tasksService.reload()">
     <svg class="sidebaricon" fill="currentColor">
       <use xlink:href="assets/bootstrap-icons.svg#arrow-clockwise"/>
     </svg>&nbsp;<ng-container i18n>Refresh</ng-container>
   </button>
-  </div>
 </app-page-header>
 
-<ng-container *ngIf="!tasksService.completedFileTasks && tasksService.loading">
+<ng-container *ngIf="!tasksService.completed && tasksService.loading">
   <div class="spinner-border spinner-border-sm fw-normal ms-2 me-auto" role="status"></div>
   <div class="visually-hidden" i18n>Loading...</div>
 </ng-container>
@@ -29,7 +17,8 @@
       <tr>
         <th scope="col">
           <div class="form-check">
-            <input type="checkbox" class="form-check-input" id="all-tasks" [disabled]="currentTasks.length == 0" (click)="toggleAll($event); $event.stopPropagation();">
+            <!--  [checked]="list.isSelected(d)" (click)="toggleSelected(d, $event); $event.stopPropagation();" -->
+            <input type="checkbox" class="form-check-input" id="all-tasks">
             <label class="form-check-label" for="all-tasks"></label>
           </div>
         </th>
@@ -43,7 +32,8 @@
       <tr *ngFor="let task of tasks">
         <th>
           <div class="form-check">
-            <input type="checkbox" class="form-check-input" id="task{{task.id}}" [checked]="selectedTasks.has(task.id)" (click)="toggleSelected(task, $event); $event.stopPropagation();">
+            <!--  [checked]="list.isSelected(d)" (click)="toggleSelected(d, $event); $event.stopPropagation();" -->
+            <input type="checkbox" class="form-check-input" id="task{{task.id}}">
             <label class="form-check-label" for="task{{task.id}}"></label>
           </div>
         </th>
@@ -71,23 +61,23 @@
   </table>
 </ng-template>
 
-<ul ngbNav #nav="ngbNav" [(activeId)]="activeTab" class="nav-tabs">
+<ul ngbNav #nav="ngbNav" class="nav-tabs">
-  <li ngbNavItem="incomplete">
+  <li ngbNavItem>
-    <a ngbNavLink i18n>Incomplete&nbsp;<span class="badge bg-secondary ms-1">{{tasksService.incompleteFileTasks.length}}</span></a>
+    <a ngbNavLink i18n>Incomplete&nbsp;<span class="badge bg-secondary ms-1">{{tasksService.incomplete.length}}</span></a>
     <ng-template ngbNavContent>
-      <ng-container [ngTemplateOutlet]="tasksTemplate" [ngTemplateOutletContext]="{tasks:tasksService.incompleteFileTasks}"></ng-container>
+      <ng-container [ngTemplateOutlet]="tasksTemplate" [ngTemplateOutletContext]="{tasks:tasksService.incomplete}"></ng-container>
     </ng-template>
   </li>
-  <li ngbNavItem="completed">
+  <li ngbNavItem>
-    <a ngbNavLink i18n>Completed&nbsp;<span class="badge bg-secondary ms-1">{{tasksService.completedFileTasks.length}}</span></a>
+    <a ngbNavLink i18n>Completed&nbsp;<span class="badge bg-secondary ms-1">{{tasksService.completed.length}}</span></a>
     <ng-template ngbNavContent>
-      <ng-container [ngTemplateOutlet]="tasksTemplate" [ngTemplateOutletContext]="{tasks:tasksService.completedFileTasks}"></ng-container>
+      <ng-container [ngTemplateOutlet]="tasksTemplate" [ngTemplateOutletContext]="{tasks:tasksService.completed}"></ng-container>
     </ng-template>
   </li>
-  <li ngbNavItem="failed">
+  <li ngbNavItem>
-    <a ngbNavLink i18n>Failed&nbsp;<span class="badge bg-secondary ms-1">{{tasksService.failedFileTasks.length}}</span></a>
+    <a ngbNavLink i18n>Failed&nbsp;<span class="badge bg-secondary ms-1">{{tasksService.failed.length}}</span></a>
     <ng-template ngbNavContent>
-      <ng-container [ngTemplateOutlet]="tasksTemplate" [ngTemplateOutletContext]="{tasks:tasksService.failedFileTasks}"></ng-container>
+      <ng-container [ngTemplateOutlet]="tasksTemplate" [ngTemplateOutletContext]="{tasks:tasksService.failed}"></ng-container>
     </ng-template>
   </li>
 </ul>

src-ui/src/app/components/manage/tasks/tasks.component.ts

@@ -9,16 +9,8 @@ import { TasksService } from 'src/app/services/tasks.service'
   styleUrls: ['./tasks.component.scss'],
 })
 export class TasksComponent implements OnInit, OnDestroy {
-  public activeTab: string
-  public selectedTasks: Set<number> = new Set()
   private unsubscribeNotifer = new Subject()
 
-  get dismissButtonText(): string {
-    return this.selectedTasks.size > 0
-      ? $localize`Dismiss selected`
-      : $localize`Dismiss all`
-  }
-
   constructor(public tasksService: TasksService) {}
 
   ngOnInit() {
@@ -29,50 +21,7 @@ export class TasksComponent implements OnInit, OnDestroy {
     this.unsubscribeNotifer.next(true)
   }
 
-  dismissTask(task: PaperlessTask) {
+  acknowledgeTask(task: PaperlessTask) {
-    this.dismissTasks(task)
+    throw new Error('Not implemented' + task)
-  }
-
-  dismissTasks(task: PaperlessTask = undefined) {
-    let tasks = task ? new Set([task.id]) : this.selectedTasks
-    if (this.selectedTasks.size == 0)
-      tasks = new Set(this.currentTasks.map((t) => t.id))
-    this.tasksService.dismissTasks(tasks)
-  }
-
-  toggleSelected(task: PaperlessTask) {
-    this.selectedTasks.has(task.id)
-      ? this.selectedTasks.delete(task.id)
-      : this.selectedTasks.add(task.id)
-  }
-
-  get currentTasks(): PaperlessTask[] {
-    let tasks: PaperlessTask[]
-    switch (this.activeTab) {
-      case 'incomplete':
-        tasks = this.tasksService.incompleteFileTasks
-        break
-      case 'completed':
-        tasks = this.tasksService.completedFileTasks
-        break
-      case 'failed':
-        tasks = this.tasksService.failedFileTasks
-        break
-      default:
-        break
-    }
-    return tasks
-  }
-
-  toggleAll(event: PointerEvent) {
-    if ((event.target as HTMLInputElement).checked) {
-      this.selectedTasks = new Set(this.currentTasks.map((t) => t.id))
-    } else {
-      this.clearSelection()
-    }
-  }
-
-  clearSelection() {
-    this.selectedTasks = new Set()
   }
 }

src-ui/src/app/data/paperless-task.ts

@@ -1,25 +1,9 @@
 import { ObjectWithId } from './object-with-id'
 
-export enum PaperlessTaskType {
-  // just file tasks, for now
-  File = 'file',
-}
-
-export enum PaperlessTaskStatus {
-  Incomplete = 'incomplete',
-  Complete = 'complete',
-  Failed = 'failed',
-  Unknown = 'unknown',
-}
-
 export interface PaperlessTask extends ObjectWithId {
-  type: PaperlessTaskType
-
-  status: PaperlessTaskStatus
-
   acknowledged: boolean
 
-  task_id: string
+  q_task_id: string
 
   name: string
 

src-ui/src/app/services/tasks.service.ts

@@ -1,13 +1,16 @@
 import { HttpClient } from '@angular/common/http'
 import { Injectable } from '@angular/core'
+import { Observable } from 'rxjs'
 import { first, map } from 'rxjs/operators'
-import {
+import { PaperlessTask } from 'src/app/data/paperless-task'
-  PaperlessTask,
-  PaperlessTaskStatus,
-  PaperlessTaskType,
-} from 'src/app/data/paperless-task'
 import { environment } from 'src/environments/environment'
 
+interface TasksAPIResponse {
+  incomplete: Array<PaperlessTask>
+  completed: Array<PaperlessTask>
+  failed: Array<PaperlessTask>
+}
+
 @Injectable({
   providedIn: 'root',
 })
@@ -16,26 +19,19 @@ export class TasksService {
 
   loading: boolean
 
-  private fileTasks: PaperlessTask[] = []
+  private incompleteTasks: PaperlessTask[] = []
-
+  public get incomplete(): PaperlessTask[] {
-  public get total(): number {
+    return this.incompleteTasks
-    return this.fileTasks?.length
   }
 
-  public get incompleteFileTasks(): PaperlessTask[] {
+  private completedTasks: PaperlessTask[] = []
-    return this.fileTasks.filter(
+  public get completed(): PaperlessTask[] {
-      (t) => t.status == PaperlessTaskStatus.Incomplete
+    return this.completedTasks
-    )
   }
 
-  public get completedFileTasks(): PaperlessTask[] {
+  private failedTasks: PaperlessTask[] = []
-    return this.fileTasks.filter(
+  public get failed(): PaperlessTask[] {
-      (t) => t.status == PaperlessTaskStatus.Complete
+    return this.failedTasks
-    )
-  }
-
-  public get failedFileTasks(): PaperlessTask[] {
-    return this.fileTasks.filter((t) => t.status == PaperlessTaskStatus.Failed)
   }
 
   constructor(private http: HttpClient) {}
@@ -44,23 +40,46 @@ export class TasksService {
     this.loading = true
 
     this.http
-      .get<PaperlessTask[]>(`${this.baseUrl}tasks/`)
+      .get<TasksAPIResponse>(`${this.baseUrl}consumption_tasks/`)
       .pipe(first())
       .subscribe((r) => {
-        this.fileTasks = r.filter((t) => t.type == PaperlessTaskType.File) // they're all File tasks, for now
+        this.incompleteTasks = r.incomplete
+        this.completedTasks = r.completed
+        this.failedTasks = r.failed
         this.loading = false
         return true
       })
   }
 
-  public dismissTasks(task_ids: Set<number>) {
+  // private savedViews: PaperlessSavedView[] = []
-    this.http
+
-      .post(`${this.baseUrl}acknowledge_tasks/`, {
+  // get allViews() {
-        tasks: [...task_ids],
+  //   return this.savedViews
-      })
+  // }
-      .pipe(first())
+
-      .subscribe((r) => {
+  // get sidebarViews() {
-        this.reload()
+  //   return this.savedViews.filter((v) => v.show_in_sidebar)
-      })
+  // }
-  }
+
+  // get dashboardViews() {
+  //   return this.savedViews.filter((v) => v.show_on_dashboard)
+  // }
+
+  // create(o: PaperlessSavedView) {
+  //   return super.create(o).pipe(tap(() => this.reload()))
+  // }
+
+  // update(o: PaperlessSavedView) {
+  //   return super.update(o).pipe(tap(() => this.reload()))
+  // }
+
+  // patchMany(objects: PaperlessSavedView[]): Observable<PaperlessSavedView[]> {
+  //   return combineLatest(objects.map((o) => super.patch(o))).pipe(
+  //     tap(() => this.reload())
+  //   )
+  // }
+
+  // delete(o: PaperlessSavedView) {
+  //   return super.delete(o).pipe(tap(() => this.reload()))
+  // }
 }