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