strictAccept: true,
selfBaseUrl: '',
staticMetadata: true,
- staticPath: undefined, // no reasonable default
+ staticPath: undefined, // No reasonable default
trustProxy: true,
querystring,
};
* @param {Boolean} options.trustProxy trust some header data to be provided by proxy
* @param {Object} options.querystring alternate qs parser to use
*/
- constructor(logger = common.nullLogger, options = {}) {
+ constructor(logger = console, options = {}) {
common.setOptions(this, defaultOptions, options);
this.router = new Router(options);
];
this.logger = logger;
- common.ensureLoggerLevels(this.logger);
}
*/
_getAddress(req) {
// TODO: RFC7239 Forwarded support
- const address = (this.trustProxy && req && req.getHeader(Enum.Header.XForwardedFor)) ||
- (this.trustProxy && req && req.getHeader(Enum.Header.XRealIP)) ||
- (req && req.connection && req.connection.remoteAddress) ||
+ const address = (this.trustProxy && req?.getHeader(Enum.Header.XForwardedFor)) ||
+ (this.trustProxy && req?.getHeader(Enum.Header.XRealIP)) ||
+ (req?.connection?.remoteAddress) ||
'';
return address.split(/\s*,\s*/u)[0];
}
*/
_getProtocol(req) {
// TODO: RFC7239 Forwarded support
- const protocol = (this.trustProxy && req && req.getHeader(Enum.Header.XForwardedProto)) ||
- ((req && req.connection && req.connection.encrypted) ? 'https' : 'http');
+ const protocol = (this.trustProxy && req?.getHeader(Enum.Header.XForwardedProto)) ||
+ ((req?.connection?.encrypted) ? 'https' : 'http');
return protocol.split(/\s*,\s*/u)[0];
}
* Parse rawBody as contentType into ctx.parsedBody.
* @param {string} contentType
* @param {object} ctx
- * @param {string|buffer}
+ * @param {string|buffer} rawBody
*/
parseBody(contentType, ctx, rawBody) {
const _scope = _fileScope('parseBody');
- if (!rawBody) {
- // 1.2.4 and earlier expected rawBody on context
- rawBody = ctx.rawBody;
- }
-
switch (contentType) {
case Enum.ContentType.ApplicationForm:
ctx.parsedBody = this.querystring.parse(rawBody);
* Return all body data from a request.
* @param {http.ClientRequest} req
* @param {Number=} maximumBodySize
+ * @param {Boolean=} toString
*/
- async bodyData(req, maximumBodySize) {
+ async bodyData(req, maximumBodySize, toString = true) {
const _scope = _fileScope('bodyData');
return new Promise((resolve, reject) => {
const body = [];
reject(new ResponseError(Enum.ErrorResponse.RequestEntityTooLarge));
}
});
- req.on('end', () => resolve(Buffer.concat(body).toString()));
+ req.on('end', () => {
+ const bodyBuffer = Buffer.concat(body);
+ resolve(toString ? bodyBuffer.toString() : bodyBuffer);
+ });
req.on('error', (e) => {
this.logger.error(_scope, 'failed', { error: e });
reject(e);
// We will not deal with any subdirs, nor any dot-files.
// (Note that we could not deal with subdirs even if we wanted, due to simple router matching scheme.)
if (fileName.indexOf(path.sep) >= 0
- || fileName.charAt(0) === '.') {
+ || fileName.startsWith('.')) {
this.logger.debug(_scope, 'rejected filename', { fileName });
return this.handlerNotFound(req, res, ctx);
}
break;
}
const suffix = Enum.EncodingTypeSuffix[encoding];
- if (suffix) {
- const encodedFilePath = `${filePath}${suffix}`;
- const [ encodedStat, encodedData ] = await this._readFileInfo(encodedFilePath);
- if (encodedStat) {
- ([ stat, data ] = [ encodedStat, encodedData ]);
- ctx.selectedEncoding = encoding;
- Dingus.addEncodingHeader(res, encoding);
- res.setHeader(Enum.Header.Vary, Enum.Header.AcceptEncoding);
- this.logger.debug(_scope, 'serving encoded version', { ctx, encodedFilePath });
- }
- break;
+ if (!suffix) {
+ this.logger.error(_scope, 'supported encoding missing mapped suffix', { ctx, encoding });
+ continue;
+ }
+ const encodedFilePath = `${filePath}${suffix}`;
+ const [ encodedStat, encodedData ] = await this._readFileInfo(encodedFilePath);
+ if (encodedStat) {
+ ([ stat, data ] = [ encodedStat, encodedData ]);
+ ctx.selectedEncoding = encoding;
+ Dingus.addEncodingHeader(res, encoding);
+ res.setHeader(Enum.Header.Vary, Enum.Header.AcceptEncoding);
+ this.logger.debug(_scope, 'serving encoded version', { ctx, encodedFilePath });
}
+ break;
}
const lastModifiedDate = new Date(stat.mtimeMs);
res.setHeader(Enum.Header.ContentType, Enum.ContentType.TextPlain);
}
- if (err && err.statusCode) {
+ if (err?.statusCode) {
res.statusCode = err.statusCode;
body = this.renderError(res.getHeader(Enum.Header.ContentType), err);
this.logger.debug(_scope, 'handler error', { err, req, res, ctx });