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 { peertubeLocalStorage } from '@app/helpers'
   7 import { Video, VideoChannel, VideoChannelService, VideoService } from '@app/shared/shared-main'
   8 import { ResultList, SearchTargetType, Video as VideoServerModel, VideoChannel as VideoChannelServerModel } from '@shared/models'
   9 import { environment } from '../../../environments/environment'
  10 import { AdvancedSearch } from './advanced-search.model'
  11
  12 @Injectable()
  13 export class SearchService {
  14   static BASE_SEARCH_URL = environment.apiUrl + '/api/v1/search/'
  15
  16   constructor (
  17     private authHttp: HttpClient,
  18     private restExtractor: RestExtractor,
  19     private restService: RestService,
  20     private videoService: VideoService
  21   ) {
  22     // Add ability to override search endpoint if the user updated this local storage key
  23     const searchUrl = peertubeLocalStorage.getItem('search-url')
  24     if (searchUrl) SearchService.BASE_SEARCH_URL = searchUrl
  25   }
  26
  27   searchVideos (parameters: {
  28     search: string,
  29     componentPagination?: ComponentPaginationLight,
  30     advancedSearch?: AdvancedSearch
  31   }): Observable<ResultList<Video>> {
  32     const { search, componentPagination, advancedSearch } = parameters
  33
  34     const url = SearchService.BASE_SEARCH_URL + 'videos'
  35     let pagination: RestPagination
  36
  37     if (componentPagination) {
  38       pagination = this.restService.componentPaginationToRestPagination(componentPagination)
  39     }
  40
  41     let params = new HttpParams()
  42     params = this.restService.addRestGetParams(params, pagination)
  43
  44     if (search) params = params.append('search', search)
  45
  46     if (advancedSearch) {
  47       const advancedSearchObject = advancedSearch.toAPIObject()
  48       params = this.restService.addObjectParams(params, advancedSearchObject)
  49     }
  50
  51     return this.authHttp
  52                .get<ResultList<VideoServerModel>>(url, { params })
  53                .pipe(
  54                  switchMap(res => this.videoService.extractVideos(res)),
  55                  catchError(err => this.restExtractor.handleError(err))
  56                )
  57   }
  58
  59   searchVideoChannels (parameters: {
  60     search: string,
  61     searchTarget?: SearchTargetType,
  62     componentPagination?: ComponentPaginationLight
  63   }): Observable<ResultList<VideoChannel>> {
  64     const { search, componentPagination, searchTarget } = parameters
  65
  66     const url = SearchService.BASE_SEARCH_URL + 'video-channels'
  67
  68     let pagination: RestPagination
  69     if (componentPagination) {
  70       pagination = this.restService.componentPaginationToRestPagination(componentPagination)
  71     }
  72
  73     let params = new HttpParams()
  74     params = this.restService.addRestGetParams(params, pagination)
  75     params = params.append('search', search)
  76
  77     if (searchTarget) {
  78       params = params.append('searchTarget', searchTarget as string)
  79     }
  80
  81     return this.authHttp
  82                .get<ResultList<VideoChannelServerModel>>(url, { params })
  83                .pipe(
  84                  map(res => VideoChannelService.extractVideoChannels(res)),
  85                  catchError(err => this.restExtractor.handleError(err))
  86                )
  87   }
  88 }