1 import { catchError, map } from 'rxjs/operators'
2 import { HttpClient, HttpParams } from '@angular/common/http'
3 import { Injectable } from '@angular/core'
4 import { objectLineFeedToHtml } from '@app/shared/misc/utils'
5 import { Observable } from 'rxjs'
6 import { ResultList, FeedFormat } from '../../../../../../shared/models'
8 VideoComment as VideoCommentServerModel,
10 VideoCommentThreadTree
11 } from '../../../../../../shared/models/videos/video-comment.model'
12 import { environment } from '../../../../environments/environment'
13 import { RestExtractor, RestService } from '../../../shared/rest'
14 import { ComponentPagination } from '../../../shared/rest/component-pagination.model'
15 import { VideoSortField } from '../../../shared/video/sort-field.type'
16 import { VideoComment } from './video-comment.model'
19 export class VideoCommentService {
20 private static BASE_VIDEO_URL = environment.apiUrl + '/api/v1/videos/'
21 private static BASE_FEEDS_URL = environment.apiUrl + '/feeds/video-comments.'
24 private authHttp: HttpClient,
25 private restExtractor: RestExtractor,
26 private restService: RestService
29 addCommentThread (videoId: number | string, comment: VideoCommentCreate) {
30 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
31 const normalizedComment = objectLineFeedToHtml(comment, 'text')
33 return this.authHttp.post<{ comment: VideoCommentServerModel }>(url, normalizedComment)
35 map(data => this.extractVideoComment(data.comment)),
36 catchError(err => this.restExtractor.handleError(err))
40 addCommentReply (videoId: number | string, inReplyToCommentId: number, comment: VideoCommentCreate) {
41 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comments/' + inReplyToCommentId
42 const normalizedComment = objectLineFeedToHtml(comment, 'text')
44 return this.authHttp.post<{ comment: VideoCommentServerModel }>(url, normalizedComment)
46 map(data => this.extractVideoComment(data.comment)),
47 catchError(err => this.restExtractor.handleError(err))
51 getVideoCommentThreads (
52 videoId: number | string,
53 componentPagination: ComponentPagination,
55 ): Observable<{ comments: VideoComment[], totalComments: number}> {
56 const pagination = this.restService.componentPaginationToRestPagination(componentPagination)
58 let params = new HttpParams()
59 params = this.restService.addRestGetParams(params, pagination, sort)
61 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
65 map(this.extractVideoComments),
66 catchError(err => this.restExtractor.handleError(err))
70 getVideoThreadComments (videoId: number | string, threadId: number): Observable<VideoCommentThreadTree> {
71 const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comment-threads/${threadId}`
76 map(tree => this.extractVideoCommentTree(tree as VideoCommentThreadTree)),
77 catchError(err => this.restExtractor.handleError(err))
81 deleteVideoComment (videoId: number | string, commentId: number) {
82 const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comments/${commentId}`
87 map(this.restExtractor.extractDataBool),
88 catchError(err => this.restExtractor.handleError(err))
92 getVideoCommentsFeeds (videoUUID?: string) {
95 format: FeedFormat.RSS,
97 url: VideoCommentService.BASE_FEEDS_URL + FeedFormat.RSS.toLowerCase()
100 format: FeedFormat.ATOM,
102 url: VideoCommentService.BASE_FEEDS_URL + FeedFormat.ATOM.toLowerCase()
105 format: FeedFormat.JSON,
107 url: VideoCommentService.BASE_FEEDS_URL + FeedFormat.JSON.toLowerCase()
111 if (videoUUID !== undefined) {
112 for (const feed of feeds) {
113 feed.url += '?videoId=' + videoUUID
120 private extractVideoComment (videoComment: VideoCommentServerModel) {
121 return new VideoComment(videoComment)
124 private extractVideoComments (result: ResultList<VideoCommentServerModel>) {
125 const videoCommentsJson = result.data
126 const totalComments = result.total
127 const comments: VideoComment[] = []
129 for (const videoCommentJson of videoCommentsJson) {
130 comments.push(new VideoComment(videoCommentJson))
133 return { comments, totalComments }
136 private extractVideoCommentTree (tree: VideoCommentThreadTree) {
137 if (!tree) return tree
139 tree.comment = new VideoComment(tree.comment)
140 tree.children.forEach(c => this.extractVideoCommentTree(c))