1 import { SortMeta } from 'primeng/api'
2 import { from, Observable } from 'rxjs'
3 import { catchError, concatMap, map, toArray } from 'rxjs/operators'
4 import { HttpClient, HttpParams } from '@angular/common/http'
5 import { Injectable } from '@angular/core'
6 import { ComponentPaginationLight, RestExtractor, RestPagination, RestService } from '@app/core'
7 import { objectLineFeedToHtml } from '@app/helpers'
13 VideoComment as VideoCommentServerModel,
16 VideoCommentThreadTree as VideoCommentThreadTreeServerModel
17 } from '@shared/models'
18 import { environment } from '../../../environments/environment'
19 import { VideoCommentThreadTree } from './video-comment-thread-tree.model'
20 import { VideoComment } from './video-comment.model'
23 export class VideoCommentService {
24 static BASE_FEEDS_URL = environment.apiUrl + '/feeds/video-comments.'
26 private static BASE_VIDEO_URL = environment.apiUrl + '/api/v1/videos/'
29 private authHttp: HttpClient,
30 private restExtractor: RestExtractor,
31 private restService: RestService
34 addCommentThread (videoId: number | string, comment: VideoCommentCreate) {
35 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
36 const normalizedComment = objectLineFeedToHtml(comment, 'text')
38 return this.authHttp.post<{ comment: VideoCommentServerModel }>(url, normalizedComment)
40 map(data => this.extractVideoComment(data.comment)),
41 catchError(err => this.restExtractor.handleError(err))
45 addCommentReply (videoId: number | string, inReplyToCommentId: number, comment: VideoCommentCreate) {
46 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comments/' + inReplyToCommentId
47 const normalizedComment = objectLineFeedToHtml(comment, 'text')
49 return this.authHttp.post<{ comment: VideoCommentServerModel }>(url, normalizedComment)
51 map(data => this.extractVideoComment(data.comment)),
52 catchError(err => this.restExtractor.handleError(err))
56 getAdminVideoComments (options: {
57 pagination: RestPagination
60 }): Observable<ResultList<VideoCommentAdmin>> {
61 const { pagination, sort, search } = options
62 const url = VideoCommentService.BASE_VIDEO_URL + 'comments'
64 let params = new HttpParams()
65 params = this.restService.addRestGetParams(params, pagination, sort)
68 params = this.buildParamsFromSearch(search, params)
71 return this.authHttp.get<ResultList<VideoCommentAdmin>>(url, { params })
73 catchError(res => this.restExtractor.handleError(res))
77 getVideoCommentThreads (parameters: {
78 videoId: number | string
79 componentPagination: ComponentPaginationLight
81 }): Observable<ThreadsResultList<VideoComment>> {
82 const { videoId, componentPagination, sort } = parameters
84 const pagination = this.restService.componentToRestPagination(componentPagination)
86 let params = new HttpParams()
87 params = this.restService.addRestGetParams(params, pagination, sort)
89 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
90 return this.authHttp.get<ThreadsResultList<VideoComment>>(url, { params })
92 map(result => this.extractVideoComments(result)),
93 catchError(err => this.restExtractor.handleError(err))
97 getVideoThreadComments (parameters: {
98 videoId: number | string
100 }): Observable<VideoCommentThreadTree> {
101 const { videoId, threadId } = parameters
102 const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comment-threads/${threadId}`
105 .get<VideoCommentThreadTreeServerModel>(url)
107 map(tree => this.extractVideoCommentTree(tree)),
108 catchError(err => this.restExtractor.handleError(err))
112 deleteVideoComment (videoId: number | string, commentId: number) {
113 const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comments/${commentId}`
117 .pipe(catchError(err => this.restExtractor.handleError(err)))
120 deleteVideoComments (comments: { videoId: number | string, commentId: number }[]) {
121 return from(comments)
123 concatMap(c => this.deleteVideoComment(c.videoId, c.commentId)),
128 getVideoCommentsFeeds (video: Pick<Video, 'uuid'>) {
131 format: FeedFormat.RSS,
133 url: VideoCommentService.BASE_FEEDS_URL + FeedFormat.RSS.toLowerCase()
136 format: FeedFormat.ATOM,
138 url: VideoCommentService.BASE_FEEDS_URL + FeedFormat.ATOM.toLowerCase()
141 format: FeedFormat.JSON,
143 url: VideoCommentService.BASE_FEEDS_URL + FeedFormat.JSON.toLowerCase()
147 if (video !== undefined) {
148 for (const feed of feeds) {
149 feed.url += '?videoId=' + video.uuid
156 private extractVideoComment (videoComment: VideoCommentServerModel) {
157 return new VideoComment(videoComment)
160 private extractVideoComments (result: ThreadsResultList<VideoCommentServerModel>) {
161 const videoCommentsJson = result.data
162 const totalComments = result.total
163 const comments: VideoComment[] = []
165 for (const videoCommentJson of videoCommentsJson) {
166 comments.push(new VideoComment(videoCommentJson))
169 return { data: comments, total: totalComments, totalNotDeletedComments: result.totalNotDeletedComments }
172 private extractVideoCommentTree (serverTree: VideoCommentThreadTreeServerModel): VideoCommentThreadTree {
173 if (!serverTree) return null
176 comment: new VideoComment(serverTree.comment),
177 children: serverTree.children.map(c => this.extractVideoCommentTree(c))
180 const hasDisplayedChildren = tree.children.length === 0
181 ? !tree.comment.isDeleted
182 : tree.children.some(c => c.hasDisplayedChildren)
184 return Object.assign(tree, { hasDisplayedChildren })
187 private buildParamsFromSearch (search: string, params: HttpParams) {
188 const filters = this.restService.parseQueryStringFilter(search, {
194 searchAccount: { prefix: 'account:' },
195 searchVideo: { prefix: 'video:' }
198 return this.restService.addObjectParams(params, filters)