D-Net

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

import {Jsonp, URLSearchParams,ResponseOptions} from '@angular/http';

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

import {Observable}     from 'rxjs/Observable';

import {Claim}           from '../claim';

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

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

import 'rxjs/add/observable/of';

import 'rxjs/add/operator/do';

import 'rxjs/add/operator/share';

import { CacheService  } from '../../../shared/cache.service';

@Injectable()

export class ContextsService {

  private baseUrl;

  constructor(private http: Http, public _cache: CacheService) {

    this.baseUrl = OpenaireProperties.getClaimsAPIURL();

  }

  public getCommunities(token:string):any {

  let  url   = this.baseUrl + 'communities';

  let key = url;

  if (this._cache.has(key)) {

    return Observable.of(this._cache.get(key));

  }

    console.info('ContextsService: request communities  '+url);

      return this.http.get( url+"?token="+token)

                    .map(request => <any> request.json().data)

                    // .do(request => console.info("Get claims: offset = "))

                    .catch(this.handleError)

                    .do(res => {

                      this._cache.set(key, res);

                    });

  }

  public getCategories(communityId :string,token:string):any {

    console.info('ContextsService:  request categories for community  with id '+communityId);

    let url= this.baseUrl  + 'communities/' + communityId + '/categories';

    let key = url;

    if (this._cache.has(key)) {

      return Observable.of(this._cache.get(key));

    }

      return this.http.get( url+"?token="+token)

                    .map(request => <any> request.json().data)

                    // .do(request => console.info("Get claims: offset = " ))

                    .catch(this.handleError)

                    .do(res => {

                      this._cache.set(key, res);

                    });

  }

  public getConcepts(categoryId :string, keyword: string,token:string,parsing:boolean):any {

    console.info('ContextsService:  request concept for category  with id '+categoryId + ' and keyword '+ keyword);

    let url= this.baseUrl  + 'categories/' + categoryId+ "/concepts";

    let key = url+"_parsing="+parsing;

    if (this._cache.has(key)) {

      return Observable.of(this._cache.get(key));

    }

      return this.http.get( url+"?token="+token)

                    .map(request => <any> request.json().data)

                    .map(res => (parsing)?this.parse(res.concept):res.concept)

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

                    .catch(this.handleError)

                    .do(res => {

                      this._cache.set(key, res);

                    });

  }

  parse (data: any):AutoCompleteValue[] {

      var array:AutoCompleteValue[] =[]

      for(var i = 0; i < data.length; i++){

        var value:AutoCompleteValue =  new AutoCompleteValue();

        value.id = data[i].id;

        value.label = data[i].label;

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

  }

}