Class ProtocolParser

src/notebooks/debugger/protocolParser.node.ts:34–132

 * @implements {IProtocolParser}
 */
export class ProtocolParser implements IProtocolParser {
    private rawData = Buffer.concat([]);
    private contentLength: number = -1;
    private disposed: boolean = false;
    private stream?: Readable;
    private events: EventEmitter;
    constructor() {
        this.events = new EventEmitter();
    }
    public dispose() {
        if (this.stream) {
            this.stream.removeListener('data', this.dataCallbackHandler);
            this.stream = undefined;
        }
    }
    public connect(stream: Readable) {
        this.stream = stream;
        stream.addListener('data', this.dataCallbackHandler);
    }
    public on(event: string | symbol, listener: Listener): this {
        this.events.on(event, listener);
        return this;
    }
    public once(event: string | symbol, listener: Listener): this {
        this.events.once(event, listener);
        return this;
    }
    private dataCallbackHandler = (data: string | Buffer) => {
        this.handleData(data as Buffer);
    };
    private dispatch(body: string): void {
        const message = JSON.parse(body) as DebugProtocol.ProtocolMessage;

        switch (message.type) {
            case 'event': {
                const event = message as DebugProtocol.Event;
                if (typeof event.event === 'string') {
                    this.events.emit(`${message.type}_${event.event}`, event);
                }
                break;
            }
            case 'request': {
                const request = message as DebugProtocol.Request;
                if (typeof request.command === 'string') {
                    this.events.emit(`${message.type}_${request.command}`, request);
                }
                break;
            }
            case 'response': {
                const reponse = message as DebugProtocol.Response;
                if (typeof reponse.command === 'string') {
                    this.events.emit(`${message.type}_${reponse.command}`, reponse);
                }
                break;
            }
            default: {
                this.events.emit(`${message.type}`, message);
            }