Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
coin-hive-stratum
Advanced tools
coin-hive-stratum - npm Package Compare versions
Comparing version 1.0.1 to 1.0.2
| { | ||
| "name": "coin-hive-stratum", | ||
| "version": "1.0.1", | ||
| "version": "1.0.2", | ||
| "description": "proxy to use CoinHive miner on any stratum pool", | ||
@@ -5,0 +5,0 @@ "main": "src/proxy.js", |
@@ -67,3 +67,3 @@ CoinHive Stratum Proxy | ||
| **Can I use this programatically?** | ||
| **Can I use this programmatically?** | ||
@@ -100,2 +100,2 @@ Yes, like this: | ||
| This project is not endorsed by or affiliated with `coinhive.com` in any way. | ||
| This project is not endorsed by or affiliated with `coinhive.com` in any way. |
351
src/proxy.js
@@ -5,165 +5,208 @@ const WebSocket = require('ws'); | ||
| const defaults = require('../config/defaults'); | ||
| function createProxy(options = defaults) { | ||
| const constructorOptions = Object.assign({}, defaults, options); | ||
| const log = function () { options.log && console.log.apply(null, arguments) }; | ||
| function getConnection(ws) { | ||
| log('new websocket connection'); | ||
| return { | ||
| listen: function listen(port = 8892) { | ||
| let wss = new WebSocket.Server({ port: +port }); | ||
| log('websocket server created'); | ||
| log('listening on port', port); | ||
| wss.on('connection', (ws) => { | ||
| let getRpcId = null; | ||
| let getHashes = null; | ||
| let sendToPool = null; | ||
| let online = null; | ||
| let workerId = null; | ||
| let rpcId = null; | ||
| let hashes = null; | ||
| let socket = null; | ||
| log('new websocket connection'); | ||
| let queue = new Queue(); | ||
| log('queue created'); | ||
| ws.on('message', function (message) { | ||
| queue.push({ | ||
| type: 'message', | ||
| payload: message | ||
| }); | ||
| online: null, | ||
| workerId: null, | ||
| rpcId: null, | ||
| hashes: null, | ||
| socket: null, | ||
| queue: null, | ||
| ws: ws | ||
| } | ||
| } | ||
| function createQueue(connection) { | ||
| log('queue created'); | ||
| connection.queue = new Queue(); | ||
| } | ||
| function bindWebSocket(connection) { | ||
| connection.ws.on('message', function (message) { | ||
| if (connection.queue) { | ||
| connection.queue.push({ | ||
| type: 'message', | ||
| payload: message | ||
| }); | ||
| } | ||
| }); | ||
| connection.ws.on('close', () => { | ||
| if (connection.queue) { | ||
| connection.queue.push({ | ||
| type: 'close', | ||
| payload: null | ||
| }); | ||
| } | ||
| }); | ||
| connection.ws.on('error', (error) => { | ||
| if (connection.queue) { | ||
| connection.queue.push({ | ||
| type: 'error', | ||
| payload: error | ||
| }); | ||
| } | ||
| }); | ||
| } | ||
| function bindQueue(connection) { | ||
| connection.queue.on('close', () => { | ||
| killConnection(connection); | ||
| log('miner connection closed'); | ||
| }); | ||
| connection.queue.on('error', (error) => { | ||
| killConnection(connection); | ||
| log('miner connection error', error.message); | ||
| }); | ||
| connection.queue.on('message', function (message) { | ||
| log('\nmessage from miner to pool:\n\n', message); | ||
| const data = JSON.parse(message); | ||
| switch (data.type) { | ||
| case 'auth': { | ||
| let login = data.params.site_key; | ||
| if (data.params.user) { | ||
| login += '.' + data.params.user; | ||
| } | ||
| sendToPool(connection, { | ||
| id: getRpcId(connection), | ||
| method: 'login', | ||
| params: { | ||
| login: login, | ||
| pass: 'x' | ||
| }, | ||
| }); | ||
| ws.on('close', () => { | ||
| queue.push({ | ||
| type: 'close', | ||
| payload: null | ||
| }); | ||
| }); | ||
| ws.on('error', (error) => { | ||
| queue.push({ | ||
| type: 'error', | ||
| payload: error | ||
| }); | ||
| }); | ||
| queue.on('close', () => { | ||
| online = false; | ||
| if (socket) { | ||
| queue.stop(); | ||
| socket.destroy(); | ||
| break; | ||
| } | ||
| case 'submit': { | ||
| sendToPool(connection, { | ||
| id: getRpcId(connection), | ||
| method: 'submit', | ||
| params: { | ||
| id: connection.workerId, | ||
| job_id: data.params.job_id, | ||
| nonce: data.params.nonce, | ||
| result: data.params.result | ||
| } | ||
| log('miner connection closed'); | ||
| }); | ||
| queue.on('error', (error) => { | ||
| if (socket) { | ||
| queue.stop(); | ||
| socket.destroy(); | ||
| break; | ||
| } | ||
| } | ||
| }) | ||
| } | ||
| function sendToPool(connection, payload) { | ||
| const stratumMessage = JSON.stringify(payload) + '\n'; | ||
| connection.socket.write(stratumMessage); | ||
| log('\nmessage sent to pool:\n\n', stratumMessage); | ||
| } | ||
| function sendToMiner(connection, payload) { | ||
| const coinHiveMessage = JSON.stringify(payload); | ||
| if (connection.online) { | ||
| connection.ws.send(coinHiveMessage); | ||
| log('\nmessage sent to miner:\n\n', coinHiveMessage); | ||
| } else { | ||
| log('\nfailed to send message to miner cos it was offline:', coinHiveMessage) | ||
| } | ||
| } | ||
| function getRpcId(connection) { | ||
| return connection.rpcId++; | ||
| } | ||
| function getHashes(connection) { | ||
| return connection.hashes++; | ||
| } | ||
| function connectSocket(connection, port, host) { | ||
| connection.socket = new net.Socket(); | ||
| log('tcp socket created'); | ||
| connection.socket.connect(+port, host, function () { | ||
| log('connected to pool'); | ||
| log('host', host); | ||
| log('port', port); | ||
| connection.online = true; | ||
| connection.rpcId = 1; | ||
| connection.hashes = 1; | ||
| connection.socket.on('data', function (buffer) { | ||
| const stratumMessage = buffer.toString('utf8'); | ||
| log('\nmessage from pool to miner:\n\n', stratumMessage); | ||
| const data = JSON.parse(stratumMessage); | ||
| if (data.id === 1) { | ||
| connection.workerId = data.result.id; | ||
| sendToMiner(connection, { | ||
| type: 'authed', | ||
| params: { | ||
| token: '', | ||
| hashes: 0 | ||
| } | ||
| log('miner connection error', error.message); | ||
| }); | ||
| queue.on('message', function (message) { | ||
| log('\nmessage from miner to pool:\n\n', message); | ||
| const data = JSON.parse(message); | ||
| switch (data.type) { | ||
| case 'auth': { | ||
| let login = data.params.site_key; | ||
| if (data.params.user) { | ||
| login += '.' + data.params.user; | ||
| } | ||
| sendToPool({ | ||
| id: getRpcId(), | ||
| method: 'login', | ||
| params: { | ||
| login: login, | ||
| pass: 'x' | ||
| }, | ||
| }); | ||
| break; | ||
| } | ||
| case 'submit': { | ||
| sendToPool({ | ||
| id: getRpcId(), | ||
| method: 'submit', | ||
| params: { | ||
| id: workerId, | ||
| job_id: data.params.job_id, | ||
| nonce: data.params.nonce, | ||
| result: data.params.result | ||
| } | ||
| }); | ||
| break; | ||
| } | ||
| } | ||
| }) | ||
| socket = new net.Socket(); | ||
| log('tcp socket created'); | ||
| socket.connect(+constructorOptions.port, constructorOptions.host, function () { | ||
| log('connected to pool'); | ||
| log('host', constructorOptions.host); | ||
| log('port', constructorOptions.port); | ||
| online = true; | ||
| workerId = null; | ||
| rpcId = 1; | ||
| hashes = 1; | ||
| getRpcId = () => rpcId++; | ||
| getHashes = () => (hashes++); | ||
| sendToPool = (payload) => { | ||
| const stratumMessage = JSON.stringify(payload) + '\n'; | ||
| socket.write(stratumMessage); | ||
| log('\nmessage sent to pool:\n\n', stratumMessage); | ||
| } | ||
| let sendToMiner = (payload) => { | ||
| const coinHiveMessage = JSON.stringify(payload); | ||
| if (online) { | ||
| ws.send(coinHiveMessage); | ||
| log('\nmessage sent to miner:\n\n', coinHiveMessage); | ||
| } else { | ||
| log('\nfailed to send message to miner cos it was offline:', coinHiveMessage) | ||
| } | ||
| } | ||
| socket.on('data', function (buffer) { | ||
| const stratumMessage = buffer.toString('utf8'); | ||
| log('\nmessage from pool to miner:\n\n', stratumMessage); | ||
| const data = JSON.parse(stratumMessage); | ||
| if (data.id === 1) { | ||
| workerId = data.result.id; | ||
| sendToMiner({ | ||
| type: 'authed', | ||
| params: { | ||
| token: '', | ||
| hashes: 0 | ||
| } | ||
| }); | ||
| if (data.result.job) { | ||
| sendToMiner({ | ||
| type: 'job', | ||
| params: data.result.job | ||
| }); | ||
| } | ||
| } else { | ||
| if (data.method === 'job') { | ||
| sendToMiner({ | ||
| type: 'job', | ||
| params: data.params | ||
| }); | ||
| } | ||
| if (data.result && data.result.status === 'OK') { | ||
| sendToMiner({ | ||
| type: 'hash_accepted', | ||
| params: { | ||
| hashes: getHashes() | ||
| } | ||
| }); | ||
| } | ||
| } | ||
| if (data.result.job) { | ||
| sendToMiner(connection, { | ||
| type: 'job', | ||
| params: data.result.job | ||
| }); | ||
| socket.on('close', function () { | ||
| log('connection to pool closed'); | ||
| ws.close(); | ||
| queue.stop(); | ||
| } | ||
| } else { | ||
| if (data.method === 'job') { | ||
| sendToMiner(connection, { | ||
| type: 'job', | ||
| params: data.params | ||
| }); | ||
| socket.on('error', function (error) { | ||
| log('pool connection error', error && error.message ? error.message : error); | ||
| ws.close(); | ||
| queue.stop(); | ||
| } | ||
| if (data.result && data.result.status === 'OK') { | ||
| sendToMiner(connection, { | ||
| type: 'hash_accepted', | ||
| params: { | ||
| hashes: getHashes(connection) | ||
| } | ||
| }); | ||
| queue.start(); | ||
| log('queue started'); | ||
| }); | ||
| }) | ||
| } | ||
| } | ||
| }); | ||
| connection.socket.on('close', function () { | ||
| log('connection to pool closed'); | ||
| killConnection(connection); | ||
| }); | ||
| connection.socket.on('error', function (error) { | ||
| log('pool connection error', error && error.message ? error.message : error); | ||
| killConnection(connection); | ||
| }); | ||
| connection.queue.start(); | ||
| log('queue started'); | ||
| }); | ||
| } | ||
| function killConnection(connection) { | ||
| if (connection.queue) { | ||
| connection.queue.stop(); | ||
| } | ||
| if (connection.ws) { | ||
| connection.ws.close(); | ||
| } | ||
| if (connection.socket) { | ||
| connection.socket.destroy(); | ||
| } | ||
| connection.online = false; | ||
| connection.socket = null; | ||
| connection.queue = null; | ||
| connection.ws = null; | ||
| connection = null; | ||
| } | ||
| function createProxy(options = defaults) { | ||
| const constructorOptions = Object.assign({}, defaults, options); | ||
| log = function () { options.log && console.log.apply(null, arguments) }; | ||
| return { | ||
| listen: function listen(port = 8892) { | ||
| let wss = new WebSocket.Server({ port: +port }); | ||
| log('websocket server created'); | ||
| log('listening on port', port); | ||
| wss.on('connection', (ws) => { | ||
| const connection = getConnection(ws); | ||
| createQueue(connection); | ||
| bindWebSocket(connection); | ||
| bindQueue(connection); | ||
| connectSocket(connection, +constructorOptions.port, constructorOptions.host); | ||
| }); | ||
| } | ||
@@ -170,0 +213,0 @@ } |
Sorry, the diff of this file is not supported yet
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Improved metrics
- Total package byte prevSize
- increased by1.47%
10355
- Lines of code
- increased by15.84%
234
- Number of lines in readme file
- increased by1.01%
100
No dependency changes