import {Injectable} from "@angular/core"; import {HttpClient} from "@angular/common/http"; import {properties} from "../../../environments/environment"; import {Observable} from "rxjs"; import {Notification, NotificationUser} from "./notifications"; import {CustomOptions} from "../services/servicesUtils/customOptions.class"; import {not} from "rxjs/internal-compatibility"; import {map} from "rxjs/operators"; import {StringUtils} from '../utils/string-utils.class'; @Injectable({ providedIn: "root" }) export class NotificationService { constructor(private httpClient: HttpClient) { } public getAllNotifications(): Observable { return this.httpClient.get(properties.notificationsAPIURL + 'all', CustomOptions.registryOptions()).pipe(map(notifications => { notifications.forEach(notification => { this.formatNotification(notification); }) return notifications; })); } public getNotifications(service: string): Observable { return this.httpClient.get(properties.notificationsAPIURL + encodeURIComponent(service), CustomOptions.registryOptions()).pipe(map(notifications => { notifications.forEach(notification => { this.formatNotification(notification); }) return notifications; })); } public sendNotification(notification: Notification): Observable { return this.httpClient.post(properties.notificationsAPIURL + 'save', notification, CustomOptions.registryOptions()); } public readNotification(id: string): Observable { return this.httpClient.put(properties.notificationsAPIURL + encodeURIComponent(id), null, CustomOptions.registryOptions()); } private formatNotification(notification: Notification): Notification { if (notification.title) { notification.preview = notification.title; } else { notification.preview = StringUtils.HTMLToString(notification.message); } return notification; } }