openaire-library/utils/fetchEntitiesClasses/fetchProjects.class.ts

import {SearchProjectsService} from '../../services/searchProjects.service';
import {ErrorCodes} from '../../utils/properties/errorCodes';
import {ErrorMessagesComponent}    from '../../utils/errorMessages.component';
import {SearchCustomFilter, SearchUtilsClass} from '../../searchPages/searchUtils/searchUtils.class';
import{EnvProperties} from '../../utils/properties/env-properties';
import {StringUtils} from '../../utils/string-utils.class';
export class FetchProjects{
  private errorCodes: ErrorCodes;
  private errorMessages: ErrorMessagesComponent;

  public results =[];

  public filters; // for getResultsForOrganizations
  public funders:any = [];  // for getResultsForOrganizations // this is filled with the initial query - before filtering

  public sub: any;
  public subResults: any;
  public searchUtils:SearchUtilsClass = new SearchUtilsClass();


  constructor (private _searchProjectsService: SearchProjectsService) {
    this.errorCodes = new ErrorCodes();
    this.errorMessages = new ErrorMessagesComponent();
    this.searchUtils.status = this.errorCodes.LOADING;

  }

  public ngOnDestroy() {
    if(this.sub){
      this.sub.unsubscribe();
    }
    if(this.subResults){
      this.subResults.unsubscribe();
    }
  }

