Function iterateCommitEvents

src/nit.ts:455–493

(assetCid: string, blockchainInfo, fromIndex, toIndex)

}

export async function iterateCommitEvents(assetCid: string, blockchainInfo, fromIndex, toIndex) {
  /* Get Commit events by using low-level event logs.
   *
   * If a blockchain provider does not support getting events by filter,
   * (e.g., Avalanche), you can use this function.
   *
   * keys in eventLog:
   *   blockNumber, blockHash, transactionIndex, removed, address, data, topics
   *   transactionHash, logIndex,
   * keys in commitEvent:
   *   eventFragment, name, signature, args, topic, 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);
  const abi = [
    "event Commit(address indexed recorder, string indexed assetCid, string commitData)"
  ];
  const commitEventInterface = new ethers.utils.Interface(abi);

  let events = [];

  for (const c of commitBlockNumbers) {
    filter.fromBlock = c;
    filter.toBlock = c;
    const eventLogs = await blockchainInfo.provider.getLogs(filter);

    for (const eventLog of eventLogs) {
      const commitEvent = commitEventInterface.parseLog(eventLog);
      // merge eventLog and commitEvent
      events.push(Object.assign({}, eventLog, commitEvent));
    }
  }

  return events;
}

export async function getCommits(events) {
  const commitDataIndex = 2;