@dxos/codec-protobuf - npm Package Compare versions

Comparing version 2.19.6 to 2.19.7-dev.3672cc37

dist/src/service.d.ts

 import pb from 'protobufjs';
 import type { Schema } from './schema';
 import { Stream } from './stream';
+export interface Any {
+    'type_url'?: string;
+    value?: Uint8Array;
+}
 export interface ServiceBackend {
-    call(method: string, request: Uint8Array): Promise<Uint8Array>;
-    callStream(method: string, request: Uint8Array): Stream<Uint8Array>;
+    call(method: string, request: Any): Promise<Any>;
+    callStream(method: string, request: Any): Stream<Any>;
 }
@@ -12,2 +16,3 @@ export declare class ServiceDescriptor<S> {
     constructor(_service: pb.Service, _schema: Schema<any>);
+    get serviceProto(): pb.Service;
     createClient(backend: ServiceBackend): Service & S;
@@ -24,6 +29,6 @@ createServer(handlers: S): ServiceHandler<S>;
     constructor(_service: pb.Service, _schema: Schema<any>, _handlers: S);
-    call(methodName: string, request: Uint8Array): Promise<Uint8Array>;
-    callStream(methodName: string, request: Uint8Array): Stream<Uint8Array>;
+    call(methodName: string, request: Any): Promise<Any>;
+    callStream(methodName: string, request: Any): Stream<Any>;
     private _getMethodInfo;
 }
 //# sourceMappingURL=service.d.ts.map

dist/src/service.js

@@ -17,2 +17,5 @@ "use strict";
     }
+    get serviceProto() {
+        return this._service;
+    }
     createClient(backend) {
@@ -39,4 +42,7 @@ return new Service(backend, this._service, this._schema);
                     const encoded = requestCodec.encode(request);
-                    const response = await backend.call(method.name, encoded);
-                    return responseCodec.decode(response);
+                    const response = await backend.call(method.name, {
+                        value: encoded,
+                        type_url: method.resolvedRequestType.fullName
+                    });
+                    return responseCodec.decode(response.value);
                 };
@@ -48,4 +54,7 @@ }
                     return new stream_1.Stream(({ next, close }) => {
-                        const stream = backend.callStream(method.name, encoded);
-                        stream.subscribe(data => next(responseCodec.decode(data)), close);
+                        const stream = backend.callStream(method.name, {
+                            value: encoded,
+                            type_url: method.resolvedRequestType.fullName
+                        });
+                        stream.subscribe(data => next(responseCodec.decode(data.value)), close);
                         return () => stream.close();
@@ -69,3 +78,3 @@ });
         (0, assert_1.default)(!method.responseStream, 'Invalid RPC method call: response streaming mismatch.');
-        const requestDecoded = requestCodec.decode(request);
+        const requestDecoded = requestCodec.decode(request.value);
         const handler = this._handlers[methodName];
@@ -75,3 +84,6 @@ (0, assert_1.default)(handler, `Handler is missing: ${methodName}`);
         const responseEncoded = responseCodec.encode(response);
-        return responseEncoded;
+        return {
+            value: responseEncoded,
+            type_url: method.resolvedResponseType.fullName
+        };
     }
