Function filterCommitEvents

src/nit.ts:435–453

(assetCid: string, blockchainInfo, fromIndex, toIndex)

}

export async function filterCommitEvents(assetCid: string, blockchainInfo, fromIndex, toIndex) {
  /* Have 3 more keys than eventLog in iterateCommitEvents: event, eventSignature, args
   *
   * keys:
   *   blockNumber, blockHash, transactionIndex, removed, address, data, topics
   *   transactionHash, logIndex, event, eventSignature, args
   */
  const commitBlockNumbers = (await getCommitBlockNumbers(assetCid, blockchainInfo)).slice(fromIndex, toIndex);
  const commitAmount = commitBlockNumbers.length;

  if (commitAmount == 0) { return []; }

  const filter = await blockchainInfo.contract.filters.Commit(null, assetCid);
  filter.fromBlock = commitBlockNumbers[0];
  filter.toBlock = commitBlockNumbers[commitAmount - 1];

  let events = await blockchainInfo.contract.queryFilter(filter, filter.fromBlock, filter.toBlock);
  return events;
}

export async function iterateCommitEvents(assetCid: string, blockchainInfo, fromIndex, toIndex) {
  /* Get Commit events by using low-level event logs.