kamma/darts-stats-web
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

data as TTL

Browse Source
This commit is contained in:
rdavidek 2025-12-28 21:08:56 +01:00
parent 7b4fd6ed57
commit 672dc74ec1
1 changed files with 28 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/main/java/cz/kamma/darts/App.java
View File

@ -12,12 +12,31 @@ import java.nio.charset.StandardCharsets;
import java.nio.file.Files; import java.nio.file.Files;
import java.nio.file.Paths; import java.nio.file.Paths;
import java.util.*; import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
public class App { public class App {
private static final Gson GSON = new Gson(); private static final Gson GSON = new Gson();
private static final Map<String, List<DartsGame>> GAMES_CACHE = Collections.synchronizedMap(new HashMap<>()); private static final Map<String, CachedData> GAMES_CACHE = new ConcurrentHashMap<>();
private static final long MAX_UPLOAD_SIZE = 5 * 1024 * 1024; // 5MB private static final long MAX_UPLOAD_SIZE = 5 * 1024 * 1024; // 5MB
private static final long TTL_MS = TimeUnit.HOURS.toMillis(2);
static class CachedData {
final List<DartsGame> games;
final long expiryTime;
CachedData(List<DartsGame> games) {
this.games = games;
this.expiryTime = System.currentTimeMillis() + TTL_MS;
}
boolean isExpired() {
return System.currentTimeMillis() > expiryTime;
}
}
public static void main(String[] args) throws IOException { public static void main(String[] args) throws IOException {
int port = 8080; int port = 8080;
@ -28,6 +47,11 @@ public class App {
server.createContext("/api/upload", new UploadHandler()); server.createContext("/api/upload", new UploadHandler());
server.createContext("/api/clear", new ClearHandler()); server.createContext("/api/clear", new ClearHandler());
ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
scheduler.scheduleAtFixedRate(() -> {
GAMES_CACHE.entrySet().removeIf(entry -> entry.getValue().isExpired());
}, 1, 1, TimeUnit.MINUTES);
server.setExecutor(null); server.setExecutor(null);
System.out.println("Server started on port " + port); System.out.println("Server started on port " + port);
server.start(); server.start();
@ -105,7 +129,7 @@ public class App {
List<DartsGame> convertedGames = convertRawToGames(rawGames); List<DartsGame> convertedGames = convertRawToGames(rawGames);
String code = generateCode(); String code = generateCode();
GAMES_CACHE.put(code, convertedGames); GAMES_CACHE.put(code, new CachedData(convertedGames));
exchange.getResponseHeaders().set("Location", "/?code=" + code); exchange.getResponseHeaders().set("Location", "/?code=" + code);
exchange.sendResponseHeaders(303, -1); exchange.sendResponseHeaders(303, -1);
@ -195,10 +219,8 @@ public class App {
Map<String, String> params = parseQuery(exchange.getRequestURI().getQuery()); Map<String, String> params = parseQuery(exchange.getRequestURI().getQuery());
String code = params.get("code"); String code = params.get("code");
List<DartsGame> games = (code != null) ? GAMES_CACHE.get(code.toUpperCase()) : null; CachedData cached = (code != null) ? GAMES_CACHE.get(code.toUpperCase()) : null;
if (games == null) { List<DartsGame> games = (cached != null && !cached.isExpired()) ? cached.games : Collections.emptyList();
games = Collections.emptyList();
}
StatsResponse response = aggregateStats(new ArrayList<>(games)); StatsResponse response = aggregateStats(new ArrayList<>(games));