From df1a603e15173000caccd80b8fd9f80e0662c93d Mon Sep 17 00:00:00 2001 From: benesjan Date: Thu, 12 Oct 2023 12:22:34 +0000 Subject: [PATCH] better naming --- .../archiver/src/archiver/archiver.ts | 42 +++++++++---------- 1 file changed, 21 insertions(+), 21 deletions(-) diff --git a/yarn-project/archiver/src/archiver/archiver.ts b/yarn-project/archiver/src/archiver/archiver.ts index 754db2761e6..9fd05cd1830 100644 --- a/yarn-project/archiver/src/archiver/archiver.ts +++ b/yarn-project/archiver/src/archiver/archiver.ts @@ -49,17 +49,17 @@ export class Archiver implements L2BlockSource, L2LogsSource, ContractDataSource /** * Next L1 block number to fetch `L2BlockProcessed` logs from (i.e. `fromBlock` in eth_getLogs). */ - private nextL2BlockFromBlock = 0n; + private nextL2BlockFromL1Block = 0n; /** * Last Processed Block Number */ - private lastProcessedBlockNumber = 0n; + private lastProcessedL1BlockNumber = 0n; /** * Use this to track logged block in order to avoid repeating the same message. */ - private lastLoggedBlockNumber = 0n; + private lastLoggedL1BlockNumber = 0n; /** * Creates a new instance of the Archiver. @@ -84,8 +84,8 @@ export class Archiver implements L2BlockSource, L2LogsSource, ContractDataSource private readonly pollingIntervalMs = 10_000, private readonly log: DebugLogger = createDebugLogger('aztec:archiver'), ) { - this.nextL2BlockFromBlock = BigInt(searchStartBlock); - this.lastProcessedBlockNumber = BigInt(searchStartBlock); + this.nextL2BlockFromL1Block = BigInt(searchStartBlock); + this.lastProcessedL1BlockNumber = BigInt(searchStartBlock); } /** @@ -139,12 +139,12 @@ export class Archiver implements L2BlockSource, L2LogsSource, ContractDataSource * @param blockUntilSynced - If true, blocks until the archiver has fully synced. */ private async sync(blockUntilSynced: boolean) { - const currentBlockNumber = await this.publicClient.getBlockNumber(); - if (currentBlockNumber <= this.lastProcessedBlockNumber) { + const currentL1BlockNumber = await this.publicClient.getBlockNumber(); + if (currentL1BlockNumber <= this.lastProcessedL1BlockNumber) { // reducing logs, otherwise this gets triggered on every loop (1s) - if (currentBlockNumber !== this.lastLoggedBlockNumber) { - this.log(`No new blocks to process, current block number: ${currentBlockNumber}`); - this.lastLoggedBlockNumber = currentBlockNumber; + if (currentL1BlockNumber !== this.lastLoggedL1BlockNumber) { + this.log(`No new blocks to process, current block number: ${currentL1BlockNumber}`); + this.lastLoggedL1BlockNumber = currentL1BlockNumber; } return; } @@ -183,15 +183,15 @@ export class Archiver implements L2BlockSource, L2LogsSource, ContractDataSource this.publicClient, this.inboxAddress, blockUntilSynced, - this.lastProcessedBlockNumber + 1n, // + 1 to prevent re-including messages from the last processed block - currentBlockNumber, + this.lastProcessedL1BlockNumber + 1n, // + 1 to prevent re-including messages from the last processed block + currentL1BlockNumber, ); const retrievedCancelledL1ToL2Messages = await retrieveNewCancelledL1ToL2Messages( this.publicClient, this.inboxAddress, blockUntilSynced, - this.lastProcessedBlockNumber + 1n, - currentBlockNumber, + this.lastProcessedL1BlockNumber + 1n, + currentL1BlockNumber, ); // TODO (#717): optimise this - there could be messages in confirmed that are also in pending. @@ -203,21 +203,21 @@ export class Archiver implements L2BlockSource, L2LogsSource, ContractDataSource this.log('Removing pending l1 to l2 messages from store where messages were cancelled'); await this.store.cancelPendingL1ToL2Messages(retrievedCancelledL1ToL2Messages.retrievedData); - this.lastProcessedBlockNumber = currentBlockNumber; + this.lastProcessedL1BlockNumber = currentL1BlockNumber; // ********** Events that are processed per block ********** // Read all data from chain and then write to our stores at the end const nextExpectedL2BlockNum = BigInt((await this.store.getBlockNumber()) + 1); this.log( - `Retrieving chain state from L1 block: ${this.nextL2BlockFromBlock}, next expected l2 block number: ${nextExpectedL2BlockNum}`, + `Retrieving chain state from L1 block: ${this.nextL2BlockFromL1Block}, next expected l2 block number: ${nextExpectedL2BlockNum}`, ); const retrievedBlocks = await retrieveBlocks( this.publicClient, this.rollupAddress, blockUntilSynced, - this.nextL2BlockFromBlock, - currentBlockNumber, + this.nextL2BlockFromL1Block, + currentL1BlockNumber, nextExpectedL2BlockNum, ); @@ -230,8 +230,8 @@ export class Archiver implements L2BlockSource, L2LogsSource, ContractDataSource this.publicClient, this.contractDeploymentEmitterAddress, blockUntilSynced, - this.nextL2BlockFromBlock, - currentBlockNumber, + this.nextL2BlockFromL1Block, + currentL1BlockNumber, blockHashMapping, ); if (retrievedBlocks.retrievedData.length === 0) { @@ -276,7 +276,7 @@ export class Archiver implements L2BlockSource, L2LogsSource, ContractDataSource ); // set the L1 block for the next search - this.nextL2BlockFromBlock = retrievedBlocks.nextEthBlockNumber; + this.nextL2BlockFromL1Block = retrievedBlocks.nextEthBlockNumber; } /**