aljaz/lnd-manageJ
1
0
Fork 0
mirror of https://github.com/aljazceru/lnd-manageJ.git synced 2026-01-21 15:04:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

add cache

Browse Source
This commit is contained in:
Carsten Otto
2021-12-28 09:30:38 +01:00
parent de40c32f63
commit fba5090268
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
backend/src/main/java/de/cotto/lndmanagej/service/OnlinePeersService.java
View File

@@ -1,5 +1,7 @@
package de.cotto.lndmanagej.service;
import com.github.benmanes.caffeine.cache.LoadingCache;
import de.cotto.lndmanagej.caching.CacheBuilder;
import de.cotto.lndmanagej.model.Node;
import de.cotto.lndmanagej.model.OnlineReport;
import de.cotto.lndmanagej.model.OnlineStatus;
@@ -12,14 +14,23 @@ import java.time.ZoneOffset;
import java.time.ZonedDateTime;
import java.time.temporal.ChronoUnit;
import java.util.List;
import java.util.Objects;
@Component
public class OnlinePeersService {
private static final int DAYS_FOR_OFFLINE_PERCENTAGE = 7;
private static final Duration CACHE_REFRESH = Duration.ofMinutes(1);
private static final Duration CACHE_EXPIRY = Duration.ofMinutes(2);
private final OnlinePeersDao dao;
private final LoadingCache<Pubkey, Integer> onlinePercentageCache;
public OnlinePeersService(OnlinePeersDao dao) {
this.dao = dao;
onlinePercentageCache = new CacheBuilder()
.withRefresh(CACHE_REFRESH)
.withExpiry(CACHE_EXPIRY)
.build(this::getOnlinePercentageLastWeekWithoutCache);
}
public OnlineReport getOnlineReport(Node node) {
@@ -34,6 +45,10 @@ public class OnlinePeersService {
}
public int getOnlinePercentageLastWeek(Pubkey pubkey) {
return Objects.requireNonNull(onlinePercentageCache.get(pubkey));
}
private int getOnlinePercentageLastWeekWithoutCache(Pubkey pubkey) {
Duration total = Duration.ZERO;
Duration online = Duration.ZERO;
ZonedDateTime intervalStart = ZonedDateTime.now(ZoneOffset.UTC);