diff --git a/src/officesense_pi/src/redis/redis.ts b/src/officesense_pi/src/redis/redis.ts index bb03317..2db42fe 100644 --- a/src/officesense_pi/src/redis/redis.ts +++ b/src/officesense_pi/src/redis/redis.ts @@ -5,10 +5,16 @@ import { updateRoomOccupancyListener } from "../core/analyze.js"; let redisClient: RedisClientType; let subRedisClient: RedisClientType; +const redisOptions = { + socket: { + host: config.redis.host, + port: config.redis.port, + }, + password: config.redis.password, +}; + export async function initSubRedis(): Promise { - subRedisClient = createClient({ - url: `redis://${config.redis.host}:${config.redis.port}`, - }); + subRedisClient = createClient(redisOptions); subRedisClient.on("error", (err) => { console.log("[Redis] SubRedis error:", err.message); @@ -24,9 +30,7 @@ export async function initSubRedis(): Promise { } export async function initRedis(): Promise { - redisClient = createClient({ - url: `redis://${config.redis.host}:${config.redis.port}`, - }); + redisClient = createClient(redisOptions); redisClient.on("error", (err) => { console.log("[Redis] Redis error:", err.message);