client/src/app/shared/shared-search/search.service.ts

   1 import { Observable, of } from 'rxjs'
   2 import { catchError, map, switchMap } from 'rxjs/operators'
   3 import { HttpClient, HttpParams } from '@angular/common/http'
   4 import { Injectable } from '@angular/core'
   5 import { ComponentPaginationLight, RestExtractor, RestPagination, RestService } from '@app/core'
   6 import { Video, VideoChannel, VideoChannelService, VideoService } from '@app/shared/shared-main'
   7 import { peertubeLocalStorage } from '@root-helpers/peertube-web-storage'
   8 import {
   9   ResultList,
  10   Video as VideoServerModel,
  11   VideoChannel as VideoChannelServerModel,
  12   VideoPlaylist as VideoPlaylistServerModel
  13 } from '@shared/models'
  14 import { environment } from '../../../environments/environment'
  15 import { VideoPlaylist, VideoPlaylistService } from '../shared-video-playlist'
  16 import { AdvancedSearch } from './advanced-search.model'
  17
  18 @Injectable()
  19 export class SearchService {
  20   static BASE_SEARCH_URL = environment.apiUrl + '/api/v1/search/'
  21
  22   constructor (
  23     private authHttp: HttpClient,
  24     private restExtractor: RestExtractor,
  25     private restService: RestService,
  26     private videoService: VideoService,
  27     private playlistService: VideoPlaylistService
  28   ) {
  29     // Add ability to override search endpoint if the user updated this local storage key
  30     const searchUrl = peertubeLocalStorage.getItem('search-url')
  31     if (searchUrl) SearchService.BASE_SEARCH_URL = searchUrl
  32   }
  33
  34   searchVideos (parameters: {
  35     search?: string
  36     componentPagination?: ComponentPaginationLight
  37     advancedSearch?: AdvancedSearch
  38     uuids?: string[]
  39   }): Observable<ResultList<Video>> {
  40     const { search, uuids, componentPagination, advancedSearch } = parameters
  41
  42     if (advancedSearch?.resultType !== undefined && advancedSearch.resultType !== 'videos') {
  43       return of({ total: 0, data: [] })
  44     }
  45
  46     const url = SearchService.BASE_SEARCH_URL + 'videos'
  47     let pagination: RestPagination
  48
  49     if (componentPagination) {
  50       pagination = this.restService.componentToRestPagination(componentPagination)
  51     }
  52
  53     let params = new HttpParams()
  54     params = this.restService.addRestGetParams(params, pagination)
  55
  56     if (search) params = params.append('search', search)
  57     if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
  58
  59     if (advancedSearch) {
  60       const advancedSearchObject = advancedSearch.toVideosAPIObject()
  61       params = this.restService.addObjectParams(params, advancedSearchObject)
  62     }
  63
  64     return this.authHttp
  65                .get<ResultList<VideoServerModel>>(url, { params })
  66                .pipe(
  67                  switchMap(res => this.videoService.extractVideos(res)),
  68                  catchError(err => this.restExtractor.handleError(err))
  69                )
  70   }
  71
  72   searchVideoChannels (parameters: {
  73     search?: string
  74     advancedSearch?: AdvancedSearch
  75     componentPagination?: ComponentPaginationLight
  76     handles?: string[]
  77   }): Observable<ResultList<VideoChannel>> {
  78     const { search, advancedSearch, componentPagination, handles } = parameters
  79
  80     if (advancedSearch?.resultType !== undefined && advancedSearch.resultType !== 'channels') {
  81       return of({ total: 0, data: [] })
  82     }
  83
  84     const url = SearchService.BASE_SEARCH_URL + 'video-channels'
  85
  86     let pagination: RestPagination
  87     if (componentPagination) {
  88       pagination = this.restService.componentToRestPagination(componentPagination)
  89     }
  90
  91     let params = new HttpParams()
  92     params = this.restService.addRestGetParams(params, pagination)
  93
  94     if (search) params = params.append('search', search)
  95     if (handles) params = this.restService.addArrayParams(params, 'handles', handles)
  96
  97     if (advancedSearch) {
  98       const advancedSearchObject = advancedSearch.toChannelAPIObject()
  99       params = this.restService.addObjectParams(params, advancedSearchObject)
 100     }
 101
 102     return this.authHttp
 103                .get<ResultList<VideoChannelServerModel>>(url, { params })
 104                .pipe(
 105                  map(res => VideoChannelService.extractVideoChannels(res)),
 106                  catchError(err => this.restExtractor.handleError(err))
 107                )
 108   }
 109
 110   searchVideoPlaylists (parameters: {
 111     search?: string
 112     advancedSearch?: AdvancedSearch
 113     componentPagination?: ComponentPaginationLight
 114     uuids?: string[]
 115   }): Observable<ResultList<VideoPlaylist>> {
 116     const { search, advancedSearch, componentPagination, uuids } = parameters
 117
 118     if (advancedSearch?.resultType !== undefined && advancedSearch.resultType !== 'playlists') {
 119       return of({ total: 0, data: [] })
 120     }
 121
 122     const url = SearchService.BASE_SEARCH_URL + 'video-playlists'
 123
 124     let pagination: RestPagination
 125     if (componentPagination) {
 126       pagination = this.restService.componentToRestPagination(componentPagination)
 127     }
 128
 129     let params = new HttpParams()
 130     params = this.restService.addRestGetParams(params, pagination)
 131
 132     if (search) params = params.append('search', search)
 133     if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
 134
 135     if (advancedSearch) {
 136       const advancedSearchObject = advancedSearch.toPlaylistAPIObject()
 137       params = this.restService.addObjectParams(params, advancedSearchObject)
 138     }
 139
 140     return this.authHttp
 141                .get<ResultList<VideoPlaylistServerModel>>(url, { params })
 142                .pipe(
 143                  switchMap(res => this.playlistService.extractPlaylists(res)),
 144                  catchError(err => this.restExtractor.handleError(err))
 145                )
 146   }
 147 }