[submitter] track oldest pending txes age per chain

[trajan0x]

For each chain id track oldest pending nonce.

[greptile-apps]

To track the oldest pending transaction age per chain, follow these steps:

1. Add a field to chainQueue struct in chain_queue.go:

// chainQueue is a single use queue for a single chain.
type chainQueue struct {
    // ... existing fields
    oldestPendingTxAge time.Duration
}

2. Update chainPendingQueue method in chain_queue.go to calculate the oldest pending transaction age:

func (t *txSubmitterImpl) chainPendingQueue(parentCtx context.Context, chainID *big.Int, txes []db.TX) (err error) {
    // ... existing code

    // Calculate the oldest pending transaction age
    if len(txes) > 0 {
        oldestTx := txes[0]
        for _, tx := range txes {
            if tx.CreationTime().Before(oldestTx.CreationTime()) {
                oldestTx = tx
            }
        }
        cq.oldestPendingTxAge = time.Since(oldestTx.CreationTime())
    }

    // ... existing code
}

3. Expose the oldest pending transaction age in txSubmitterImpl struct in submitter.go:

// txSubmitterImpl is the implementation of the transaction submitter.
type txSubmitterImpl struct {
    // ... existing fields
    oldestPendingTxAgePerChain *hashmap.Map[uint32, time.Duration]
}

4. Update NewTransactionSubmitter function in submitter.go to initialize the new field:

func NewTransactionSubmitter(metrics metrics.Handler, signer signer.Signer, fetcher ClientFetcher, db db.Service, config config.IConfig) TransactionSubmitter {
    return &txSubmitterImpl{
        // ... existing fields
        oldestPendingTxAgePerChain: hashmap.New[uint32, time.Duration](),
    }
}

5. Store the oldest pending transaction age in chainPendingQueue method in chain_queue.go:

func (t *txSubmitterImpl) chainPendingQueue(parentCtx context.Context, chainID *big.Int, txes []db.TX) (err error) {
    // ... existing code

    // Store the oldest pending transaction age
    if len(txes) > 0 {
        t.oldestPendingTxAgePerChain.Set(uint32(chainID.Int64()), cq.oldestPendingTxAge)
    }

    // ... existing code
}

References

/ethergo/submitter/chain_queue.go
/ethergo/submitter/submitter.go
/ethergo/submitter/db/txdb/store.go

About Greptile

This response provides a starting point for your research, not a precise solution.

Help us improve! Please leave a 👍 if this is helpful and 👎 if it is irrelevant.

Ask Greptile · Edit Issue Bot Settings