Fetch things in bulk for the homepage

4 files changed, 133 insertions, 6 deletions

diff --git a/client/src/app/shared/shared-search/find-in-bulk.service.ts b/client/src/app/shared/shared-search/find-in-bulk.service.ts
new file mode 100644
index 000000000..0383d8648
--- /dev/null
+++ b/client/src/app/shared/shared-search/find-in-bulk.service.ts
@@ -0,0 +1,118 @@
+import * as debug from 'debug'
+import { Observable, Subject } from 'rxjs'
+import { map } from 'rxjs/operators'
+import { Injectable, NgZone } from '@angular/core'
+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 (
+    private searchService: SearchService,
+    private ngZone: NgZone
+  ) {
+    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(
+          map(({ data }) => data),
+          map(data => data.find(finder))
+        )
+        .subscribe(result => {
+          obs.next(result)
+          obs.complete()
+        })
+
+      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,
+        ngZone: this.ngZone,
+        notifierObservable: notifier.asObservable()
+      })
+    }
+  }
+}
diff --git a/client/src/app/shared/shared-search/index.ts b/client/src/app/shared/shared-search/index.ts
index f687f6767..0235893c4 100644
--- a/client/src/app/shared/shared-search/index.ts
+++ b/client/src/app/shared/shared-search/index.ts
@@ -1,3 +1,4 @@
 export * from './advanced-search.model'
+export * from './find-in-bulk.service'
 export * from './search.service'
 export * from './shared-search.module'
diff --git a/client/src/app/shared/shared-search/search.service.ts b/client/src/app/shared/shared-search/search.service.ts
index a1603da98..fdfab0e0e 100644
--- a/client/src/app/shared/shared-search/search.service.ts
+++ b/client/src/app/shared/shared-search/search.service.ts
@@ -32,11 +32,12 @@ export class SearchService {
   }
 
   searchVideos (parameters: {
-    search: string
+    search?: string
     componentPagination?: ComponentPaginationLight
     advancedSearch?: AdvancedSearch
+    uuids?: string[]
   }): Observable<ResultList<Video>> {
-    const { search, componentPagination, advancedSearch } = parameters
+    const { search, uuids, componentPagination, advancedSearch } = parameters
 
     const url = SearchService.BASE_SEARCH_URL + 'videos'
     let pagination: RestPagination
@@ -49,6 +50,7 @@ export class SearchService {
     params = this.restService.addRestGetParams(params, pagination)
 
     if (search) params = params.append('search', search)
+    if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
 
     if (advancedSearch) {
       const advancedSearchObject = advancedSearch.toVideosAPIObject()
@@ -64,11 +66,12 @@ export class SearchService {
   }
 
   searchVideoChannels (parameters: {
-    search: string
+    search?: string
     advancedSearch?: AdvancedSearch
     componentPagination?: ComponentPaginationLight
+    handles?: string[]
   }): Observable<ResultList<VideoChannel>> {
-    const { search, advancedSearch, componentPagination } = parameters
+    const { search, advancedSearch, componentPagination, handles } = parameters
 
     const url = SearchService.BASE_SEARCH_URL + 'video-channels'
 
@@ -81,6 +84,7 @@ export class SearchService {
     params = this.restService.addRestGetParams(params, pagination)
 
     if (search) params = params.append('search', search)
+    if (handles) params = this.restService.addArrayParams(params, 'handles', handles)
 
     if (advancedSearch) {
       const advancedSearchObject = advancedSearch.toChannelAPIObject()
@@ -96,11 +100,12 @@ export class SearchService {
   }
 
   searchVideoPlaylists (parameters: {
-    search: string
+    search?: string
     advancedSearch?: AdvancedSearch
     componentPagination?: ComponentPaginationLight
+    uuids?: string[]
   }): Observable<ResultList<VideoPlaylist>> {
-    const { search, advancedSearch, componentPagination } = parameters
+    const { search, advancedSearch, componentPagination, uuids } = parameters
 
     const url = SearchService.BASE_SEARCH_URL + 'video-playlists'
 
@@ -113,6 +118,7 @@ export class SearchService {
     params = this.restService.addRestGetParams(params, pagination)
 
     if (search) params = params.append('search', search)
+    if (uuids) params = this.restService.addArrayParams(params, 'uuids', uuids)
 
     if (advancedSearch) {
       const advancedSearchObject = advancedSearch.toPlaylistAPIObject()
diff --git a/client/src/app/shared/shared-search/shared-search.module.ts b/client/src/app/shared/shared-search/shared-search.module.ts
index be4ef5e3f..8b5492400 100644
--- a/client/src/app/shared/shared-search/shared-search.module.ts
+++ b/client/src/app/shared/shared-search/shared-search.module.ts
@@ -1,6 +1,7 @@
 import { NgModule } from '@angular/core'
 import { SharedMainModule } from '../shared-main'
 import { SharedVideoPlaylistModule } from '../shared-video-playlist'
+import { FindInBulkService } from './find-in-bulk.service'
 import { SearchService } from './search.service'
 
 @NgModule({
@@ -16,6 +17,7 @@ import { SearchService } from './search.service'
   ],
 
   providers: [
+    FindInBulkService,
     SearchService
   ]
 })