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