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

   1 import { SortMeta } from 'primeng/api'
   2 import { Observable } from 'rxjs'
   3 import { catchError, map } from 'rxjs/operators'
   4 import { HttpClient, HttpParams } from '@angular/common/http'
   5 import { Injectable } from '@angular/core'
   6 import { RestExtractor, RestPagination, RestService } from '@app/core'
   7 import { ActivityPubActorType, ActorFollow, FollowState, ResultList, ServerFollowCreate } from '@shared/models'
   8 import { environment } from '../../../environments/environment'
   9
  10 @Injectable()
  11 export class InstanceFollowService {
  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 (options: {
  22     pagination: RestPagination
  23     sort: SortMeta
  24     search?: string
  25     actorType?: ActivityPubActorType
  26     state?: FollowState
  27   }): Observable<ResultList<ActorFollow>> {
  28     const { pagination, sort, search, state, actorType } = options
  29
  30     let params = new HttpParams()
  31     params = this.restService.addRestGetParams(params, pagination, sort)
  32
  33     if (search) params = params.append('search', search)
  34     if (state) params = params.append('state', state)
  35     if (actorType) params = params.append('actorType', actorType)
  36
  37     return this.authHttp.get<ResultList<ActorFollow>>(InstanceFollowService.BASE_APPLICATION_URL + '/following', { params })
  38                .pipe(
  39                  map(res => this.restExtractor.convertResultListDateToHuman(res)),
  40                  catchError(res => this.restExtractor.handleError(res))
  41                )
  42   }
  43
  44   getFollowers (options: {
  45     pagination: RestPagination
  46     sort: SortMeta
  47     search?: string
  48     actorType?: ActivityPubActorType
  49     state?: FollowState
  50   }): Observable<ResultList<ActorFollow>> {
  51     const { pagination, sort, search, state, actorType } = options
  52
  53     let params = new HttpParams()
  54     params = this.restService.addRestGetParams(params, pagination, sort)
  55
  56     if (search) params = params.append('search', search)
  57     if (state) params = params.append('state', state)
  58     if (actorType) params = params.append('actorType', actorType)
  59
  60     return this.authHttp.get<ResultList<ActorFollow>>(InstanceFollowService.BASE_APPLICATION_URL + '/followers', { params })
  61                .pipe(
  62                  map(res => this.restExtractor.convertResultListDateToHuman(res)),
  63                  catchError(res => this.restExtractor.handleError(res))
  64                )
  65   }
  66
  67   follow (hostsOrHandles: string[]) {
  68     const body: ServerFollowCreate = {
  69       handles: hostsOrHandles.filter(v => v.includes('@')),
  70       hosts: hostsOrHandles.filter(v => !v.includes('@'))
  71     }
  72
  73     return this.authHttp.post(InstanceFollowService.BASE_APPLICATION_URL + '/following', body)
  74                .pipe(catchError(res => this.restExtractor.handleError(res)))
  75   }
  76
  77   unfollow (follow: ActorFollow) {
  78     const handle = follow.following.name + '@' + follow.following.host
  79
  80     return this.authHttp.delete(InstanceFollowService.BASE_APPLICATION_URL + '/following/' + handle)
  81                .pipe(catchError(res => this.restExtractor.handleError(res)))
  82   }
  83
  84   acceptFollower (follow: ActorFollow) {
  85     const handle = follow.follower.name + '@' + follow.follower.host
  86
  87     return this.authHttp.post(`${InstanceFollowService.BASE_APPLICATION_URL}/followers/${handle}/accept`, {})
  88                .pipe(catchError(res => this.restExtractor.handleError(res)))
  89   }
  90
  91   rejectFollower (follow: ActorFollow) {
  92     const handle = follow.follower.name + '@' + follow.follower.host
  93
  94     return this.authHttp.post(`${InstanceFollowService.BASE_APPLICATION_URL}/followers/${handle}/reject`, {})
  95                .pipe(catchError(res => this.restExtractor.handleError(res)))
  96   }
  97
  98   removeFollower (follow: ActorFollow) {
  99     const handle = follow.follower.name + '@' + follow.follower.host
 100
 101     return this.authHttp.delete(`${InstanceFollowService.BASE_APPLICATION_URL}/followers/${handle}`)
 102                .pipe(catchError(res => this.restExtractor.handleError(res)))
 103   }
 104 }