From f1998c321a4eec6d75b58d84aa8610971bf21979 Mon Sep 17 00:00:00 2001
From: Brian Picciano <mediocregopher@gmail.com>
Date: Sat, 31 Jul 2021 11:35:39 -0600
Subject: move static files into static sub-dir, refactor nix a bit

---
 static/src/assets/trading-in-the-rain/CW.js | 43 +++++++++++++++++++++++++++++
 1 file changed, 43 insertions(+)
 create mode 100644 static/src/assets/trading-in-the-rain/CW.js

(limited to 'static/src/assets/trading-in-the-rain/CW.js')

diff --git a/static/src/assets/trading-in-the-rain/CW.js b/static/src/assets/trading-in-the-rain/CW.js
new file mode 100644
index 0000000..043c1a8
--- /dev/null
+++ b/static/src/assets/trading-in-the-rain/CW.js
@@ -0,0 +1,43 @@
+function CW(resource) {
+  this.conn = new WebSocket('wss://stream.cryptowat.ch/connect?apikey=GPDLXH702E1NAD96OSBO');
+  this.conn.binaryType = "arraybuffer";
+
+  this.conn.onopen = () => {
+    console.log("CW websocket connected");
+    if (this.onconnect) this.onconnect();
+  }
+
+  let decoder = new TextDecoder();
+  this.conn.onmessage = (msg) => {
+    let d = JSON.parse(decoder.decode(msg.data));
+
+    // The server will always send an AUTHENTICATED signal when you establish a valid connection
+    // At this point you can subscribe to resources
+    if (d.authenticationResult && d.authenticationResult.status === 'AUTHENTICATED') {
+      if (this.onauth) this.onauth();
+      this.conn.send(JSON.stringify({
+        subscribe: {
+          subscriptions: [
+            {streamSubscription: {resource: resource}},
+          ],
+        }
+      }));
+      return;
+    }
+
+    // Market data comes in a marketUpdate
+    // In this case, we're expecting trades so we look for marketUpdate.tradesUpdate
+    if (!d.marketUpdate || !d.marketUpdate.tradesUpdate) {
+      return;
+    }
+
+    let trades = d.marketUpdate.tradesUpdate.trades;
+    for (let i in trades) {
+      trades[i].price = parseFloat(trades[i].priceStr);
+      trades[i].volume = parseFloat(trades[i].amountStr);
+    }
+    if (this.ontrades) this.ontrades(trades);
+  }
+
+  this.close = () => this.conn.close();
+}
-- 
cgit v1.2.3