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

   1 import { Observable } 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     const url = SearchService.BASE_SEARCH_URL + 'videos'
  43     let pagination: RestPagination
  44
  45     if (componentPagination) {
  46       pagination = this.restService.componentPaginationToRestPagination(componentPagination)
  47     }
  48
  49     let params = new HttpParams()
  50     params = this.restService.addRestGetParams(params, pagination)
  51
  52     if (search) params = params.append('search', search)
  53     if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
  54
  55     if (advancedSearch) {
  56       const advancedSearchObject = advancedSearch.toVideosAPIObject()
  57       params = this.restService.addObjectParams(params, advancedSearchObject)
  58     }
  59
  60     return this.authHttp
  61                .get<ResultList<VideoServerModel>>(url, { params })
  62                .pipe(
  63                  switchMap(res => this.videoService.extractVideos(res)),
  64                  catchError(err => this.restExtractor.handleError(err))
  65                )
  66   }
  67
  68   searchVideoChannels (parameters: {
  69     search?: string
  70     advancedSearch?: AdvancedSearch
  71     componentPagination?: ComponentPaginationLight
  72     handles?: string[]
  73   }): Observable<ResultList<VideoChannel>> {
  74     const { search, advancedSearch, componentPagination, handles } = parameters
  75
  76     const url = SearchService.BASE_SEARCH_URL + 'video-channels'
  77
  78     let pagination: RestPagination
  79     if (componentPagination) {
  80       pagination = this.restService.componentPaginationToRestPagination(componentPagination)
  81     }
  82
  83     let params = new HttpParams()
  84     params = this.restService.addRestGetParams(params, pagination)
  85
  86     if (search) params = params.append('search', search)
  87     if (handles) params = this.restService.addArrayParams(params, 'handles', handles)
  88
  89     if (advancedSearch) {
  90       const advancedSearchObject = advancedSearch.toChannelAPIObject()
  91       params = this.restService.addObjectParams(params, advancedSearchObject)
  92     }
  93
  94     return this.authHttp
  95                .get<ResultList<VideoChannelServerModel>>(url, { params })
  96                .pipe(
  97                  map(res => VideoChannelService.extractVideoChannels(res)),
  98                  catchError(err => this.restExtractor.handleError(err))
  99                )
 100   }
 101
 102   searchVideoPlaylists (parameters: {
 103     search?: string
 104     advancedSearch?: AdvancedSearch
 105     componentPagination?: ComponentPaginationLight
 106     uuids?: string[]
 107   }): Observable<ResultList<VideoPlaylist>> {
 108     const { search, advancedSearch, componentPagination, uuids } = parameters
 109
 110     const url = SearchService.BASE_SEARCH_URL + 'video-playlists'
 111
 112     let pagination: RestPagination
 113     if (componentPagination) {
 114       pagination = this.restService.componentPaginationToRestPagination(componentPagination)
 115     }
 116
 117     let params = new HttpParams()
 118     params = this.restService.addRestGetParams(params, pagination)
 119
 120     if (search) params = params.append('search', search)
 121     if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
 122
 123     if (advancedSearch) {
 124       const advancedSearchObject = advancedSearch.toPlaylistAPIObject()
 125       params = this.restService.addObjectParams(params, advancedSearchObject)
 126     }
 127
 128     return this.authHttp
 129                .get<ResultList<VideoPlaylistServerModel>>(url, { params })
 130                .pipe(
 131                  switchMap(res => this.playlistService.extractPlaylists(res)),
 132                  catchError(err => this.restExtractor.handleError(err))
 133                )
 134   }
 135 }