import path from 'path'; import { spawn, execSync } from 'child_process'; import { Lbry } from 'lbry-redux'; export default class Daemon { static path = process.env.LBRY_DAEMON || (process.env.NODE_ENV === 'production' ? path.join(process.resourcesPath, 'static/daemon', 'lbrynet') : path.join(__static, 'daemon/lbrynet')); subprocess; handlers; constructor() { this.handlers = []; } launch() { this.subprocess = spawn(Daemon.path, ['start']); this.subprocess.stdout.on('data', data => console.log(`Daemon: ${data}`)); this.subprocess.stderr.on('data', data => console.error(`Daemon: ${data}`)); this.subprocess.on('exit', () => this.fire('exit')); this.subprocess.on('error', error => console.error(`Daemon error: ${error}`)); } quit() { Lbry.stop() .then() .catch(() => { if (process.platform === 'win32') { try { execSync(`taskkill /pid ${this.subprocess.pid} /t /f`); } catch (error) { console.error(error.message); } } else { this.subprocess.kill(); } }); } // Follows the publish/subscribe pattern // Subscribe method on(event, handler, context = handler) { this.handlers.push({ event, handler: handler.bind(context) }); } // Publish method fire(event, args) { this.handlers.forEach(topic => { if (topic.event === event) topic.handler(args); }); } }