openaire-library/claims/claim-utils/displayClaims/displayClaims.component.ts

import {Component, Input, ViewChild} from '@angular/core';
import {Location} from '@angular/common';
import {ActivatedRoute, Router} from '@angular/router';
import {Subject, Subscriber} from 'rxjs';
import {debounceTime, distinctUntilChanged} from 'rxjs/operators';
import {ClaimsService} from '../service/claims.service';
import {ModalLoading} from '../../../utils/modal/loading.component';
import {AlertModal} from '../../../utils/modal/alert';
import {Session, User} from '../../../login/utils/helper.class';
import {EnvProperties} from '../../../utils/properties/env-properties';
import {LoginErrorCodes} from '../../../login/utils/guardHelper.class';
import {SEOService} from '../../../sharedComponents/SEO/SEO.service';
import {IndexInfoService} from '../../../utils/indexInfo.service';
import {ClaimDBRecord} from '../claimHelper.class';
import {Dates} from '../../../utils/string-utils.class';
import {HelperService} from '../../../utils/helper/helper.service';
import {Meta, Title} from '@angular/platform-browser';
import {PiwikService} from '../../../utils/piwik/piwik.service';
import {properties} from '../../../../../environments/environment';
import {FormArray, FormBuilder, FormGroup} from '@angular/forms';
import {Option} from '../../../sharedComponents/input/input.component';

declare var UIkit;
@Component({
  selector: 'displayClaims',
  templateUrl: 'displayClaims.component.html',
  // providers: [ClaimsService]

})
export class DisplayClaimsComponent {
  @Input() piwikSiteId = null;
  @Input() title: string = "";
  properties: EnvProperties;
  public searchTermStream = new Subject<string>();
  subscriptions: any = [];
  //string because comes as input from component directive
  @Input() enableDelete: boolean = false;
  @Input() showUserEmail: boolean = true;
  @Input() myClaims: boolean = false;
  @Input() isAdmin: boolean = false;
  page: number = 1;
  size: number = 50;
  defaultSize:number = 50;
  sizes = [10, 20, 30, 50];
  keyword: string; // the keyword string to give to the request as parameter
  inputkeyword: string; // the string written in the input field (keyword=inputkeyword when its length is bigger than 3 and the user stops typing)
  types = ["All", "Project", "Context", "Result", "User"];
  pageLoading:boolean = false;
  @Input() fetchBy: string;
  @Input() fetchId: string;
  @Input() user: User;
  resultsNum: number;
  claims: ClaimDBRecord[];
  @Input() externalPortalUrl: string = null;
  @Input() claimsInfoURL: string;// ="https://www.openaire.eu/linking";
  lastIndexDate = null;

  @ViewChild(ModalLoading) loading: ModalLoading;
  public filterForm: FormGroup;
  public entitiesCtrl: FormArray;

  allOptions: Option[] = [{label: "Projects", value: {id:"project", label: "Projects"}},{label: "Publications", value:{id:"publication", label: "Publications"}},{label: "Research data", value: {id:"dataset", label: "Research data"}},
    {label: "Software", value:  {id:"software", label: "Software"}},{label: "Other reserch products", value: {id:"other", label: "Other reserch products"}},{label: "Communities", value: {id:"community", label: "Communities"}}];

  sortOptions: Option[] = [
    {label:"Date (recent) ", value:{ sort: "date", descending: true }}, {label:"Date (oldest) ", value:{ sort: "date",descending:false }},
    // {label:"User (desc) ", value:{ sort: "user",descending: true }}, {label:"User (asc) ", value:{ sort: "user",descending:false }},
    // {label:"Title (desc) ", value:{ sort: "source",descending: true }}, {label:"Title (asc) ", value:{ sort: "source",descending:false }},
    {label:"Title (desc) ", value:{ sort: "target",descending: true }}, {label:"Title (asc) ", value: { sort: "target",descending:false }},
  ];

  entityTypes: string[] = [];

  // descending = true;
  // sortby = "date";

  selected = [];
  // deleteMessage: string = "";
  showErrorMessage: boolean = false;
  showForbiddenMessage: boolean = false;
  userValidMessage: string = "";

  //params for pagingFormatter to use when navigate to page
  params;
  @ViewChild(AlertModal) alert;

  claimsDeleted: number = 0;
  @Input() communityId: string = null;

  url = null;
  public pageContents = null;

  constructor(private _claimService: ClaimsService, private route: ActivatedRoute, private _router: Router, private location: Location,
              private _meta: Meta, private _title: Title, private _piwikService: PiwikService,
              private seoService: SEOService, private indexInfoService: IndexInfoService, private helper: HelperService, private _fb: FormBuilder) {
  }

  ngOnInit() {
    this.entitiesCtrl = this._fb.array([]);
    this.filterForm = this._fb.group({
      keyword: [''],
      entities: this.entitiesCtrl,
      sort: this._fb.control(this.sortOptions[0].value)
    });

    this.properties = properties;
    this.url = properties.domain + properties.baseLink + this._router.url;
    if(!this.myClaims){
      this.sortOptions.push({label:"User (desc) ", value:{ sort: "user",descending: true }});
      this.sortOptions.push( {label:"User (asc) ", value:{ sort: "user",descending:false }})
    }
    var description = "Openaire, linking, claim, publication, research data, software, other research product, project, community";
    this.updateTitle(this.title);
    this.updateDescription(description);
    this.updateUrl(this.url);
    if (this.properties.enablePiwikTrack && (typeof document !== 'undefined')) {
      this.subscriptions.push(this._piwikService.trackView(this.properties, this.title, this.piwikSiteId).subscribe());
    }

    this.subscriptions.push(this.helper.getPageHelpContents(this.properties, this.communityId, this._router.url).subscribe(contents => {
      this.pageContents = contents;
    }));
    this.subscriptions.push(this.indexInfoService.getLastIndexDate(this.properties).subscribe(res => {
      this.lastIndexDate = res;
    }));
    this.subscriptions.push(this.route.queryParams.subscribe(params => {
      this.seoService.createLinkForCanonicalURL(this.url, false);

      if (this.myClaims) {
        this.fetchBy = "User";
        this.fetchId = this.user.email;
      } else {
        this.fetchBy = (this.fetchBy) ? this.fetchBy : params['fetchBy'];
        this.fetchBy = (this.types.indexOf(this.fetchBy) != -1) ? this.fetchBy : 'All';
        this.fetchId = (this.fetchId) ? this.fetchId : params['fetchId'];
        this.fetchId = this.fetchId ? this.fetchId : '';
      }

      let page = (params['page'] === undefined) ? 1 : +params['page'];
      let size = (params['size'] === undefined) ? this.defaultSize : +params['size'];

      this.keyword = (params['keyword'] ? params['keyword'] : "");
      this.inputkeyword = this.keyword;
      this.page = (page <= 0) ? 1 : page;
      this.size = (size <= 0) ? this.defaultSize : size;
      this.entityTypes = [];//(params['types']?params['types']:[]);
      // this.setTypes(params['types']); // check the appropriate checkboxes
      this.setSortby(params['sort']);
      this.getClaims();
      this.subscriptions.push(this.searchTermStream
        .pipe(debounceTime(300), distinctUntilChanged())
        .subscribe((term: string) => {
          this.keyword = term;
          this.page = 1;
          this.goTo();
        }));
      this.subscriptions.push(this.filterForm.get('entities').valueChanges.subscribe(value => {
        this.goTo();
      }));
      this.subscriptions.push(this.filterForm.get('keyword').valueChanges.subscribe(value => {
        this.changekeyword();
      }));
      this.subscriptions.push(this.filterForm.get('sort').valueChanges.subscribe(value => {
        this.goTo();
      }));
    }));
  }

