Method parse

server/src/modules/block_parser.js:122–178

* Saves a new block or retries reward distribution for an unprocessed block. * @param {object} block Forged block returned by the ADAMANT node API * @returns {Promise }

(block)

   * @returns {Promise<void>}
   */
  async parse(block) {
    const { id, height } = block;

    // Untrusted node data: the block id is used directly in MongoDB filters, so a
    // non-scalar id from a malformed or malicious response could become an operator
    // query (NoSQL injection). Only a string or finite number is a safe block id.
    if (typeof id !== 'string' && !Number.isFinite(id)) {
      log.warn('Skipping a forged block with a missing or malformed id from the node response.');
      return;
    }

    let savedBlock;
    try {
      savedBlock = await mongo.blocksCollection.findOne({ id });
    } catch (error) {
      log.error(`Failed to parse block ${id} at height ${height}: ${error}`);
      return;
    }

    if (savedBlock) {
      if (!savedBlock.processed) {
        log.info(`Re-trying to distribute rewards for block ${id} (height ${height})…`);

        const rewardDistributor = new RewardDistributor({
          ...block,
          ...savedBlock,
        });

        await rewardDistributor.distribute();
      }
    } else {
      log.info(`New block forged: ${id} (height ${height}).`);

      try {
        await mongo.blocksCollection.insertOne({
          ...block,
          processed: false,
          rewardedAddresses: [],
        });
      } catch (error) {
        log.error(`Failed to parse block ${id} at height ${height}: ${error}`);
        return;
      }

      log.info(
          `Forged block successfully stored: ${id} (height ${height}). Distributing rewards…`,
      );

      const rewardDistributor = new RewardDistributor({
        ...block,
        processed: false,
        rewardedAddresses: [],
      });

      await rewardDistributor.distribute();
    }
  }
}