Skip to content

Commit 4bf4aa8

Browse files
committed
chore: formatting and increment usage stats asynchronously
1 parent ee10f0f commit 4bf4aa8

5 files changed

Lines changed: 9 additions & 3 deletions

File tree

server/src/main/java/org/eclipse/openvsx/ratelimit/RateLimitService.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@
3939
@Service
4040
@ConditionalOnBean(RateLimitConfig.class)
4141
public class RateLimitService {
42+
4243
private final Logger logger = LoggerFactory.getLogger(RateLimitService.class);
4344

4445
private final ProxyManager<byte[]> proxyManager;

server/src/main/java/org/eclipse/openvsx/ratelimit/UsageStatsService.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import org.slf4j.Logger;
2020
import org.slf4j.LoggerFactory;
2121
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
22+
import org.springframework.scheduling.annotation.Async;
2223
import org.springframework.stereotype.Service;
2324
import redis.clients.jedis.JedisCluster;
2425
import redis.clients.jedis.params.ScanParams;
@@ -33,6 +34,7 @@
3334
@Service
3435
@ConditionalOnBean(RateLimitConfig.class)
3536
public class UsageStatsService {
37+
3638
private final static String USAGE_DATA_KEY = "usage.customer";
3739
private final static int WINDOW_MINUTES = 5;
3840

@@ -48,6 +50,7 @@ public UsageStatsService(RepositoryService repositories, CustomerService custome
4850
this.jedisCluster = jedisCluster;
4951
}
5052

53+
@Async
5154
public void incrementUsage(Customer customer) {
5255
var key = customer.getId();
5356
var window = getCurrentUsageWindow();

server/src/main/java/org/eclipse/openvsx/ratelimit/cache/RateLimitCacheService.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -34,13 +34,13 @@
3434
@Service
3535
@ConditionalOnBean(RateLimitConfig.class)
3636
public class RateLimitCacheService extends JedisPubSub {
37-
public static final String CACHE_MANAGER = "rateLimitCacheManager";
38-
39-
private static final String CONFIG_UPDATE_CHANNEL = "ratelimit.config";
4037

38+
public static final String CACHE_MANAGER = "rateLimitCacheManager";
4139
public static final String CACHE_CUSTOMER = "ratelimit.customer";
4240
public static final String CACHE_TIER = "ratelimit.tier";
4341

42+
private static final String CONFIG_UPDATE_CHANNEL = "ratelimit.config";
43+
4444
private final Logger logger = LoggerFactory.getLogger(RateLimitCacheService.class);
4545

4646
private final JedisCluster jedisCluster;

server/src/main/java/org/eclipse/openvsx/ratelimit/filter/RateLimitServletFilterFactory.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
@Component
2424
@ConditionalOnBean(RateLimitConfig.class)
2525
public class RateLimitServletFilterFactory {
26+
2627
private final UsageStatsService usageStatsService;
2728
private final IdentityService identityService;
2829
private final RateLimitService rateLimitService;

server/src/main/java/org/eclipse/openvsx/ratelimit/jobs/CollectUsageStatsHandler.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424

2525
@Component
2626
public class CollectUsageStatsHandler implements JobRequestHandler<HandlerJobRequest<?>> {
27+
2728
private final Logger logger = LoggerFactory.getLogger(CollectUsageStatsHandler.class);
2829

2930
private UsageStatsService usageStatsService;

0 commit comments

Comments
 (0)