1 import { from, Subject, Subscription } from 'rxjs'
2 import { concatMap, map, switchMap, tap } from 'rxjs/operators'
3 import { Component, OnDestroy, OnInit } from '@angular/core'
4 import { ComponentPagination, hasMoreItems, MarkdownService, User, UserService } from '@app/core'
5 import { Account, AccountService, Video, VideoChannel, VideoChannelService, VideoService } from '@app/shared/shared-main'
6 import { MiniatureDisplayOptions } from '@app/shared/shared-video-miniature'
7 import { NSFWPolicyType, VideoSortField } from '@shared/models'
10 selector: 'my-account-video-channels',
11 templateUrl: './account-video-channels.component.html',
12 styleUrls: [ './account-video-channels.component.scss' ]
14 export class AccountVideoChannelsComponent implements OnInit, OnDestroy {
16 videoChannels: VideoChannel[] = []
18 videos: { [id: number]: { total: number, videos: Video[] } } = {}
20 channelsDescriptionHTML: { [ id: number ]: string } = {}
22 channelPagination: ComponentPagination = {
28 videosPagination: ComponentPagination = {
33 videosSort: VideoSortField = '-publishedAt'
35 onChannelDataSubject = new Subject<any>()
38 nsfwPolicy: NSFWPolicyType
39 miniatureDisplayOptions: MiniatureDisplayOptions = {
50 private accountSub: Subscription
53 private accountService: AccountService,
54 private videoChannelService: VideoChannelService,
55 private videoService: VideoService,
56 private markdown: MarkdownService,
57 private userService: UserService
61 // Parent get the account for us
62 this.accountSub = this.accountService.accountLoaded
63 .subscribe(account => {
64 this.account = account
66 this.loadMoreChannels()
69 this.userService.getAnonymousOrLoggedUser()
71 this.userMiniature = user
73 this.nsfwPolicy = user.nsfwPolicy
78 if (this.accountSub) this.accountSub.unsubscribe()
83 account: this.account,
84 componentPagination: this.channelPagination,
88 this.videoChannelService.listAccountVideoChannels(options)
91 this.channelPagination.totalItems = res.total
93 switchMap(res => from(res.data)),
94 concatMap(videoChannel => {
97 videoPagination: this.videosPagination,
98 sort: this.videosSort,
99 nsfwPolicy: this.nsfwPolicy
102 return this.videoService.getVideoChannelVideos(options)
103 .pipe(map(data => ({ videoChannel, videos: data.data, total: data.total })))
106 .subscribe(async ({ videoChannel, videos, total }) => {
107 this.channelsDescriptionHTML[videoChannel.id] = await this.markdown.textMarkdownToHTML(videoChannel.description)
109 this.videoChannels.push(videoChannel)
111 this.videos[videoChannel.id] = { videos, total }
113 this.onChannelDataSubject.next([ videoChannel ])
117 getVideosOf (videoChannel: VideoChannel) {
118 const obj = this.videos[videoChannel.id]
124 getTotalVideosOf (videoChannel: VideoChannel) {
125 const obj = this.videos[videoChannel.id]
126 if (!obj) return undefined
131 getChannelDescription (videoChannel: VideoChannel) {
132 return this.channelsDescriptionHTML[videoChannel.id]
136 if (!hasMoreItems(this.channelPagination)) return
138 this.channelPagination.currentPage += 1
140 this.loadMoreChannels()
143 getVideoChannelLink (videoChannel: VideoChannel) {
144 return [ '/c', videoChannel.nameWithHost ]