botframework-streaming - npm Package Compare versions

Comparing version 4.12.0-dev-20201110-dec6519b1afc to 4.12.0-dev-20201112.60e5e9fc1086

lib/assemblers/index.js

@@ -9,7 +9,14 @@ "use strict";
  */
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./payloadAssembler"));
+__exportStar(require("./payloadAssembler"), exports);
 //# sourceMappingURL=index.js.map

lib/assemblers/payloadAssembler.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PayloadAssembler = void 0;
 /**
@@ -13,0 +15,0 @@ * @module botframework-streaming

lib/contentStream.d.ts

@@ -26,7 +26,7 @@ /**
      */
-    readonly contentType: string;
+    get contentType(): string;
     /**
      * Gets the length of this [ContentStream](xref:botframework-streaming.ContentStream).
      */
-    readonly length: number;
+    get length(): number;
     /**
@@ -33,0 +33,0 @@ * Gets the data contained within this [ContentStream](xref:botframework-streaming.ContentStream).

lib/contentStream.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.ContentStream = void 0;
 /**
@@ -13,0 +15,0 @@ * A stream of fixed or infinite length containing content to be decoded.

lib/disassemblers/cancelDisassembler.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.CancelDisassembler = void 0;
 /**
@@ -4,0 +5,0 @@ * Streaming cancel disassembler.

lib/disassemblers/httpContentStreamDisassembler.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.HttpContentStreamDisassembler = void 0;
 const payloadTypes_1 = require("../payloads/payloadTypes");
@@ -13,0 +15,0 @@ const payloadDisassembler_1 = require("./payloadDisassembler");

lib/disassemblers/index.js

@@ -9,11 +9,18 @@ "use strict";
  */
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./cancelDisassembler"));
-__export(require("./httpContentStreamDisassembler"));
-__export(require("./payloadDisassembler"));
-__export(require("./requestDisassembler"));
-__export(require("./responseDisassembler"));
+__exportStar(require("./cancelDisassembler"), exports);
+__exportStar(require("./httpContentStreamDisassembler"), exports);
+__exportStar(require("./payloadDisassembler"), exports);
+__exportStar(require("./requestDisassembler"), exports);
+__exportStar(require("./responseDisassembler"), exports);
 //# sourceMappingURL=index.js.map

lib/disassemblers/payloadDisassembler.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PayloadDisassembler = void 0;
 const subscribableStream_1 = require("../subscribableStream");
