application.ts

import { Blockchain } from '@liskhq/lisk-blockchain';
import { DB } from '@liskhq/lisk-db';
import { DPOS } from '@liskhq/lisk-dpos';
import { P2P } from '@liskhq/lisk-p2p';
import * as transactions from '@liskhq/lisk-transactions';
import * as bunyan from 'bunyan';
import * as fs from 'fs';
import * as crypto from 'crypto';
import * as os from 'os';
import { Sync } from './sync';

export class App {
	private readonly _p2p: P2P;
	private readonly _blockchain: Blockchain;
	private readonly _dpos: DPOS;
	private readonly _db: DB;
	private readonly _logger: bunyan;
	private _initialized: boolean;
	private readonly _sync: Sync;

	public constructor() {
		this._initialized = false;
		this._logger = bunyan.createLogger({ name: 'lisk-node' });
		this._logger.info('Starting application');

		const genesisStr = fs.readFileSync(
			`${__dirname}/../configs/mainnet/genesis_block.json`,
			'utf8',
		);
		this._logger.info('Genesis block file obtained');
		const genesis = JSON.parse(genesisStr);
		this._p2p = new P2P({
			blacklistedPeers: [],
			connectTimeout: 5000,
			ackTimeout: 15000,
			seedPeers: [
				{
					ipAddress: '83.136.254.92',
					wsPort: 8001,
				},
				{
					ipAddress: '83.136.249.76',
					wsPort: 8001,
				},
			],
			wsEngine: 'ws',
			nodeInfo: {
				wsPort: 8001,
				nethash: genesis.payloadHash,
				version: '1.4.1',
				os: os.platform(),
				height: 1,
				httpPort: 8000,
				broadhash:
					'2768b267ae621a9ed3b3034e2e8a1bed40895c621bbb1bbd613d92b9d24e54b5',
				nonce: crypto.randomBytes(8).toString('hex'),
			},
		});
		this._db = new DB('./blockchain.db');
		this._logger.info('Database instansiated');
		this._blockchain = new Blockchain(genesis, this._db, {
			0: transactions.TransferTransaction,
			1: transactions.SecondSignatureTransaction,
			2: transactions.DelegateTransaction,
			3: transactions.VoteTransaction,
			4: transactions.MultisignatureTransaction,
			5: transactions.DappTransaction,
			6: transactions.InTransferTransaction,
			7: transactions.OutTransferTransaction,
		});
		this._logger.info('Blockchain instansiated');
		this._dpos = new DPOS(this._db, this._blockchain);
		this._logger.info('DPOS instansiated');
		this._sync = new Sync(
			this._blockchain,
			this._dpos,
			this._p2p,
			this._logger,
		);
	}

	public async init(): Promise<void> {
		this._logger.info('Starting initialization');
		await this._blockchain.init();
		this._logger.info('Blockchain initialized.');
		await this._dpos.init(this._blockchain.lastBlock);
		this._logger.info('DPOS initialized.');
		this._initialized = true;
		this._logger.info('Finished initialized.');
	}

	public async start(): Promise<void> {
		await this._p2p.start();
		await this._sync.start();
	}

	public async stop(): Promise<void> {
		if (this._initialized) {
			await this._p2p.stop();
			await this._db.close();
		}
	}
}