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