38 lines
877 B
JavaScript
38 lines
877 B
JavaScript
const config = require('./config');
|
|
|
|
const Redis = require('redis');
|
|
const redis = {};
|
|
|
|
redis.client = Redis.createClient({
|
|
url: `redis://default@${config.REDIS_HOST}:${config.REDIS_PORT}`
|
|
});
|
|
|
|
redis.connect = async () => {
|
|
await redis.client.connect().catch(console.error);
|
|
}
|
|
|
|
redis.quit = async () => {
|
|
await redis.client.quit();
|
|
}
|
|
|
|
redis.ensureGroup = async (stream, group) => {
|
|
await redis.connect();
|
|
|
|
try {
|
|
await redis.client.xGroupCreate(stream, group, "0", {MKSTREAM: true});
|
|
|
|
console.log(`Created consumer group: ${group} (${stream})`);
|
|
} catch (err) {
|
|
if (err) {
|
|
if (err.message.includes('BUSYGROUP')) {
|
|
console.log(`Consumer group already exists: ${group} (${stream})`);
|
|
} else {
|
|
console.error(err);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
redis
|
|
} |