gravatite/public-pool
1
0
Fork 0
mirror of https://github.com/benjamin-wilson/public-pool.git synced 2026-09-29 09:05:06 -07:00
Code Issues Packages Projects Releases Wiki Activity

re-add zmq with pre-built binaries and pinned version

Browse Source
This commit is contained in:
Ben Wilson
2024-01-23 21:24:33 -05:00
parent a98ec3879e
commit dadb03ed1c
3 changed files with 114 additions and 77 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/services/bitcoin-rpc.service.ts
+8 -9
View File
@@ -3,12 +3,11 @@ import { ConfigService } from '@nestjs/config';
import { RPCClient } from 'rpc-bitcoin';
import { BehaviorSubject, filter, shareReplay } from 'rxjs';
import { RpcBlockService } from 'src/ORM/rpc-block/rpc-block.service';
import * as zmq from 'zeromq/v5-compat';
import { IBlockTemplate } from '../models/bitcoin-rpc/IBlockTemplate';
import { IMiningInfo } from '../models/bitcoin-rpc/IMiningInfo';
// import * as zmq from 'zeromq';
@Injectable()
export class BitcoinRpcService {
@@ -37,13 +36,13 @@ export class BitcoinRpcService {
});
if (this.configService.get('BITCOIN_ZMQ_HOST')) {
// const sock = zmq.socket("sub");
// sock.connect(this.configService.get('BITCOIN_ZMQ_HOST'));
// sock.subscribe("rawblock");
// sock.on("message", async (topic: Buffer, message: Buffer) => {
// console.log("new block zmq");
// this.pollMiningInfo();
// });
const sock = zmq.socket("sub");
sock.connect(this.configService.get('BITCOIN_ZMQ_HOST'));
sock.subscribe("rawblock");
sock.on("message", async (topic: Buffer, message: Buffer) => {
console.log("new block zmq");
this.pollMiningInfo();
});
this.pollMiningInfo();
} else {
setInterval(this.pollMiningInfo.bind(this), 500);