Skip to content

Commit e7e8985

Browse files
committed
PR comments+ fix
1 parent d3ef6b6 commit e7e8985

File tree

4 files changed

+9
-9
lines changed

4 files changed

+9
-9
lines changed

dd-java-agent/appsec/src/main/java/com/datadog/appsec/config/AppSecConfigServiceImpl.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
import datadog.trace.api.Config;
4848
import datadog.trace.api.ProductActivation;
4949
import datadog.trace.api.UserIdCollectionMode;
50+
import datadog.trace.api.telemetry.LogCollector;
5051
import java.io.ByteArrayInputStream;
5152
import java.io.FileInputStream;
5253
import java.io.FileNotFoundException;
@@ -60,8 +61,6 @@
6061
import java.util.Map;
6162
import java.util.Set;
6263
import java.util.concurrent.ConcurrentHashMap;
63-
64-
import datadog.trace.api.telemetry.LogCollector;
6564
import okio.Okio;
6665
import org.slf4j.Logger;
6766
import org.slf4j.LoggerFactory;
@@ -348,10 +347,7 @@ public void init() {
348347
throw new IllegalStateException("Expected default waf config to be available");
349348
}
350349
try {
351-
handleWafUpdateResultReport(
352-
DEFAULT_WAF_CONFIG_RULE,
353-
wafConfig,
354-
defaultConfigActivated ? DEFAULT_CONFIG_LOCATION : tracerConfig.getAppSecRulesFile());
350+
handleWafUpdateResultReport(DEFAULT_WAF_CONFIG_RULE, wafConfig);
355351
} catch (AppSecModule.AppSecModuleActivationException e) {
356352
throw new RuntimeException(e);
357353
}
@@ -512,6 +508,10 @@ private void applyRemoteConfigListener() {
512508
setAppSecActivation(features.asm);
513509
setUserIdCollectionMode(features.autoUserInstrum);
514510

511+
if (!AppSecSystem.isActive()) {
512+
return;
513+
}
514+
515515
distributeSubConfigurations("waf", reconfiguration);
516516
}
517517

dd-java-agent/appsec/src/test/groovy/com/datadog/appsec/config/AppSecConfigServiceImplSpecification.groovy

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -122,7 +122,7 @@ class AppSecConfigServiceImplSpecification extends DDSpecification {
122122
when:
123123
appSecConfigService.init()
124124
then:
125-
2 * config.getAppSecRulesFile() >> (p as String)
125+
1 * config.getAppSecRulesFile() >> (p as String)
126126

127127
when:
128128
appSecConfigService.maybeSubscribeConfigPolling()

remote-config/remote-config-api/src/main/java/datadog/remoteconfig/ConfigurationPoller.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ <T> void addListener(
1919
ConfigurationChangesTypedListener<T> listener);
2020

2121
void addListener(
22-
Product product, ConfigurationChangesListener mapConfigurationChangesTypedListener);
22+
Product product, ConfigurationChangesListener configurationChangesListener);
2323

2424
void removeListeners(Product product);
2525

remote-config/remote-config-core/src/main/java/datadog/remoteconfig/DefaultConfigurationPoller.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ public DefaultConfigurationPoller(
135135

136136
@Override
137137
public synchronized void addListener(
138-
Product product, ConfigurationChangesListener mapConfigurationChangesTypedListener) {
138+
Product product, ConfigurationChangesListener configurationChangesListener) {
139139
this.addListener(product, new SimpleProductListener(mapConfigurationChangesTypedListener));
140140
}
141141

0 commit comments

Comments
 (0)