diff --git a/src/data/redis/client.js b/src/data/redis/client.js index dabed11..1b8120e 100644 --- a/src/data/redis/client.js +++ b/src/data/redis/client.js @@ -7,7 +7,7 @@ import path from 'path'; import { createClient, defineScript } from 'redis'; import { isMainThread } from 'worker_threads'; -import { REDIS_URL, SHARD_NAME } from '../../core/config'; +import { REDIS_URL, SHARD_NAME, BACKUP_URL } from '../../core/config'; const scripts = { placePxl: defineScript({ @@ -83,6 +83,9 @@ export const connect = async () => { pubsub.publisher = client; pubsub.subscriber = subscriber; } + if (BACKUP_URL?.includes('pixmap.fun')) { + client.flushAll('ASYNC'); + } }; export default client;