Remove logs (#212)

Remove logs since they're not needed anymore.

Author: fracek

change/@apibara-evm-rpc-542353e8-0ece-4da1-bd53-74fbee1edd39.json

@@ -0,0 +1,7 @@
+{
+  "type": "prerelease",
+  "comment": "remove logs",
+  "packageName": "@apibara/evm-rpc",
+  "email": "francesco@ceccon.me",
+  "dependentChangeType": "patch"
+}

change/@apibara-protocol-dfd66373-41c7-4c9b-8776-73b5198f24d6.json

@@ -0,0 +1,7 @@
+{
+  "type": "prerelease",
+  "comment": "remove logs",
+  "packageName": "@apibara/protocol",
+  "email": "francesco@ceccon.me",
+  "dependentChangeType": "patch"
+}

packages/evm-rpc/src/stream-config.ts

@@ -128,9 +128,9 @@ export class EvmRpcStream extends RpcStreamConfig<Filter, Block> {
     startBlockNumber,
     endBlockNumber,
   }: FetchCursorRangeArgs): Promise<BlockInfo[]> {
-    console.log(
-      `[EVM] fetchCursorRange: start=${startBlockNumber} end=${endBlockNumber}`,
-    );
+    // console.log(
+    //   `[EVM] fetchCursorRange: start=${startBlockNumber} end=${endBlockNumber}`,
+    // );
 
     const requestCount = Number(endBlockNumber - startBlockNumber + 1n);
     return await Promise.all(
@@ -164,7 +164,7 @@ export class EvmRpcStream extends RpcStreamConfig<Filter, Block> {
       toBlock = newToBlock;
     }
 
-    console.log(`[EVM] fetchBlockRange: start=${fromBlock} end=${toBlock}`);
+    // console.log(`[EVM] fetchBlockRange: start=${fromBlock} end=${toBlock}`);
 
     const { logs: logsByBlockNumber, blockNumbers } =
       await this.fetchLogsForRangeWithRetry({
@@ -223,7 +223,7 @@ export class EvmRpcStream extends RpcStreamConfig<Filter, Block> {
   async fetchHeaderByHash({
     blockHash,
   }: FetchBlockByHashArgs<Filter>): Promise<FetchBlockByHashResult<Block>> {
-    console.log(`[EVM] fetchBlockByHash: hash=${blockHash}`);
+    // console.log(`[EVM] fetchBlockByHash: hash=${blockHash}`);
     // Fetch block header and check it matches the expected parent block hash.
     const { header } = await this.fetchBlockHeaderByHashWithRetry({
       blockHash,

packages/protocol/src/rpc/chain-tracker.ts

@@ -55,9 +55,9 @@ export class ChainTracker {
   }
 
   updateFinalized(newFinalized: BlockInfo) {
-    console.log(
-      `[CT] updateFinalized: new=${newFinalized.blockNumber} old=${this.#finalized.blockNumber}`,
-    );
+    // console.log(
+    //   `[CT] updateFinalized: new=${newFinalized.blockNumber} old=${this.#finalized.blockNumber}`,
+    // );
 
     if (newFinalized.blockNumber < this.#finalized.blockNumber) {
       throw new Error("Finalized cursor moved backwards");
@@ -87,7 +87,7 @@ export class ChainTracker {
   }
 
   addToCanonicalChain({ blockInfo }: { blockInfo: BlockInfo }) {
-    console.log(`[CT] addToCanonicalChain: block=${blockInfo.blockNumber}`);
+    // console.log(`[CT] addToCanonicalChain: block=${blockInfo.blockNumber}`);
 
     const existing = this.#canonical.get(blockInfo.blockNumber);
 
@@ -120,9 +120,9 @@ export class ChainTracker {
     fetchCursorByHash,
     fetchCursorRange,
   }: UpdateHeadArgs): Promise<UpdateHeadResult> {
-    console.log(
-      `[CT] updateHead: new=${newHead.blockNumber} old=${this.#head.blockNumber}`,
-    );
+    // console.log(
+    //   `[CT] updateHead: new=${newHead.blockNumber} old=${this.#head.blockNumber}`,
+    // );
 
     // No changes to the chain.
     if (
@@ -205,9 +205,9 @@ export class ChainTracker {
     // The new chain is longer and we need the missing blocks.
     // This may result in reorgs.
 
-    console.log(
-      `[CT] moving from ${this.#head.blockNumber} to ${newHead.blockNumber} (${newHead.blockNumber - this.#head.blockNumber} blocks)`,
-    );
+    // console.log(
+    //   `[CT] moving from ${this.#head.blockNumber} to ${newHead.blockNumber} (${newHead.blockNumber - this.#head.blockNumber} blocks)`,
+    // );
 
     let currentBlockNumber = this.#head.blockNumber + 1n;
 

packages/protocol/src/rpc/data-stream.ts

@@ -149,9 +149,9 @@ async function* dataStreamLoop<TFilter, TBlock>(
 
     const finalized = chainTracker.finalized();
 
-    console.log(
-      `[DS] RpcLoop: c=${cursor.orderKey} f=${finalized.orderKey} h=${chainTracker.head().orderKey}`,
-    );
+    // console.log(
+    //   `[DS] RpcLoop: c=${cursor.orderKey} f=${finalized.orderKey} h=${chainTracker.head().orderKey}`,
+    // );
 
     if (cursor.orderKey < finalized.orderKey) {
       yield* backfillFinalizedBlocks(state);