D-Net

import {SearchPublicationsService} from '../../services/searchPublications.service';

import {ErrorCodes} from '../../utils/properties/openaireProperties';

import {SearchFields} from '../../utils/properties/searchFields';

 import {SearchUtilsClass } from '../../searchPages/searchUtils/searchUtils.class';

import {DOI} from '../../utils/string-utils.class';

export class FetchPublications {

  public results =[];

  // public filters =[];

  public searchUtils:SearchUtilsClass = new SearchUtilsClass();

  // public baseUrl:string = "";

  public sub: any;

  public subResults: any;

  public searchFields:SearchFields = new SearchFields();

  // public refineFields: string[] =  this.searchFields.RESULT_REFINE_FIELDS;

  // public fieldIdsMap=this.searchFields.RESULT_FIELDS;

    //:  { [key:string] :{ name:string, operator:string, type:string, indexField:string, equalityOperator:string  }} = this.searchFields.PUBLICATION_FIELDS_MAP;

  public CSV: any = {  "columnNames":  ["Title", "Authors", "Publication Year", "DOI",

                                       /*"Download From", "Publication type", "Journal",*/

                                       "Funder", "Project Name (GA Number)", "Access"],

                      "export":[]

                  };

  public CSVDownloaded = false;

  public csvParams: string;

  constructor ( private _searchPublicationsService: SearchPublicationsService ) {

    var errorCodes:ErrorCodes = new ErrorCodes();

    this.searchUtils.status =errorCodes.LOADING;

    // this.baseUrl = OpenaireProperties.getLinkToSearchPublications();

  }

  public ngOnDestroy() {

    if(this.sub){

      this.sub.unsubscribe();

    }

    if(this.subResults){

      this.subResults.unsubscribe();

    }

  }

  public getResultsByKeyword(keyword:string,  page: number, size: number){

    var parameters = "";

    if(keyword.length > 0){

      var DOIs:string[] = DOI.getDOIsFromString(keyword);

      var doisParams = "";

      for(var i =0 ;i < DOIs.length; i++){

        doisParams+=(doisParams.length > 0?"&":"")+'doi="'+ DOIs[i]+'"';

      }

      if(doisParams.length > 0){

        parameters +=  "&"+doisParams;

      }else{

        parameters = "q=" + keyword;

      }

    }

    var errorCodes:ErrorCodes = new ErrorCodes();

    this.searchUtils.status = errorCodes.LOADING;

    this.subResults = this._searchPublicationsService.searchPublications(parameters,null, page, size, []).subscribe(

        data => {

            this.searchUtils.totalResults = data[0];

            console.info("search Publications: [Parameters:"+parameters+" ]  [total results:"+this.searchUtils.totalResults+"]");

            this.results = data[1];

            var errorCodes:ErrorCodes = new ErrorCodes();

            this.searchUtils.status = errorCodes.DONE;

            if(this.searchUtils.totalResults == 0 ){

              this.searchUtils.status = errorCodes.NONE;

            }

         },

        err => {

            console.log(err);

             //TODO check erros (service not available, bad request)

            // if( ){

            //   this.searchUtils.status = ErrorCodes.ERROR;

            // }

            var errorCodes:ErrorCodes = new ErrorCodes();

            this.searchUtils.status = errorCodes.ERROR;

        }

    );

  }

public getResultsForEntity(entity:string, id:string, page: number, size: number){

    var errorCodes:ErrorCodes = new ErrorCodes();

    this.searchUtils.status = errorCodes.LOADING;

  var parameters = "";

  if(entity == "project") {

    parameters = "projects/"+id;

  } else if(entity == "person") {

    parameters = "people/"+id;

  }

  if(parameters != "") {

      this._searchPublicationsService.searchPublicationsForEntity(parameters, page, size).subscribe(

          data => {

              this.searchUtils.totalResults = data[0];

              console.info("search Publications for "+entity+": [Parameters:"+parameters+" ]  [total results:"+this.searchUtils.totalResults+"]");

              this.results = data[1];

              var errorCodes:ErrorCodes = new ErrorCodes();

              this.searchUtils.status = errorCodes.DONE;

              if(this.searchUtils.totalResults == 0 ){

                this.searchUtils.status = errorCodes.NONE;

              }

          },

          err => {

              console.log(err);

               //TODO check erros (service not available, bad request)

              // if( ){

              //   this.searchUtils.status = ErrorCodes.ERROR;

              // }

              var errorCodes:ErrorCodes = new ErrorCodes();

              this.searchUtils.status = errorCodes.ERROR;

          }

      );

  }

}

public getResultsForDataproviders(id:string, resultsFrom:string, page: number, size: number){

    var errorCodes:ErrorCodes = new ErrorCodes();

    this.searchUtils.status = errorCodes.LOADING;

  var parameters;

  if(resultsFrom == "collectedFrom") {

      parameters = "publications?fq=collectedfromdatasourceid exact "+'"'+id+'"';

  } else if(resultsFrom == "hostedBy") {

      parameters = "publications?fq=resulthostingdatasourceid exact "+'"'+id+'"';

  }

  if(parameters != "") {

      this._searchPublicationsService.searchPublicationsForDataproviders(parameters, page, size).subscribe(

          data => {

              this.searchUtils.totalResults = data[0];

              console.info("search Publications for Dataproviders: [Parameters:"+parameters+" ]  [total results:"+this.searchUtils.totalResults+"]");

              this.results = data[1];

              var errorCodes:ErrorCodes = new ErrorCodes();

              this.searchUtils.status = errorCodes.DONE;

              if(this.searchUtils.totalResults == 0 ){

                this.searchUtils.status = errorCodes.NONE;

              }

          },

          err => {

              console.log(err);

               //TODO check erros (service not available, bad request)

              // if( ){

              //   this.searchUtils.status = ErrorCodes.ERROR;

              // }

              var errorCodes:ErrorCodes = new ErrorCodes();

              this.searchUtils.status = errorCodes.ERROR;

          }

      );

  }

}

public getAggregatorResults(id:string, page: number, size: number){

    var errorCodes:ErrorCodes = new ErrorCodes();

    this.searchUtils.status = errorCodes.LOADING;

  this.subResults = this._searchPublicationsService.searchAggregators(id, '&fq=collectedfromdatasourceid exact "'+id+'"',"&refine=true&fields=resulthostingdatasource" , page, size).subscribe(

      data => {

          this.results = data;

          var errorCodes:ErrorCodes = new ErrorCodes();

          this.searchUtils.status = errorCodes.DONE;

          if(this.searchUtils.totalResults == 0 ){

            this.searchUtils.status = errorCodes.NONE;

          }

      },

      err => {

          console.log(err);

           //TODO check erros (service not available, bad request)

          // if( ){

          //   this.searchUtils.status = ErrorCodes.ERROR;

          // }

          var errorCodes:ErrorCodes = new ErrorCodes();

          this.searchUtils.status = errorCodes.ERROR;

      }

  );

}

}