@@ -13,0 +15,0 @@ /**

lib/disassemblers/requestDisassembler.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.RequestDisassembler = void 0;
 /**
@@ -13,0 +15,0 @@ * @module botframework-streaming

lib/disassemblers/responseDisassembler.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.ResponseDisassembler = void 0;
 /**
@@ -13,0 +15,0 @@ * @module botframework-streaming

lib/httpContentStream.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.HttpContent = exports.HttpContentStream = void 0;
 const protocol_base_1 = require("./utilities/protocol-base");
@@ -4,0 +5,0 @@ /**

lib/index.js

@@ -10,23 +10,24 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.WebSocketServer = exports.WebSocketClient = exports.NodeWebSocketFactoryBase = exports.NodeWebSocketFactory = exports.NodeWebSocket = exports.SubscribableStream = exports.StreamingResponse = exports.StreamingRequest = exports.RequestHandler = exports.NamedPipeServer = exports.NamedPipeClient = exports.HttpContent = exports.ContentStream = void 0;
 var contentStream_1 = require("./contentStream");
-exports.ContentStream = contentStream_1.ContentStream;
+Object.defineProperty(exports, "ContentStream", { enumerable: true, get: function () { return contentStream_1.ContentStream; } });
 var httpContentStream_1 = require("./httpContentStream");
-exports.HttpContent = httpContentStream_1.HttpContent;
+Object.defineProperty(exports, "HttpContent", { enumerable: true, get: function () { return httpContentStream_1.HttpContent; } });
 var namedPipe_1 = require("./namedPipe");
-exports.NamedPipeClient = namedPipe_1.NamedPipeClient;
-exports.NamedPipeServer = namedPipe_1.NamedPipeServer;
+Object.defineProperty(exports, "NamedPipeClient", { enumerable: true, get: function () { return namedPipe_1.NamedPipeClient; } });
+Object.defineProperty(exports, "NamedPipeServer", { enumerable: true, get: function () { return namedPipe_1.NamedPipeServer; } });
 var requestHandler_1 = require("./requestHandler");
-exports.RequestHandler = requestHandler_1.RequestHandler;
+Object.defineProperty(exports, "RequestHandler", { enumerable: true, get: function () { return requestHandler_1.RequestHandler; } });
 var streamingRequest_1 = require("./streamingRequest");
-exports.StreamingRequest = streamingRequest_1.StreamingRequest;
+Object.defineProperty(exports, "StreamingRequest", { enumerable: true, get: function () { return streamingRequest_1.StreamingRequest; } });
 var streamingResponse_1 = require("./streamingResponse");
-exports.StreamingResponse = streamingResponse_1.StreamingResponse;
+Object.defineProperty(exports, "StreamingResponse", { enumerable: true, get: function () { return streamingResponse_1.StreamingResponse; } });
 var subscribableStream_1 = require("./subscribableStream");
-exports.SubscribableStream = subscribableStream_1.SubscribableStream;
+Object.defineProperty(exports, "SubscribableStream", { enumerable: true, get: function () { return subscribableStream_1.SubscribableStream; } });
 var webSocket_1 = require("./webSocket");
-exports.NodeWebSocket = webSocket_1.NodeWebSocket;
-exports.NodeWebSocketFactory = webSocket_1.NodeWebSocketFactory;
-exports.NodeWebSocketFactoryBase = webSocket_1.NodeWebSocketFactoryBase;
-exports.WebSocketClient = webSocket_1.WebSocketClient;
-exports.WebSocketServer = webSocket_1.WebSocketServer;
+Object.defineProperty(exports, "NodeWebSocket", { enumerable: true, get: function () { return webSocket_1.NodeWebSocket; } });
+Object.defineProperty(exports, "NodeWebSocketFactory", { enumerable: true, get: function () { return webSocket_1.NodeWebSocketFactory; } });
+Object.defineProperty(exports, "NodeWebSocketFactoryBase", { enumerable: true, get: function () { return webSocket_1.NodeWebSocketFactoryBase; } });
+Object.defineProperty(exports, "WebSocketClient", { enumerable: true, get: function () { return webSocket_1.WebSocketClient; } });
+Object.defineProperty(exports, "WebSocketServer", { enumerable: true, get: function () { return webSocket_1.WebSocketServer; } });
 //# sourceMappingURL=index.js.map

lib/interfaces/index.js

@@ -9,3 +9,25 @@ "use strict";
  */
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+__exportStar(require("./IBrowserFileReader"), exports);
+__exportStar(require("./IBrowserWebSocket"), exports);
+__exportStar(require("./IEventEmitter"), exports);
+__exportStar(require("./INodeBuffer"), exports);
+__exportStar(require("./INodeIncomingMessage"), exports);
+__exportStar(require("./INodeServer"), exports);
+__exportStar(require("./INodeSocket"), exports);
+__exportStar(require("./IReceiveRequest"), exports);
+__exportStar(require("./IReceiveResponse"), exports);
+__exportStar(require("./ISocket"), exports);
+__exportStar(require("./IStreamingTransportClient"), exports);
+__exportStar(require("./IStreamingTransportServer"), exports);
 //# sourceMappingURL=index.js.map

lib/namedPipe/index.js