  ngOnDestroy() {
    this.subscriptions.forEach(subscription => {
      if (subscription instanceof Subscriber) {
        subscription.unsubscribe();
      }
    });
  }

  getClaims() {
    if (!Session.isLoggedIn()) {
      this.userValidMessage = "User session has expired. Please login again.";
      this._router.navigate(['/user-info'], {
        queryParams: {
          "errorCode": LoginErrorCodes.NOT_VALID,
          "redirectUrl": this._router.url
        }
      });
    } else {
      this.selected = [];
      let types = '';
      this.showErrorMessage = false;
      this.showForbiddenMessage = false;
      for (let type of this.entitiesCtrl.getRawValue()) {
        types += (this.entitiesCtrl.getRawValue().length > 0 ? '&' : '') + "types=" + type.id;
      }
      this.pageLoading = true;
      if (this.fetchBy == "Project") {
        this.subscriptions.push(this._claimService.getClaimsByProject(this.size, this.page, this.fetchId, this.keyword, this.filterForm.get("sort").value.sort, this.filterForm.get("sort").value.descending, types, this.properties.claimsAPIURL).subscribe(
          data => {
            this.manageAPIData(data);
            this.pageLoading = false;
          },
          err => {
            this.handleErrors(err, "Error getting claims for project with id: " + this.fetchId);
          }
        ));
      } else if (this.fetchBy == "User") {
        this.subscriptions.push(this._claimService.getClaimsByUser(this.size, this.page, this.fetchId, this.keyword, this.filterForm.get("sort").value.sort, this.filterForm.get("sort").value.descending, types, this.properties.claimsAPIURL).subscribe(
          data => {
            this.manageAPIData(data);
            this.pageLoading = false;
          },
          err => {
            this.handleErrors(err, "Error getting claims for user with id: " + this.fetchId);
            this.pageLoading = false;
          }
        ));
      } else if (this.fetchBy == "Result") {
        this.subscriptions.push(this._claimService.getClaimsByResult(this.size, this.page, this.fetchId, this.keyword, this.filterForm.get("sort").value.sort, this.filterForm.get("sort").value.descending, types, this.properties.claimsAPIURL).subscribe(
          data => {
            this.manageAPIData(data);
            this.pageLoading = false;
          },
          err => {
            this.handleErrors(err, "Error getting claims for entity with id: " + this.fetchId);
            this.pageLoading = false;
          }
        ));
      } else if (this.fetchBy == "Context") {
        this.subscriptions.push(this._claimService.getClaimsBycontext(this.size, this.page, this.fetchId, this.keyword, this.filterForm.get("sort").value.sort, this.filterForm.get("sort").value.descending, types, this.properties.claimsAPIURL).subscribe(
          data => {
            this.manageAPIData(data);
            this.pageLoading = false;
          },
          err => {
            this.handleErrors(err, "Error getting claims for context with id: " + this.fetchId);
            this.pageLoading = false;
          }
        ));
      } else {
        this.subscriptions.push(this._claimService.getClaims(this.size, this.page, this.keyword, this.filterForm.get("sort").value.sort, this.filterForm.get("sort").value.descending, types, this.properties.claimsAPIURL).subscribe(
          data => {
              this.manageAPIData(data);
              this.pageLoading = false;
          },
          err => {
            this.handleErrors(err, "Error getting claims");
            this.pageLoading = false;
          }
        ));
      }
    }
  }

  manageAPIData(data) {
    this.claims = data.data;
    this.resultsNum = data.total;


  }

  handleErrors(err, message) {

    this.showErrorMessage = true;
    console.error("Dispaly Claims (component): " + message +" " + (err && err.error?err.error:''));
    try {
      let error = err && err.error?err.error:err;
      if (error.code && error.code == 403) {
        this.showErrorMessage = false;
        this.showForbiddenMessage = true;
        if(!Session.isLoggedIn()) {

          this._router.navigate(['/user-info'], {
            queryParams: {
              "errorCode": LoginErrorCodes.NOT_VALID,
              "redirectUrl": this._router.url
            }
          });
        }

      }
    } catch (e) {

    }

  }

