grpc-server-js - npm Package Compare versions

Comparing version 0.3.2 to 0.4.0

lib/handler.js

@@ -151,3 +151,13 @@ 'use strict';
 function getPeer () {
-  throw new Error('not implemented');
+  const { socket } = this.call.session;
+
+  if (!(socket && socket.remoteAddress)) {
+    return 'unknown';
+  }
+
+  if (socket.remotePort) {
+    return `${socket.remoteAddress}:${socket.remotePort}`;
+  }
+
+  return socket.remoteAddress;
 }
@@ -154,0 +164,0 @@

lib/index.d.ts

@@ -126,5 +126,8 @@ /// <reference types="node" />
 export declare type ServerWritableStream<RequestType, ResponseType> =
-    ServerSurfaceCall & Writable & { request: RequestType | null; };
+    ServerSurfaceCall & Writable & {
+      request: RequestType | null;
+      end: (metadata?: Metadata) => void;
+    };
 export declare type ServerDuplexStream<RequestType, ResponseType> =
-    ServerSurfaceCall & Duplex;
+    ServerSurfaceCall & Duplex & { end: (metadata?: Metadata) => void; };
 
@@ -131,0 +134,0 @@

lib/server.js

@@ -248,5 +248,7 @@ 'use strict';
     // If any sessions are active, close them gracefully.
-    pendingChecks += this[kSessions].size;
     this[kSessions].forEach((session) => {
-      session.close(maybeCallback);
+      if (!session.closed) {
+        session.close(maybeCallback);
+        pendingChecks++;
+      }
     });
@@ -253,0 +255,0 @@

package.json

 {
   "name": "grpc-server-js",
-  "version": "0.3.2",
+  "version": "0.4.0",
   "description": "Pure JavaScript gRPC Server",
@@ -30,3 +30,3 @@ "author": "Colin J. Ihrig <[e-mail]> (http://www.cjihrig.com/)",
     "cb-barrier": "1.x.x",
-    "@hapi/lab": "22.x.x"
+    "@hapi/lab": "23.x.x"
   },
@@ -33,0 +33,0 @@ "keywords": [

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

58921

increased by0.53%

Lines of code

1650

increased by0.73%

No dependency changes