Merge remote-tracking branch 'origin/1912-lisk-service-does-work-against-the-migrated-mainnet1' into 1912-lisk-service-does-work-against-the-migrated-mainnet

Author: nagdahimanshu

services/blockchain-connector/shared/sdk/index.js

@@ -121,6 +121,9 @@ const init = async () => {
 	await cacheRegisteredRewardModule();
 	await cacheFeeConstants();
 	await updateTokenInfo();
+	await getTokenInitializationFees();
+	await getRewardTokenID();
+	await getPosConstants();
 
 	// Download the genesis block, if applicable
 	await getGenesisBlock();

services/blockchain-connector/shared/sdk/token.js

@@ -24,6 +24,7 @@ const logger = Logger();
 let escrowedAmounts;
 let supportedTokens;
 let totalSupply;
+let initializationFees;;
 
 const getTokenBalances = async address => {
 	try {
@@ -98,9 +99,12 @@ const getTotalSupply = async (isForceUpdate = false) => {
 
 const getTokenInitializationFees = async () => {
 	try {
-		const response = await invokeEndpoint('token_getInitializationFees');
-		if (response.error) throw new Error(response.error);
-		return response;
+		if (!initializationFees) {
+			const response = await invokeEndpoint('token_getInitializationFees');
+			if (response.error) throw new Error(response.error);
+			initializationFees = response;
+		}
+		return initializationFees;
 	} catch (err) {
 		if (err.message.includes(timeoutMessage)) {
 			throw new TimeoutException("Request timed out when calling 'getTokenInitializationFees'.");

services/blockchain-indexer/shared/dataService/knownAccounts.js

@@ -62,10 +62,10 @@ const reloadAccountKnowledge = async () => {
 				}
 			} else {
 				logger.warn('Lisk static URL did not respond with valid data.');
-				logger.debug(`Recieved: ${util.inspect(res)}.`);
+				logger.debug(`Received: ${util.inspect(res)}.`);
 			}
 		} else {
-			logger.warn(`Static information anavailable for the current chainID: ${chainID}.`);
+			logger.warn(`Static information unavailable for the current chainID: ${chainID}.`);
 		}
 	} catch (err) {
 		logger.error(`Could not reload known accounts: ${err.message}.`);

services/blockchain-indexer/shared/indexer/genesisBlock.js

@@ -44,6 +44,7 @@ const allAccountsAddresses = [];
 let isTokensBalanceIndexed = false;
 
 const indexTokenModuleAssets = async dbTrx => {
+	logger.info('Starting to index the genesis assets from the Token module.');
 	const genesisBlockAssetsLength = await requestConnector('getGenesisAssetsLength', {
 		module: MODULE.TOKEN,
 		subStore: MODULE_SUB_STORE.TOKEN.USER,
@@ -75,9 +76,13 @@ const indexTokenModuleAssets = async dbTrx => {
 	}
 
 	await updateTotalLockedAmounts(tokenIDLockedAmountChangeMap, dbTrx);
+	logger.info('Finished indexing all the genesis assets from the Token module.');
 };
 
 const indexPosValidatorsInfo = async (numValidators, dbTrx) => {
+	logger.debug(
+		'Starting to index the PoS Validators information from the genesis PoS module assets.',
+	);
 	if (numValidators > 0) {
 		const commissionsTable = await getCommissionsTable();
 
@@ -99,9 +104,13 @@ const indexPosValidatorsInfo = async (numValidators, dbTrx) => {
 
 		await commissionsTable.upsert(commissionEntries, dbTrx);
 	}
+	logger.debug(
+		'Finished indexing the PoS Validators information from the genesis PoS module assets.',
+	);
 };
 
 const indexPosStakesInfo = async (numStakers, dbTrx) => {
+	logger.debug('Starting to index the PoS stakes information from the genesis PoS module assets.');
 	let totalStake = BigInt(0);
 	let totalSelfStake = BigInt(0);
 
@@ -144,9 +153,11 @@ const indexPosStakesInfo = async (numStakers, dbTrx) => {
 
 	await updateTotalSelfStake(totalSelfStake, dbTrx);
 	logger.info(`Updated total self-stakes information at genesis: ${totalSelfStake.toString()}.`);
+	logger.debug('Finished indexing the PoS stakes information from the genesis PoS module assets.');
 };
 
 const indexPosModuleAssets = async dbTrx => {
+	logger.info('Starting to index the genesis assets from the PoS module.');
 	const genesisBlockAssetsLength = await requestConnector('getGenesisAssetsLength', {
 		module: MODULE.POS,
 	});
@@ -155,11 +166,14 @@ const indexPosModuleAssets = async dbTrx => {
 
 	await indexPosValidatorsInfo(numValidators, dbTrx);
 	await indexPosStakesInfo(numStakers, dbTrx);
+	logger.info('Finished indexing all the genesis assets from the PoS module.');
 };
 
 const indexGenesisBlockAssets = async dbTrx => {
+	logger.info('Starting to index the genesis assets.');
 	await indexTokenModuleAssets(dbTrx);
 	await indexPosModuleAssets(dbTrx);
+	logger.info('Finished indexing all the genesis assets.');
 };
 
 const indexTokenBalances = async () => {

services/blockchain-indexer/tests/unit/shared/dataservice/knownAccounts.test.js

@@ -149,7 +149,7 @@ describe('reloadAccountKnowledge', () => {
 					info: jest.fn(),
 					warn: async data =>
 						expect(data).toEqual(
-							'Static information anavailable for the current chainID: invalidChainID.',
+							'Static information unavailable for the current chainID: invalidChainID.',
 						),
 					error: jest.fn(),
 				}),