  goTo(page: number = 1) {
    this.page = page;
    this.location.go(location.pathname, this.getParametersString());
    this.getClaims();
  }

  getParametersString() {
    let params = '';
    params += (this.page == 1 ? "" : (params.length > 0 ? '&' : '') + "page=" + this.page);
    params += (this.size == 10 ? "" : (params.length > 0 ? '&' : '') + "size=" + this.size);
    let types = "";
    for (let type of this.entitiesCtrl.getRawValue()) {
      types += (this.entitiesCtrl.getRawValue().length > 0 ? ',' : '') + type.id;
    }
    params += (this.entitiesCtrl.getRawValue().length > 0) ? (params.length > 0 ? '&' : '') + "types=" + types : "";
    if (this.isAdmin) {
      params += (this.fetchBy == 'All' ? "" : (params.length > 0 ? '&' : '') + "fetchBy=" + this.fetchBy);
      params += (this.fetchId == '' ? "" : (params.length > 0 ? '&' : '') + "fetchId=" + this.fetchId);
    }
    params += (this.filterForm.get("sort").value.sort == 'date' && this.filterForm.get("sort").value.descending ? "" : (params.length > 0 ? '&' : '') + "sort=" +this.filterForm.get("sort").value.sort + "-" + this.filterForm.get("sort").value.descending);
    params += (this.keyword == '' ? "" : (params.length > 0 ? '&' : '') + "keyword=" + this.keyword);
    if (this.communityId != null) {
      params += "&communityId=" + this.communityId;
    }
    return params;
  }

  setSortby(sortby: string) {
    let sort = "date";
    let desc = "desc";
    if(sortby && sortby.split("-").length == 2){
      sort = sortby.split("-")[0];
      desc = sortby.split("-")[1];
    }

    let option = this.sortOptions.find( option => option.value.sort == sort && ((option.value.descending && desc=="desc") || (!option.value.descending && desc=="asc")));
    this.filterForm.get("sort").setValue(option?option.value:this.sortOptions[0].value);
  }

  changekeyword() {

    if (this.filterForm.get("keyword").value.length >= 3 || this.filterForm.get("keyword").value.length == 0) {
      this.searchTermStream.next(this.filterForm.get("keyword").value);
    }
  }

  select(item: any, event) {
    let value = event.currentTarget.checked;
    if (value) {
      this.selected.push(item);
    } else {
      for (var _i = 0; _i < this.selected.length; _i++) {
        let claim = this.selected[_i];
        if (claim['id'] == item.id) {
          this.selected.splice(_i, 1);
        }
      }


    }
  }

  selectAll(event) {
    let value = event.currentTarget.checked;
    if (value) {
      this.selected = [];
      for (let _i = 0; _i < this.claims.length; _i++) {
        let claim = this.claims[_i];
        this.selected.push(claim);
      }
    } else {
      this.selected = [];
    }
  }

  isSelected(id: string) {
    for (let _i = 0; _i < this.selected.length; _i++) {
      let claim = this.selected[_i];
      if (claim['id'] == id) {
        return true;
      }
    }
    return false;
  }


  confirmOpen() {
    if (this.selected.length <= 0) {

    } else {
      this.alert.cancelButton = true;
      this.alert.okButton = true;
      this.alert.alertTitle = "";// "Delete " + this.selected.length + " links(s)";
      this.alert.okButtonLeft = false;
      // this.alert.message = this.selected.length + " links will be deleted. Do you want to proceed? ";
      this.alert.okButtonText = "Delete";
      this.alert.cancelButtonText = "Cancel";
      this.alert.open();
    }
  }

  confirmClose() {
    this.delete();
  }

  delete() {
    this.loading.open();
    this.claimsDeleted = 0;
    let ids = [];
    for (let i = 0; i < this.selected.length; i++) {
      let id = this.selected[i].id;
      ids.push(id);

    }
    this.batchDeleteById(ids);
  }

