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