1 import { HttpClient, HttpParams } from '@angular/common/http'
2 import { Injectable } from '@angular/core'
3 import { lineFeedToHtml } from '@app/shared/misc/utils'
4 import { MarkdownService } from '@app/videos/shared'
5 import 'rxjs/add/operator/catch'
6 import 'rxjs/add/operator/map'
7 import { Observable } from 'rxjs/Observable'
8 import { ResultList } from '../../../../../../shared/models'
10 VideoComment as VideoCommentServerModel,
12 VideoCommentThreadTree
13 } from '../../../../../../shared/models/videos/video-comment.model'
14 import { environment } from '../../../../environments/environment'
15 import { RestExtractor, RestService } from '../../../shared/rest'
16 import { ComponentPagination } from '../../../shared/rest/component-pagination.model'
17 import { VideoSortField } from '../../../shared/video/sort-field.type'
18 import { VideoComment } from './video-comment.model'
21 export class VideoCommentService {
22 private static BASE_VIDEO_URL = environment.apiUrl + '/api/v1/videos/'
25 private authHttp: HttpClient,
26 private restExtractor: RestExtractor,
27 private restService: RestService
30 addCommentThread (videoId: number | string, comment: VideoCommentCreate) {
31 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
32 const normalizedComment = lineFeedToHtml(comment, 'text')
34 return this.authHttp.post(url, normalizedComment)
35 .map(data => this.extractVideoComment(data['comment']))
36 .catch(this.restExtractor.handleError)
39 addCommentReply (videoId: number | string, inReplyToCommentId: number, comment: VideoCommentCreate) {
40 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comments/' + inReplyToCommentId
41 const normalizedComment = lineFeedToHtml(comment, 'text')
43 return this.authHttp.post(url, normalizedComment)
44 .map(data => this.extractVideoComment(data['comment']))
45 .catch(this.restExtractor.handleError)
48 getVideoCommentThreads (
49 videoId: number | string,
50 componentPagination: ComponentPagination,
52 ): Observable<{ comments: VideoComment[], totalComments: number}> {
53 const pagination = this.restService.componentPaginationToRestPagination(componentPagination)
55 let params = new HttpParams()
56 params = this.restService.addRestGetParams(params, pagination, sort)
58 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
61 .map(this.extractVideoComments)
62 .catch((res) => this.restExtractor.handleError(res))
65 getVideoThreadComments (videoId: number | string, threadId: number): Observable<VideoCommentThreadTree> {
66 const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comment-threads/${threadId}`
70 .map(tree => this.extractVideoCommentTree(tree as VideoCommentThreadTree))
71 .catch((res) => this.restExtractor.handleError(res))
74 deleteVideoComment (videoId: number | string, commentId: number) {
75 const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comments/${commentId}`
79 .map(this.restExtractor.extractDataBool)
80 .catch((res) => this.restExtractor.handleError(res))
83 private extractVideoComment (videoComment: VideoCommentServerModel) {
84 return new VideoComment(videoComment)
87 private extractVideoComments (result: ResultList<VideoCommentServerModel>) {
88 const videoCommentsJson = result.data
89 const totalComments = result.total
92 for (const videoCommentJson of videoCommentsJson) {
93 comments.push(new VideoComment(videoCommentJson))
96 return { comments, totalComments }
99 private extractVideoCommentTree (tree: VideoCommentThreadTree) {
100 if (!tree) return tree
102 tree.comment = new VideoComment(tree.comment)
103 tree.children.forEach(c => this.extractVideoCommentTree(c))