client/src/app/shared/instance/follow.service.ts

   1 import { catchError, map } from 'rxjs/operators'
   2 import { HttpClient, HttpParams } from '@angular/common/http'
   3 import { Injectable } from '@angular/core'
   4 import { SortMeta } from 'primeng/primeng'
   5 import { Observable } from 'rxjs'
   6 import { ActorFollow, ResultList } from '@shared/index'
   7 import { environment } from '../../../environments/environment'
   8 import { RestExtractor, RestPagination, RestService } from '../rest'
   9
  10 @Injectable()
  11 export class FollowService {
  12   private static BASE_APPLICATION_URL = 'https://peertube2.cpy.re' + '/api/v1/server'
  13
  14   constructor (
  15     private authHttp: HttpClient,
  16     private restService: RestService,
  17     private restExtractor: RestExtractor
  18   ) {
  19   }
  20
  21   getFollowing (pagination: RestPagination, sort: SortMeta, search?: string): Observable<ResultList<ActorFollow>> {
  22     let params = new HttpParams()
  23     params = this.restService.addRestGetParams(params, pagination, sort)
  24
  25     if (search) params = params.append('search', search)
  26
  27     return this.authHttp.get<ResultList<ActorFollow>>(FollowService.BASE_APPLICATION_URL + '/following', { params })
  28                .pipe(
  29                  map(res => this.restExtractor.convertResultListDateToHuman(res)),
  30                  catchError(res => this.restExtractor.handleError(res))
  31                )
  32   }
  33
  34   getFollowers (pagination: RestPagination, sort: SortMeta, search?: string): Observable<ResultList<ActorFollow>> {
  35     let params = new HttpParams()
  36     params = this.restService.addRestGetParams(params, pagination, sort)
  37
  38     if (search) params = params.append('search', search)
  39
  40     return this.authHttp.get<ResultList<ActorFollow>>(FollowService.BASE_APPLICATION_URL + '/followers', { params })
  41                .pipe(
  42                  map(res => this.restExtractor.convertResultListDateToHuman(res)),
  43                  catchError(res => this.restExtractor.handleError(res))
  44                )
  45   }
  46
  47   follow (notEmptyHosts: string[]) {
  48     const body = {
  49       hosts: notEmptyHosts
  50     }
  51
  52     return this.authHttp.post(FollowService.BASE_APPLICATION_URL + '/following', body)
  53                .pipe(
  54                  map(this.restExtractor.extractDataBool),
  55                  catchError(res => this.restExtractor.handleError(res))
  56                )
  57   }
  58
  59   unfollow (follow: ActorFollow) {
  60     return this.authHttp.delete(FollowService.BASE_APPLICATION_URL + '/following/' + follow.following.host)
  61                .pipe(
  62                  map(this.restExtractor.extractDataBool),
  63                  catchError(res => this.restExtractor.handleError(res))
  64                )
  65   }
  66
  67   acceptFollower (follow: ActorFollow) {
  68     const handle = follow.follower.name + '@' + follow.follower.host
  69
  70     return this.authHttp.post(`${FollowService.BASE_APPLICATION_URL}/followers/${handle}/accept`, {})
  71                .pipe(
  72                  map(this.restExtractor.extractDataBool),
  73                  catchError(res => this.restExtractor.handleError(res))
  74                )
  75   }
  76
  77   rejectFollower (follow: ActorFollow) {
  78     const handle = follow.follower.name + '@' + follow.follower.host
  79
  80     return this.authHttp.post(`${FollowService.BASE_APPLICATION_URL}/followers/${handle}/reject`, {})
  81                .pipe(
  82                  map(this.restExtractor.extractDataBool),
  83                  catchError(res => this.restExtractor.handleError(res))
  84                )
  85   }
  86
  87   removeFollower (follow: ActorFollow) {
  88     const handle = follow.follower.name + '@' + follow.follower.host
  89
  90     return this.authHttp.delete(`${FollowService.BASE_APPLICATION_URL}/followers/${handle}`)
  91                .pipe(
  92                  map(this.restExtractor.extractDataBool),
  93                  catchError(res => this.restExtractor.handleError(res))
  94                )
  95   }
  96 }