mirror of https://github.com/lukechilds/node.git
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
98 lines
2.8 KiB
98 lines
2.8 KiB
'use strict';
|
|
|
|
const EventEmitter = require('events');
|
|
const errors = require('internal/errors');
|
|
const util = require('util');
|
|
const { Connection, open, url } = process.binding('inspector');
|
|
|
|
if (!Connection)
|
|
throw new errors.Error('ERR_INSPECTOR_NOT_AVAILABLE');
|
|
|
|
const connectionSymbol = Symbol('connectionProperty');
|
|
const messageCallbacksSymbol = Symbol('messageCallbacks');
|
|
const nextIdSymbol = Symbol('nextId');
|
|
const onMessageSymbol = Symbol('onMessage');
|
|
|
|
class Session extends EventEmitter {
|
|
constructor() {
|
|
super();
|
|
this[connectionSymbol] = null;
|
|
this[nextIdSymbol] = 1;
|
|
this[messageCallbacksSymbol] = new Map();
|
|
}
|
|
|
|
connect() {
|
|
if (this[connectionSymbol])
|
|
throw new errors.Error('ERR_INSPECTOR_ALREADY_CONNECTED');
|
|
this[connectionSymbol] =
|
|
new Connection((message) => this[onMessageSymbol](message));
|
|
}
|
|
|
|
[onMessageSymbol](message) {
|
|
const parsed = JSON.parse(message);
|
|
try {
|
|
if (parsed.id) {
|
|
const callback = this[messageCallbacksSymbol].get(parsed.id);
|
|
this[messageCallbacksSymbol].delete(parsed.id);
|
|
if (callback)
|
|
callback(parsed.error || null, parsed.result || null);
|
|
} else {
|
|
this.emit(parsed.method, parsed);
|
|
this.emit('inspectorNotification', parsed);
|
|
}
|
|
} catch (error) {
|
|
process.emitWarning(error);
|
|
}
|
|
}
|
|
|
|
post(method, params, callback) {
|
|
if (typeof method !== 'string') {
|
|
throw new errors.TypeError('ERR_INVALID_ARG_TYPE',
|
|
'method', 'string', method);
|
|
}
|
|
if (!callback && util.isFunction(params)) {
|
|
callback = params;
|
|
params = null;
|
|
}
|
|
if (params && typeof params !== 'object') {
|
|
throw new errors.TypeError('ERR_INVALID_ARG_TYPE',
|
|
'params', 'object', params);
|
|
}
|
|
if (callback && typeof callback !== 'function') {
|
|
throw new errors.TypeError('ERR_INVALID_CALLBACK');
|
|
}
|
|
|
|
if (!this[connectionSymbol]) {
|
|
throw new errors.Error('ERR_INSPECTOR_NOT_CONNECTED');
|
|
}
|
|
const id = this[nextIdSymbol]++;
|
|
const message = { id, method };
|
|
if (params) {
|
|
message['params'] = params;
|
|
}
|
|
if (callback) {
|
|
this[messageCallbacksSymbol].set(id, callback);
|
|
}
|
|
this[connectionSymbol].dispatch(JSON.stringify(message));
|
|
}
|
|
|
|
disconnect() {
|
|
if (!this[connectionSymbol])
|
|
return;
|
|
this[connectionSymbol].disconnect();
|
|
this[connectionSymbol] = null;
|
|
const remainingCallbacks = this[messageCallbacksSymbol].values();
|
|
for (const callback of remainingCallbacks) {
|
|
process.nextTick(callback, new errors.Error('ERR_INSPECTOR_CLOSED'));
|
|
}
|
|
this[messageCallbacksSymbol].clear();
|
|
this[nextIdSymbol] = 1;
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
open: (port, host, wait) => open(port, host, !!wait),
|
|
close: process._debugEnd,
|
|
url: url,
|
|
Session
|
|
};
|
|
|