client/src/app/videos/+video-watch/comment/video-comment.service.ts

   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'
   9 import {
  10   VideoComment as VideoCommentServerModel,
  11   VideoCommentCreate,
  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 { SortField } from '../../../shared/video/sort-field.type'
  18 import { VideoComment } from './video-comment.model'
  19
  20 @Injectable()
  21 export class VideoCommentService {
  22   private static BASE_VIDEO_URL = environment.apiUrl + '/api/v1/videos/'
  23
  24   constructor (
  25     private authHttp: HttpClient,
  26     private restExtractor: RestExtractor,
  27     private restService: RestService
  28   ) {}
  29
  30   addCommentThread (videoId: number | string, comment: VideoCommentCreate) {
  31     const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
  32     const normalizedComment = lineFeedToHtml(comment, 'text')
  33
  34     return this.authHttp.post(url, normalizedComment)
  35       .map(data => this.extractVideoComment(data['comment']))
  36       .catch(this.restExtractor.handleError)
  37   }
  38
  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')
  42
  43     return this.authHttp.post(url, normalizedComment)
  44       .map(data => this.extractVideoComment(data['comment']))
  45       .catch(this.restExtractor.handleError)
  46   }
  47
  48   getVideoCommentThreads (
  49     videoId: number | string,
  50     componentPagination: ComponentPagination,
  51     sort: SortField
  52   ): Observable<{ comments: VideoComment[], totalComments: number}> {
  53     const pagination = this.restService.componentPaginationToRestPagination(componentPagination)
  54
  55     let params = new HttpParams()
  56     params = this.restService.addRestGetParams(params, pagination, sort)
  57
  58     const url = VideoCommentService.BASE_VIDEO_URL + videoId + '/comment-threads'
  59     return this.authHttp
  60       .get(url, { params })
  61       .map(this.extractVideoComments)
  62       .catch((res) => this.restExtractor.handleError(res))
  63   }
  64
  65   getVideoThreadComments (videoId: number | string, threadId: number): Observable<VideoCommentThreadTree> {
  66     const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comment-threads/${threadId}`
  67
  68     return this.authHttp
  69       .get(url)
  70       .map(tree => this.extractVideoCommentTree(tree as VideoCommentThreadTree))
  71       .catch((res) => this.restExtractor.handleError(res))
  72   }
  73
  74   deleteVideoComment (videoId: number | string, commentId: number) {
  75     const url = `${VideoCommentService.BASE_VIDEO_URL + videoId}/comments/${commentId}`
  76
  77     return this.authHttp
  78       .delete(url)
  79       .map(this.restExtractor.extractDataBool)
  80       .catch((res) => this.restExtractor.handleError(res))
  81   }
  82
  83   private extractVideoComment (videoComment: VideoCommentServerModel) {
  84     return new VideoComment(videoComment)
  85   }
  86
  87   private extractVideoComments (result: ResultList<VideoCommentServerModel>) {
  88     const videoCommentsJson = result.data
  89     const totalComments = result.total
  90     const comments = []
  91
  92     for (const videoCommentJson of videoCommentsJson) {
  93       comments.push(new VideoComment(videoCommentJson))
  94     }
  95
  96     return { comments, totalComments }
  97   }
  98
  99   private extractVideoCommentTree (tree: VideoCommentThreadTree) {
 100     if (!tree) return tree
 101
 102     tree.comment = new VideoComment(tree.comment)
 103     tree.children.forEach(c => this.extractVideoCommentTree(c))
 104
 105     return tree
 106   }
 107 }