electron.js refactoring

electron/js/server.js

@@ -0,0 +1,135 @@
+'use strict';
+const path = require('path');
+const childProcess = require('child_process');
+const electron = require('electron');
+const fs = require('fs');
+const stdoutWebProxyPrefix = 'gRPC Web proxy started at: ';
+const Util = require('./util.js');
+
+function dateForFile() {
+	return new Date().toISOString().replace(/:/g, '_').replace(/\..+/, '');
+};
+
+let maxStdErrChunksBuffer = 10;
+
+class Server {
+
+	start (binPath, workingDir) {
+		return new Promise((resolve, reject) => {
+
+			// stop will resolve immediately in case child process is not running
+			this.stop().then(() => {
+				
+				this.isRunning = false;
+				let logsDir = path.join(workingDir, 'logs');
+
+				try { fs.mkdirSync(logsDir); } catch (e) {};
+
+				try {
+					let env = process.env;
+					
+					if (!process.stdout.isTTY) {
+						env['GOLOG_FILE'] = path.join(logsDir, 'anytype_' + dateForFile() + '.log');
+					};
+					
+					let args = [ '127.0.0.1:0', '127.0.0.1:0' ];
+					this.cp = childProcess.spawn(binPath, args, { env: env });
+				} catch (err) {
+					console.error('[Server] Process start error: ', err.toString());
+					reject(err);
+				};
+				
+				this.cp.on('error', err => {
+					this.isRunning = false;
+					console.error('[Server] Failed to start server: ', err.toString());
+					reject(err);
+				});
+				
+				this.cp.stdout.on('data', data => {
+					let str = data.toString();
+
+					if (!this.isRunning && str && (str.indexOf(stdoutWebProxyPrefix) >= 0)) {
+						var regex = new RegExp(stdoutWebProxyPrefix + '([^\n^\s]+)');
+						this.address = 'http://' + regex.exec(str)[1];
+						this.isRunning = true;
+						resolve(true);
+					};
+
+					console.log(str);
+				});
+
+				this.cp.stderr.on('data', data => {
+					let chunk = data.toString();
+					
+					// max chunk size is 8192 bytes
+					// https://github.com/nodejs/node/issues/12921
+					// https://nodejs.org/api/buffer.html#buffer_class_property_buffer_poolsize
+					
+					if (chunk.length > 8000) {
+						// in case we've got a crash lets change the max buffer to collect the whole stack trace
+						maxStdErrChunksBuffer = 1024; // 1024x8192 = 8 Mb max
+					};
+					
+					if (!this.lastErrors) {
+						this.lastErrors = [];
+					} else if (this.lastErrors.length >= maxStdErrChunksBuffer) {
+						this.lastErrors.shift();
+					};
+					
+					this.lastErrors.push(chunk);
+					Util.log('warn', chunk);
+				});
+				
+				this.cp.on('exit', () => {
+					if (this.stopTriggered) {
+						return;
+					};
+					
+					this.isRunning = false;
+					
+					let crashReport = path.join(logsDir, 'crash_' + dateForFile() + '.log');
+					try {
+						fs.writeFileSync(crashReport, this.lastErrors.join('\n'), 'utf-8');
+					} catch(e) {
+						console.log('failed to save a file');
+					};
+					
+					electron.dialog.showErrorBox('Anytype helper crashed', 'You will be redirected to the crash log file. You can send it to Anytype developers: dev@anytype.io');
+					electron.shell.showItemInFolder(crashReport);
+					
+					electron.app.relaunch();
+					electron.app.exit(0);
+				});
+			});
+		});
+	};
+	
+	stop () {
+		return new Promise((resolve, reject) => {
+			if (this.cp && this.isRunning) {
+				this.cp.on('exit', () => {
+					resolve(true);
+
+					this.isRunning = false;
+					this.cp = null;
+				});
+				
+				this.stopTriggered = true;
+				this.cp.kill('SIGTERM');
+			} else {
+				resolve();
+			};
+		});
+	};
+	
+	getAddress () {
+		return this.address;
+	};
+	
+	setAddress (address) {
+		this.address = address;
+	};
+	
+};
+
+module.exports = new Server();