Make redis connection into a model module

This commit is contained in:
Apher 2026-06-28 19:13:12 +00:00
parent 66845ed610
commit e04ed134b0
2 changed files with 17 additions and 11 deletions

View File

@ -18,6 +18,7 @@ const sequelize = new Sequelize(
} }
); );
// SQL Connection
const db = {}; const db = {};
db.Sequelize = Sequelize; db.Sequelize = Sequelize;
@ -37,4 +38,19 @@ db.user.belongsToMany(db.role, {
db.ROLES = ["user", "admin"]; db.ROLES = ["user", "admin"];
module.exports = db; // Redis Connection
const Redis = require('redis');
const redis = {};
redis.client = redis.createClient({
host: process.env.REDIS_HOST,
port: process.env.REDIS_PORT,
});
redis.client.on('error', (err) => console.error('Redis error:', err));
module.exports = {
db,
redis
};

View File

@ -9,8 +9,6 @@ const { sequelize, Sequelize } = require('./models');
const db = require("./models"); const db = require("./models");
const Role = db.role; const Role = db.role;
const redis = require('redis');
const createApp = () => { const createApp = () => {
const app = express(); const app = express();
@ -43,14 +41,6 @@ const createApp = () => {
})); }));
} }
// Redis Connection
const redisClient = redis.createClient({
host: process.env.REDIS_HOST,
port: process.env.REDIS_PORT,
});
redisClient.on('error', (err) => console.error('Redis error:', err));
// Health check // Health check
app.get("/health", (req, res) => res.status(200).send({status: "ok"})); app.get("/health", (req, res) => res.status(200).send({status: "ok"}));