@@ -9,9 +9,16 @@ "use strict";
  */
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./namedPipeClient"));
-__export(require("./namedPipeServer"));
-__export(require("./namedPipeTransport"));
+__exportStar(require("./namedPipeClient"), exports);
+__exportStar(require("./namedPipeServer"), exports);
+__exportStar(require("./namedPipeTransport"), exports);
 //# sourceMappingURL=index.js.map

lib/namedPipe/namedPipeClient.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.NamedPipeClient = void 0;
 /**
@@ -13,0 +15,0 @@ * @module botframework-streaming

lib/namedPipe/namedPipeServer.d.ts

@@ -29,3 +29,3 @@ import { RequestHandler } from '../requestHandler';
      */
-    readonly isConnected: boolean;
+    get isConnected(): boolean;
     /**
@@ -32,0 +32,0 @@ * Used to establish the connection used by this server and begin listening for incoming messages.

lib/namedPipe/namedPipeServer.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.NamedPipeServer = void 0;
 /**
@@ -13,0 +15,0 @@ * @module botframework-streaming

lib/namedPipe/namedPipeTransport.d.ts

@@ -41,3 +41,3 @@ /**
      */
-    readonly isConnected: boolean;
+    get isConnected(): boolean;
     /**
@@ -44,0 +44,0 @@ * Closes the transport.

lib/namedPipe/namedPipeTransport.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.NamedPipeTransport = void 0;
 /**
@@ -139,6 +140,6 @@ * Named pipes based transport sender and receiver abstraction
 }
+exports.NamedPipeTransport = NamedPipeTransport;
 NamedPipeTransport.PipePath = '\\\\.\\pipe\\';
 NamedPipeTransport.ServerIncomingPath = '.incoming';
 NamedPipeTransport.ServerOutgoingPath = '.outgoing';
-exports.NamedPipeTransport = NamedPipeTransport;
 //# sourceMappingURL=namedPipeTransport.js.map

lib/payloads/headerSerializer.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.HeaderSerializer = void 0;
 const payloadConstants_1 = require("./payloadConstants");
@@ -69,2 +70,3 @@ /**
 }
+exports.HeaderSerializer = HeaderSerializer;
 HeaderSerializer.Delimiter = '.';
@@ -85,3 +87,2 @@ HeaderSerializer.Terminator = '\n';
 HeaderSerializer.Encoding = 'utf8';
-exports.HeaderSerializer = HeaderSerializer;
 //# sourceMappingURL=headerSerializer.js.map

lib/payloads/index.js

@@ -9,13 +9,20 @@ "use strict";
  */
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./headerSerializer"));
-__export(require("./streamManager"));
-__export(require("./payloadAssemblerManager"));
-__export(require("./payloadTypes"));
-__export(require("./requestManager"));
-__export(require("./sendOperations"));
-__export(require("./streamManager"));
+__exportStar(require("./headerSerializer"), exports);
+__exportStar(require("./streamManager"), exports);
+__exportStar(require("./payloadAssemblerManager"), exports);
+__exportStar(require("./payloadTypes"), exports);
+__exportStar(require("./requestManager"), exports);
+__exportStar(require("./sendOperations"), exports);
+__exportStar(require("./streamManager"), exports);
 //# sourceMappingURL=index.js.map

lib/payloads/payloadAssemblerManager.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PayloadAssemblerManager = void 0;
 const payloadAssembler_1 = require("../assemblers/payloadAssembler");
@@ -4,0 +5,0 @@ const payloadTypes_1 = require("./payloadTypes");

lib/payloads/payloadConstants.js

