diff options
author | Brian Picciano <mediocregopher@gmail.com> | 2022-09-13 12:56:08 +0200 |
---|---|---|
committer | Brian Picciano <mediocregopher@gmail.com> | 2022-09-13 12:56:08 +0200 |
commit | 4f01edb9230f58ff84b0dd892c931ec8ac9aad55 (patch) | |
tree | 9c1598a3f98203913ac2548883c02a81deb33dc7 /srv/src/http/static/trading-in-the-rain/CW.js | |
parent | 5485984e05aebde22819adebfbd5ad51475a6c21 (diff) |
move src out of srv, clean up default.nix and Makefile
Diffstat (limited to 'srv/src/http/static/trading-in-the-rain/CW.js')
-rw-r--r-- | srv/src/http/static/trading-in-the-rain/CW.js | 43 |
1 files changed, 0 insertions, 43 deletions
diff --git a/srv/src/http/static/trading-in-the-rain/CW.js b/srv/src/http/static/trading-in-the-rain/CW.js deleted file mode 100644 index 043c1a8..0000000 --- a/srv/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(); -} |