@any2api/grpc-connector - npm Package Compare versions

Comparing version 0.0.1 to 0.0.3

dist/grpc-connector.d.ts

@@ -13,2 +13,3 @@ import { Observable } from '@reactivex/rxjs';
     private bidirectionalStreaming;
+    private prepareParameters(params);
 }

dist/grpc-connector.js

@@ -16,6 +16,3 @@ "use strict";
                     .subscribe((request) => {
-                    // workaround for argue js type checking
-                    if (params.metadata) {
-                        Object.setPrototypeOf(params.metadata, Object.getPrototypeOf(new grpc.Metadata()));
-                    }
+                    this.prepareParameters(params);
                     const upstreamCall = this.client.makeUnaryRequest(`/${params.method.namespace}/${params.method.name}`, (accessor) => accessor.getBinary(), (buffer) => new gateframe_common_1.LazyMessageAccesor(params.responseType, buffer), request, params.metadata, params.callOptions, (e, response) => {
@@ -44,6 +41,3 @@ if (!downstreamCall) {
             return rxjs_1.Observable.create((observer) => {
-                // workaround for argue js type checking
-                if (params.metadata) {
-                    Object.setPrototypeOf(params.metadata, Object.getPrototypeOf(new grpc.Metadata()));
-                }
+                this.prepareParameters(params);
                 let downstreamCall;
@@ -75,2 +69,3 @@ const upstreamCall = this.client.makeClientStreamRequest(`/${params.method.namespace}/${params.method.name}`, (accessor) => accessor.getBinary(), (buffer) => new gateframe_common_1.LazyMessageAccesor(params.responseType, buffer), params.metadata, params.callOptions, (e, response) => {
             return rxjs_1.Observable.create((observer) => {
+                this.prepareParameters(params);
                 let downstreamCall;
@@ -80,6 +75,2 @@ params.requestObservable
                     .subscribe((request) => {
-                    // workaround for argue js type checking
-                    if (params.metadata) {
-                        Object.setPrototypeOf(params.metadata, Object.getPrototypeOf(new grpc.Metadata()));
-                    }
                     const upstreamCall = this.client.makeServerStreamRequest(`/${params.method.namespace}/${params.method.name}`, (accessor) => accessor.getBinary(), (buffer) => new gateframe_common_1.LazyMessageAccesor(params.responseType, buffer), request, params.metadata, params.callOptions);
@@ -117,6 +108,2 @@ upstreamCall.on('metadata', (m) => {
             return rxjs_1.Observable.create((observer) => {
-                // workaround for argue js type checking
-                if (params.metadata) {
-                    Object.setPrototypeOf(params.metadata, Object.getPrototypeOf(new grpc.Metadata()));
-                }
                 let downstreamCall;
@@ -169,3 +156,16 @@ const upstreamCall = this.client.makeBidiStreamRequest(`/${params.method.namespace}/${params.method.name}`, (accessor) => accessor.getBinary(), (buffer) => new gateframe_common_1.LazyMessageAccesor(params.responseType, buffer), params.metadata, params.callOptions);
     }
+    // enshure liberal acceptance of parameters
+    prepareParameters(params) {
+        if (params.metadata) {
+            // workaround for argue js type checking
+            Object.setPrototypeOf(params.metadata, Object.getPrototypeOf(new grpc.Metadata()));
+        }
+        else {
+            params.metadata = new grpc.Metadata();
+        }
+        if (!params.callOptions) {
+            params.callOptions = {}; // object is required, values do not need to be set
+        }
+    }
 }
 exports.GrpcConnector = GrpcConnector;

package.json

 {
   "name": "@any2api/grpc-connector",
-  "version": "0.0.1",
+  "version": "0.0.3",
   "description": "default grpc-connector for the any2api gateframe",
@@ -11,3 +11,3 @@ "main": "./dist/index.js",
     "build": "tsc -p ./lib/tsconfig.lib.json --outDir dist/",
-    "prepublishOnly": "npm run build"
+    "prepublishOnly": "npm run test && npm run build"
   },
@@ -14,0 +14,0 @@ "keywords": [

No alert changes

Improved metrics

Lines of code

268

increased by0.37%

Worsened metrics

Total package byte prevSize

15340

decreased by-1.38%

No dependency changes