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

import {SearchProjectsService} from '../../services/searchProjects.service';
import {ErrorCodes} from '../../utils/properties/openaireProperties';
import {SearchUtilsClass } from '../../searchPages/searchUtils/searchUtils.class';

export class FetchProjects{
  private errorCodes: ErrorCodes;

  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.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){
    var parameters = "";
    if(keyword.length > 0){
      parameters = "q=" + keyword;
    }

    //var errorCodes:ErrorCodes = new ErrorCodes();
    this.searchUtils.status = this.errorCodes.LOADING;

  this.subResults = this._searchProjectsService.searchProjects(parameters, null, page, size, []).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;
            }
         }
    );
  }

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

    this._searchProjectsService.getProjectsforDataProvider(id, page, size).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;
            }
        }
    );
  }

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

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

          this._searchProjectsService.numOfEntityProjects(id, entity).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;
                  }
              }
          );
      }
  }

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

    this._searchProjectsService.getProjectsForOrganizations(organizationId,filterquery, page, size,refineFields).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;
            }
        }
    );
  }


}