import { Result } from "@sapphire/framework";
import db, {
	type Actor,
	addTicketComment,
	desc,
	editTicket,
	eq,
	getGuildByDiscordId,
	getModerators,
	getTicketByChannelId,
	tickets,
} from "@stealth-developers/db";
import {
	ActionRowBuilder,
	ButtonBuilder,
	ChannelType,
	ContainerBuilder,
	type Guild,
	OverwriteType,
	PermissionFlagsBits,
	TextChannel,
	TextDisplayBuilder,
} from "discord.js";
import { upsertGuildActor } from "f/guild-actor";
import { randomUUID } from "node:crypto";

import type { AnyUser } from "@/types";

import { client } from "@/client";
import { PublicError, getCategory, logger, upsertUser } from "@/lib";

import type { CreateTicketArgs, NewTicketContext, TicketContext } from "../types";

import { TicketButtonPresets } from "../buttons";
import { hasAccessToTicket } from "../lib";
import { TicketModalPresets } from "../modals";
import { addParticipant } from "./assignment";
import { getCommentContainer } from "./comments";
import { getTicketContainer } from "./helpers";
import { canDmUser, messageChannel, messageUser } from "./helpers";

export async function createTicket(
	ctx: NewTicketContext,
	args?: CreateTicketArgs,
): Promise<{ channelId: string; publicId: string }> {
	const isOnBehalf = !!args?.for;
	const publicId = randomUUID();

	const dbGuild = ctx.dbGuild;
	if (!dbGuild) throw new PublicError("Failed to create ticket: Guild not found in database");

	const moderators = await getModerators(dbGuild.id);
	if (!moderators) throw new PublicError("Failed to create ticket: No moderators found");

	const creator = ctx.creatorActor;
	if (!creator) throw new PublicError("Failed to create ticket: Creator user not found");

	const subject = isOnBehalf ? args?.for : ctx.creatorUser;
	const subjectUser = subject ? await upsertUser(subject, ctx.guild) : creator;
	if (!subjectUser) throw new PublicError("Failed to create ticket: Subject user not found");

	if (isOnBehalf && !creator.moderator)
		throw new PublicError("You don't have permission to create a ticket for another user.");

	if (!dbGuild.ticketCategory)
		throw new PublicError(
			"Ticket category is not set up in this guild. Please contact an administrator.",
		);
	const ticketCategory = await getCategory(dbGuild.ticketCategory);
	let createdChannel: TextChannel | undefined = undefined;

	const canDm = await canDmUser(subject);

	let ticketId: string | undefined = undefined;

	const txResult = await Result.fromAsync(async () => {
		return await db.transaction(async (tx) => {
			const [maxTicket] = await tx
				.select({ localId: tickets.localId })
				.from(tickets)
				.where(eq(tickets.guildId, creator.guildId))
				.orderBy(desc(tickets.localId))
				.limit(1);

			const localId = (maxTicket?.localId ?? 0) + 1;

			const [ticket] = await tx
				.insert(tickets)
				.values({
					id: publicId,
					guildId: creator.guildId,
					localId: localId,
					status: "provisioning",
					openedAt: new Date(),
					openedBy: creator.id,
					subject: subjectUser.id,
				})
				.returning();

			if (!ticket) throw new PublicError("Failed to add ticket to database, please try again.");
			return { ticket, localId };
		});
	});

	if (txResult.isErr()) {
		const error = txResult.unwrapErr();
		const message =
			error instanceof PublicError
				? `Failed to create ticket: ${error.message}`
				: "There was an error creating the ticket.";

		if (error instanceof Error) logger.error(error.stack, error.message);
		throw new PublicError(message);
	}

	const { ticket, localId } = txResult.unwrap();
	ticketId = ticket.id;

	const setupResult = await Result.fromAsync(async () => {
		const channel = await ctx.guild.channels.create({
			type: ChannelType.GuildText,
			parent: ticketCategory,
			name: `ticket-${String(localId).padStart(4, "0")}`,
			permissionOverwrites: [
				{
					id: ctx.guild.id,
					type: OverwriteType.Role,
					deny: [PermissionFlagsBits.ViewChannel],
				},
				{
					id: dbGuild.moderatorRole!,
					type: OverwriteType.Role,
					allow: [
						PermissionFlagsBits.ViewChannel,
						PermissionFlagsBits.ManageChannels,
						PermissionFlagsBits.CreatePrivateThreads,
					],
				},
				{
					id: client.user!.id,
					type: OverwriteType.Member,
					allow: [
						PermissionFlagsBits.ViewChannel,
						PermissionFlagsBits.ManageChannels,
						PermissionFlagsBits.CreatePrivateThreads,
					],
				},
				{
					id: subjectUser.discordId!,
					type: OverwriteType.Member,
					allow: [
						PermissionFlagsBits.ViewChannel,
						PermissionFlagsBits.SendMessages,
						PermissionFlagsBits.AttachFiles,
					],
				},
			],
		});

		if (!channel) throw new PublicError("Failed to create Discord channel.");
		createdChannel = channel;

		const greeting = dbGuild.ticketGreeting;
		const components = [];

		if (greeting) {
			components.push(
				new ContainerBuilder()
					.setAccentColor(0x3a9027)
					.addTextDisplayComponents(
						new TextDisplayBuilder({
							content: greeting.replaceAll("{user}", `<@${subjectUser.discordId}>`),
						}),
					)
					.addActionRowComponents(
						new ActionRowBuilder<ButtonBuilder>().addComponents(
							TicketButtonPresets.claimTicketButton(publicId),
							TicketButtonPresets.closeTicketButton(publicId),
						),
					),
			);
		}

		if (!canDm) {
			components.push(
				new ContainerBuilder()
					.setAccentColor(0xdf8e1d)
					.addTextDisplayComponents(
						new TextDisplayBuilder().setContent("## I can't DM you!"),
						new TextDisplayBuilder().setContent(
							[
								"You won't receive a notification once your ticket has been handled.",
								`To check the outcome, you can use the \`/ticket view\` command with the ID \`${ticket.localId}\``,
								"or, see all of your tickets with `/ticket manage list`.",
							].join(" "),
						),
					),
			);
		}

		components.push(
			new ContainerBuilder()
				.setAccentColor(0x3a9027)
				.addTextDisplayComponents(
					new TextDisplayBuilder({
						content: [
							"# Uploading Videos\n",
							"You can either upload your video directly to this channel, or",
							"you can use the button below to upload it directly to us, which",
							"allows you to upload videos up to 2GB in size.",
						].join(" "),
					}),
				)
				.addActionRowComponents(
					new ActionRowBuilder<ButtonBuilder>().addComponents(
						TicketButtonPresets.uploadLink(publicId),
					),
				),
		);

		await channel.send({
			components,
			flags: ["IsComponentsV2"],
		});

		await db
			.update(tickets)
			.set({ channelId: channel.id, status: "open" })
			.where(eq(tickets.id, ticket.id));

		try {
			const modThread = await channel.threads.create({
				name: `Moderator Thread - #${String(ticket.localId).padStart(4, "0")}`,
				type: ChannelType.PrivateThread,
				autoArchiveDuration: 10080,
				reason: "Private discussion thread for moderators",
			});

			await modThread.send({
				content: `This thread is only visible to moderators, use it to discuss the ticket.`,
			});

			await channel.send({
				content: `Moderator thread created at ${modThread.url}`,
			});

			await db.update(tickets).set({ threadId: modThread.id }).where(eq(tickets.id, ticket.id));
		} catch (threadError) {
			logger.error(
				threadError,
				`Failed to create private moderator thread for ticket ${ticket.id}`,
			);
		}

		return channel;
	});

	if (setupResult.isErr()) {
		if (createdChannel) {
			await Result.fromAsync(() => (createdChannel as TextChannel).delete());
		}

		await Result.fromAsync(() => db.delete(tickets).where(eq(tickets.id, ticketId!)));

		const error = setupResult.unwrapErr();
		const message =
			error instanceof PublicError
				? `Failed to create ticket: ${error.message}`
				: "There was an error creating the ticket.";

		if (error instanceof Error) logger.error(error.stack, error.message);

		throw new PublicError(message);
	}

	await addParticipant(ctx.guild.id, {
		actor: subjectUser,
		ticketId: ticketId!,
		role: "subject",
		reason: "subject of ticket",
	});

	const channel = setupResult.unwrap();
	return { channelId: channel.id, publicId };
}

