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, RestService } from '@app/core'
   6 import { ServerLogLevel } 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 restService: RestService,
  18     private restExtractor: RestExtractor
  19   ) {}
  20
  21   getLogs (options: {
  22     isAuditLog: boolean
  23     startDate: string
  24     tagsOneOf?: string[]
  25     level?: ServerLogLevel
  26     endDate?: string
  27   }): Observable<any[]> {
  28     const { isAuditLog, startDate, endDate, tagsOneOf } = options
  29
  30     let params = new HttpParams()
  31     params = params.append('startDate', startDate)
  32
  33     if (!isAuditLog) params = params.append('level', options.level)
  34     if (endDate) params = params.append('endDate', options.endDate)
  35     if (tagsOneOf) params = this.restService.addArrayParams(params, 'tagsOneOf', tagsOneOf)
  36
  37     const path = isAuditLog
  38       ? LogsService.BASE_AUDIT_LOG_URL
  39       : LogsService.BASE_LOG_URL
  40
  41     return this.authHttp.get<any[]>(path, { params })
  42                .pipe(
  43                  map(rows => rows.map(r => new LogRow(r))),
  44                  catchError(err => this.restExtractor.handleError(err))
  45                )
  46   }
  47 }