- return error response in JsonRpcClient

Author: goce-h4

src/client-proxy.ts

@@ -1,5 +1,6 @@
 import { ClientProxy } from "@nestjs/microservices";
 import axios from "axios";
+import { resolve } from "dns";
 
 export class JSONRPCClient extends ClientProxy {
   constructor(private readonly url: string) {
@@ -30,13 +31,15 @@ export class JSONRPCClient extends ClientProxy {
       {
         get(obj, prop) {
           return function(params: any) {
-            // console.log(url);
-            // console.log(namespace);
-            // console.log(prop.toString());
-            // console.log(params);
             return axios
               .post(url, { method: namespace + "." + prop.toString(), params, jsonrpc: "2.0" })
-              .then(res => Promise.resolve(res));
+              .then(res => Promise.resolve(res))
+              .catch(err => {
+                const { code, message, data } = err.response.data;
+                let resp = { code, message, data };
+
+                return Promise.resolve(resp);
+              });
           };
         }
       }

src/index.spec.ts

@@ -61,6 +61,23 @@ describe("json-rpc-e2e", () => {
       .then(res => expect(res.data).toStrictEqual({ data: "hi" }));
   });
 
+  it(`should return an error from JSONRPCClient call`, () => {
+    console.log("Testing RPC CLient");
+    const client = new JSONRPCClient("http://localhost:8080/rpc/v1");
+    const service = client.getService<TestService>("test");
+
+    const errorObj = {
+      message: "RPC EXCEPTION",
+      code: 403,
+      data: {
+        fromService: "Test Service",
+        params: { data: "hi" }
+      }
+    };
+
+    return service.testError({ data: "hi" }).then(res => expect(res).toStrictEqual(errorObj));
+  });
+
   afterAll(async () => {
     await app.close();
   });

src/index.ts

@@ -60,7 +60,6 @@ export class JSONRPCServer extends Server implements CustomTransportStrategy {
 
     app.post(this.options.path, express.json(), async (req, res) => {
       // let handlers = this.getHandlers();
-      console.log(req.body);
 
       let handler = this.getHandlerByPattern(req.body.method);
       console.log(handler);

src/test-handler.ts

@@ -97,4 +97,5 @@ export class TestService implements ITestClientService {
 
 export interface ITestClientService {
   invokeClientService(params: any): any;
+  testError(params: any): any;
 }