D-Net

import {SearchDatasetsService} from '../../services/searchDatasets.service';

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

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

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

export class FetchDatasets{

  public results =[];

  public searchUtils:SearchUtilsClass = new SearchUtilsClass();

  private sub: any;

  private subResults: any;

  public csvParams: string;

  constructor ( private _searchDatasetsService: SearchDatasetsService ) {

    var errorCodes:ErrorCodes = new ErrorCodes();

    this.searchUtils.status =errorCodes.LOADING;

  }

  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._searchDatasetsService.searchDatasets(parameters,null, page, size, []).subscribe(

        data => {

            this.searchUtils.totalResults = data[0];

            console.info("search Datasets: [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._searchDatasetsService.searchDatasetsForEntity(parameters, page, size).subscribe(

          data => {

              this.searchUtils.totalResults = data[0];

              console.info("search Datasets 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 = "datasets?fq=collectedfromdatasourceid exact "+'"'+id+'"';

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

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

  }

  if(parameters != "") {

      this._searchDatasetsService.searchDatasetsForDataproviders(parameters, page, size).subscribe(

          data => {

              this.searchUtils.totalResults = data[0];

              console.info("search Datasets 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._searchDatasetsService.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;

      }

  );

}

}