From 40305f17064cf2b256883f5fbc6aa1904c8b533e Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 19:13:34 +0700 Subject: [PATCH 01/10] Update proxy.js profit auto switch --- proxy.js | 197 ++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 file changed, 189 insertions(+), 8 deletions(-) diff --git a/proxy.js b/proxy.js index c3608a1..022ab30 100644 --- a/proxy.js +++ b/proxy.js @@ -8,11 +8,16 @@ const path = require('path'); const winston = require('winston'); const BN = require('bignumber.js'); const diff2 = BN('ffffffff', 16); +var request = require('request'); +const TeleBot = require('telebot'); +const fetch = require("node-fetch"); const server = http.createServer(app); const io = require('socket.io').listen(server); const bodyParser = require('body-parser'); +const ioClient = require('socket.io-client') + app.use(bodyParser.json()); // support json encoded bodies app.use(bodyParser.urlencoded({ extended: true })); // support encoded bodies @@ -38,6 +43,12 @@ var config = JSON.parse(fs.readFileSync('config.json')); const localport = config.workerport; var pools = config.pools; +var workerhashrates = {}; + +const telebot = config.telegram && config.telegram.token? new TeleBot(config.telegram.token):null; +if(telebot) + telebot.on(['/id'], (msg) => msg.reply.text(msg.from.id)); + logger.info("start http interface on port %d ", config.httpport); server.listen(config.httpport,'::'); @@ -60,7 +71,7 @@ function attachPool(localsocket,coin,firstConn,setWorker,user,pass) { if(data) logger.debug('received from pool ('+coin+') on connect:'+data.toString().trim()+' ('+pass+')'); logger.info('new login to '+coin+' ('+pass+')'); - var request = {"id":1,"method":"login","params":{"login":pools[user][idx].name,"pass":"x","agent":"XMRig/2.4.3"}}; + var request = {"id":1,"method":"login","params":{"login":pools[user][idx].name,"pass":pass,"agent":"XMRig/2.5.0"}}; remotesocket.write(JSON.stringify(request)+"\n"); }); @@ -120,6 +131,7 @@ function attachPool(localsocket,coin,firstConn,setWorker,user,pass) { remotesocket.on('close', function(had_error,text) { logger.info("pool conn to "+coin+" ended ("+pass+')'); + if(workerhashrates[user]) delete workerhashrates[user][pass]; if(had_error) logger.error(' --'+text); }); remotesocket.on('error', function(text) { @@ -146,6 +158,10 @@ function attachPool(localsocket,coin,firstConn,setWorker,user,pass) { const now = ((new Date).getTime())/1000; const rate = shares / (now-connectTime); + if(!workerhashrates[user]) workerhashrates[user]={}; + + workerhashrates[user][pass]={time:now,hashrate:rate}; + logger.info(' HashRate:'+((rate).toFixed(2))+' kH/s'); } remotesocket.write(JSON.stringify(data)+"\n"); @@ -154,6 +170,17 @@ function attachPool(localsocket,coin,firstConn,setWorker,user,pass) { return poolCB; }; +if(telebot) { + telebot.on(/^\/hr (.+)$/, (msg, props) => { + const user = props.match[1]; + var whs = "hashrate:\n"; + for (var worker in workerhashrates[user]) { + whs = whs + worker + ": " + workerhashrates[user][worker].hashrate.toFixed(2) + " kH/s\n"; + } + + return telebot.sendMessage(msg.from.id, whs); + }); +} function createResponder(localsocket,user,pass){ @@ -167,9 +194,11 @@ function createResponder(localsocket,user,pass){ connected = true; }; - var poolCB = attachPool(localsocket,config.default,true,idCB,user,pass); + var poolCB = attachPool(localsocket,pools[user].default||config.default,true,idCB,user,pass); + + var switchCB = function(newcoin,newuser){ - var switchCB = function(newcoin){ + if(user!==newuser) return; logger.info('-- switch worker to '+newcoin+' ('+pass+')'); connected = false; @@ -281,25 +310,177 @@ workerserver.listen(localport); logger.info("start mining proxy on port %d ", localport); io.on('connection', function(socket){ + + var intervalObj; socket.on('reload',function(user) { config = JSON.parse(fs.readFileSync('config.json')); pools = config.pools; + var coins = []; - for (var pool of pools[user]) coins.push(pool.symbol); + for (var pool of pools[user]) + coins.push({ + symbol:pool.symbol, + login:pool.name.split('.')[0], + url:pool.url, + api:pool.api, + tick: pool.tick, + active:((pools[user].default||config.default)===pool.symbol)?1:0 + }); + socket.emit('coins',coins); logger.info("pool config reloaded"); }); socket.on('user',function(user) { var coins = []; - for (var pool of pools[user]) coins.push(pool.symbol); + for (var pool of pools[user]) + coins.push({ + symbol:pool.symbol, + login:pool.name.split('.')[0], + url:pool.url?pool.url:'', + api:pool.api?pool.api:'', + tick: pool.tick, + active:((pools[user].default||config.default)===pool.symbol)?1:0 + }); + socket.emit('coins',coins); + logger.info('-> current for '+user+': '+(pools[user].default||config.default)); + socket.emit('workers',workerhashrates[user]||{},((new Date).getTime())/1000); + if(intervalObj) clearInterval(intervalObj); + intervalObj = setInterval(() => { + socket.emit('active',(pools[user].default||config.default)); + socket.emit('workers',workerhashrates[user]||{},((new Date).getTime())/1000); + }, 2000); }); socket.on('switch', function(user,coin){ - logger.info('->'+coin); + logger.info('->'+coin+' ('+user+')'); + pools[user].default=coin; + switchEmitter.emit('switch',coin,user); socket.emit('active',coin); - switchEmitter.emit('switch',coin); - config.default=coin; + if(telebot && config.telegram.chat_id && config.telegram.token) { + telebot.sendMessage(config.telegram.chat_id, 'switched to '+coin+' ('+user+')'); + } + }); + + socket.on('disconnect', function(reason){ + if(intervalObj) clearInterval(intervalObj); }); + + }); +if(telebot) + telebot.start(); + +const getPrice = async url => { + try { + const response = await fetch(url); + const json = await response.json(); + + return json; + } catch (error) { + console.log(error); + } +}; + +const getAltexPrice = async url => { + try { + const response = await fetch(url); + const json = await response.json(); + let res = {}; + res.bid = json.data[json.data.length - 1].price; + return res; + } catch (error) { + console.log(error); + } +}; + +const getStats = async url => { + try { + const response = await fetch(url); + const json = await response.json(); + let res = {}; + res.reward = json.network.reward; + res.coinbase = json.network.coinbase; + res.difficulty = json.network.difficulty; + res.coinUnits = json.config.coinUnits + return res; + } catch (error) { + console.log(error); + } +}; +var lastWinner = config.default; +const client = ioClient.connect("http://localhost:" + config.httpport); +function calculateAutoswitch() { + logger.info(' -> default ' + config.default); + logger.info(' -> treshold ' + config.autoswitch.treshold); + let hr = 7200; // TODO use combined hashrate + for (pool in pools) { + let prices = []; + logger.info(' -> pool ' + pool); + + for (index = 0, len = pools[pool].length; index < len; ++index) { + let tickUrl = pools[pool][index].tick; + if(tickUrl.includes("tradeogre")) { + prices.push(getPrice(tickUrl)); + } else if(tickUrl.includes("altex")){ + prices.push(getAltexPrice(tickUrl)); + } + } + Promise.all(prices).then(function(prices) { + let stats = []; + for (index = 0, len = pools[pool].length; index < len; ++index) { + + let statUrl = pools[pool][index].api + "/stats"; + stats.push(getStats(statUrl)); + } + + Promise.all(stats).then(function(stats) { + let bestcoinrev = 0.0; + let newWinner = lastWinner; + for (index = 0, len = pools[pool].length; index < len; ++index) { + let symbol = pools[pool][index].symbol; + // logger.info(symbol + ' -> reward ' + stats[index].reward); + let reward = stats[index].reward; + // if(stats[index].coinbase){ + // reward = reward - stats[index].coinbase; + // logger.info(symbol + ' -> coinbase ' + stats[index].coinbase); + // } + let revcoin = (hr * 86400 / stats[index].difficulty * reward) + revcoin = getReadableCoins(revcoin, 2, true, stats[index].coinUnits, symbol) + let revBTC = revcoin * prices[index].bid; + let revCompete = revBTC; + if(symbol == lastWinner){ + revCompete = revBTC * (100.0 + parseFloat(config.autoswitch.treshold))/100.0; + } + + logger.info('[autoswitchcalc] ' + symbol + ' -> rev-'+symbol+': ' + revcoin + '\t\trev BTC: ' + revBTC + '\t\tbid price: ' + prices[index].bid+ '\t\trev Compete: ' + revCompete); + if (revCompete > bestcoinrev) { + bestcoinrev = revCompete + newWinner = symbol + } + } + + if(lastWinner != newWinner){ + logger.info(' -> winner: ' + newWinner); + lastWinner = newWinner; + client.emit('switch', pool, newWinner) + } + + + + function getReadableCoins (coins, digits, withoutSymbol, coinUnits, symbol) { + var amount = (parseInt(coins || 0) / coinUnits).toFixed(digits || coinUnits.toString().length - 1) + return amount + (withoutSymbol ? '' : (' ' + symbol)) + } + }); + + }); + } +} + +var period = parseInt(config.autoswitch.period); +if(period > 0) { + calculateAutoswitch(); + setInterval(calculateAutoswitch, period * 60000); +} From 4d668c5310dae586601451779501362cd1a91577 Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 19:15:59 +0700 Subject: [PATCH 02/10] Update package.json --- package.json | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/package.json b/package.json index b8c4beb..f2b0561 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "cryptonote-proxy", - "version": "2.0.0", + "version": "4.0.0", "license": "0BSD", "authors": "sebseb", "main": "proxy.js", @@ -12,7 +12,10 @@ "bignumber.js": "^5.0.0", "body-parser": "^1.18.2", "express": "^4.16.2", + "node-fetch": "^2.1.2", "socket.io": "^2.0.4", + "socket.io-client": "^2.1.1", + "telebot": "^1.2.6", "winston": "^2.4.0" }, "engines": { From 275e8417a4ab9c1e261c1e2097046a88d4aaaeac Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 19:27:23 +0700 Subject: [PATCH 03/10] Update config.json --- config.json | 112 +++++++++++++++++++++++++++++++++------------------- 1 file changed, 71 insertions(+), 41 deletions(-) diff --git a/config.json b/config.json index 6bdb418..470caeb 100644 --- a/config.json +++ b/config.json @@ -1,48 +1,78 @@ { "workerport":2349, "httpport":2350, - "default":"nh", + "default":"CNV7", + "telegram":{ + "token": "telegram token from @botfather", + "chat_id": "yourID" + }, + "autoswitch":{ + "treshold": "10[in percent delete this to disable]", + "period": "30[in minutes delete this to disable]" + }, "pools": { - "userA":[ - { - "symbol":"itns", - "name":"izlkfjdflkjgdlfkgjdflkgjdlkfgj", - "host":"45.32.171.89", - "port":"9999" - },{ - "symbol":"xun", - "name":"Xunhfkjfhlkdfjglkdfjgdlkfgjdlkfgjdflkg", - "host":"78.47.92.206", - "port":"9999" - },{ - "symbol":"etn", - "name":"etndfglkdjfgldkjfgkldjfglkjfg", - "host":"pool.etn.spacepools.org", - "port":"7777" - },{ - "symbol":"msr", - "name":"5q9dflkjdflgkdjfgdfgdfgdfgdfg", - "host":"masari.superpools.net", - "port":"8889" - },{ - "symbol":"nh", - "name":"38efCkzYVUrojQAjuBAQHpudVpKKuaqxrZ.pr", - "host":"cryptonight.eu.nicehash.com", - "port":"3355" - } - ],"userB":[ - { - "symbol":"itns", - "name":"izlkfjdflkjgdlfkgjdflkgjdlkfgj", - "host":"45.32.171.89", - "port":"9999" - },{ - "symbol":"nh", - "name":"38efCkzYVUrojQAjuBAQHpudVpKKuaqxrZ.pr", - "host":"cryptonight.eu.nicehash.com", - "port":"3355" - } - ] + "CNV7":[ + { + "symbol":"XTL", + "name":"XTLWALLET", + "host":"stellite.ingest.cryptoknight.cc", + "port":"16221", + "url":"https://cryptoknight.cc/stellite", + "api":"https://cryptoknight.cc/rpc/stellite", + "tick":"https://api.altex.exchange/v1/marketHistory/market/BTC_XTL" + }, + { + "symbol":"XTL", + "name":"XTLWALLET", + "host":"stellite.ingest.cryptoknight.cc", + "port":"16221", + "url":"https://cryptoknight.cc/stellite", + "api":"https://cryptoknight.cc/rpc/stellite", + "tick":"https://tradeogre.com/api/v1/ticker/BTC-TUBE" + } + ], + "IPBC":[ + { + "symbol":"BITTUBE", + "name":"TUBEWALLET", + "host":"ipbc.ingest.cryptoknight.cc", + "port":"4462", + "url":"https://cryptoknight.cc/ipbc", + "api":"https://cryptoknight.cc/rpc/ipbc", + "tick":"https://tradeogre.com/api/v1/ticker/BTC-TUBE" + } + ], + "LITEV7":[ + { + "symbol":"IRIDIUM", + "name":"IRDWALLET", + "host":"iridium.ingest.cryptoknight.cc", + "port":"50502", + "url":"https://cryptoknight.cc/iridium", + "api":"https://cryptoknight.cc/rpc/stellite", + "tick":"https://tradeogre.com/api/v1/ticker/BTC-IRD" + }, + { + "symbol":"WORKTIPS", + "name":"WTIPWALLET", + "host":"worktips.work", + "port":"7777", + "url":"http://worktips.work", + "api":"http://worktips.work:8117", + "tick":"https://api.altex.exchange/v1/marketHistory/market/XMR_WTIP" + } + ], + "HEAVY":[ + { + "symbol":"HAVEN", + "name":"XHVWALLET", + "host":"haven.ingest.cryptoknight.cc", + "port":"5532", + "url":"https://cryptoknight.cc/haven", + "api":"https://cryptoknight.cc/rpc/haven", + "tick":"https://tradeogre.com/api/v1/ticker/BTC-XHV" + } + ] } } From 161f0f218699cf4a56f927f20bc7ebc94b1eb96a Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 19:28:41 +0700 Subject: [PATCH 04/10] Update index.html Nethash Poolhash NetLastBlock PoolLastBlock CurrEffort RevCoin RevBTC/XMR --- index.html | 363 ++++++++++++++++++++++++++++++++++++++++------------- 1 file changed, 273 insertions(+), 90 deletions(-) diff --git a/index.html b/index.html index 3d3d7d1..7f4a6f2 100644 --- a/index.html +++ b/index.html @@ -1,103 +1,286 @@ -CryptoKnight Proxy Mining Switch - - - - - - - + CryptoKnight Proxy Mining Auto Switch + + + + + + + + + -
- -
-Load RIG -
+
+ +
+ Load +
- +
- +
+ Reload Config +
- -
-Reload Config -
+
+
+ From 40bd18db1efef35c2fcd07b1c70ca29a2516d4e1 Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 19:30:20 +0700 Subject: [PATCH 05/10] Update readme.md --- readme.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/readme.md b/readme.md index e64b387..b92523b 100644 --- a/readme.md +++ b/readme.md @@ -1,3 +1,5 @@ +Proxy by : https://github.com/sebseb7/cryptonote-proxy +Auto Switch by : https://github.com/noemnoem/cryptonote-proxy [![NPM](https://nodei.co/npm/cryptonote-proxy.png)](https://npmjs.org/package/cryptonote-proxy) From 921355f23115ab636246190cf3ec70317cd25af2 Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 19:30:58 +0700 Subject: [PATCH 06/10] Update readme.md --- readme.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/readme.md b/readme.md index b92523b..3d7839a 100644 --- a/readme.md +++ b/readme.md @@ -1,6 +1,8 @@ Proxy by : https://github.com/sebseb7/cryptonote-proxy + Auto Switch by : https://github.com/noemnoem/cryptonote-proxy + [![NPM](https://nodei.co/npm/cryptonote-proxy.png)](https://npmjs.org/package/cryptonote-proxy) From ff38ce6995d8c084d30f190af31e9f2db5fdf42c Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 19:39:22 +0700 Subject: [PATCH 07/10] Update readme.md --- readme.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/readme.md b/readme.md index 3d7839a..98ff4f7 100644 --- a/readme.md +++ b/readme.md @@ -1,3 +1,5 @@ +[![IMG1](https://preview.ibb.co/mADHTT/Crypto_Knight_Proxy_Mining_Switch_1.png)](https://github.com/iisbetoq/cryptonote-proxy) + Proxy by : https://github.com/sebseb7/cryptonote-proxy Auto Switch by : https://github.com/noemnoem/cryptonote-proxy From d84f003bf4b9b39098356892ff1babe4fdfd6cfd Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 20:50:51 +0700 Subject: [PATCH 08/10] Update readme.md --- readme.md | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/readme.md b/readme.md index 98ff4f7..87cc9b8 100644 --- a/readme.md +++ b/readme.md @@ -1,8 +1,9 @@ -[![IMG1](https://preview.ibb.co/mADHTT/Crypto_Knight_Proxy_Mining_Switch_1.png)](https://github.com/iisbetoq/cryptonote-proxy) +

