1 import {Component, Input, OnInit, ViewChild} from '@angular/core';
2 import {Router, ActivatedRoute, ParamMap} from '@angular/router';
3 import {Observable, of} from 'rxjs';
4 import {map} from 'rxjs/operators';
5 import {Pager} from '@eg/share/util/pager';
6 import {GridComponent} from '@eg/share/grid/grid.component';
7 import {GridDataSource, GridColumn} from '@eg/share/grid/grid';
8 import {IdlObject} from '@eg/core/idl.service';
9 import {EventService} from '@eg/core/event.service';
10 import {NetService} from '@eg/core/net.service';
11 import {AuthService} from '@eg/core/auth.service';
12 import {PcrudService} from '@eg/core/pcrud.service';
13 import {BibRecordService, BibRecordSummary} from '@eg/share/catalog/bib-record.service';
14 import {VandelayService, VandelayImportSelection} from './vandelay.service';
17 selector: 'eg-queued-record-matches',
18 templateUrl: 'queued-record-matches.component.html'
20 export class QueuedRecordMatchesComponent implements OnInit {
22 @Input() queueType: string;
23 @Input() recordId: number;
24 @ViewChild('bibGrid', { static: false }) bibGrid: GridComponent;
25 @ViewChild('authGrid', { static: false }) authGrid: GridComponent;
27 queuedRecord: IdlObject;
28 bibDataSource: GridDataSource;
29 authDataSource: GridDataSource;
30 markOverlayTarget: (rows: any[]) => any;
31 matchRowClick: (row: any) => void;
32 matchMap: {[id: number]: IdlObject};
35 private router: Router,
36 private route: ActivatedRoute,
37 private evt: EventService,
38 private net: NetService,
39 private auth: AuthService,
40 private pcrud: PcrudService,
41 private bib: BibRecordService,
42 private vandelay: VandelayService) {
44 this.bibDataSource = new GridDataSource();
45 this.authDataSource = new GridDataSource();
47 this.bibDataSource.getRows = (pager: Pager) => {
48 return this.getBibMatchRows(pager);
52 this.authDataSource.getRows = (pager: Pager) => {
56 // Mark or un-mark as row as the merge target on row click
57 this.matchRowClick = (row: any) => {
58 this.toggleMergeTarget(row.id);
62 toggleMergeTarget(matchId: number) {
64 if (this.isOverlayTarget(matchId)) {
66 // clear selection on secondary click;
67 delete this.vandelay.importSelection.overlayMap[this.recordId];
71 // Start a new one if necessary, which will be adopted
72 // and completed by the queue UI before import.
74 let selection = this.vandelay.importSelection;
76 selection = new VandelayImportSelection();
77 this.vandelay.importSelection = selection;
79 const match = this.matchMap[matchId];
80 selection.overlayMap[this.recordId] = match.eg_record();
84 isOverlayTarget(matchId: number): boolean {
85 const selection = this.vandelay.importSelection;
87 const match = this.matchMap[matchId];
88 return selection.overlayMap[this.recordId] === match.eg_record();
95 // This thing is a nesty beast -- clean it up
96 getBibMatchRows(pager: Pager): Observable<any> {
98 return new Observable(observer => {
100 this.getQueuedRecord().then(() => {
102 const matches = this.queuedRecord.matches();
105 matches.forEach(m => {
106 this.matchMap[m.id()] = m;
107 if (!recIds.includes(m.eg_record())) {
108 recIds.push(m.eg_record());
112 const bibSummaries: {[id: number]: BibRecordSummary} = {};
113 this.bib.getBibSummary(recIds).subscribe(
114 summary => bibSummaries[summary.id] = summary,
117 this.bib.fleshBibUsers(
118 Object.values(bibSummaries).map(sum => sum.record)
120 matches.forEach(match => {
123 eg_record: match.eg_record(),
124 bre_quality: match.quality(),
125 vqbr_quality: this.queuedRecord.quality(),
126 match_score: match.match_score(),
127 bib_summary: bibSummaries[match.eg_record()]
141 getQueuedRecord(): Promise<any> {
142 if (this.queuedRecord) {
143 return Promise.resolve('');
145 const idlClass = this.queueType === 'bib' ? 'vqbr' : 'vqar';
146 const flesh = {flesh: 1, flesh_fields: {}};
147 flesh.flesh_fields[idlClass] = ['matches'];
148 return this.pcrud.retrieve(idlClass, this.recordId, flesh)
149 .toPromise().then(rec => this.queuedRecord = rec);