builder/lib/processors/minifier.js - UI5 Tooling

import {fileURLToPath} from "node:url";
import posixPath from "node:path/posix";
import {promisify} from "node:util";
import os from "node:os";
import workerpool from "workerpool";
import Resource from "@ui5/fs/Resource";
import {getLogger} from "@ui5/logger";
const log = getLogger("builder:processors:minifier");
import {setTimeout as setTimeoutPromise} from "node:timers/promises";
const debugFileRegex = /((?:\.view|\.fragment|\.controller|\.designtime|\.support)?\.js)$/;
const MIN_WORKERS = 2;
const MAX_WORKERS = 4;
const osCpus = os.cpus().length || 1;
const maxWorkers = Math.max(Math.min(osCpus - 1, MAX_WORKERS), MIN_WORKERS);
const sourceMappingUrlPattern = /\/\/# sourceMappingURL=(\S+)\s*$/;
const httpPattern = /^https?:\/\//i;
// Shared workerpool across all executions until the taskUtil cleanup is triggered
let pool;
function getPool(taskUtil) {
	if (!pool) {
		log.verbose(`Creating workerpool with up to ${maxWorkers} workers (available CPU cores: ${osCpus})`);
		const workerPath = fileURLToPath(new URL("./minifierWorker.js", import.meta.url));
		pool = workerpool.pool(workerPath, {
			workerType: "auto",
			maxWorkers
		});
		taskUtil.registerCleanupTask((force) => {
			const attemptPoolTermination = async () => {
				log.verbose(`Attempt to terminate the workerpool...`);
				if (!pool) {
					return;
				}
				// There are many stats that could be used, but these ones seem the most
				// convenient. When all the (available) workers are idle, then it's safe to terminate.
				let {idleWorkers, totalWorkers} = pool.stats();
				while (idleWorkers !== totalWorkers && !force) {
					await setTimeoutPromise(100); // Wait a bit workers to finish and try again
					if (!pool) { // pool might have been terminated in the meantime
						return;
					}
					({idleWorkers, totalWorkers} = pool.stats());
				}
				const poolToBeTerminated = pool;
				pool = null;
				return poolToBeTerminated.terminate(force);
			};
			return attemptPoolTermination();
		});
	}
	return pool;
}
async function minifyInWorker(options, taskUtil) {
	return getPool(taskUtil).exec("execMinification", [options]);
}
async function extractAndRemoveSourceMappingUrl(resource) {
	const resourceContent = await resource.getString();
	const resourcePath = resource.getPath();
	const sourceMappingUrlMatch = resourceContent.match(sourceMappingUrlPattern);
	if (sourceMappingUrlMatch) {
		const sourceMappingUrl = sourceMappingUrlMatch[1];
		if (log.isLevelEnabled("silly")) {
			log.silly(`Found source map reference in content of resource ${resourcePath}: ${sourceMappingUrl}`);
		}
		// Strip sourceMappingURL from the resource to be minified
		// It is not required anymore and will be replaced for in the minified resource
		// and its debug variant anyways
		resource.setString(resourceContent.replace(sourceMappingUrlPattern, ""));
		return sourceMappingUrl;
	}
	return null;
}
async function getSourceMapFromUrl({sourceMappingUrl, resourcePath, readFile}) {
	// =======================================================================
	// This code is almost identical to code located in lbt/bundle/Builder.js
	// Please try to update both places when making changes
	// =======================================================================
	if (sourceMappingUrl.startsWith("data:")) {
		// Data-URI indicates an inline source map
		const expectedTypeAndEncoding = "data:application/json;charset=utf-8;base64,";
		if (sourceMappingUrl.startsWith(expectedTypeAndEncoding)) {
			const base64Content = sourceMappingUrl.slice(expectedTypeAndEncoding.length);
			// Create a resource with a path suggesting it's the source map for the resource
			// (which it is but inlined)
			return Buffer.from(base64Content, "base64").toString();
		} else {
			log.warn(
				`Source map reference in resource ${resourcePath} is a data URI but has an unexpected` +
				`encoding: ${sourceMappingUrl}. Expected it to start with ` +
				`"data:application/json;charset=utf-8;base64,"`);
		}
	} else if (httpPattern.test(sourceMappingUrl)) {
		log.warn(`Source map reference in resource ${resourcePath} is an absolute URL. ` +
			`Currently, only relative URLs are supported.`);
	} else if (posixPath.isAbsolute(sourceMappingUrl)) {
		log.warn(`Source map reference in resource ${resourcePath} is an absolute path. ` +
			`Currently, only relative paths are supported.`);
	} else {
		const sourceMapPath = posixPath.join(posixPath.dirname(resourcePath), sourceMappingUrl);
		try {
			const sourceMapContent = await readFile(sourceMapPath);
			return sourceMapContent.toString();
		} catch (e) {
			// No input source map
			log.warn(`Unable to read source map for resource ${resourcePath}: ${e.message}`);
		}
	}
}
/**
 * @public
 * @module @ui5/builder/processors/minifier
 */
/**
 * Result set
 *
 * @public
 * @typedef {object} MinifierResult
 * @property {@ui5/fs/Resource} resource Minified resource
 * @property {@ui5/fs/Resource} dbgResource Debug (non-minified) variant
 * @property {@ui5/fs/Resource} sourceMap Source Map
 */
