Skip to content

Commit 064f48a

Browse files
committed
Fix address-filter configci
1 parent ddaf146 commit 064f48a

File tree

2 files changed

+13
-14
lines changed

2 files changed

+13
-14
lines changed

execution/gethexec/node.go

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@ import (
1212
"sync/atomic"
1313
"time"
1414

15-
"github.com/offchainlabs/nitro/address-filter"
1615
"github.com/spf13/pflag"
1716

1817
"github.com/ethereum/go-ethereum/arbitrum"
@@ -29,6 +28,7 @@ import (
2928
"github.com/ethereum/go-ethereum/params"
3029
"github.com/ethereum/go-ethereum/rpc"
3130

31+
addressfilter "github.com/offchainlabs/nitro/address-filter"
3232
"github.com/offchainlabs/nitro/arbos/arbostypes"
3333
"github.com/offchainlabs/nitro/arbos/programs"
3434
"github.com/offchainlabs/nitro/arbutil"
@@ -138,7 +138,7 @@ type Config struct {
138138
ExposeMultiGas bool `koanf:"expose-multi-gas"`
139139
RPCServer rpcserver.Config `koanf:"rpc-server"`
140140
ConsensusRPCClient rpcclient.ClientConfig `koanf:"consensus-rpc-client" reload:"hot"`
141-
addressfilter addressfilter.Config `koanf:"address-filter" reload:"hot"`
141+
AddressFilter addressfilter.Config `koanf:"address-filter" reload:"hot"`
142142

143143
forwardingTarget string
144144
}
@@ -170,7 +170,7 @@ func (c *Config) Validate() error {
170170
if err := c.ConsensusRPCClient.Validate(); err != nil {
171171
return fmt.Errorf("error validating ConsensusRPCClient config: %w", err)
172172
}
173-
if err := c.addressfilter.Validate(); err != nil {
173+
if err := c.AddressFilter.Validate(); err != nil {
174174
return fmt.Errorf("error validating addressfilter config: %w", err)
175175
}
176176
return nil
@@ -244,7 +244,7 @@ var ConfigDefault = Config{
244244
WebsocketMessageSizeLimit: 256 * 1024 * 1024,
245245
},
246246

247-
addressfilter: addressfilter.DefaultConfig,
247+
AddressFilter: addressfilter.DefaultConfig,
248248
}
249249

250250
type ConfigFetcher interface {
@@ -270,7 +270,7 @@ type ExecutionNode struct {
270270
started atomic.Bool
271271
bulkBlockMetadataFetcher *BulkBlockMetadataFetcher
272272
consensusRPCClient *consensusrpcclient.ConsensusRPCClient
273-
addressfilterService *addressfilter.Service
273+
addressFilterService *addressfilter.Service
274274
}
275275

276276
func CreateExecutionNode(
@@ -365,7 +365,7 @@ func CreateExecutionNode(
365365

366366
bulkBlockMetadataFetcher := NewBulkBlockMetadataFetcher(l2BlockChain, execEngine, config.BlockMetadataApiCacheSize, config.BlockMetadataApiBlocksLimit)
367367

368-
addressfilterService, err := addressfilter.NewService(ctx, &config.addressfilter)
368+
addressFilterService, err := addressfilter.NewService(ctx, &config.AddressFilter)
369369
if err != nil {
370370
return nil, fmt.Errorf("failed to create restricted addr service: %w", err)
371371
}
@@ -385,7 +385,7 @@ func CreateExecutionNode(
385385
ParentChainReader: parentChainReader,
386386
ClassicOutbox: classicOutbox,
387387
bulkBlockMetadataFetcher: bulkBlockMetadataFetcher,
388-
addressfilterService: addressfilterService,
388+
addressFilterService: addressFilterService,
389389
}
390390

391391
if config.ConsensusRPCClient.URL != "" {
@@ -477,8 +477,8 @@ func (n *ExecutionNode) Initialize(ctx context.Context) error {
477477
if err != nil {
478478
return fmt.Errorf("error setting sync backend: %w", err)
479479
}
480-
if n.addressfilterService != nil {
481-
if err = n.addressfilterService.Initialize(ctx); err != nil {
480+
if n.addressFilterService != nil {
481+
if err = n.addressFilterService.Initialize(ctx); err != nil {
482482
return fmt.Errorf("error initializing restricted addr service: %w", err)
483483
}
484484
}
@@ -516,8 +516,8 @@ func (n *ExecutionNode) Start(ctxIn context.Context) error {
516516
}
517517
n.bulkBlockMetadataFetcher.Start(ctx)
518518

519-
if n.addressfilterService != nil {
520-
n.addressfilterService.Start(ctx)
519+
if n.addressFilterService != nil {
520+
n.addressFilterService.Start(ctx)
521521
}
522522
return nil
523523
}
@@ -549,8 +549,8 @@ func (n *ExecutionNode) StopAndWait() {
549549
// }
550550
n.StopWaiter.StopAndWait()
551551

552-
if n.addressfilterService != nil && n.addressfilterService.Started() {
553-
n.addressfilterService.StopAndWait()
552+
if n.addressFilterService != nil && n.addressFilterService.Started() {
553+
n.addressFilterService.StopAndWait()
554554
}
555555
}
556556

util/s3syncer/syncer.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,6 @@ type Syncer struct {
2626
config *Config
2727
downloadConfig DownloadConfig
2828
handleData DataHandler
29-
tempFilePrefix string
3029
digestETag string
3130
mutex sync.Mutex
3231
}

0 commit comments

Comments
 (0)