2021-08-02 13:29:09 +00:00
|
|
|
import * as debug from 'debug'
|
2021-08-17 09:27:47 +00:00
|
|
|
import { Observable, Subject } from 'rxjs'
|
2021-08-02 14:50:56 +00:00
|
|
|
import { first, map } from 'rxjs/operators'
|
2021-10-14 09:50:22 +00:00
|
|
|
import { Injectable } from '@angular/core'
|
2021-08-02 13:29:09 +00:00
|
|
|
import { buildBulkObservable } from '@app/helpers'
|
|
|
|
import { ResultList } from '@shared/models/common'
|
|
|
|
import { Video, VideoChannel } from '../shared-main'
|
|
|
|
import { VideoPlaylist } from '../shared-video-playlist'
|
|
|
|
import { SearchService } from './search.service'
|
|
|
|
|
|
|
|
const logger = debug('peertube:search:FindInBulkService')
|
|
|
|
|
|
|
|
type BulkObservables <P extends number | string, R> = {
|
|
|
|
notifier: Subject<P>
|
|
|
|
result: Observable<R>
|
|
|
|
}
|
|
|
|
|
|
|
|
@Injectable()
|
|
|
|
export class FindInBulkService {
|
|
|
|
|
|
|
|
private getVideoInBulk: BulkObservables<string, ResultList<Video>>
|
|
|
|
private getChannelInBulk: BulkObservables<string, ResultList<VideoChannel>>
|
|
|
|
private getPlaylistInBulk: BulkObservables<string, ResultList<VideoPlaylist>>
|
|
|
|
|
|
|
|
constructor (
|
2021-10-14 09:50:22 +00:00
|
|
|
private searchService: SearchService
|
2021-08-02 13:29:09 +00:00
|
|
|
) {
|
|
|
|
this.getVideoInBulk = this.buildBulkObservableObject(this.getVideosInBulk.bind(this))
|
|
|
|
this.getChannelInBulk = this.buildBulkObservableObject(this.getChannelsInBulk.bind(this))
|
|
|
|
this.getPlaylistInBulk = this.buildBulkObservableObject(this.getPlaylistsInBulk.bind(this))
|
|
|
|
}
|
|
|
|
|
|
|
|
getVideo (uuid: string): Observable<Video> {
|
|
|
|
logger('Schedule video fetch for uuid %s.', uuid)
|
|
|
|
|
|
|
|
return this.getData({
|
|
|
|
observableObject: this.getVideoInBulk,
|
|
|
|
finder: v => v.uuid === uuid,
|
|
|
|
param: uuid
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
getChannel (handle: string): Observable<VideoChannel> {
|
|
|
|
logger('Schedule channel fetch for handle %s.', handle)
|
|
|
|
|
|
|
|
return this.getData({
|
|
|
|
observableObject: this.getChannelInBulk,
|
|
|
|
finder: c => c.nameWithHost === handle || c.nameWithHostForced === handle,
|
|
|
|
param: handle
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
getPlaylist (uuid: string): Observable<VideoPlaylist> {
|
|
|
|
logger('Schedule playlist fetch for uuid %s.', uuid)
|
|
|
|
|
|
|
|
return this.getData({
|
|
|
|
observableObject: this.getPlaylistInBulk,
|
|
|
|
finder: p => p.uuid === uuid,
|
|
|
|
param: uuid
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
private getData <P extends number | string, R> (options: {
|
|
|
|
observableObject: BulkObservables<P, ResultList<R>>
|
|
|
|
param: P
|
|
|
|
finder: (d: R) => boolean
|
|
|
|
}) {
|
|
|
|
const { observableObject, param, finder } = options
|
|
|
|
|
|
|
|
return new Observable<R>(obs => {
|
|
|
|
observableObject.result
|
|
|
|
.pipe(
|
2021-08-02 14:50:56 +00:00
|
|
|
first(),
|
2021-08-02 13:29:09 +00:00
|
|
|
map(({ data }) => data),
|
|
|
|
map(data => data.find(finder))
|
|
|
|
)
|
|
|
|
.subscribe(result => {
|
2021-08-02 14:50:56 +00:00
|
|
|
if (!result) {
|
|
|
|
obs.error(new Error($localize`Element ${param} not found`))
|
|
|
|
} else {
|
|
|
|
obs.next(result)
|
|
|
|
obs.complete()
|
|
|
|
}
|
2021-08-02 13:29:09 +00:00
|
|
|
})
|
|
|
|
|
|
|
|
observableObject.notifier.next(param)
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
private getVideosInBulk (uuids: string[]) {
|
|
|
|
logger('Fetching videos %s.', uuids.join(', '))
|
|
|
|
|
|
|
|
return this.searchService.searchVideos({ uuids })
|
|
|
|
}
|
|
|
|
|
|
|
|
private getChannelsInBulk (handles: string[]) {
|
|
|
|
logger('Fetching channels %s.', handles.join(', '))
|
|
|
|
|
|
|
|
return this.searchService.searchVideoChannels({ handles })
|
|
|
|
}
|
|
|
|
|
|
|
|
private getPlaylistsInBulk (uuids: string[]) {
|
|
|
|
logger('Fetching playlists %s.', uuids.join(', '))
|
|
|
|
|
|
|
|
return this.searchService.searchVideoPlaylists({ uuids })
|
|
|
|
}
|
|
|
|
|
|
|
|
private buildBulkObservableObject <T extends number | string, R> (bulkGet: (params: T[]) => Observable<R>) {
|
|
|
|
const notifier = new Subject<T>()
|
|
|
|
|
|
|
|
return {
|
|
|
|
notifier,
|
|
|
|
|
|
|
|
result: buildBulkObservable({
|
|
|
|
time: 500,
|
|
|
|
bulkGet,
|
|
|
|
notifierObservable: notifier.asObservable()
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|