Skip to content

Commit

Permalink
Closes #2459: Fix Code Smells
Browse files Browse the repository at this point in the history
  • Loading branch information
jamesrdi committed Dec 22, 2023
1 parent f3a0306 commit bedd4f3
Show file tree
Hide file tree
Showing 8 changed files with 31 additions and 31 deletions.
6 changes: 5 additions & 1 deletion .github/workflows/continuous-integration.yml
Expand Up @@ -44,6 +44,8 @@ jobs:
with:
distribution: adopt
java-version: ${{ env.JAVA_VERSION }}
- name: Print Java version
run: java -version
- name: Cache maven dependencies
id: cache
uses: actions/cache@v3
Expand All @@ -54,7 +56,9 @@ jobs:
- name: Change versions to match tag
run: ci/change_version.sh -m .
- name: Compile & build
run: ./mvnw -B install -DskipTests -Dasciidoctor.skip -Djacoco.skip
run: ./mvnw clean -B install -DskipTests -Dasciidoctor.skip -Djacoco.skip
- name: Print Compilation Command
run: mvn clean compile -X
- name: Populate cache
if: steps.cache.outputs.cache-hit != 'true'
run: |
Expand Down
Expand Up @@ -13,7 +13,6 @@
import java.util.HashMap;
import java.util.List;
import java.util.function.Consumer;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import javax.sql.DataSource;
import org.apache.ibatis.jdbc.RuntimeSqlException;
Expand Down Expand Up @@ -78,9 +77,7 @@ public void dropDb() {
private List<String> parseScripts(Stream<String> scripts) {
try (Connection connection = dataSource.getConnection()) {
DB db = DB.getDB(connection);
return scripts
.map(script -> SqlReplacer.getScriptAsSql(db, now, script))
.collect(Collectors.toList());
return scripts.map(script -> SqlReplacer.getScriptAsSql(db, now, script)).toList();
} catch (SQLException e) {
throw new RuntimeSqlException("Connection to database failed.", e);
}
Expand Down
Expand Up @@ -10,7 +10,6 @@
import java.util.List;
import java.util.Objects;
import java.util.Set;
import java.util.stream.Collectors;
import javax.security.auth.Subject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Expand Down Expand Up @@ -61,7 +60,7 @@ public List<String> getGroupIds() {
.map(Principal::getName)
.filter(Objects::nonNull)
.map(this::convertAccessId)
.collect(Collectors.toList());
.toList();
}
LOGGER.trace("No groupIds found in subject!");
return Collections.emptyList();
Expand Down
Expand Up @@ -107,17 +107,17 @@ public <T> T interceptTestFactoryMethod(

Iterable<DynamicNode> newChildrenForDynamicContainer;
// TestFactory must have one of the following return types. See link above for further details
if (factoryResult instanceof DynamicNode) {
newChildrenForDynamicContainer = Collections.singleton((DynamicNode) factoryResult);
if (factoryResult instanceof DynamicNode dynamicNode) {
newChildrenForDynamicContainer = Collections.singleton(dynamicNode);
} else if (factoryResult instanceof Stream) {
Stream<DynamicNode> nodes = (Stream<DynamicNode>) factoryResult;
newChildrenForDynamicContainer = nodes.collect(Collectors.toList());
newChildrenForDynamicContainer = nodes.toList();
} else if (factoryResult instanceof Iterable) {
newChildrenForDynamicContainer = (Iterable<DynamicNode>) factoryResult;
} else if (factoryResult instanceof Iterator) {
newChildrenForDynamicContainer = () -> (Iterator<DynamicNode>) factoryResult;
} else if (factoryResult instanceof DynamicNode[]) {
newChildrenForDynamicContainer = Arrays.asList((DynamicNode[]) factoryResult);
} else if (factoryResult instanceof DynamicNode[] dynamicNodes) {
newChildrenForDynamicContainer = Arrays.asList(dynamicNodes);
} else {
throw new SystemException(
String.format(
Expand All @@ -142,8 +142,11 @@ public <T> T interceptTestFactoryMethod(
Store store = getMethodLevelStore(extensionContext);
return (T)
Stream.of(annotation.value())
.peek(a -> store.put(ACCESS_IDS_STORE_KEY, a))
.map(wrapTestsInDynamicContainer);
.map(
a -> {
store.put(ACCESS_IDS_STORE_KEY, a);
return wrapTestsInDynamicContainer.apply(a);
});
}

return extractAccessIdAndPerformInvocation(invocation, invocationContext.getExecutable());
Expand Down Expand Up @@ -207,8 +210,11 @@ public Stream<TestTemplateInvocationContext> provideTestTemplateInvocationContex
AnnotationSupport.findRepeatableAnnotations(context.getElement(), WithAccessId.class);
Store store = getMethodLevelStore(context);
return accessIds.stream()
.peek(a -> store.put(ACCESS_IDS_STORE_KEY, a))
.map(JaasExtensionInvocationContext::new);
.map(
a -> {
store.put(ACCESS_IDS_STORE_KEY, a);
return new JaasExtensionInvocationContext(a);
});
}

// endregion
Expand All @@ -217,8 +223,7 @@ private static void persistDynamicContainerChildren(
Iterable<DynamicNode> nodes, Map<String, List<DynamicNode>> childrenMap) {
nodes.forEach(
node -> {
if (node instanceof DynamicContainer) {
DynamicContainer container = (DynamicContainer) node;
if (node instanceof DynamicContainer container) {
List<DynamicNode> children = container.getChildren().collect(Collectors.toList());
childrenMap.put(container.hashCode() + container.getDisplayName(), children);
persistDynamicContainerChildren(children, childrenMap);
Expand All @@ -228,8 +233,7 @@ private static void persistDynamicContainerChildren(

private static DynamicNode duplicateDynamicNode(
DynamicNode node, Map<String, List<DynamicNode>> lookupMap) {
if (node instanceof DynamicContainer) {
DynamicContainer container = (DynamicContainer) node;
if (node instanceof DynamicContainer container) {
Stream<DynamicNode> children =
lookupMap.get(node.hashCode() + node.getDisplayName()).stream()
.map(x -> duplicateDynamicNode(x, lookupMap));
Expand Down Expand Up @@ -259,7 +263,7 @@ private static List<Principal> getPrincipals(WithAccessId withAccessId) {
return Stream.concat(
Stream.of(withAccessId.user()).map(UserPrincipal::new),
Arrays.stream(withAccessId.groups()).map(GroupPrincipal::new))
.collect(Collectors.toList());
.toList();
}
return Collections.emptyList();
}
Expand Down
Expand Up @@ -64,9 +64,9 @@ public boolean run() throws SQLException {
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug(outWriter.toString());
}
if (!errorWriter.toString().trim().isEmpty()) {
LOGGER.error(errorWriter.toString());
if (!errorWriter.toString().trim().isEmpty()) {
LOGGER.error(errorWriter.toString());
}
}
return false;
}
Expand Down
Expand Up @@ -8,7 +8,6 @@
import java.util.Optional;
import java.util.function.Function;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
import pro.taskana.common.api.exceptions.SystemException;
import pro.taskana.common.internal.util.ReflectionUtil;

Expand Down Expand Up @@ -43,6 +42,6 @@ protected static List<String> splitStringAndTrimElements(String str, String sepa
return Arrays.stream(str.split(Pattern.quote(separator)))
.filter(not(String::isEmpty))
.map(String::trim)
.collect(Collectors.toList());
.toList();
}
}
3 changes: 1 addition & 2 deletions mvnw
Expand Up @@ -32,7 +32,7 @@
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
# ----------------------------------------------------------------------------

rm -rf ~/.m2/repository/org/aspectj
if [ -z "$MAVEN_SKIP_RC" ] ; then

if [ -f /usr/local/etc/mavenrc ] ; then
Expand Down Expand Up @@ -68,7 +68,6 @@ case "$(uname)" in
fi
;;
esac

if [ -z "$JAVA_HOME" ] ; then
if [ -r /etc/gentoo-release ] ; then
JAVA_HOME=$(java-config --jre-home)
Expand Down
4 changes: 1 addition & 3 deletions pom.xml
Expand Up @@ -120,9 +120,7 @@
<sonar.sources>src/main/java</sonar.sources>
<sonar.tests>src/test/java</sonar.tests>
<sonar.exclusions>
org/camunda/bpm/dmn/**/*,
**/example/**/*,
**/*Example*
org/camunda/bpm/dmn/**/*, **/example/**/*, **/*Example*
</sonar.exclusions>
</properties>

Expand Down

0 comments on commit bedd4f3

Please sign in to comment.