@grpc/grpc-js - npm Package Compare versions

Comparing version 1.0.2 to 1.0.3

build/src/call-stream.js

@@ -110,2 +110,3 @@ "use strict";
     outputStatus() {
+        var _a;
         /* Precondition: this.finalStatus !== null */
@@ -115,3 +116,3 @@ if (!this.statusOutput) {
             const filteredStatus = this.filterStack.receiveTrailers(this.finalStatus);
-            this.listener.onReceiveStatus(filteredStatus);
+            (_a = this.listener) === null || _a === void 0 ? void 0 : _a.onReceiveStatus(filteredStatus);
             if (this.subchannel) {
@@ -132,3 +133,2 @@ this.subchannel.callUnref();
     endCall(status) {
-        this.destroyHttp2Stream();
         /* If the status is OK and a new status comes in (e.g. from a
@@ -145,2 +145,3 @@ * deserialization failure), that new status takes priority */
         }
+        this.destroyHttp2Stream();
     }
@@ -166,3 +167,4 @@ maybeOutputStatus() {
         process.nextTick(() => {
-            this.listener.onReceiveMessage(message);
+            var _a;
+            (_a = this.listener) === null || _a === void 0 ? void 0 : _a.onReceiveMessage(message);
             this.maybeOutputStatus();
@@ -281,2 +283,3 @@ });
             stream.on('response', (headers, flags) => {
+                var _a;
                 let headersString = '';
@@ -328,6 +331,5 @@ for (const header of Object.keys(headers)) {
                         const finalMetadata = this.filterStack.receiveMetadata(metadata);
-                        this.listener.onReceiveMetadata(finalMetadata);
+                        (_a = this.listener) === null || _a === void 0 ? void 0 : _a.onReceiveMetadata(finalMetadata);
                     }
                     catch (error) {
-                        this.destroyHttp2Stream();
                         this.endCall({
@@ -448,3 +450,2 @@ code: constants_1.Status.UNKNOWN,
         this.trace('cancelWithStatus code: ' + status + ' details: "' + details + '"');
-        this.destroyHttp2Stream();
         this.endCall({ code: status, details, metadata: new metadata_1.Metadata() });
@@ -451,0 +452,0 @@ }

build/src/channel.js

@@ -247,3 +247,3 @@ "use strict";
     updateState(newState) {
-        logging_1.trace(constants_1.LogVerbosity.DEBUG, 'connectivity_state', this.target +
+        logging_1.trace(constants_1.LogVerbosity.DEBUG, 'connectivity_state', uri_parser_1.uriToString(this.target) +
             ' ' +
@@ -310,3 +310,3 @@ ConnectivityState[this.connectivityState] +
         const callNumber = getNewCallNumber();
-        logging_1.trace(constants_1.LogVerbosity.DEBUG, 'channel', this.target +
+        logging_1.trace(constants_1.LogVerbosity.DEBUG, 'channel', uri_parser_1.uriToString(this.target) +
             ' createCall [' +
@@ -313,0 +313,0 @@ callNumber +

build/src/http_proxy.js

@@ -117,3 +117,3 @@ "use strict";
         if (host === serverHost) {
-            trace('Not using proxy for target in no_proxy list: ' + target);
+            trace('Not using proxy for target in no_proxy list: ' + uri_parser_1.uriToString(target));
             return noProxyResult;
@@ -120,0 +120,0 @@ }

build/src/index.d.ts

@@ -10,7 +10,7 @@ /// <reference types="node" />
 import { Deserialize, loadPackageDefinition, makeClientConstructor, MethodDefinition, Serialize, ServiceDefinition } from './make-client';
-import { Metadata } from './metadata';
+import { Metadata, MetadataValue } from './metadata';
 import { Server, UntypedHandleCall, UntypedServiceImplementation } from './server';
 import { KeyCertPair, ServerCredentials } from './server-credentials';
 import { StatusBuilder } from './status-builder';
-import { handleBidiStreamingCall, handleServerStreamingCall, handleUnaryCall, ServerUnaryCall, ServerReadableStream, ServerWritableStream, ServerDuplexStream } from './server-call';
+import { handleBidiStreamingCall, handleServerStreamingCall, handleUnaryCall, sendUnaryData, ServerUnaryCall, ServerReadableStream, ServerWritableStream, ServerDuplexStream } from './server-call';
 export interface OAuth2Client {
@@ -29,3 +29,3 @@ getRequestMetadata: (url: string, callback: (err: Error | null, headers?: {
 /**** Metadata ****/
-export { Metadata };
+export { Metadata, MetadataValue };
 /**** Constants ****/
@@ -41,3 +41,3 @@ export { LogVerbosity as logVerbosity, Status as status, ConnectivityState as connectivityState, };
 export declare const waitForClientReady: (client: Client, deadline: number | Date, callback: (error?: Error | undefined) => void) => void;
-export { ChannelCredentials, CallCredentials, Deadline, Serialize as serialize, Deserialize as deserialize, ClientUnaryCall, ClientReadableStream, ClientWritableStream, ClientDuplexStream, CallOptions, MethodDefinition, StatusObject, ServiceError, ServerUnaryCall, ServerReadableStream, ServerWritableStream, ServerDuplexStream, ServiceDefinition, UntypedHandleCall, UntypedServiceImplementation, };
+export { sendUnaryData, ChannelCredentials, CallCredentials, Deadline, Serialize as serialize, Deserialize as deserialize, ClientUnaryCall, ClientReadableStream, ClientWritableStream, ClientDuplexStream, CallOptions, MethodDefinition, StatusObject, ServiceError, ServerUnaryCall, ServerReadableStream, ServerWritableStream, ServerDuplexStream, ServiceDefinition, UntypedHandleCall, UntypedServiceImplementation, };
 /**** Server ****/
@@ -44,0 +44,0 @@ export { handleBidiStreamingCall, handleServerStreamingCall, handleUnaryCall };

build/src/resolver-dns.js

@@ -94,3 +94,3 @@ "use strict";
             code: constants_1.Status.UNAVAILABLE,
-            details: `Name resolution failed for target ${this.target}`,
+            details: `Name resolution failed for target ${uri_parser_1.uriToString(this.target)}`,
             metadata: new metadata_1.Metadata(),
@@ -105,3 +105,3 @@ };
         if (this.ipResult !== null) {
-            trace('Returning IP address for target ' + this.target);
+            trace('Returning IP address for target ' + uri_parser_1.uriToString(this.target));
             setImmediate(() => {
@@ -116,3 +116,3 @@ this.listener.onSuccessfulResolution(this.ipResult, null, null);
                     code: constants_1.Status.UNAVAILABLE,
-                    details: `Failed to parse DNS address ${this.target}`,
+                    details: `Failed to parse DNS address ${uri_parser_1.uriToString(this.target)}`,
                     metadata: new metadata_1.Metadata(),
@@ -147,3 +147,3 @@ });
                 trace('Resolved addresses for target ' +
-                    this.target +
+                    uri_parser_1.uriToString(this.target) +
                     ': ' +
@@ -162,3 +162,3 @@ allAddressesString);
                 trace('Resolution error for target ' +
-                    this.target +
+                    uri_parser_1.uriToString(this.target) +
                     ': ' +
@@ -209,3 +209,3 @@ err.message);
     updateResolution() {
-        trace('Resolution update requested for target ' + this.target);
+        trace('Resolution update requested for target ' + uri_parser_1.uriToString(this.target));
         if (this.pendingLookupPromise === null) {
@@ -212,0 +212,0 @@ this.startResolution();

build/src/resolving-load-balancer.js

@@ -28,2 +28,3 @@ "use strict";
 const constants_2 = require("./constants");
+const uri_parser_1 = require("./uri-parser");
 const TRACER_NAME = 'resolving_load_balancer';
@@ -286,3 +287,3 @@ function trace(text) {
     updateState(connectivitystate, picker) {
-        trace(this.target +
+        trace(uri_parser_1.uriToString(this.target) +
             ' ' +
@@ -289,0 +290,0 @@ channel_1.ConnectivityState[this.currentState] +

build/src/server-call.d.ts

@@ -14,2 +14,3 @@ /// <reference types="node" />
     cancelled: boolean;
+    readonly metadata: Metadata;
     getPeer(): string;
@@ -16,0 +17,0 @@ sendMetadata(responseMetadata: Metadata): void;

package.json

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

src/call-stream.ts

@@ -230,3 +230,3 @@ /*
       );
-      this.listener!.onReceiveStatus(filteredStatus);
+      this.listener?.onReceiveStatus(filteredStatus);
       if (this.subchannel) {
@@ -253,3 +253,2 @@ this.subchannel.callUnref();
   private endCall(status: StatusObject): void {
-    this.destroyHttp2Stream();
     /* If the status is OK and a new status comes in (e.g. from a
@@ -268,2 +267,3 @@ * deserialization failure), that new status takes priority */
     }
+    this.destroyHttp2Stream();
   }
@@ -295,3 +295,3 @@
     process.nextTick(() => {
-      this.listener!.onReceiveMessage(message);
+      this.listener?.onReceiveMessage(message);
       this.maybeOutputStatus();
@@ -472,5 +472,4 @@ });
             const finalMetadata = this.filterStack.receiveMetadata(metadata);
-            this.listener!.onReceiveMetadata(finalMetadata);
+            this.listener?.onReceiveMetadata(finalMetadata);
           } catch (error) {
-            this.destroyHttp2Stream();
             this.endCall({
@@ -596,3 +595,2 @@ code: Status.UNKNOWN,
     );
-    this.destroyHttp2Stream();
     this.endCall({ code: status, details, metadata: new Metadata() });
@@ -599,0 +597,0 @@ }

src/channel.ts

@@ -409,3 +409,3 @@ /*
       'connectivity_state',
-      this.target +
+      uriToString(this.target) +
         ' ' +
@@ -500,3 +500,3 @@ ConnectivityState[this.connectivityState] +
       'channel',
-      this.target +
+      uriToString(this.target) +
         ' createCall [' +
@@ -503,0 +503,0 @@ callNumber +

src/http_proxy.ts

@@ -139,3 +139,3 @@ /*
     if (host === serverHost) {
-      trace('Not using proxy for target in no_proxy list: ' + target);
+      trace('Not using proxy for target in no_proxy list: ' + uriToString(target));
       return noProxyResult;
@@ -142,0 +142,0 @@ }

src/index.ts

@@ -48,3 +48,3 @@ /*
 } from './make-client';
-import { Metadata } from './metadata';
+import { Metadata, MetadataValue } from './metadata';
 import {
@@ -61,2 +61,3 @@ Server,
   handleUnaryCall,
+  sendUnaryData,
   ServerUnaryCall,
@@ -193,3 +194,3 @@ ServerReadableStream,
 
-export { Metadata };
+export { Metadata, MetadataValue };
 
@@ -234,2 +235,3 @@ /**** Constants ****/
 export {
+  sendUnaryData,
   ChannelCredentials,
@@ -236,0 +238,0 @@ CallCredentials,

src/resolver-dns.ts

@@ -114,3 +114,3 @@ /*
       code: Status.UNAVAILABLE,
-      details: `Name resolution failed for target ${this.target}`,
+      details: `Name resolution failed for target ${uriToString(this.target)}`,
       metadata: new Metadata(),
@@ -126,3 +126,3 @@ };
     if (this.ipResult !== null) {
-      trace('Returning IP address for target ' + this.target);
+      trace('Returning IP address for target ' + uriToString(this.target));
       setImmediate(() => {
@@ -137,3 +137,3 @@ this.listener.onSuccessfulResolution(this.ipResult!, null, null);
           code: Status.UNAVAILABLE,
-          details: `Failed to parse DNS address ${this.target}`,
+          details: `Failed to parse DNS address ${uriToString(this.target)}`,
           metadata: new Metadata(),
@@ -177,3 +177,3 @@ });
             'Resolved addresses for target ' +
-              this.target +
+              uriToString(this.target) +
               ': ' +
@@ -199,3 +199,3 @@ allAddressesString
             'Resolution error for target ' +
-              this.target +
+              uriToString(this.target) +
               ': ' +
@@ -262,3 +262,3 @@ (err as Error).message
   updateResolution() {
-    trace('Resolution update requested for target ' + this.target);
+    trace('Resolution update requested for target ' + uriToString(this.target));
     if (this.pendingLookupPromise === null) {
@@ -265,0 +265,0 @@ this.startResolution();

src/resolving-load-balancer.ts

@@ -38,3 +38,3 @@ /*
 import { SubchannelAddress } from './subchannel';
-import { GrpcUri } from './uri-parser';
+import { GrpcUri, uriToString } from './uri-parser';
 
@@ -357,3 +357,3 @@ const TRACER_NAME = 'resolving_load_balancer';
     trace(
-      this.target +
+      uriToString(this.target) +
         ' ' +
@@ -360,0 +360,0 @@ ConnectivityState[this.currentState] +

src/server-call.ts

@@ -66,2 +66,3 @@ /*
   cancelled: boolean;
+  readonly metadata: Metadata
   getPeer(): string;
@@ -68,0 +69,0 @@ sendMetadata(responseMetadata: Metadata): void;

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

890998

increased by0.09%

Lines of code

18696

increased by0.02%

No dependency changes