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

   1 import { Observable, of } from 'rxjs'
   2 import { map, switchMap } from 'rxjs/operators'
   3 import { Injectable } from '@angular/core'
   4 import { ServerService } from '@app/core'
   5 import { AdvancedSearch } from '@app/search/advanced-search.model'
   6 import { SearchService } from '@app/search/search.service'
   7 import { UserService } from '@app/shared'
   8 import { RecommendationInfo } from '@app/shared/video/recommendation-info.model'
   9 import { Video } from '@app/shared/video/video.model'
  10 import { VideoService } from '@app/shared/video/video.service'
  11 import { RecommendationService } from '@app/videos/recommendations/recommendations.service'
  12 import { ServerConfig } from '@shared/models'
  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 userService: UserService,
  27     private serverService: ServerService
  28   ) {
  29     this.config = this.serverService.getTmpConfig()
  30
  31     this.serverService.getConfig()
  32      .subscribe(config => this.config = config)
  33   }
  34
  35   getRecommendations (recommendation: RecommendationInfo): Observable<Video[]> {
  36     return this.fetchPage(1, recommendation)
  37       .pipe(
  38         map(videos => {
  39           const otherVideos = videos.filter(v => v.uuid !== recommendation.uuid)
  40           return otherVideos.slice(0, this.pageSize)
  41         })
  42       )
  43   }
  44
  45   private fetchPage (page: number, recommendation: RecommendationInfo): Observable<Video[]> {
  46     const pagination = { currentPage: page, itemsPerPage: this.pageSize + 1 }
  47     const defaultSubscription = this.videos.getVideos({ videoPagination: pagination, sort: '-createdAt' })
  48                                     .pipe(map(v => v.data))
  49
  50     const tags = recommendation.tags
  51     const searchIndexConfig = this.config.search.searchIndex
  52     if (
  53       !tags || tags.length === 0 ||
  54       (searchIndexConfig.enabled === true && searchIndexConfig.disableLocalSearch === true)
  55     ) {
  56       return defaultSubscription
  57     }
  58
  59     return this.userService.getAnonymousOrLoggedUser()
  60       .pipe(
  61         map(user => {
  62           return {
  63             search: '',
  64             componentPagination: pagination,
  65             advancedSearch: new AdvancedSearch({
  66               tagsOneOf: recommendation.tags.join(','),
  67               sort: '-createdAt',
  68               searchTarget: 'local',
  69               nsfw: user.nsfwPolicy
  70                 ? this.videos.nsfwPolicyToParam(user.nsfwPolicy)
  71                 : undefined
  72             })
  73           }
  74         }),
  75         switchMap(params => this.searchService.searchVideos(params)),
  76         map(v => v.data),
  77         switchMap(videos => {
  78           if (videos.length <= 1) return defaultSubscription
  79
  80           return of(videos)
  81         })
  82       )
  83   }
  84 }