explore-services/sample-components/sampleComponent-2/src/app/services/claims.service.ts

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 '../entities/claim';
import {OpenaireProperties} from '../openaireProperties';

@Injectable()
export class ClaimsService {
  private baseUrl;
  constructor(private jsonp: Jsonp, private http: Http) {
    this.baseUrl = OpenaireProperties.getClaimsAPIURL();
  }

  private getClaimRequest(size : number, page : number, url :string):any {
    console.info('ClaimsService: Claims request: '+url);
      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);
  }
  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;
    console.warn('Delete url: '+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);

  }
  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;
    console.warn('Delete url: '+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.error(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);
            }
          )
        ;
      });
      }

}