<dependency>
<groupId>org.onap.sdc.sdc-distribution-client</groupId>
<artifactId>sdc-distribution-client</artifactId>
+ <version>${sdc-distribution-client.version}</version>
</dependency>
<dependency>
<groupId>org.jmockit</groupId>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
</dependency>
+ <dependency>
+ <groupId>com.github.stefanbirkner</groupId>
+ <artifactId>system-rules</artifactId>
+ <version>1.17.2</version>
+ <scope>test</scope>
+ </dependency>
</dependencies>
</project>
public static final String TOSCA_CSAR = "TOSCA_CSAR";
- @Value("${listenerservice.config.asdcAddress}")
- private String asdcAddress;
-
- @Value("${listenerservice.config.messageBusAddress}")
- private List<String> messageBusAddress;
+ @Value("${listenerservice.config.sdcAddress}")
+ private String sdcAddress;
@Value("${listenerservice.config.user}")
private String user;
@Value("${listenerservice.config.activateServerTLSAuth}")
private boolean activateServerTLSAuth;
- @Value("${listenerservice.config.isUseHttpsWithDmaap}")
- private boolean isUseHttpsWithDmaap;
-
@Value("${listenerservice.config.isUseHttpsWithSDC}")
private boolean isUseHttpsWithSDC;
private int getHttpProxyPort;
@Override
- public String getAsdcAddress() {
- return asdcAddress;
- }
-
- @Override
- public List<String> getMsgBusAddress() {
- return messageBusAddress;
+ public String getSdcAddress() {
+ return sdcAddress;
}
@Override
return false;
}
- @Override
- public Boolean isUseHttpsWithDmaap() {
- return isUseHttpsWithDmaap;
- }
-
@Override
public Boolean isUseHttpsWithSDC() {
return isUseHttpsWithSDC;
@Override
public String getHttpProxyHost() {
- return getHttpsProxyHost;
+ return getHttpProxyHost;
}
@Override
@Override
public int getHttpProxyPort() {
- return getHttpsProxyPort;
+ return getHttpProxyPort;
}
-
}
-
listenerDto.setManagedChannelForGrpc();
listenerDto.setDistributionClient(distributionClient);
-
IDistributionClientResult result = distributionClient.init(configuration, notification);
startSdcClientBasedOnTheResult(result);
}
listenerservice:
config:
- asdcAddress: ${asdcAddress:localhost:8443}
- messageBusAddress: ${messageBusAddress:localhost}
+ sdcAddress: ${sdcAddress:localhost:8443}
user: ${sdcusername:cds}
password: ${password:Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U}
pollingInterval: ${pollingInterval:15}
keyStorePassword: ${keyStorePassword}
keyStorePath: ${keyStorePath}
activateServerTLSAuth : ${activateServerTLSAuth:false}
- isUseHttpsWithDmaap: ${isUseHttpsWithDmaap:false}
isUseHttpsWithSDC: ${isUseHttpsWithSDC:true}
archivePath: ${archivePath:/opt/app/onap/cds-sdc-listener/}
grpcAddress: ${grpcAddress:localhost}
package org.onap.ccsdk.cds.sdclistener;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+
+import org.junit.Rule;
import org.junit.Test;
+import org.junit.contrib.java.lang.system.EnvironmentVariables;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
-import static org.junit.Assert.assertEquals;
-
@RunWith(SpringRunner.class)
@EnableConfigurationProperties(SdcListenerConfiguration.class)
@SpringBootTest(classes = {SdcListenerConfigurationTest.class})
public class SdcListenerConfigurationTest {
+ @Rule
+ public EnvironmentVariables environmentVariables = new EnvironmentVariables();
+
@Autowired
private SdcListenerConfiguration listenerConfiguration;
@Test
public void testCdsSdcListenerConfiguration() {
- assertEquals(listenerConfiguration.getAsdcAddress(), "localhost:8443");
- assertEquals(listenerConfiguration.getMsgBusAddress().stream().findFirst().get(), "localhost");
- assertEquals(listenerConfiguration.getUser(), "cds");
- assertEquals(listenerConfiguration.getPassword(), "Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U");
- assertEquals(listenerConfiguration.getPollingInterval(), 15);
- assertEquals(listenerConfiguration.getPollingTimeout(), 60);
- assertEquals(listenerConfiguration.getRelevantArtifactTypes().stream().findFirst().get(), "TOSCA_CSAR");
- assertEquals(listenerConfiguration.getConsumerGroup(), "cds-id-local");
- assertEquals(listenerConfiguration.getEnvironmentName(), "AUTO");
- assertEquals(listenerConfiguration.getConsumerID(), "cds-id-local");
- assertEquals(listenerConfiguration.activateServerTLSAuth(), false);
- assertEquals(listenerConfiguration.isUseHttpsWithSDC(), true);
- assertEquals(listenerConfiguration.isUseHttpsWithDmaap(), false);
+ environmentVariables.set("SASL_JAAS_CONFIG",
+ "org.apache.kafka.common.security.scram.ScramLoginModule required username=admin password=admin-secret;");
+ assertEquals("localhost:8443", listenerConfiguration.getSdcAddress());
+ assertEquals(
+ "org.apache.kafka.common.security.scram.ScramLoginModule required username=admin password=admin-secret;",
+ listenerConfiguration.getKafkaSaslJaasConfig());
+ assertEquals("cds", listenerConfiguration.getUser());
+ assertEquals("Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U", listenerConfiguration.getPassword());
+ assertEquals(15, listenerConfiguration.getPollingInterval());
+ assertEquals(60, listenerConfiguration.getPollingTimeout());
+ assertEquals("TOSCA_CSAR", listenerConfiguration.getRelevantArtifactTypes().stream().findFirst().get());
+ assertEquals("cds-id-local", listenerConfiguration.getConsumerGroup());
+ assertEquals("AUTO", listenerConfiguration.getEnvironmentName());
+ assertEquals("cds-id-local", listenerConfiguration.getConsumerID());
+ assertFalse(listenerConfiguration.activateServerTLSAuth());
+ assertEquals(true, listenerConfiguration.isUseHttpsWithSDC());
}
}
container_name: cdssdclistener
restart: always
environment:
- asdcAddress: localhost:8443
- messageBusAddress: localhost
+ sdcAddress: localhost:8443
sdcusername: vid
password: Kp8bJ4SXszM0WXlhak3eHlcse2gAw84vaoGGmJvUy2U
pollingInterval: 15
<mockk.version>1.9</mockk.version>
<dmaap.client.version>1.1.5</dmaap.client.version>
<mockkserver.version>5.5.1</mockkserver.version>
- <sdc-distribution-client.version>1.4.5</sdc-distribution-client.version>
+ <sdc-distribution-client.version>2.0.0</sdc-distribution-client.version>
+ <kafka.version>3.3.1</kafka.version>
<jmockit.version>1.49</jmockit.version>
<reactorcore.version>3.2.6.RELEASE</reactorcore.version>
</properties>
<artifactId>sdc-distribution-client</artifactId>
<version>${sdc-distribution-client.version}</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>kafka-clients</artifactId>
+ <version>${kafka.version}</version>
+ </dependency>
</dependencies>
</dependencyManagement>