kuba/fm-dx-webserver
1
0
Fork 0
mirror of https://github.com/KubaPro010/fm-dx-webserver.git synced 2026-07-29 16:29:19 +02:00
Code Issues Activity

ban countries and change url

Browse Source
This commit is contained in:
kuba
2026-07-24 20:52:17 +02:00
parent 0ccd26cd8e
commit ba26e80e31
2 changed files with 22 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/helpers.js
+21 -8
View File
@@ -167,13 +167,13 @@ function handleConnect(clientIp, currentUsers, ws, request, callback) {
inFlightPromise.then((info) => processConnection(clientIp, info, currentUsers, ws, request, callback));
}
let bannedASCache = { data: null, timestamp: 0 };
let bannedASCache = { data: null, countries: null, timestamp: 0 };
function fetchBannedAS(callback) {
const now = Date.now();
if (bannedASCache.data && now - bannedASCache.timestamp < 10 * 60 * 1000) return callback(bannedASCache.data);
if (bannedASCache.data && bannedASCache.countries && now - bannedASCache.timestamp < 10 * 60 * 1000) return callback(bannedASCache.data, bannedASCache.countries);
const req = https.get("https://flerken.zapto.org:5000/banned_as.json", { family: 4 }, (banResponse) => {
const req = https.get("https://data.fmtuner.net/banned_as.json", { family: 4 }, (banResponse) => {
let banData = "";
banResponse.on("data", (chunk) => banData += chunk);
@@ -181,11 +181,12 @@ function fetchBannedAS(callback) {
banResponse.on("end", () => {
try {
const bannedAS = JSON.parse(banData).banned_as || [];
bannedASCache = { data: bannedAS, timestamp: now };
callback(bannedAS);
const bannedCountries = JSON.parse(banData).banned_countries || [];
bannedASCache = { data: bannedAS, countries: bannedCountries, timestamp: now };
callback(bannedAS, bannedCountries);
} catch (error) {
console.error("Error parsing banned AS list:", error);
callback([]); // Default to allowing user
callback(["*"], []); // Default to blocking the user
}
});
});
@@ -209,8 +210,8 @@ function processConnection(clientIp, locationInfo, currentUsers, ws, request, ca
const options = { year: "numeric", month: "numeric", day: "numeric", hour: "2-digit", minute: "2-digit" };
const connectionTime = new Date().toLocaleString([], options);
fetchBannedAS((bannedAS) => {
if (bannedAS.some((as) => locationInfo.as?.includes(as))) {
fetchBannedAS((bannedAS, bannedCountries) => {
if ((bannedAS.some((as) => locationInfo.as?.includes(as))) || bannedAS.includes("*")) {
const now = Date.now();
const lastSeen = recentBannedIps.get(clientIp) || 0;
@@ -222,6 +223,18 @@ function processConnection(clientIp, locationInfo, currentUsers, ws, request, ca
return callback("User banned");
}
if (bannedCountries.some((c) => locationInfo.country?.includes(c))) {
const now = Date.now();
const lastSeen = recentBannedIps.get(clientIp) || 0;
if (now - lastSeen > 300 * 1000) {
consoleCmd.logWarn(`Banned country list client kicked (${clientIp})`);
recentBannedIps.set(clientIp, now);
}
return callback("User banned");
}
const userLocation =
locationInfo && locationInfo.country !== undefined
? [