import type { Driver, TableForeignKeyOptions, TableIndexOptions, QueryRunner } from '@n8n/typeorm';
import { Table, TableCheck, TableColumn, TableForeignKey, TableUnique } from '@n8n/typeorm';
import { UnexpectedError } from 'n8n-workflow';
import LazyPromise from 'p-lazy';

import { Column } from './column';

function buildEnumCheck(
	columnName: string,
	values: string[],
	prefix: string,
	tableName: string,
	driver: Driver,
): TableCheck {
	const checkName = `CHK_${prefix}${tableName}_${columnName}`;
	const escapedColumnName = driver.escape(columnName);
	const escapedValues = values.map((v) => `'${v.replace(/'/g, "''")}'`).join(', ');
	const expression = `${escapedColumnName} IN (${escapedValues})`;
	return new TableCheck({ name: checkName, expression });
}

function buildEnumChecks(
	columns: Column[],
	prefix: string,
	tableName: string,
	driver: Driver,
): TableCheck[] {
	return columns
		.map((column) => column.getEnumCheck())
		.filter((enumCheck) => enumCheck !== undefined)
		.map((enumCheck) =>
			buildEnumCheck(enumCheck.columnName, enumCheck.values, prefix, tableName, driver),
		);
}

abstract class TableOperation<R = void> extends LazyPromise<R> {
	abstract execute(queryRunner: QueryRunner): Promise<R>;

	constructor(
		protected tableName: string,
		protected prefix: string,
		queryRunner: QueryRunner,
	) {
		super((resolve, reject) => {
			void this.execute(queryRunner).then(resolve).catch(reject);
		});
	}
}

export class CreateTable extends TableOperation {
	private columns: Column[] = [];

	private indices = new Set<TableIndexOptions>();

	private uniqueConstraints = new Set<TableUnique>();

	private foreignKeys = new Set<TableForeignKeyOptions>();

	private checks = new Set<TableCheck>();

	withColumns(...columns: Column[]) {
		this.columns.push(...columns);
		return this;
	}

	get withTimestamps() {
		this.columns.push(
			new Column('createdAt').timestamp().notNull.default('NOW()'),
			new Column('updatedAt').timestamp().notNull.default('NOW()'),
		);
		return this;
	}

	get withCreatedAt() {
		this.columns.push(new Column('createdAt').timestampTimezone().notNull.default('NOW()'));
		return this;
	}

	withIndexOn(columnName: string | string[], isUnique = false) {
		const columnNames = Array.isArray(columnName) ? columnName : [columnName];
		this.indices.add({ columnNames, isUnique });
		return this;
	}

	withUniqueConstraintOn(columnName: string | string[]) {
		const columnNames = Array.isArray(columnName) ? columnName : [columnName];
		this.uniqueConstraints.add(new TableUnique({ columnNames }));
		return this;
	}

	withCheck(name: string, expression: string) {
		this.checks.add(new TableCheck({ name, expression }));
		return this;
	}

	withForeignKey(
		columnName: string,
		ref: {
			tableName: string;
			columnName: string;
			onDelete?: 'RESTRICT' | 'CASCADE' | 'NO ACTION' | 'SET NULL';
			onUpdate?: 'RESTRICT' | 'CASCADE' | 'NO ACTION' | 'SET NULL';
			name?: string;
		},
	) {
		const foreignKey: TableForeignKeyOptions = {
			columnNames: [columnName],
			referencedTableName: `${this.prefix}${ref.tableName}`,
			referencedColumnNames: [ref.columnName],
		};
		if (ref.onDelete) foreignKey.onDelete = ref.onDelete;
		if (ref.onUpdate) foreignKey.onUpdate = ref.onUpdate;
		if (ref.name) foreignKey.name = ref.name;
		this.foreignKeys.add(foreignKey);
		return this;
	}

	async execute(queryRunner: QueryRunner) {
		const { driver } = queryRunner.connection;
		const {
			columns,
			tableName: name,
			prefix,
			indices,
			uniqueConstraints,
			foreignKeys,
			checks,
		} = this;

		for (const check of buildEnumChecks(columns, prefix, name, driver)) {
			checks.add(check);
		}

		return await queryRunner.createTable(
			new Table({
				name: `${prefix}${name}`,
				columns: columns.map((c) => c.toOptions(driver)),
				...(indices.size ? { indices: [...indices] } : {}),
				...(uniqueConstraints.size ? { uniques: [...uniqueConstraints] } : {}),
				...(foreignKeys.size ? { foreignKeys: [...foreignKeys] } : {}),
				...(checks.size ? { checks: [...checks] } : {}),
			}),
			true,
		);
	}
}

export class DropTable extends TableOperation {
	async execute(queryRunner: QueryRunner) {
		const { tableName: name, prefix } = this;
		return await queryRunner.dropTable(`${prefix}${name}`, true);
	}
}