+ +

+ -Proxy by : https://github.com/sebseb7/cryptonote-proxy -Auto Switch by : https://github.com/noemnoem/cryptonote-proxy [![NPM](https://nodei.co/npm/cryptonote-proxy.png)](https://npmjs.org/package/cryptonote-proxy) @@ -15,4 +16,6 @@ https://nodejs.org/ - start with "node proxy.js" - don't open index.html from this repo, to control the switch point your browser to the "httpport" as in config.json -Support https://discord.gg/h7JDXpT +Proxy by : https://github.com/sebseb7/cryptonote-proxy + +Auto Switch by : https://github.com/noemnoem/cryptonote-proxy From ee6c1d3f3e91c4cd0a87d4e09df956c64a1f7817 Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 21:08:08 +0700 Subject: [PATCH 09/10] Update readme.md --- readme.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/readme.md b/readme.md index 87cc9b8..52bbe8b 100644 --- a/readme.md +++ b/readme.md @@ -1,5 +1,5 @@

- + Crypto_Knight_Proxy_Mining_Switch_4

From f901afb184677a9d833d35dd698eac79a655d8a9 Mon Sep 17 00:00:00 2001 From: IisBetoQ Date: Thu, 7 Jun 2018 21:13:05 +0700 Subject: [PATCH 10/10] Update readme.md --- readme.md | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/readme.md b/readme.md index 52bbe8b..8d4b6d7 100644 --- a/readme.md +++ b/readme.md @@ -1,5 +1,5 @@

- Crypto_Knight_Proxy_Mining_Switch_4 + Screen_Shot_2018_06_07_at_21_09_55

@@ -15,7 +15,8 @@ https://nodejs.org/ - adjust config.json - start with "node proxy.js" - don't open index.html from this repo, to control the switch point your browser to the "httpport" as in config.json +- more [manual installation](https://github.com/iisbetoq/cryptonote-proxy/wiki) -Proxy by : https://github.com/sebseb7/cryptonote-proxy +Proxy by : [sebseb7](https://github.com/sebseb7/cryptonote-proxy) -Auto Switch by : https://github.com/noemnoem/cryptonote-proxy +Auto Switch by : [noemnoem](https://github.com/noemnoem/cryptonote-proxy)