LP1779158 Angular7 and ng-lint updates
[Evergreen.git] / Open-ILS / src / eg2 / src / app / staff / cat / vandelay / vandelay.service.ts
index 3f4a197..cd52d44 100644 (file)
@@ -1,9 +1,8 @@
 import {Injectable} from '@angular/core';
-import {Observable} from 'rxjs/Observable';
-import {tap} from 'rxjs/operators/tap';
-import {map} from 'rxjs/operators/map';
+import {Observable} from 'rxjs';
+import {tap, map} from 'rxjs/operators';
 import {HttpClient} from '@angular/common/http';
-import {saveAs} from 'file-saver/FileSaver';
+import {saveAs} from 'file-saver';
 import {IdlService, IdlObject} from '@eg/core/idl.service';
 import {OrgService} from '@eg/core/org.service';
 import {NetService} from '@eg/core/net.service';
@@ -73,8 +72,8 @@ export class VandelayService {
         }
         const cls = (dtype === 'bib') ? 'vqbrad' : 'vqarad';
         const orderBy = {};
-        orderBy[cls] = 'id'
-        return this.pcrud.retrieveAll(cls, 
+        orderBy[cls] = 'id';
+        return this.pcrud.retrieveAll(cls,
             {order_by: orderBy}, {atomic: true}).toPromise()
         .then(list => {
             this.attrDefs[dtype] = list;
@@ -88,7 +87,7 @@ export class VandelayService {
         }
 
         const owners = this.org.ancestors(this.auth.user().ws_ou(), true);
-        return this.pcrud.search('vmp', 
+        return this.pcrud.search('vmp',
             {owner: owners}, {order_by: {vmp: ['name']}}, {atomic: true})
         .toPromise().then(profiles => {
             this.mergeProfiles = profiles;
@@ -119,8 +118,8 @@ export class VandelayService {
             return Promise.resolve(this.bibSources);
         }
 
-        return this.pcrud.retrieveAll('cbs', 
-          {order_by: {cbs: 'id'}}, 
+        return this.pcrud.retrieveAll('cbs',
+          {order_by: {cbs: 'id'}},
           {atomic: true}
         ).toPromise().then(sources => {
             this.bibSources = sources;
@@ -143,7 +142,7 @@ export class VandelayService {
 
     // todo: differentiate between biblio and authority a la queue api
     getMatchSets(mtype: string): Promise<IdlObject[]> {
-    
+
         const mstype = mtype.match(/bib/) ? 'biblio' : 'authority';
 
         if (this.matchSets[mtype]) {
@@ -154,7 +153,7 @@ export class VandelayService {
 
         const owners = this.org.ancestors(this.auth.user().ws_ou(), true);
 
-        return this.pcrud.search('vms', 
+        return this.pcrud.search('vms',
             {owner: owners, mtype: mstype}, {}, {atomic: true})
         .toPromise().then(sets => {
             this.matchSets[mtype] = sets;
@@ -167,12 +166,10 @@ export class VandelayService {
             return Promise.resolve(this.bibBuckets);
         }
 
-        const bkts = [];
         return this.net.request(
-            'open-ils.actor', 
+            'open-ils.actor',
             'open-ils.actor.container.retrieve_by_class',
             this.auth.token(), this.auth.user().id(), 'biblio', 'staff_client'
-        //).pipe(tap(bkt => bkts.push(bkt))).toPromise().then(() => bkts);
         ).toPromise().then(bkts => {
             this.bibBuckets = bkts;
             return bkts;
@@ -197,8 +194,8 @@ export class VandelayService {
 
         const owners = this.org.ancestors(this.auth.user().ws_ou(), true);
 
-        return this.pcrud.search('vibtg', 
-            {always_apply : 'f', owner: owners}, 
+        return this.pcrud.search('vibtg',
+            {always_apply : 'f', owner: owners},
             {vibtg : ['label']},
             {atomic: true}
         ).toPromise().then(groups => {
@@ -210,31 +207,31 @@ export class VandelayService {
 
     // Create a queue and return the ID of the new queue via promise.
     createQueue(
-        queueName: string, 
-        recordType: string, 
-        importDefId: number, 
-        matchSet: number, 
+        queueName: string,
+        recordType: string,
+        importDefId: number,
+        matchSet: number,
         matchBucket: number): Promise<number> {
 
         const method = `open-ils.vandelay.${recordType}_queue.create`;
 
         let qType = recordType;
         if (recordType.match(/bib_acq/)) {
-            let qType = 'acq';
+            qType = 'acq';
         }
 
         return new Promise((resolve, reject) => {
             this.net.request(
-                'open-ils.vandelay', method, 
-                this.auth.token(), queueName, null, qType, 
+                'open-ils.vandelay', method,
+                this.auth.token(), queueName, null, qType,
                 matchSet, importDefId, matchBucket
             ).subscribe(queue => {
                 const e = this.evt.parse(queue);
-                if (e) { 
+                if (e) {
                     reject(e);
                 } else {
                     // createQueue is always called after queues have
-                    // been fetched and cached.  
+                    // been fetched and cached.
                     this.allQueues[qType].push(queue);
                     resolve(queue.id());
                 }
@@ -242,20 +239,20 @@ export class VandelayService {
         });
     }
 
-    getQueuedRecords(queueId: number, queueType: string, 
+    getQueuedRecords(queueId: number, queueType: string,
       options?: any, limitToMatches?: boolean): Observable<any> {
 
         const qtype = queueType.match(/bib/) ? 'bib' : 'auth';
 
-        let method = 
+        let method =
           `open-ils.vandelay.${qtype}_queue.records.retrieve`;
 
         if (limitToMatches) {
-            method = 
+            method =
               `open-ils.vandelay.${qtype}_queue.records.matches.retrieve`;
         }
 
-        return this.net.request('open-ils.vandelay', 
+        return this.net.request('open-ils.vandelay',
             method, this.auth.token(), queueId, options);
     }
 
@@ -264,11 +261,11 @@ export class VandelayService {
 
         const etype = queue.queue_type().match(/auth/) ? 'auth' : 'bib';
 
-        let url = 
-          `${VANDELAY_EXPORT_PATH}?type=${etype}&queueid=${queue.id()}`
+        let url =
+          `${VANDELAY_EXPORT_PATH}?type=${etype}&queueid=${queue.id()}`;
 
         let saveName = queue.name();
-           
+
         if (nonImported) {
             url += '&nonimported=1';
             saveName += '_nonimported';
@@ -289,7 +286,7 @@ export class VandelayService {
         );
     }
 
-    // Poll every 2 seconds for session tracker updates so long 
+    // Poll every 2 seconds for session tracker updates so long
     // as the session tracker is active.
     // Returns an Observable of tracker objects.
     pollSessionTracker(id: number): Observable<IdlObject> {
@@ -300,13 +297,13 @@ export class VandelayService {
 
     getNextSessionTracker(id: number, observer: any) {
 
-               // No need for this to be an authoritative call.
+        // No need for this to be an authoritative call.
         // It will complete eventually regardless.
         this.pcrud.retrieve('vst', id).subscribe(
             tracker => {
                 if (tracker && tracker.state() === 'active') {
                     observer.next(tracker);
-                    setTimeout(() => 
+                    setTimeout(() =>
                         this.getNextSessionTracker(id, observer), 2000);
                 } else {
                     console.debug(