client/src/app/+admin/users/shared/user.service.ts

   1 import { Injectable } from '@angular/core'
   2 import 'rxjs/add/operator/catch'
   3 import 'rxjs/add/operator/map'
   4
   5 import { BytesPipe } from 'angular-pipes/src/math/bytes.pipe'
   6
   7 import { AuthHttp, RestExtractor, RestDataSource, User } from '../../../shared'
   8 import { UserCreate } from '../../../../../../shared'
   9
  10 @Injectable()
  11 export class UserService {
  12   private static BASE_USERS_URL = API_URL + '/api/v1/users/'
  13   private bytesPipe = new BytesPipe()
  14
  15   constructor (
  16     private authHttp: AuthHttp,
  17     private restExtractor: RestExtractor
  18   ) {}
  19
  20   addUser (userCreate: UserCreate) {
  21     return this.authHttp.post(UserService.BASE_USERS_URL, userCreate)
  22                         .map(this.restExtractor.extractDataBool)
  23                         .catch(this.restExtractor.handleError)
  24   }
  25
  26   getDataSource () {
  27     return new RestDataSource(this.authHttp, UserService.BASE_USERS_URL, this.formatDataSource.bind(this))
  28   }
  29
  30   removeUser (user: User) {
  31     return this.authHttp.delete(UserService.BASE_USERS_URL + user.id)
  32   }
  33
  34   private formatDataSource (users: User[]) {
  35     const newUsers = []
  36
  37     users.forEach(user => {
  38       let videoQuota
  39       if (user.videoQuota === -1) {
  40         videoQuota = 'Unlimited'
  41       } else {
  42         videoQuota = this.bytesPipe.transform(user.videoQuota)
  43       }
  44
  45       const newUser = Object.assign(user, {
  46         videoQuota
  47       })
  48       newUsers.push(newUser)
  49     })
  50
  51     return newUsers
  52   }
  53 }