mirror of https://github.com/webpack/webpack.git
				
				
				
			
		
			
				
	
	
		
			64 lines
		
	
	
		
			1.6 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
			
		
		
	
	
			64 lines
		
	
	
		
			1.6 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
/*
 | 
						|
	MIT License http://www.opensource.org/licenses/mit-license.php
 | 
						|
	Author Tobias Koppers @sokra
 | 
						|
*/
 | 
						|
 | 
						|
"use strict";
 | 
						|
 | 
						|
const { URL } = require("url");
 | 
						|
const NormalModule = require("../NormalModule");
 | 
						|
 | 
						|
/** @typedef {import("../Compiler")} Compiler */
 | 
						|
 | 
						|
class HttpUriPlugin {
 | 
						|
	/**
 | 
						|
	 * Apply the plugin
 | 
						|
	 * @param {Compiler} compiler the compiler instance
 | 
						|
	 * @returns {void}
 | 
						|
	 */
 | 
						|
	apply(compiler) {
 | 
						|
		compiler.hooks.compilation.tap(
 | 
						|
			"HttpUriPlugin",
 | 
						|
			(compilation, { normalModuleFactory }) => {
 | 
						|
				normalModuleFactory.hooks.resolveForScheme
 | 
						|
					.for("http")
 | 
						|
					.tap("HttpUriPlugin", resourceData => {
 | 
						|
						const url = new URL(resourceData.resource);
 | 
						|
						resourceData.path = url.origin + url.pathname;
 | 
						|
						resourceData.query = url.search;
 | 
						|
						resourceData.fragment = url.hash;
 | 
						|
						return /** @type {true} */ (true);
 | 
						|
					});
 | 
						|
				NormalModule.getCompilationHooks(compilation)
 | 
						|
					.readResourceForScheme.for("http")
 | 
						|
					.tapAsync("HttpUriPlugin", (resource, module, callback) => {
 | 
						|
						return require("http").get(new URL(resource), res => {
 | 
						|
							if (res.statusCode !== 200) {
 | 
						|
								res.destroy();
 | 
						|
								return callback(
 | 
						|
									new Error(`http request status code = ${res.statusCode}`)
 | 
						|
								);
 | 
						|
							}
 | 
						|
 | 
						|
							const bufferArr = [];
 | 
						|
 | 
						|
							res.on("data", chunk => {
 | 
						|
								bufferArr.push(chunk);
 | 
						|
							});
 | 
						|
 | 
						|
							res.on("end", () => {
 | 
						|
								if (!res.complete) {
 | 
						|
									return callback(new Error("http request was terminated"));
 | 
						|
								}
 | 
						|
 | 
						|
								callback(null, Buffer.concat(bufferArr));
 | 
						|
							});
 | 
						|
						});
 | 
						|
					});
 | 
						|
			}
 | 
						|
		);
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
module.exports = HttpUriPlugin;
 |