client/src/app/+admin/system/logs/logs.service.ts

   1 import { catchError, map } from 'rxjs/operators'
   2 import { HttpClient, HttpParams } from '@angular/common/http'
   3 import { Injectable } from '@angular/core'
   4 import { Observable } from 'rxjs'
   5 import { environment } from '../../../../environments/environment'
   6 import { RestExtractor, RestService } from '../../../shared'
   7 import { LogRow } from '@app/+admin/system/logs/log-row.model'
   8 import { LogLevel } from '@shared/models/server/log-level.type'
   9
  10 @Injectable()
  11 export class LogsService {
  12   private static BASE_LOG_URL = environment.apiUrl + '/api/v1/server/logs'
  13   private static BASE_AUDIT_LOG_URL = environment.apiUrl + '/api/v1/server/audit-logs'
  14
  15   constructor (
  16     private authHttp: HttpClient,
  17     private restService: RestService,
  18     private restExtractor: RestExtractor
  19   ) {}
  20
  21   getLogs (options: {
  22     isAuditLog: boolean,
  23     startDate: string,
  24     level?: LogLevel,
  25     endDate?: string
  26   }): Observable<any[]> {
  27     const { isAuditLog, startDate } = options
  28
  29     let params = new HttpParams()
  30     params = params.append('startDate', startDate)
  31
  32     if (!isAuditLog) params = params.append('level', options.level)
  33     if (options.endDate) params.append('endDate', options.endDate)
  34
  35     const path = isAuditLog
  36       ? LogsService.BASE_AUDIT_LOG_URL
  37       : LogsService.BASE_LOG_URL
  38
  39     return this.authHttp.get<any[]>(path, { params })
  40                .pipe(
  41                  map(rows => rows.map(r => new LogRow(r))),
  42                  catchError(err => this.restExtractor.handleError(err))
  43                )
  44   }
  45 }