58 lines
1.9 KiB
JavaScript
58 lines
1.9 KiB
JavaScript
const child_process = require('child_process');
|
|
const ProcessWrapper = require('../../process/processWrapper');
|
|
const constants = require('../../constants');
|
|
|
|
let swarmProcess;
|
|
|
|
class SwarmProcess extends ProcessWrapper {
|
|
constructor(options) {
|
|
super();
|
|
this.storageConfig = options.storageConfig;
|
|
this.webServerConfig = options.webServerConfig;
|
|
}
|
|
|
|
startSwarmDaemon() {
|
|
const self = this;
|
|
if (!this.storageConfig.account || !this.storageConfig.account.address || !this.storageConfig.account.password) {
|
|
return 'Account address and password are needed in the storage config to start the Swarm process';
|
|
}
|
|
let corsDomain = 'http://localhost:8000';
|
|
if (self.webServerConfig && self.webServerConfig && self.webServerConfig.host && self.webServerConfig.port) {
|
|
corsDomain = `http://${self.webServerConfig.host}:${self.webServerConfig.port}`;
|
|
}
|
|
const child = child_process.spawn(this.storageConfig.swarmPath || 'swarm',
|
|
[
|
|
`--bzzaccount ${this.storageConfig.account.address}`,
|
|
`--password ${this.storageConfig.account.password}`,
|
|
`--corsdomain ${corsDomain}`,
|
|
"--ens-api ''"
|
|
]);
|
|
let lastMessage;
|
|
child.stderr.on('data', (data) => {
|
|
if (!self.readyCalled && data.indexOf('Swarm http proxy started') > -1) {
|
|
self.readyCalled = true;
|
|
self.send({result: constants.storage.initiated});
|
|
}
|
|
lastMessage = data;
|
|
console.log('Swarm: ' + data);
|
|
});
|
|
child.on('exit', (code) => {
|
|
if (code) {
|
|
console.error('Swarm exited with error code ' + code);
|
|
console.error(lastMessage);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
|
|
process.on('message', (msg) => {
|
|
if (msg.action === constants.storage.init) {
|
|
swarmProcess = new SwarmProcess(msg.options);
|
|
const error = swarmProcess.startSwarmDaemon();
|
|
|
|
if (error) {
|
|
swarmProcess.send({result: constants.storage.initiated, error});
|
|
}
|
|
}
|
|
});
|