mirror/DisCal-Discord-Bot
1
0
Fork 0
mirror of https://github.com/DreamExposure/DisCal-Discord-Bot.git synced 2026-01-26 13:58:27 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add cache key prefix to d4j stores

Browse Source
This commit is contained in:
NovaFox161
2023-01-29 20:18:14 -06:00
parent 932515fb5b
commit 4fbe4cc9af
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
client/src/main/kotlin/org/dreamexposure/discal/client/config/DiscordConfig.kt
View File

@@ -22,6 +22,7 @@ import discord4j.store.api.mapping.MappingStoreService
import discord4j.store.api.service.StoreService
import discord4j.store.jdk.JdkStoreService
import discord4j.store.redis.RedisClusterStoreService
import discord4j.store.redis.RedisStoreDefaults
import discord4j.store.redis.RedisStoreService
import io.lettuce.core.RedisClient
import io.lettuce.core.RedisURI
@@ -84,6 +85,7 @@ class DiscordConfig {
val redisPassword = Config.REDIS_PASSWORD.getString().toCharArray()
val redisPort = Config.REDIS_PORT.getInt()
val redisCluster = Config.CACHE_REDIS_IS_CLUSTER.getBoolean()
val prefix = Config.CACHE_PREFIX.getString()
return if (useRedis) {
val uriBuilder = RedisURI.Builder
@@ -93,10 +95,12 @@ class DiscordConfig {
val rss = if (redisCluster) {
RedisClusterStoreService.Builder()
.redisClient(RedisClusterClient.create(uriBuilder.build()))
.keyPrefix("$prefix.${RedisStoreDefaults.DEFAULT_KEY_PREFIX}")
.build()
} else {
RedisStoreService.Builder()
.redisClient(RedisClient.create(uriBuilder.build()))
.keyPrefix("$prefix.${RedisStoreDefaults.DEFAULT_KEY_PREFIX}")
.build()
}