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'
11 Video as VideoServerModel,
12 VideoChannel as VideoChannelServerModel,
13 VideoPlaylist as VideoPlaylistServerModel
14 } from '@shared/models'
15 import { environment } from '../../../environments/environment'
16 import { VideoPlaylist, VideoPlaylistService } from '../shared-video-playlist'
17 import { AdvancedSearch } from './advanced-search.model'
20 export class SearchService {
21 static BASE_SEARCH_URL = environment.apiUrl + '/api/v1/search/'
24 private authHttp: HttpClient,
25 private restExtractor: RestExtractor,
26 private restService: RestService,
27 private videoService: VideoService,
28 private playlistService: VideoPlaylistService
30 // Add ability to override search endpoint if the user updated this local storage key
31 const searchUrl = peertubeLocalStorage.getItem('search-url')
32 if (searchUrl) SearchService.BASE_SEARCH_URL = searchUrl
35 searchVideos (parameters: {
37 componentPagination?: ComponentPaginationLight,
38 advancedSearch?: AdvancedSearch
39 }): Observable<ResultList<Video>> {
40 const { search, componentPagination, advancedSearch } = parameters
42 const url = SearchService.BASE_SEARCH_URL + 'videos'
43 let pagination: RestPagination
45 if (componentPagination) {
46 pagination = this.restService.componentPaginationToRestPagination(componentPagination)
49 let params = new HttpParams()
50 params = this.restService.addRestGetParams(params, pagination)
52 if (search) params = params.append('search', search)
55 const advancedSearchObject = advancedSearch.toAPIObject()
56 params = this.restService.addObjectParams(params, advancedSearchObject)
60 .get<ResultList<VideoServerModel>>(url, { params })
62 switchMap(res => this.videoService.extractVideos(res)),
63 catchError(err => this.restExtractor.handleError(err))
67 searchVideoChannels (parameters: {
69 searchTarget?: SearchTargetType,
70 componentPagination?: ComponentPaginationLight
71 }): Observable<ResultList<VideoChannel>> {
72 const { search, componentPagination, searchTarget } = parameters
74 const url = SearchService.BASE_SEARCH_URL + 'video-channels'
76 let pagination: RestPagination
77 if (componentPagination) {
78 pagination = this.restService.componentPaginationToRestPagination(componentPagination)
81 let params = new HttpParams()
82 params = this.restService.addRestGetParams(params, pagination)
83 params = params.append('search', search)
86 params = params.append('searchTarget', searchTarget as string)
90 .get<ResultList<VideoChannelServerModel>>(url, { params })
92 map(res => VideoChannelService.extractVideoChannels(res)),
93 catchError(err => this.restExtractor.handleError(err))
97 searchVideoPlaylists (parameters: {
99 searchTarget?: SearchTargetType,
100 componentPagination?: ComponentPaginationLight
101 }): Observable<ResultList<VideoPlaylist>> {
102 const { search, componentPagination, searchTarget } = parameters
104 const url = SearchService.BASE_SEARCH_URL + 'video-playlists'
106 let pagination: RestPagination
107 if (componentPagination) {
108 pagination = this.restService.componentPaginationToRestPagination(componentPagination)
111 let params = new HttpParams()
112 params = this.restService.addRestGetParams(params, pagination)
113 params = params.append('search', search)
116 params = params.append('searchTarget', searchTarget as string)
120 .get<ResultList<VideoPlaylistServerModel>>(url, { params })
122 switchMap(res => this.playlistService.extractPlaylists(res)),
123 catchError(err => this.restExtractor.handleError(err))