openaire-library/utils/staticAutoComplete/ISVocabularies.service.ts

import {Injectable} from '@angular/core';
import {Http, Response} from '@angular/http';
import {HttpClient, HttpErrorResponse} from "@angular/common/http";
import {Observable, throwError,  of } from 'rxjs';
import {AutoCompleteValue} from '../../searchPages/searchUtils/searchHelperClasses.class';

import{EnvProperties} from '../properties/env-properties';
import {catchError, map} from "rxjs/operators";

@Injectable()
export class ISVocabulariesService {
    constructor(private http: HttpClient ) {}

    getVocabularyByType(field:string,entity:string, properties:EnvProperties):any{
      //console.log("getVocabulary field: "+ field + " for entity: "+ entity);
      var file = "";
      var vocabulary = "";
      if( field == "lang"){
          // file="languages.json";
          // return this.getVocabularyFromFile(file);
          vocabulary = "dnet:languages.json";
          return this.getVocabularyFromService(vocabulary, properties);
      }else if ( field == "type" && (entity == "publication")){
        // file = "publicationTypes.json";
        // return this.getVocabularyFromFile(file);
        vocabulary = "dnet:publication_resource.json";
        return this.getVocabularyFromService(vocabulary, properties);

      }else if ( field == "type" && (entity == "dataset")){
        // file = "dnet:dataCite_resource.json";
        // return this.getVocabularyFromFile(file);
        vocabulary = "dnet:dataCite_resource.json";
        return this.getVocabularyFromService(vocabulary, properties);

      }else if ( field == "type" && (entity == "software" || entity == "other")){
        return of([]);

      }else if( field == "access" && (entity == "publication" || entity == "dataset" ||  entity == "software" || entity == "other")){
        // file= "accessMode.json";
        // return this.getVocabularyFromFile(file);
        vocabulary = "dnet:access_modes.json";
        return this.getVocabularyFromService(vocabulary, properties);

      } else if( (field == "type") && (entity == "dataprovider")){
        // file = "dataProviderType.json";
        //   return this.getVocabularyFromFile(file);
          vocabulary = "dnet:datasource_typologies.json";
          return this.getVocabularyFromService(vocabulary, properties);

      } else if( field == "compatibility" && (entity == "dataprovider")){
        // file = "dataProviderCompatibility.json";
        //   return this.getVocabularyFromFile(file);
          vocabulary = "dnet:datasourceCompatibilityLevel.json";
          return this.getVocabularyFromService(vocabulary, properties);

      } else if( field == "country" ){
        // file = "countries.json";
        //   return this.getVocabularyFromFile(file);
          vocabulary = "dnet:countries.json";
          return this.getVocabularyFromService(vocabulary, properties);

      }
      return null;

    }
    // getVocabularyFromFile (file:string):AutoCompleteValue[] {
    //        var lang = JSON.parse(JSON.stringify(require('../utils/vocabularies/'+file)));
    //       return  this.parse(lang["terms"]);
    // }
    getVocabularyFromService (vocabularyName:string, properties:EnvProperties):any {
        let url = properties.vocabulariesAPI + vocabularyName;
        //console.log(url);

        // return this.http.get(url).toPromise()
        // .then(request =>
        //   {
        //     request = request.json()['terms'];
        //     var results:AutoCompleteValue[] = this.parse(request);
        //     console.log("Get vocabulary : "+ vocabularyName+ " - get " +results.length+ "results");
        //     return results;
        //   });
        return this.http.get((properties.useCache)? (properties.cacheUrl+encodeURIComponent(url)): url)
                    //.map(res => <any> res.json())
                    .pipe(map(res => res['terms']))
                    .pipe(map(res => this.parse(res, vocabularyName)))
                    .pipe(catchError(this.handleError));

    }

    parse (data: any, vocabularyName: string):AutoCompleteValue[] {
        var array:AutoCompleteValue[] =[]
        for(var i = 0; i < data.length; i++){
          var value:AutoCompleteValue =  new AutoCompleteValue();
          value.id = data[i].englishName;//data[i].code;
          if(vocabularyName == 'dnet:countries.json'){ //use Country code instead of country name
            value.id =  data[i].code;
          }
          value.label = data[i].englishName;
          array.push(value);
        }

        return array;

    }
private handleError (error: HttpErrorResponse) {
      // in a real world app, we may send the error to some remote logging infrastructure
      // instead of just logging it to the console
      console.log(error);
      return throwError(error  || 'Server error');
    }
}