Skip to content

Commit

Permalink
refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
mehdi-aouadi committed Oct 16, 2024
1 parent 6a42ffc commit a5b7a08
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,7 @@
import tech.pegasys.teku.storage.server.pruner.StatePruner;

public class StorageService extends Service implements StorageServiceFacade {
public static final Duration STATE_PRUNING_INTERVAL = Duration.ofMinutes(1);
private final StorageConfiguration config;
private volatile ChainStorage chainStorage;
private final ServiceConfig serviceConfig;
Expand Down Expand Up @@ -143,7 +144,7 @@ protected SafeFuture<?> doStart() {
config
.getStatePruningInterval()
.equals(StorageConfiguration.DEFAULT_STATE_PRUNING_INTERVAL)
? Duration.ofMinutes(1)
? STATE_PRUNING_INTERVAL
: config.getStatePruningInterval();
configureStatePruner(
StorageConfiguration.DEFAULT_STORAGE_RETAINED_SLOTS,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ void shouldSetupStatePrunerWhenPruneMode() {
assertThat(maybeStatePruner).isPresent();
final StatePruner statePruner = maybeStatePruner.get();
assertThat(statePruner.isRunning()).isTrue();
assertThat(statePruner.getPruneInterval()).isEqualTo(Duration.ofMinutes(1));
assertThat(statePruner.getPruneInterval()).isEqualTo(StorageService.STATE_PRUNING_INTERVAL);
}

@Test
Expand All @@ -125,7 +125,7 @@ void shouldSetupStatePrunerWhenMinimalMode() {
assertThat(maybeStatePruner).isPresent();
final StatePruner statePruner = maybeStatePruner.get();
assertThat(statePruner.isRunning()).isTrue();
assertThat(statePruner.getPruneInterval()).isEqualTo(Duration.ofMinutes(1));
assertThat(statePruner.getPruneInterval()).isEqualTo(StorageService.STATE_PRUNING_INTERVAL);
}

@Test
Expand Down

0 comments on commit a5b7a08

Please sign in to comment.