|
|
|
@ -1,5 +1,5 @@ |
|
|
|
/* |
|
|
|
/* |
|
|
|
* Copyright 2012-2020 the original author or authors. |
|
|
|
* Copyright 2012-2021 the original author or authors. |
|
|
|
* |
|
|
|
* |
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
* Licensed under the Apache License, Version 2.0 (the "License"); |
|
|
|
* you may not use this file except in compliance with the License. |
|
|
|
* you may not use this file except in compliance with the License. |
|
|
|
@ -16,8 +16,13 @@ |
|
|
|
|
|
|
|
|
|
|
|
package org.springframework.boot.env; |
|
|
|
package org.springframework.boot.env; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import java.util.OptionalInt; |
|
|
|
|
|
|
|
import java.util.OptionalLong; |
|
|
|
import java.util.Random; |
|
|
|
import java.util.Random; |
|
|
|
import java.util.UUID; |
|
|
|
import java.util.UUID; |
|
|
|
|
|
|
|
import java.util.function.BiPredicate; |
|
|
|
|
|
|
|
import java.util.function.Function; |
|
|
|
|
|
|
|
import java.util.function.Predicate; |
|
|
|
|
|
|
|
|
|
|
|
import org.apache.commons.logging.Log; |
|
|
|
import org.apache.commons.logging.Log; |
|
|
|
import org.apache.commons.logging.LogFactory; |
|
|
|
import org.apache.commons.logging.LogFactory; |
|
|
|
@ -27,6 +32,7 @@ import org.springframework.core.env.MutablePropertySources; |
|
|
|
import org.springframework.core.env.PropertySource; |
|
|
|
import org.springframework.core.env.PropertySource; |
|
|
|
import org.springframework.core.env.StandardEnvironment; |
|
|
|
import org.springframework.core.env.StandardEnvironment; |
|
|
|
import org.springframework.core.log.LogMessage; |
|
|
|
import org.springframework.core.log.LogMessage; |
|
|
|
|
|
|
|
import org.springframework.util.Assert; |
|
|
|
import org.springframework.util.DigestUtils; |
|
|
|
import org.springframework.util.DigestUtils; |
|
|
|
import org.springframework.util.StringUtils; |
|
|
|
import org.springframework.util.StringUtils; |
|
|
|
|
|
|
|
|
|
|
|
@ -46,11 +52,13 @@ import org.springframework.util.StringUtils; |
|
|
|
* suffix whose syntax is: |
|
|
|
* suffix whose syntax is: |
|
|
|
* <p> |
|
|
|
* <p> |
|
|
|
* {@code OPEN value (,max) CLOSE} where the {@code OPEN,CLOSE} are any character and |
|
|
|
* {@code OPEN value (,max) CLOSE} where the {@code OPEN,CLOSE} are any character and |
|
|
|
* {@code value,max} are integers. If {@code max} is provided then {@code value} is the |
|
|
|
* {@code value,max} are integers. If {@code max} is not provided, then 0 is used as the |
|
|
|
* minimum value and {@code max} is the maximum (exclusive). |
|
|
|
* lower bound and {@code value} is the upper bound. If {@code max} is provided then |
|
|
|
|
|
|
|
* {@code value} is the minimum value and {@code max} is the maximum (exclusive). |
|
|
|
* |
|
|
|
* |
|
|
|
* @author Dave Syer |
|
|
|
* @author Dave Syer |
|
|
|
* @author Matt Benson |
|
|
|
* @author Matt Benson |
|
|
|
|
|
|
|
* @author Madhura Bhave |
|
|
|
* @since 1.0.0 |
|
|
|
* @since 1.0.0 |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
public class RandomValuePropertySource extends PropertySource<Random> { |
|
|
|
public class RandomValuePropertySource extends PropertySource<Random> { |
|
|
|
@ -113,22 +121,21 @@ public class RandomValuePropertySource extends PropertySource<Random> { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private int getNextIntInRange(String range) { |
|
|
|
private int getNextIntInRange(String range) { |
|
|
|
String[] tokens = StringUtils.commaDelimitedListToStringArray(range); |
|
|
|
Range<Integer> intRange = Range.get(range, Integer::parseInt, (t) -> t > 0, 0, (t1, t2) -> t1 < t2); |
|
|
|
int start = Integer.parseInt(tokens[0]); |
|
|
|
OptionalInt first = getSource().ints(1, intRange.getMin(), intRange.getMax()).findFirst(); |
|
|
|
if (tokens.length == 1) { |
|
|
|
if (!first.isPresent()) { |
|
|
|
return getSource().nextInt(start); |
|
|
|
throw new RuntimeException("Could not get random number for range '" + range + "'"); |
|
|
|
} |
|
|
|
} |
|
|
|
return start + getSource().nextInt(Integer.parseInt(tokens[1]) - start); |
|
|
|
return first.getAsInt(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private long getNextLongInRange(String range) { |
|
|
|
private long getNextLongInRange(String range) { |
|
|
|
String[] tokens = StringUtils.commaDelimitedListToStringArray(range); |
|
|
|
Range<Long> longRange = Range.get(range, Long::parseLong, (t) -> t > 0L, 0L, (t1, t2) -> t1 < t2); |
|
|
|
if (tokens.length == 1) { |
|
|
|
OptionalLong first = getSource().longs(1, longRange.getMin(), longRange.getMax()).findFirst(); |
|
|
|
return Math.abs(getSource().nextLong() % Long.parseLong(tokens[0])); |
|
|
|
if (!first.isPresent()) { |
|
|
|
|
|
|
|
throw new RuntimeException("Could not get random number for range '" + range + "'"); |
|
|
|
} |
|
|
|
} |
|
|
|
long lowerBound = Long.parseLong(tokens[0]); |
|
|
|
return first.getAsLong(); |
|
|
|
long upperBound = Long.parseLong(tokens[1]) - lowerBound; |
|
|
|
|
|
|
|
return lowerBound + Math.abs(getSource().nextLong() % upperBound); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private Object getRandomBytes() { |
|
|
|
private Object getRandomBytes() { |
|
|
|
@ -158,4 +165,39 @@ public class RandomValuePropertySource extends PropertySource<Random> { |
|
|
|
logger.trace("RandomValuePropertySource add to Environment"); |
|
|
|
logger.trace("RandomValuePropertySource add to Environment"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
static final class Range<T extends Number> { |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private final T min; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private final T max; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private Range(T min, T max) { |
|
|
|
|
|
|
|
this.min = min; |
|
|
|
|
|
|
|
this.max = max; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
static <T extends Number> Range<T> get(String range, Function<String, T> parse, Predicate<T> boundValidator, |
|
|
|
|
|
|
|
T defaultMin, BiPredicate<T, T> rangeValidator) { |
|
|
|
|
|
|
|
String[] tokens = StringUtils.commaDelimitedListToStringArray(range); |
|
|
|
|
|
|
|
T token1 = parse.apply(tokens[0]); |
|
|
|
|
|
|
|
if (tokens.length == 1) { |
|
|
|
|
|
|
|
Assert.isTrue(boundValidator.test(token1), "Bound must be positive."); |
|
|
|
|
|
|
|
return new Range<>(defaultMin, token1); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
T token2 = parse.apply(tokens[1]); |
|
|
|
|
|
|
|
Assert.isTrue(rangeValidator.test(token1, token2), "Lower bound must be less than upper bound."); |
|
|
|
|
|
|
|
return new Range<>(token1, token2); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
T getMin() { |
|
|
|
|
|
|
|
return this.min; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
T getMax() { |
|
|
|
|
|
|
|
return this.max; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|