client/src/app/shared/shared-main/account/actor.service.ts

   1 import { Observable, ReplaySubject } from 'rxjs'
   2 import { catchError, map, tap } from 'rxjs/operators'
   3 import { HttpClient } from '@angular/common/http'
   4 import { Injectable } from '@angular/core'
   5 import { RestExtractor } from '@app/core'
   6 import { Account as ServerAccount, VideoChannel as ServerVideoChannel } from '@shared/models'
   7 import { environment } from '../../../../environments/environment'
   8 import { Account } from './account.model'
   9 import { VideoChannel } from '../video-channel/video-channel.model'
  10
  11 @Injectable()
  12 export class ActorService {
  13   static BASE_ACTOR_API_URL = environment.apiUrl + '/api/v1/actors/'
  14
  15   actorLoaded = new ReplaySubject<Account | VideoChannel>(1)
  16
  17   constructor (
  18     private authHttp: HttpClient,
  19     private restExtractor: RestExtractor
  20   ) {}
  21
  22   getActor (actorName: string): Observable<Account | VideoChannel> {
  23     return this.authHttp.get<ServerAccount | ServerVideoChannel>(ActorService.BASE_ACTOR_API_URL + actorName)
  24                 .pipe(
  25                   map(actorHash => {
  26                     const isAccount = /\/accounts\/.+/.test(actorHash.url)
  27                     const isVideoChannel = /\/video-channels\/.+/.test(actorHash.url)
  28
  29                     if (isAccount) {
  30                       return new Account(actorHash)
  31                     }
  32
  33                     if (isVideoChannel) {
  34                       return new VideoChannel(actorHash)
  35                     }
  36                   }),
  37                   tap(actor => this.actorLoaded.next(actor)),
  38                   catchError(res => this.restExtractor.handleError(res))
  39                 )
  40   }
  41 }