client/src/app/shared/video-abuse/video-abuse.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 { SortMeta } from 'primeng/api'
   5 import { Observable } from 'rxjs'
   6 import { ResultList, VideoAbuse, VideoAbuseCreate, VideoAbuseState, VideoAbuseUpdate } from '../../../../../shared'
   7 import { environment } from '../../../environments/environment'
   8 import { RestExtractor, RestPagination, RestService } from '../rest'
   9 import { omit } from 'lodash-es'
  10
  11 @Injectable()
  12 export class VideoAbuseService {
  13   private static BASE_VIDEO_ABUSE_URL = environment.apiUrl + '/api/v1/videos/'
  14
  15   constructor (
  16     private authHttp: HttpClient,
  17     private restService: RestService,
  18     private restExtractor: RestExtractor
  19   ) {}
  20
  21   getVideoAbuses (options: {
  22     pagination: RestPagination,
  23     sort: SortMeta,
  24     search?: string
  25   }): Observable<ResultList<VideoAbuse>> {
  26     const { pagination, sort, search } = options
  27     const url = VideoAbuseService.BASE_VIDEO_ABUSE_URL + 'abuse'
  28
  29     let params = new HttpParams()
  30     params = this.restService.addRestGetParams(params, pagination, sort)
  31
  32     if (search) {
  33       const filters = this.restService.parseQueryStringFilter(search, {
  34         id: { prefix: '#' },
  35         state: {
  36           prefix: 'state:',
  37           handler: v => {
  38             if (v === 'accepted') return VideoAbuseState.ACCEPTED
  39             if (v === 'pending') return VideoAbuseState.PENDING
  40             if (v === 'rejected') return VideoAbuseState.REJECTED
  41
  42             return undefined
  43           }
  44         },
  45         videoIs: {
  46           prefix: 'videoIs:',
  47           handler: v => {
  48             if (v === 'deleted') return v
  49             if (v === 'blacklisted') return v
  50
  51             return undefined
  52           }
  53         },
  54         searchReporter: { prefix: 'reporter:' },
  55         searchReportee: { prefix: 'reportee:' },
  56         predefinedReason: { prefix: 'tag:' }
  57       })
  58
  59       params = this.restService.addObjectParams(params, filters)
  60     }
  61
  62     return this.authHttp.get<ResultList<VideoAbuse>>(url, { params })
  63                .pipe(
  64                  catchError(res => this.restExtractor.handleError(res))
  65                )
  66   }
  67
  68   reportVideo (parameters: { id: number } & VideoAbuseCreate) {
  69     const url = VideoAbuseService.BASE_VIDEO_ABUSE_URL + parameters.id + '/abuse'
  70
  71     const body = omit(parameters, [ 'id' ])
  72
  73     return this.authHttp.post(url, body)
  74                .pipe(
  75                  map(this.restExtractor.extractDataBool),
  76                  catchError(res => this.restExtractor.handleError(res))
  77                )
  78   }
  79
  80   updateVideoAbuse (videoAbuse: VideoAbuse, abuseUpdate: VideoAbuseUpdate) {
  81     const url = VideoAbuseService.BASE_VIDEO_ABUSE_URL + videoAbuse.video.uuid + '/abuse/' + videoAbuse.id
  82
  83     return this.authHttp.put(url, abuseUpdate)
  84                .pipe(
  85                  map(this.restExtractor.extractDataBool),
  86                  catchError(res => this.restExtractor.handleError(res))
  87                )
  88   }
  89
  90   removeVideoAbuse (videoAbuse: VideoAbuse) {
  91     const url = VideoAbuseService.BASE_VIDEO_ABUSE_URL + videoAbuse.video.uuid + '/abuse/' + videoAbuse.id
  92
  93     return this.authHttp.delete(url)
  94                .pipe(
  95                  map(this.restExtractor.extractDataBool),
  96                  catchError(res => this.restExtractor.handleError(res))
  97                )
  98   }}