customer-data.service.ts

import {Injectable} from '@angular/core';
import {Http, Headers, Response, RequestMethod, RequestOptions} from '@angular/http';

import 'rxjs/add/operator/map';
import 'rxjs/add/operator/do';
import 'rxjs/add/operator/catch';
import {Observable} from 'rxjs/Rx';

import {GlobalService} from './global.service';
import {Customer} from './customer';


@Injectable()
export class CustomerDataService {

    constructor(private _globalService:GlobalService, private _http:Http){}


    addCustomer(customer:Customer):Observable<any>{
        var url     = this._globalService.apiHost+'customer';
        var headers = this.getHeaders();
        var body    = JSON.stringify(customer);
        var requestOptions = new RequestOptions({method: RequestMethod.Post,headers: headers});

        return this._http.post(url,body,requestOptions)
            .map(response => response.json())
            .map((response) => {
                console.log("response "+response);
                return response;
            })
            .catch(this.handleError);
    }

    updateCustomer(customer):Observable<any>{
        var url     = this._globalService.apiHost+'customer';
        var headers = this.getHeaders();
        var body    = JSON.stringify(customer);
        var requestOptions = new RequestOptions({method: RequestMethod.Put,headers: headers});
        return this._http.put(url,body,requestOptions)
            .map(response => response.json())
            .map((response) => {
                console.log(response);
                return response;
            })
            .catch(this.handleError);
    }


    deleteCustomer(id:number):Observable<any>{
        var url     = this._globalService.apiHost+'customer/'+id;
        var headers = this.getHeaders();
        var option  = new RequestOptions({headers: headers});
        return this._http.delete(url,option)
            .map(response => response.json())
            .map((response) => {
                return response;
            })
            .catch(this.handleError);
    }

    getAllCustomer(): Observable<Customer[]> {
        let headers = this.getHeaders();

        return this._http.get(
            this._globalService.apiHost+'customer',{headers: headers})
            .map(response => response.json())
            .map((response) => {
                return <Customer[]>response.data;
            })
            .catch(this.handleError);
    }

    getCustomerById(id:number):Observable<Customer> {
        let headers = this.getHeaders();
        return this._http.get(
            this._globalService.apiHost+'customer/'+id,
            {
                headers: headers
            }
        )
            .map(response => response.json())
            .map((response) => {
                return <Customer>response.data;
            })
            .catch(this.handleError);
    }

    private getHeaders():Headers {
        return new Headers({'Content-Type': 'application/json'});
    }


    private handleError (error: Response | any) {

        let errorMessage:any = {};
        // Connection error
        if(error.status == 0) {
            errorMessage = {
                success: false,
                status: 0,
                data: "Maaf koneksi sedang tidak ada. Silahkan coba lagi.",
            };
        }
        else {
            errorMessage = error.json();
        }
        return Observable.throw(errorMessage);
    }
}