D-Net

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

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

import {Observable}     from 'rxjs/Observable';

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

import 'rxjs/add/observable/of';

import 'rxjs/add/operator/do';

import 'rxjs/add/operator/share';

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

@Injectable()

export class OpenaireProjectsService {

  private searchUrl;

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

    this.searchUrl = OpenaireProperties.getSearchServiceURL();

  }

  getFunders():any {

     let url = this.searchUrl+'search?action=refine&rTransformer=results_openaire_browse&fields=funderid&query=%28oaftype+exact+project%29&locale=en_GB&format=json';

     let key = url;

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

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

     }

     return this.http.get( url)

                     .map(request => <any> request.json().response.browseResults.result)

                     .do(funders => console.log("getFunders : "+funders))

                     .catch(this.handleError)

                     .do(res => {

                       this._cache.set(key, res);

                     });

    }

    searchForProjects(keyword:string, funderId:string):any {

       let url = this.searchUrl+'search?action=search&sTransformer=projects_openaire&query='+

       '%28oaftype+exact+project%29+and+%28%28projecttitle+%3D+%22'+keyword+'%22%29+or+%28projectacronym+%3D+%22'+keyword+'%22%29+or+%28projectcode+%3D+%22'+keyword+'%22%29%29+and+%28funderid+exact+'+funderId+'%29&size=10&locale=en_GB&format=json';

       let key = url;

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

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

       }

       return this.http.get( url)

                       .map(request => <any> (request.json().response.results)?request.json().response.results.result:request.json().response.results)

                       .do(funders => console.log("getFunders : "+funders))

                       .catch(this.handleError)

                       .do(res => {

                         this._cache.set(key, res);

                       });

      }

      searchForProjectsObs(keyword:string, funderId:string):any {

         let url = this.searchUrl+'search?action=search&sTransformer=projects_openaire&query='+

         '%28oaftype+exact+project%29+and+%28%28projecttitle+%3D+%22'+keyword+'%22%29+or+%28projectacronym+%3D+%22'+keyword+'%22%29+or+%28projectcode+%3D+%22'+keyword+'%22%29%29+and+%28funderid+exact+'+funderId+'%29&size=10&locale=en_GB&format=json';

         let key = url;

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

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

         }

         return this.http.get(url).toPromise()

                    .then(request =>{

              var valid:boolean= this.isJsonString(request);

              if(valid==true){

                return (request.json().response.results)?request.json().response.results.result:request.json().response.result;

              }else{

                return [];

              }

          })

        }

  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.error(error);

    return Observable.throw(error  || 'Server error');

  }

  private isJsonString(str) {

    console.info("Check jsooon");

    if(str instanceof Array || str instanceof Object) {

      try {

          str.json();

      } catch (e) {

          console.info("INValid");

          return false;

      }

      console.info("valid");

      return true

    }

    console.info("INValid");

    return false

  }

}