mirror of
https://github.com/verdaccio/verdaccio.git
synced 2024-12-16 21:56:25 -05:00
9242d498d7
* server now are executed in the jest setup phase * disable one snapshot
78 lines
2 KiB
JavaScript
78 lines
2 KiB
JavaScript
// @flow
|
|
import _ from 'lodash';
|
|
import rimRaf from 'rimraf';
|
|
import path from 'path';
|
|
import {fork} from 'child_process';
|
|
import type {IVerdaccioConfig, IServerBridge, IServerProcess} from '../types';
|
|
|
|
export default class VerdaccioProcess implements IServerProcess {
|
|
|
|
bridge: IServerBridge;
|
|
config: IVerdaccioConfig;
|
|
childFork: any;
|
|
isDebug: boolean;
|
|
silence: boolean;
|
|
|
|
constructor(config: IVerdaccioConfig, bridge: IServerBridge, silence: boolean = true, isDebug: boolean = false) {
|
|
this.config = config;
|
|
this.bridge = bridge;
|
|
this.silence = silence;
|
|
this.isDebug = isDebug;
|
|
}
|
|
|
|
init(): Promise<any> {
|
|
return new Promise((resolve, reject) => {
|
|
const verdaccioRegisterWrap: string = path.join(__dirname, '../../bin/verdaccio');
|
|
|
|
rimRaf(this.config.storagePath, (err) => {
|
|
if (_.isNil(err) === false) {
|
|
reject(err);
|
|
}
|
|
|
|
let childOptions = {
|
|
silent: this.silence
|
|
};
|
|
|
|
if (this.isDebug) {
|
|
childOptions = Object.assign({}, childOptions, {
|
|
execArgv: [`--inspect=${this.config.port + 5}`]
|
|
});
|
|
}
|
|
|
|
this.childFork = fork(verdaccioRegisterWrap, ['-c', this.config.configPath], childOptions);
|
|
|
|
this.childFork.on('message', (msg) => {
|
|
if ('verdaccio_started' in msg) {
|
|
this.bridge.debug().status(200).then((body) => {
|
|
this.bridge.auth('test', 'test')
|
|
.status(201)
|
|
.body_ok(/'test'/)
|
|
.then(() => {
|
|
resolve([this, body.pid]);
|
|
}, reject)
|
|
}, reject);
|
|
}
|
|
});
|
|
|
|
this.childFork.on('error', (err) => {
|
|
reject([err, this]);
|
|
});
|
|
|
|
this.childFork.on('disconnect', (err) => {
|
|
reject([err, this]);
|
|
});
|
|
|
|
this.childFork.on('exit', (err) => {
|
|
reject([err, this]);
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
}
|
|
|
|
stop(): void {
|
|
return this.childFork.kill('SIGINT');
|
|
}
|
|
|
|
}
|