From b836390b22fb9ce256c5f22032ec2eb22ebbb22a Mon Sep 17 00:00:00 2001 From: tenthirtyone Date: Sun, 27 Aug 2017 22:53:39 -0400 Subject: [PATCH] remove sockets --- server/lib/api/index.js | 1 - server/lib/api/socket.js | 68 ---------------------------------------- server/package.json | 1 - 3 files changed, 70 deletions(-) delete mode 100644 server/lib/api/socket.js diff --git a/server/lib/api/index.js b/server/lib/api/index.js index 11d1994..7811a31 100644 --- a/server/lib/api/index.js +++ b/server/lib/api/index.js @@ -35,7 +35,6 @@ app.use((req, res) => res.status(404).send({ error: 'Not found', })); -// Socket server const server = require('http').Server(app); module.exports = { diff --git a/server/lib/api/socket.js b/server/lib/api/socket.js deleted file mode 100644 index fef4ee8..0000000 --- a/server/lib/api/socket.js +++ /dev/null @@ -1,68 +0,0 @@ -const server = require('.'); -const io = require('socket.io')(server); - -let refreshBlocks = false; -const txInterval = 200; -let txCounter = 0; - -// Not quite debouncing -setInterval(() => { - refreshBlocks = true; -}, 10000); - - -io.on('connection', (socket) => { - socket.on('subscribe', (data) => { - }); - - socket.on('message', (data) => { - }); - - socket.on('unsubscribe', (data) => { - }); - - socket.on('disconnect', (data) => { - }); -}); - -// Emit block refresh and txs -function processBlock(entry, block) { - if (refreshBlocks) { - refreshBlocks = false; - emitBlock(entry); - } - block.txs.forEach((tx) => { - txCounter++; - if (txCounter % txInterval === 0) { - txCounter = 0; - emitTx(tx); - } - }); -} - -function emitBlock(block) { - io.sockets.emit('block', { - hash: block.toJSON().hash, - }); -} - -function emitTx(transaction) { - const txJSON = transaction.toJSON(); - io.sockets.emit('tx', { - txid: txJSON.hash, - valueOut: transaction.outputs.reduce((sum, output) => { - output = output.toJSON(); - - const valB = (output.value || output.valueOut.value || 0) / 1e8; - - return sum + valB; - }, 0), - }); -} - -module.exports = { - io, - processBlock, - emitBlock, - emitTx, -}; diff --git a/server/package.json b/server/package.json index acdc50d..af0b5d1 100644 --- a/server/package.json +++ b/server/package.json @@ -20,7 +20,6 @@ "helmet": "^3.8.1", "mongoose": "^4.11.5", "request": "^2.81.0", - "socket.io": "^2.0.3", "winston": "^2.3.1" }, "devDependencies": {