D-Net

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';

import {SearchInputComponent} from '../../../sharedComponents/search-input/search-input.component';

declare var UIkit;

@Component({

  selector: 'displayClaims',

  templateUrl: 'displayClaims.component.html',

  // providers: [ClaimsService]

})

export class DisplayClaimsComponent {

  @Input() piwikSiteId = null;

  @Input() pageTitle: string = "";

  properties: EnvProperties;

  public searchTermStream = new Subject<string>();

  subscriptions: any = [];

  public subResults: 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)

  @ViewChild('searchInputComponent') searchInputComponent: SearchInputComponent;

  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:"context", 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.pageTitle);

    this.updateDescription(description);

    this.updateUrl(this.url);

    if (this.properties.enablePiwikTrack && (typeof document !== 'undefined')) {

      this.subscriptions.push(this._piwikService.trackView(this.properties, this.pageTitle, 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.filterForm.get('keyword').setValue(this.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();

      }

    });

    if(this.subResults){

      this.subResults.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.subResults){

        this.subResults.unsubscribe();

      }

      if (this.fetchBy == "Project") {

        this.subResults = 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.subResults = 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.subResults = 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.subResults = 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.subResults = 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);

    if(this.myClaims) {

      this._title.setTitle(_title);

    }

    this._meta.updateTag({content: _title}, "property='og:title'");

  }

  private updateUrl(url: string) {

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

  }

  public onSearchClose() {

    this.inputkeyword = this.filterForm.get('keyword').value;

  }

  public resetInput() {

    this.inputkeyword = null;

    this.searchInputComponent.reset()

  }

}