All files / lib/routes related.js

25% Statements 9/36
0% Branches 0/17
0% Functions 0/10
25.71% Lines 9/35
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80  1x   1x 1x 1x 1x 1x 1x 1x   1x                                                                                                                                        
'use strict'
const relatedRoute = module.exports = { }
 
const jsonApi = require('../jsonApi.js')
const async = require('async')
const helper = require('./helper.js')
const router = require('../router.js')
const postProcess = require('../postProcess.js')
const responseHelper = require('../responseHelper.js')
const pagination = require('../pagination.js')
 
relatedRoute.register = () => {
  router.bindRoute({
    verb: 'get',
    path: ':type/:id/:relation'
  }, (request, resourceConfig, res) => {
    let relation
    let mainResource
    let relatedResources
    let response
 
    async.waterfall([
      callback => {
        helper.verifyRequest(request, resourceConfig, res, 'find', callback)
      },
      callback => {
        relation = resourceConfig.attributes[request.params.relation]
        if (!relation || !relation._settings || !(relation._settings.__one || relation._settings.__many)) {
          return callback({ // eslint-disable-line standard/no-callback-literal
            status: '404',
            code: 'ENOTFOUND',
            title: 'Resource not found',
            detail: 'The requested relation does not exist within the requested type'
          })
        }
        if (relation._settings.__as) {
          return callback({ // eslint-disable-line standard/no-callback-literal
            status: '404',
            code: 'EFOREIGN',
            title: 'Relation is Foreign',
            detail: 'The requested relation is a foreign relation and cannot be accessed in this manner.'
          })
        }
        callback()
      },
      function validatePaginationParams (callback) {
        pagination.validatePaginationParams(request)
        return callback()
      },
      callback => {
        resourceConfig.handlers.find(request, callback)
      },
      (result, callback) => {
        mainResource = result
        postProcess._fetchRelatedResources(request, mainResource, callback)
      },
      (newResources, total, callback) => {
        relatedResources = newResources
        if (relation._settings.__one) {
          // if this is a hasOne, then disable pagination meta data.
          total = null
          relatedResources = relatedResources[0]
        }
        request.resourceConfig = (relation._settings.__one || relation._settings.__many).map(resourceName => {
          return jsonApi._resources[resourceName]
        })
 
        response = responseHelper._generateResponse(request, resourceConfig, relatedResources, total)
        if (relatedResources !== null) {
          response.included = [ ]
        }
        postProcess.handle(request, response, callback)
      }
    ], err => {
      if (err) return helper.handleError(request, res, err)
      return router.sendResponse(res, response, 200)
    })
  })
}