55 lines
1.6 KiB
C#
55 lines
1.6 KiB
C#
|
using Lavalink4NET;
|
|||
|
|
using TomatenMusic;
|
|||
|
|
using TomatenMusic.Music;
|
|||
|
|
using TomatenMusic_Api.Models;
|
|||
|
|
using static TomatenMusic_Api.InProcessEventBus;
|
|||
|
|
|
|||
|
|
namespace TomatenMusic_Api
|
|||
|
|
{
|
|||
|
|
public class TomatenMusicService : IHostedService
|
|||
|
|
{
|
|||
|
|
private readonly InProcessEventBus _inProcessEventBus;
|
|||
|
|
private readonly ILogger<TomatenMusicService> _logger;
|
|||
|
|
public TomatenMusicBot _bot { get; set; }
|
|||
|
|
public IAudioService _audioService { get; set; }
|
|||
|
|
|
|||
|
|
public TomatenMusicService(InProcessEventBus inProcessEventBus, ILogger<TomatenMusicService> logger)
|
|||
|
|
{
|
|||
|
|
_inProcessEventBus = inProcessEventBus;
|
|||
|
|
_logger = logger;
|
|||
|
|
|
|||
|
|
Initialize();
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private void Initialize()
|
|||
|
|
{
|
|||
|
|
_inProcessEventBus.OnConnectRequest += _inProcessEventBus_OnConnectRequest;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
private async Task _inProcessEventBus_OnConnectRequest(InProcessEventBus sender, ChannelConnectEventArgs e)
|
|||
|
|
{
|
|||
|
|
_logger.LogInformation("Channel Connected!");
|
|||
|
|
GuildPlayer player = await _audioService.JoinAsync<GuildPlayer>(e.Guild_Id, e.Channel.Id, true);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task StartAsync(CancellationToken cancellationToken)
|
|||
|
|
{
|
|||
|
|
_logger.LogInformation("Starting service...");
|
|||
|
|
_bot = new TomatenMusicBot();
|
|||
|
|
await _bot.InitBotAsync();
|
|||
|
|
_audioService = TomatenMusicBot.ServiceProvider.GetRequiredService<IAudioService>();
|
|||
|
|
_logger.LogInformation("Service started!");
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
public async Task StopAsync(CancellationToken cancellationToken)
|
|||
|
|
{
|
|||
|
|
_logger.LogInformation("Shutting down service...");
|
|||
|
|
await _bot.ShutdownBotAsync();
|
|||
|
|
_logger.LogInformation("Service shut down!");
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|