70 lines
1.8 KiB
JavaScript
70 lines
1.8 KiB
JavaScript
|
import path from 'path';
|
||
|
|
import fs from 'fs';
|
||
|
|
import { spawn, execSync } from 'child_process';
|
||
|
|
import { Lbry } from 'lbry-redux';
|
||
|
|
|
||
|
|
export default class Daemon {
|
||
|
|
static lbrynetPath =
|
||
|
|
process.env.LBRY_DAEMON ||
|
||
|
|
(process.env.NODE_ENV === 'production'
|
||
|
|
? path.join(process.resourcesPath, 'static/daemon', 'lbrynet')
|
||
|
|
: path.join(__static, 'daemon/lbrynet'));
|
||
|
|
|
||
|
|
static headersPath =
|
||
|
|
process.env.LBRY_DAEMON ||
|
||
|
|
(process.env.NODE_ENV === 'production'
|
||
|
|
? path.join(process.resourcesPath, 'static/daemon', 'headers')
|
||
|
|
: path.join(__static, 'daemon/headers'));
|
||
|
|
|
||
|
|
subprocess;
|
||
|
|
handlers;
|
||
|
|
|
||
|
|
constructor() {
|
||
|
|
this.handlers = [];
|
||
|
|
}
|
||
|
|
|
||
|
|
launch() {
|
||
|
|
let flags = ['start'];
|
||
|
|
|
||
|
|
if (fs.existsSync(Daemon.headersPath)) {
|
||
|
|
flags.push(`--initial-headers=${Daemon.headersPath}`);
|
||
|
|
}
|
||
|
|
|
||
|
|
this.subprocess = spawn(Daemon.lbrynetPath, flags);
|
||
|
|
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);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
}
|