Refactor uploads to service, working global dd

src-ui/src/app/services/upload-documents.service.spec.ts

@@ -0,0 +1,16 @@
+import { TestBed } from '@angular/core/testing';
+
+import { UploadDocumentsService } from './upload-documents.service';
+
+describe('UploadDocumentsService', () => {
+  let service: UploadDocumentsService;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({});
+    service = TestBed.inject(UploadDocumentsService);
+  });
+
+  it('should be created', () => {
+    expect(service).toBeTruthy();
+  });
+});

src-ui/src/app/services/upload-documents.service.ts

@@ -0,0 +1,56 @@
+import { Injectable } from '@angular/core';
+import { HttpEventType } from '@angular/common/http';
+import { FileSystemFileEntry, NgxFileDropEntry } from 'ngx-file-drop';
+import { ConsumerStatusService, FileStatusPhase } from './consumer-status.service';
+import { DocumentService } from './rest/document.service';
+
+@Injectable({
+  providedIn: 'root'
+})
+export class UploadDocumentsService {
+
+  constructor(
+    private documentService: DocumentService,
+    private consumerStatusService: ConsumerStatusService
+  ) {
+  }
+
+  uploadFiles(files: NgxFileDropEntry[]) {
+    for (const droppedFile of files) {
+      if (droppedFile.fileEntry.isFile) {
+
+      const fileEntry = droppedFile.fileEntry as FileSystemFileEntry;
+        fileEntry.file((file: File) => {
+          let formData = new FormData()
+          formData.append('document', file, file.name)
+          let status = this.consumerStatusService.newFileUpload(file.name)
+
+          status.message = $localize`Connecting...`
+
+          this.documentService.uploadDocument(formData).subscribe(event => {
+            if (event.type == HttpEventType.UploadProgress) {
+              status.updateProgress(FileStatusPhase.UPLOADING, event.loaded, event.total)
+              status.message = $localize`Uploading...`
+            } else if (event.type == HttpEventType.Response) {
+              status.taskId = event.body["task_id"]
+              status.message = $localize`Upload complete, waiting...`
+            }
+
+          }, error => {
+            switch (error.status) {
+              case 400: {
+                this.consumerStatusService.fail(status, error.error.document)
+                break;
+              }
+              default: {
+                this.consumerStatusService.fail(status, $localize`HTTP error: ${error.status} ${error.statusText}`)
+                break;
+              }
+            }
+          })
+        });
+      }
+    }
+  }
+
+}