  batchDeleteById(ids: string[]) {
    if (!this.user) {
      this.userValidMessage = "User session has expired. Please login again.";
      this._router.navigate(['/user-info'], {
        queryParams: {
          "errorCode": LoginErrorCodes.NOT_VALID,
          "redirectUrl": this._router.url
        }
      });
    } else {
      //console.warn("Deleting claim with ids:"+ids);
      this.subscriptions.push(this._claimService.deleteBulk(ids, this.properties.claimsAPIURL).subscribe(
        res => {
          //console.info('Delete response'+res.code );
          //console.warn("Deleted ids:"+ res.deletedIds);
          //console.warn("Not found ids:"+ res.notFoundIds);
          //remove this claim from the
          let newClaims = this.claims;
          for (let id of res.deletedIds) {
            for (let _i = 0; _i < this.claims.length; _i++) {
              let claim = this.claims[_i];
              if (claim['id'] == id) {
                newClaims.splice(_i, 1);
              }
            }
            for (let _i = 0; _i < this.selected.length; _i++) {
              let claim = this.selected[_i];
              if (claim['id'] == id) {
                this.selected.splice(_i, 1);
              }
            }
          }
          this.claims = newClaims;
          this.resultsNum = this.resultsNum - res.deletedIds.length;
          this.loading.close();
          if (res.deletedIds.length > 0) {
            UIkit.notification('<div class = " " >' + res.deletedIds.length + ' link(s) successfully deleted.</div>', {
              status: 'success',
              timeout: 6000,
              pos: 'bottom-right'
            });
          }
          if (res.notFoundIds.length > 0) {
            UIkit.notification('<div class = " " >' + res.notFoundIds.length + ' link(s) couldn\'t be deleted.</div>', {
              status: 'danger',
              timeout: 6000,
              pos: 'bottom-right'
            });
          }

          let goToPage = this.page;
          if (this.totalPages(this.resultsNum) < this.page && this.page > 0) {
            goToPage = this.page - 1;
          }
          this.goTo(goToPage);
        }, err => {
          //console.log(err);
          this.handleErrors(err,"Error deleting claims with ids: " + ids);
          this.showErrorMessage = true;
          this.loading.close();

        }));
    }
  }

  pageChange($event) {
    let page: number = +$event.value;
    this.goTo(page);
  }

  isClaimAvailable(claim: ClaimDBRecord): boolean {
    //claim.target.collectedFrom == "infrastruct_::openaire" &&
    let lastUpdateDate = new Date((this.lastIndexDate != null) ? this.lastIndexDate : this.properties.lastIndexUpdate);
    let lastUpdateDateStr = Dates.getDateToString(lastUpdateDate);
    let claimDate = new Date(claim.date);
    let claimDateStr = Dates.getDateToString(claimDate);
    if (claimDateStr < lastUpdateDateStr) {
      return true;
    } else {
      if (claim.target.collectedFrom != "infrastruct_::openaire" && claim.indexed) {
        //  check if direct index succeded
        return true
      }
    }
    return false;
  }

  totalPages(totalResults: number): number {
    let totalPages: any = totalResults / (this.size);
    if (!(Number.isInteger(totalPages))) {
      totalPages = (parseInt(totalPages, 10) + 1);
    }
    return totalPages;
  }

  private updateDescription(description: string) {
    this._meta.updateTag({content: description}, "name='description'");
    this._meta.updateTag({content: description}, "property='og:description'");
  }

  private updateTitle(title: string) {
    var _prefix = "";
    if (!this.communityId) {
      _prefix = "OpenAIRE | ";
    }
    var _title = _prefix + ((title.length > 50) ? title.substring(0, 50) : title);
    this._title.setTitle(_title);
    this._meta.updateTag({content: _title}, "property='og:title'");
  }

  private updateUrl(url: string) {
    this._meta.updateTag({content: url}, "property='og:url'");
  }
}