openaire-library/connect/userEmailPreferences/mailPrefs.service.ts

import {Injectable} from '@angular/core';
import {Http, RequestOptions, Headers, Response} from '@angular/http';
import {HttpClient, HttpErrorResponse} from "@angular/common/http";
import {Observable, throwError} from 'rxjs';
//import { HttpErrorResponse } from '@angular/common/http';

import {EnvProperties} from '../../utils/properties/env-properties';
import { CustomOptions } from '../../services/servicesUtils/customOptions.class';

@Injectable()
export class MailPrefsService {
    constructor(private http: HttpClient ) {}

    getUserEmailPreferencesForCommunity (communityId:string, apiUrl:string):any {
      let url = apiUrl +"users/notification"+"?communityId="+communityId;

      return this.http.get(url, CustomOptions.getAuthOptions())
                      //.map(request => <any> request.json())
                      //.do(request => console.info("Get user email preferences for communityId= "+communityId ));
                      //.catch(this.handleError);
    }

    getUserEmailPreferencesForOpenaire (apiUrl:string):any {
      let url = apiUrl +"users/notification";

      //var error: HttpErrorResponse = new HttpErrorResponse({"error": {"code": 204}, "status" : 204}); // doesn't work
      //var response: Response = new Response({"body" : {"code":200, "data": []}, "status": 200, "headers": null, "url": "", "merge": null});

      return this.http.get(url, CustomOptions.getAuthOptions())
                      //.timeoutWith(100, Observable.throw(response))   // goes to error
                      //.timeoutWith(100, Observable.of(response))      // goes to
                      //.do(request => console.info(request))
                      //.map(request => <any> request.json())
                      //.do(request => console.info("Get user email preferences for OpenAIRE" ));
                      //.catch(this.handleError);
    }

    saveUserEmailPreferences (notification: any, apiUrl: string) {
      let url = apiUrl +"users/notification/save";

      let body = JSON.stringify( notification );
      //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,  CustomOptions.getAuthOptionsWithBody())
                            //.map(res => res.json())
                            //.do(request => console.info("Insert Response:"+request.status) );
                            //.catch(this.handleError);
    }

    private handleError (error: HttpErrorResponse) {
      // 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 throwError(error  || 'Server error');
    }
}