/**
 * Minifies the supplied resources.
 *
 * @public
 * @function default
 * @static
 *
 * @param {object} parameters Parameters
 * @param {@ui5/fs/Resource[]} parameters.resources List of resources to be processed
 * @param {fs|module:@ui5/fs/fsInterface} parameters.fs Node fs or custom
 *    [fs interface]{@link module:@ui5/fs/fsInterface}. Required when setting "readSourceMappingUrl" to true
 * @param {@ui5/builder/tasks/TaskUtil|object} [parameters.taskUtil] TaskUtil instance.
 *    Required when using the <code>useWorkers</code> option
 * @param {object} [parameters.options] Options
 * @param {boolean} [parameters.options.readSourceMappingUrl=false]
 *   Whether to make use of any existing source maps referenced in the resources to be minified. Use this option to
 *   preserve references to the original source files, such as TypeScript files, in the generated source map.<br>
 *   If a resource has been modified by a previous task, any existing source map will be ignored regardless of this
 *    setting. This is to ensure that no inconsistent source maps are used. Check the verbose log for details.
 * @param {boolean} [parameters.options.addSourceMappingUrl=true]
 *   Whether to add a sourceMappingURL reference to the end of the minified resource
 * @param {boolean} [parameters.options.useWorkers=false]
 *  Whether to offload the minification task onto separate CPU threads. This often speeds up the build process
 * @returns {Promise<module:@ui5/builder/processors/minifier~MinifierResult[]>}
 *   Promise resolving with object of resource, dbgResource and sourceMap
 */
export default async function({
	resources, fs, taskUtil, options: {readSourceMappingUrl = false, addSourceMappingUrl = true, useWorkers = false
	} = {}}) {
	let minify;
	if (readSourceMappingUrl && !fs) {
		throw new Error(`Option 'readSourceMappingUrl' requires parameter 'fs' to be provided`);
	}
	if (useWorkers) {
		if (!taskUtil) {
			// TaskUtil is required for worker support
			throw new Error(`Minifier: Option 'useWorkers' requires a taskUtil instance to be provided`);
		}
		minify = minifyInWorker;
	} else {
		// Do not use workerpool
		minify = (await import("./minifierWorker.js")).default;
	}
	return Promise.all(resources.map(async (resource) => {
		const resourcePath = resource.getPath();
		const dbgPath = resourcePath.replace(debugFileRegex, "-dbg$1");
		const dbgFilename = posixPath.basename(dbgPath);
		const filename = posixPath.basename(resource.getPath());
		const sourceMapOptions = {
			filename
		};
		if (addSourceMappingUrl) {
			sourceMapOptions.url = filename + ".map";
		}
		// Remember contentModified flag before making changes to the resource via setString
		const resourceContentModified = resource.getSourceMetadata()?.contentModified;
		// In any case: Extract *and remove* source map reference from resource before cloning it
		const sourceMappingUrl = await extractAndRemoveSourceMappingUrl(resource);
		const code = await resource.getString();
		// Create debug variant based off the original resource before minification
		const dbgResource = await resource.clone();
		dbgResource.setPath(dbgPath);
		let dbgSourceMapResource;
		if (sourceMappingUrl) {
			if (resourceContentModified) {
				log.verbose(
					`Source map found in resource will be ignored because the resource has been ` +
					`modified in a previous task: ${resourcePath}`);
			} else if (readSourceMappingUrl) {
				// Try to find a source map reference in the to-be-minified resource
				// If we find one, provide it to terser as an input source map and keep using it for the
				// debug variant of the resource
				const sourceMapContent = await getSourceMapFromUrl({
					sourceMappingUrl,
					resourcePath,
					readFile: promisify(fs.readFile)
				});
				if (sourceMapContent) {
					const sourceMapJson = JSON.parse(sourceMapContent);
					if (sourceMapJson.sections) {
						// TODO 5.0
						// Module "@jridgewell/trace-mapping" (used by Terser) can't handle index map sections lacking
						// a "names" array. Since this is a common occurrence for UI5 Tooling bundles, we search for
						// such cases here and fix them until https://github.com/jridgewell/trace-mapping/pull/29 is
						// resolved and Terser upgraded the dependency
						// Create a dedicated clone before modifying the source map as to not alter the debug source map
						const clonedSourceMapJson = JSON.parse(sourceMapContent);
						clonedSourceMapJson.sections.forEach(({map}) => {
							if (!map.names) {
								// Add missing names array
								map.names = [];
							}
						});
						// Use modified source map as input source map
						sourceMapOptions.content = JSON.stringify(clonedSourceMapJson);
					} else {
						// Provide source map to terser as "input source map"
						sourceMapOptions.content = sourceMapContent;
					}
					// Use the original source map for the debug variant of the resource
					// First update the file reference within the source map
					sourceMapJson.file = dbgFilename;
					// Then create a new resource
					dbgSourceMapResource = new Resource({
						string: JSON.stringify(sourceMapJson),
						path: dbgPath + ".map"
					});
					// And reference the resource in the debug resource
					dbgResource.setString(code + `//# sourceMappingURL=${dbgFilename}.map\n`);
				}
			} else {
				// If the original resource content was unmodified and the input source map was not parsed,
				// re-add the original source map reference to the debug variant
				if (!sourceMappingUrl.startsWith("data:") && !sourceMappingUrl.endsWith(filename + ".map")) {
					// Do not re-add inline source maps as well as references to the source map of
					// the minified resource
					dbgResource.setString(code + `//# sourceMappingURL=${sourceMappingUrl}\n`);
				}
			}
		}
		const result = await minify({
			filename,
			dbgFilename,
			code,
			sourceMapOptions
		}, taskUtil);
		resource.setString(result.code);
		const sourceMapResource = new Resource({
			path: resource.getPath() + ".map",
			string: result.map
		});
		return {resource, dbgResource, sourceMapResource, dbgSourceMapResource};
	}));
}
export const __localFunctions__ = (process.env.NODE_ENV === "test") ?
	{getSourceMapFromUrl} : undefined;