-
Notifications
You must be signed in to change notification settings - Fork 248
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
caoli
committed
Feb 28, 2018
1 parent
b50ebd9
commit bf0019c
Showing
9 changed files
with
151 additions
and
18 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -13,4 +13,5 @@ app/web/store | |
| plugins/ | ||
| app/web/asset/ | ||
| app/view/ | ||
| test.js | ||
| test.js | ||
| script/webpack4/ | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,6 @@ | ||
| 'use strict'; | ||
| const path = require('path'); | ||
| const fs = require('fs'); | ||
| const source = path.join(process.cwd(), 'script/webpack4/webpack-hot-middleware/middleware.js'); | ||
| const target = path.join(process.cwd(), 'node_modules/webpack-hot-middleware/middleware.js'); | ||
| fs.createReadStream(source).pipe(fs.createWriteStream(target)); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,128 @@ | ||
| module.exports = webpackHotMiddleware; | ||
|
|
||
| var helpers = require('./helpers'); | ||
| var pathMatch = helpers.pathMatch; | ||
|
|
||
| function webpackHotMiddleware(compiler, opts) { | ||
| opts = opts || {}; | ||
| opts.log = typeof opts.log == 'undefined' ? console.log.bind(console) : opts.log; | ||
| opts.path = opts.path || '/__webpack_hmr'; | ||
| opts.heartbeat = opts.heartbeat || 10 * 1000; | ||
|
|
||
| var eventStream = createEventStream(opts.heartbeat); | ||
| var latestStats = null; | ||
|
|
||
| if(compiler.hooks) { | ||
| compiler.hooks.run.tap("webpackHotMiddleware", function() { | ||
| latestStats = null; | ||
| if (opts.log) opts.log("webpack building..."); | ||
| eventStream.publish({action: "building"}); | ||
| }); | ||
| compiler.hooks.done.tap("webpackHotMiddleware", function(statsResult) { | ||
| // Keep hold of latest stats so they can be propagated to new clients | ||
| latestStats = statsResult; | ||
| publishStats("built", latestStats, eventStream, opts.log); | ||
| }); | ||
| } else { | ||
| compiler.plugin("compile", function() { | ||
| latestStats = null; | ||
| if (opts.log) opts.log("webpack building..."); | ||
| eventStream.publish({action: "building"}); | ||
| }); | ||
| compiler.plugin("done", function(statsResult) { | ||
| // Keep hold of latest stats so they can be propagated to new clients | ||
| latestStats = statsResult; | ||
| publishStats("built", latestStats, eventStream, opts.log); | ||
| }); | ||
| } | ||
| var middleware = function(req, res, next) { | ||
| if (!pathMatch(req.url, opts.path)) return next(); | ||
| eventStream.handler(req, res); | ||
| if (latestStats) { | ||
| // Explicitly not passing in `log` fn as we don't want to log again on | ||
| // the server | ||
| publishStats("sync", latestStats, eventStream); | ||
| } | ||
| }; | ||
| middleware.publish = eventStream.publish; | ||
| return middleware; | ||
| } | ||
|
|
||
| function createEventStream(heartbeat) { | ||
| var clientId = 0; | ||
| var clients = {}; | ||
| function everyClient(fn) { | ||
| Object.keys(clients).forEach(function(id) { | ||
| fn(clients[id]); | ||
| }); | ||
| } | ||
| setInterval(function heartbeatTick() { | ||
| everyClient(function(client) { | ||
| client.write("data: \uD83D\uDC93\n\n"); | ||
| }); | ||
| }, heartbeat).unref(); | ||
| return { | ||
| handler: function(req, res) { | ||
| req.socket.setKeepAlive(true); | ||
| res.writeHead(200, { | ||
| 'Access-Control-Allow-Origin': '*', | ||
| 'Content-Type': 'text/event-stream;charset=utf-8', | ||
| 'Cache-Control': 'no-cache, no-transform', | ||
| 'Connection': 'keep-alive', | ||
| // While behind nginx, event stream should not be buffered: | ||
| // http://nginx.org/docs/http/ngx_http_proxy_module.html#proxy_buffering | ||
| 'X-Accel-Buffering': 'no' | ||
| }); | ||
| res.write('\n'); | ||
| var id = clientId++; | ||
| clients[id] = res; | ||
| req.on("close", function(){ | ||
| delete clients[id]; | ||
| }); | ||
| }, | ||
| publish: function(payload) { | ||
| everyClient(function(client) { | ||
| client.write("data: " + JSON.stringify(payload) + "\n\n"); | ||
| }); | ||
| } | ||
| }; | ||
| } | ||
|
|
||
| function publishStats(action, statsResult, eventStream, log) { | ||
| // For multi-compiler, stats will be an object with a 'children' array of stats | ||
| var bundles = extractBundles(statsResult.toJson({ errorDetails: false })); | ||
| bundles.forEach(function(stats) { | ||
| if (log) { | ||
| log("webpack built " + (stats.name ? stats.name + " " : "") + | ||
| stats.hash + " in " + stats.time + "ms"); | ||
| } | ||
| eventStream.publish({ | ||
| name: stats.name, | ||
| action: action, | ||
| time: stats.time, | ||
| hash: stats.hash, | ||
| warnings: stats.warnings || [], | ||
| errors: stats.errors || [], | ||
| modules: buildModuleMap(stats.modules) | ||
| }); | ||
| }); | ||
| } | ||
|
|
||
| function extractBundles(stats) { | ||
| // Stats has modules, single bundle | ||
| if (stats.modules) return [stats]; | ||
|
|
||
| // Stats has children, multiple bundles | ||
| if (stats.children && stats.children.length) return stats.children; | ||
|
|
||
| // Not sure, assume single | ||
| return [stats]; | ||
| } | ||
|
|
||
| function buildModuleMap(modules) { | ||
| var map = {}; | ||
| modules.forEach(function(module) { | ||
| map[module.id] = module.name; | ||
| }); | ||
| return map; | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters