client/src/app/core/rest/rest-extractor.service.ts

   1 import { throwError as observableThrowError } from 'rxjs'
   2 import { Injectable } from '@angular/core'
   3 import { Router } from '@angular/router'
   4 import { dateToHuman } from '@app/helpers'
   5 import { HttpStatusCode, ResultList } from '@shared/models'
   6
   7 @Injectable()
   8 export class RestExtractor {
   9
  10   constructor (private router: Router) { }
  11
  12   extractDataBool () {
  13     return true
  14   }
  15
  16   applyToResultListData <T, A, U> (
  17     result: ResultList<T>,
  18     fun: (data: T, ...args: A[]) => U,
  19     additionalArgs: A[] = []
  20   ): ResultList<U> {
  21     const data: T[] = result.data
  22
  23     return {
  24       total: result.total,
  25       data: data.map(d => fun.apply(this, [ d, ...additionalArgs ]))
  26     }
  27   }
  28
  29   convertResultListDateToHuman <T> (result: ResultList<T>, fieldsToConvert: string[] = [ 'createdAt' ]): ResultList<T> {
  30     return this.applyToResultListData(result, this.convertDateToHuman, [ fieldsToConvert ])
  31   }
  32
  33   convertDateToHuman (target: any, fieldsToConvert: string[]) {
  34     fieldsToConvert.forEach(field => {
  35       target[field] = dateToHuman(target[field])
  36     })
  37
  38     return target
  39   }
  40
  41   handleError (err: any) {
  42     let errorMessage
  43
  44     if (err.error instanceof Error) {
  45       // A client-side or network error occurred. Handle it accordingly.
  46       errorMessage = err.error.detail || err.error.title
  47       console.error('An error occurred:', errorMessage)
  48     } else if (typeof err.error === 'string') {
  49       errorMessage = err.error
  50     } else if (err.status !== undefined) {
  51       // A server-side error occurred.
  52       if (err.error?.errors) {
  53         const errors = err.error.errors
  54         const errorsArray: string[] = []
  55
  56         Object.keys(errors).forEach(key => {
  57           errorsArray.push(errors[key].msg)
  58         })
  59
  60         errorMessage = errorsArray.join('. ')
  61       } else if (err.error?.error) {
  62         errorMessage = err.error.error
  63       } else if (err.status === HttpStatusCode.PAYLOAD_TOO_LARGE_413) {
  64         // eslint-disable-next-line max-len
  65         errorMessage = $localize`Media is too large for the server. Please contact you administrator if you want to increase the limit size.`
  66       } else if (err.status === HttpStatusCode.TOO_MANY_REQUESTS_429) {
  67         const secondsLeft = err.headers.get('retry-after')
  68         if (secondsLeft) {
  69           const minutesLeft = Math.floor(parseInt(secondsLeft, 10) / 60)
  70           errorMessage = $localize`Too many attempts, please try again after ${minutesLeft} minutes.`
  71         } else {
  72           errorMessage = $localize`Too many attempts, please try again later.`
  73         }
  74       } else if (err.status === HttpStatusCode.INTERNAL_SERVER_ERROR_500) {
  75         errorMessage = $localize`Server error. Please retry later.`
  76       }
  77
  78       errorMessage = errorMessage || 'Unknown error.'
  79       console.error(`Backend returned code ${err.status}, errorMessage is: ${errorMessage}`)
  80     } else {
  81       console.error(err)
  82       errorMessage = err
  83     }
  84
  85     const errorObj: { message: string, status: string, body: string } = {
  86       message: errorMessage,
  87       status: undefined,
  88       body: undefined
  89     }
  90
  91     if (err.status) {
  92       errorObj.status = err.status
  93       errorObj.body = err.error
  94     }
  95
  96     return observableThrowError(() => errorObj)
  97   }
  98
  99   redirectTo404IfNotFound (obj: { status: number }, type: 'video' | 'other', status = [ HttpStatusCode.NOT_FOUND_404 ]) {
 100     if (obj?.status && status.includes(obj.status)) {
 101       // Do not use redirectService to avoid circular dependencies
 102       this.router.navigate([ '/404' ], { state: { type, obj }, skipLocationChange: true })
 103     }
 104
 105     return observableThrowError(() => obj)
 106   }
 107 }