D-Net

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

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

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

import {Observable}     from 'rxjs/Observable';

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

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 ClaimsService {

  private baseUrl;

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

    this.baseUrl = OpenaireProperties.getClaimsAPIURL();

  }

  private getClaimRequest(size : number, page : number, url :string):any {

    console.info('ClaimsService: Claims request: '+url);

    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())

                    .do(request => console.info("Get claims: offset = "+(size*(page-1)) + " limit ="+size ))

                    .catch(this.handleError)

                    .do(res => {

                      this._cache.set(key, res);

                    });

  }

  getClaims( size : number, page : number, keyword:string, sortby: string, descending: boolean, types: string):any {

    console.info('ClaimsService: getClaims     ' );

    console.info('ClaimsService: Types : '+types );

    let url = this.baseUrl +"claims"+"?offset="+(size*(page-1) + "&limit="+size)+"&keyword="+keyword+"&sortby="+sortby+"&descending="+descending+"&"+types;

     return this.getClaimRequest(size,page,url);

  }

  getClaimsByUser( size : number, page : number, user:string, keyword:string, sortby: string, descending: boolean, types: string):any {

    console.info('ClaimsService: getClaims for user : '+user);

    let url = this.baseUrl +"users/"+user+"/claims"+"?offset="+(size*(page-1) + "&limit="+size)+"&keyword="+keyword+"&sortby="+sortby+"&descending="+descending+"&"+types;

     return this.getClaimRequest(size,page,url);

  }

  getClaimsBycontext( size : number, page : number, contextId:string, keyword:string, sortby: string, descending: boolean, types: string):any {

    console.info('ClaimsService: getClaims for context : '+contextId);

    let url = this.baseUrl +"contexts/"+contextId+"/claims"+"?offset="+(size*(page-1) + "&limit="+size)+"&keyword="+keyword+"&sortby="+sortby+"&descending="+descending+"&"+types;

     return this.getClaimRequest(size,page,url);

  }

  getClaimsByResult( size : number, page : number, resultId:string, keyword:string, sortby: string, descending: boolean, types: string):any {

    console.info('ClaimsService: getClaims for result : '+resultId);

    let url = this.baseUrl +"results/"+resultId+"/claims"+"?offset="+(size*(page-1) + "&limit="+size)+"&keyword="+keyword+"&sortby="+sortby+"&descending="+descending+"&"+types;

     return this.getClaimRequest(size,page,url);

  }

  getClaimsByProject( size : number, page : number, projectId:string, keyword:string, sortby: string, descending: boolean, types: string):any {

    console.info('ClaimsService: getClaims for project : '+projectId);

    let url = this.baseUrl +"projects/"+projectId+"/claims"+"?offset="+(size*(page-1) + "&limit="+size)+"&keyword="+keyword+"&sortby="+sortby+"&descending="+descending+"&"+types;

     return this.getClaimRequest(size,page,url);

  }

  deleteClaimById(claimId:string):any{

    console.warn('Trying to delete claim with id : '+claimId);

    let url = this.baseUrl +"claims/"+claimId;

    let headers = new Headers({ 'Content-Type': 'application/json' });

    let options = new RequestOptions({ headers: headers });

      return this.http.delete( url, options).map(request => <any> request.json())

      // .do(request => console.info("After delete" ))

      .catch(this.handleError);

  }

  deleteBulk(claimIds:string[]):any{

    console.warn('Trying to delete claims with ids : '+claimIds);

     var url = "";

    for(var claimId of claimIds){

      url=url+(url.length >0 ?"&":"")+"claimId="+claimId;

    }

    url= this.baseUrl +"claims/bulk?"+url;

    let headers = new Headers({ 'Content-Type': 'application/json' });

    let options = new RequestOptions({ headers: headers });

      return this.http.delete( url, options).map(request => <any> request.json())

      // .do(request => console.info("After delete" ))

      .catch(this.handleError);

  }

  insertBulkClaims(claims):any{

    console.warn('Trying toinsert claims  : '+claims);

    let url = this.baseUrl +"claims/bulk";

    let body = JSON.stringify( claims );

    console.warn('Json body:  : '+body);

    let headers = new Headers({ 'Content-Type': 'application/json' });

    let options = new RequestOptions({ headers: headers });

    return this.http.post(url, body, options)

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

                          .do(request => console.info("Insert Response:"+request.status) )

                          .catch(this.handleError);

    }

  insertClaim(claim):any{

    console.warn('Trying toinsert claim  : '+claim);

   let url = this.baseUrl +"claims";

          let body = JSON.stringify( claim );

          let headers = new Headers({ 'Content-Type': 'application/json' });

          let options = new RequestOptions({ headers: headers });

          return this.http.post(url, body, options)

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

                          .do(request => console.info("Insert Response:"+request.status) )

                          .catch(this.handleError);

    }

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

  }

  getClaim(id:string):any {

  let url = this.baseUrl+"claims/"+id;

      return new Promise((resolve, reject) => {

        this.http.get(url)

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

          .subscribe(

            data => {

              resolve(data.data);

            },

            err => {

              reject(err);

            }

          )

        ;

      });

      }

}