  public getResultsByKeyword(keyword:string,  page: number, size: number, properties:EnvProperties,  customFilter:SearchCustomFilter=null){
    var parameters = "";
    if(keyword.length > 0){
      parameters = "q=" + StringUtils.URIEncode(keyword);
    }

    //var errorCodes:ErrorCodes = new ErrorCodes();
    this.searchUtils.status = this.errorCodes.LOADING;
    var refineParams = null;
    if(customFilter){
      refineParams = (refineParams?(refineParams+'&'):'')+"&fq="+StringUtils.URIEncode(customFilter.queryFieldName + " exact " + StringUtils.quote((customFilter.valueId )));
    }
  this.subResults = this._searchProjectsService.searchProjects(parameters, refineParams, page, size, [], properties).subscribe(
        data => {
            this.searchUtils.totalResults = data[0];
            //console.info("search Projects: [Parameters:"+parameters+" ]  [total results:"+this.searchUtils.totalResults+"]");
            this.results = data[1];

             //var errorCodes:ErrorCodes = new ErrorCodes();
            this.searchUtils.status = this.errorCodes.DONE;
            if(this.searchUtils.totalResults == 0 ){
              this.searchUtils.status = this.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;
            if(err.status == '404') {
              this.searchUtils.status = this.errorCodes.NOT_FOUND;
            } else if(err.status == '500') {
              this.searchUtils.status = this.errorCodes.ERROR;
            } else {
              this.searchUtils.status = this.errorCodes.NOT_AVAILABLE;
            }*/
            this.handleError("Error getting projects for keyword: "+keyword, err);
            this.searchUtils.status = this.errorMessages.getErrorCode(err.status);
         }
    );
  }

  public getResultsForDataproviders(id:string, page: number, size: number, properties:EnvProperties){
      //var errorCodes:ErrorCodes = new ErrorCodes();
      this.searchUtils.status = this.errorCodes.LOADING;

    this._searchProjectsService.getProjectsforDataProvider(id, page, size, properties).subscribe(
        data => {
            this.searchUtils.totalResults = data[0];
            //console.info("search Projects for Dataproviders: [Id:"+id+" ]  [total results:"+this.searchUtils.totalResults+"]");
            this.results = data[1];

            //var errorCodes:ErrorCodes = new ErrorCodes();
            this.searchUtils.status = this.errorCodes.DONE;
            if(this.searchUtils.totalResults == 0 ){
              this.searchUtils.status = this.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;
            if(err.status == '404') {
              this.searchUtils.status = this.errorCodes.NOT_FOUND;
            } else if(err.status == '500') {
              this.searchUtils.status = this.errorCodes.ERROR;
            } else {
              this.searchUtils.status = this.errorCodes.NOT_AVAILABLE;
            }*/
            this.handleError("Error getting projects for content provider with id: "+id, err);
            this.searchUtils.status = this.errorMessages.getErrorCode(err.status);
        }
    );
  }

  public getNumForEntity(entity: string, id:string, properties:EnvProperties) {
      //var errorCodes:ErrorCodes = new ErrorCodes();
      this.searchUtils.status = this.errorCodes.LOADING;

      if(id != "" && entity != "") {

          this._searchProjectsService.numOfEntityProjects(id, entity, properties ).subscribe(
              data => {
                  this.searchUtils.totalResults = data;

                  //var errorCodes:ErrorCodes = new ErrorCodes();
                  this.searchUtils.status = this.errorCodes.DONE;
                  if(this.searchUtils.totalResults == 0 ){
                    this.searchUtils.status = this.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;

                  if(err.status == '404') {
                    this.searchUtils.status = this.errorCodes.NOT_FOUND;
                  } else if(err.status == '500') {
                    this.searchUtils.status = this.errorCodes.ERROR;
                  } else {
                    this.searchUtils.status = this.errorCodes.NOT_AVAILABLE;
                  }*/
                  this.handleError("Error getting number of projects for "+entity+" with id: "+id, err);
                  this.searchUtils.status = this.errorMessages.getErrorCode(err.status);
              }
          );
      }
  }

  public getResultsForOrganizations(organizationId:string, filterquery:string, page: number, size: number, refineFields:string[], properties:EnvProperties){
      //var errorCodes:ErrorCodes = new ErrorCodes();
      this.searchUtils.status = this.errorCodes.LOADING;

    this._searchProjectsService.getProjectsForOrganizations(organizationId,filterquery, page, size,refineFields, properties).subscribe(
        data => {
            this.searchUtils.totalResults = data[0]; // the results can be filtered so this number can be no total results
            //console.info("search Projects for Organization: [Id:"+organizationId+" ]  [total results:"+this.searchUtils.totalResults+"]");
            this.results = data[1];
            if(refineFields && refineFields.length > 0){
              this.filters = data[2];
              filterquery = decodeURIComponent(filterquery);
              for(var i = 0; i < this.filters.length; i++){
                if(filterquery.indexOf(this.filters[i].filterId) !== -1){
                  //console.log("this.filters[i].filterId:"+this.filters[i].filterId);
                  for(var j = 0; j < this.filters[i].values.length; j++){
                    //console.log("this.filters[i].values[j].id:"+this.filters[i].values[j].id);
                      if(filterquery.indexOf(this.filters[i].values[j].id) !== -1){
                        this.filters[i].values[j].selected = true;
                      }
                  }
                }
              }
            }

            if(filterquery == ""){
              this.searchUtils.totalResultsNoFilters = this.searchUtils.totalResults;
              this.funders = [];
              for(var i = 0; i < this.filters.length; i++){
                //console.log("this.filters[i].filterId:"+this.filters[i].filterId);
                if(this.filters[i].filterId == "funder"){
                   this.funders = (this.filters[i].values);

                }
              }
              //console.log("  this.funders:"+   this.funders);

            }
            //var errorCodes:ErrorCodes = new ErrorCodes();
            this.searchUtils.status = this.errorCodes.DONE;
            if(this.searchUtils.totalResults == 0 ){
              this.searchUtils.status = this.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;
            if(err.status == '404') {
              this.searchUtils.status = this.errorCodes.NOT_FOUND;
            } else if(err.status == '500') {
              this.searchUtils.status = this.errorCodes.ERROR;
            } else {
              this.searchUtils.status = this.errorCodes.NOT_AVAILABLE;
            }*/
            this.handleError("Error getting projects for organization with id: "+organizationId, err);
            this.searchUtils.status = this.errorMessages.getErrorCode(err.status);
        }
    );
  }

  private handleError(message: string, error) {
      console.error("Fetch Projects (class): "+message, error);
  }
}