aljaz/lnd-manageJ
1
0
Fork 0
mirror of https://github.com/aljazceru/lnd-manageJ.git synced 2026-01-29 02:44:26 +01:00
Code Issues Packages Projects Releases Wiki Activity

add cache for synced-to-chain

Browse Source
This commit is contained in:
Carsten Otto
2021-11-12 11:50:35 +01:00
parent 9193353705
commit b03114c536
1 changed files with 24 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
application/src/main/java/de/cotto/lndmanagej/service/OwnNodeService.java
View File

@@ -1,17 +1,41 @@
package de.cotto.lndmanagej.service;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import de.cotto.lndmanagej.grpc.GrpcGetInfo;
import org.springframework.stereotype.Component;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import java.util.concurrent.TimeUnit;
@Component
public class OwnNodeService {
private static final int CACHE_EXPIRY_SECONDS = 30;
private final GrpcGetInfo grpcGetInfo;
private final LoadingCache<String, Boolean> syncedToChainCache;
public OwnNodeService(GrpcGetInfo grpcGetInfo) {
this.grpcGetInfo = grpcGetInfo;
CacheLoader<String, Boolean> loader = new CacheLoader<>() {
@Nonnull
@Override
public Boolean load(@Nullable String ignored) {
return isSyncedToChainWithoutCache();
}
};
syncedToChainCache = CacheBuilder.newBuilder()
.expireAfterWrite(CACHE_EXPIRY_SECONDS, TimeUnit.SECONDS)
.build(loader);
}
public boolean isSyncedToChain() {
return syncedToChainCache.getUnchecked("");
}
private boolean isSyncedToChainWithoutCache() {
return grpcGetInfo.isSyncedToChain().orElse(false);
}
}