1 import { forkJoin, Observable, of } from 'rxjs'
2 import { catchError, map, switchMap, tap } from 'rxjs/operators'
3 import { HttpClient, HttpParams } from '@angular/common/http'
4 import { Injectable } from '@angular/core'
5 import { RestExtractor, ServerService } from '@app/core'
6 import { immutableAssign } from '@app/helpers'
7 import { VideoService } from '@app/shared/shared-main'
8 import { peertubeTranslate, VideosOverview as VideosOverviewServer } from '@shared/models'
9 import { environment } from '../../../../environments/environment'
10 import { VideosOverview } from './videos-overview.model'
13 export class OverviewService {
14 static BASE_OVERVIEW_URL = environment.apiUrl + '/api/v1/overviews/'
17 private authHttp: HttpClient,
18 private restExtractor: RestExtractor,
19 private videosService: VideoService,
20 private serverService: ServerService
23 getVideosOverview (page: number): Observable<VideosOverview> {
24 let params = new HttpParams()
25 params = params.append('page', page + '')
28 .get<VideosOverviewServer>(OverviewService.BASE_OVERVIEW_URL + 'videos', { params })
30 switchMap(serverVideosOverview => this.updateVideosOverview(serverVideosOverview)),
31 catchError(err => this.restExtractor.handleError(err))
35 private updateVideosOverview (serverVideosOverview: VideosOverviewServer): Observable<VideosOverview> {
36 const observables: Observable<any>[] = []
37 const videosOverviewResult: VideosOverview = {
43 // Build videos objects
44 for (const key of Object.keys(serverVideosOverview)) {
45 for (const object of serverVideosOverview[ key ]) {
49 switchMap(videos => this.videosService.extractVideos({ total: 0, data: videos })),
50 map(result => result.data),
52 videosOverviewResult[key].push(immutableAssign(object, { videos }))
59 if (observables.length === 0) return of(videosOverviewResult)
61 return forkJoin(observables)
63 // Translate categories
65 return this.serverService.getServerLocale()
68 for (const c of videosOverviewResult.categories) {
69 c.category.label = peertubeTranslate(c.category.label, translations)
74 map(() => videosOverviewResult)