Merge pull request #41 from cosmos-client/ws

feat: ws
cosmos-client · Jul 29, 2021 · e5ca1f2 · e5ca1f2
2 parents 323815f + 7b729e8
commit e5ca1f2
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 10 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "cosmos-client",
   "description": "REST API Client for Cosmos SDK Blockchain",
-  "version": "0.42.12",
+  "version": "0.42.13",
   "author": "LCNEM, Inc.",
   "bugs": {
     "url": "https://github.com/cosmos-client/cosmos-client-ts/issues"

diff --git a/src/websocket/module.ts b/src/websocket/module.ts
@@ -1,5 +1,4 @@
 import { WebSocketSubject } from 'rxjs/webSocket';
-import { CosmosSDK } from '../sdk';
 
 type BaseSchema = {
   id: '1';
@@ -11,11 +10,11 @@ export type RequestSchema = BaseSchema & {
   params: string[];
 };
 
-export type ResponseSchema = BaseSchema & ({ result: any } | { error: string });
+export type ResponseSchema = BaseSchema & { result?: any; error?: string };
 
-export function connect(sdk: CosmosSDK) {
+export function connect(url: string) {
   const ws = new WebSocketSubject<RequestSchema | ResponseSchema>({
-    url: `${sdk.url}/websocket`,
+    url: `${url}/websocket`,
   });
 
   return ws;

diff --git a/src/websocket/websocket.spec.ts b/src/websocket/websocket.spec.ts
@@ -1,4 +1,4 @@
-import { cosmosclient, websocket } from '..';
+import { websocket } from '..';
 
 function sleep(sec: number) {
   return new Promise((resolve, _) => {
@@ -11,8 +11,7 @@ function sleep(sec: number) {
 describe('websocket', () => {
   it('websocker', async () => {
     expect.hasAssertions();
-    const sdk = new cosmosclient.CosmosSDK('ws://localhost:26657', 'testchain');
-    const ws = websocket.connect(sdk);
+    const ws = websocket.connect('ws://localhost:26657');
 
     ws.next({
       id: '1',