updating utils files: Organizing them and also adding a redis client/store, to use with express-session

Author: HDdev8

…20231109_01_add_teams_and_memberships.js …20230911_01_add_teams_and_memberships.jsmigrations/20231109_01_add_teams_and_memberships.js renamed to migrations/20230911_01_add_teams_and_memberships.js migrations/20231109_01_add_teams_and_memberships.js renamed to migrations/20230911_01_add_teams_and_memberships.js

@@ -0,0 +1,30 @@
+const {DataTypes} = require("sequelize");
+
+module.exports = {
+  up: async ({context: queryInterface}) => {
+    await queryInterface.createTable("user_posts", {
+      id: {
+        type: DataTypes.INTEGER,
+        primaryKey: true,
+        autoIncrement: true,
+      },
+      user_id: {
+        type: DataTypes.INTEGER,
+        allowNull: false,
+        references: {model: "users", key: "id"},
+      },
+      post_id: {
+        type: DataTypes.INTEGER,
+        allowNull: false,
+        references: {model: "posts", key: "id"},
+      },
+      read: {
+        type: DataTypes.BOOLEAN,
+        defaultValue: false,
+      },
+    });
+  },
+  down: async ({context: queryInterface}) => {
+    await queryInterface.dropTable("user_posts");
+  },
+};

migrations/20230917_02_add_user_posts.js

@@ -0,0 +1,13 @@
+const {DataTypes} = require("sequelize");
+
+module.exports = {
+  up: async ({context: queryInterface}) => {
+    await queryInterface.addColumn("posts", "content", {
+      type: DataTypes.STRING,
+      defaultValue: "",
+    });
+  },
+  down: async ({context: queryInterface}) => {
+    await queryInterface.removeColumn("posts", "content");
+  },
+};

migrations/20230922_03_add_content_to_posts.js

@@ -0,0 +1,3 @@
+const {migrationDown} = require("./sequelize");
+
+migrationDown();

utils/db.js

@@ -0,0 +1,3 @@
+const {migrationUp} = require("./sequelize");
+
+migrationUp();

utils/migrationDown.js

@@ -0,0 +1,62 @@
+const RedisStore = require("connect-redis").default;
+const redis = require("redis");
+
+// Method 1
+// const redisClient1 = redis.createClient({
+//   host: process.env.REDIS_HOST,
+//   port: process.env.REDIS_PORT,
+//   password: process.env.REDIS_PASSWORD,
+// });
+// // Method 2
+// const redisClient2 = redis.createClient({
+//   url: process.env.REDIS_URI,
+// });
+
+const redisClient = redis.createClient();
+redisClient.connect().catch(console.error);
+
+// const redisClient = createClient({
+//   username: "default", // use your Redis user. More info https://redis.io/docs/management/security/acl/
+//   password: "secret", // use your password here
+//   socket: {
+//     host: "my-redis.cloud.redislabs.com",
+//     port: 6379,
+//     tls: true,
+//     key: readFileSync("./redis_user_private.key"),
+//     cert: readFileSync("./redis_user.crt"),
+//     ca: [readFileSync("./redis_ca.pem")],
+//   },
+// });
+// redisClient.on("error", (err) => console.log("Redis Client Error", err));
+// await redisClient.connect();
+// await redisClient.disconnect();
+
+// {
+//     secret: process.env.session_secret,
+//     name: process.env.session_name,
+//     store: new RedisSession({
+//       client
+//     }),
+//     rolling: true,
+//     saveUninitialized: true,
+//     unset: 'destroy',
+//     resave: true,
+//     proxy: true,
+//     logErrors: process.env.debug === 'true',
+//     cookie: {
+//       path: '/',
+//       domain: '.' + process.env.app_domain,
+//       secure: true,
+//       sameSite: true,
+//       httpOnly: true,
+//       expires: false,
+//       maxAge: 60000 * process.env.session_exp_mins,
+//     }
+//   }
+
+const redisStore = new RedisStore({
+  client: redisClient,
+  prefix: "myapp:",
+});
+
+module.exports = redisStore;

utils/migrationUp.js

@@ -0,0 +1,64 @@
+const Sequelize = require("sequelize");
+const {Umzug, SequelizeStorage} = require("umzug");
+const config = require("../config/config");
+const logger = require("../logger/logger");
+
+const sequelize = new Sequelize(config.DB, {
+  dialectOptions: {
+    ssl: {
+      require: true,
+      rejectUnauthorized: false,
+    },
+  },
+  dialect: "postgres",
+});
+
+const migrationConf = {
+  migrations: {glob: "migrations/*.js"},
+  context: sequelize.getQueryInterface(),
+  storage: new SequelizeStorage({sequelize, tableName: "migrations"}),
+};
+
+const migrationUp = async () => {
+  try {
+    await sequelize.authenticate();
+    const migrator = new Umzug(migrationConf);
+    const migrations = await migrator.up();
+    logger.info("Migrations up to date", {
+      files: migrations.map((m) => m.name),
+    });
+  } catch (error) {
+    logger.error(`Error running migration: ${error}`);
+  }
+};
+
+const migrationDown = async () => {
+  try {
+    await sequelize.authenticate();
+    const migrator = new Umzug(migrationConf);
+    const migrations = await migrator.down();
+    logger.info("Migrations removed", {
+      files: migrations.map((m) => m.name),
+    });
+  } catch (error) {
+    logger.error(`Error rolling back migration: ${error}`);
+  }
+};
+
+const connectToDatabase = async () => {
+  try {
+    await sequelize.authenticate();
+    logger.info(`connected to the database`);
+  } catch (err) {
+    logger.error(`failed to connect to the database: ${err}`);
+    process.exitCode = 1;
+  }
+  return null;
+};
+
+module.exports = {
+  connectToDatabase,
+  sequelize,
+  migrationUp,
+  migrationDown,
+};