refactor: migrate server.listen from bin

fixes: #1510

Author: hiroppy

bin/webpack-dev-server.js

@@ -22,13 +22,10 @@ const Server = require('../lib/Server');
 
 const colors = require('../lib/utils/colors');
 const createConfig = require('../lib/utils/createConfig');
-const createDomain = require('../lib/utils/createDomain');
 const createLogger = require('../lib/utils/createLogger');
 const defaultTo = require('../lib/utils/defaultTo');
 const findPort = require('../lib/utils/findPort');
 const getVersions = require('../lib/utils/getVersions');
-const runBonjour = require('../lib/utils/runBonjour');
-const status = require('../lib/utils/status');
 const tryParseInt = require('../lib/utils/tryParseInt');
 
 let server;
@@ -159,11 +156,6 @@ function startDevServer(config, options) {
     }).apply(compiler);
   }
 
-  const suffix =
-    options.inline !== false || options.lazy === true
-      ? '/'
-      : '/webpack-dev-server/';
-
   try {
     server = new Server(compiler, options, log);
   } catch (err) {
@@ -200,52 +192,27 @@ function startDevServer(config, options) {
       }
     });
 
-    server.listen(options.socket, options.host, (err) => {
+    runServer();
+  } else if (options.port) {
+    runServer();
+  } else {
+    // only run port finder if no port as been specified
+    findPort(server, DEFAULT_PORT, defaultPortRetry, (err, port) => {
       if (err) {
         throw err;
       }
-      // chmod 666 (rw rw rw)
-      const READ_WRITE = 438;
-
-      fs.chmod(options.socket, READ_WRITE, (err) => {
-        if (err) {
-          throw err;
-        }
-
-        const uri = createDomain(options, server.listeningApp) + suffix;
-
-        status(uri, options, log, argv.color);
-      });
+      options.port = port;
+      runServer();
     });
-    return;
   }
 
-  const startServer = () => {
+  function runServer() {
     server.listen(options.port, options.host, (err) => {
       if (err) {
         throw err;
       }
-      if (options.bonjour) {
-        runBonjour(options);
-      }
-      const uri = createDomain(options, server.listeningApp) + suffix;
-      status(uri, options, log, argv.color);
     });
-  };
-
-  if (options.port) {
-    startServer();
-    return;
   }
-
-  // only run port finder if no port as been specified
-  findPort(server, DEFAULT_PORT, defaultPortRetry, (err, port) => {
-    if (err) {
-      throw err;
-    }
-    options.port = port;
-    startServer();
-  });
 }
 
 processOptions(config);

examples/api/simple/server.js

@@ -6,6 +6,7 @@ const webpackConfig = require('./webpack.config');
 
 const compiler = Webpack(webpackConfig);
 const devServerOptions = Object.assign({}, webpackConfig.devServer, {
+  open: true,
   stats: {
     colors: true,
   },

lib/Server.js

@@ -27,6 +27,10 @@ const validateOptions = require('schema-utils');
 const updateCompiler = require('./utils/updateCompiler');
 const createLogger = require('./utils/createLogger');
 const getCertificate = require('./utils/getCertificate');
+const status = require('./utils/status');
+const createDomain = require('./utils/createDomain');
+const runBonjour = require('./utils/runBonjour');
+const open = require('./utils/open');
 const routes = require('./utils/routes');
 const schema = require('./options.json');
 
@@ -809,6 +813,45 @@ class Server {
         prefix: this.sockPath,
       });
 
+      if (this.options.bonjour) {
+        runBonjour(this.options);
+      }
+
+      const showStatusAndOpen = () => {
+        const suffix =
+          this.options.inline !== false || this.options.lazy === true
+            ? '/'
+            : '/webpack-dev-server/';
+
+        const uri = `${createDomain(this.options, this.listeningApp)}${suffix}`;
+
+        // TODO: don't emit when webpack-dev-server is used via Node.js API
+        status(
+          uri,
+          this.options,
+          this.log,
+          this.options.stats && this.options.stats.colors
+        );
+        if (this.options.open) {
+          open(uri, this.options, this.log);
+        }
+      };
+
+      if (this.options.socket) {
+        // chmod 666 (rw rw rw)
+        const READ_WRITE = 438;
+
+        fs.chmod(this.options.socket, READ_WRITE, (err) => {
+          if (err) {
+            throw err;
+          }
+
+          showStatusAndOpen();
+        });
+      } else {
+        showStatusAndOpen();
+      }
+
       if (fn) {
         fn.call(this.listeningApp, err);
       }

lib/utils/open.js

@@ -0,0 +1,21 @@
+'use strict';
+
+const opn = require('opn');
+
+function open(uri, options, log) {
+  let openOptions = {};
+  let openMessage = 'Unable to open browser';
+
+  if (typeof options.open === 'string') {
+    openOptions = { app: options.open };
+    openMessage += `: ${options.open}`;
+  }
+
+  opn(`${uri}${options.openPage || ''}`, openOptions).catch(() => {
+    log.warn(
+      `${openMessage}. If you are running in a headless environment, please do not use the --open flag`
+    );
+  });
+}
+
+module.exports = open;

lib/utils/status.js

@@ -1,6 +1,5 @@
 'use strict';
 
-const open = require('opn');
 const colors = require('./colors');
 
 function status(uri, options, log, useColor) {
@@ -41,22 +40,6 @@ function status(uri, options, log, useColor) {
       'Broadcasting "http" with subtype of "webpack" via ZeroConf DNS (Bonjour)'
     );
   }
-
-  if (options.open) {
-    let openOptions = {};
-    let openMessage = 'Unable to open browser';
-
-    if (typeof options.open === 'string') {
-      openOptions = { app: options.open };
-      openMessage += `: ${options.open}`;
-    }
-
-    open(uri + (options.openPage || ''), openOptions).catch(() => {
-      log.warn(
-        `${openMessage}. If you are running in a headless environment, please do not use the --open flag`
-      );
-    });
-  }
 }
 
 module.exports = status;