@@ -10,2 +10,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PayloadConstants = void 0;
 /**
@@ -12,0 +13,0 @@ * Constants for streaming payloads.

lib/payloads/payloadTypes.js

@@ -10,2 +10,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PayloadTypes = void 0;
 /**
@@ -12,0 +13,0 @@ * Typess of payloads supported in the streaming library.

lib/payloads/requestManager.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.RequestManager = void 0;
 /**
@@ -13,0 +15,0 @@ * A streaming pending request.

lib/payloads/sendOperations.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.SendOperations = void 0;
 const cancelDisassembler_1 = require("../disassemblers/cancelDisassembler");
@@ -13,0 +15,0 @@ const httpContentStreamDisassembler_1 = require("../disassemblers/httpContentStreamDisassembler");

lib/payloads/streamManager.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.StreamManager = void 0;
 const payloadAssembler_1 = require("../assemblers/payloadAssembler");
@@ -4,0 +5,0 @@ /**

lib/payloadTransport/index.js

@@ -9,9 +9,17 @@ "use strict";
  */
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./payloadReceiver"));
-__export(require("./payloadSender"));
-__export(require("./transportDisconnectedEvent"));
+__exportStar(require("./payloadReceiver"), exports);
+__exportStar(require("./payloadSender"), exports);
+__exportStar(require("./transportDisconnectedEvent"), exports);
+__exportStar(require("./transportDisconnectedEventHandler"), exports);
 //# sourceMappingURL=index.js.map

lib/payloadTransport/payloadReceiver.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PayloadReceiver = void 0;
 const payloadTypes_1 = require("../payloads/payloadTypes");
@@ -13,0 +15,0 @@ const headerSerializer_1 = require("../payloads/headerSerializer");

lib/payloadTransport/payloadSender.d.ts

@@ -24,3 +24,3 @@ /**
      */
-    readonly isConnected: boolean;
+    get isConnected(): boolean;
     /**
@@ -27,0 +27,0 @@ * Connects to the given transport sender.

lib/payloadTransport/payloadSender.js

@@ -10,2 +10,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.PayloadSender = void 0;
 const headerSerializer_1 = require("../payloads/headerSerializer");
@@ -12,0 +13,0 @@ const payloadConstants_1 = require("../payloads/payloadConstants");

lib/payloadTransport/transportDisconnectedEvent.js

@@ -10,2 +10,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.TransportDisconnectedEvent = void 0;
 /**
@@ -25,2 +26,3 @@ * Event to be included when disconnection events are fired.
 }
+exports.TransportDisconnectedEvent = TransportDisconnectedEvent;
 /**
@@ -30,3 +32,2 @@ * A new and empty TransportDisconnectedEvent.
 TransportDisconnectedEvent.Empty = new TransportDisconnectedEvent();
-exports.TransportDisconnectedEvent = TransportDisconnectedEvent;
 //# sourceMappingURL=transportDisconnectedEvent.js.map

lib/protocolAdapter.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.ProtocolAdapter = void 0;
 const payloadAssemblerManager_1 = require("./payloads/payloadAssemblerManager");
@@ -13,0 +15,0 @@ const sendOperations_1 = require("./payloads/sendOperations");

lib/requestHandler.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.RequestHandler = void 0;
 /**
@@ -4,0 +5,0 @@ * Implemented by classes used to process incoming streaming requests sent over an [IStreamingTransport](xref:botframework-streaming.IStreamingTransport).

lib/streamingRequest.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.StreamingRequest = void 0;
 /**
@@ -4,0 +5,0 @@ * @module botframework-streaming

lib/streamingResponse.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.StreamingResponse = void 0;
 /**
@@ -4,0 +5,0 @@ * @module botframework-streaming

lib/subscribableStream.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.SubscribableStream = void 0;
 /**
@@ -4,0 +5,0 @@ * @module botframework-streaming

lib/utilities/createNodeServer.js

@@ -10,2 +10,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.getServerFactory = exports.createNodeServer = void 0;
 exports.createNodeServer = function (callback) {
@@ -12,0 +13,0 @@ if (callback && typeof callback !== 'function') {

lib/utilities/index.js

@@ -9,7 +9,14 @@ "use strict";
  */
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./protocol-base"));
+__exportStar(require("./protocol-base"), exports);
 //# sourceMappingURL=index.js.map

lib/utilities/protocol-base.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.generateGuid = void 0;
 /**
@@ -4,0 +5,0 @@ * @module botframework-streaming

lib/webSocket/factories/index.js

@@ -9,8 +9,15 @@ "use strict";
  */
