client.js 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306
  1. /*eslint-env browser*/
  2. /*global __resourceQuery __webpack_public_path__*/
  3. var options = {
  4. path: '/__webpack_hmr',
  5. timeout: 20 * 1000,
  6. overlay: true,
  7. reload: false,
  8. log: true,
  9. warn: true,
  10. name: '',
  11. autoConnect: true,
  12. overlayStyles: {},
  13. overlayWarnings: false,
  14. ansiColors: {},
  15. };
  16. if (__resourceQuery) {
  17. var querystring = require('querystring');
  18. var overrides = querystring.parse(__resourceQuery.slice(1));
  19. setOverrides(overrides);
  20. }
  21. if (typeof window === 'undefined') {
  22. // do nothing
  23. } else if (typeof window.EventSource === 'undefined') {
  24. console.warn(
  25. "webpack-hot-middleware's client requires EventSource to work. " +
  26. 'You should include a polyfill if you want to support this browser: ' +
  27. 'https://developer.mozilla.org/en-US/docs/Web/API/Server-sent_events#Tools'
  28. );
  29. } else {
  30. if (options.autoConnect) {
  31. connect();
  32. }
  33. }
  34. /* istanbul ignore next */
  35. function setOptionsAndConnect(overrides) {
  36. setOverrides(overrides);
  37. connect();
  38. }
  39. function setOverrides(overrides) {
  40. if (overrides.autoConnect)
  41. options.autoConnect = overrides.autoConnect == 'true';
  42. if (overrides.path) options.path = overrides.path;
  43. if (overrides.timeout) options.timeout = overrides.timeout;
  44. if (overrides.overlay) options.overlay = overrides.overlay !== 'false';
  45. if (overrides.reload) options.reload = overrides.reload !== 'false';
  46. if (overrides.noInfo && overrides.noInfo !== 'false') {
  47. options.log = false;
  48. }
  49. if (overrides.name) {
  50. options.name = overrides.name;
  51. }
  52. if (overrides.quiet && overrides.quiet !== 'false') {
  53. options.log = false;
  54. options.warn = false;
  55. }
  56. if (overrides.dynamicPublicPath) {
  57. options.path = __webpack_public_path__ + options.path;
  58. }
  59. if (overrides.ansiColors)
  60. options.ansiColors = JSON.parse(overrides.ansiColors);
  61. if (overrides.overlayStyles)
  62. options.overlayStyles = JSON.parse(overrides.overlayStyles);
  63. if (overrides.overlayWarnings) {
  64. options.overlayWarnings = overrides.overlayWarnings == 'true';
  65. }
  66. }
  67. function EventSourceWrapper() {
  68. var source;
  69. var lastActivity = new Date();
  70. var listeners = [];
  71. init();
  72. var timer = setInterval(function () {
  73. if (new Date() - lastActivity > options.timeout) {
  74. handleDisconnect();
  75. }
  76. }, options.timeout / 2);
  77. function init() {
  78. source = new window.EventSource(options.path);
  79. source.onopen = handleOnline;
  80. source.onerror = handleDisconnect;
  81. source.onmessage = handleMessage;
  82. }
  83. function handleOnline() {
  84. if (options.log) console.log('[HMR] connected');
  85. lastActivity = new Date();
  86. }
  87. function handleMessage(event) {
  88. lastActivity = new Date();
  89. for (var i = 0; i < listeners.length; i++) {
  90. listeners[i](event);
  91. }
  92. }
  93. function handleDisconnect() {
  94. clearInterval(timer);
  95. source.close();
  96. setTimeout(init, options.timeout);
  97. }
  98. return {
  99. addMessageListener: function (fn) {
  100. listeners.push(fn);
  101. },
  102. };
  103. }
  104. function getEventSourceWrapper() {
  105. if (!window.__whmEventSourceWrapper) {
  106. window.__whmEventSourceWrapper = {};
  107. }
  108. if (!window.__whmEventSourceWrapper[options.path]) {
  109. // cache the wrapper for other entries loaded on
  110. // the same page with the same options.path
  111. window.__whmEventSourceWrapper[options.path] = EventSourceWrapper();
  112. }
  113. return window.__whmEventSourceWrapper[options.path];
  114. }
  115. function connect() {
  116. getEventSourceWrapper().addMessageListener(handleMessage);
  117. function handleMessage(event) {
  118. if (event.data == '\uD83D\uDC93') {
  119. return;
  120. }
  121. try {
  122. processMessage(JSON.parse(event.data));
  123. } catch (ex) {
  124. if (options.warn) {
  125. console.warn('Invalid HMR message: ' + event.data + '\n' + ex);
  126. }
  127. }
  128. }
  129. }
  130. // the reporter needs to be a singleton on the page
  131. // in case the client is being used by multiple bundles
  132. // we only want to report once.
  133. // all the errors will go to all clients
  134. var singletonKey = '__webpack_hot_middleware_reporter__';
  135. var reporter;
  136. if (typeof window !== 'undefined') {
  137. if (!window[singletonKey]) {
  138. window[singletonKey] = createReporter();
  139. }
  140. reporter = window[singletonKey];
  141. }
  142. function createReporter() {
  143. var strip = require('strip-ansi');
  144. var overlay;
  145. if (typeof document !== 'undefined' && options.overlay) {
  146. overlay = require('./client-overlay')({
  147. ansiColors: options.ansiColors,
  148. overlayStyles: options.overlayStyles,
  149. });
  150. }
  151. var styles = {
  152. errors: 'color: #ff0000;',
  153. warnings: 'color: #999933;',
  154. };
  155. var previousProblems = null;
  156. function log(type, obj) {
  157. var newProblems = obj[type]
  158. .map(function (msg) {
  159. return strip(msg);
  160. })
  161. .join('\n');
  162. if (previousProblems == newProblems) {
  163. return;
  164. } else {
  165. previousProblems = newProblems;
  166. }
  167. var style = styles[type];
  168. var name = obj.name ? "'" + obj.name + "' " : '';
  169. var title = '[HMR] bundle ' + name + 'has ' + obj[type].length + ' ' + type;
  170. // NOTE: console.warn or console.error will print the stack trace
  171. // which isn't helpful here, so using console.log to escape it.
  172. if (console.group && console.groupEnd) {
  173. console.group('%c' + title, style);
  174. console.log('%c' + newProblems, style);
  175. console.groupEnd();
  176. } else {
  177. console.log(
  178. '%c' + title + '\n\t%c' + newProblems.replace(/\n/g, '\n\t'),
  179. style + 'font-weight: bold;',
  180. style + 'font-weight: normal;'
  181. );
  182. }
  183. }
  184. return {
  185. cleanProblemsCache: function () {
  186. previousProblems = null;
  187. },
  188. problems: function (type, obj) {
  189. if (options.warn) {
  190. log(type, obj);
  191. }
  192. if (overlay) {
  193. if (options.overlayWarnings || type === 'errors') {
  194. overlay.showProblems(type, obj[type]);
  195. return false;
  196. }
  197. overlay.clear();
  198. }
  199. return true;
  200. },
  201. success: function () {
  202. if (overlay) overlay.clear();
  203. },
  204. useCustomOverlay: function (customOverlay) {
  205. overlay = customOverlay;
  206. },
  207. };
  208. }
  209. var processUpdate = require('./process-update');
  210. var customHandler;
  211. var subscribeAllHandler;
  212. function processMessage(obj) {
  213. switch (obj.action) {
  214. case 'building':
  215. if (options.log) {
  216. console.log(
  217. '[HMR] bundle ' +
  218. (obj.name ? "'" + obj.name + "' " : '') +
  219. 'rebuilding'
  220. );
  221. }
  222. break;
  223. case 'built':
  224. if (options.log) {
  225. console.log(
  226. '[HMR] bundle ' +
  227. (obj.name ? "'" + obj.name + "' " : '') +
  228. 'rebuilt in ' +
  229. obj.time +
  230. 'ms'
  231. );
  232. }
  233. // fall through
  234. case 'sync':
  235. if (obj.name && options.name && obj.name !== options.name) {
  236. return;
  237. }
  238. var applyUpdate = true;
  239. if (obj.errors.length > 0) {
  240. if (reporter) reporter.problems('errors', obj);
  241. applyUpdate = false;
  242. } else if (obj.warnings.length > 0) {
  243. if (reporter) {
  244. var overlayShown = reporter.problems('warnings', obj);
  245. applyUpdate = overlayShown;
  246. }
  247. } else {
  248. if (reporter) {
  249. reporter.cleanProblemsCache();
  250. reporter.success();
  251. }
  252. }
  253. if (applyUpdate) {
  254. processUpdate(obj.hash, obj.modules, options);
  255. }
  256. break;
  257. default:
  258. if (customHandler) {
  259. customHandler(obj);
  260. }
  261. }
  262. if (subscribeAllHandler) {
  263. subscribeAllHandler(obj);
  264. }
  265. }
  266. if (module) {
  267. module.exports = {
  268. subscribeAll: function subscribeAll(handler) {
  269. subscribeAllHandler = handler;
  270. },
  271. subscribe: function subscribe(handler) {
  272. customHandler = handler;
  273. },
  274. useCustomOverlay: function useCustomOverlay(customOverlay) {
  275. if (reporter) reporter.useCustomOverlay(customOverlay);
  276. },
  277. setOptionsAndConnect: setOptionsAndConnect,
  278. };
  279. }