export class AddColumns extends TableOperation {
	constructor(
		tableName: string,
		protected columns: Column[],
		prefix: string,
		queryRunner: QueryRunner,
	) {
		super(tableName, prefix, queryRunner);
	}

	async execute(queryRunner: QueryRunner) {
		const { driver } = queryRunner.connection;
		const { tableName, prefix, columns } = this;
		const fullTableName = `${prefix}${tableName}`;

		await queryRunner.addColumns(
			fullTableName,
			columns.map((c) => new TableColumn(c.toOptions(driver))),
		);

		const enumChecks = buildEnumChecks(columns, prefix, tableName, driver);
		if (enumChecks.length > 0) {
			await queryRunner.createCheckConstraints(fullTableName, enumChecks);
		}
	}
}

export class DropColumns extends TableOperation {
	constructor(
		tableName: string,
		protected columnNames: string[],
		prefix: string,
		queryRunner: QueryRunner,
	) {
		super(tableName, prefix, queryRunner);
	}

	async execute(queryRunner: QueryRunner) {
		const { tableName, prefix, columnNames } = this;
		return await queryRunner.dropColumns(`${prefix}${tableName}`, columnNames);
	}
}

abstract class ForeignKeyOperation extends TableOperation {
	protected foreignKey: TableForeignKey;

	constructor(
		tableName: string,
		columnName: string,
		[referencedTableName, referencedColumnName]: [string, string],
		prefix: string,
		queryRunner: QueryRunner,
		customConstraintName?: string,
		onDelete?: string,
	) {
		super(tableName, prefix, queryRunner);

		this.foreignKey = new TableForeignKey({
			name: customConstraintName,
			columnNames: [columnName],
			referencedTableName: `${prefix}${referencedTableName}`,
			referencedColumnNames: [referencedColumnName],
			onDelete,
		});
	}
}

export class AddForeignKey extends ForeignKeyOperation {
	async execute(queryRunner: QueryRunner) {
		const { tableName, prefix } = this;
		return await queryRunner.createForeignKey(`${prefix}${tableName}`, this.foreignKey);
	}
}

export class DropForeignKey extends ForeignKeyOperation {
	async execute(queryRunner: QueryRunner) {
		const { tableName, prefix } = this;
		return await queryRunner.dropForeignKey(`${prefix}${tableName}`, this.foreignKey);
	}
}

class ModifyNotNull extends TableOperation {
	constructor(
		tableName: string,
		protected columnName: string,
		protected isNullable: boolean,
		prefix: string,
		queryRunner: QueryRunner,
	) {
		super(tableName, prefix, queryRunner);
	}

	async execute(queryRunner: QueryRunner) {
		const { tableName, prefix, columnName, isNullable } = this;
		const table = await queryRunner.getTable(`${prefix}${tableName}`);
		if (!table) throw new UnexpectedError('No table found', { extra: { tableName } });
		const oldColumn = table.findColumnByName(columnName)!;
		const newColumn = oldColumn.clone();
		newColumn.isNullable = isNullable;
		return await queryRunner.changeColumn(table, oldColumn, newColumn);
	}
}

export class AddNotNull extends ModifyNotNull {
	constructor(
		tableName: string,
		protected columnName: string,
		prefix: string,
		queryRunner: QueryRunner,
	) {
		super(tableName, columnName, false, prefix, queryRunner);
	}
}

export class DropNotNull extends ModifyNotNull {
	constructor(
		tableName: string,
		protected columnName: string,
		prefix: string,
		queryRunner: QueryRunner,
	) {
		super(tableName, columnName, true, prefix, queryRunner);
	}
}

export class DropEnumCheck extends TableOperation {
	constructor(
		tableName: string,
		protected columnName: string,
		prefix: string,
		queryRunner: QueryRunner,
	) {
		super(tableName, prefix, queryRunner);
	}

	async execute(queryRunner: QueryRunner) {
		const { tableName, prefix, columnName } = this;
		const fullTableName = `${prefix}${tableName}`;
		const checkName = `CHK_${prefix}${tableName}_${columnName}`;
		return await queryRunner.dropCheckConstraint(fullTableName, checkName);
	}
}

export class AddEnumCheck extends TableOperation {
	constructor(
		tableName: string,
		protected columnName: string,
		protected values: string[],
		prefix: string,
		queryRunner: QueryRunner,
	) {
		super(tableName, prefix, queryRunner);
	}

	async execute(queryRunner: QueryRunner) {
		const { tableName, prefix, columnName, values } = this;
		const { driver } = queryRunner.connection;
		const fullTableName = `${prefix}${tableName}`;
		return await queryRunner.createCheckConstraints(fullTableName, [
			buildEnumCheck(columnName, values, prefix, tableName, driver),
		]);
	}
}