@@ -462,21 +462,25 @@ func (u *Updater) addSettlement(
462462
463463 return nil
464464}
465-
466465func (u * Updater ) getL1Txns (ctx context.Context , blockNum uint64 ) (map [string ]TxMetadata , error ) {
467466 txns , ok := u .l1BlockCache .Get (blockNum )
468467 if ok {
469468 u .metrics .BlockTxnCacheHits .Inc ()
469+ u .logger .Info ("cache hit for block transactions" , "blockNum" , blockNum )
470470 return txns , nil
471471 }
472472
473473 u .metrics .BlockTxnCacheMisses .Inc ()
474+ u .logger .Info ("cache miss for block transactions" , "blockNum" , blockNum )
474475
475476 block , err := u .l1Client .BlockByNumber (ctx , big .NewInt (0 ).SetUint64 (blockNum ))
476477 if err != nil {
478+ u .logger .Error ("failed to get block by number" , "blockNum" , blockNum , "error" , err )
477479 return nil , fmt .Errorf ("failed to get block by number: %w" , err )
478480 }
479481
482+ u .logger .Info ("retrieved block" , "blockNum" , blockNum , "blockHash" , block .Hash ().Hex ())
483+
480484 var txnReceipts sync.Map
481485 eg , ctx := errgroup .WithContext (ctx )
482486
@@ -502,39 +506,49 @@ func (u *Updater) getL1Txns(ctx context.Context, blockNum uint64) (map[string]Tx
502506 for _ , bucket := range buckets {
503507 eg .Go (func () error {
504508 start := time .Now ()
509+ u .logger .Info ("requesting batch receipts" , "bucketSize" , len (bucket ))
505510 results , err := u .receiptBatcher .BatchReceipts (ctx , bucket )
506511 if err != nil {
512+ u .logger .Error ("failed to get batch receipts" , "error" , err )
507513 return fmt .Errorf ("failed to get batch receipts: %w" , err )
508514 }
509515 u .metrics .TxnReceiptRequestDuration .Observe (time .Since (start ).Seconds ())
516+ u .logger .Info ("received batch receipts" , "duration" , time .Since (start ).Seconds ())
510517 for _ , result := range results {
511518 if result .Err != nil {
519+ u .logger .Error ("failed to get receipt for txn" , "txnHash" , result .Receipt .TxHash .Hex (), "error" , result .Err )
512520 return fmt .Errorf ("failed to get receipt for txn: %s" , result .Err )
513521 }
514522
515523 txnReceipts .Store (result .Receipt .TxHash .Hex (), result .Receipt )
524+ u .logger .Info ("stored receipt" , "txnHash" , result .Receipt .TxHash .Hex ())
516525 }
517526
518527 return nil
519528 })
520529 }
521530
522531 if err := eg .Wait (); err != nil {
532+ u .logger .Error ("error while waiting for batch receipts" , "error" , err )
523533 return nil , err
524534 }
525535
526536 u .metrics .TxnReceiptRequestBlockDuration .Observe (time .Since (blockStart ).Seconds ())
537+ u .logger .Info ("completed batch receipt requests for block" , "blockNum" , blockNum , "duration" , time .Since (blockStart ).Seconds ())
527538
528539 txnsMap := make (map [string ]TxMetadata )
529540 for i , tx := range txnsArray {
530541 receipt , ok := txnReceipts .Load (tx .Hex ())
531542 if ! ok {
543+ u .logger .Error ("receipt not found for txn" , "txnHash" , tx .Hex ())
532544 return nil , fmt .Errorf ("receipt not found for txn: %s" , tx )
533545 }
534546 txnsMap [strings .TrimPrefix (tx .Hex (), "0x" )] = TxMetadata {PosInBlock : i , Succeeded : receipt .(* types.Receipt ).Status == types .ReceiptStatusSuccessful }
547+ u .logger .Info ("added txn to map" , "txnHash" , tx .Hex (), "posInBlock" , i , "succeeded" , receipt .(* types.Receipt ).Status == types .ReceiptStatusSuccessful )
535548 }
536549
537550 _ = u .l1BlockCache .Add (blockNum , txnsMap )
551+ u .logger .Info ("added block transactions to cache" , "blockNum" , blockNum )
538552
539553 return txnsMap , nil
540554}
0 commit comments