D-Net

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

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

import {Observable}     from 'rxjs/Observable';

import 'rxjs/add/operator/do';

import 'rxjs/add/operator/share';

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

export class SearchCrossrefService {

  searchCrossrefResults (term: string, size : number, page : number):any {

     let url = OpenaireProperties.getSearchCrossrefAPIURL()+'?query='+term+'&rows='+size+'&offset='+(size*(page-1));

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

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

     }

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

                     .do(items => console.log("Crossref Results: total results = "+items['total-results']+" keyword = "+term))

                       this._cache.set(key, res);

                     });

    }

      /*

      $request ="http://api.crossref.org/works"."?filter=";

                      foreach($dois as $doi){

                          $request.="doi:".urlencode( trim($doi)).",";

                      }

      */

      var doisParams = "";

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

        doisParams+=(doisParams.length > 0?",":"")+'doi:'+DOIs[i];

      }

       let url = OpenaireProperties.getSearchCrossrefAPIURL()+'?filter='+doisParams;

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

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

       }

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

                         this._cache.set(key, res);

                       });

      }

      searchCrossrefByMultipleDOIs(dois: string[]):any {

        let url = OpenaireProperties.getSearchCrossrefAPIURL()+'?filter=doi:';

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

          url=url+(url.length==0?'':',')+'doi:'+dois[i];

        }

        url = OpenaireProperties.getSearchCrossrefAPIURL()+'?filter='+url;

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

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

        }

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

                         do(res => {

                           this._cache.set(key, res);

                         });

        }

  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

  }

}