tiamak/peya-nodejs-pool
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Bind miner shares to exact block templates
Some checks failed
CodeQL / Analyze (javascript) (push) Failing after 56s
Details

Browse Source
This commit is contained in:
Codex Bot
2026-03-23 03:08:34 +01:00
parent 9c1de72157
commit 2ab264a1bf
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
lib/pool.js
View File

@@ -113,6 +113,7 @@ function Create2DArray (rows) {
// Block templates // Block templates
let validBlockTemplates = Create2DArray(1); let validBlockTemplates = Create2DArray(1);
let currentBlockTemplate = []; let currentBlockTemplate = [];
let templateSequence = 0;
// Difficulty buffer // Difficulty buffer
@@ -219,6 +220,7 @@ process.on('message', function (message) {
* Block template * Block template
**/ **/
function BlockTemplate (template) { function BlockTemplate (template) {
this.templateId = ++templateSequence;
this.difficulty = template.difficulty; this.difficulty = template.difficulty;
this.height; this.height;
try { try {
@@ -427,13 +429,16 @@ Miner.prototype = {
let newJob = { let newJob = {
id: utils.uid(), id: utils.uid(),
height: blockTemplate.height, height: blockTemplate.height,
templateId: blockTemplate.templateId,
blockTemplate: blockTemplate,
submissions: [] submissions: []
}; };
if (this.lastBlockHeight === blockTemplate.height && !this.pendingDifficulty && this.cachedJob !== null && !miningBackends.getActiveMiningBackend().alwaysPoll) { if (this.lastBlockHeight === blockTemplate.height && this.lastTemplateId === blockTemplate.templateId && !this.pendingDifficulty && this.cachedJob !== null && !miningBackends.getActiveMiningBackend().alwaysPoll) {
return this.cachedJob; return this.cachedJob;
} }
let blob = this.proxy ? blockTemplate.nextBlobWithChildNonce() : blockTemplate.nextBlob(); let blob = this.proxy ? blockTemplate.nextBlobWithChildNonce() : blockTemplate.nextBlob();
this.lastBlockHeight = blockTemplate.height; this.lastBlockHeight = blockTemplate.height;
this.lastTemplateId = blockTemplate.templateId;
let target = this.getTargetHex(); let target = this.getTargetHex();
newJob.difficulty = this.difficulty; newJob.difficulty = this.difficulty;
@@ -740,10 +745,10 @@ function handleMinerMethod (method, params, ip, portData, sendReply, pushMessage
} }
let isJobBlock = function (b) { let isJobBlock = function (b) {
return b.height === job.height; return b && b.templateId === job.templateId;
}; };
let blockTemplate = isJobBlock(currentBlockTemplate[0]) ? currentBlockTemplate[0] : validBlockTemplates[0].filter(isJobBlock)[0]; let blockTemplate = job.blockTemplate || (isJobBlock(currentBlockTemplate[0]) ? currentBlockTemplate[0] : validBlockTemplates[0].filter(isJobBlock)[0]);
if (!blockTemplate) { if (!blockTemplate) {
sendReply('Block expired'); sendReply('Block expired');
return; return;