1 import { HttpClient, HttpParams } from '@angular/common/http'
2 import { Injectable } from '@angular/core'
3 import 'rxjs/add/operator/catch'
4 import 'rxjs/add/operator/map'
5 import { Observable } from 'rxjs/Observable'
6 import { ResultList } from '../../../../../../shared/models'
8 VideoComment as VideoCommentServerModel, VideoCommentCreate,
10 } from '../../../../../../shared/models/videos/video-comment.model'
11 import { environment } from '../../../../environments/environment'
12 import { RestExtractor, RestService } from '../../../shared/rest'
13 import { ComponentPagination } from '../../../shared/rest/component-pagination.model'
14 import { SortField } from '../../../shared/video/sort-field.type'
15 import { VideoComment } from './video-comment.model'
18 export class VideoCommentService {
19 private static BASE_VIDEO_URL = environment.apiUrl + '/api/v1/videos/'
22 private authHttp: HttpClient,
23 private restExtractor: RestExtractor,
24 private restService: RestService
27 addCommentThread (videoId: number | string, comment: VideoCommentCreate) {
28 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
30 return this.authHttp.post(url, comment)
31 .map(data => this.extractVideoComment(data['comment']))
32 .catch(this.restExtractor.handleError)
35 addCommentReply (videoId: number | string, inReplyToCommentId: number, comment: VideoCommentCreate) {
36 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comments/' + inReplyToCommentId
38 return this.authHttp.post(url, comment)
39 .map(data => this.extractVideoComment(data['comment']))
40 .catch(this.restExtractor.handleError)
43 getVideoCommentThreads (
44 videoId: number | string,
45 componentPagination: ComponentPagination,
47 ): Observable<{ comments: VideoComment[], totalComments: number}> {
48 const pagination = this.restService.componentPaginationToRestPagination(componentPagination)
50 let params = new HttpParams()
51 params = this.restService.addRestGetParams(params, pagination, sort)
53 const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
56 .map(this.extractVideoComments)
57 .catch((res) => this.restExtractor.handleError(res))
60 getVideoThreadComments (videoId: number | string, threadId: number): Observable<VideoCommentThreadTree> {
61 const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comment-threads/${threadId}`
65 .map(tree => this.extractVideoCommentTree(tree as VideoCommentThreadTree))
66 .catch((res) => this.restExtractor.handleError(res))
69 private extractVideoComment (videoComment: VideoCommentServerModel) {
70 return new VideoComment(videoComment)
73 private extractVideoComments (result: ResultList<VideoCommentServerModel>) {
74 const videoCommentsJson = result.data
75 const totalComments = result.total
78 for (const videoCommentJson of videoCommentsJson) {
79 comments.push(new VideoComment(videoCommentJson))
82 return { comments, totalComments }
85 private extractVideoCommentTree (tree: VideoCommentThreadTree) {
86 if (!tree) return tree
88 tree.comment = new VideoComment(tree.comment)
89 tree.children.forEach(c => this.extractVideoCommentTree(c))