mirror of
https://github.com/Myxelium/Lunaris2.0.git
synced 2026-04-13 16:10:36 +00:00
Compare commits
2 Commits
0.1.9
...
Lavalink4n
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
34375f52bd | ||
| 05b7324ecc |
@@ -5,7 +5,6 @@ using Lavalink4NET;
|
|||||||
using Lavalink4NET.Events.Players;
|
using Lavalink4NET.Events.Players;
|
||||||
using Lavalink4NET.Players.Queued;
|
using Lavalink4NET.Players.Queued;
|
||||||
using Lavalink4NET.Rest.Entities.Tracks;
|
using Lavalink4NET.Rest.Entities.Tracks;
|
||||||
using System.Threading;
|
|
||||||
|
|
||||||
namespace Lunaris2.Handler.MusicPlayer.PlayCommand;
|
namespace Lunaris2.Handler.MusicPlayer.PlayCommand;
|
||||||
|
|
||||||
@@ -38,45 +37,42 @@ public class PlayHandler : IRequestHandler<PlayCommand>
|
|||||||
await _musicEmbed.NowPlayingEmbed(track, _context, _client);
|
await _musicEmbed.NowPlayingEmbed(track, _context, _client);
|
||||||
}
|
}
|
||||||
|
|
||||||
public Task Handle(PlayCommand command, CancellationToken cancellationToken)
|
public async Task Handle(PlayCommand command, CancellationToken cancellationToken)
|
||||||
{
|
|
||||||
new Thread(PlayMusic).Start();
|
|
||||||
return Task.CompletedTask;
|
|
||||||
|
|
||||||
async void PlayMusic()
|
|
||||||
{
|
{
|
||||||
|
await _audioService.StartAsync(cancellationToken);
|
||||||
var context = command.Message;
|
var context = command.Message;
|
||||||
_context = context;
|
_context = context;
|
||||||
|
|
||||||
if ((context.User as SocketGuildUser)?.VoiceChannel == null)
|
|
||||||
{
|
|
||||||
await context.SendMessageAsync("You must be in a voice channel to use this command.", _client);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await _audioService.StartAsync(cancellationToken);
|
|
||||||
|
|
||||||
var searchQuery = context.GetOptionValueByName(Option.Input);
|
var searchQuery = context.GetOptionValueByName(Option.Input);
|
||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(searchQuery))
|
if (string.IsNullOrWhiteSpace(searchQuery)) {
|
||||||
{
|
|
||||||
await context.SendMessageAsync("Please provide search terms.", _client);
|
await context.SendMessageAsync("Please provide search terms.", _client);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
var player = await _audioService.GetPlayerAsync(_client, context, connectToVoiceChannel: true);
|
var player = await _audioService.GetPlayerAsync(_client, context, connectToVoiceChannel: true);
|
||||||
|
|
||||||
if (player is null) return;
|
if (player is null)
|
||||||
|
return;
|
||||||
|
|
||||||
var trackLoadOptions = new TrackLoadOptions { SearchMode = TrackSearchMode.YouTube, };
|
var trackLoadOptions = new TrackLoadOptions
|
||||||
|
{
|
||||||
|
SearchMode = TrackSearchMode.YouTube,
|
||||||
|
};
|
||||||
|
|
||||||
var track = await _audioService.Tracks.LoadTrackAsync(searchQuery, trackLoadOptions, cancellationToken: cancellationToken);
|
var track = await _audioService.Tracks
|
||||||
|
.LoadTrackAsync(
|
||||||
|
searchQuery,
|
||||||
|
trackLoadOptions,
|
||||||
|
cancellationToken: cancellationToken);
|
||||||
|
|
||||||
if (track is null) await context.SendMessageAsync("😖 No results.", _client);
|
if (track is null)
|
||||||
|
await context.SendMessageAsync("😖 No results.", _client);
|
||||||
|
|
||||||
if (player.CurrentTrack is null)
|
if (player.CurrentTrack is null)
|
||||||
{
|
{
|
||||||
await player.PlayAsync(track, cancellationToken: cancellationToken)
|
await player
|
||||||
|
.PlayAsync(track, cancellationToken: cancellationToken)
|
||||||
.ConfigureAwait(false);
|
.ConfigureAwait(false);
|
||||||
|
|
||||||
await _musicEmbed.NowPlayingEmbed(track, context, _client);
|
await _musicEmbed.NowPlayingEmbed(track, context, _client);
|
||||||
@@ -95,5 +91,4 @@ public class PlayHandler : IRequestHandler<PlayCommand>
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
}
|
}
|
||||||
@@ -6,7 +6,6 @@ using Lunaris2.Handler.ChatCommand;
|
|||||||
using Lavalink4NET.Extensions;
|
using Lavalink4NET.Extensions;
|
||||||
using Lunaris2.Handler.MusicPlayer;
|
using Lunaris2.Handler.MusicPlayer;
|
||||||
using Lunaris2.Notification;
|
using Lunaris2.Notification;
|
||||||
using Lunaris2.Service;
|
|
||||||
using Lunaris2.SlashCommand;
|
using Lunaris2.SlashCommand;
|
||||||
using Microsoft.Extensions.Configuration;
|
using Microsoft.Extensions.Configuration;
|
||||||
using Microsoft.Extensions.DependencyInjection;
|
using Microsoft.Extensions.DependencyInjection;
|
||||||
@@ -42,7 +41,10 @@ public class Program
|
|||||||
.Build();
|
.Build();
|
||||||
|
|
||||||
services
|
services
|
||||||
|
.AddSingleton(client)
|
||||||
.AddMediatR(mediatRServiceConfiguration => mediatRServiceConfiguration.RegisterServicesFromAssembly(Assembly.GetExecutingAssembly()))
|
.AddMediatR(mediatRServiceConfiguration => mediatRServiceConfiguration.RegisterServicesFromAssembly(Assembly.GetExecutingAssembly()))
|
||||||
|
.AddSingleton<DiscordEventListener>()
|
||||||
|
.AddSingleton(service => new InteractionService(service.GetRequiredService<DiscordSocketClient>()))
|
||||||
.AddLavalink()
|
.AddLavalink()
|
||||||
.ConfigureLavalink(options =>
|
.ConfigureLavalink(options =>
|
||||||
{
|
{
|
||||||
@@ -56,10 +58,6 @@ public class Program
|
|||||||
.AddSingleton<LavaNode>()
|
.AddSingleton<LavaNode>()
|
||||||
.AddSingleton<MusicEmbed>()
|
.AddSingleton<MusicEmbed>()
|
||||||
.AddSingleton<ChatSettings>()
|
.AddSingleton<ChatSettings>()
|
||||||
.AddSingleton(client)
|
|
||||||
.AddSingleton<DiscordEventListener>()
|
|
||||||
.AddSingleton<VoiceChannelMonitorService>()
|
|
||||||
.AddSingleton(service => new InteractionService(service.GetRequiredService<DiscordSocketClient>()))
|
|
||||||
.Configure<ChatSettings>(configuration.GetSection("LLM"));
|
.Configure<ChatSettings>(configuration.GetSection("LLM"));
|
||||||
|
|
||||||
client.Ready += () => Client_Ready(client);
|
client.Ready += () => Client_Ready(client);
|
||||||
@@ -88,8 +86,6 @@ public class Program
|
|||||||
private static Task Client_Ready(DiscordSocketClient client)
|
private static Task Client_Ready(DiscordSocketClient client)
|
||||||
{
|
{
|
||||||
client.RegisterCommands();
|
client.RegisterCommands();
|
||||||
|
|
||||||
new VoiceChannelMonitorService(client).StartMonitoring();
|
|
||||||
return Task.CompletedTask;
|
return Task.CompletedTask;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,59 +0,0 @@
|
|||||||
using Discord.WebSocket;
|
|
||||||
|
|
||||||
namespace Lunaris2.Service;
|
|
||||||
|
|
||||||
public class VoiceChannelMonitorService
|
|
||||||
{
|
|
||||||
private readonly DiscordSocketClient _client;
|
|
||||||
private readonly Dictionary<ulong, Timer> _timers = new();
|
|
||||||
|
|
||||||
public VoiceChannelMonitorService(DiscordSocketClient client)
|
|
||||||
{
|
|
||||||
_client = client;
|
|
||||||
}
|
|
||||||
|
|
||||||
public void StartMonitoring()
|
|
||||||
{
|
|
||||||
Task.Run(async () =>
|
|
||||||
{
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
await CheckVoiceChannels();
|
|
||||||
await Task.Delay(TimeSpan.FromMinutes(1));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
private async Task CheckVoiceChannels()
|
|
||||||
{
|
|
||||||
foreach (var guild in _client.Guilds)
|
|
||||||
{
|
|
||||||
var voiceChannel = guild.VoiceChannels.FirstOrDefault(vc => vc.ConnectedUsers.Count == 1);
|
|
||||||
if (voiceChannel != null)
|
|
||||||
{
|
|
||||||
if (!_timers.ContainsKey(voiceChannel.Id))
|
|
||||||
{
|
|
||||||
_timers[voiceChannel.Id] = new Timer(async _ => await LeaveChannel(voiceChannel), null, TimeSpan.FromMinutes(3), Timeout.InfiniteTimeSpan);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
if (voiceChannel == null || !_timers.ContainsKey(voiceChannel.Id))
|
|
||||||
continue;
|
|
||||||
|
|
||||||
await _timers[voiceChannel.Id].DisposeAsync();
|
|
||||||
_timers.Remove(voiceChannel.Id);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private async Task LeaveChannel(SocketVoiceChannel voiceChannel)
|
|
||||||
{
|
|
||||||
if (voiceChannel.ConnectedUsers.Count == 1 && voiceChannel.Users.Any(u => u.Id == _client.CurrentUser.Id))
|
|
||||||
{
|
|
||||||
await voiceChannel.DisconnectAsync();
|
|
||||||
await _timers[voiceChannel.Id].DisposeAsync();
|
|
||||||
_timers.Remove(voiceChannel.Id);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -9,6 +9,18 @@ public static class Option
|
|||||||
|
|
||||||
public static class Command
|
public static class Command
|
||||||
{
|
{
|
||||||
|
// public static class Hello
|
||||||
|
// {
|
||||||
|
// public const string Name = "hello";
|
||||||
|
// public const string Description = "Say hello to the bot!";
|
||||||
|
// }
|
||||||
|
//
|
||||||
|
// public static class Goodbye
|
||||||
|
// {
|
||||||
|
// public const string Name = "goodbye";
|
||||||
|
// public const string Description = "Say goodbye to the bot!";
|
||||||
|
// }
|
||||||
|
|
||||||
public static class Disconnect
|
public static class Disconnect
|
||||||
{
|
{
|
||||||
public const string Name = "disconnect";
|
public const string Name = "disconnect";
|
||||||
|
|||||||
Reference in New Issue
Block a user