@grpc/grpc-js - npm Package Compare versions

Comparing version 1.10.8 to 1.10.9

build/src/compression-filter.d.ts

@@ -15,2 +15,3 @@ /// <reference types="node" />
     private currentCompressionAlgorithm;
+    private maxReceiveMessageLength;
     constructor(channelOptions: ChannelOptions, sharedFilterConfig: SharedCompressionFilterConfig);
@@ -17,0 +18,0 @@ sendMetadata(metadata: Promise<Metadata>): Promise<Metadata>;

build/src/compression-filter.js

@@ -76,2 +76,6 @@ "use strict";
 class DeflateHandler extends CompressionHandler {
+    constructor(maxRecvMessageLength) {
+        super();
+        this.maxRecvMessageLength = maxRecvMessageLength;
+    }
     compressMessage(message) {
@@ -91,10 +95,21 @@ return new Promise((resolve, reject) => {
         return new Promise((resolve, reject) => {
-            zlib.inflate(message, (err, output) => {
-                if (err) {
-                    reject(err);
+            let totalLength = 0;
+            const messageParts = [];
+            const decompresser = zlib.createInflate();
+            decompresser.on('data', (chunk) => {
+                messageParts.push(chunk);
+                totalLength += chunk.byteLength;
+                if (this.maxRecvMessageLength !== -1 && totalLength > this.maxRecvMessageLength) {
+                    decompresser.destroy();
+                    reject({
+                        code: constants_1.Status.RESOURCE_EXHAUSTED,
+                        details: `Received message that decompresses to a size larger than ${this.maxRecvMessageLength}`
+                    });
                 }
-                else {
-                    resolve(output);
-                }
             });
+            decompresser.on('end', () => {
+                resolve(Buffer.concat(messageParts));
+            });
+            decompresser.write(message);
+            decompresser.end();
         });
@@ -104,2 +119,6 @@ }
 class GzipHandler extends CompressionHandler {
+    constructor(maxRecvMessageLength) {
+        super();
+        this.maxRecvMessageLength = maxRecvMessageLength;
+    }
     compressMessage(message) {
@@ -119,10 +138,21 @@ return new Promise((resolve, reject) => {
         return new Promise((resolve, reject) => {
-            zlib.unzip(message, (err, output) => {
-                if (err) {
-                    reject(err);
+            let totalLength = 0;
+            const messageParts = [];
+            const decompresser = zlib.createGunzip();
+            decompresser.on('data', (chunk) => {
+                messageParts.push(chunk);
+                totalLength += chunk.byteLength;
+                if (this.maxRecvMessageLength !== -1 && totalLength > this.maxRecvMessageLength) {
+                    decompresser.destroy();
+                    reject({
+                        code: constants_1.Status.RESOURCE_EXHAUSTED,
+                        details: `Received message that decompresses to a size larger than ${this.maxRecvMessageLength}`
+                    });
                 }
-                else {
-                    resolve(output);
-                }
             });
+            decompresser.on('end', () => {
+                resolve(Buffer.concat(messageParts));
+            });
+            decompresser.write(message);
+            decompresser.end();
         });
@@ -144,3 +174,3 @@ }
 }
-function getCompressionHandler(compressionName) {
+function getCompressionHandler(compressionName, maxReceiveMessageSize) {
     switch (compressionName) {
@@ -150,5 +180,5 @@ case 'identity':
         case 'deflate':
-            return new DeflateHandler();
+            return new DeflateHandler(maxReceiveMessageSize);
         case 'gzip':
-            return new GzipHandler();
+            return new GzipHandler(maxReceiveMessageSize);
         default:
@@ -160,3 +190,3 @@ return new UnknownHandler(compressionName);
     constructor(channelOptions, sharedFilterConfig) {
-        var _a;
+        var _a, _b;
         super();
@@ -168,6 +198,7 @@ this.sharedFilterConfig = sharedFilterConfig;
         const compressionAlgorithmKey = channelOptions['grpc.default_compression_algorithm'];
+        this.maxReceiveMessageLength = (_a = channelOptions['grpc.max_receive_message_length']) !== null && _a !== void 0 ? _a : constants_1.DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH;
         if (compressionAlgorithmKey !== undefined) {
             if (isCompressionAlgorithmKey(compressionAlgorithmKey)) {
                 const clientSelectedEncoding = compression_algorithms_1.CompressionAlgorithms[compressionAlgorithmKey];
-                const serverSupportedEncodings = (_a = sharedFilterConfig.serverSupportedEncodingHeader) === null || _a === void 0 ? void 0 : _a.split(',');
+                const serverSupportedEncodings = (_b = sharedFilterConfig.serverSupportedEncodingHeader) === null || _b === void 0 ? void 0 : _b.split(',');
                 /**
@@ -183,3 +214,3 @@ * There are two possible situations here:
                     this.currentCompressionAlgorithm = clientSelectedEncoding;
-                    this.sendCompression = getCompressionHandler(this.currentCompressionAlgorithm);
+                    this.sendCompression = getCompressionHandler(this.currentCompressionAlgorithm, -1);
                 }
@@ -210,3 +241,3 @@ }
             if (typeof encoding === 'string') {
-                this.receiveCompression = getCompressionHandler(encoding);
+                this.receiveCompression = getCompressionHandler(encoding, this.maxReceiveMessageLength);
             }
@@ -213,0 +244,0 @@ }

build/src/internal-channel.js

@@ -29,3 +29,2 @@ "use strict";
 const logging_1 = require("./logging");
-const max_message_size_filter_1 = require("./max-message-size-filter");
 const http_proxy_1 = require("./http_proxy");
@@ -244,3 +243,2 @@ const uri_parser_1 = require("./uri-parser");
         this.filterStackFactory = new filter_stack_1.FilterStackFactory([
-            new max_message_size_filter_1.MaxMessageSizeFilterFactory(this.options),
             new compression_filter_1.CompressionFilterFactory(this, this.options),
@@ -247,0 +245,0 @@ ]);

build/src/server-interceptors.js

@@ -25,7 +25,4 @@ "use strict";
 const zlib = require("zlib");
-const util_1 = require("util");
 const stream_decoder_1 = require("./stream-decoder");
 const logging = require("./logging");
-const unzip = (0, util_1.promisify)(zlib.unzip);
-const inflate = (0, util_1.promisify)(zlib.inflate);
 const TRACER_NAME = 'server_call';
@@ -343,3 +340,2 @@ function trace(text) {
         this.incomingEncoding = 'identity';
-        this.decoder = new stream_decoder_1.StreamDecoder();
         this.readQueue = [];
@@ -386,2 +382,3 @@ this.isReadPending = false;
         }
+        this.decoder = new stream_decoder_1.StreamDecoder(this.maxReceiveMessageSize);
         const metadata = metadata_1.Metadata.fromHttp2Headers(headers);
@@ -489,15 +486,41 @@ if (logging.isTracerEnabled(TRACER_NAME)) {
     decompressMessage(message, encoding) {
-        switch (encoding) {
-            case 'deflate':
-                return inflate(message.subarray(5));
-            case 'gzip':
-                return unzip(message.subarray(5));
-            case 'identity':
-                return message.subarray(5);
-            default:
-                return Promise.reject({
-                    code: constants_1.Status.UNIMPLEMENTED,
-                    details: `Received message compressed with unsupported encoding "${encoding}"`,
+        const messageContents = message.subarray(5);
+        if (encoding === 'identity') {
+            return messageContents;
+        }
+        else if (encoding === 'deflate' || encoding === 'gzip') {
+            let decompresser;
+            if (encoding === 'deflate') {
+                decompresser = zlib.createInflate();
+            }
+            else {
+                decompresser = zlib.createGunzip();
+            }
+            return new Promise((resolve, reject) => {
+                let totalLength = 0;
+                const messageParts = [];
+                decompresser.on('data', (chunk) => {
+                    messageParts.push(chunk);
+                    totalLength += chunk.byteLength;
+                    if (this.maxReceiveMessageSize !== -1 && totalLength > this.maxReceiveMessageSize) {
+                        decompresser.destroy();
+                        reject({
+                            code: constants_1.Status.RESOURCE_EXHAUSTED,
+                            details: `Received message that decompresses to a size larger than ${this.maxReceiveMessageSize}`
+                        });
+                    }
                 });
+                decompresser.on('end', () => {
+                    resolve(Buffer.concat(messageParts));
+                });
+                decompresser.write(messageContents);
+                decompresser.end();
+            });
         }
+        else {
+            return Promise.reject({
+                code: constants_1.Status.UNIMPLEMENTED,
+                details: `Received message compressed with unsupported encoding "${encoding}"`,
+            });
+        }
     }
@@ -512,4 +535,11 @@ async decompressAndMaybePush(queueEntry) {
             : 'identity';
-        const decompressedMessage = await this.decompressMessage(queueEntry.compressedMessage, compressedMessageEncoding);
+        let decompressedMessage;
         try {
+            decompressedMessage = await this.decompressMessage(queueEntry.compressedMessage, compressedMessageEncoding);
+        }
+        catch (err) {
+            this.sendStatus(err);
+            return;
+        }
+        try {
             queueEntry.parsedMessage = this.handler.deserialize(decompressedMessage);
@@ -552,14 +582,12 @@ }
             data.length);
-        const rawMessages = this.decoder.write(data);
+        let rawMessages;
+        try {
+            rawMessages = this.decoder.write(data);
+        }
+        catch (e) {
+            this.sendStatus({ code: constants_1.Status.RESOURCE_EXHAUSTED, details: e.message });
+            return;
+        }
         for (const messageBytes of rawMessages) {
             this.stream.pause();
-            if (this.maxReceiveMessageSize !== -1 &&
-                messageBytes.length - 5 > this.maxReceiveMessageSize) {
-                this.sendStatus({
-                    code: constants_1.Status.RESOURCE_EXHAUSTED,
-                    details: `Received message larger than max (${messageBytes.length - 5} vs. ${this.maxReceiveMessageSize})`,
-                    metadata: null,
-                });
-                return;
-            }
             const queueEntry = {
@@ -566,0 +594,0 @@ type: 'COMPRESSED',

build/src/stream-decoder.d.ts

 /// <reference types="node" />
 export declare class StreamDecoder {
+    private maxReadMessageLength;
     private readState;
@@ -10,3 +11,4 @@ private readCompressFlag;
     private readMessageRemaining;
+    constructor(maxReadMessageLength: number);
     write(data: Buffer): Buffer[];
 }

build/src/stream-decoder.js

@@ -27,3 +27,4 @@ "use strict";
 class StreamDecoder {
-    constructor() {
+    constructor(maxReadMessageLength) {
+        this.maxReadMessageLength = maxReadMessageLength;
         this.readState = ReadState.NO_DATA;
@@ -61,2 +62,5 @@ this.readCompressFlag = Buffer.alloc(1);
                         this.readMessageSize = this.readPartialSize.readUInt32BE(0);
+                        if (this.maxReadMessageLength !== -1 && this.readMessageSize > this.maxReadMessageLength) {
+                            throw new Error(`Received message larger than max (${this.readMessageSize} vs ${this.maxReadMessageLength})`);
+                        }
                         this.readMessageRemaining = this.readMessageSize;
@@ -63,0 +67,0 @@ if (this.readMessageRemaining > 0) {

build/src/subchannel-call.js

@@ -76,2 +76,3 @@ "use strict";
     constructor(http2Stream, callEventTracker, listener, transport, callId) {
+        var _a;
         this.http2Stream = http2Stream;
@@ -82,3 +83,2 @@ this.callEventTracker = callEventTracker;
         this.callId = callId;
-        this.decoder = new stream_decoder_1.StreamDecoder();
         this.isReadFilterPending = false;
@@ -98,2 +98,4 @@ this.isPushPending = false;
         this.serverEndedCall = false;
+        const maxReceiveMessageLength = (_a = transport.getOptions()['grpc.max_receive_message_length']) !== null && _a !== void 0 ? _a : constants_1.DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH;
+        this.decoder = new stream_decoder_1.StreamDecoder(maxReceiveMessageLength);
         http2Stream.on('response', (headers, flags) => {
@@ -135,3 +137,10 @@ let headersString = '';
             this.trace('receive HTTP/2 data frame of length ' + data.length);
-            const messages = this.decoder.write(data);
+            let messages;
+            try {
+                messages = this.decoder.write(data);
+            }
+            catch (e) {
+                this.cancelWithStatus(constants_1.Status.RESOURCE_EXHAUSTED, e.message);
+                return;
+            }
             for (const message of messages) {
@@ -138,0 +147,0 @@ this.trace('parsed message of length ' + message.length);

build/src/transport.d.ts

@@ -23,2 +23,3 @@ /// <reference types="node" />
     getPeerName(): string;
+    getOptions(): ChannelOptions;
     createCall(metadata: Metadata, host: string, method: string, listener: SubchannelCallInterceptingListener, subchannelCallStatsTracker: Partial<CallEventTracker>): SubchannelCall;
@@ -30,2 +31,3 @@ addDisconnectListener(listener: TransportDisconnectListener): void;
     private session;
+    private options;
     /**
@@ -117,2 +119,3 @@ * Name of the remote server, if it is not the same as the subchannel
     getPeerName(): string;
+    getOptions(): ChannelOptions;
     shutdown(): void;
@@ -119,0 +122,0 @@ }

build/src/transport.js

@@ -46,2 +46,3 @@ "use strict";
         this.session = session;
+        this.options = options;
         this.remoteName = remoteName;
@@ -470,2 +471,5 @@ /**
     }
+    getOptions() {
+        return this.options;
+    }
     shutdown() {
@@ -472,0 +476,0 @@ this.session.close();

package.json

 {
   "name": "@grpc/grpc-js",
-  "version": "1.10.8",
+  "version": "1.10.9",
   "description": "gRPC Library for Node - pure JS implementation",
@@ -5,0 +5,0 @@ "homepage": "https://grpc.io/",

src/compression-filter.ts

@@ -24,3 +24,3 @@ /*
 import { CompressionAlgorithms } from './compression-algorithms';
-import { LogVerbosity } from './constants';
+import { DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH, LogVerbosity, Status } from './constants';
 import { BaseFilter, Filter, FilterFactory } from './filter';
@@ -102,2 +102,6 @@ import * as logging from './logging';
 class DeflateHandler extends CompressionHandler {
+  constructor(private maxRecvMessageLength: number) {
+    super();
+  }
+
   compressMessage(message: Buffer) {
@@ -117,9 +121,21 @@ return new Promise<Buffer>((resolve, reject) => {
     return new Promise<Buffer>((resolve, reject) => {
-      zlib.inflate(message, (err, output) => {
-        if (err) {
-          reject(err);
-        } else {
-          resolve(output);
+      let totalLength = 0;
+      const messageParts: Buffer[] = [];
+      const decompresser = zlib.createInflate();
+      decompresser.on('data', (chunk: Buffer) => {
+        messageParts.push(chunk);
+        totalLength += chunk.byteLength;
+        if (this.maxRecvMessageLength !== -1 && totalLength > this.maxRecvMessageLength) {
+          decompresser.destroy();
+          reject({
+            code: Status.RESOURCE_EXHAUSTED,
+            details: `Received message that decompresses to a size larger than ${this.maxRecvMessageLength}`
+          });
         }
       });
+      decompresser.on('end', () => {
+        resolve(Buffer.concat(messageParts));
+      });
+      decompresser.write(message);
+      decompresser.end();
     });
@@ -130,2 +146,6 @@ }
 class GzipHandler extends CompressionHandler {
+  constructor(private maxRecvMessageLength: number) {
+    super();
+  }
+
   compressMessage(message: Buffer) {
@@ -145,9 +165,21 @@ return new Promise<Buffer>((resolve, reject) => {
     return new Promise<Buffer>((resolve, reject) => {
-      zlib.unzip(message, (err, output) => {
-        if (err) {
-          reject(err);
-        } else {
-          resolve(output);
+      let totalLength = 0;
+      const messageParts: Buffer[] = [];
+      const decompresser = zlib.createGunzip();
+      decompresser.on('data', (chunk: Buffer) => {
+        messageParts.push(chunk);
+        totalLength += chunk.byteLength;
+        if (this.maxRecvMessageLength !== -1 && totalLength > this.maxRecvMessageLength) {
+          decompresser.destroy();
+          reject({
+            code: Status.RESOURCE_EXHAUSTED,
+            details: `Received message that decompresses to a size larger than ${this.maxRecvMessageLength}`
+          });
         }
       });
+      decompresser.on('end', () => {
+        resolve(Buffer.concat(messageParts));
+      });
+      decompresser.write(message);
+      decompresser.end();
     });
@@ -177,3 +209,3 @@ }
 
-function getCompressionHandler(compressionName: string): CompressionHandler {
+function getCompressionHandler(compressionName: string, maxReceiveMessageSize: number): CompressionHandler {
   switch (compressionName) {
@@ -183,5 +215,5 @@ case 'identity':
     case 'deflate':
-      return new DeflateHandler();
+      return new DeflateHandler(maxReceiveMessageSize);
     case 'gzip':
-      return new GzipHandler();
+      return new GzipHandler(maxReceiveMessageSize);
     default:
@@ -196,2 +228,3 @@ return new UnknownHandler(compressionName);
   private currentCompressionAlgorithm: CompressionAlgorithm = 'identity';
+  private maxReceiveMessageLength: number;
 
@@ -206,2 +239,3 @@ constructor(
       channelOptions['grpc.default_compression_algorithm'];
+    this.maxReceiveMessageLength = channelOptions['grpc.max_receive_message_length'] ?? DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH
     if (compressionAlgorithmKey !== undefined) {
@@ -227,3 +261,4 @@ if (isCompressionAlgorithmKey(compressionAlgorithmKey)) {
           this.sendCompression = getCompressionHandler(
-            this.currentCompressionAlgorithm
+            this.currentCompressionAlgorithm,
+            -1
           );
@@ -260,3 +295,3 @@ }
       if (typeof encoding === 'string') {
-        this.receiveCompression = getCompressionHandler(encoding);
+        this.receiveCompression = getCompressionHandler(encoding, this.maxReceiveMessageLength);
       }
@@ -263,0 +298,0 @@ }

src/internal-channel.ts

@@ -36,3 +36,2 @@ /*
 import { SubchannelAddress } from './subchannel-address';
-import { MaxMessageSizeFilterFactory } from './max-message-size-filter';
 import { mapProxyName } from './http_proxy';
@@ -406,3 +405,2 @@ import { GrpcUri, parseUri, uriToString } from './uri-parser';
     this.filterStackFactory = new FilterStackFactory([
-      new MaxMessageSizeFilterFactory(this.options),
       new CompressionFilterFactory(this, this.options),
@@ -409,0 +407,0 @@ ]);

src/server-interceptors.ts

@@ -33,3 +33,2 @@ /*
 import * as zlib from 'zlib';
-import { promisify } from 'util';
 import { StreamDecoder } from './stream-decoder';
@@ -39,5 +38,2 @@ import { CallEventTracker } from './transport';
 
-const unzip = promisify(zlib.unzip);
-const inflate = promisify(zlib.inflate);
-
 const TRACER_NAME = 'server_call';
@@ -501,3 +497,3 @@
   private incomingEncoding = 'identity';
-  private decoder = new StreamDecoder();
+  private decoder: StreamDecoder;
   private readQueue: ReadQueueEntry[] = [];
@@ -560,2 +556,4 @@ private isReadPending = false;
 
+    this.decoder = new StreamDecoder(this.maxReceiveMessageSize);
+
     const metadata = Metadata.fromHttp2Headers(headers);
@@ -681,14 +679,37 @@
   ): Buffer | Promise<Buffer> {
-    switch (encoding) {
-      case 'deflate':
-        return inflate(message.subarray(5));
-      case 'gzip':
-        return unzip(message.subarray(5));
-      case 'identity':
-        return message.subarray(5);
-      default:
-        return Promise.reject({
-          code: Status.UNIMPLEMENTED,
-          details: `Received message compressed with unsupported encoding "${encoding}"`,
+    const messageContents = message.subarray(5);
+    if (encoding === 'identity') {
+      return messageContents;
+    } else if (encoding === 'deflate' || encoding === 'gzip') {
+      let decompresser: zlib.Gunzip | zlib.Deflate;
+      if (encoding === 'deflate') {
+        decompresser = zlib.createInflate();
+      } else {
+        decompresser = zlib.createGunzip();
+      }
+      return new Promise((resolve, reject) => {
+        let totalLength = 0
+        const messageParts: Buffer[] = [];
+        decompresser.on('data', (chunk: Buffer) => {
+          messageParts.push(chunk);
+          totalLength += chunk.byteLength;
+          if (this.maxReceiveMessageSize !== -1 && totalLength > this.maxReceiveMessageSize) {
+            decompresser.destroy();
+            reject({
+              code: Status.RESOURCE_EXHAUSTED,
+              details: `Received message that decompresses to a size larger than ${this.maxReceiveMessageSize}`
+            });
+          }
         });
+        decompresser.on('end', () => {
+          resolve(Buffer.concat(messageParts));
+        });
+        decompresser.write(messageContents);
+        decompresser.end();
+      });
+    } else {
+      return Promise.reject({
+        code: Status.UNIMPLEMENTED,
+        details: `Received message compressed with unsupported encoding "${encoding}"`,
+      });
     }
@@ -706,7 +727,13 @@ }
       : 'identity';
-    const decompressedMessage = await this.decompressMessage(
-      queueEntry.compressedMessage!,
-      compressedMessageEncoding
-    );
+    let decompressedMessage: Buffer;
     try {
+      decompressedMessage = await this.decompressMessage(
+        queueEntry.compressedMessage!,
+        compressedMessageEncoding
+      );
+    } catch (err) {
+      this.sendStatus(err as PartialStatusObject);
+      return;
+    }
+    try {
       queueEntry.parsedMessage = this.handler.deserialize(decompressedMessage);
@@ -752,19 +779,12 @@ } catch (err) {
     );
-    const rawMessages = this.decoder.write(data);
+    let rawMessages: Buffer[];
+    try {
+      rawMessages = this.decoder.write(data);
+    } catch (e) {
+      this.sendStatus({ code: Status.RESOURCE_EXHAUSTED, details: (e as Error).message });
+      return;
+    }
 
     for (const messageBytes of rawMessages) {
       this.stream.pause();
-      if (
-        this.maxReceiveMessageSize !== -1 &&
-        messageBytes.length - 5 > this.maxReceiveMessageSize
-      ) {
-        this.sendStatus({
-          code: Status.RESOURCE_EXHAUSTED,
-          details: `Received message larger than max (${
-            messageBytes.length - 5
-          } vs. ${this.maxReceiveMessageSize})`,
-          metadata: null,
-        });
-        return;
-      }
       const queueEntry: ReadQueueEntry = {
@@ -771,0 +791,0 @@ type: 'COMPRESSED',

src/stream-decoder.ts

@@ -33,2 +33,4 @@ /*
 
+  constructor(private maxReadMessageLength: number) {}
+
   write(data: Buffer): Buffer[] {
@@ -64,2 +66,5 @@ let readHead = 0;
             this.readMessageSize = this.readPartialSize.readUInt32BE(0);
+            if (this.maxReadMessageLength !== -1 && this.readMessageSize > this.maxReadMessageLength) {
+              throw new Error(`Received message larger than max (${this.readMessageSize} vs ${this.maxReadMessageLength})`);
+            }
             this.readMessageRemaining = this.readMessageSize;
@@ -66,0 +71,0 @@ if (this.readMessageRemaining > 0) {

src/subchannel-call.ts

@@ -21,3 +21,3 @@ /*
 
-import { Status } from './constants';
+import { DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH, Status } from './constants';
 import { Metadata } from './metadata';
@@ -120,3 +120,3 @@ import { StreamDecoder } from './stream-decoder';
 export class Http2SubchannelCall implements SubchannelCall {
-  private decoder = new StreamDecoder();
+  private decoder: StreamDecoder;
 
@@ -152,2 +152,4 @@ private isReadFilterPending = false;
   ) {
+    const maxReceiveMessageLength = transport.getOptions()['grpc.max_receive_message_length'] ?? DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH;
+    this.decoder = new StreamDecoder(maxReceiveMessageLength);
     http2Stream.on('response', (headers, flags) => {
@@ -188,3 +190,9 @@ let headersString = '';
       this.trace('receive HTTP/2 data frame of length ' + data.length);
-      const messages = this.decoder.write(data);
+      let messages: Buffer[];
+      try {
+        messages = this.decoder.write(data);
+      } catch (e) {
+        this.cancelWithStatus(Status.RESOURCE_EXHAUSTED, (e as Error).message);
+        return;
+      }
 
@@ -191,0 +199,0 @@ for (const message of messages) {

src/transport.ts

@@ -87,2 +87,3 @@ /*
   getPeerName(): string;
+  getOptions(): ChannelOptions;
   createCall(
@@ -151,3 +152,3 @@ metadata: Metadata,
     subchannelAddress: SubchannelAddress,
-    options: ChannelOptions,
+    private options: ChannelOptions,
     /**
@@ -622,2 +623,6 @@ * Name of the remote server, if it is not the same as the subchannel
 
+  getOptions() {
+    return this.options;
+  }
+
   shutdown() {
@@ -624,0 +629,0 @@ this.session.close();

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

1846999

increased by0.03%

Worsened metrics

Number of package files

436

decreased by-0.91%

Lines of code

37859

decreased by-0.09%

No dependency changes