Compare commits

...
Author SHA1 Message Date
Bill Oley 7694d0afe7 Update dependencies 2019-04-01 17:01:00 -04:00
14 changed files with 58 additions and 25 deletions

No files matched your search

+5 -2
View File
@@ -46,9 +46,12 @@
<user-service id="usernamePasswordService"> <user-service id="usernamePasswordService">
<user name="test" password="test1" authorities="A,B,C" /> <user name="test" password="test1" authorities="A,B,C" />
</user-service> </user-service>
<beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider"> <beans:bean id="noOpPasswordEncoder" class="org.springframework.security.crypto.password.NoOpPasswordEncoder"/>
<beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider">
<beans:property name="userDetailsService" ref="usernamePasswordService"/> <beans:property name="userDetailsService" ref="usernamePasswordService"/>
<beans:property name="passwordEncoder" ref="noOpPasswordEncoder"/>
</beans:bean> </beans:bean>
<authentication-manager alias="authenticationManager"> <authentication-manager alias="authenticationManager">
@@ -64,6 +64,7 @@ import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.data.Stat; import org.apache.zookeeper.data.Stat;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import timely.auth.AuthCache; import timely.auth.AuthCache;
@@ -143,7 +144,7 @@ public class Balancer {
} }
protected static ConfigurableApplicationContext initializeConfiguration(String[] args) { protected static ConfigurableApplicationContext initializeConfiguration(String[] args) {
return new SpringApplicationBuilder(SpringBootstrap.class).web(false).run(args); return new SpringApplicationBuilder(SpringBootstrap.class).web(WebApplicationType.NONE).run(args);
} }
private void shutdownHook() { private void shutdownHook() {
@@ -5,8 +5,10 @@ import javax.validation.Valid;
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.NestedConfigurationProperty; import org.springframework.boot.context.properties.NestedConfigurationProperty;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import timely.configuration.Cache; import timely.configuration.Cache;
@Validated
@Component @Component
@ConfigurationProperties(prefix = "timely-balancer") @ConfigurationProperties(prefix = "timely-balancer")
public class BalancerConfiguration { public class BalancerConfiguration {
+5 -2
View File
@@ -46,9 +46,12 @@
<user-service id="usernamePasswordService"> <user-service id="usernamePasswordService">
<user name="test" password="test1" authorities="A,B,C" /> <user name="test" password="test1" authorities="A,B,C" />
</user-service> </user-service>
<beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider"> <beans:bean id="noOpPasswordEncoder" class="org.springframework.security.crypto.password.NoOpPasswordEncoder"/>
<beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider">
<beans:property name="userDetailsService" ref="usernamePasswordService"/> <beans:property name="userDetailsService" ref="usernamePasswordService"/>
<beans:property name="passwordEncoder" ref="noOpPasswordEncoder"/>
</beans:bean> </beans:bean>
<authentication-manager alias="authenticationManager"> <authentication-manager alias="authenticationManager">
@@ -43,6 +43,7 @@ import io.netty.handler.stream.ChunkedWriteHandler;
import io.netty.util.internal.SystemPropertyUtil; import io.netty.util.internal.SystemPropertyUtil;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import timely.auth.AuthCache; import timely.auth.AuthCache;
@@ -81,7 +82,7 @@ public class GrafanaAuth {
} }
protected static ConfigurableApplicationContext initializeConfiguration(String[] args) { protected static ConfigurableApplicationContext initializeConfiguration(String[] args) {
return new SpringApplicationBuilder(SpringBootstrap.class).web(false).run(args); return new SpringApplicationBuilder(SpringBootstrap.class).web(WebApplicationType.NONE).run(args);
} }
private void shutdownHook() { private void shutdownHook() {
@@ -5,9 +5,11 @@ import javax.validation.Valid;
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.NestedConfigurationProperty; import org.springframework.boot.context.properties.NestedConfigurationProperty;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
import timely.balancer.configuration.BalancerHttp; import timely.balancer.configuration.BalancerHttp;
import timely.balancer.configuration.BalancerSecurity; import timely.balancer.configuration.BalancerSecurity;
@Validated
@Component @Component
@ConfigurationProperties(prefix = "grafana-auth") @ConfigurationProperties(prefix = "grafana-auth")
public class GrafanaAuthConfiguration { public class GrafanaAuthConfiguration {
+6 -6
View File
@@ -50,13 +50,13 @@
<version.commons-io>2.6</version.commons-io> <version.commons-io>2.6</version.commons-io>
<version.commons-lang3>3.5</version.commons-lang3> <version.commons-lang3>3.5</version.commons-lang3>
<version.commons-pool2>2.6.0</version.commons-pool2> <version.commons-pool2>2.6.0</version.commons-pool2>
<version.curator>2.11.1</version.curator> <version.curator>4.1.0</version.curator>
<version.disruptor>3.3.6</version.disruptor> <version.disruptor>3.3.6</version.disruptor>
<version.eclipse-lifecycle>1.0.0</version.eclipse-lifecycle> <version.eclipse-lifecycle>1.0.0</version.eclipse-lifecycle>
<version.fast-classpath-scanner>2.0.5</version.fast-classpath-scanner> <version.fast-classpath-scanner>2.0.5</version.fast-classpath-scanner>
<version.flink>1.1.4</version.flink> <version.flink>1.1.4</version.flink>
<version.google-flatbuffers>1.10.0</version.google-flatbuffers> <version.google-flatbuffers>1.10.0</version.google-flatbuffers>
<version.guava>19.0</version.guava> <version.guava>27.1-jre</version.guava>
<version.hadoop>2.7.3</version.hadoop> <version.hadoop>2.7.3</version.hadoop>
<version.httpcomponents>4.5.2</version.httpcomponents> <version.httpcomponents>4.5.2</version.httpcomponents>
<version.impsort>1.2.0</version.impsort> <version.impsort>1.2.0</version.impsort>
@@ -77,13 +77,13 @@
<version.maven-rpm>2.1.4</version.maven-rpm> <version.maven-rpm>2.1.4</version.maven-rpm>
<version.maven-shade>2.4.2</version.maven-shade> <version.maven-shade>2.4.2</version.maven-shade>
<version.maven-surefire>2.19.1</version.maven-surefire> <version.maven-surefire>2.19.1</version.maven-surefire>
<version.netty>4.0.56.Final</version.netty> <version.netty>4.1.33.Final</version.netty>
<version.netty-tcnative>2.0.7.Final</version.netty-tcnative> <version.netty-tcnative>2.0.20.Final</version.netty-tcnative>
<version.os-maven>1.5.0.Final</version.os-maven> <version.os-maven>1.5.0.Final</version.os-maven>
<version.powermock>1.6.4</version.powermock> <version.powermock>1.6.4</version.powermock>
<version.slf4j>1.7.21</version.slf4j> <version.slf4j>1.7.25</version.slf4j>
<version.spotbugs-maven>3.1.7</version.spotbugs-maven> <version.spotbugs-maven>3.1.7</version.spotbugs-maven>
<version.spring-boot>1.4.1.RELEASE</version.spring-boot> <version.spring-boot>2.1.3.RELEASE</version.spring-boot>
<version.tyrus>1.13</version.tyrus> <version.tyrus>1.13</version.tyrus>
</properties> </properties>
<dependencyManagement> <dependencyManagement>
+5 -2
View File
@@ -46,9 +46,12 @@
<user-service id="usernamePasswordService"> <user-service id="usernamePasswordService">
<user name="test" password="test1" authorities="A,B,C" /> <user name="test" password="test1" authorities="A,B,C" />
</user-service> </user-service>
<beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider"> <beans:bean id="noOpPasswordEncoder" class="org.springframework.security.crypto.password.NoOpPasswordEncoder"/>
<beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider">
<beans:property name="userDetailsService" ref="usernamePasswordService"/> <beans:property name="userDetailsService" ref="usernamePasswordService"/>
<beans:property name="passwordEncoder" ref="noOpPasswordEncoder"/>
</beans:bean> </beans:bean>
<authentication-manager alias="authenticationManager"> <authentication-manager alias="authenticationManager">
+2 -1
View File
@@ -70,6 +70,7 @@ import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.data.Stat; import org.apache.zookeeper.data.Stat;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import timely.api.response.TimelyException; import timely.api.response.TimelyException;
@@ -250,7 +251,7 @@ public class Server {
} }
protected static Configuration initializeConfiguration(String[] args) { protected static Configuration initializeConfiguration(String[] args) {
applicationContext = new SpringApplicationBuilder(SpringBootstrap.class).web(false).run(args); applicationContext = new SpringApplicationBuilder(SpringBootstrap.class).web(WebApplicationType.NONE).run(args);
return applicationContext.getBean(Configuration.class); return applicationContext.getBean(Configuration.class);
} }
@@ -9,7 +9,9 @@ import javax.validation.Valid;
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.context.properties.NestedConfigurationProperty; import org.springframework.boot.context.properties.NestedConfigurationProperty;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.validation.annotation.Validated;
@Validated
@Component @Component
@ConfigurationProperties(prefix = "timely") @ConfigurationProperties(prefix = "timely")
public class Configuration { public class Configuration {
@@ -14,6 +14,7 @@ import org.apache.accumulo.core.data.Range;
import org.apache.accumulo.core.data.Value; import org.apache.accumulo.core.data.Value;
import org.apache.commons.configuration.BaseConfiguration; import org.apache.commons.configuration.BaseConfiguration;
import org.springframework.boot.Banner.Mode; import org.springframework.boot.Banner.Mode;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.context.ConfigurableApplicationContext; import org.springframework.context.ConfigurableApplicationContext;
import timely.api.model.Meta; import timely.api.model.Meta;
@@ -26,7 +27,7 @@ public class GetMetricTableSplitPoints {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
try (ConfigurableApplicationContext ctx = new SpringApplicationBuilder(SpringBootstrap.class) try (ConfigurableApplicationContext ctx = new SpringApplicationBuilder(SpringBootstrap.class)
.bannerMode(Mode.OFF).web(false).run(args)) { .bannerMode(Mode.OFF).web(WebApplicationType.NONE).run(args)) {
Configuration conf = ctx.getBean(Configuration.class); Configuration conf = ctx.getBean(Configuration.class);
final BaseConfiguration apacheConf = new BaseConfiguration(); final BaseConfiguration apacheConf = new BaseConfiguration();
@@ -4,16 +4,22 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue; import static org.junit.Assert.assertTrue;
import org.junit.After; import org.junit.After;
import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import org.springframework.beans.factory.BeanCreationException; import org.springframework.beans.factory.BeanCreationException;
import org.springframework.boot.test.util.EnvironmentTestUtils; import org.springframework.boot.test.util.TestPropertyValues;
import org.springframework.context.annotation.AnnotationConfigApplicationContext; import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import timely.configuration.Configuration; import timely.configuration.Configuration;
import timely.configuration.SpringBootstrap; import timely.configuration.SpringBootstrap;
public class ConfigurationTest { public class ConfigurationTest {
private final AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(); private AnnotationConfigApplicationContext context;
@Before
public void createContext() {
context = new AnnotationConfigApplicationContext();
}
@After @After
public void closeContext() { public void closeContext() {
@@ -24,7 +30,7 @@ public class ConfigurationTest {
public void testMinimalConfiguration() throws Exception { public void testMinimalConfiguration() throws Exception {
context.register(SpringBootstrap.class); context.register(SpringBootstrap.class);
// @formatter:off // @formatter:off
EnvironmentTestUtils.addEnvironment(this.context, TestPropertyValues.of(
"timely.server.ip:127.0.0.1", "timely.server.ip:127.0.0.1",
"timely.server.tcp-port:54321", "timely.server.tcp-port:54321",
"timely.server.udp-port:54325", "timely.server.udp-port:54325",
@@ -38,7 +44,7 @@ public class ConfigurationTest {
"timely.accumulo.password:secret", "timely.accumulo.password:secret",
"timely.http.host:localhost", "timely.http.host:localhost",
"timely.security.serverSsl.use-generated-keypair:true", "timely.security.serverSsl.use-generated-keypair:true",
"timely.metric-age-off-days[default]:7"); "timely.metric-age-off-days[default]:7").applyTo(this.context);
// @formatter:on // @formatter:on
context.refresh(); context.refresh();
Configuration config = this.context.getBean(Configuration.class); Configuration config = this.context.getBean(Configuration.class);
@@ -62,7 +68,7 @@ public class ConfigurationTest {
public void testMissingSSLProperty() throws Exception { public void testMissingSSLProperty() throws Exception {
context.register(SpringBootstrap.class); context.register(SpringBootstrap.class);
// @formatter:off // @formatter:off
EnvironmentTestUtils.addEnvironment(this.context, TestPropertyValues.of(
"timely.server.ip:127.0.0.1", "timely.server.ip:127.0.0.1",
"timely.server.tcp-port:54321", "timely.server.tcp-port:54321",
"timely.server.udp-port:54325", "timely.server.udp-port:54325",
@@ -74,7 +80,7 @@ public class ConfigurationTest {
"timely.accumulo.instance-name:test", "timely.accumulo.instance-name:test",
"timely.accumulo.username:root", "timely.accumulo.username:root",
"timely.accumulo.password:secret", "timely.accumulo.password:secret",
"timely.http.host:localhost"); "timely.http.host:localhost").applyTo(this.context);
// @formatter:on // @formatter:on
context.refresh(); context.refresh();
} }
@@ -83,7 +89,7 @@ public class ConfigurationTest {
public void testSSLProperty() throws Exception { public void testSSLProperty() throws Exception {
context.register(SpringBootstrap.class); context.register(SpringBootstrap.class);
// @formatter:off // @formatter:off
EnvironmentTestUtils.addEnvironment(this.context, TestPropertyValues.of(
"timely.server.ip:127.0.0.1", "timely.server.ip:127.0.0.1",
"timely.server.tcp-port:54321", "timely.server.tcp-port:54321",
"timely.server.udp-port:54325", "timely.server.udp-port:54325",
@@ -97,7 +103,7 @@ public class ConfigurationTest {
"timely.accumulo.password:secret", "timely.accumulo.password:secret",
"timely.http.host:localhost", "timely.http.host:localhost",
"timely.security.serverSsl.certificate-file:/tmp/foo", "timely.security.serverSsl.certificate-file:/tmp/foo",
"timely.security.serverSsl.key-file:/tmp/bar"); "timely.security.serverSsl.key-file:/tmp/bar").applyTo(this.context);
// @formatter:on // @formatter:on
context.refresh(); context.refresh();
} }
@@ -41,6 +41,11 @@ public class CaptureChannelHandlerContext implements ChannelHandlerContext {
return null; return null;
} }
@Override
public <T> boolean hasAttr(AttributeKey<T> attributeKey) {
return false;
}
@Override @Override
public Channel channel() { public Channel channel() {
return null; return null;
+4 -1
View File
@@ -46,9 +46,12 @@
<user-service id="usernamePasswordService"> <user-service id="usernamePasswordService">
<user name="test" password="test1" authorities="A,B,C" /> <user name="test" password="test1" authorities="A,B,C" />
</user-service> </user-service>
<beans:bean id="noOpPasswordEncoder" class="org.springframework.security.crypto.password.NoOpPasswordEncoder"/>
<beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider"> <beans:bean id="UserNamePasswordAuthenticationProvider" class="org.springframework.security.authentication.dao.DaoAuthenticationProvider">
<beans:property name="userDetailsService" ref="usernamePasswordService"/> <beans:property name="userDetailsService" ref="usernamePasswordService"/>
<beans:property name="passwordEncoder" ref="noOpPasswordEncoder"/>
</beans:bean> </beans:bean>
<authentication-manager alias="authenticationManager"> <authentication-manager alias="authenticationManager">