Nimiq Insight API

nimiq-insight.js

const START = Date.now();
const Nimiq = require('@nimiq/core');

require('dotenv').config();

const config = {
	protocol: "dumb",
	network: process.env.NETWORK || "main",
	type: "nano"
};

const io = require("socket.io");
const server = io.listen(process.env.PORT);

// event fired every time a new client connects:
server.on("connection", (socket) => {
	console.info(`Client connected [id=${socket.id}]`);

	socket.on("disconnect", () => {
		console.info(`Client gone [id=${socket.id}]`);
	});

	socket.on("subscribe", (data) => {
		socket.join(data, () => {
			console.info(`Subscribed ${data}`);
		});
	});

	socket.on("unsubscribe", (data) => {
		socket.leave(data, () => {
			console.info(`Unsubscribed ${data}`);
		});
	});
});

/*
// sends test transactions
const dummy = {
	txid: "...",
	value: 123,
	recipient: "NQ..."
};

setInterval(() => {
	server.to('inv').emit('tx', dummy);
}, 5000);
*/

if (!Nimiq.GenesisConfig.CONFIGS[config.network]) {
	console.error(`Invalid network name: ${config.network}`);
	process.exit(1);
}

const TAG = 'Node';
const $ = {};

(async () => {
	Nimiq.GenesisConfig.init(Nimiq.GenesisConfig.CONFIGS[config.network]);

	let networkConfig = new Nimiq.DumbNetworkConfig();

	$.consensus = await Nimiq.Consensus.nano(networkConfig);

	$.blockchain = $.consensus.blockchain;
	$.network = $.consensus.network;

	Nimiq.Log.i(TAG, `Blockchain state: height=${$.blockchain.height}, headHash=${$.blockchain.headHash}`);

	$.blockchain.on('head-changed', async (head) => {
		if ($.consensus.established) {
			const hash = await $.consensus.getHeadHash();
			const block = await $.consensus.getBlock(hash, true);
			const transactions = block.body.transactions;
			for (const transaction of transactions) {
				const address = transaction.recipient.toUserFriendlyAddress()
				const data = {
					txid: transaction.hash().toPlain(),
					value: transaction.value,
					recipient: address
				};
				server.to(address.replace(/ /g,'')).emit('tx', data);
				console.log(`TX sent ${data.txid}`);
			}
		}
	});

	$.network.connect();

	$.consensus.on('established', () => {
		Nimiq.Log.i(TAG, `Blockchain ${config.type}-consensus established in ${(Date.now() - START) / 1000}s.`);
		Nimiq.Log.i(TAG, `Current state: height=${$.blockchain.height}, totalWork=${$.blockchain.totalWork}, headHash=${$.blockchain.headHash}`);
	});
})().catch(e => {
	console.error(e);
	process.exit(1);
});