highperfocused/public-pool
1
0
Fork 0
mirror of https://github.com/benjamin-wilson/public-pool.git synced 2025-03-28 18:52:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

bug

Browse Source
This commit is contained in:
Ben 2023-11-24 15:43:09 -05:00
parent b9af79978f
commit 5ee67bb5fe
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/services/bitcoin-rpc.service.ts
View File

@ -55,7 +55,7 @@ export class BitcoinRpcService {
} }
} }
private async waitForBlock(blockHeight: number) { private async waitForBlock(blockHeight: number): Promise<IBlockTemplate> {
while (true) { while (true) {
await new Promise(r => setTimeout(r, 100)); await new Promise(r => setTimeout(r, 100));
@ -80,21 +80,21 @@ export class BitcoinRpcService {
const { lockedBy } = await this.rpcBlockService.lockBlock(blockHeight, process.env.NODE_APP_INSTANCE); const { lockedBy } = await this.rpcBlockService.lockBlock(blockHeight, process.env.NODE_APP_INSTANCE);
if (lockedBy != process.env.NODE_APP_INSTANCE) { if (lockedBy != process.env.NODE_APP_INSTANCE) {
await this.waitForBlock(blockHeight); result = await this.waitForBlock(blockHeight);
return; } else {
}
result = await this.client.getblocktemplate({ result = await this.client.getblocktemplate({
template_request: { template_request: {
rules: ['segwit'], rules: ['segwit'],
mode: 'template', mode: 'template',
capabilities: ['serverlist', 'proposal'] capabilities: ['serverlist', 'proposal']
} }
}); });
await this.rpcBlockService.saveBlock(blockHeight, JSON.stringify(result)); await this.rpcBlockService.saveBlock(blockHeight, JSON.stringify(result));
}
} else { } else {
//wait for block //wait for block
await this.waitForBlock(blockHeight); result = await this.waitForBlock(blockHeight);
} }