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 => 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'); } }