client/src/app/+admin/follows/shared/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'
   7 import { environment } from '../../../../environments/environment'
   8 import { RestExtractor, RestPagination, RestService } from '../../../shared'
   9
  10 @Injectable()
  11 export class FollowService {
  12   private static BASE_APPLICATION_URL = environment.apiUrl + '/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 }