diff --git a/src/main/java/com/ghostchu/peerbanhelper/PeerBanHelperServer.java b/src/main/java/com/ghostchu/peerbanhelper/PeerBanHelperServer.java index f0facbcd4..1413e0530 100644 --- a/src/main/java/com/ghostchu/peerbanhelper/PeerBanHelperServer.java +++ b/src/main/java/com/ghostchu/peerbanhelper/PeerBanHelperServer.java @@ -329,7 +329,7 @@ private void loadBanListToMemory() { log.info(tlUI(Lang.LOAD_BANLIST_FROM_FILE, data.size())); downloaders.forEach(downloader -> { downloader.login(); - downloader.setBanList(generateFullPeerAddress(), null, null, true); + downloader.setBanList(BAN_LIST.keySet(), null, null, true); }); Collection relaunch = data.values().stream().map(BanMetadata::getTorrent).toList(); downloaders.forEach(downloader -> downloader.relaunchTorrentIfNeededByTorrentWrapper(relaunch)); @@ -595,7 +595,7 @@ public void updateDownloader(@NotNull Downloader downloader, boolean updateBanLi } else { downloader.setLastStatus(DownloaderLastStatus.HEALTHY, loginResult.getMessage()); } - downloader.setBanList(generateFullPeerAddress(), added, removed, applyFullList); + downloader.setBanList(BAN_LIST.keySet(), added, removed, applyFullList); downloader.relaunchTorrentIfNeeded(needToRelaunch); } catch (Throwable th) { log.error(tlUI(Lang.ERR_UPDATE_BAN_LIST, downloader.getName(), downloader.getEndpoint()), th); @@ -889,13 +889,6 @@ public JavalinWebContainer getWebContainer() { return webContainer; } - public Collection generateFullPeerAddress(){ - Set addresses = new HashSet<>(); - addresses.addAll(BAN_LIST.values().stream().map(ban -> new PeerAddress(ban.getPeer().getRawIp(), ban.getPeer().getAddress().getPort())).toList()); - addresses.addAll(BAN_LIST.values().stream().map(ban -> new PeerAddress(ban.getPeer().getAddress().getIp(), ban.getPeer().getAddress().getPort())).toList()); - return addresses; - } - public record IPDBResponse( LazyLoad geoData ) {