@airyrooms/catela/api/PromiseHttpResourceExecutor.js

import request from 'superagent-bluebird-promise'
import { HttpMethod } from 'api/const'
import moment from 'moment'

class PromiseHttpResourceExecutor {
  constructor () {
    this._forbiddenHeadersInClient = ['cookie']
  }

  validate (resourceExecutionSpec) {
    return true
  }

  execute (resourceExecutionSpec, offlineCallback, errorCallback, successCallback, attachments, onProgressListener) {
    switch (resourceExecutionSpec.method) {
      case HttpMethod.POST:
        return this._executePOSTResourceExecution(resourceExecutionSpec, offlineCallback, errorCallback, successCallback, attachments, onProgressListener)
      case HttpMethod.GET:
        return this._executeGETResourceExecution(resourceExecutionSpec, offlineCallback, errorCallback, successCallback)
    }
  }

  _handleBadGateway (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_502] An error occurred when trying to execute resource. Error code: 502 - Bad Gateway.', null))
    }
  }

  _handleServerError (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_500] An error occurred when trying to execute resource. Error code: 500 - Internal server error.', null))
    }
  }

  _handleServerUnavailable (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_503] An error occurred when trying to execute resource. Error code: 503 - Server Unavailable.', null))
    }
  }

  _handleBadRequest (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_400] An error occurred when trying to execute resource. Error code: 400 - Bad Request.', null))
    }
  }

  _handleUnauthorized (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_401] An error occurred when trying to execute resource. Error code: 401 - Bad Gateway.', null))
    }
  }

  _handleForbidden (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_403] An error occurred when trying to execute resource. Error code: 403 - Forbidden.', null))
    }
  }

  _handleSuccess (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      let resourceExecutionResult = {
        status: result.status,
        body: result.body,
        headers: result.headers
      }
      successCallback(null, resourceExecutionResult)
    }
  }

  _handleNoContent (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      let resourceExecutionResult = {
        status: result.status,
        data: null,
        headers: result.headers
      }
      successCallback(null, resourceExecutionResult)
    }
  }

  _handleUnprocessableEntity (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_422] An error occurred when trying to execute resource. Error code: 422 - Unprocessable entity.', null))
    }
  }

  _handleUnsupportedMediaType (err, result, offlineCallback, errorCallback, successCallback) {
    if (err) {
      errorCallback(err, null)
    } else {
      errorCallback(new Error('[ERROR_CODE_415] An error occurred when trying to execute resource. Error code: 415 - Unsupported media type.', null))
    }
  }

  _isProcessOnNode () {
    return (typeof window === 'undefined' && typeof document === 'undefined')
  }

  _executeGETResourceExecution (resourceExecutionSpec, offlineCallback, errorCallback, successCallback) {
    let getRequest = request.get(resourceExecutionSpec.uri).withCredentials()

    if (resourceExecutionSpec.headers != null && typeof resourceExecutionSpec !== 'undefined') {
      if (__SERVER__) {
        Object.keys(resourceExecutionSpec.headers).forEach((h) => {
          getRequest.set(h, resourceExecutionSpec.headers[h])
        })
      } else {
        Object.keys(resourceExecutionSpec.headers).forEach((h) => {
          if (this._forbiddenHeadersInClient.indexOf(h.toLowerCase()) < 0) {
            getRequest.set(h, resourceExecutionSpec.headers[h])
          }
        })
      }
    }

    if (resourceExecutionSpec.timeout != null && typeof resourceExecutionSpec.timeout !== 'undefined') {
      getRequest.timeout(resourceExecutionSpec.timeout)
    }

    const now = moment().format('YYYY-MM-DD HH:mm:ss')
    const uri = resourceExecutionSpec.uri
    const timeStart = new Date().getTime()

    getRequest.end((err, result) => {
      const timeElapsed = new Date().getTime() - timeStart

      if (err) {
        if (this._isProcessOnNode())
          console.log(`INFO [${now}] [GET] ${uri} [ERROR] [MARKER] -> ${timeElapsed}ms`)
        return this._handleServerError(err, result, offlineCallback, errorCallback, successCallback)
      } else {
        if (this._isProcessOnNode()) {
          const status = result.status
          console.log(`INFO [${now}] [GET] ${uri} [STATUS: ${status}] [MARKER] -> ${timeElapsed}ms`)
        }
        switch (result.status) {
          case 502:
            return this._handleBadGateway(err, result, offlineCallback, errorCallback, successCallback)
          case 500:
            return this._handleServerError(err, result, offlineCallback, errorCallback, successCallback)
          case 503:
            return this._handleServerUnavailable(err, result, offlineCallback, errorCallback, successCallback)
          case 400:
            return this._handleBadRequest(err, result, offlineCallback, errorCallback, successCallback)
          case 401:
            return this._handleUnauthorized(err, result, offlineCallback, errorCallback, successCallback)
          case 403:
            return this._handleForbidden(err, result, offlineCallback, errorCallback, successCallback)
          case 200:
            return this._handleSuccess(null, result, offlineCallback, errorCallback, successCallback)
          case 204:
            return this._handleNoContent(err, result, offlineCallback, errorCallback, successCallback)
          case 422:
            return this._handleUnprocessableEntity(err, result, offlineCallback, errorCallback, successCallback)
          case 415:
            return this._handleUnsupportedMediaType(err, result, offlineCallback, errorCallback, successCallback)
        }
      }
    })
  }

  _executePOSTResourceExecution (resourceExecutionSpec, offlineCallback, errorCallback, successCallback, attachments, onProgressListener) {
    let postRequest = request.post(resourceExecutionSpec.uri).withCredentials()

    if (attachments) {
      Object.keys(attachments).forEach((key) => {
        postRequest.attach(key, attachments[key])
      })
    }

    if (onProgressListener) {
      postRequest.on('progress', onProgressListener)
    }

    if (resourceExecutionSpec.body != null && typeof resourceExecutionSpec.body !== 'undefined') {
      if (!attachments) {
        postRequest.send(JSON.stringify(resourceExecutionSpec.body))
      }
    }
    if (resourceExecutionSpec.contentType != null && typeof resourceExecutionSpec.contentType !== 'undefined') {
      postRequest.set('Content-Type', resourceExecutionSpec.contentType)
    }
    if (resourceExecutionSpec.timeout != null && typeof resourceExecutionSpec.timeout !== 'undefined') {
      postRequest.timeout(resourceExecutionSpec.timeout)
    }

    if (resourceExecutionSpec.headers != null && typeof resourceExecutionSpec !== 'undefined') {
      if (__SERVER__) {
        Object.keys(resourceExecutionSpec.headers).forEach((h) => {
          postRequest.set(h, resourceExecutionSpec.headers[h])
        })
      } else {
        Object.keys(resourceExecutionSpec.headers).forEach((h) => {
          if (this._forbiddenHeadersInClient.indexOf(h.toLowerCase()) < 0) {
            postRequest.set(h, resourceExecutionSpec.headers[h])
          }
        })
      }
    }

    const now = moment().format('YYYY-MM-DD HH:mm:ss')
    const uri = resourceExecutionSpec.uri
    const timeStart = new Date().getTime()

    postRequest.end((err, result) => {
      const timeElapsed = new Date().getTime() - timeStart

      if (err) {
        if (this._isProcessOnNode())
          console.log(`INFO [${now}] [POST] ${uri} [ERROR] [MARKER] -> ${timeElapsed}ms`)
        return this._handleServerError(err, result, offlineCallback, errorCallback, successCallback)
      } else {
        if (this._isProcessOnNode()) {
          const status = result.status
          console.log(`INFO [${now}] [POST] ${uri} [STATUS: ${status}] [MARKER] -> ${timeElapsed}ms`)
        }
        switch (result.status) {
          case 502:
            return this._handleBadGateway(err, result, offlineCallback, errorCallback, successCallback)
          case 500:
            return this._handleServerError(err, result, offlineCallback, errorCallback, successCallback)
          case 503:
            return this._handleServerUnavailable(err, result, offlineCallback, errorCallback, successCallback)
          case 400:
            return this._handleBadRequest(err, result, offlineCallback, errorCallback, successCallback)
          case 401:
            return this._handleUnauthorized(err, result, offlineCallback, errorCallback, successCallback)
          case 403:
            return this._handleForbidden(err, result, offlineCallback, errorCallback, successCallback)
          case 200:
            return this._handleSuccess(null, result, offlineCallback, errorCallback, successCallback)
          case 204:
            return this._handleNoContent(err, result, offlineCallback, errorCallback, successCallback)
          case 422:
            return this._handleUnprocessableEntity(err, result, offlineCallback, errorCallback, successCallback)
          case 415:
            return this._handleUnsupportedMediaType(err, result, offlineCallback, errorCallback, successCallback)
        }
      }
    })
  }
}

export default PromiseHttpResourceExecutor