-function __export(m) {
-    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
-}
+var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+}) : (function(o, m, k, k2) {
+    if (k2 === undefined) k2 = k;
+    o[k2] = m[k];
+}));
+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);
+};
 Object.defineProperty(exports, "__esModule", { value: true });
-__export(require("./nodeWebSocketFactory"));
-__export(require("./nodeWebSocketFactoryBase"));
+__exportStar(require("./nodeWebSocketFactory"), exports);
+__exportStar(require("./nodeWebSocketFactoryBase"), exports);
 //# sourceMappingURL=index.js.map

lib/webSocket/factories/nodeWebSocketFactory.js

@@ -10,6 +10,7 @@ "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -19,2 +20,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.NodeWebSocketFactory = void 0;
 const nodeWebSocket_1 = require("../nodeWebSocket");
@@ -21,0 +23,0 @@ const nodeWebSocketFactoryBase_1 = require("./nodeWebSocketFactoryBase");

lib/webSocket/factories/nodeWebSocketFactoryBase.js

@@ -10,2 +10,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.NodeWebSocketFactoryBase = void 0;
 /**
@@ -12,0 +13,0 @@ * Represents an abstract NodeWebSocketFactoryBase class to create a WebSocket.

lib/webSocket/index.js

@@ -10,14 +10,15 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.WebSocketTransport = exports.WebSocketServer = exports.WebSocketClient = exports.NodeWebSocket = exports.NodeWebSocketFactoryBase = exports.NodeWebSocketFactory = void 0;
 var factories_1 = require("./factories");
-exports.NodeWebSocketFactory = factories_1.NodeWebSocketFactory;
-exports.NodeWebSocketFactoryBase = factories_1.NodeWebSocketFactoryBase;
+Object.defineProperty(exports, "NodeWebSocketFactory", { enumerable: true, get: function () { return factories_1.NodeWebSocketFactory; } });
+Object.defineProperty(exports, "NodeWebSocketFactoryBase", { enumerable: true, get: function () { return factories_1.NodeWebSocketFactoryBase; } });
 var nodeWebSocket_1 = require("./nodeWebSocket");
-exports.NodeWebSocket = nodeWebSocket_1.NodeWebSocket;
+Object.defineProperty(exports, "NodeWebSocket", { enumerable: true, get: function () { return nodeWebSocket_1.NodeWebSocket; } });
 var nodeWebSocketClient_1 = require("./nodeWebSocketClient");
-exports.WebSocketClient = nodeWebSocketClient_1.WebSocketClient;
+Object.defineProperty(exports, "WebSocketClient", { enumerable: true, get: function () { return nodeWebSocketClient_1.WebSocketClient; } });
 var webSocketServer_1 = require("./webSocketServer");
-exports.WebSocketServer = webSocketServer_1.WebSocketServer;
+Object.defineProperty(exports, "WebSocketServer", { enumerable: true, get: function () { return webSocketServer_1.WebSocketServer; } });
 /** @internal */
 var webSocketTransport_1 = require("./webSocketTransport");
-exports.WebSocketTransport = webSocketTransport_1.WebSocketTransport;
+Object.defineProperty(exports, "WebSocketTransport", { enumerable: true, get: function () { return webSocketTransport_1.WebSocketTransport; } });
 //# sourceMappingURL=index.js.map

lib/webSocket/nodeWebSocket.d.ts

@@ -32,3 +32,3 @@ /**
      */
