const { Events } = require('discord.js');
const axios = require('axios').default;

const SWARM_EVENTS_CHANNEL_ID = '1536067515115905155';
const VRC_CROSSPOST_CHANNEL_ID = '1438261670916133055';
const VRC_TL_EVENT_REGEX = /https:\/\/vrc\.tl\/event\/(\d+)/g;
const REMINDER_EMOTE = '🔔';

module.exports = {
	name: Events.MessageCreate,
	async execute(message) {
		if (message.author.bot) return;
		if (message.channel.id !== SWARM_EVENTS_CHANNEL_ID) return;

		const matches = [...message.content.matchAll(VRC_TL_EVENT_REGEX)];
		if (matches.length === 0) return;

		const eventIds = [...new Set(matches.map(match => match[1]))];

		for (const eventId of eventIds) {
			try {
				const { data } = await axios.get(`https://vrc.tl/api/v1/events/${eventId}`);
				const event = data.events?.[0];
				if (!event) continue;

				const performersById = new Map(data.performers.map(performer => [performer.id, performer.name]));

				const lineup = [...event.eventSlots]
					.sort((a, b) => a.start - b.start)
					.flatMap(slot => [...slot.performers]
						.sort((a, b) => a.order - b.order)
						.map(slotPerformer => performersById.get(slotPerformer.performerId)))
					.filter(Boolean);

				const lines = [
					`**${event.name}**`,
					`<t:${event.start}:F> (<t:${event.start}:R>)`,
				];

				if (lineup.length > 0) {
					lines.push(`DJ Lineup: ${lineup.join(', ')}`);
				}

				if (event.urls?.vrcGroup) {
					lines.push(`Group: ${event.urls.vrcGroup}`);
				}

				const reminderPrompt = `\nReact with ${REMINDER_EMOTE} to get pinged 1 hour before this starts.`;
				const db = await message.client.localDB;

				const reply = await message.reply([...lines, reminderPrompt].join('\n'));
				await reply.react(REMINDER_EMOTE);
				db.prepare(`
					INSERT INTO vrctl_event_reminders (vrctl_event_id, message_id, channel_id, event_name, event_start)
					VALUES (?, ?, ?, ?, ?)
				`).run(eventId, reply.id, reply.channel.id, event.name, event.start);

				try {
					const crosspostChannel = await message.client.channels.fetch(VRC_CROSSPOST_CHANNEL_ID);
					const crosspostLines = [...lines, `Link: https://vrc.tl/event/${eventId}`, reminderPrompt];
					const crosspost = await crosspostChannel.send(crosspostLines.join('\n'));
					await crosspost.react(REMINDER_EMOTE);
					db.prepare(`
						INSERT INTO vrctl_event_reminders (vrctl_event_id, message_id, channel_id, event_name, event_start)
						VALUES (?, ?, ?, ?, ?)
					`).run(eventId, crosspost.id, crosspost.channel.id, event.name, event.start);
				} catch (crosspostError) {
					console.error(`Failed to crosspost vrc.tl event ${eventId} to vrc channel:`, crosspostError);
				}
			} catch (error) {
				console.error(`Failed to fetch vrc.tl event ${eventId}:`, error?.response?.data ?? error);
			}
		}
	},
};