Signal/Signal-Server
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Server synced 2026-04-20 00:19:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add Managed#stop to CurrencyConversionManager

Browse Source
This commit is contained in:
Chris Eager
2025-10-06 10:09:06 -05:00
committed by Chris Eager
parent 63f892add1
commit e9d6b91416
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
service/src/main/java/org/whispersystems/textsecuregcm/currency/CurrencyConversionManager.java
View File

@@ -21,6 +21,7 @@ import java.util.Locale;
import java.util.Map;
import java.util.Optional;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
import org.slf4j.Logger;
@@ -63,6 +64,7 @@ public class CurrencyConversionManager implements Managed {
private Map<String, BigDecimal> cachedCoinGeckoValues;
private ScheduledFuture<?> cacheUpdateFuture;
public CurrencyConversionManager(
final FixerClient fixerClient,
@@ -85,7 +87,7 @@ public class CurrencyConversionManager implements Managed {
@Override
public void start() throws Exception {
executor.scheduleAtFixedRate(() -> {
cacheUpdateFuture = executor.scheduleWithFixedDelay(() -> {
try {
updateCacheIfNecessary();
} catch (Throwable t) {
@@ -94,6 +96,13 @@ public class CurrencyConversionManager implements Managed {
}, 0, 15, TimeUnit.SECONDS);
}
@Override
public void stop() throws Exception {
if (cacheUpdateFuture != null) {
cacheUpdateFuture.cancel(true);
}
}
@VisibleForTesting
void updateCacheIfNecessary() throws IOException {
if (Duration.between(fixerUpdatedTimestamp, clock.instant()).abs().compareTo(FIXER_REFRESH_INTERVAL) >= 0 || cachedFixerValues == null) {
@@ -102,7 +111,7 @@ public class CurrencyConversionManager implements Managed {
}
{
final Map<String, BigDecimal> CoinGeckoValuesFromSharedCache = cacheCluster.withCluster(connection -> {
final Map<String, BigDecimal> coinGeckoValuesFromSharedCache = cacheCluster.withCluster(connection -> {
final Map<String, BigDecimal> parsedSharedCacheData = new HashMap<>();
connection.sync().hgetall(COIN_GECKO_SHARED_CACHE_DATA_KEY).forEach((currency, conversionRate) ->
@@ -111,8 +120,8 @@ public class CurrencyConversionManager implements Managed {
return parsedSharedCacheData;
});
if (CoinGeckoValuesFromSharedCache != null && !CoinGeckoValuesFromSharedCache.isEmpty()) {
cachedCoinGeckoValues = CoinGeckoValuesFromSharedCache;
if (coinGeckoValuesFromSharedCache != null && !coinGeckoValuesFromSharedCache.isEmpty()) {
cachedCoinGeckoValues = coinGeckoValuesFromSharedCache;
}
}