feat(nestjs-json-rpc,nestjs-json-rpc-sdk): add ws transport

Add WebSocket transport for backend
Add Websocket transport for sdk,

Author: klerick

apps/json-api-front/proxy.conf.json

@@ -2,5 +2,10 @@
   "/api": {
     "target": "http://localhost:3000",
     "secure": false
+  },
+  "/rpc": {
+    "target": "http://localhost:3000",
+    "secure": false,
+    "ws": true
   }
 }

apps/json-api-front/src/app/app.component.ts

@@ -8,15 +8,11 @@ import {
   Rpc,
 } from '@klerick/nestjs-json-rpc-sdk/json-rpc-sdk.module';
 
+import { RpcService as IRpcService } from '@nestjs-json-api/type-for-rpc';
 import { switchMap } from 'rxjs';
 
-interface TestRpc {
-  test(a: number, b: number): Promise<number>;
-  test2(firstArg: string, secondArg: number): Promise<string>;
-}
-
 type RpcMap = {
-  TestRpc: TestRpc;
+  RpcService: IRpcService;
 };
 
 @Component({
@@ -33,9 +29,15 @@ export class AppComponent implements OnInit {
   private rpcBatch = inject(RPC_BATCH);
 
   ngOnInit(): void {
-    const rpc1 = this.rpc.TestRpc.test(1, 2);
-    const rpc2 = this.rpc.TestRpc.test2('string', 2);
+    const rpc1 = this.rpc.RpcService.someMethode(1);
+
+    const rpc2 = this.rpc.RpcService.methodeWithObjectParams({
+      a: 1,
+      b: 1,
+    });
+
     this.rpcBatch(rpc2, rpc1).subscribe(([r2, r1]) => console.log(r1, r2));
+
     this.JsonApiSdkService.getAll(class Users {}, {
       page: {
         size: 2,
@@ -74,9 +76,9 @@ export class AppComponent implements OnInit {
 
     const tmpUsers = new Users();
     tmpUsers.id = 1;
-    // this.JsonApiSdkService.getRelationships(tmpUsers, 'addresses').subscribe(
-    //   (r) => console.log(r)
-    // );
+    this.JsonApiSdkService.getRelationships(tmpUsers, 'addresses').subscribe(
+      (r) => console.log(r)
+    );
 
     const roles = new Roles();
     roles.id = 10000;

apps/json-api-front/src/app/app.config.ts

@@ -4,6 +4,7 @@ import {
   JsonRpcAngular,
   TransportType,
 } from '@klerick/nestjs-json-rpc-sdk/json-rpc-sdk.module';
+import io from 'socket.io-client';
 
 export const appConfig: ApplicationConfig = {
   providers: [
@@ -17,9 +18,12 @@ export const appConfig: ApplicationConfig = {
     ),
     importProvidersFrom(
       JsonRpcAngular.forRoot({
-        transport: TransportType.HTTP,
+        transport: TransportType.WS,
         rpcPath: 'rpc',
-        rpcHost: 'http://localhost:4200',
+        rpcHost: 'ws://localhost:4200',
+        useWsNativeSocket: true,
+        // useWsNativeSocket: false,
+        // webSocketCtor: io('http://localhost:3000', { path: '/rpc' }),
       })
     ),
   ],

apps/json-api-server-e2e/src/json-api/json-api-sdk/atomic-sdk.spec.ts

@@ -3,7 +3,7 @@ import { FilterOperand, JsonSdkPromise } from 'json-api-nestjs-sdk';
 import { Addresses, CommentKind, Comments, Roles, Users } from 'database';
 import { faker } from '@faker-js/faker';
 import { getUser } from '../utils/data-utils';
-import { run, creatSdk } from '../utils/run-ppplication';
+import { run, creatSdk } from '../utils/run-application';
 
 let app: INestApplication;
 

apps/json-api-server-e2e/src/json-api/json-api-sdk/check-common-decorator.spec.ts

@@ -3,7 +3,7 @@ import { FilterOperand, JsonSdkPromise } from 'json-api-nestjs-sdk';
 import { AxiosError } from 'axios';
 import { Users } from 'database';
 
-import { run, creatSdk } from '../utils/run-ppplication';
+import { run, creatSdk } from '../utils/run-application';
 
 let app: INestApplication;
 

apps/json-api-server-e2e/src/json-api/json-api-sdk/check-othe-call.spec.ts

@@ -4,7 +4,7 @@ import { BookList, Users } from 'database';
 import { AxiosError } from 'axios';
 import { faker } from '@faker-js/faker';
 import { lastValueFrom } from 'rxjs';
-import { creatSdk, run, axiosAdapter } from '../utils/run-ppplication';
+import { creatSdk, run, axiosAdapter } from '../utils/run-application';
 
 let app: INestApplication;
 

apps/json-api-server-e2e/src/json-api/json-api-sdk/get-method.spec.ts

@@ -4,7 +4,7 @@ import { faker } from '@faker-js/faker';
 
 import { FilterOperand, JsonSdkPromise } from 'json-api-nestjs-sdk';
 import { getUser } from '../utils/data-utils';
-import { creatSdk, run } from '../utils/run-ppplication';
+import { creatSdk, run } from '../utils/run-application';
 
 let app: INestApplication;
 

apps/json-api-server-e2e/src/json-api/json-api-sdk/patch-methode.spec.ts

@@ -3,7 +3,7 @@ import { Addresses, CommentKind, Comments, Users } from 'database';
 import { faker } from '@faker-js/faker';
 import { JsonSdkPromise } from 'json-api-nestjs-sdk';
 
-import { creatSdk, run } from '../utils/run-ppplication';
+import { creatSdk, run } from '../utils/run-application';
 
 let app: INestApplication;
 

apps/json-api-server-e2e/src/json-api/json-api-sdk/post-method.spec.ts

@@ -2,7 +2,7 @@ import { Addresses, BookList, CommentKind, Comments, Users } from 'database';
 import { faker } from '@faker-js/faker';
 import { JsonSdkPromise } from 'json-api-nestjs-sdk';
 
-import { creatSdk, run } from '../utils/run-ppplication';
+import { creatSdk, run } from '../utils/run-application';
 import { INestApplication } from '@nestjs/common';
 let app: INestApplication;
 

apps/json-api-server-e2e/src/json-api/json-rpc/run-json-rpc.spec.ts

@@ -5,7 +5,7 @@ import {
   RpcError,
 } from '@klerick/nestjs-json-rpc-sdk';
 
-import { creatRpcSdk, MapperRpc, run } from '../utils/run-ppplication';
+import { creatRpcSdk, MapperRpc, run } from '../utils/run-application';
 
 let app: INestApplication;