export async function triggerCloseTicket(user: AnyUser, guild: Guild, channelId: string) {
	const dbGuild = await getGuildByDiscordId(guild.id);
	if (!dbGuild) throw new PublicError("Failed to create ticket: Guild not found in database");

	const dbUser = await upsertUser(user, guild);
	if (!dbUser) throw new PublicError("Failed to create ticket: User not found in database");

	const ticket = await getTicketByChannelId(channelId);
	if (!ticket) throw new PublicError("Failed to close ticket: Ticket not found in database");

	return TicketModalPresets.close(ticket.id, Boolean(dbUser.moderator));
}

/**
 * @param user
 * @param ticketId
 * @param reasons
 * @param cleanup whether to delete the ticket channel immediately after closing
 * @returns
 */
export async function closeTicket(
	user: Actor,
	ticketId: string,
	reasons: { public: string; private?: string | null },
	cleanup: boolean = false,
) {
	const result = await editTicket(ticketId, {
		closedAt: new Date(),
		closeReason: reasons.public,
		privateReason: reasons.private,
		closedBy: user.id,
		status: "closed",
	});

	if (!result) throw new PublicError("Failed to close ticket: Ticket not found in database");

	const dbGuild = result.guild;
	if (!dbGuild) throw new PublicError("Failed to close ticket: Guild not found in database");

	const guild = await client.guilds.fetch(dbGuild.discordId);
	if (!guild) throw new PublicError("Failed to close ticket: Guild not found in Discord");

	if (!result.channelId)
		throw new PublicError("Failed to close ticket: Channel not found in database");

	const dbSubject = result.subjectActor;
	if (!dbSubject || !dbSubject.discordId)
		throw new PublicError("Failed to close ticket: Subject not found in database");

	const channel = await guild.channels.fetch(result.channelId);
	if (!channel || !channel.isTextBased())
		throw new PublicError("Failed to close ticket: Channel not found in database");

	if (cleanup) {
		channel
			.delete()
			.catch((err) => logger.error(err, `Failed to delete channel ${channel.id} during cleanup`));
	} else {
		const moderators = await getModerators(dbGuild.id);
		if (!moderators) throw new PublicError("Failed to close ticket: Moderators not found");

		const actionRow = new ActionRowBuilder<ButtonBuilder>().addComponents(
			TicketButtonPresets.reopenTicketButton(ticketId),
			TicketButtonPresets.cleanTicketButton(ticketId),
		);

		messageChannel(channel, {
			content: `This ticket has been closed by <@${user.discordId}>.`,
			components: [actionRow],
			flags: ["SuppressNotifications"],
		}).catch((err) => logger.error(err, `Failed to message closed channel ${channel.id}`));

		if (channel.type === ChannelType.GuildText && !dbSubject.moderator)
			channel.permissionOverwrites
				.edit(
					dbSubject.discordId!,
					{
						ViewChannel: false,
						SendMessages: false,
						AttachFiles: false,
					},
					{ type: OverwriteType.Member },
				)
				.catch((err) =>
					logger.error(err, `Failed to update name/permissions for closed channel ${channel.id}`),
				);
	}

	(async () => {
		try {
			const botActor = await upsertGuildActor(guild);
			if (!botActor) {
				logger.warn("Failed to complete closeTicket notifications: Bot actor not found.");
				return;
			}

			const subject = await client.users.fetch(dbSubject.discordId!);
			const container = getTicketContainer(result, true);

			const messageRes = await Result.fromAsync(
				messageUser(subject, {
					components: [container],
					flags: ["IsComponentsV2"],
				}),
			);

			if (messageRes.isErr()) {
				await addTicketComment({
					actorId: botActor.id,
					ticketId: result.id,
					content: `User has DMs closed, a notification was not sent.`,
				});
			}

			const logChannel = dbGuild.ticketLogChannel;
			if (!logChannel) {
				await addTicketComment({
					actorId: botActor.id,
					ticketId: result.id,
					content: `No log channel was found, a notification was not sent.`,
				});
			} else {
				const containerLong = getTicketContainer(result, false);
				const commentContainer = getCommentContainer(result.localId, result.comments);

				const message = await Result.fromAsync(
					messageChannel(logChannel, {
						components: [containerLong, commentContainer],
						flags: ["SuppressNotifications", "IsComponentsV2"],
						allowedMentions: { parse: [] },
					}),
				);

				if (message.isErr()) {
					await addTicketComment({
						actorId: botActor.id,
						ticketId: result.id,
						content: `Failed to send log message: ${message.unwrapErr()}`,
					});
				}
			}
		} catch (err) {
			logger.error(err, `Error performing background notification tasks for ticket ${result.id}`);
		}
	})();

	return result;
}

