client/src/app/shared/video/abstract-video-list.ts

   1 import { ElementRef, OnDestroy, OnInit, ViewChild } from '@angular/core'
   2 import { ActivatedRoute, Router } from '@angular/router'
   3 import { isInMobileView } from '@app/shared/misc/utils'
   4 import { InfiniteScrollerDirective } from '@app/shared/video/infinite-scroller.directive'
   5 import { NotificationsService } from 'angular2-notifications'
   6 import 'rxjs/add/operator/debounceTime'
   7 import { Observable } from 'rxjs/Observable'
   8 import { fromEvent } from 'rxjs/observable/fromEvent'
   9 import { Subscription } from 'rxjs/Subscription'
  10 import { AuthService } from '../../core/auth'
  11 import { ComponentPagination } from '../rest/component-pagination.model'
  12 import { SortField } from './sort-field.type'
  13 import { Video } from './video.model'
  14
  15 export abstract class AbstractVideoList implements OnInit, OnDestroy {
  16   private static LINES_PER_PAGE = 3
  17
  18   @ViewChild('videoElement') videosElement: ElementRef
  19   @ViewChild(InfiniteScrollerDirective) infiniteScroller: InfiniteScrollerDirective
  20
  21   pagination: ComponentPagination = {
  22     currentPage: 1,
  23     itemsPerPage: 10,
  24     totalItems: null
  25   }
  26   sort: SortField = '-createdAt'
  27   defaultSort: SortField = '-createdAt'
  28   loadOnInit = true
  29   pageHeight: number
  30   videoWidth: number
  31   videoHeight: number
  32   videoPages: Video[][] = []
  33
  34   protected baseVideoWidth = 215
  35   protected baseVideoHeight = 230
  36
  37   protected abstract notificationsService: NotificationsService
  38   protected abstract authService: AuthService
  39   protected abstract router: Router
  40   protected abstract route: ActivatedRoute
  41   protected abstract currentRoute: string
  42   abstract titlePage: string
  43
  44   protected loadedPages: { [ id: number ]: Video[] } = {}
  45   protected otherRouteParams = {}
  46
  47   private resizeSubscription: Subscription
  48
  49   abstract getVideosObservable (page: number): Observable<{ videos: Video[], totalVideos: number}>
  50
  51   get user () {
  52     return this.authService.getUser()
  53   }
  54
  55   ngOnInit () {
  56     // Subscribe to route changes
  57     const routeParams = this.route.snapshot.params
  58     this.loadRouteParams(routeParams)
  59
  60     this.resizeSubscription = fromEvent(window, 'resize')
  61       .debounceTime(500)
  62       .subscribe(() => this.calcPageSizes())
  63
  64     this.calcPageSizes()
  65     if (this.loadOnInit === true) this.loadMoreVideos(this.pagination.currentPage)
  66   }
  67
  68   ngOnDestroy () {
  69     if (this.resizeSubscription) this.resizeSubscription.unsubscribe()
  70   }
  71
  72   onNearOfTop () {
  73     this.previousPage()
  74   }
  75
  76   onNearOfBottom () {
  77     if (this.hasMoreVideos()) {
  78       this.nextPage()
  79     }
  80   }
  81
  82   onPageChanged (page: number) {
  83     this.pagination.currentPage = page
  84     this.setNewRouteParams()
  85   }
  86
  87   reloadVideos () {
  88     this.loadedPages = {}
  89     this.loadMoreVideos(this.pagination.currentPage)
  90   }
  91
  92   loadMoreVideos (page: number) {
  93     if (this.loadedPages[page] !== undefined) return
  94
  95     const observable = this.getVideosObservable(page)
  96
  97     observable.subscribe(
  98       ({ videos, totalVideos }) => {
  99         // Paging is too high, return to the first one
 100         if (this.pagination.currentPage > 1 && totalVideos <= ((this.pagination.currentPage - 1) * this.pagination.itemsPerPage)) {
 101           this.pagination.currentPage = 1
 102           this.setNewRouteParams()
 103           return this.reloadVideos()
 104         }
 105
 106         this.loadedPages[page] = videos
 107         this.buildVideoPages()
 108         this.pagination.totalItems = totalVideos
 109
 110         // Initialize infinite scroller now we loaded the first page
 111         if (Object.keys(this.loadedPages).length === 1) {
 112           // Wait elements creation
 113           setTimeout(() => this.infiniteScroller.initialize(), 500)
 114         }
 115       },
 116       error => this.notificationsService.error('Error', error.message)
 117     )
 118   }
 119
 120   protected hasMoreVideos () {
 121     // No results
 122     if (this.pagination.totalItems === 0) return false
 123
 124     // Not loaded yet
 125     if (!this.pagination.totalItems) return true
 126
 127     const maxPage = this.pagination.totalItems / this.pagination.itemsPerPage
 128     return maxPage > this.maxPageLoaded()
 129   }
 130
 131   protected previousPage () {
 132     const min = this.minPageLoaded()
 133
 134     if (min > 1) {
 135       this.loadMoreVideos(min - 1)
 136     }
 137   }
 138
 139   protected nextPage () {
 140     this.loadMoreVideos(this.maxPageLoaded() + 1)
 141   }
 142
 143   protected buildRouteParams () {
 144     // There is always a sort and a current page
 145     const params = {
 146       sort: this.sort,
 147       page: this.pagination.currentPage
 148     }
 149
 150     return Object.assign(params, this.otherRouteParams)
 151   }
 152
 153   protected loadRouteParams (routeParams: { [ key: string ]: any }) {
 154     this.sort = routeParams['sort'] as SortField || this.defaultSort
 155
 156     if (routeParams['page'] !== undefined) {
 157       this.pagination.currentPage = parseInt(routeParams['page'], 10)
 158     } else {
 159       this.pagination.currentPage = 1
 160     }
 161   }
 162
 163   protected setNewRouteParams () {
 164     const routeParams = this.buildRouteParams()
 165     this.router.navigate([ this.currentRoute, routeParams ])
 166   }
 167
 168   protected buildVideoPages () {
 169     this.videoPages = Object.values(this.loadedPages)
 170   }
 171
 172   private minPageLoaded () {
 173     return Math.min(...Object.keys(this.loadedPages).map(e => parseInt(e, 10)))
 174   }
 175
 176   private maxPageLoaded () {
 177     return Math.max(...Object.keys(this.loadedPages).map(e => parseInt(e, 10)))
 178   }
 179
 180   private calcPageSizes () {
 181     if (isInMobileView() || this.baseVideoWidth === -1) {
 182       this.pagination.itemsPerPage = 5
 183
 184       // Video takes all the width
 185       this.videoWidth = -1
 186       this.pageHeight = this.pagination.itemsPerPage * this.videoHeight
 187     } else {
 188       this.videoWidth = this.baseVideoWidth
 189       this.videoHeight = this.baseVideoHeight
 190
 191       const videosWidth = this.videosElement.nativeElement.offsetWidth
 192       this.pagination.itemsPerPage = Math.floor(videosWidth / this.videoWidth) * AbstractVideoList.LINES_PER_PAGE
 193       this.pageHeight = this.videoHeight * AbstractVideoList.LINES_PER_PAGE
 194     }
 195
 196     // Rebuild pages because maybe we modified the number of items per page
 197     const videos = [].concat(...this.videoPages)
 198     this.loadedPages = {}
 199
 200     let i = 1
 201     // Don't include the last page if it not complete
 202     while (videos.length >= this.pagination.itemsPerPage && i < 10000) { // 10000 -> Hard limit in case of infinite loop
 203       this.loadedPages[i] = videos.splice(0, this.pagination.itemsPerPage)
 204       i++
 205     }
 206
 207     // Re fetch the last page
 208     if (videos.length !== 0) {
 209       this.loadMoreVideos(i)
 210     } else {
 211       this.buildVideoPages()
 212     }
 213
 214     console.log('Rebuilt pages with %s elements per page.', this.pagination.itemsPerPage)
 215   }
 216 }