2020-05-29 14:16:24 +00:00
|
|
|
import { Observable } from 'rxjs'
|
2018-08-23 15:58:39 +00:00
|
|
|
import { catchError, map, switchMap } from 'rxjs/operators'
|
2018-07-19 14:17:54 +00:00
|
|
|
import { HttpClient, HttpParams } from '@angular/common/http'
|
|
|
|
import { Injectable } from '@angular/core'
|
2020-06-23 12:10:17 +00:00
|
|
|
import { ComponentPaginationLight, RestExtractor, RestPagination, RestService } from '@app/core'
|
|
|
|
import { Video, VideoChannel, VideoChannelService, VideoService } from '@app/shared/shared-main'
|
2021-06-17 14:02:38 +00:00
|
|
|
import { peertubeLocalStorage } from '@root-helpers/peertube-web-storage'
|
|
|
|
import {
|
|
|
|
ResultList,
|
|
|
|
Video as VideoServerModel,
|
|
|
|
VideoChannel as VideoChannelServerModel,
|
|
|
|
VideoPlaylist as VideoPlaylistServerModel
|
|
|
|
} from '@shared/models'
|
2020-06-23 12:49:20 +00:00
|
|
|
import { environment } from '../../../environments/environment'
|
2021-06-17 14:02:38 +00:00
|
|
|
import { VideoPlaylist, VideoPlaylistService } from '../shared-video-playlist'
|
2020-06-23 12:49:20 +00:00
|
|
|
import { AdvancedSearch } from './advanced-search.model'
|
2018-07-19 14:17:54 +00:00
|
|
|
|
|
|
|
@Injectable()
|
|
|
|
export class SearchService {
|
|
|
|
static BASE_SEARCH_URL = environment.apiUrl + '/api/v1/search/'
|
|
|
|
|
|
|
|
constructor (
|
|
|
|
private authHttp: HttpClient,
|
|
|
|
private restExtractor: RestExtractor,
|
|
|
|
private restService: RestService,
|
2021-06-17 14:02:38 +00:00
|
|
|
private videoService: VideoService,
|
|
|
|
private playlistService: VideoPlaylistService
|
2020-03-04 15:11:21 +00:00
|
|
|
) {
|
|
|
|
// Add ability to override search endpoint if the user updated this local storage key
|
|
|
|
const searchUrl = peertubeLocalStorage.getItem('search-url')
|
|
|
|
if (searchUrl) SearchService.BASE_SEARCH_URL = searchUrl
|
|
|
|
}
|
2018-07-19 14:17:54 +00:00
|
|
|
|
2019-07-22 13:40:13 +00:00
|
|
|
searchVideos (parameters: {
|
2021-08-02 13:29:09 +00:00
|
|
|
search?: string
|
2021-07-29 13:19:22 +00:00
|
|
|
componentPagination?: ComponentPaginationLight
|
2020-05-29 14:16:24 +00:00
|
|
|
advancedSearch?: AdvancedSearch
|
2021-08-02 13:29:09 +00:00
|
|
|
uuids?: string[]
|
2019-07-22 13:40:13 +00:00
|
|
|
}): Observable<ResultList<Video>> {
|
2021-08-02 13:29:09 +00:00
|
|
|
const { search, uuids, componentPagination, advancedSearch } = parameters
|
2018-07-19 14:17:54 +00:00
|
|
|
|
2019-07-22 13:40:13 +00:00
|
|
|
const url = SearchService.BASE_SEARCH_URL + 'videos'
|
2020-05-29 14:16:24 +00:00
|
|
|
let pagination: RestPagination
|
|
|
|
|
|
|
|
if (componentPagination) {
|
|
|
|
pagination = this.restService.componentPaginationToRestPagination(componentPagination)
|
|
|
|
}
|
2018-07-19 14:17:54 +00:00
|
|
|
|
|
|
|
let params = new HttpParams()
|
|
|
|
params = this.restService.addRestGetParams(params, pagination)
|
2018-07-24 09:40:04 +00:00
|
|
|
|
|
|
|
if (search) params = params.append('search', search)
|
2021-08-02 13:29:09 +00:00
|
|
|
if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
|
2018-07-19 14:17:54 +00:00
|
|
|
|
2020-05-29 14:16:24 +00:00
|
|
|
if (advancedSearch) {
|
2021-07-29 13:19:22 +00:00
|
|
|
const advancedSearchObject = advancedSearch.toVideosAPIObject()
|
2020-05-29 14:16:24 +00:00
|
|
|
params = this.restService.addObjectParams(params, advancedSearchObject)
|
|
|
|
}
|
2018-07-20 16:31:49 +00:00
|
|
|
|
2018-07-19 14:17:54 +00:00
|
|
|
return this.authHttp
|
|
|
|
.get<ResultList<VideoServerModel>>(url, { params })
|
|
|
|
.pipe(
|
|
|
|
switchMap(res => this.videoService.extractVideos(res)),
|
|
|
|
catchError(err => this.restExtractor.handleError(err))
|
|
|
|
)
|
|
|
|
}
|
2018-08-23 15:58:39 +00:00
|
|
|
|
2019-07-22 13:40:13 +00:00
|
|
|
searchVideoChannels (parameters: {
|
2021-08-02 13:29:09 +00:00
|
|
|
search?: string
|
2021-07-29 13:19:22 +00:00
|
|
|
advancedSearch?: AdvancedSearch
|
2020-05-29 14:16:24 +00:00
|
|
|
componentPagination?: ComponentPaginationLight
|
2021-08-02 13:29:09 +00:00
|
|
|
handles?: string[]
|
2019-07-22 13:40:13 +00:00
|
|
|
}): Observable<ResultList<VideoChannel>> {
|
2021-08-02 13:29:09 +00:00
|
|
|
const { search, advancedSearch, componentPagination, handles } = parameters
|
2018-08-23 15:58:39 +00:00
|
|
|
|
2019-07-22 13:40:13 +00:00
|
|
|
const url = SearchService.BASE_SEARCH_URL + 'video-channels'
|
2020-05-29 14:16:24 +00:00
|
|
|
|
|
|
|
let pagination: RestPagination
|
|
|
|
if (componentPagination) {
|
|
|
|
pagination = this.restService.componentPaginationToRestPagination(componentPagination)
|
|
|
|
}
|
2018-08-23 15:58:39 +00:00
|
|
|
|
|
|
|
let params = new HttpParams()
|
|
|
|
params = this.restService.addRestGetParams(params, pagination)
|
2021-07-29 13:51:19 +00:00
|
|
|
|
|
|
|
if (search) params = params.append('search', search)
|
2021-08-02 13:29:09 +00:00
|
|
|
if (handles) params = this.restService.addArrayParams(params, 'handles', handles)
|
2018-08-23 15:58:39 +00:00
|
|
|
|
2021-07-29 13:19:22 +00:00
|
|
|
if (advancedSearch) {
|
|
|
|
const advancedSearchObject = advancedSearch.toChannelAPIObject()
|
|
|
|
params = this.restService.addObjectParams(params, advancedSearchObject)
|
2020-05-29 14:16:24 +00:00
|
|
|
}
|
|
|
|
|
2018-08-23 15:58:39 +00:00
|
|
|
return this.authHttp
|
|
|
|
.get<ResultList<VideoChannelServerModel>>(url, { params })
|
|
|
|
.pipe(
|
|
|
|
map(res => VideoChannelService.extractVideoChannels(res)),
|
|
|
|
catchError(err => this.restExtractor.handleError(err))
|
|
|
|
)
|
|
|
|
}
|
2021-06-17 14:02:38 +00:00
|
|
|
|
|
|
|
searchVideoPlaylists (parameters: {
|
2021-08-02 13:29:09 +00:00
|
|
|
search?: string
|
2021-07-29 13:19:22 +00:00
|
|
|
advancedSearch?: AdvancedSearch
|
2021-06-17 14:02:38 +00:00
|
|
|
componentPagination?: ComponentPaginationLight
|
2021-08-02 13:29:09 +00:00
|
|
|
uuids?: string[]
|
2021-06-17 14:02:38 +00:00
|
|
|
}): Observable<ResultList<VideoPlaylist>> {
|
2021-08-02 13:29:09 +00:00
|
|
|
const { search, advancedSearch, componentPagination, uuids } = parameters
|
2021-06-17 14:02:38 +00:00
|
|
|
|
|
|
|
const url = SearchService.BASE_SEARCH_URL + 'video-playlists'
|
|
|
|
|
|
|
|
let pagination: RestPagination
|
|
|
|
if (componentPagination) {
|
|
|
|
pagination = this.restService.componentPaginationToRestPagination(componentPagination)
|
|
|
|
}
|
|
|
|
|
|
|
|
let params = new HttpParams()
|
|
|
|
params = this.restService.addRestGetParams(params, pagination)
|
2021-07-29 13:51:19 +00:00
|
|
|
|
|
|
|
if (search) params = params.append('search', search)
|
2021-08-02 13:29:09 +00:00
|
|
|
if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
|
2021-06-17 14:02:38 +00:00
|
|
|
|
2021-07-29 13:19:22 +00:00
|
|
|
if (advancedSearch) {
|
|
|
|
const advancedSearchObject = advancedSearch.toPlaylistAPIObject()
|
|
|
|
params = this.restService.addObjectParams(params, advancedSearchObject)
|
2021-06-17 14:02:38 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
return this.authHttp
|
|
|
|
.get<ResultList<VideoPlaylistServerModel>>(url, { params })
|
|
|
|
.pipe(
|
|
|
|
switchMap(res => this.playlistService.extractPlaylists(res)),
|
|
|
|
catchError(err => this.restExtractor.handleError(err))
|
|
|
|
)
|
|
|
|
}
|
2018-07-19 14:17:54 +00:00
|
|
|
}
|