import { Command } from '@n8n/decorators';
import { z } from 'zod';
import { Container } from '@n8n/di';

import { BaseCommand } from '../base-command';
import { ImportService } from '../../services/import.service';
import { safeJoinPath } from '@n8n/backend-common';

const flagsSchema = z.object({
	inputDir: z
		.string()
		.describe('Input directory that holds output files for import')
		.default('./outputs'),
	truncateTables: z.coerce.boolean().describe('Truncate tables before import').default(false),
	keyFile: z
		.string()
		.describe('Optional path to a file containing a custom encryption key')
		.optional(),
	skipMigrationChecks: z.coerce
		.boolean()
		.describe('Skip migration validation checks')
		.default(false),
	skipTogglingForeignKeyConstraints: z.coerce
		.boolean()
		.describe('Skip disabling foreign key constraints')
		.default(false),
});

@Command({
	name: 'import:entities',
	description: 'Import database entities from JSON files',
	examples: [
		'',
		'--inputDir=./exports',
		'--inputDir=/path/to/backup',
		'--truncateTables',
		'--inputDir=./exports --truncateTables',
		'--keyFile=/path/to/key.txt',
		'--inputDir=./exports --keyFile=/path/to/key.txt',
		'--skipMigrationChecks',
		'--inputDir=./exports --skipMigrationChecks',
	],
	flagsSchema,
})
export class ImportEntitiesCommand extends BaseCommand<z.infer<typeof flagsSchema>> {
	async run() {
		const inputDir = this.flags.inputDir;
		const truncateTables = this.flags.truncateTables;
		const keyFilePath = this.flags.keyFile ? safeJoinPath(this.flags.keyFile) : undefined;
		const skipMigrationChecks = this.flags.skipMigrationChecks ?? false;
		const skipTogglingForeignKeyConstraints = this.flags.skipTogglingForeignKeyConstraints ?? false;

		this.logger.info('\n⚠️⚠️ This feature is currently under development. ⚠️⚠️');
		this.logger.info('\n🚀 Starting entity import...');
		this.logger.info(`📁 Input directory: ${inputDir}`);
		this.logger.info(`🗑️  Truncate tables: ${truncateTables}`);
		if (skipMigrationChecks) {
			this.logger.info('⏭️  Skipping migration checks');
		}
		if (skipTogglingForeignKeyConstraints) {
			this.logger.info('⏭️  Skipping disabling foreign key constraints');
		}

		await Container.get(ImportService).importEntities(
			inputDir,
			truncateTables,
			keyFilePath,
			skipMigrationChecks,
			skipTogglingForeignKeyConstraints,
		);
	}

	catch(error: Error) {
		this.logger.error('❌ Error importing entities. See log messages for details. \n');
		this.logger.error('Error details:');
		this.logger.error('\n====================================\n');
		this.logger.error(`${error.message} \n`);
	}
}