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

   1 import { Observable } from 'rxjs'
   2 import { catchError, map } from 'rxjs/operators'
   3 import { HttpClient, HttpParams } from '@angular/common/http'
   4 import { Injectable } from '@angular/core'
   5 import { RestExtractor } from '@app/core'
   6 import { LogLevel } from '@shared/models'
   7 import { environment } from '../../../../environments/environment'
   8 import { LogRow } from './log-row.model'
   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 restExtractor: RestExtractor
  18   ) {}
  19
  20   getLogs (options: {
  21     isAuditLog: boolean,
  22     startDate: string,
  23     level?: LogLevel,
  24     endDate?: string
  25   }): Observable<any[]> {
  26     const { isAuditLog, startDate } = options
  27
  28     let params = new HttpParams()
  29     params = params.append('startDate', startDate)
  30
  31     if (!isAuditLog) params = params.append('level', options.level)
  32     if (options.endDate) params.append('endDate', options.endDate)
  33
  34     const path = isAuditLog
  35       ? LogsService.BASE_AUDIT_LOG_URL
  36       : LogsService.BASE_LOG_URL
  37
  38     return this.authHttp.get<any[]>(path, { params })
  39                .pipe(
  40                  map(rows => rows.map(r => new LogRow(r))),
  41                  catchError(err => this.restExtractor.handleError(err))
  42                )
  43   }
  44 }