Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

vscode-jsonrpc

Package Overview
Dependencies
Maintainers
7
Versions
130
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

vscode-jsonrpc - npm Package Compare versions

Comparing version 9.0.0-next.4 to 9.0.0-next.5

tsconfig.tsbuildinfo

9

lib/browser/main.js

@@ -20,5 +20,8 @@ "use strict";

};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.createMessageConnection = exports.BrowserMessageWriter = exports.BrowserMessageReader = void 0;
const ril_1 = require("./ril");
const ril_1 = __importDefault(require("./ril"));
// Install the browser runtime abstract.

@@ -29,2 +32,4 @@ ril_1.default.install();

class BrowserMessageReader extends api_1.AbstractMessageReader {
_onData;
_messageListener;
constructor(port) {

@@ -45,2 +50,4 @@ super();

class BrowserMessageWriter extends api_1.AbstractMessageWriter {
port;
errorCount;
constructor(port) {

@@ -47,0 +54,0 @@ super();

@@ -9,2 +9,4 @@ "use strict";

class MessageBuffer extends api_1.AbstractMessageBuffer {
static emptyBuffer = new Uint8Array(0);
asciiDecoder;
constructor(encoding = 'utf-8') {

@@ -40,4 +42,6 @@ super(encoding);

}
MessageBuffer.emptyBuffer = new Uint8Array(0);
class ReadableStreamWrapper {
socket;
_onData;
_messageListener;
constructor(socket) {

@@ -73,2 +77,3 @@ this.socket = socket;

class WritableStreamWrapper {
socket;
constructor(socket) {

@@ -75,0 +80,0 @@ this.socket = socket;

5

lib/common/api.js

@@ -7,2 +7,5 @@ "use strict";

/// <reference path="../../typings/thenable.d.ts" />
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });

@@ -82,3 +85,3 @@ exports.ProgressType = exports.ProgressToken = exports.createMessageConnection = exports.NullLogger = exports.ConnectionOptions = exports.ConnectionStrategy = exports.AbstractMessageBuffer = exports.WriteableStreamMessageWriter = exports.AbstractMessageWriter = exports.MessageWriter = exports.ReadableStreamMessageReader = exports.AbstractMessageReader = exports.MessageReader = exports.SharedArrayReceiverStrategy = exports.SharedArraySenderStrategy = exports.CancellationToken = exports.CancellationTokenSource = exports.Emitter = exports.Event = exports.Disposable = exports.LRUCache = exports.Touch = exports.LinkedMap = exports.ParameterStructures = exports.NotificationType9 = exports.NotificationType8 = exports.NotificationType7 = exports.NotificationType6 = exports.NotificationType5 = exports.NotificationType4 = exports.NotificationType3 = exports.NotificationType2 = exports.NotificationType1 = exports.NotificationType0 = exports.NotificationType = exports.ErrorCodes = exports.ResponseError = exports.RequestType9 = exports.RequestType8 = exports.RequestType7 = exports.RequestType6 = exports.RequestType5 = exports.RequestType4 = exports.RequestType3 = exports.RequestType2 = exports.RequestType1 = exports.RequestType0 = exports.RequestType = exports.Message = exports.RAL = void 0;

Object.defineProperty(exports, "TraceValues", { enumerable: true, get: function () { return connection_1.TraceValues; } });
const ral_1 = require("./ral");
const ral_1 = __importDefault(require("./ral"));
exports.RAL = ral_1.default;

@@ -6,6 +6,32 @@ "use strict";

*--------------------------------------------------------------------------------------------*/
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.CancellationTokenSource = exports.CancellationToken = void 0;
const ral_1 = require("./ral");
const Is = require("./is");
const ral_1 = __importDefault(require("./ral"));
const Is = __importStar(require("./is"));
const events_1 = require("./events");

@@ -35,5 +61,4 @@ var CancellationToken;

class MutableToken {
constructor() {
this._isCancelled = false;
}
_isCancelled = false;
_emitter;
cancel() {

@@ -68,2 +93,3 @@ if (!this._isCancelled) {

class CancellationTokenSource {
_token;
get token() {

@@ -70,0 +96,0 @@ if (!this._token) {

@@ -0,1 +1,2 @@

/// <reference path="../../typings/thenable.d.ts" />
import { Message, RequestMessage, RequestType, RequestType0, RequestType1, RequestType2, RequestType3, RequestType4, RequestType5, RequestType6, RequestType7, RequestType8, RequestType9, ResponseMessage, ResponseError, NotificationMessage, NotificationType, NotificationType0, NotificationType1, NotificationType2, NotificationType3, NotificationType4, NotificationType5, NotificationType6, NotificationType7, NotificationType8, NotificationType9, _EM, ParameterStructures } from './messages';

@@ -2,0 +3,0 @@ import type { Disposable } from './disposable';

@@ -6,6 +6,33 @@ "use strict";

* ------------------------------------------------------------------------------------------ */
/// <reference path="../../typings/thenable.d.ts" />
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.createMessageConnection = exports.ConnectionOptions = exports.MessageStrategy = exports.CancellationStrategy = exports.CancellationSenderStrategy = exports.CancellationReceiverStrategy = exports.RequestCancellationReceiverStrategy = exports.IdCancellationReceiverStrategy = exports.ConnectionStrategy = exports.ConnectionError = exports.ConnectionErrors = exports.LogTraceNotification = exports.SetTraceNotification = exports.TraceFormat = exports.TraceValues = exports.TraceValue = exports.Trace = exports.NullLogger = exports.ProgressType = exports.ProgressToken = void 0;
const ral_1 = require("./ral");
const Is = require("./is");
const ral_1 = __importDefault(require("./ral"));
const Is = __importStar(require("./is"));
const messages_1 = require("./messages");

@@ -31,2 +58,8 @@ const linkedMap_1 = require("./linkedMap");

class ProgressType {
/**
* Clients must not use these properties. They are here to ensure correct typing.
* in TypeScript
*/
__;
_pr;
constructor() {

@@ -159,2 +192,3 @@ }

class ConnectionError extends Error {
code;
constructor(code, message) {

@@ -161,0 +195,0 @@ super(message);

@@ -6,5 +6,8 @@ "use strict";

* ------------------------------------------------------------------------------------------ */
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.Emitter = exports.Event = void 0;
const ral_1 = require("./ral");
const ral_1 = __importDefault(require("./ral"));
var Event;

@@ -16,2 +19,4 @@ (function (Event) {

class CallbackList {
_callbacks;
_contexts;
add(callback, context = null, bucket) {

@@ -75,2 +80,6 @@ if (!this._callbacks) {

class Emitter {
_options;
static _noop = function () { };
_event;
_callbacks;
constructor(_options) {

@@ -131,2 +140,1 @@ this._options = _options;

exports.Emitter = Emitter;
Emitter._noop = function () { };

@@ -6,3 +6,2 @@ "use strict";

*--------------------------------------------------------------------------------------------*/
var _a;
Object.defineProperty(exports, "__esModule", { value: true });

@@ -19,4 +18,9 @@ exports.LRUCache = exports.LinkedMap = exports.Touch = void 0;

class LinkedMap {
[Symbol.toStringTag] = 'LinkedMap';
_map;
_head;
_tail;
_size;
_state;
constructor() {
this[_a] = 'LinkedMap';
this._map = new Map();

@@ -208,3 +212,3 @@ this._head = undefined;

}
[(_a = Symbol.toStringTag, Symbol.iterator)]() {
[Symbol.iterator]() {
return this.entries();

@@ -373,2 +377,4 @@ }

class LRUCache extends LinkedMap {
_limit;
_ratio;
constructor(limit, ratio = 1) {

@@ -375,0 +381,0 @@ super();

@@ -12,2 +12,5 @@ "use strict";

class AbstractMessageBuffer {
_encoding;
_chunks;
_totalLength;
constructor(encoding = 'utf-8') {

@@ -14,0 +17,0 @@ this._encoding = encoding;

@@ -6,6 +6,32 @@ "use strict";

* ------------------------------------------------------------------------------------------ */
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.ReadableStreamMessageReader = exports.AbstractMessageReader = exports.MessageReader = void 0;
const ral_1 = require("./ral");
const Is = require("./is");
const ral_1 = __importDefault(require("./ral"));
const Is = __importStar(require("./is"));
const events_1 = require("./events");

@@ -23,2 +49,5 @@ const semaphore_1 = require("./semaphore");

class AbstractMessageReader {
errorEmitter;
closeEmitter;
partialMessageEmitter;
constructor() {

@@ -103,2 +132,11 @@ this.errorEmitter = new events_1.Emitter();

class ReadableStreamMessageReader extends AbstractMessageReader {
readable;
options;
callback;
nextMessageLength;
messageToken;
buffer;
partialMessageTimer;
_partialMessageTimeout;
readSemaphore;
constructor(readable, options) {

@@ -105,0 +143,0 @@ super();

@@ -6,5 +6,28 @@ "use strict";

* ------------------------------------------------------------------------------------------ */
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.Message = exports.NotificationType9 = exports.NotificationType8 = exports.NotificationType7 = exports.NotificationType6 = exports.NotificationType5 = exports.NotificationType4 = exports.NotificationType3 = exports.NotificationType2 = exports.NotificationType1 = exports.NotificationType0 = exports.NotificationType = exports.RequestType9 = exports.RequestType8 = exports.RequestType7 = exports.RequestType6 = exports.RequestType5 = exports.RequestType4 = exports.RequestType3 = exports.RequestType2 = exports.RequestType1 = exports.RequestType = exports.RequestType0 = exports.AbstractMessageSignature = exports.ParameterStructures = exports.ResponseError = exports.ErrorCodes = void 0;
const is = require("./is");
const is = __importStar(require("./is"));
/**

@@ -71,2 +94,4 @@ * Predefined error codes.

class ResponseError extends Error {
code;
data;
constructor(code, message, data) {

@@ -91,2 +116,19 @@ super(message);

class ParameterStructures {
kind;
/**
* The parameter structure is automatically inferred on the number of parameters
* and the parameter type in case of a single param.
*/
static auto = new ParameterStructures('auto');
/**
* Forces `byPosition` parameter structure. This is useful if you have a single
* parameter which has a literal type.
*/
static byPosition = new ParameterStructures('byPosition');
/**
* Forces `byName` parameter structure. This is only useful when having a single
* parameter. The library will report errors if used with a different number of
* parameters.
*/
static byName = new ParameterStructures('byName');
constructor(kind) {

@@ -104,21 +146,7 @@ this.kind = kind;

/**
* The parameter structure is automatically inferred on the number of parameters
* and the parameter type in case of a single param.
*/
ParameterStructures.auto = new ParameterStructures('auto');
/**
* Forces `byPosition` parameter structure. This is useful if you have a single
* parameter which has a literal type.
*/
ParameterStructures.byPosition = new ParameterStructures('byPosition');
/**
* Forces `byName` parameter structure. This is only useful when having a single
* parameter. The library will report errors if used with a different number of
* parameters.
*/
ParameterStructures.byName = new ParameterStructures('byName');
/**
* An abstract implementation of a MessageType.
*/
class AbstractMessageSignature {
method;
numberOfParams;
constructor(method, numberOfParams) {

@@ -137,2 +165,6 @@ this.method = method;

class RequestType0 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -144,2 +176,7 @@ super(method, 0);

class RequestType extends AbstractMessageSignature {
_parameterStructures;
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method, _parameterStructures = ParameterStructures.auto) {

@@ -155,2 +192,7 @@ super(method, 1);

class RequestType1 extends AbstractMessageSignature {
_parameterStructures;
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method, _parameterStructures = ParameterStructures.auto) {

@@ -166,2 +208,6 @@ super(method, 1);

class RequestType2 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -173,2 +219,6 @@ super(method, 2);

class RequestType3 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -180,2 +230,6 @@ super(method, 3);

class RequestType4 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -187,2 +241,6 @@ super(method, 4);

class RequestType5 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -194,2 +252,6 @@ super(method, 5);

class RequestType6 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -201,2 +263,6 @@ super(method, 6);

class RequestType7 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -208,2 +274,6 @@ super(method, 7);

class RequestType8 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -215,2 +285,6 @@ super(method, 8);

class RequestType9 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -222,2 +296,7 @@ super(method, 9);

class NotificationType extends AbstractMessageSignature {
_parameterStructures;
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method, _parameterStructures = ParameterStructures.auto) {

@@ -233,2 +312,6 @@ super(method, 1);

class NotificationType0 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -240,2 +323,7 @@ super(method, 0);

class NotificationType1 extends AbstractMessageSignature {
_parameterStructures;
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method, _parameterStructures = ParameterStructures.auto) {

@@ -251,2 +339,6 @@ super(method, 1);

class NotificationType2 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -258,2 +350,6 @@ super(method, 2);

class NotificationType3 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -265,2 +361,6 @@ super(method, 3);

class NotificationType4 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -272,2 +372,6 @@ super(method, 4);

class NotificationType5 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -279,2 +383,6 @@ super(method, 5);

class NotificationType6 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -286,2 +394,6 @@ super(method, 6);

class NotificationType7 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -293,2 +405,6 @@ super(method, 7);

class NotificationType8 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -300,2 +416,6 @@ super(method, 8);

class NotificationType9 extends AbstractMessageSignature {
/**
* Clients must not use this property. It is here to ensure correct typing.
*/
_;
constructor(method) {

@@ -302,0 +422,0 @@ super(method, 9);

@@ -6,6 +6,32 @@ "use strict";

* ------------------------------------------------------------------------------------------ */
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.WriteableStreamMessageWriter = exports.AbstractMessageWriter = exports.MessageWriter = void 0;
const ral_1 = require("./ral");
const Is = require("./is");
const ral_1 = __importDefault(require("./ral"));
const Is = __importStar(require("./is"));
const semaphore_1 = require("./semaphore");

@@ -25,2 +51,4 @@ const events_1 = require("./events");

class AbstractMessageWriter {
errorEmitter;
closeEmitter;
constructor() {

@@ -69,2 +97,6 @@ this.errorEmitter = new events_1.Emitter();

class WriteableStreamMessageWriter extends AbstractMessageWriter {
writable;
options;
errorCount;
writeSemaphore;
constructor(writable, options) {

@@ -71,0 +103,0 @@ super();

@@ -6,6 +6,12 @@ "use strict";

* ------------------------------------------------------------------------------------------ */
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.Semaphore = void 0;
const ral_1 = require("./ral");
const ral_1 = __importDefault(require("./ral"));
class Semaphore {
_capacity;
_active;
_waiting;
constructor(capacity = 1) {

@@ -12,0 +18,0 @@ if (capacity <= 0) {

@@ -15,2 +15,3 @@ "use strict";

class SharedArraySenderStrategy {
buffers;
constructor() {

@@ -46,2 +47,3 @@ this.buffers = new Map();

class SharedArrayBufferCancellationToken {
data;
constructor(buffer) {

@@ -58,2 +60,3 @@ this.data = new Int32Array(buffer, 0, 1);

class SharedArrayBufferCancellationTokenSource {
token;
constructor(buffer) {

@@ -68,5 +71,3 @@ this.token = new SharedArrayBufferCancellationToken(buffer);

class SharedArrayReceiverStrategy {
constructor() {
this.kind = 'request';
}
kind = 'request';
createCancellationTokenSource(request) {

@@ -73,0 +74,0 @@ const buffer = request.$cancellationData;

@@ -13,5 +13,20 @@ "use strict";

}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
var __exportStar = (this && this.__exportStar) || function(m, exports) {
for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });

@@ -23,8 +38,8 @@ exports.createMessageConnection = exports.createServerSocketTransport = exports.createClientSocketTransport = exports.createServerPipeTransport = exports.createClientPipeTransport = exports.generateRandomPipeName = exports.StreamMessageWriter = exports.StreamMessageReader = exports.SocketMessageWriter = exports.SocketMessageReader = exports.PortMessageWriter = exports.PortMessageReader = exports.IPCMessageWriter = exports.IPCMessageReader = void 0;

* ----------------------------------------------------------------------------------------- */
const ril_1 = require("./ril");
const ril_1 = __importDefault(require("./ril"));
// Install the node runtime abstract.
ril_1.default.install();
const path = require("path");
const os = require("os");
const fs = require("fs");
const path = __importStar(require("path"));
const os = __importStar(require("os"));
const fs = __importStar(require("fs"));
const crypto_1 = require("crypto");

@@ -35,2 +50,3 @@ const net_1 = require("net");

class IPCMessageReader extends api_1.AbstractMessageReader {
process;
constructor(process) {

@@ -50,2 +66,4 @@ super();

class IPCMessageWriter extends api_1.AbstractMessageWriter {
process;
errorCount;
constructor(process) {

@@ -88,2 +106,3 @@ super();

class PortMessageReader extends api_1.AbstractMessageReader {
onData;
constructor(port) {

@@ -104,2 +123,4 @@ super();

class PortMessageWriter extends api_1.AbstractMessageWriter {
port;
errorCount;
constructor(port) {

@@ -137,2 +158,3 @@ super();

class SocketMessageWriter extends api_1.WriteableStreamMessageWriter {
socket;
constructor(socket, options) {

@@ -139,0 +161,0 @@ super((0, ril_1.default)().stream.asWritableStream(socket), options);

@@ -10,2 +10,3 @@ "use strict";

class MessageBuffer extends api_1.AbstractMessageBuffer {
static emptyBuffer = Buffer.allocUnsafe(0);
constructor(encoding = 'utf-8') {

@@ -40,4 +41,4 @@ super(encoding);

}
MessageBuffer.emptyBuffer = Buffer.allocUnsafe(0);
class ReadableStreamWrapper {
stream;
constructor(stream) {

@@ -64,2 +65,3 @@ this.stream = stream;

class WritableStreamWrapper {
stream;
constructor(stream) {

@@ -66,0 +68,0 @@ this.stream = stream;

{
"name": "vscode-jsonrpc",
"description": "A json rpc implementation over streams",
"version": "9.0.0-next.4",
"version": "9.0.0-next.5",
"author": "Microsoft Corporation",

@@ -18,7 +18,16 @@ "license": "MIT",

},
"main": "./lib/node/main.js",
"browser": {
"./lib/node/main.js": "./lib/browser/main.js"
"exports": {
".": {
"types": "./lib/common/api.d.ts",
"default": "./lib/common/api.js"
},
"./node": {
"types": "./lib/node/main.d.ts",
"node": "./lib/node/main.js"
},
"./browser": {
"types": "./lib/browser/main.d.ts",
"browser": "./lib/browser/main.js"
}
},
"typings": "./lib/common/api.d.ts",
"devDependencies": {

@@ -32,6 +41,6 @@ "@types/msgpack-lite": "^0.1.10",

"preversion": "npm test",
"compile": "node ../build/bin/tsc -b ./tsconfig.json",
"watch": "node ../build/bin/tsc -b ./tsconfig.watch.json -w",
"clean": "node ../node_modules/rimraf/dist/esm/bin.mjs lib && node ../node_modules/rimraf/dist/esm/bin.mjs dist",
"lint": "node ../node_modules/eslint/bin/eslint.js --ext ts src",
"compile": "tsc -b ./tsconfig.json",
"watch": "tsc -b ./tsconfig.watch.json -w",
"clean": "rimraf lib && rimraf dist",
"lint": "eslint --ext ts src",
"test": "npm run test:node && npm run test:browser",

@@ -44,5 +53,5 @@ "test:node": "node ../node_modules/mocha/bin/_mocha",

"all": "npm run clean && npm run compile && npm run lint && npm run test",
"compile:publish": "node ../build/bin/tsc -b ./tsconfig.publish.json",
"compile:publish": "tsc -b ./tsconfig.publish.json",
"all:publish": "git clean -xfd . && npm install && npm run compile:publish && npm run lint && npm run test"
}
}
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc