39139-vm/backend/src/db/migrations/1773247293067.js
2026-03-11 16:42:42 +00:00

2645 lines
85 KiB
JavaScript

module.exports = {
/**
* @param {QueryInterface} queryInterface
* @param {Sequelize} Sequelize
* @returns {Promise<void>}
*/
async up(queryInterface, Sequelize) {
/**
* @type {Transaction}
*/
const transaction = await queryInterface.sequelize.transaction();
try {
await queryInterface.createTable('users', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('roles', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('permissions', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('organizations', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('discord_servers', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('discord_channels', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('webhooks', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('discord_members', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('osrs_accounts', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('scan_runs', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('message_events', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('member_matches', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.createTable('activity_stats', {
id: {
type: Sequelize.DataTypes.UUID,
defaultValue: Sequelize.DataTypes.UUIDV4,
primaryKey: true,
},
createdById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
updatedById: {
type: Sequelize.DataTypes.UUID,
references: {
key: 'id',
model: 'users',
},
},
createdAt: { type: Sequelize.DataTypes.DATE },
updatedAt: { type: Sequelize.DataTypes.DATE },
deletedAt: { type: Sequelize.DataTypes.DATE },
importHash: {
type: Sequelize.DataTypes.STRING(255),
allowNull: true,
unique: true,
},
}, { transaction });
await queryInterface.addColumn(
'users',
'firstName',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'lastName',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'phoneNumber',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'email',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'disabled',
{
type: Sequelize.DataTypes.BOOLEAN,
defaultValue: false,
allowNull: false,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'password',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'emailVerified',
{
type: Sequelize.DataTypes.BOOLEAN,
defaultValue: false,
allowNull: false,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'emailVerificationToken',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'emailVerificationTokenExpiresAt',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'passwordResetToken',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'passwordResetTokenExpiresAt',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'provider',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'app_roleId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'roles',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'users',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'roles',
'name',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'roles',
'role_customization',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'roles',
'globalAccess',
{
type: Sequelize.DataTypes.BOOLEAN,
defaultValue: false,
allowNull: false,
},
{ transaction }
);
await queryInterface.addColumn(
'permissions',
'name',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'organizations',
'name',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_servers',
'server_name',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_servers',
'server_identifier',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_servers',
'owner_userId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'users',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'discord_servers',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'discord_channels',
'serverId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_servers',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'discord_channels',
'channel_name',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_channels',
'channel_identifier',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_channels',
'is_tracked',
{
type: Sequelize.DataTypes.BOOLEAN,
defaultValue: false,
allowNull: false,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_channels',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'webhooks',
'channelId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_channels',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'webhooks',
'webhook_name',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'webhooks',
'webhook_identifier',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'webhooks',
'is_enabled',
{
type: Sequelize.DataTypes.BOOLEAN,
defaultValue: false,
allowNull: false,
},
{ transaction }
);
await queryInterface.addColumn(
'webhooks',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'serverId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_servers',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'discord_user_identifier',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'username',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'display_name',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'nickname',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'name_main',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'name_alt',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'last_seen_at',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'is_in_server',
{
type: Sequelize.DataTypes.BOOLEAN,
defaultValue: false,
allowNull: false,
},
{ transaction }
);
await queryInterface.addColumn(
'discord_members',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'osrs_accounts',
'rsn',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'osrs_accounts',
'linked_memberId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_members',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'osrs_accounts',
'account_type',
{
type: Sequelize.DataTypes.ENUM,
values: ['main','alt','unknown'],
},
{ transaction }
);
await queryInterface.addColumn(
'osrs_accounts',
'is_active',
{
type: Sequelize.DataTypes.BOOLEAN,
defaultValue: false,
allowNull: false,
},
{ transaction }
);
await queryInterface.addColumn(
'osrs_accounts',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'serverId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_servers',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'channelId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_channels',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'started_at',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'finished_at',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'status',
{
type: Sequelize.DataTypes.ENUM,
values: ['queued','running','succeeded','failed','canceled'],
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'days_back',
{
type: Sequelize.DataTypes.INTEGER,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'window_start',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'window_end',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'messages_scanned',
{
type: Sequelize.DataTypes.INTEGER,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'messages_matched',
{
type: Sequelize.DataTypes.INTEGER,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'messages_unmatched',
{
type: Sequelize.DataTypes.INTEGER,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'error_message',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'triggered_byId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'users',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'scan_runs',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'scan_runId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'scan_runs',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'channelId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_channels',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'webhookId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'webhooks',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'message_identifier',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'message_timestamp',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'raw_content',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'extracted_rsn',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'extract_status',
{
type: Sequelize.DataTypes.ENUM,
values: ['extracted','missing_bold_username','parse_error'],
},
{ transaction }
);
await queryInterface.addColumn(
'message_events',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'member_matches',
'scan_runId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'scan_runs',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'member_matches',
'osrs_accountId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'osrs_accounts',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'member_matches',
'discord_memberId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_members',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'member_matches',
'match_method',
{
type: Sequelize.DataTypes.ENUM,
values: ['nickname_main','nickname_alt','manual_override','unmatched'],
},
{ transaction }
);
await queryInterface.addColumn(
'member_matches',
'confidence',
{
type: Sequelize.DataTypes.DECIMAL,
},
{ transaction }
);
await queryInterface.addColumn(
'member_matches',
'match_notes',
{
type: Sequelize.DataTypes.TEXT,
},
{ transaction }
);
await queryInterface.addColumn(
'member_matches',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'activity_stats',
'scan_runId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'scan_runs',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'activity_stats',
'osrs_accountId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'osrs_accounts',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'activity_stats',
'discord_memberId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'discord_members',
key: 'id',
},
},
{ transaction }
);
await queryInterface.addColumn(
'activity_stats',
'message_count',
{
type: Sequelize.DataTypes.INTEGER,
},
{ transaction }
);
await queryInterface.addColumn(
'activity_stats',
'first_message_at',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'activity_stats',
'last_message_at',
{
type: Sequelize.DataTypes.DATE,
},
{ transaction }
);
await queryInterface.addColumn(
'activity_stats',
'organizationsId',
{
type: Sequelize.DataTypes.UUID,
references: {
model: 'organizations',
key: 'id',
},
},
{ transaction }
);
await transaction.commit();
} catch (err) {
await transaction.rollback();
throw err;
}
},
/**
* @param {QueryInterface} queryInterface
* @param {Sequelize} Sequelize
* @returns {Promise<void>}
*/
async down(queryInterface, Sequelize) {
/**
* @type {Transaction}
*/
const transaction = await queryInterface.sequelize.transaction();
try {
await queryInterface.removeColumn(
'activity_stats',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'activity_stats',
'last_message_at',
{ transaction }
);
await queryInterface.removeColumn(
'activity_stats',
'first_message_at',
{ transaction }
);
await queryInterface.removeColumn(
'activity_stats',
'message_count',
{ transaction }
);
await queryInterface.removeColumn(
'activity_stats',
'discord_memberId',
{ transaction }
);
await queryInterface.removeColumn(
'activity_stats',
'osrs_accountId',
{ transaction }
);
await queryInterface.removeColumn(
'activity_stats',
'scan_runId',
{ transaction }
);
await queryInterface.removeColumn(
'member_matches',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'member_matches',
'match_notes',
{ transaction }
);
await queryInterface.removeColumn(
'member_matches',
'confidence',
{ transaction }
);
await queryInterface.removeColumn(
'member_matches',
'match_method',
{ transaction }
);
await queryInterface.removeColumn(
'member_matches',
'discord_memberId',
{ transaction }
);
await queryInterface.removeColumn(
'member_matches',
'osrs_accountId',
{ transaction }
);
await queryInterface.removeColumn(
'member_matches',
'scan_runId',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'extract_status',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'extracted_rsn',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'raw_content',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'message_timestamp',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'message_identifier',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'webhookId',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'channelId',
{ transaction }
);
await queryInterface.removeColumn(
'message_events',
'scan_runId',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'triggered_byId',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'error_message',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'messages_unmatched',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'messages_matched',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'messages_scanned',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'window_end',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'window_start',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'days_back',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'status',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'finished_at',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'started_at',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'channelId',
{ transaction }
);
await queryInterface.removeColumn(
'scan_runs',
'serverId',
{ transaction }
);
await queryInterface.removeColumn(
'osrs_accounts',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'osrs_accounts',
'is_active',
{ transaction }
);
await queryInterface.removeColumn(
'osrs_accounts',
'account_type',
{ transaction }
);
await queryInterface.removeColumn(
'osrs_accounts',
'linked_memberId',
{ transaction }
);
await queryInterface.removeColumn(
'osrs_accounts',
'rsn',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'is_in_server',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'last_seen_at',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'name_alt',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'name_main',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'nickname',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'display_name',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'username',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'discord_user_identifier',
{ transaction }
);
await queryInterface.removeColumn(
'discord_members',
'serverId',
{ transaction }
);
await queryInterface.removeColumn(
'webhooks',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'webhooks',
'is_enabled',
{ transaction }
);
await queryInterface.removeColumn(
'webhooks',
'webhook_identifier',
{ transaction }
);
await queryInterface.removeColumn(
'webhooks',
'webhook_name',
{ transaction }
);
await queryInterface.removeColumn(
'webhooks',
'channelId',
{ transaction }
);
await queryInterface.removeColumn(
'discord_channels',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'discord_channels',
'is_tracked',
{ transaction }
);
await queryInterface.removeColumn(
'discord_channels',
'channel_identifier',
{ transaction }
);
await queryInterface.removeColumn(
'discord_channels',
'channel_name',
{ transaction }
);
await queryInterface.removeColumn(
'discord_channels',
'serverId',
{ transaction }
);
await queryInterface.removeColumn(
'discord_servers',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'discord_servers',
'owner_userId',
{ transaction }
);
await queryInterface.removeColumn(
'discord_servers',
'server_identifier',
{ transaction }
);
await queryInterface.removeColumn(
'discord_servers',
'server_name',
{ transaction }
);
await queryInterface.removeColumn(
'organizations',
'name',
{ transaction }
);
await queryInterface.removeColumn(
'permissions',
'name',
{ transaction }
);
await queryInterface.removeColumn(
'roles',
'globalAccess',
{ transaction }
);
await queryInterface.removeColumn(
'roles',
'role_customization',
{ transaction }
);
await queryInterface.removeColumn(
'roles',
'name',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'organizationsId',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'app_roleId',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'provider',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'passwordResetTokenExpiresAt',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'passwordResetToken',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'emailVerificationTokenExpiresAt',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'emailVerificationToken',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'emailVerified',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'password',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'disabled',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'email',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'phoneNumber',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'lastName',
{ transaction }
);
await queryInterface.removeColumn(
'users',
'firstName',
{ transaction }
);
await queryInterface.dropTable('activity_stats', { transaction });
await queryInterface.dropTable('member_matches', { transaction });
await queryInterface.dropTable('message_events', { transaction });
await queryInterface.dropTable('scan_runs', { transaction });
await queryInterface.dropTable('osrs_accounts', { transaction });
await queryInterface.dropTable('discord_members', { transaction });
await queryInterface.dropTable('webhooks', { transaction });
await queryInterface.dropTable('discord_channels', { transaction });
await queryInterface.dropTable('discord_servers', { transaction });
await queryInterface.dropTable('organizations', { transaction });
await queryInterface.dropTable('permissions', { transaction });
await queryInterface.dropTable('roles', { transaction });
await queryInterface.dropTable('users', { transaction });
await transaction.commit();
} catch (err) {
await transaction.rollback();
throw err;
}
}
};