diff --git a/src/main/java/ru/serega6531/packmate/service/PatternMatcher.java b/src/main/java/ru/serega6531/packmate/service/PatternMatcher.java index e2d2cbb..c08e55a 100644 --- a/src/main/java/ru/serega6531/packmate/service/PatternMatcher.java +++ b/src/main/java/ru/serega6531/packmate/service/PatternMatcher.java @@ -10,7 +10,7 @@ import ru.serega6531.packmate.utils.Bytes; import java.util.*; import java.util.regex.Matcher; -public class PatternMatcher { +class PatternMatcher { private static final Map compiledPatterns = new HashMap<>(); @@ -65,7 +65,7 @@ public class PatternMatcher { startSearch = end + 1; } - } else { // SUBBYTES + } else if (pattern.getSearchType() == PatternSearchType.SUBBYTES) { int startSearch = 0; final byte[] value = Hex.decode(pattern.getValue()); diff --git a/src/main/java/ru/serega6531/packmate/service/ServicesService.java b/src/main/java/ru/serega6531/packmate/service/ServicesService.java index 4037371..ee93035 100644 --- a/src/main/java/ru/serega6531/packmate/service/ServicesService.java +++ b/src/main/java/ru/serega6531/packmate/service/ServicesService.java @@ -50,7 +50,7 @@ public class ServicesService { return Optional.empty(); } - public Optional findByPort(int port) { + private Optional findByPort(int port) { return Optional.ofNullable(services.get(port)); } diff --git a/src/main/java/ru/serega6531/packmate/service/StreamService.java b/src/main/java/ru/serega6531/packmate/service/StreamService.java index 14a60ed..96b2e41 100644 --- a/src/main/java/ru/serega6531/packmate/service/StreamService.java +++ b/src/main/java/ru/serega6531/packmate/service/StreamService.java @@ -145,7 +145,7 @@ public class StreamService { return foundPatterns; } - public Stream save(Stream stream) { + private Stream save(Stream stream) { Stream saved; if (stream.getId() == null) { saved = repository.save(stream); @@ -167,6 +167,7 @@ public class StreamService { repository.setFavorite(id, favorite); } + @SuppressWarnings("ConstantConditions") public List findAll(Pagination pagination, Optional service, boolean onlyFavorites) { PageRequest page = PageRequest.of(0, pagination.getPageSize(), pagination.getDirection(), "id"); diff --git a/src/main/java/ru/serega6531/packmate/service/StreamSubscriptionService.java b/src/main/java/ru/serega6531/packmate/service/StreamSubscriptionService.java index 0890081..e89f2a5 100644 --- a/src/main/java/ru/serega6531/packmate/service/StreamSubscriptionService.java +++ b/src/main/java/ru/serega6531/packmate/service/StreamSubscriptionService.java @@ -14,12 +14,13 @@ import java.io.IOException; import java.util.ArrayList; import java.util.Collections; import java.util.List; +import java.util.Objects; @Service @Slf4j public class StreamSubscriptionService { - private List subscribers = Collections.synchronizedList(new ArrayList<>()); + private final List subscribers = Collections.synchronizedList(new ArrayList<>()); private final ObjectMapper mapper; @@ -30,12 +31,12 @@ public class StreamSubscriptionService { public void addSubscriber(WebSocketSession session) { subscribers.add(session); - log.info("Подписан пользователь {}", session.getRemoteAddress().getHostName()); + log.info("Подписан пользователь {}", Objects.requireNonNull(session.getRemoteAddress()).getHostName()); } public void removeSubscriber(WebSocketSession session) { subscribers.remove(session); - log.info("Отписан пользователь {}", session.getRemoteAddress().getHostName()); + log.info("Отписан пользователь {}", Objects.requireNonNull(session.getRemoteAddress()).getHostName()); } public void broadcast(SubscriptionMessage message) {