mirror of https://github.com/embarklabs/embark.git
171 lines
5.6 KiB
JavaScript
171 lines
5.6 KiB
JavaScript
const fs = require('../../core/fs.js');
|
|
var {canonicalHost} = require('../../utils/host.js');
|
|
var utils = require('../../utils/utils.js');
|
|
var Server = require('./server.js');
|
|
const opn = require('opn');
|
|
|
|
require('ejs');
|
|
const Templates = {
|
|
embark_building_placeholder: require('./templates/embark-building-placeholder.html.ejs')
|
|
};
|
|
|
|
class WebServer {
|
|
constructor(embark, options) {
|
|
this.embark = embark;
|
|
this.logger = embark.logger;
|
|
this.events = embark.events;
|
|
this.buildDir = embark.config.buildDir;
|
|
this.plugins = options.plugins;
|
|
this.webServerConfig = embark.config.webServerConfig;
|
|
if (!this.webServerConfig.enabled) {
|
|
return;
|
|
}
|
|
|
|
this.host = this.webServerConfig.host;
|
|
this.port = parseInt(this.webServerConfig.port, 10);
|
|
this.enableCatchAll = this.webServerConfig.enableCatchAll === true;
|
|
this.enableCatchAll = false; // FIXME when true, some Requests end up failing (eg: process-logs)
|
|
|
|
this.events.emit("status", __("Starting Server"));
|
|
this.server = new Server({logger: this.logger, host: this.host, port: this.port, events: this.events, plugins: this.plugins, enableCatchAll: this.enableCatchAll});
|
|
|
|
this.server = new Server({
|
|
logger: this.logger,
|
|
buildDir: this.buildDir,
|
|
events: this.events,
|
|
host: this.host,
|
|
port: this.port,
|
|
plugins: this.plugins,
|
|
openBrowser: this.webServerConfig.openBrowser
|
|
});
|
|
|
|
this.events.on('webserver:config:change', () => {
|
|
this.embark.config.webServerConfig = null;
|
|
this.embark.config.loadWebServerConfigFile();
|
|
this.webServerConfig = this.embark.config.webServerConfig;
|
|
this.host = this.webServerConfig.host;
|
|
this.port = this.webServerConfig.port;
|
|
this.server.host = this.host;
|
|
this.server.port = this.port;
|
|
|
|
this.testPort(() => {
|
|
this.server.stop((_err) => {
|
|
this.server.start((_err, message, port) => {
|
|
this.logger.info(message);
|
|
this.port = port;
|
|
this.events.request('open-browser', () => {});
|
|
});
|
|
});
|
|
});
|
|
});
|
|
|
|
this.testPort(() => {
|
|
this.listenToCommands();
|
|
this.registerConsoleCommands();
|
|
this.server.start((_err, message, port) => {
|
|
this.logger.info(message);
|
|
this.port = port;
|
|
this.setServiceCheck();
|
|
});
|
|
});
|
|
}
|
|
|
|
testPort(done) {
|
|
if (this.port === 0) {
|
|
this.logger.warn(__('Assigning an available port'));
|
|
this.server.port = 0;
|
|
return done();
|
|
}
|
|
utils.pingEndpoint(this.host, this.port, 'http', 'http', '', (err) => {
|
|
if (err) { // Port is ok
|
|
return done();
|
|
}
|
|
this.logger.warn(__('Webserver already running on port %s. Assigning an available port', this.port));
|
|
this.port = 0;
|
|
this.server.port = 0;
|
|
done();
|
|
});
|
|
this.server.start((_err, message) => this.logger.info(message));
|
|
}
|
|
|
|
setServiceCheck() {
|
|
const self = this;
|
|
|
|
this.events.request("services:register", 'Webserver', function (cb) {
|
|
let url = 'http://' + canonicalHost(self.host) + ':' + self.port;
|
|
utils.checkIsAvailable(url, function (available) {
|
|
let devServer = __('Webserver') + ' (' + url + ')';
|
|
let serverStatus = (available ? 'on' : 'off');
|
|
return cb({name: devServer, status: serverStatus});
|
|
});
|
|
});
|
|
|
|
this.events.on('check:wentOffline:Webserver', () => {
|
|
this.logger.info(__("Webserver is offline"));
|
|
});
|
|
}
|
|
|
|
listenToCommands() {
|
|
this.events.setCommandHandler('build-placeholder', (cb) => this.buildPlaceholderPage(cb));
|
|
this.events.setCommandHandler('open-browser', (cb) => this.openBrowser(cb));
|
|
this.events.setCommandHandler('start-webserver', (cb) => this.server.start(cb));
|
|
this.events.setCommandHandler('stop-webserver', (cb) => this.server.stop(cb));
|
|
this.events.setCommandHandler('logs:webserver:turnOn', (cb) => this.server.enableLogging(cb));
|
|
this.events.setCommandHandler('logs:webserver:turnOff', (cb) => this.server.disableLogging(cb));
|
|
}
|
|
|
|
registerConsoleCommands() {
|
|
const self = this;
|
|
self.embark.registerConsoleCommand((cmd, _options) => {
|
|
return {
|
|
match: () => cmd === 'webserver start',
|
|
process: (cb) => self.events.request('start-webserver', cb)
|
|
};
|
|
});
|
|
|
|
self.embark.registerConsoleCommand((cmd, _options) => {
|
|
return {
|
|
match: () => cmd === 'webserver stop',
|
|
process: (cb) => self.events.request('stop-webserver', cb)
|
|
};
|
|
});
|
|
|
|
self.embark.registerConsoleCommand((cmd, _options) => {
|
|
return {
|
|
match: () => cmd === 'browser open',
|
|
process: (cb) => self.events.request('open-browser', cb)
|
|
};
|
|
});
|
|
|
|
self.embark.registerConsoleCommand((cmd, _options) => {
|
|
return {
|
|
match: () => cmd === 'log webserver on',
|
|
process: (cb) => self.events.request('logs:webserver:turnOn', cb)
|
|
};
|
|
});
|
|
|
|
self.embark.registerConsoleCommand((cmd, _options) => {
|
|
return {
|
|
match: () => cmd === 'log webserver off',
|
|
process: (cb) => self.events.request('logs:webserver:turnOff', cb)
|
|
};
|
|
});
|
|
}
|
|
|
|
buildPlaceholderPage(cb) {
|
|
let html = Templates.embark_building_placeholder({buildingMsg: __('Embark is building, please wait...')});
|
|
fs.mkdirpSync(this.buildDir); // create buildDir if it does not exist
|
|
fs.writeFile(utils.joinPath(this.buildDir, 'index.html'), html, cb);
|
|
}
|
|
|
|
openBrowser(cb) {
|
|
const _cb = () => { cb(); };
|
|
return opn(
|
|
`http://${canonicalHost(this.server.hostname)}:${this.server.port}`,
|
|
{wait: false}
|
|
).then(_cb, _cb); // fail silently, e.g. in a docker container
|
|
}
|
|
}
|
|
|
|
module.exports = WebServer;
|