Kutt/server/migrations/20241103083933_user-roles.js

const { ROLES } = require("../consts");
const env = require("../env");

/**
 * @param { import("knex").Knex } knex
 * @returns { Promise<void> }
 */
async function up(knex) {
  const hasRole = await knex.schema.hasColumn("users", "role");
  if (!hasRole) {
    await knex.transaction(async function(trx) {
      await trx.schema.alterTable("users", table => {
        table
          .enu("role", [ROLES.USER, ROLES.ADMIN])
          .notNullable()
          .defaultTo(ROLES.USER);
      });
      const adminEmails = env.ADMIN_EMAILS.split(",").map((e) => e.trim());
      const adminRoleQuery = trx("users").update("role", ROLES.ADMIN);
      adminEmails.forEach((adminEmail, index) => {
        if (index === 0) {
          adminRoleQuery.where("email", adminEmail);
        } else {
          adminRoleQuery.orWhere("email", adminEmail);
        }
      });
      await adminRoleQuery;
    });
  }
};

/**
 * @param { import("knex").Knex } knex
 * @returns { Promise<void> }
 */
async function down(knex) {};

module.exports = {
  up,
  down,
}