1
0
Fork 0
mirror of https://github.com/terribleplan/next.js.git synced 2024-01-19 02:48:18 +00:00
next.js/server/hot-reloader.js

160 lines
4 KiB
JavaScript
Raw Normal View History

2016-10-24 15:20:50 +00:00
import { join, relative, sep } from 'path'
2016-10-14 15:05:08 +00:00
import WebpackDevServer from 'webpack-dev-server'
2016-10-17 07:05:46 +00:00
import webpack from './build/webpack'
2016-10-15 19:49:42 +00:00
import read from './read'
2016-10-14 15:05:08 +00:00
export default class HotReloader {
2016-10-17 07:05:46 +00:00
constructor (dir) {
this.dir = dir
this.server = null
2016-10-19 12:41:45 +00:00
this.stats = null
this.compilationErrors = null
2016-10-24 07:22:15 +00:00
this.prevAssets = null
2016-10-24 15:20:50 +00:00
this.prevChunkHashes = null
2016-10-17 07:05:46 +00:00
}
async start () {
await this.prepareServer()
2016-10-19 12:41:45 +00:00
this.stats = await this.waitUntilValid()
2016-10-17 07:05:46 +00:00
await this.listen()
}
async prepareServer () {
const compiler = await webpack(this.dir, { hotReload: true })
2016-10-15 19:49:42 +00:00
compiler.plugin('after-emit', (compilation, callback) => {
const { assets } = compilation
2016-10-24 07:22:15 +00:00
if (this.prevAssets) {
for (const f of Object.keys(assets)) {
deleteCache(assets[f].existsAt)
}
for (const f of Object.keys(this.prevAssets)) {
if (!assets[f]) {
deleteCache(this.prevAssets[f].existsAt)
}
2016-10-23 16:42:13 +00:00
}
}
this.prevAssets = assets
2016-10-24 07:22:15 +00:00
2016-10-15 19:49:42 +00:00
callback()
})
2016-10-14 15:05:08 +00:00
2016-10-19 12:41:45 +00:00
compiler.plugin('done', (stats) => {
this.stats = stats
this.compilationErrors = null
2016-10-24 07:22:15 +00:00
2016-10-24 15:20:50 +00:00
const chunkHashes = {}
stats.compilation.chunks.map((c) => {
chunkHashes[c.name] = c.hash
})
2016-10-24 07:22:15 +00:00
2016-10-24 15:20:50 +00:00
if (this.prevChunkHashes) {
const names = new Set(Object.keys(chunkHashes))
const prevNames = new Set(Object.keys(this.prevChunkHashes))
const added = diff(names, prevNames)
const removed = diff(prevNames, names)
const failed = new Set(stats.compilation.errors
.map((e) => e.module.reasons)
.reduce((a, b) => a.concat(b), [])
.map((r) => r.module.chunks)
.reduce((a, b) => a.concat(b), [])
.map((c) => c.name)
.filter((n) => chunkHashes[n] !== this.prevChunkHashes[n]))
const rootDir = join('bundles', 'pages')
for (const n of new Set([...added, ...removed, ...failed])) {
const route = toRoute(relative(rootDir, n))
this.send('reload', route)
2016-10-24 07:22:15 +00:00
}
}
2016-10-24 15:20:50 +00:00
this.prevChunkHashes = chunkHashes
2016-10-19 12:41:45 +00:00
})
2016-10-17 07:05:46 +00:00
this.server = new WebpackDevServer(compiler, {
publicPath: '/',
hot: true,
noInfo: true,
2016-10-18 09:33:49 +00:00
clientLogLevel: 'warning',
stats: {
assets: false,
children: false,
chunks: false,
color: false,
errors: true,
errorDetails: false,
hash: false,
modules: false,
publicPath: false,
reasons: false,
source: false,
timings: false,
version: false,
warnings: false
}
2016-10-17 07:05:46 +00:00
})
2016-10-14 15:05:08 +00:00
}
2016-10-19 12:41:45 +00:00
waitUntilValid () {
return new Promise((resolve) => {
2016-10-14 15:05:08 +00:00
this.server.middleware.waitUntilValid(resolve)
})
}
listen () {
return new Promise((resolve, reject) => {
this.server.listen(3030, (err) => {
if (err) return reject(err)
resolve()
})
})
}
2016-10-19 12:41:45 +00:00
getCompilationErrors () {
if (!this.compilationErrors) {
this.compilationErrors = new Map()
2016-10-24 15:20:50 +00:00
2016-10-19 12:41:45 +00:00
if (this.stats.hasErrors()) {
2016-10-24 15:20:50 +00:00
const { compiler, errors } = this.stats.compilation
for (const err of errors) {
for (const r of err.module.reasons) {
for (const c of r.module.chunks) {
// get the path of the bundle file
const path = join(compiler.outputPath, c.name)
const errors = this.compilationErrors.get(path) || []
this.compilationErrors.set(path, errors.concat([err]))
}
}
2016-10-19 12:41:45 +00:00
}
}
}
return this.compilationErrors
}
2016-10-24 07:22:15 +00:00
send (type, data) {
this.server.sockWrite(this.server.sockets, type, data)
}
2016-10-14 15:05:08 +00:00
get fileSystem () {
return this.server.middleware.fileSystem
}
}
2016-10-19 12:41:45 +00:00
function deleteCache (path) {
delete require.cache[path]
delete read.cache[path]
}
2016-10-24 07:22:15 +00:00
function diff (a, b) {
return new Set([...a].filter((v) => !b.has(v)))
}
2016-10-24 15:20:50 +00:00
function toRoute (file) {
const f = sep === '\\' ? file.replace(/\\/g, '/') : file
return ('/' + f).replace(/(\/index)?\.js$/, '') || '/'
}