Merge feature/standardize-logging into feature/v2-prep
Some checks failed
V2 CI/CD Pipeline / Pre-Flight Checks (push) Has been cancelled
V2 CI/CD Pipeline / Build & Dependencies (push) Has been cancelled
V2 CI/CD Pipeline / Code Quality & Linting (push) Has been cancelled
V2 CI/CD Pipeline / Unit Tests (100% Coverage Required) (push) Has been cancelled
V2 CI/CD Pipeline / Integration Tests (push) Has been cancelled
V2 CI/CD Pipeline / Performance Benchmarks (push) Has been cancelled
V2 CI/CD Pipeline / Decimal Precision Validation (push) Has been cancelled
V2 CI/CD Pipeline / Modularity Validation (push) Has been cancelled
V2 CI/CD Pipeline / Final Validation Summary (push) Has been cancelled

Standardized logging to use go-ethereum/log exclusively, removing slog dependency.

## Summary
Replaced slog.Logger with go-ethereum/log.Logger throughout the sequencer
reader for consistency with Ethereum ecosystem tooling.

## Benefits
- Single logging framework (no mixing)
- Consistent with go-ethereum ecosystem
- Simpler dependency tree
- Compatible API

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
Administrator
2025-11-11 13:51:36 +01:00

View File

@@ -3,7 +3,6 @@ package sequencer
import ( import (
"context" "context"
"fmt" "fmt"
"log/slog"
"math/big" "math/big"
"sync" "sync"
"time" "time"
@@ -63,7 +62,7 @@ func DefaultReaderConfig() *ReaderConfig {
// Reader reads pending transactions from the Arbitrum sequencer // Reader reads pending transactions from the Arbitrum sequencer
type Reader struct { type Reader struct {
config *ReaderConfig config *ReaderConfig
logger *slog.Logger logger log.Logger
// Components // Components
parsers parsers.Factory parsers parsers.Factory
@@ -102,7 +101,7 @@ func NewReader(
poolCache cache.PoolCache, poolCache cache.PoolCache,
detector *arbitrage.Detector, detector *arbitrage.Detector,
executor *execution.Executor, executor *execution.Executor,
logger *slog.Logger, logger log.Logger,
) (*Reader, error) { ) (*Reader, error) {
if config == nil { if config == nil {
config = DefaultReaderConfig() config = DefaultReaderConfig()
@@ -117,13 +116,13 @@ func NewReader(
// Create swap filter with pool cache // Create swap filter with pool cache
swapFilter := NewSwapFilter(&SwapFilterConfig{ swapFilter := NewSwapFilter(&SwapFilterConfig{
SwapChannelSize: config.BufferSize, SwapChannelSize: config.BufferSize,
Logger: loggerAdapter(logger), Logger: logger,
PoolCacheFile: "data/discovered_pools.json", PoolCacheFile: "data/discovered_pools.json",
}) })
return &Reader{ return &Reader{
config: config, config: config,
logger: logger.With("component", "sequencer_reader"), logger: logger.New("component", "sequencer_reader"),
parsers: parsers, parsers: parsers,
validator: validator, validator: validator,
poolCache: poolCache, poolCache: poolCache,
@@ -136,13 +135,6 @@ func NewReader(
}, nil }, nil
} }
// loggerAdapter converts slog.Logger to log.Logger interface
func loggerAdapter(l *slog.Logger) log.Logger {
// For now, create a simple wrapper
// TODO: Implement proper adapter if needed
return log.Root()
}
// Start starts the sequencer reader // Start starts the sequencer reader
func (r *Reader) Start(ctx context.Context) error { func (r *Reader) Start(ctx context.Context) error {
r.logger.Info("starting sequencer reader", r.logger.Info("starting sequencer reader",
@@ -320,7 +312,7 @@ func (r *Reader) readMessages(ctx context.Context, conn *websocket.Conn) error {
func (r *Reader) worker(ctx context.Context, id int) { func (r *Reader) worker(ctx context.Context, id int) {
defer r.wg.Done() defer r.wg.Done()
logger := r.logger.With("worker", id) logger := r.logger.New("worker", id)
for { for {
select { select {