Function initServerProcess

src/dev-server/server-process.ts:13–135

(sendMsg: d.DevServerSendMessage)

import { createWebSocket, DevWebSocket } from './server-web-socket';

export function initServerProcess(sendMsg: d.DevServerSendMessage) {
  let server: Server = null;
  let webSocket: DevWebSocket = null;
  let serverCtx: d.DevServerContext = null;

  const buildResultsResolves: BuildRequestResolve[] = [];
  const compilerRequestResolves: CompilerRequestResolve[] = [];

  const startServer = async (msg: d.DevServerMessage) => {
    const devServerConfig = msg.startServer;
    devServerConfig.port = await findClosestOpenPort(
      devServerConfig.address,
      devServerConfig.port,
      devServerConfig.strictPort,
    );
    devServerConfig.browserUrl = getBrowserUrl(
      devServerConfig.protocol,
      devServerConfig.address,
      devServerConfig.port,
      devServerConfig.basePath,
      '/',
    );
    devServerConfig.root = normalizePath(devServerConfig.root);

    const sys = createNodeSys({ process });
    serverCtx = createServerContext(sys, sendMsg, devServerConfig, buildResultsResolves, compilerRequestResolves);
    server = createHttpServer(devServerConfig, serverCtx);

    webSocket = devServerConfig.websocket ? createWebSocket(server, sendMsg) : null;

    server.listen(devServerConfig.port, devServerConfig.address);
    serverCtx.isServerListening = true;

    if (devServerConfig.openBrowser) {
      const initialLoadUrl = getBrowserUrl(
        devServerConfig.protocol,
        devServerConfig.address,
        devServerConfig.port,
        devServerConfig.basePath,
        devServerConfig.initialLoadUrl || DEV_SERVER_INIT_URL,
      );
      openInBrowser({ url: initialLoadUrl });
    }

    sendMsg({ serverStarted: devServerConfig });
  };

  const closeServer = () => {
    const promises: Promise<any>[] = [];

    buildResultsResolves.forEach((r) => r.reject('dev server closed'));
    buildResultsResolves.length = 0;

    compilerRequestResolves.forEach((r) => r.reject('dev server closed'));
    compilerRequestResolves.length = 0;

    if (serverCtx) {
      if (serverCtx.sys) {