client/src/app/shared/shared-main/users/user-history.service.ts

   1 import { catchError, switchMap } from 'rxjs/operators'
   2 import { HttpClient, HttpParams } from '@angular/common/http'
   3 import { Injectable } from '@angular/core'
   4 import { ComponentPaginationLight, RestExtractor, RestService } from '@app/core'
   5 import { ResultList } from '@shared/models'
   6 import { environment } from '../../../../environments/environment'
   7 import { Video } from '../video/video.model'
   8 import { VideoService } from '../video/video.service'
   9
  10 @Injectable()
  11 export class UserHistoryService {
  12   static BASE_USER_VIDEOS_HISTORY_URL = environment.apiUrl + '/api/v1/users/me/history/videos'
  13
  14   constructor (
  15     private authHttp: HttpClient,
  16     private restExtractor: RestExtractor,
  17     private restService: RestService,
  18     private videoService: VideoService
  19   ) {}
  20
  21   list (historyPagination: ComponentPaginationLight, search?: string) {
  22     const pagination = this.restService.componentToRestPagination(historyPagination)
  23
  24     let params = new HttpParams()
  25     params = this.restService.addRestGetParams(params, pagination)
  26
  27     if (search) params = params.append('search', search)
  28
  29     return this.authHttp
  30                .get<ResultList<Video>>(UserHistoryService.BASE_USER_VIDEOS_HISTORY_URL, { params })
  31                .pipe(
  32                  switchMap(res => this.videoService.extractVideos(res)),
  33                  catchError(err => this.restExtractor.handleError(err))
  34                )
  35   }
  36
  37   deleteElement (video: Video) {
  38     return this.authHttp
  39                .delete(UserHistoryService.BASE_USER_VIDEOS_HISTORY_URL + '/' + video.id)
  40                .pipe(catchError(err => this.restExtractor.handleError(err)))
  41   }
  42
  43   clearAll () {
  44     return this.authHttp
  45                .post(UserHistoryService.BASE_USER_VIDEOS_HISTORY_URL + '/remove', {})
  46                .pipe(catchError(err => this.restExtractor.handleError(err)))
  47   }
  48 }