Bugfix Websocket hostname. (#21)

* Add yarn-error.log to gitignore. * Add ts-node to devDependencies. Add script to only build tsc. Add websocket to keywords. * Update yarn.lock libs. * FIX websocket endpoint hostname. FIX corrent import for all examples. FIX websocket instrucions on readme.
mempool · May 20, 2021 · e3068c2 · e3068c2
1 parent 0aa3757
commit e3068c2
Show file tree

Hide file tree

Showing 28 changed files with 242 additions and 175 deletions.
diff --git a/.gitignore b/.gitignore
@@ -1,4 +1,6 @@
 /node_modules
 /lib
 /dist/*
-!.gitkeep
+!.gitkeep
+
+yarn-error.log
diff --git a/README-bitcoin.md b/README-bitcoin.md
@@ -630,60 +630,69 @@ Default push: `{ action: 'want', data: ['blocks', ...] }` to express what you wa
 
 Push transactions related to address: `{ 'track-address': '3PbJ...bF9B' }` to receive all new transactions containing that address as input or output. Returns an array of transactions. address-transactions for new mempool transactions, and block-transactions for new block confirmed transactions.
 
-[ [NodeJS Example](examples/nodejs/bitcoin/addresses.ts) ] [ [HTML Example](examples/html/bitcoin/addresses.html) ] [ [Top](#features) ]
+[ [NodeJS Example](examples/nodejs/bitcoin/websocket.ts) ] [ [HTML Example](examples/html/bitcoin/websocket.html) ] [ [Top](#features) ]
 
 #### **Websocket Server**
 
-```js
-const {
-  bitcoin: { websocket },
-} = mempoolJS();
-
-const ws = websocket.initServer({
-  options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
-});
+Only use on server side apps.
 
-ws.on('message', function incoming(data) {
-  const res = JSON.parse(data.toString());
-  if (res.blocks) {
-    console.log(res.blocks);
-  }
-  if (res.mempoolInfo) {
-    console.log(res.mempoolInfo);
-  }
-  if (res.transactions) {
-    console.log(res.transactions);
-  }
-  if (res.mempoolBlocks) {
-    console.log(res.mempoolBlocks);
-  }
-});
+```js
+const { bitcoin: { websocket } } = mempoolJS();
+
+const init = async () => {
+
+  const ws = websocket.initServer({
+    options: ["blocks", "stats", "mempool-blocks", "live-2h-chart"],
+  });
+
+  ws.on("message", function incoming(data) {
+    const res = JSON.parse(data.toString());
+    if (res.blocks) {
+      console.log(res.blocks);
+    }
+    if (res.mempoolInfo) {
+      console.log(res.mempoolInfo);
+    }
+    if (res.transactions) {
+      console.log(res.transactions);
+    }
+    if (res.mempoolBlocks) {
+      console.log(res.mempoolBlocks);
+    }
+  });
+}
+init();
 ```
 
 #### **Websocket Client**
 
-```js
-const {
-  bitcoin: { websocket },
-} = mempoolJS();
+Only use on browser apps.
 
-const ws = websocket.initClient({
-  options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
-});
-
-ws.on('message', function incoming(data) {
-  const res = JSON.parse(data.toString());
-  if (res.blocks) {
-    console.log(res.blocks);
-  }
-  if (res.mempoolInfo) {
-    console.log(res.mempoolInfo);
-  }
-  if (res.transactions) {
-    console.log(res.transactions);
-  }
-  if (res.mempoolBlocks) {
-    console.log(res.mempoolBlocks);
-  }
-});
+```js
+const init = async () => {
+  const {
+    bitcoin: { websocket },
+  } = mempoolJS();
+
+  const ws = websocket.initClient({
+    options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
+  });
+
+  ws.addEventListener('message', function incoming({data}) {
+    const res = JSON.parse(data.toString());
+    if (res.blocks) {
+      console.log(res.blocks);
+    }
+    if (res.mempoolInfo) {
+      console.log(res.mempoolInfo);
+    }
+    if (res.transactions) {
+      console.log(res.transactions);
+    }
+    if (res.mempoolBlocks) {
+      console.log(res.mempoolBlocks);
+    }
+  });
+};
+init();
 ```
diff --git a/README-liquid.md b/README-liquid.md
@@ -698,60 +698,69 @@ Default push: `{ action: 'want', data: ['blocks', ...] }` to express what you wa
 
 Push transactions related to address: `{ 'track-address': '3PbJ...bF9B' }` to receive all new transactions containing that address as input or output. Returns an array of transactions. address-transactions for new mempool transactions, and block-transactions for new block confirmed transactions.
 
-[ [NodeJS Example](examples/nodejs/liquid/addresses.ts) ] [ [HTML Example](examples/html/liquid/addresses.html) ] [ [Top](#features) ]
+[ [NodeJS Example](examples/nodejs/liquid/websocket.ts) ] [ [HTML Example](examples/html/liquid/websocket.html) ] [ [Top](#features) ]
 
 #### **Websocket Server**
 
-```js
-const {
-  liquid: { websocket },
-} = mempoolJS();
-
-const ws = websocket.initServer({
-  options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
-});
-
-ws.on('message', function incoming(data) {
-  const res = JSON.parse(data.toString());
-  if (res.blocks) {
-    console.log(res.blocks);
-  }
-  if (res.mempoolInfo) {
-    console.log(res.mempoolInfo);
-  }
-  if (res.transactions) {
-    console.log(res.transactions);
-  }
-  if (res.mempoolBlocks) {
-    console.log(res.mempoolBlocks);
-  }
-});
+Only use on server side apps.
+
+```js
+const { liquid: { websocket } } = mempoolJS();
+
+const init = async () => {
+
+  const ws = websocket.initServer({
+    options: ["blocks", "stats", "mempool-blocks", "live-2h-chart"],
+  });
+
+  ws.on("message", function incoming(data) {
+    const res = JSON.parse(data.toString());
+    if (res.blocks) {
+      console.log(res.blocks);
+    }
+    if (res.mempoolInfo) {
+      console.log(res.mempoolInfo);
+    }
+    if (res.transactions) {
+      console.log(res.transactions);
+    }
+    if (res.mempoolBlocks) {
+      console.log(res.mempoolBlocks);
+    }
+  });
+}
+init();
 ```
 
 #### **Websocket Client**
 
-```js
-const {
-  liquid: { websocket },
-} = mempoolJS();
-
-const ws = websocket.initClient({
-  options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
-});
-
-ws.on('message', function incoming(data) {
-  const res = JSON.parse(data.toString());
-  if (res.blocks) {
-    console.log(res.blocks);
-  }
-  if (res.mempoolInfo) {
-    console.log(res.mempoolInfo);
-  }
-  if (res.transactions) {
-    console.log(res.transactions);
-  }
-  if (res.mempoolBlocks) {
-    console.log(res.mempoolBlocks);
-  }
-});
-```
+Only use on browser apps.
+
+```js
+const init = async () => {
+  const {
+    liquid: { websocket },
+  } = mempoolJS();
+
+  const ws = websocket.initClient({
+    options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
+  });
+
+  ws.addEventListener('message', function incoming({data}) {
+    const res = JSON.parse(data.toString());
+    if (res.blocks) {
+      console.log(res.blocks);
+    }
+    if (res.mempoolInfo) {
+      console.log(res.mempoolInfo);
+    }
+    if (res.transactions) {
+      console.log(res.transactions);
+    }
+    if (res.mempoolBlocks) {
+      console.log(res.mempoolBlocks);
+    }
+  });
+};
+init();
+```
diff --git a/examples/html/bitcoin/websocket.html b/examples/html/bitcoin/websocket.html
@@ -8,12 +8,12 @@
         const {
           bitcoin: { websocket },
         } = mempoolJS();
-        // console.log(mempoolJS());
+
         const ws = websocket.initClient({
           options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
         });
 
-        ws.on('message', function incoming(data) {
+        ws.addEventListener('message', function incoming({data}) {
           const res = JSON.parse(data.toString());
           if (res.blocks) {
             console.log(res.blocks);

diff --git a/examples/html/liquid/websocket.html b/examples/html/liquid/websocket.html
@@ -8,12 +8,12 @@
         const {
           liquid: { websocket },
         } = mempoolJS();
-
-        const ws = websocket.initServer({
+        
+        const ws = websocket.initClient({
           options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
         });
 
-        ws.on('message', function incoming(data) {
+        ws.addEventListener('message', function incoming({data}) {
           const res = JSON.parse(data.toString());
           if (res.blocks) {
             console.log(res.blocks);

diff --git a/examples/nodejs/bisq/addresses.ts b/examples/nodejs/bisq/addresses.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bisq/blocks.ts b/examples/nodejs/bisq/blocks.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bisq/statistics.ts b/examples/nodejs/bisq/statistics.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bisq/transactions.ts b/examples/nodejs/bisq/transactions.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bitcoin/addresses.ts b/examples/nodejs/bitcoin/addresses.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bitcoin/blocks.ts b/examples/nodejs/bitcoin/blocks.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bitcoin/fees.ts b/examples/nodejs/bitcoin/fees.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bitcoin/mempool.ts b/examples/nodejs/bitcoin/mempool.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bitcoin/transactions.ts b/examples/nodejs/bitcoin/transactions.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/bitcoin/websocket.ts b/examples/nodejs/bitcoin/websocket.ts
@@ -1,15 +1,14 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
-const init = async () => {
-  const {
-    bitcoin: { websocket },
-  } = mempoolJS();
+const { bitcoin: { websocket } } = mempoolJS();
 
+const init = async () => {
+
   const ws = websocket.initServer({
-    options: ['blocks', 'stats', 'mempool-blocks', 'live-2h-chart'],
+    options: ["blocks", "stats", "mempool-blocks", "live-2h-chart"],
   });
-
-  ws.on('message', function incoming(data) {
+  
+  ws.on("message", function incoming(data) {
     const res = JSON.parse(data.toString());
     if (res.blocks) {
       console.log(res.blocks);
@@ -24,5 +23,5 @@ const init = async () => {
       console.log(res.mempoolBlocks);
     }
   });
-};
+}
 init();
diff --git a/examples/nodejs/liquid/addresses.ts b/examples/nodejs/liquid/addresses.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/liquid/assets.ts b/examples/nodejs/liquid/assets.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/liquid/blocks.ts b/examples/nodejs/liquid/blocks.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/liquid/fees.ts b/examples/nodejs/liquid/fees.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/liquid/mempool.ts b/examples/nodejs/liquid/mempool.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {

diff --git a/examples/nodejs/liquid/transactions.ts b/examples/nodejs/liquid/transactions.ts
@@ -1,4 +1,4 @@
-import mempoolJS from '../../../src/index';
+import mempoolJS from "@mempool/mempool.js";
 
 const init = async () => {
   const {