added redis configuration
This commit is contained in:
94
package-lock.json
generated
94
package-lock.json
generated
@@ -17,7 +17,9 @@
|
||||
"jsonwebtoken": "^9.0.2",
|
||||
"pg": "^8.16.0",
|
||||
"pino": "^9.7.0",
|
||||
"pino-http": "^10.4.0"
|
||||
"pino-http": "^10.4.0",
|
||||
"redis": "^5.7.0",
|
||||
"uuid": "^11.1.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@eslint/js": "^9.28.0",
|
||||
@@ -265,6 +267,61 @@
|
||||
"url": "https://opencollective.com/pkgr"
|
||||
}
|
||||
},
|
||||
"node_modules/@redis/bloom": {
|
||||
"version": "5.7.0",
|
||||
"resolved": "https://registry.npmjs.org/@redis/bloom/-/bloom-5.7.0.tgz",
|
||||
"integrity": "sha512-KtBHDH2Aw1BxYDQd87PJsdEmZcpMbD4oPzdBwB4IvSRmMovukO2NNGi5vpCHhCoicS83zu7cjX1fw79uFBZFJA==",
|
||||
"engines": {
|
||||
"node": ">= 18"
|
||||
},
|
||||
"peerDependencies": {
|
||||
"@redis/client": "^5.7.0"
|
||||
}
|
||||
},
|
||||
"node_modules/@redis/client": {
|
||||
"version": "5.7.0",
|
||||
"resolved": "https://registry.npmjs.org/@redis/client/-/client-5.7.0.tgz",
|
||||
"integrity": "sha512-YV3Knspdj9k6H6s4v8QRcj1WBxHt40vtPmszLKGwRUOUpUOLWSlI9oCUjprMDcQNzgSCXGXYdL/Aj6nT2+Ub0w==",
|
||||
"dependencies": {
|
||||
"cluster-key-slot": "1.1.2"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 18"
|
||||
}
|
||||
},
|
||||
"node_modules/@redis/json": {
|
||||
"version": "5.7.0",
|
||||
"resolved": "https://registry.npmjs.org/@redis/json/-/json-5.7.0.tgz",
|
||||
"integrity": "sha512-VP3wtse1PSB/UjZAV1lWyDrWrrZcwi/cjb3L0lIarcIJ+EbHliB2QPml0Bvjz8F8F0eDJRtChJVXFc+jhGxCtA==",
|
||||
"engines": {
|
||||
"node": ">= 18"
|
||||
},
|
||||
"peerDependencies": {
|
||||
"@redis/client": "^5.7.0"
|
||||
}
|
||||
},
|
||||
"node_modules/@redis/search": {
|
||||
"version": "5.7.0",
|
||||
"resolved": "https://registry.npmjs.org/@redis/search/-/search-5.7.0.tgz",
|
||||
"integrity": "sha512-dDZIq8pZJnT+kZ9xRlLLi2Rvkd792z9eh31QRIwPr5wXjAXeaQ+Nf65em6dLpsxZ60MmhwDwLrBPJpYVjKPBPQ==",
|
||||
"engines": {
|
||||
"node": ">= 18"
|
||||
},
|
||||
"peerDependencies": {
|
||||
"@redis/client": "^5.7.0"
|
||||
}
|
||||
},
|
||||
"node_modules/@redis/time-series": {
|
||||
"version": "5.7.0",
|
||||
"resolved": "https://registry.npmjs.org/@redis/time-series/-/time-series-5.7.0.tgz",
|
||||
"integrity": "sha512-AJTF9sz3y1MJAukgQW4Jw8zt8qGOE3+1d87pufOP35zsFBlHipGscpctoXiNMebfy0114y/FjSprr65LjbJQSQ==",
|
||||
"engines": {
|
||||
"node": ">= 18"
|
||||
},
|
||||
"peerDependencies": {
|
||||
"@redis/client": "^5.7.0"
|
||||
}
|
||||
},
|
||||
"node_modules/@types/estree": {
|
||||
"version": "1.0.7",
|
||||
"resolved": "https://registry.npmjs.org/@types/estree/-/estree-1.0.7.tgz",
|
||||
@@ -644,6 +701,14 @@
|
||||
"url": "https://github.com/sponsors/sindresorhus"
|
||||
}
|
||||
},
|
||||
"node_modules/cluster-key-slot": {
|
||||
"version": "1.1.2",
|
||||
"resolved": "https://registry.npmjs.org/cluster-key-slot/-/cluster-key-slot-1.1.2.tgz",
|
||||
"integrity": "sha512-RMr0FhtfXemyinomL4hrWcYJxmX6deFdCxpJzhDttxgO1+bcCnkk+9drydLVDmAMG7NE6aN/fl4F7ucU/90gAA==",
|
||||
"engines": {
|
||||
"node": ">=0.10.0"
|
||||
}
|
||||
},
|
||||
"node_modules/color-convert": {
|
||||
"version": "2.0.1",
|
||||
"resolved": "https://registry.npmjs.org/color-convert/-/color-convert-2.0.1.tgz",
|
||||
@@ -2894,6 +2959,21 @@
|
||||
"node": ">= 12.13.0"
|
||||
}
|
||||
},
|
||||
"node_modules/redis": {
|
||||
"version": "5.7.0",
|
||||
"resolved": "https://registry.npmjs.org/redis/-/redis-5.7.0.tgz",
|
||||
"integrity": "sha512-ZRbiWYBUYdDTopodRjCVwwCLThrkciPW3bOrkdMCW3nYEelBwUGN6SovmACDsiLUB7mnU3mXnaI5f0W7bDcwng==",
|
||||
"dependencies": {
|
||||
"@redis/bloom": "5.7.0",
|
||||
"@redis/client": "5.7.0",
|
||||
"@redis/json": "5.7.0",
|
||||
"@redis/search": "5.7.0",
|
||||
"@redis/time-series": "5.7.0"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">= 18"
|
||||
}
|
||||
},
|
||||
"node_modules/resolve-from": {
|
||||
"version": "4.0.0",
|
||||
"resolved": "https://registry.npmjs.org/resolve-from/-/resolve-from-4.0.0.tgz",
|
||||
@@ -3399,6 +3479,18 @@
|
||||
"punycode": "^2.1.0"
|
||||
}
|
||||
},
|
||||
"node_modules/uuid": {
|
||||
"version": "11.1.0",
|
||||
"resolved": "https://registry.npmjs.org/uuid/-/uuid-11.1.0.tgz",
|
||||
"integrity": "sha512-0/A9rDy9P7cJ+8w1c9WD9V//9Wj15Ce2MPz8Ri6032usz+NfePxx5AcN3bN+r6ZL6jEo066/yNYB3tn4pQEx+A==",
|
||||
"funding": [
|
||||
"https://github.com/sponsors/broofa",
|
||||
"https://github.com/sponsors/ctavan"
|
||||
],
|
||||
"bin": {
|
||||
"uuid": "dist/esm/bin/uuid"
|
||||
}
|
||||
},
|
||||
"node_modules/vary": {
|
||||
"version": "1.1.2",
|
||||
"resolved": "https://registry.npmjs.org/vary/-/vary-1.1.2.tgz",
|
||||
|
@@ -21,7 +21,9 @@
|
||||
"jsonwebtoken": "^9.0.2",
|
||||
"pg": "^8.16.0",
|
||||
"pino": "^9.7.0",
|
||||
"pino-http": "^10.4.0"
|
||||
"pino-http": "^10.4.0",
|
||||
"redis": "^5.7.0",
|
||||
"uuid": "^11.1.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@eslint/js": "^9.28.0",
|
||||
|
58
src/config/redis.js
Normal file
58
src/config/redis.js
Normal file
@@ -0,0 +1,58 @@
|
||||
const { createClient } = require('redis');
|
||||
const { redisUrl } = require('./config');
|
||||
const { logger } = require('../util/logger');
|
||||
|
||||
const client = createClient({
|
||||
url: redisUrl,
|
||||
socket: {
|
||||
reconnectStrategy: (retries) => {
|
||||
const delay = Math.min(retries * 100, 5000);
|
||||
logger.info(`Redis reconnecting attempt ${retries}, delay ${delay}ms`);
|
||||
return delay;
|
||||
},
|
||||
},
|
||||
});
|
||||
|
||||
client.on('connect', () => logger.info('Connected to redis'));
|
||||
client.on('error', () => logger.error(err, 'Redis error'));
|
||||
client.on('ready', () => logger.info('Redis client ready'));
|
||||
client.on('end', () => logger.info('Redis connection closed'));
|
||||
|
||||
client
|
||||
.connect()
|
||||
.catch((err) => logger.error(err, 'Failed to connect to Redis'));
|
||||
|
||||
// Helper functions
|
||||
async function setJson(key, value, ttl = null) {
|
||||
try {
|
||||
const jsonValue = JSON.stringify(value);
|
||||
if (ttl) {
|
||||
return await client.set(key, jsonValue, { EX: ttl });
|
||||
}
|
||||
return await client.set(key, jsonValue);
|
||||
} catch (err) {
|
||||
logger.error(err, 'Redis setJson error');
|
||||
throw err;
|
||||
}
|
||||
}
|
||||
|
||||
async function getJson(key) {
|
||||
try {
|
||||
const value = await client.get(key);
|
||||
return value ? JSON.parse(value) : null;
|
||||
} catch (err) {
|
||||
logger.error(err, 'Redis getJson error');
|
||||
throw err;
|
||||
}
|
||||
}
|
||||
|
||||
process.on('SIGTERM', async () => {
|
||||
logger.info('SIGTERM received - closing Redis connection');
|
||||
await client.quit();
|
||||
});
|
||||
|
||||
module.exports = {
|
||||
client,
|
||||
getJson,
|
||||
setJson,
|
||||
};
|
Reference in New Issue
Block a user