Fix sonar findings (#3135)
Signed-off-by: Avgustin Marinov <Avgustin.Marinov@bosch.com>
This commit is contained in:
@@ -28,13 +28,12 @@ import org.eclipse.hawkbit.repository.model.DistributionSet;
|
|||||||
import org.eclipse.hawkbit.repository.model.SoftwareModule;
|
import org.eclipse.hawkbit.repository.model.SoftwareModule;
|
||||||
import org.eclipse.hawkbit.repository.model.Target;
|
import org.eclipse.hawkbit.repository.model.Target;
|
||||||
import org.jspecify.annotations.NonNull;
|
import org.jspecify.annotations.NonNull;
|
||||||
import org.jspecify.annotations.NullMarked;
|
|
||||||
import org.jspecify.annotations.Nullable;
|
import org.jspecify.annotations.Nullable;
|
||||||
import org.springframework.amqp.core.Message;
|
import org.springframework.amqp.core.Message;
|
||||||
|
import org.springframework.amqp.listener.ConditionalRejectingErrorHandler;
|
||||||
|
import org.springframework.amqp.listener.FatalExceptionStrategy;
|
||||||
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
|
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
|
||||||
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
||||||
import org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler;
|
|
||||||
import org.springframework.amqp.rabbit.listener.FatalExceptionStrategy;
|
|
||||||
import org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory;
|
import org.springframework.amqp.rabbit.listener.RabbitListenerContainerFactory;
|
||||||
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
|
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
|
||||||
import org.springframework.amqp.support.converter.JacksonJsonMessageConverter;
|
import org.springframework.amqp.support.converter.JacksonJsonMessageConverter;
|
||||||
|
|||||||
@@ -21,7 +21,7 @@ import org.eclipse.hawkbit.repository.exception.CancelActionNotAllowedException;
|
|||||||
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
import org.eclipse.hawkbit.repository.exception.EntityNotFoundException;
|
||||||
import org.eclipse.hawkbit.repository.exception.InvalidTargetAttributeException;
|
import org.eclipse.hawkbit.repository.exception.InvalidTargetAttributeException;
|
||||||
import org.eclipse.hawkbit.repository.exception.TenantNotExistException;
|
import org.eclipse.hawkbit.repository.exception.TenantNotExistException;
|
||||||
import org.springframework.amqp.rabbit.listener.FatalExceptionStrategy;
|
import org.springframework.amqp.listener.FatalExceptionStrategy;
|
||||||
import org.springframework.amqp.support.converter.MessageConversionException;
|
import org.springframework.amqp.support.converter.MessageConversionException;
|
||||||
import org.springframework.messaging.MessageHandlingException;
|
import org.springframework.messaging.MessageHandlingException;
|
||||||
import org.springframework.messaging.handler.invocation.MethodArgumentResolutionException;
|
import org.springframework.messaging.handler.invocation.MethodArgumentResolutionException;
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ import static org.assertj.core.api.Assertions.assertThat;
|
|||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.Test;
|
||||||
import org.springframework.amqp.rabbit.listener.FatalExceptionStrategy;
|
import org.springframework.amqp.listener.FatalExceptionStrategy;
|
||||||
import org.springframework.amqp.support.converter.MessageConversionException;
|
import org.springframework.amqp.support.converter.MessageConversionException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -10,7 +10,7 @@
|
|||||||
package org.eclipse.hawkbit.autoconfigure.dmf.amqp;
|
package org.eclipse.hawkbit.autoconfigure.dmf.amqp;
|
||||||
|
|
||||||
import org.eclipse.hawkbit.amqp.DmfApiConfiguration;
|
import org.eclipse.hawkbit.amqp.DmfApiConfiguration;
|
||||||
import org.springframework.amqp.rabbit.listener.ConditionalRejectingErrorHandler;
|
import org.springframework.amqp.listener.ConditionalRejectingErrorHandler;
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
|
||||||
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
|
||||||
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Bean;
|
||||||
|
|||||||
@@ -495,16 +495,13 @@ class MgmtDistributionSetTypeResourceTest extends AbstractManagementApiIntegrati
|
|||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getDistributionSetTypesFilteredBySoftDeletedMode() throws Exception {
|
void getDistributionSetTypesFilteredBySoftDeletedMode() throws Exception {
|
||||||
final DistributionSetType activeType = distributionSetTypeManagement.create(
|
distributionSetTypeManagement.create(DistributionSetTypeManagement.Create.builder().key("activeKey").name("activeType").build());
|
||||||
DistributionSetTypeManagement.Create.builder()
|
|
||||||
.key("activeKey").name("activeType").build());
|
|
||||||
|
|
||||||
// create type + DS using it, then delete type → soft-delete
|
// create type + DS using it, then delete type → soft-delete
|
||||||
final DistributionSetType deletedType = distributionSetTypeManagement.create(
|
final DistributionSetType deletedType = distributionSetTypeManagement.create(
|
||||||
DistributionSetTypeManagement.Create.builder()
|
DistributionSetTypeManagement.Create.builder().key("deletedKey").name("deletedType").build());
|
||||||
.key("deletedKey").name("deletedType").build());
|
distributionSetManagement.create(
|
||||||
distributionSetManagement.create(DistributionSetManagement.Create.builder()
|
DistributionSetManagement.Create.builder().type(deletedType).name("ds").version("1.0").build());
|
||||||
.type(deletedType).name("ds").version("1.0").build());
|
|
||||||
distributionSetTypeManagement.delete(deletedType.getId());
|
distributionSetTypeManagement.delete(deletedType.getId());
|
||||||
|
|
||||||
// default — built-in + activeType, no deletedType
|
// default — built-in + activeType, no deletedType
|
||||||
|
|||||||
@@ -1230,8 +1230,7 @@ class MgmtSoftwareModuleResourceTest extends AbstractManagementApiIntegrationTes
|
|||||||
|
|
||||||
@Test
|
@Test
|
||||||
void getSoftwareModulesFilteredBySoftDeletedMode() throws Exception {
|
void getSoftwareModulesFilteredBySoftDeletedMode() throws Exception {
|
||||||
final SoftwareModule activeSm = softwareModuleManagement.create(
|
softwareModuleManagement.create(SoftwareModuleManagement.Create.builder().type(osType).name("activeSm").version("1.0").build());
|
||||||
SoftwareModuleManagement.Create.builder().type(osType).name("activeSm").version("1.0").build());
|
|
||||||
|
|
||||||
SoftwareModule deletedSm = softwareModuleManagement.create(
|
SoftwareModule deletedSm = softwareModuleManagement.create(
|
||||||
SoftwareModuleManagement.Create.builder().type(osType).name("deletedSm").version("1.0").build());
|
SoftwareModuleManagement.Create.builder().type(osType).name("deletedSm").version("1.0").build());
|
||||||
|
|||||||
@@ -494,8 +494,7 @@ public class MgmtSoftwareModuleTypeResourceTest extends AbstractManagementApiInt
|
|||||||
// 3 built-in types exist (os, runtime, application)
|
// 3 built-in types exist (os, runtime, application)
|
||||||
final int builtInTypes = 3;
|
final int builtInTypes = 3;
|
||||||
|
|
||||||
final SoftwareModuleType activeType = softwareModuleTypeManagement.create(
|
softwareModuleTypeManagement.create(SoftwareModuleTypeManagement.Create.builder().key("activeKey").name("activeType").build());
|
||||||
SoftwareModuleTypeManagement.Create.builder().key("activeKey").name("activeType").build());
|
|
||||||
|
|
||||||
// create type + SM using it, then delete type → soft-delete
|
// create type + SM using it, then delete type → soft-delete
|
||||||
final SoftwareModuleType deletedType = softwareModuleTypeManagement.create(
|
final SoftwareModuleType deletedType = softwareModuleTypeManagement.create(
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ package org.eclipse.hawkbit.ui.security;
|
|||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.time.Instant;
|
import java.time.Instant;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
|
import java.util.Objects;
|
||||||
|
|
||||||
import jakarta.servlet.FilterChain;
|
import jakarta.servlet.FilterChain;
|
||||||
import jakarta.servlet.ServletException;
|
import jakarta.servlet.ServletException;
|
||||||
@@ -50,7 +51,9 @@ class UserDetailsSetter extends OncePerRequestFilter {
|
|||||||
final Collection<? extends GrantedAuthority> grantedAuthorities = grantedAuthoritiesService.getGrantedAuthorities(authentication);
|
final Collection<? extends GrantedAuthority> grantedAuthorities = grantedAuthoritiesService.getGrantedAuthorities(authentication);
|
||||||
if (authentication instanceof OAuth2AuthenticationToken oAuth2AuthenticationToken) {
|
if (authentication instanceof OAuth2AuthenticationToken oAuth2AuthenticationToken) {
|
||||||
newAuthentication = new OAuth2AuthenticationToken(
|
newAuthentication = new OAuth2AuthenticationToken(
|
||||||
oAuth2AuthenticationToken.getPrincipal(), grantedAuthorities,
|
// principal is not null, but the method is not @NonNull annotated
|
||||||
|
Objects.requireNonNull(oAuth2AuthenticationToken.getPrincipal()),
|
||||||
|
grantedAuthorities,
|
||||||
oAuth2AuthenticationToken.getAuthorizedClientRegistrationId());
|
oAuth2AuthenticationToken.getAuthorizedClientRegistrationId());
|
||||||
if (authentication.getPrincipal() instanceof OidcUser user) {
|
if (authentication.getPrincipal() instanceof OidcUser user) {
|
||||||
// if there is no refresh token and the access token is expired then re-login is required
|
// if there is no refresh token and the access token is expired then re-login is required
|
||||||
|
|||||||
Reference in New Issue
Block a user