123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161 |
- import { Observable } from 'rxjs'
- import { catchError, switchMap } from 'rxjs/operators'
- import { HttpClient, HttpParams } from '@angular/common/http'
- import { Injectable } from '@angular/core'
- import { RestExtractor, RestPagination, RestService } from '@app/core'
- import { AdvancedInputFilter } from '@app/shared/shared-forms'
- import { CommonVideoParams, Video, VideoService } from '@app/shared/shared-main'
- import { ResultList, VideoInclude, VideoPrivacy } from '@peertube/peertube-models'
- import { getAllPrivacies } from '@peertube/peertube-core-utils'
- @Injectable()
- export class VideoAdminService {
- constructor (
- private videoService: VideoService,
- private authHttp: HttpClient,
- private restExtractor: RestExtractor,
- private restService: RestService
- ) {}
- getAdminVideos (
- options: CommonVideoParams & { pagination: RestPagination, search?: string }
- ): Observable<ResultList<Video>> {
- const { pagination, search } = options
- let params = new HttpParams()
- params = this.videoService.buildCommonVideosParams({ params, ...options })
- params = params.set('start', pagination.start.toString())
- .set('count', pagination.count.toString())
- params = this.buildAdminParamsFromSearch(search, params)
- return this.authHttp
- .get<ResultList<Video>>(VideoService.BASE_VIDEO_URL, { params })
- .pipe(
- switchMap(res => this.videoService.extractVideos(res)),
- catchError(err => this.restExtractor.handleError(err))
- )
- }
- buildAdminInputFilter (): AdvancedInputFilter[] {
- return [
- {
- title: $localize`Video type`,
- children: [
- {
- value: 'isLive:false',
- label: $localize`VOD`
- },
- {
- value: 'isLive:true',
- label: $localize`Live`
- }
- ]
- },
- {
- title: $localize`Video files`,
- children: [
- {
- value: 'webVideos:true isLocal:true',
- label: $localize`With Web Videos`
- },
- {
- value: 'webVideos:false isLocal:true',
- label: $localize`Without Web Videos`
- },
- {
- value: 'hls:true isLocal:true',
- label: $localize`With HLS`
- },
- {
- value: 'hls:false isLocal:true',
- label: $localize`Without HLS`
- }
- ]
- },
- {
- title: $localize`Videos scope`,
- children: [
- {
- value: 'isLocal:false',
- label: $localize`Remote videos`
- },
- {
- value: 'isLocal:true',
- label: $localize`Local videos`
- }
- ]
- },
- {
- title: $localize`Exclude`,
- children: [
- {
- value: 'excludeMuted',
- label: $localize`Exclude muted accounts`
- },
- {
- value: 'excludePublic',
- label: $localize`Exclude public videos`
- }
- ]
- }
- ]
- }
- private buildAdminParamsFromSearch (search: string, params: HttpParams) {
- let include = VideoInclude.BLACKLISTED |
- VideoInclude.BLOCKED_OWNER |
- VideoInclude.NOT_PUBLISHED_STATE |
- VideoInclude.FILES
- let privacyOneOf = getAllPrivacies()
- if (!search) return this.restService.addObjectParams(params, { include, privacyOneOf })
- const filters = this.restService.parseQueryStringFilter(search, {
- isLocal: {
- prefix: 'isLocal:',
- isBoolean: true
- },
- hasHLSFiles: {
- prefix: 'hls:',
- isBoolean: true
- },
- hasWebVideoFiles: {
- prefix: 'webVideos:',
- isBoolean: true
- },
- isLive: {
- prefix: 'isLive:',
- isBoolean: true
- },
- excludeMuted: {
- prefix: 'excludeMuted',
- handler: () => true
- },
- excludePublic: {
- prefix: 'excludePublic',
- handler: () => true
- }
- })
- if (filters.excludeMuted) {
- include &= ~VideoInclude.BLOCKED_OWNER
- filters.excludeMuted = undefined
- }
- if (filters.excludePublic) {
- privacyOneOf = [ VideoPrivacy.PRIVATE, VideoPrivacy.UNLISTED, VideoPrivacy.INTERNAL, VideoPrivacy.PASSWORD_PROTECTED ]
- filters.excludePublic = undefined
- }
- return this.restService.addObjectParams(params, { ...filters, include, privacyOneOf })
- }
- }
|