-    readonly isConnected: boolean;
+    get isConnected(): boolean;
     /**
@@ -35,0 +35,0 @@ * Writes a buffer to the socket and sends it.

lib/webSocket/nodeWebSocket.js

@@ -10,6 +10,7 @@ "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -19,2 +20,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.NodeWebSocket = void 0;
 const crypto = require("crypto");
@@ -21,0 +23,0 @@ const http_1 = require("http");

lib/webSocket/nodeWebSocketClient.js

@@ -10,6 +10,7 @@ "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -19,2 +20,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.WebSocketClient = void 0;
 const protocolAdapter_1 = require("../protocolAdapter");
@@ -21,0 +23,0 @@ const payloads_1 = require("../payloads");

lib/webSocket/webSocketServer.d.ts

@@ -28,3 +28,3 @@ import { RequestHandler } from '../requestHandler';
      */
-    readonly isConnected: boolean;
+    get isConnected(): boolean;
     /**
@@ -31,0 +31,0 @@ * Used to establish the connection used by this server and begin listening for incoming messages.

lib/webSocket/webSocketServer.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.WebSocketServer = void 0;
 /**
@@ -13,0 +15,0 @@ * @module botframework-streaming

lib/webSocket/webSocketTransport.d.ts

@@ -38,3 +38,3 @@ /**
      */
-    readonly isConnected: boolean;
+    get isConnected(): boolean;
     /**
@@ -41,0 +41,0 @@ * Close the socket this transport is connected to.

lib/webSocket/webSocketTransport.js

 "use strict";
 var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
     return new (P || (P = Promise))(function (resolve, reject) {
         function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
         function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
-        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
         step((generator = generator.apply(thisArg, _arguments || [])).next());
@@ -11,2 +12,3 @@ });
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.WebSocketTransport = void 0;
 /**
@@ -13,0 +15,0 @@ * Web socket based transport.

package.json

@@ -5,3 +5,3 @@ {
   "description": "Streaming library for the Microsoft Bot Framework",
-  "version": "4.12.0-dev-20201110-dec6519b1afc",
+  "version": "4.12.0-dev-20201112.60e5e9fc1086",
   "license": "MIT",
@@ -25,3 +25,10 @@ "keywords": [
   "browser": "lib/index-browser.js",
-  "typings": "lib/index.d.ts",
+  "types": "lib/index.d.ts",
+  "typesVersions": {
+    "<3.9": {
+      "*": [
+        "_ts3.4/*"
+      ]
+    }
+  },
   "dependencies": {
@@ -38,2 +45,3 @@ "@types/ws": "^6.0.3",
     "chai": "^4.2.0",
+    "downlevel-dts": "^0.7.0",
     "exorcist": "^1.0.1",
@@ -45,12 +53,14 @@ "mocha": "^6.2.3",
     "sinon": "^7.5.0",
-    "ts-node": "^4.1.0",
-    "typescript": "3.5.3"
+    "ts-node": "^9.0.0",
+    "typescript": "^4.0.5"
   },
   "scripts": {
     "build": "npm-run-all -p build:lib build:es5",
+    "build:es5": "npm-run-all build:es5:tsc build:es5:browserify",
+    "build:es5:browserify": "browserify -s BFSE --debug es5/index-browser.js | exorcist lib/index-browser.js.map > lib/index-browser.js",
+    "build:es5:tsc": "tsc -p tsconfig-es5.json",
     "build:lib": "tsc -p tsconfig.json",
-    "build:es5": "tsc -p tsconfig-es5.json",
-    "postbuild": "browserify -s BFSE --debug es5/index-browser.js | exorcist lib/index-browser.js.map > lib/index-browser.js",
     "build:rollup": "yarn clean && yarn build && api-extractor run --verbose --local",
     "clean": "rimraf q s lib es5",
+    "postbuild": "downlevel-dts lib _ts3.4/lib",
     "test": "yarn build && nyc mocha tests/",
@@ -60,2 +70,3 @@ "test:compat": "api-extractor run --verbose"
   "files": [
+    "_ts3.4",
     "lib",
@@ -62,0 +73,0 @@ "src"

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1179266

increased by9.27%

Number of package files

416

increased by19.54%

Lines of code

18280

increased by14.47%

Worsened metrics

Dev dependency count

14

increased by7.69%

No dependency changes