75 lines
2.4 KiB
TypeScript
75 lines
2.4 KiB
TypeScript
import { Injectable } from '@angular/core';
|
|
import { InAppNotification } from '@app/core/model/inapp-notification/inapp-notification.model';
|
|
import { InAppNotificationLookup } from '@app/core/query/inapp-notification.lookup';
|
|
import { BaseHttpParams } from '@common/http/base-http-params';
|
|
import { InterceptorType } from '@common/http/interceptors/interceptor-type';
|
|
import { QueryResult } from '@common/model/query-result';
|
|
import { Guid } from '@common/types/guid';
|
|
import { Observable, throwError } from 'rxjs';
|
|
import { catchError } from 'rxjs/operators';
|
|
import { BaseHttpV2Service } from '../http/base-http-v2.service';
|
|
import { ConfigurationService } from '../configuration/configuration.service';
|
|
|
|
@Injectable()
|
|
export class InAppNotificationService {
|
|
|
|
constructor(private http: BaseHttpV2Service, private configurationService: ConfigurationService) {
|
|
}
|
|
|
|
private get apiBase(): string { return `${this.configurationService.notificationServiceAddress}api/inapp-notification`; }
|
|
|
|
|
|
query(q: InAppNotificationLookup): Observable<QueryResult<InAppNotification>> {
|
|
const url = `${this.apiBase}/query`;
|
|
|
|
return this.http
|
|
.post<QueryResult<InAppNotification>>(url, q).pipe(
|
|
catchError((error: any) => throwError(error)));
|
|
}
|
|
|
|
getSingle(id: Guid, reqFields: string[] = []): Observable<InAppNotification> {
|
|
const url = `${this.apiBase}/${id}`;
|
|
const options = { params: { f: reqFields } };
|
|
|
|
return this.http
|
|
.get<InAppNotification>(url, options).pipe(
|
|
catchError((error: any) => throwError(error)));
|
|
}
|
|
|
|
read(id: Guid): Observable<void> {
|
|
const url = `${this.apiBase}/${id}/read`;
|
|
|
|
return this.http
|
|
.post<void>(url, {}).pipe(
|
|
catchError((error: any) => throwError(error)));
|
|
}
|
|
|
|
countUnread(): Observable<number> {
|
|
const url = `${this.apiBase}/count-unread`;
|
|
const params = new BaseHttpParams();
|
|
params.interceptorContext = {
|
|
excludedInterceptors: [InterceptorType.ProgressIndication]
|
|
};
|
|
const options = { params: params };
|
|
|
|
return this.http
|
|
.get<number>(url, options).pipe(
|
|
catchError((error: any) => throwError(error)));
|
|
}
|
|
|
|
readAll(): Observable<boolean> {
|
|
const url = `${this.apiBase}/read-all`;
|
|
|
|
return this.http
|
|
.post<boolean>(url, {}).pipe(
|
|
catchError((error: any) => throwError(error)));
|
|
}
|
|
|
|
delete(id: Guid): Observable<InAppNotification> {
|
|
const url = `${this.apiBase}/${id}`;
|
|
return this.http
|
|
.delete<InAppNotification>(url).pipe(
|
|
catchError((error: any) => throwError(error)));
|
|
}
|
|
}
|