client/src/app/videos/recommendations/recent-videos-recommendation.service.ts

   1 import { Injectable, OnInit } from '@angular/core'
   2 import { RecommendationService } from '@app/videos/recommendations/recommendations.service'
   3 import { Video } from '@app/shared/video/video.model'
   4 import { RecommendationInfo } from '@app/shared/video/recommendation-info.model'
   5 import { VideoService } from '@app/shared/video/video.service'
   6 import { map, switchMap } from 'rxjs/operators'
   7 import { Observable, of } from 'rxjs'
   8 import { SearchService } from '@app/search/search.service'
   9 import { AdvancedSearch } from '@app/search/advanced-search.model'
  10 import { ServerService } from '@app/core'
  11 import { ServerConfig } from '@shared/models'
  12 import { truncate } from 'lodash'
  13
  14 /**
  15  * Provides "recommendations" by providing the most recently uploaded videos.
  16  */
  17 @Injectable()
  18 export class RecentVideosRecommendationService implements RecommendationService {
  19   readonly pageSize = 5
  20
  21   private config: ServerConfig
  22
  23   constructor (
  24     private videos: VideoService,
  25     private searchService: SearchService,
  26     private serverService: ServerService
  27   ) {
  28     this.config = this.serverService.getTmpConfig()
  29
  30     this.serverService.getConfig()
  31      .subscribe(config => this.config = config)
  32    }
  33
  34   getRecommendations (recommendation: RecommendationInfo): Observable<Video[]> {
  35     return this.fetchPage(1, recommendation)
  36       .pipe(
  37         map(videos => {
  38           const otherVideos = videos.filter(v => v.uuid !== recommendation.uuid)
  39           return otherVideos.slice(0, this.pageSize)
  40         })
  41       )
  42   }
  43
  44   private fetchPage (page: number, recommendation: RecommendationInfo): Observable<Video[]> {
  45     const pagination = { currentPage: page, itemsPerPage: this.pageSize + 1 }
  46     const defaultSubscription = this.videos.getVideos({ videoPagination: pagination, sort: '-createdAt' })
  47                                     .pipe(map(v => v.data))
  48
  49     const tags = recommendation.tags
  50     const searchIndexConfig = this.config.search.searchIndex
  51     if (
  52       !tags || tags.length === 0 ||
  53       (searchIndexConfig.enabled === true && searchIndexConfig.disableLocalSearch === true)
  54     ) {
  55       return defaultSubscription
  56     }
  57
  58     const params = {
  59       search: '',
  60       componentPagination: pagination,
  61       advancedSearch: new AdvancedSearch({ tagsOneOf: recommendation.tags.join(','), sort: '-createdAt', searchTarget: 'local' })
  62     }
  63
  64     return this.searchService.searchVideos(params)
  65                .pipe(
  66                  map(v => v.data),
  67                  switchMap(videos => {
  68                    if (videos.length <= 1) return defaultSubscription
  69
  70                    return of(videos)
  71                  })
  72                )
  73   }
  74 }