- working test for JSON RPC Client

Author: goce-h4

src/client-proxy.ts

@@ -30,7 +30,11 @@ export class JSONRPCClient extends ClientProxy {
       {
         get(obj, prop) {
           return function(params: any) {
-            axios
+            // 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));
           };

src/index.spec.ts

@@ -3,7 +3,7 @@ import * as request from "supertest";
 import { Test } from "@nestjs/testing";
 import { INestMicroservice, ServiceUnavailableException } from "@nestjs/common";
 
-import { TestService, TestClientService } from "./test-handler";
+import { TestService } from "./test-handler";
 import { JSONRPCServer } from ".";
 import { JSONRPCClient } from "./client-proxy";
 
@@ -54,9 +54,11 @@ describe("json-rpc-e2e", () => {
   it(`should make and RPC call with the JSONRPCClient`, () => {
     console.log("Testing RPC CLient");
     const client = new JSONRPCClient("http://localhost:8080/rpc/v1");
-    const service = client.getService<TestClientService>("test.service");
+    const service = client.getService<TestService>("test");
 
-    return service.invokeService({ data: "hi" }).then(res => expect(res.data).toBe("hi"));
+    return service
+      .invokeClientService({ data: "hi" })
+      .then(res => expect(res.data).toStrictEqual({ data: "hi" }));
   });
 
   afterAll(async () => {

src/index.ts

@@ -56,13 +56,14 @@ export class JSONRPCServer extends Server implements CustomTransportStrategy {
   }
 
   public async listen(callback: () => void) {
-    console.log("Server listening on 8080");
     let app = express();
 
     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);
       if (handler == null) {
         return res.status(404).json({ error: "Not Found" });
       }
@@ -96,7 +97,6 @@ export class JSONRPCServer extends Server implements CustomTransportStrategy {
   }
 
   public async close() {
-    console.log("Closing server");
     await invokeAsync(cb => this.server && this.server.close(cb));
     // do nothing, maybe block further requests
   }

src/test-handler.ts

@@ -64,7 +64,7 @@ class TestGuard implements CanActivate {
 @JSONRpcService({
   namespace: "test"
 })
-export class TestService {
+export class TestService implements ITestClientService {
   constructor() {
     DecorationsState.serviceConstructorCount = DecorationsState.serviceConstructorCount + 1;
     console.log("TestService count now at", DecorationsState.serviceConstructorCount);
@@ -85,26 +85,16 @@ export class TestService {
     // construct the error object with some data inside
     throw new CodedRpcException("RPC EXCEPTION", 403, { fromService: "Test Service", params });
   }
-}
-
-@JSONRpcService({
-  namespace: "test.service"
-})
-export class TestClientService implements ITestClientService {
-  constructor() {
-    DecorationsState.serviceConstructorCount = DecorationsState.serviceConstructorCount + 1;
-    console.log("TestService count now at", DecorationsState.serviceConstructorCount);
-  }
 
   @UsePipes(TestPipe)
   @UseInterceptors(TestInterceptor)
   @UseGuards(TestGuard)
-  public async invokeService(params: any) {
+  public async invokeClientService(params: any) {
     console.log("Invoke Client Service WAS called");
     return params;
   }
 }
 
 export interface ITestClientService {
-  invokeService(params: any): any;
+  invokeClientService(params: any): any;
 }