using System.Diagnostics;

using DSharpPlus;
using DSharpPlus.Entities;
using DSharpPlus.SlashCommands;
using DSharpPlus.VoiceNext;

using Microsoft.Extensions.Logging;

internal class Program {
	public DiscordClient _client;
	public SlashCommandsExtension _slashCommands;

	public static void Main(string[] args) {
		Program program = new();
		program.RunAsync().Wait();
	}
	
	public Program() {
		string discordToken = File.ReadAllText("TOKEN.txt");
		_client = new DiscordClient(new DiscordConfiguration {
			Token = discordToken,
			TokenType = TokenType.Bot,
			Intents = DiscordIntents.All,
			MinimumLogLevel = LogLevel.Warning
		});
		
		_client.UseVoiceNext();
		_slashCommands = _client.UseSlashCommands();
		_slashCommands.RegisterCommands<MediaCommands>();
	}

	public async Task RunAsync() {
		await _client.ConnectAsync(new("nothing", ActivityType.Playing), UserStatus.Online);
		await Task.Delay(-1);
	}

	internal class MediaCommands : ApplicationCommandModule {
		public static Stream? ConvertAudioToPcm(string filePath) {
			Process? ffmpeg = Process.Start(new ProcessStartInfo {
				FileName = "ffmpeg",
				Arguments = $@"-i ""{filePath}"" -ac 2 -f s16le -ar 48000 pipe:1",
				RedirectStandardOutput = true,
				UseShellExecute = false
			});

			return ffmpeg?.StandardOutput.BaseStream;
		}

		[SlashCommand("join", "joins")]
		public async Task JoinCommand(InteractionContext ctx) {
			DiscordChannel channel = ctx.Member.VoiceState?.Channel;
			await channel.ConnectAsync();
		}

		[SlashCommand("play", "plays")]
		public async Task PlayCommand(InteractionContext ctx, [Option("path", "path")] string path) {
			VoiceNextExtension vnext = ctx.Client.GetVoiceNext();
			VoiceNextConnection connection = vnext.GetConnection(ctx.Guild);

			VoiceTransmitSink transmit = connection.GetTransmitSink();

			Stream? pcm = ConvertAudioToPcm(path);
			await pcm.CopyToAsync(transmit);
			await pcm.DisposeAsync();
		}

		[SlashCommand("leave", "leaves")]
		public async Task LeaveCommand(InteractionContext ctx) {
			VoiceNextExtension vnext = ctx.Client.GetVoiceNext();
			VoiceNextConnection connection = vnext.GetConnection(ctx.Guild);

			connection.Disconnect();
		}
	}
}