X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=lib%2Fcommon.js;h=723f922b20930355d6adc53ead1fc97f6e719597;hb=refs%2Fheads%2Fv1.2-dev;hp=21070b8782918f267bf32e3adf96537df08e615a;hpb=4778ea0b65e1f22f3d85cfa8bad0e1b29f87b7d3;p=squeep-api-dingus diff --git a/lib/common.js b/lib/common.js index 21070b8..723f922 100644 --- a/lib/common.js +++ b/lib/common.js @@ -11,8 +11,15 @@ const uuid = require('uuid'); const Enum = require('./enum'); /** - * Return a function which combines a part of the filename with a scope, for use in logging. - * @param {string} filename + * @callback ScopeFn + * @param {String} scope + * @returns {String} + */ +/** + * Return a function which prefixes a provided scope with the most- + * relevant part of the filename, for use in logging. + * @param {String} filename + * @returns {ScopeFn} */ const fileScope = (filename) => { let fScope = path.basename(filename, '.js'); @@ -20,17 +27,18 @@ const fileScope = (filename) => { fScope = path.basename(path.dirname(filename)); } return (scope) => `${fScope}:${scope}`; -} +}; /** * Simple ETag from data. - * @param {string} filePath - * @param {object} fileStat - * @param {*} fileData + * @param {String} filePath (currently unused) + * @param {fs.Stats} fileStat + * @param {crypto.BinaryLike} fileData content + * @returns {String} */ const generateETag = (_filePath, fileStat, fileData) => { const hash = crypto.createHash('sha256'); - if (fileStat && fileStat.mtimeMs) { + if (fileStat?.mtimeMs) { hash.update(fileStat.mtimeMs.toString()); } hash.update(fileData); @@ -39,16 +47,19 @@ const generateETag = (_filePath, fileStat, fileData) => { }; /** - * @param {object} obj - * @param {string} prop - * @param {*} def + * Access property with default. + * @param {Object} obj + * @param {String} prop + * @param {*} def default value if prop does not exist for obj + * @return {*} */ const get = (obj, prop, def) => obj && prop && (prop in obj) ? obj[prop] : def; /** * @param {http.ClientRequest} req * @param {http.ServerResponse} res - * @param {object} ctx + * @param {Object} ctx + * @deprecated after v1.2.5 (integrated into logger module) */ const handlerLogData = (req, res, ctx) => ({ req: requestLogData(req), @@ -57,10 +68,12 @@ const handlerLogData = (req, res, ctx) => ({ }); /** - * + * Determine whether a client has already requested a resource, + * based on If-Modified-Since and If-None-Match headers. * @param {http.ClientRequest} req * @param {Number} modifiedTimeMs - * @param {string} eTag + * @param {String} eTag + * @returns {Boolean} */ const isClientCached = (req, modifiedTimeMs, eTag) => { let clientCached = false; @@ -93,6 +106,7 @@ const isClientCached = (req, modifiedTimeMs, eTag) => { * Expects only one-level deep, is not recursive! * @param {Object} origEnum * @param {Object} additionalEnum + * @returns {Object} */ const mergeEnum = (origEnum, additionalEnum) => { for (const e of Object.keys(additionalEnum)) { @@ -118,9 +132,9 @@ const httpStatusCodeClass = (statusCode) => Math.floor(statusCode / 100); const _isObject = (obj) => obj && typeof obj === 'object'; const _isArray = (obj) => Array.isArray(obj); /** - * Return a new object with all objects combined. - * @param {...any} objects - * @returns + * Return a new object with all objects combined, later properties taking precedence. + * @param {...Object} objects + * @returns {Object} */ const mergeDeep = (...objects) => { return objects.reduce((acc, obj) => { @@ -144,7 +158,8 @@ const mergeDeep = (...objects) => { /** * Return a new object with selected props. * @param {Object} obj - * @param {string[]} props + * @param {String[]} props + * @returns {Object} */ const pick = (obj, props) => { const picked = {}; @@ -160,6 +175,7 @@ const pick = (obj, props) => { * Return a subset of a request object, suitable for logging. * Obscures sensitive header values. * @param {http.ClientRequest} req + * @deprecated after v1.2.5 (integrated into logger module) */ const requestLogData = (req) => { const data = pick(req, [ @@ -178,20 +194,22 @@ const requestLogData = (req) => { * Remove sensitive header data. * @param {Object} data * @param {Object} data.headers + * @deprecated after v1.2.5 (integrated into logger module) */ const scrubHeaderObject = (data) => { - if (data && data.headers && 'authorization' in data.headers) { + if (data?.headers && 'authorization' in data.headers) { data.headers = Object.assign({}, data.headers, { authorization: obscureAuthorizationHeader(data.headers['authorization']), }); } -} +}; /** * Hide sensitive part of an Authorization header. * @param {String} authHeader * @returns {String} + * @deprecated after v1.2.5 (integrated into logger module) */ const obscureAuthorizationHeader = (authHeader) => { if (!authHeader) { @@ -200,12 +218,13 @@ const obscureAuthorizationHeader = (authHeader) => { const space = authHeader.indexOf(' '); // This blurs entire string if no space found, because -1. return authHeader.slice(0, space + 1) + '*'.repeat(authHeader.length - (space + 1)); -} +}; /** * Return a subset of a response object, suitable for logging. * @param {http.ServerResponse} res + * @deprecated after v1.2.5 (integrated into logger module) */ const responseLogData = (res) => { const response = pick(res, [ @@ -218,7 +237,7 @@ const responseLogData = (res) => { /** - * Store updates to defaultOptions, but no new properties. + * Store all properties in defaultOptions on target from either options or defaultOptions. * @param {Object} target * @param {Object} defaultOptions * @param {Object} options @@ -228,10 +247,10 @@ const setOptions = (target, defaultOptions, options) => { }; /** - * Return a list of source split at first delimiter. - * @param {string} src - * @param {string} delimiter - * @param {string} fill trailing stand-in if no delimiter in src + * Return a two-item list of src, split at first delimiter encountered. + * @param {String} src + * @param {String} delimiter + * @param {String} fill trailing stand-in if no delimiter in src */ const splitFirst = (src, delimiter, fill) => { const idx = src.indexOf(delimiter); @@ -243,14 +262,21 @@ const splitFirst = (src, delimiter, fill) => { }; /** - * Generate a new request identifier. + * Generate a new request identifier, a time/host-based uuid. * @returns {String} */ const requestId = () => { return uuid.v1(); }; +/** + * Do nothing. + */ const nop = () => { /**/ }; + +/** + * A logger object which does nothing. + */ const nullLogger = { error: nop, warn: nop, @@ -260,8 +286,10 @@ const nullLogger = { }; /** - * Populates any absent logger levels. + * Populates any absent logger level functions on a logger object. * @param {Object} logger + * @returns {Object} + * @deprecated after v1.2.9 (this is not our responsibility) */ const ensureLoggerLevels = (logger = {}) => { for (const level in nullLogger) { @@ -275,11 +303,12 @@ const ensureLoggerLevels = (logger = {}) => { /** * Merges folded header lines * @param {String[]} lines + * @returns {String} */ const unfoldHeaderLines = (lines) => { const foldedLineRE = /^(\t| +)(.*)$/; if (lines) { - lines.reduceRight((_, line, idx) => { + lines.reduceRight((_, line, idx) => { // NOSONAR const result = foldedLineRE.exec(line); if (result && idx) { const prevIdx = idx - 1;