Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
}).catch((err) => {
mainStory.error('scanner', err.message, {attach: err});
httpEventEmitter.emit(scanError, {error: err, ok: false});
});
.on('data', (line) => mainStory.info(line))
.on('end', () => { if (!program.server) process.exit(); });
_write(chunk: string, enc: string, next: Function) {
const str = chunk.toString();
if (str && str.length) {
mainStory.info('http', str.replace('\n', ''));
}
next();
}
}
httpServer.on('listening', () => {
mainStory.info('http', `Listening on port ${chalk.cyan.bold(port)}`);
});
httpServer.listen(port);
log: (data) => {
mainStory.info('webpack', data);
}
});
mainStory.trace('scanner', 'Added a new track', {attach: file.props});
}).catch(err => {
mainStory.warn('scanner', err.message);
mainStory.trace('scanner', 'Library scan encountered an error', {attach: err});
});
}
return Promise.resolve();
case 'unlink':
return File.findOne({path: filePath}).then((file) => {
if (!file) {
return Promise.resolve();
}
return file.remove();
});
case 'mkdir':
mainStory.info('scanner', 'Scanning new dir ' + filePath);
case 'rmdir':
return Promise.resolve();
}
}
const operationMapperFactory = module.exports.operationMapperFactory = (models, mediastic) => {
async endAdminParty () {
const node = await this.getNode();
mainStory.info('configure', 'Ending admin party...');
const url = `http://${
this.opts.couchHost
}:${this.opts.couchPort}/_node/${
node
}/_config/admins/${this.opts.adminUsername}`;
mainStory.info('configure', 'PUT ' + url);
const res: any = await fetch(url, {
method: 'PUT',
body: `"${this.opts.adminPassword}"`
}).then((res) => res.json());
mainStory.info('configure', 'CouchDB responded with', {attach: res});
}
getNode (): Promise {
mediastic.use((metadata, next) => {
mainStory.trace('scanner', 'Working on '+ metadata.path);
try {
next();
} catch (err) {
mainStory.error('scanner', 'Uncaught exception', {attach: err});
}
});
httpServer.on('error', () => {
mainStory.warn('http', `Port ${String(port)} busy`);
port += 1;
if (port >= initialPort + 20) {
mainStory.error('http', 'Cannot open port (tried 20 times)');
return;
}
httpServer.listen(port);
});
httpServer.on('listening', () => {
}).catch((err) => {
res.send({ok: false, error: 'An error has occured while creating a report'});
mainStory.error('analytics', 'An error occured', {attach: err});
});
});