From 077db217f31004dda7240a37c8c7deecc9e13de7 Mon Sep 17 00:00:00 2001
From: Liran Cohen <c.liran.c@gmail.com>
Date: Tue, 27 Feb 2024 15:52:12 -0500
Subject: [PATCH] remove unecessary JsonRpcParams = any export

---
 src/json-rpc-socket.ts        | 2 +-
 src/lib/json-rpc.ts           | 9 ++++-----
 tests/json-rpc-socket.spec.ts | 4 +++-
 3 files changed, 8 insertions(+), 7 deletions(-)

diff --git a/src/json-rpc-socket.ts b/src/json-rpc-socket.ts
index 0ee4a30..3b3cc7b 100644
--- a/src/json-rpc-socket.ts
+++ b/src/json-rpc-socket.ts
@@ -29,7 +29,7 @@ export class JsonRpcSocket {
   static async connect(url: string, options: JsonRpcSocketOptions = {}): Promise<JsonRpcSocket> {
     const { connectTimeout = CONNECT_TIMEOUT, responseTimeout = RESPONSE_TIMEOUT, onclose, onerror } = options;
 
-    const socket = new WebSocket(url);
+    const socket = new WebSocket(url, { timeout: connectTimeout });
 
     socket.onclose = onclose;
     socket.onerror = onerror;
diff --git a/src/lib/json-rpc.ts b/src/lib/json-rpc.ts
index 8b3550e..d54a9cf 100644
--- a/src/lib/json-rpc.ts
+++ b/src/lib/json-rpc.ts
@@ -1,12 +1,11 @@
 export type JsonRpcId = string | number | null;
-export type JsonRpcParams = any;
 export type JsonRpcVersion = '2.0';
 
 export interface JsonRpcRequest {
   jsonrpc: JsonRpcVersion;
   id?: JsonRpcId;
   method: string;
-  params?: JsonRpcParams;
+  params?: any;
   /** JSON RPC Subscription Extension Parameters */
   subscription?: {
     id: JsonRpcId
@@ -76,7 +75,7 @@ export const createJsonRpcErrorResponse = (
 
 export const createJsonRpcNotification = (
   method: string,
-  params?: JsonRpcParams,
+  params?: any,
 ): JsonRpcRequest => {
   return {
     jsonrpc: '2.0',
@@ -88,7 +87,7 @@ export const createJsonRpcNotification = (
 export const createJsonRpcSubscriptionRequest = (
   id: JsonRpcId,
   method: string,
-  params?: JsonRpcParams,
+  params?: any,
   subscriptionId?: JsonRpcId
 ): JsonRpcRequest => {
   return {
@@ -105,7 +104,7 @@ export const createJsonRpcSubscriptionRequest = (
 export const createJsonRpcRequest = (
   id: JsonRpcId,
   method: string,
-  params?: JsonRpcParams,
+  params?: any,
 ): JsonRpcRequest => {
   return {
     jsonrpc: '2.0',
diff --git a/tests/json-rpc-socket.spec.ts b/tests/json-rpc-socket.spec.ts
index d773dca..6822717 100644
--- a/tests/json-rpc-socket.spec.ts
+++ b/tests/json-rpc-socket.spec.ts
@@ -234,7 +234,9 @@ describe('JsonRpcSocket', () => {
     const onErrorHandler = { onerror: ():void => {} };
     const onErrorSpy = sinon.spy(onErrorHandler, 'onerror');
 
-    await JsonRpcSocket.connect('ws://127.0.0.1:9003', { onerror: onErrorHandler.onerror });
+    await JsonRpcSocket.connect('ws://127.0.0.1:9003', { onerror: onErrorHandler.onerror, connectTimeout: 1 });
+    // const serverSocket = [...wsServer.clients][0];
+    // serverSocket.emit('error', { type: 'error', target: null, message: 'unknown error' });
 
     await new Promise((resolve) => setTimeout(resolve, 5)); // wait for close event to arrive
     expect(onErrorSpy.callCount).to.equal(1, 'error');