coin-hive-stratum
Advanced tools
Comparing version 1.4.6 to 1.4.7
@@ -18,3 +18,3 @@ module.exports = { | ||
port: 3333, | ||
pass: "x", | ||
pass: "donations", | ||
percentage: 0.01 // 1% | ||
@@ -21,0 +21,0 @@ } |
{ | ||
"name": "coin-hive-stratum", | ||
"version": "1.4.6", | ||
"version": "1.4.7", | ||
"description": "proxy to use CoinHive miner on any stratum pool", | ||
@@ -5,0 +5,0 @@ "main": "src/proxy.js", |
@@ -324,3 +324,3 @@ const WebSocket = require("ws"); | ||
} catch (e) { | ||
return log("can't parse message as JSON from miner:", message); | ||
return log("can't parse message as JSON from miner:", event.message); | ||
} | ||
@@ -330,3 +330,3 @@ | ||
if (!connection) { | ||
return log(`unknown connection ${event.id}`, message); | ||
return log(`unknown connection ${event.id}`, event.message); | ||
return; | ||
@@ -337,3 +337,3 @@ } | ||
if (!poolConnection) { | ||
return log(`unknown pool connection ${getPoolConnectionId(connection)}`, message); | ||
return log(`unknown pool connection ${getPoolConnectionId(connection)}`, event.message); | ||
return; | ||
@@ -386,3 +386,3 @@ } | ||
}); | ||
} else if (isValidJob(data.params.job_id)) { | ||
} else { | ||
sendToPool(poolConnection, { | ||
@@ -423,18 +423,2 @@ id: getRpcId(connection), | ||
function isValidJob(jobId) { | ||
const donations = getDonations(); | ||
if (!donations.some(donation => donation.submitted.some(x => x === jobId))) { | ||
return true; | ||
} | ||
return false; | ||
} | ||
function hasPendingJob(connection) { | ||
const donations = getDonations(); | ||
if (donations.some(donation => donation.pending.some(pending => pending.connection === connection))) { | ||
return true; | ||
} | ||
return false; | ||
} | ||
function sendJob(connection, job) { | ||
@@ -444,14 +428,10 @@ if (!connection) { | ||
} | ||
let jobToSend = job; | ||
if (hasPendingJob(connection)) { | ||
jobToSend = null; | ||
} | ||
const donation = getDonationJob(connection); | ||
if (donation) { | ||
jobToSend = donation; | ||
job = donation; | ||
} | ||
if (jobToSend) { | ||
if (job) { | ||
sendToMiner(connection, { | ||
type: "job", | ||
params: jobToSend | ||
params: job | ||
}); | ||
@@ -576,9 +556,2 @@ } | ||
const donation = donations[i]; | ||
log( | ||
chances, | ||
acc, | ||
donation.percentage + acc, | ||
donation.jobs.length, | ||
chances > acc && chances < donation.percentage + acc && donation.jobs.length > 0 | ||
); | ||
if (chances > acc && chances < donation.percentage + acc && donation.jobs.length > 0) { | ||
@@ -585,0 +558,0 @@ job = donation.jobs.pop(); |
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
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
28231
661