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

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