diff options
author | Brian Picciano <mediocregopher@gmail.com> | 2023-08-13 22:06:32 +0200 |
---|---|---|
committer | Brian Picciano <mediocregopher@gmail.com> | 2023-08-13 22:06:32 +0200 |
commit | c4ec9064063f3b15aeb25feb85a3afaaa02008ba (patch) | |
tree | c7e9878f69ecc4649024c57e3164b2337ba0fdf2 /src/http/static/trading-in-the-rain/CW.js | |
parent | 0bc9cd83b45df0a38c2944569603d6d9cf2e9edd (diff) |
Remove leftover static assets specific to individual blog posts
Diffstat (limited to 'src/http/static/trading-in-the-rain/CW.js')
-rw-r--r-- | src/http/static/trading-in-the-rain/CW.js | 43 |
1 files changed, 0 insertions, 43 deletions
diff --git a/src/http/static/trading-in-the-rain/CW.js b/src/http/static/trading-in-the-rain/CW.js deleted file mode 100644 index 043c1a8..0000000 --- a/src/http/static/trading-in-the-rain/CW.js +++ /dev/null @@ -1,43 +0,0 @@ -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(); -} |