@@ -82,3 +94,3 @@ callStream(methodName, request) {
         (0, assert_1.default)(method.responseStream, 'Invalid RPC method call: response streaming mismatch.');
-        const requestDecoded = requestCodec.decode(request);
+        const requestDecoded = requestCodec.decode(request.value);
         const handler = this._handlers[methodName];
@@ -88,3 +100,6 @@ (0, assert_1.default)(handler, `Handler is missing: ${methodName}`);
         return new stream_1.Stream(({ next, close }) => {
-            responseStream.subscribe(data => next(responseCodec.encode(data)), close);
+            responseStream.subscribe(data => next({
+                value: responseCodec.encode(data),
+                type_url: method.resolvedResponseType.fullName
+            }), close);
             return () => responseStream.close();
@@ -91,0 +106,0 @@ });

package.json

 {
   "name": "@dxos/codec-protobuf",
-  "version": "2.19.6",
+  "version": "2.19.7-dev.3672cc37",
   "license": "AGPL-3.0",
@@ -5,0 +5,0 @@ "author": "DXOS.org",

src/service.ts

@@ -11,5 +11,10 @@ //
 
+export interface Any {
+  'type_url'?: string;
+  value?: Uint8Array;
+}
+
 export interface ServiceBackend {
-  call (method: string, request: Uint8Array): Promise<Uint8Array>;
-  callStream (method: string, request: Uint8Array): Stream<Uint8Array>;
+  call (method: string, request: Any): Promise<Any>;
+  callStream (method: string, request: Any): Stream<Any>;
 }
@@ -23,2 +28,6 @@
 
+  get serviceProto (): pb.Service {
+    return this._service;
+  }
+
   createClient (backend: ServiceBackend): Service & S {
@@ -52,4 +61,7 @@ return new Service(backend, this._service, this._schema) as Service & S;
           const encoded = requestCodec.encode(request);
-          const response = await backend.call(method.name, encoded);
-          return responseCodec.decode(response);
+          const response = await backend.call(method.name, {
+            value: encoded,
+            type_url: method.resolvedRequestType!.fullName
+          });
+          return responseCodec.decode(response.value!);
         };
@@ -60,4 +72,7 @@ } else {
           return new Stream(({ next, close }) => {
-            const stream = backend.callStream(method.name, encoded);
-            stream.subscribe(data => next(responseCodec.decode(data)), close);
+            const stream = backend.callStream(method.name, {
+              value: encoded,
+              type_url: method.resolvedRequestType!.fullName
+            });
+            stream.subscribe(data => next(responseCodec.decode(data.value!)), close);
 
@@ -79,3 +94,3 @@ return () => stream.close();
 
-  async call (methodName: string, request: Uint8Array): Promise<Uint8Array> {
+  async call (methodName: string, request: Any): Promise<Any> {
     const { method, requestCodec, responseCodec } = this._getMethodInfo(methodName);
@@ -85,3 +100,3 @@ assert(!method.requestStream, 'Invalid RPC method call: request streaming mismatch.');
 
-    const requestDecoded = requestCodec.decode(request);
+    const requestDecoded = requestCodec.decode(request.value!);
 
@@ -95,6 +110,9 @@ const handler = this._handlers[methodName as keyof S];
 
-    return responseEncoded;
+    return {
+      value: responseEncoded,
+      type_url: method.resolvedResponseType!.fullName
+    };
   }
 
-  callStream (methodName: string, request: Uint8Array): Stream<Uint8Array> {
+  callStream (methodName: string, request: Any): Stream<Any> {
     const { method, requestCodec, responseCodec } = this._getMethodInfo(methodName);
@@ -104,3 +122,3 @@ assert(!method.requestStream, 'Invalid RPC method call: request streaming mismatch.');
 
-    const requestDecoded = requestCodec.decode(request);
+    const requestDecoded = requestCodec.decode(request.value!);
 
@@ -111,4 +129,7 @@ const handler = this._handlers[methodName as keyof S];
     const responseStream = (handler as any).bind(this._handlers)(requestDecoded) as Stream<unknown>;
-    return new Stream<Uint8Array>(({ next, close }) => {
-      responseStream.subscribe(data => next(responseCodec.encode(data)), close);
+    return new Stream<Any>(({ next, close }) => {
+      responseStream.subscribe(data => next({
+        value: responseCodec.encode(data),
+        type_url: method.resolvedResponseType!.fullName
+      }), close);
       return () => responseStream.close();
@@ -115,0 +136,0 @@ });

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

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

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

100211

increased by1.57%

Lines of code

1318

increased by3.05%

Worsened metrics

Number of low quality alerts

2

increased by100%

No dependency changes