Method routeRequest

lib/server.js:128–210

* Route requests on 's3' port * @param {http.IncomingMessage} req - http request object * @param {http.ServerResponse} res - http response object * @returns {undefined}

(req, res)

     * @returns {undefined}
     */
    routeRequest(req, res) {
        monitoringClient.httpActiveRequests.inc();
        const requestStartTime = process.hrtime.bigint();

        // Skip server access logs for heartbeat.
        const isLoggingEnabled = _config.serverAccessLogs
            && (_config.serverAccessLogs.mode === serverAccessLogsModes.LOG_ONLY
                || _config.serverAccessLogs.mode === serverAccessLogsModes.ENABLED);
        const isInternalRoute = req.url.startsWith('/_');
        const isBackbeatRoute = req.url.startsWith('/_/backbeat/');
        if (isLoggingEnabled && (!isInternalRoute || isBackbeatRoute)) {
            // eslint-disable-next-line no-param-reassign
            req.serverAccessLog = {
                enabled: false,
                startTime: requestStartTime,
                startTimeUnixMS: Date.now(),
            };

            // eslint-disable-next-line no-param-reassign
            res.serverAccessLog = {};

            res.on('finish', () => {
                // eslint-disable-next-line no-param-reassign
                req.serverAccessLog.onFinishEndTime = process.hrtime.bigint();
            });
        }

        // disable nagle algorithm
        req.socket.setNoDelay();
        res.on('close', () => {
            // this is tested by retrieveData
            // eslint-disable-next-line no-param-reassign
            res.isclosed = true;
        });

        const monitorEndOfRequest = () => {
            if (req.serverAccessLog) {
                // eslint-disable-next-line no-param-reassign
                req.serverAccessLog.onCloseEndTime = process.hrtime.bigint();
                logServerAccess(req, res);
            }

            const responseTimeInNs = Number(process.hrtime.bigint() - requestStartTime);
            const labels = {
                method: req.method,
                code: res.statusCode,
            };
            if (req.apiMethod) {
                labels.action = req.apiMethod;
            }
            monitoringClient.httpRequestsTotal.labels(labels).inc();
            monitoringClient.httpRequestDurationSeconds
                .labels(labels)
                .observe(responseTimeInNs / 1e9);
            monitoringClient.httpActiveRequests.dec();
        };
        res.on('close', monitorEndOfRequest);