export async function reopenTicket(ctx: TicketContext) {
	const { actor, guild, ticket, ticketChannel } = ctx;
	if (ticket.status !== "closed") throw new PublicError("This ticket is not closed.");

	const canAccess = hasAccessToTicket(actor, guild, ticket, { requireModerator: true });
	if (!canAccess) throw new PublicError("You don't have permission to reopen this ticket.");

	const newTicket = await editTicket(ticket.id, {
		status: "open",
		closedAt: null,
		closedBy: null,

		claimedBy: actor.id,
		claimedAt: new Date(),
		lastClaimantActivityAt: new Date(),
	});

	if (ticketChannel) {
		const actionRow = new ActionRowBuilder<ButtonBuilder>().addComponents(
			TicketButtonPresets.claimTicketButton(ticket.id),
			TicketButtonPresets.closeTicketButton(ticket.id),
		);

		messageChannel(ticketChannel, {
			content: `<@${actor.discordId}> reopened this ticket.`,
			flags: ["SuppressNotifications"],
			components: [actionRow],
		}).catch((err) =>
			logger.error(err, `Failed to send reopen message to channel ${ticketChannel.id}`),
		);

		if (!ticket.subjectActor)
			throw new PublicError("Failed to reopen ticket: Subject actor not found");

		const moderators = await getModerators(guild.id);
		if (!moderators) throw new PublicError("Failed to reopen ticket: Moderators not found");

		if (ticketChannel.type === ChannelType.GuildText) {
			ticketChannel.permissionOverwrites
				.edit(
					ticket.subjectActor.discordId!,
					{
						ViewChannel: true,
						SendMessages: true,
						AttachFiles: true,
					},
					{
						type: OverwriteType.Member,
					},
				)
				.catch((err) =>
					logger.error(
						err,
						`Failed to update name/permissions on reopen for channel ${ticketChannel.id}`,
					),
				);
		}
	}

	return newTicket;
}

export async function cleanTicket(ctx: TicketContext) {
	const { ticket, actor, ticketChannel, guild } = ctx;
	if (ticket.status !== "closed")
		throw new Error("Tickets must be closed before they can be cleaned up.");

	const canAccess = hasAccessToTicket(actor, guild, ticket, { requireModerator: true });
	if (!canAccess) throw new PublicError("You don't have permission to clean up this ticket.");
	if (!ticketChannel) throw new PublicError("Ticket channel not found.");

	const result = await editTicket(ticket.id, {
		channelId: null,
	});

	ticketChannel
		.delete("Ticket channel cleaned up")
		.catch((err) =>
			logger.error(err, `failed to delete channel ${ticketChannel.id} during clean up`),
		);

	return result;
}