diff options
Diffstat (limited to 'client/src/app/shared/video/video.service.ts')
-rw-r--r-- | client/src/app/shared/video/video.service.ts | 170 |
1 files changed, 170 insertions, 0 deletions
diff --git a/client/src/app/shared/video/video.service.ts b/client/src/app/shared/video/video.service.ts new file mode 100644 index 000000000..b2a26417c --- /dev/null +++ b/client/src/app/shared/video/video.service.ts | |||
@@ -0,0 +1,170 @@ | |||
1 | import { HttpClient, HttpParams, HttpRequest } 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 { Video as VideoServerModel, VideoDetails as VideoDetailsServerModel } from '../../../../../shared' | ||
7 | import { ResultList } from '../../../../../shared/models/result-list.model' | ||
8 | import { UserVideoRateUpdate } from '../../../../../shared/models/videos/user-video-rate-update.model' | ||
9 | import { UserVideoRate } from '../../../../../shared/models/videos/user-video-rate.model' | ||
10 | import { VideoRateType } from '../../../../../shared/models/videos/video-rate.type' | ||
11 | import { VideoUpdate } from '../../../../../shared/models/videos/video-update.model' | ||
12 | import { RestExtractor } from '../rest/rest-extractor.service' | ||
13 | import { RestService } from '../rest/rest.service' | ||
14 | import { Search } from '../search/search.model' | ||
15 | import { UserService } from '../users/user.service' | ||
16 | import { SortField } from './sort-field.type' | ||
17 | import { VideoDetails } from './video-details.model' | ||
18 | import { VideoEdit } from './video-edit.model' | ||
19 | import { VideoPagination } from './video-pagination.model' | ||
20 | import { Video } from './video.model' | ||
21 | |||
22 | @Injectable() | ||
23 | export class VideoService { | ||
24 | private static BASE_VIDEO_URL = API_URL + '/api/v1/videos/' | ||
25 | |||
26 | constructor ( | ||
27 | private authHttp: HttpClient, | ||
28 | private restExtractor: RestExtractor, | ||
29 | private restService: RestService | ||
30 | ) {} | ||
31 | |||
32 | getVideo (uuid: string): Observable<VideoDetails> { | ||
33 | return this.authHttp.get<VideoDetailsServerModel>(VideoService.BASE_VIDEO_URL + uuid) | ||
34 | .map(videoHash => new VideoDetails(videoHash)) | ||
35 | .catch((res) => this.restExtractor.handleError(res)) | ||
36 | } | ||
37 | |||
38 | viewVideo (uuid: string): Observable<VideoDetails> { | ||
39 | return this.authHttp.post(VideoService.BASE_VIDEO_URL + uuid + '/views', {}) | ||
40 | .map(this.restExtractor.extractDataBool) | ||
41 | .catch(this.restExtractor.handleError) | ||
42 | } | ||
43 | |||
44 | updateVideo (video: VideoEdit) { | ||
45 | const language = video.language ? video.language : null | ||
46 | |||
47 | const body: VideoUpdate = { | ||
48 | name: video.name, | ||
49 | category: video.category, | ||
50 | licence: video.licence, | ||
51 | language, | ||
52 | description: video.description, | ||
53 | privacy: video.privacy, | ||
54 | tags: video.tags, | ||
55 | nsfw: video.nsfw | ||
56 | } | ||
57 | |||
58 | return this.authHttp.put(VideoService.BASE_VIDEO_URL + video.id, body) | ||
59 | .map(this.restExtractor.extractDataBool) | ||
60 | .catch(this.restExtractor.handleError) | ||
61 | } | ||
62 | |||
63 | uploadVideo (video: FormData) { | ||
64 | const req = new HttpRequest('POST', VideoService.BASE_VIDEO_URL + 'upload', video, { reportProgress: true }) | ||
65 | |||
66 | return this.authHttp | ||
67 | .request(req) | ||
68 | .catch(this.restExtractor.handleError) | ||
69 | } | ||
70 | |||
71 | getMyVideos (videoPagination: VideoPagination, sort: SortField): Observable<{ videos: Video[], totalVideos: number}> { | ||
72 | const pagination = this.videoPaginationToRestPagination(videoPagination) | ||
73 | |||
74 | let params = new HttpParams() | ||
75 | params = this.restService.addRestGetParams(params, pagination, sort) | ||
76 | |||
77 | return this.authHttp.get(UserService.BASE_USERS_URL + '/me/videos', { params }) | ||
78 | .map(this.extractVideos) | ||
79 | .catch((res) => this.restExtractor.handleError(res)) | ||
80 | } | ||
81 | |||
82 | getVideos (videoPagination: VideoPagination, sort: SortField): Observable<{ videos: Video[], totalVideos: number}> { | ||
83 | const pagination = this.videoPaginationToRestPagination(videoPagination) | ||
84 | |||
85 | let params = new HttpParams() | ||
86 | params = this.restService.addRestGetParams(params, pagination, sort) | ||
87 | |||
88 | return this.authHttp | ||
89 | .get(VideoService.BASE_VIDEO_URL, { params }) | ||
90 | .map(this.extractVideos) | ||
91 | .catch((res) => this.restExtractor.handleError(res)) | ||
92 | } | ||
93 | |||
94 | searchVideos (search: Search, videoPagination: VideoPagination, sort: SortField): Observable<{ videos: Video[], totalVideos: number}> { | ||
95 | const url = VideoService.BASE_VIDEO_URL + 'search/' + encodeURIComponent(search.value) | ||
96 | |||
97 | const pagination = this.videoPaginationToRestPagination(videoPagination) | ||
98 | |||
99 | let params = new HttpParams() | ||
100 | params = this.restService.addRestGetParams(params, pagination, sort) | ||
101 | |||
102 | if (search.field) params.set('field', search.field) | ||
103 | |||
104 | return this.authHttp | ||
105 | .get<ResultList<VideoServerModel>>(url, { params }) | ||
106 | .map(this.extractVideos) | ||
107 | .catch((res) => this.restExtractor.handleError(res)) | ||
108 | } | ||
109 | |||
110 | removeVideo (id: number) { | ||
111 | return this.authHttp | ||
112 | .delete(VideoService.BASE_VIDEO_URL + id) | ||
113 | .map(this.restExtractor.extractDataBool) | ||
114 | .catch((res) => this.restExtractor.handleError(res)) | ||
115 | } | ||
116 | |||
117 | loadCompleteDescription (descriptionPath: string) { | ||
118 | return this.authHttp | ||
119 | .get(API_URL + descriptionPath) | ||
120 | .map(res => res['description']) | ||
121 | .catch((res) => this.restExtractor.handleError(res)) | ||
122 | } | ||
123 | |||
124 | setVideoLike (id: number) { | ||
125 | return this.setVideoRate(id, 'like') | ||
126 | } | ||
127 | |||
128 | setVideoDislike (id: number) { | ||
129 | return this.setVideoRate(id, 'dislike') | ||
130 | } | ||
131 | |||
132 | getUserVideoRating (id: number): Observable<UserVideoRate> { | ||
133 | const url = UserService.BASE_USERS_URL + 'me/videos/' + id + '/rating' | ||
134 | |||
135 | return this.authHttp | ||
136 | .get(url) | ||
137 | .catch(res => this.restExtractor.handleError(res)) | ||
138 | } | ||
139 | |||
140 | private videoPaginationToRestPagination (videoPagination: VideoPagination) { | ||
141 | const start: number = (videoPagination.currentPage - 1) * videoPagination.itemsPerPage | ||
142 | const count: number = videoPagination.itemsPerPage | ||
143 | |||
144 | return { start, count } | ||
145 | } | ||
146 | |||
147 | private setVideoRate (id: number, rateType: VideoRateType) { | ||
148 | const url = VideoService.BASE_VIDEO_URL + id + '/rate' | ||
149 | const body: UserVideoRateUpdate = { | ||
150 | rating: rateType | ||
151 | } | ||
152 | |||
153 | return this.authHttp | ||
154 | .put(url, body) | ||
155 | .map(this.restExtractor.extractDataBool) | ||
156 | .catch(res => this.restExtractor.handleError(res)) | ||
157 | } | ||
158 | |||
159 | private extractVideos (result: ResultList<VideoServerModel>) { | ||
160 | const videosJson = result.data | ||
161 | const totalVideos = result.total | ||
162 | const videos = [] | ||
163 | |||
164 | for (const videoJson of videosJson) { | ||
165 | videos.push(new Video(videoJson)) | ||
166 | } | ||
167 | |||
168 | return { videos, totalVideos } | ||
169 | } | ||
170 | } | ||