D-Net

import {Injectable} from '@angular/core';

import {Http, Response} from '@angular/http';

import {Observable}     from 'rxjs/Observable';

import {AutoCompleteValue} from '../../searchPages/searchUtils/searchHelperClasses.class';

import 'rxjs/add/observable/of';

import 'rxjs/add/operator/do';

import 'rxjs/add/operator/share';

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

@Injectable()

export class ISVocabulariesService {

    private api =OpenaireProperties.getVocabulariesAPI();

    constructor(private http: Http ) {}

    getVocabularyByType(field:string,entity:string):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);

      }else if ( field == "type" && (entity == "publication")){

        // file = "publicationTypes.json";

        // return this.getVocabularyFromFile(file);

        vocabulary = "dnet:publication_resource.json";

        return this.getVocabularyFromService(vocabulary);

      }else if ( field == "type" && (entity == "dataset")){

        // file = "dnet:dataCite_resource.json";

        // return this.getVocabularyFromFile(file);

        vocabulary = "dnet:dataCite_resource.json";

        return this.getVocabularyFromService(vocabulary);

      }else if( field == "access" && (entity == "publication" || entity == "dataset")){

        // file= "accessMode.json";

        // return this.getVocabularyFromFile(file);

        vocabulary = "dnet:access_modes.json";

        return this.getVocabularyFromService(vocabulary);

      } else if( (field == "type") && (entity == "dataprovider")){

        // file = "dataProviderType.json";

        //   return this.getVocabularyFromFile(file);

          vocabulary = "dnet:datasource_typologies.json";

          return this.getVocabularyFromService(vocabulary);

      } else if( field == "compatibility" && (entity == "dataprovider")){

        // file = "dataProviderCompatibility.json";

        //   return this.getVocabularyFromFile(file);

          vocabulary = "dnet:datasourceCompatibilityLevel.json";

          return this.getVocabularyFromService(vocabulary);

      } else if( field == "country" ){

        // file = "countries.json";

        //   return this.getVocabularyFromFile(file);

          vocabulary = "dnet:countries.json";

          return this.getVocabularyFromService(vocabulary);

      }

      return null;

    }

    // getVocabularyFromFile (file:string):AutoCompleteValue[] {

    //        var lang = JSON.parse(JSON.stringify(require('../utils/vocabularies/'+file)));

    //       return  this.parse(lang["terms"]);

    // }

    getVocabularyFromService (vocabularyName:string):any {

        let url = this.api + 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((OpenaireProperties.isCacheEnabled())? (OpenaireProperties.getCacheUrl()+encodeURIComponent(url)): url)

                    .do(res => console.log(res))

                    .map(res => <any> res.json())

                    .map(res => res['terms'])

                    .do(res => console.log(res))

                    .map(res => this.parse(res))

                    .do(res => console.log(res))

                    .catch(this.handleError);

    }

    parse (data: any):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;

          value.label = data[i].englishName;

          array.push(value);

        }

        return array;

    }

private handleError (error: Response) {

      // 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 Observable.throw(error  || 'Server error');

    }

}