Fix websocket client disconnect implementation

Author: Fabrice Bascoulergue

.eslintrc.json

@@ -29,6 +29,7 @@
             "parser": "@typescript-eslint/parser",
             "extends": ["plugin:@typescript-eslint/recommended"],
             "rules": {
+                "@typescript-eslint/ban-ts-comment": "off",
                 "@typescript-eslint/no-non-null-assertion": "off",
                 "@typescript-eslint/no-use-before-define": "off",
                 "@typescript-eslint/no-warning-comments": "off",

src/client/LumClient.ts

@@ -68,6 +68,21 @@ export class LumClient {
      * Disconnect the underlying tendermint client
      */
     disconnect() {
+        // Temporary fix missing stop calls from the cosmjs socket implementation
+        // @ts-ignore
+        this.tmClient.client && this.tmClient.client.socket && this.tmClient.client.events && this.tmClient.client.socket.events._stopNow();
+        // @ts-ignore
+        this.tmClient.client &&
+            // @ts-ignore
+            this.tmClient.client.socket &&
+            // @ts-ignore
+            this.tmClient.client.socket.connectionStatus &&
+            // @ts-ignore
+            this.tmClient.client.socket.connectionStatus.updates &&
+            // @ts-ignore
+            this.tmClient.client.socket.connectionStatus.updates._stopNow();
+
+        // Disconnect the client
         this.tmClient.disconnect();
     }
 

tests/client.test.ts

@@ -1,6 +1,6 @@
 import { LumWallet, LumWalletFactory, LumClient, LumUtils, LumConstants, LumRegistry, LumTypes, LumMessages } from '../src';
 import axios from 'axios';
-import { BeamData, BeamState } from "../src/codec/chain/beam/beam";
+import { BeamData, BeamState } from '../src/codec/chain/beam/beam';
 
 const randomString = (): string => {
     return Math.random().toString(36).substring(7);
@@ -12,7 +12,7 @@ describe('LumClient', () => {
     let w2: LumWallet;
 
     beforeAll(async () => {
-        clt = await LumClient.connect('http://node0.testnet.lum.network/rpc');
+        clt = await LumClient.connect('https://node0.testnet.lum.network/rpc');
 
         // Prepare the wallets
         w1 = await LumWalletFactory.fromMnemonic(LumUtils.generateMnemonic());
@@ -47,6 +47,12 @@ describe('LumClient', () => {
         await expect(clt.disconnect()).resolves.toBeTruthy();
     });
 
+    it('should allow to connect via webshockets', async () => {
+        const wsClt = await LumClient.connect('wss://node0.testnet.lum.network/rpc');
+        expect(await wsClt.status()).toBeTruthy();
+        wsClt.disconnect();
+    });
+
     it('should open a beam and close it', async () => {
         const beamId = randomString();
 
@@ -251,7 +257,7 @@ describe('LumClient', () => {
                     url: 'https://test.com',
                     signature: 'test',
                 },
-            })
+            }),
         );
 
         const fee = {