Function routeHandler

lib/route.js:463–591

(req, res, params, context, query)

  class="cm">// HTTP request entry point, the routing has already been executed
  function routeHandler (req, res, params, context, query) {
    const id = getGenReqId(context.server, req)

    const loggerOpts = {
      level: context.logLevel
    }

    if (context.logSerializers) {
      loggerOpts.serializers = context.logSerializers
    }
    const childLogger = createChildLogger(context, logger, req, id, loggerOpts)
    class="cm">// Set initial value; will be re-evaluated after FastifyRequest is constructed if it's a function
    childLogger[kDisableRequestLogging] = disableRequestLoggingFn ? false : disableRequestLogging

    if (closing === true) {
      /* istanbul ignore next mac, windows */
      if (req.httpVersionMajor !== 2) {
        res.setHeader(class="st">'Connection', class="st">'close')
      }

      class="cm">// Load-shedding fast path during drain. server.close() and
      class="cm">// closeIdleConnections() only reap idle sockets; requests already
      class="cm">// pipelined or arriving on an active keep-alive connection still reach
      class="cm">// this point with closing === true. Short-circuiting with 503 avoids
      class="cm">// running the full handler chain (and any downstream calls) for work
      class="cm">// the load balancer should redirect elsewhere.
      if (return503OnClosing) {
        const headers = {
          class="st">'Content-Type': class="st">'application/json',
          class="st">'Content-Length': class="st">'80'
        }
        res.writeHead(503, headers)
        res.end(class="st">'{"error":"Service Unavailable","message":"Service Unavailable","statusCode":503}')
        childLogger.info({ res: { statusCode: 503 } }, class="st">'request aborted - refusing to accept new requests as server is closing')
        return
      }
    }

    class="cm">// When server.forceCloseConnections is true, we will collect any requests
    class="cm">// that have indicated they want persistence so that they can be reaped
    class="cm">// on server close. Otherwise, the container is a noop container.
    const connHeader = String.prototype.toLowerCase.call(req.headers.connection || class="st">'')
    if (connHeader === class="st">'keep-alive') {
      if (keepAliveConnections.has(req.socket) === false) {
        keepAliveConnections.add(req.socket)
        req.socket.on(class="st">'close', removeTrackedSocket.bind({ keepAliveConnections, socket: req.socket }))
      }
    }

    class="cm">// we revert the changes in defaultRoute
    if (req.headers[kRequestAcceptVersion] !== undefined) {
      req.headers[class="st">'accept-version'] = req.headers[kRequestAcceptVersion]
      req.headers[kRequestAcceptVersion] = undefined
    }

    const request = new context.Request(id, params, req, query, childLogger, context)
    const reply = new context.Reply(res, request, childLogger)