tueem/TomatenMusic-V2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update README.md #1

Closed
EkiciLP wants to merge 0 commits from dev into master
pull from: dev
merge into: tueem:master
Conversation 0 Commits - Files Changed 63 +473 -1744
63 changed files with 473 additions and 1744 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -361,4 +361,3 @@ MigrationBackup/
# Fody - auto-generated XML schema # Fody - auto-generated XML schema
FodyWeavers.xsd FodyWeavers.xsd
/GitVersion.yml

33
GitVersion.yml
View File

@ -1,33 +0,0 @@
mode: ContinuousDelivery
branches:
main:
regex: ^master$|^main$
mode: ContinuousDelivery
tag: ''
increment: Minor
prevent-increment-of-merged-branch-version: true
track-merge-target: false
source-branches: [ 'develop', 'release' ]
tracks-release-branches: false
is-release-branch: true
is-mainline: true
pre-release-weight: 55000
develop:
regex: ^dev(elop)?(ment)?$
mode: ContinuousDeployment
tag: pre
increment: Patch
prevent-increment-of-merged-branch-version: false
track-merge-target: true
source-branches: []
tracks-release-branches: true
is-release-branch: false
is-mainline: false
pre-release-weight: 0
ignore:
sha: []
merge-message-formats: {}
major-version-bump-message: '\+semver:\s?(breaking|major)'
minor-version-bump-message: '\+semver:\s?(feature|minor)'
patch-version-bump-message: '\+semver:\s?(fix|patch)'
commit-message-incrementing: Enabled

2
README.md
View File

@ -2,5 +2,3 @@ Dev ![TeamCity dev build status](https://ci.tomatentum.net/app/rest/builds/build
Master ![TeamCity master build status](https://ci.tomatentum.net/app/rest/builds/buildType:id:TomatenMusicV2_Build,branch:name:master/statusIcon.svg) Master ![TeamCity master build status](https://ci.tomatentum.net/app/rest/builds/buildType:id:TomatenMusicV2_Build,branch:name:master/statusIcon.svg)
# TomatenMusic # TomatenMusic
Project CI can be found [here](https://ci.tomatentum.net/project/TomatenMusicV2 "Tomatentum CI")

0
TomatenMusic/.config/dotnet-tools.json → TomatenMusic Api/.config/dotnet-tools.json
View File

0
TomatenMusic/Auth/Controllers/UsersController.cs → TomatenMusic Api/Auth/Controllers/UsersController.cs
View File

0
TomatenMusic/Auth/Entities/User.cs → TomatenMusic Api/Auth/Entities/User.cs
View File

0
TomatenMusic/Auth/Helpers/AppSettings.cs → TomatenMusic Api/Auth/Helpers/AppSettings.cs
View File

0
TomatenMusic/Auth/Helpers/AuthorizeAttribute.cs → TomatenMusic Api/Auth/Helpers/AuthorizeAttribute.cs
View File

0
TomatenMusic/Auth/Helpers/JwtMiddleware.cs → TomatenMusic Api/Auth/Helpers/JwtMiddleware.cs
View File

0
TomatenMusic/Auth/Models/AuthenticateRequest.cs → TomatenMusic Api/Auth/Models/AuthenticateRequest.cs
View File

0
TomatenMusic/Auth/Models/AuthenticateResponse.cs → TomatenMusic Api/Auth/Models/AuthenticateResponse.cs
View File

0
TomatenMusic/Auth/Services/UserService.cs → TomatenMusic Api/Auth/Services/UserService.cs
View File

60
TomatenMusic/Controllers/PlayerController.cs → TomatenMusic Api/Controllers/PlayerController.cs
View File

@ -1,12 +1,9 @@
using DSharpPlus.Entities; using DSharpPlus.Entities;
using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Mvc;
using TomatenMusic; using TomatenMusic;
using TomatenMusic.Music;
using TomatenMusic_Api; using TomatenMusic_Api;
using TomatenMusic_Api.Auth.Helpers; using TomatenMusic_Api.Auth.Helpers;
using TomatenMusic_Api.Models; using TomatenMusic_Api.Models;
using TomatenMusic_Api.Models.EventArgs;
using static TomatenMusic_Api.InProcessEventBus;
namespace TomatenMusic_Api.Controllers; namespace TomatenMusic_Api.Controllers;
@ -57,9 +54,8 @@ public class PlayerController : ControllerBase
} }
[HttpPost("connect")] [HttpPost("connect")]
public async Task<IActionResult> PostConnect(ChannelConnectRequest request) public async Task<IActionResult> PostConnection(ChannelConnectRequest request)
{ {
try try
{ {
await _tomatenMusicDataService.GetGuildAsync(request.Guild_Id); await _tomatenMusicDataService.GetGuildAsync(request.Guild_Id);
@ -81,7 +77,7 @@ public class PlayerController : ControllerBase
try try
{ {
channel = await _tomatenMusicDataService.GetDiscordChannelAsync(request.Guild_Id, request.Channel_Id); channel = await _tomatenMusicDataService.GetDiscordChannelAsync(request.Channel_Id);
}catch (Exception ex) }catch (Exception ex)
{ {
return NotFound("Channel was not Found"); return NotFound("Channel was not Found");
@ -89,58 +85,8 @@ public class PlayerController : ControllerBase
_eventBus.OnConnectRequestEvent(new ChannelConnectArgs(request.Guild_Id, channel)); _eventBus.OnConnectRequestEvent(new InProcessEventBus.ChannelConnectEventArgs(request.Guild_Id, channel));
return Ok(); return Ok();
} }
[HttpPost("disconnect")]
public async Task<IActionResult> PostDisconnect(ChannelDisconnectRequest request)
{
try
{
await _tomatenMusicDataService.GetGuildAsync(request.GuildId);
}
catch (Exception ex)
{
return NotFound("That Guild was not found");
}
if (!await _tomatenMusicDataService.IsConnectedAsync(request.GuildId) == true)
return BadRequest("The Bot is not connected.");
_eventBus.OnDisconnectRequestEvent(new ChannelDisconnectArgs(request.GuildId));
return Ok();
}
[HttpPost("play")]
public async Task<IActionResult> PostPlay(TrackPlayRequest request)
{
try
{
await _tomatenMusicDataService.GetGuildAsync(request.GuildId);
}
catch (Exception ex)
{
return NotFound("That Guild was not found");
}
if (!await _tomatenMusicDataService.IsConnectedAsync(request.GuildId) == true)
return BadRequest("The Bot is not connected.");
MusicActionResponse response;
try
{
response = await _tomatenMusicDataService.TrackProvider.SearchAsync(request.TrackUri);
}catch (Exception ex)
{
return NotFound(ex.Message + "\n" + ex.StackTrace);
}
_eventBus.OnPlayRequestEvent(new TrackPlayArgs(response, request.GuildId, TimeSpan.FromSeconds(request.StartTimeSeconds), request.Now));
return Ok();
}
} }

4
TomatenMusic/Models/BasicTrackInfo.cs → TomatenMusic Api/Models/BasicTrackInfo.cs
View File

@ -27,9 +27,9 @@ namespace TomatenMusic_Api.Models
Name = track.Title; Name = track.Title;
Platform = ctx.SpotifyIdentifier == null ? TrackPlatform.YOUTUBE : TrackPlatform.SPOTIFY; Platform = ctx.SpotifyIdentifier == null ? TrackPlatform.YOUTUBE : TrackPlatform.SPOTIFY;
YoutubeId = track.TrackIdentifier; YoutubeId = track.Identifier;
SpotifyId = ctx.SpotifyIdentifier; SpotifyId = ctx.SpotifyIdentifier;
URL = new Uri(track.Source); URL = ctx.YoutubeUri;
} }
} }

0
TomatenMusic/Models/ChannelConnectRequest.cs → TomatenMusic Api/Models/ChannelConnectRequest.cs
View File

0
TomatenMusic/Models/PlayerConnectionInfo.cs → TomatenMusic Api/Models/PlayerConnectionInfo.cs
View File

8
TomatenMusic/Program.cs → TomatenMusic Api/Program.cs
View File

@ -4,9 +4,11 @@ using TomatenMusic_Api.Auth.Services;
var builder = WebApplication.CreateBuilder(args); var builder = WebApplication.CreateBuilder(args);
// Add services to the container.
builder.Services.AddControllers(); builder.Services.AddControllers();
builder.Services.AddCors(); builder.Services.AddCors();
// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
builder.Services.AddEndpointsApiExplorer(); builder.Services.AddEndpointsApiExplorer();
builder.Services.AddSwaggerGen(); builder.Services.AddSwaggerGen();
@ -22,9 +24,11 @@ builder.Services.AddSingleton<TomatenMusicDataService>();
var app = builder.Build(); var app = builder.Build();
// Configure the HTTP request pipeline. // Configure the HTTP request pipeline.
app.UseSwagger();
app.UseSwaggerUI();
app.UseSwagger();
app.UseSwaggerUI();
app.UseHttpsRedirection();
app.UseWebSockets(); app.UseWebSockets();
app.UseCors(x => x app.UseCors(x => x

0
TomatenMusic/Properties/launchSettings.json → TomatenMusic Api/Properties/launchSettings.json
View File

30
TomatenMusic Api/Services/EventBus.cs Normal file
View File

@ -0,0 +1,30 @@
using DSharpPlus.Entities;
using Emzi0767.Utilities;
using Microsoft.AspNetCore.Mvc;
using TomatenMusic_Api.Models;
namespace TomatenMusic_Api;
public class InProcessEventBus
{
public event AsyncEventHandler<InProcessEventBus, ChannelConnectEventArgs>? OnConnectRequest;
public void OnConnectRequestEvent(ChannelConnectEventArgs e)
{
_ = OnConnectRequest?.Invoke(this, e);
}
public class ChannelConnectEventArgs : AsyncEventArgs
{
public ulong Guild_Id { get; set; }
public DiscordChannel Channel { get; set; }
public ChannelConnectEventArgs(ulong guild_Id, DiscordChannel channel)
{
Guild_Id = guild_Id;
Channel = channel;
}
}
}

17
TomatenMusic/Services/TomatenMusicDataService.cs → TomatenMusic Api/Services/TomatenMusicDataService.cs
View File

@ -11,14 +11,12 @@ namespace TomatenMusic_Api
public class TomatenMusicDataService : IHostedService public class TomatenMusicDataService : IHostedService
{ {
private ILogger<TomatenMusicDataService> _logger; private ILogger<TomatenMusicDataService> _logger;
private IServiceProvider _serviceProvider { get; set; } = TomatenMusicBot.ServiceProvider; public IServiceProvider _serviceProvider { get; set; } = TomatenMusicBot.ServiceProvider;
public IAudioService _audioService { get; set; } public IAudioService _audioService { get; set; }
public TrackProvider TrackProvider { get; set; }
public TomatenMusicDataService(ILogger<TomatenMusicDataService> logger) public TomatenMusicDataService(ILogger<TomatenMusicDataService> logger)
{ {
_logger = logger; _logger = logger;
_audioService = _serviceProvider.GetRequiredService<IAudioService>(); _audioService = _serviceProvider.GetRequiredService<IAudioService>();
TrackProvider = _serviceProvider.GetRequiredService<TrackProvider>();
} }
public async Task<PlayerConnectionInfo> GetConnectionInfoAsync(ulong guild_id) public async Task<PlayerConnectionInfo> GetConnectionInfoAsync(ulong guild_id)
@ -60,19 +58,18 @@ namespace TomatenMusic_Api
return list; return list;
} }
public Task<DiscordChannel> GetDiscordChannelAsync(ulong guild_id, ulong channel_id) public Task<DiscordChannel> GetDiscordChannelAsync(ulong channel_id)
{ {
var client = _serviceProvider.GetRequiredService<DiscordShardedClient>(); DiscordClient client = _serviceProvider.GetRequiredService<DiscordClient>();
var guildClient = client.GetShard(guild_id);
return guildClient.GetChannelAsync(channel_id); return client.GetChannelAsync(channel_id);
} }
public Task<DiscordGuild> GetGuildAsync(ulong guild_id) public Task<DiscordGuild> GetGuildAsync(ulong guild_id)
{ {
var client = _serviceProvider.GetRequiredService<DiscordShardedClient>(); DiscordClient client = _serviceProvider.GetRequiredService<DiscordClient>();
var guildClient = client.GetShard(guild_id);
return guildClient.GetGuildAsync(guild_id); return client.GetGuildAsync(guild_id);
} }
public Task StartAsync(CancellationToken cancellationToken) public Task StartAsync(CancellationToken cancellationToken)

42
TomatenMusic/Services/TomatenMusicService.cs → TomatenMusic Api/Services/TomatenMusicService.cs
View File

@ -2,7 +2,6 @@
using TomatenMusic; using TomatenMusic;
using TomatenMusic.Music; using TomatenMusic.Music;
using TomatenMusic_Api.Models; using TomatenMusic_Api.Models;
using TomatenMusic_Api.Models.EventArgs;
using static TomatenMusic_Api.InProcessEventBus; using static TomatenMusic_Api.InProcessEventBus;
namespace TomatenMusic_Api namespace TomatenMusic_Api
@ -25,48 +24,11 @@ namespace TomatenMusic_Api
private void Initialize() private void Initialize()
{ {
_inProcessEventBus.OnConnectRequest += _inProcessEventBus_OnConnectRequest; _inProcessEventBus.OnConnectRequest += _inProcessEventBus_OnConnectRequest;
_inProcessEventBus.OnDisconnectRequest += _inProcessEventBus_OnDisconnectRequest;
_inProcessEventBus.OnPlayRequest += _inProcessEventBus_OnPlayRequest;
} }
private async Task _inProcessEventBus_OnPlayRequest(InProcessEventBus sender, TrackPlayArgs e) private async Task _inProcessEventBus_OnConnectRequest(InProcessEventBus sender, ChannelConnectEventArgs e)
{
GuildPlayer player = _audioService.GetPlayer<GuildPlayer>(e.GuildId);
if (e.Response.Tracks != null && e.Response.Tracks.Any())
{
if (e.Now)
await player.PlayNowAsync(e.Response.Tracks);
else
await player.PlayItemAsync(e.Response.Tracks);
return;
}
if (e.Response.IsPlaylist)
{
if (e.Now)
await player.PlayNowAsync(e.Response.Playlist);
else
await player.PlayItemAsync(e.Response.Playlist);
}else
{
if (e.Now)
await player.PlayNowAsync(e.Response.Track, e.StartTime);
else
await player.PlayAsync(e.Response.Track, e.StartTime);
}
}
private async Task _inProcessEventBus_OnDisconnectRequest(InProcessEventBus sender, ChannelDisconnectArgs e)
{
GuildPlayer player = _audioService.GetPlayer<GuildPlayer>(e.GuildId);
player.DisconnectAsync();
}
private async Task _inProcessEventBus_OnConnectRequest(InProcessEventBus sender, ChannelConnectArgs e)
{ {
_logger.LogInformation("Channel Connected!");
GuildPlayer player = await _audioService.JoinAsync<GuildPlayer>(e.Guild_Id, e.Channel.Id, true); GuildPlayer player = await _audioService.JoinAsync<GuildPlayer>(e.Guild_Id, e.Channel.Id, true);
} }

12
TomatenMusic/TomatenMusic.csproj → TomatenMusic Api/TomatenMusic Api.csproj
View File

@ -5,6 +5,10 @@
<Nullable>enable</Nullable> <Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
<RootNamespace>TomatenMusic_Api</RootNamespace> <RootNamespace>TomatenMusic_Api</RootNamespace>
<RestoreAdditionalProjectSources>
https://api.nuget.org/v3/index.json;
https://nuget.emzi0767.com/api/v3/index.json
</RestoreAdditionalProjectSources>
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
@ -24,12 +28,12 @@
<PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="6.15.0" /> <PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="6.15.0" />
</ItemGroup> </ItemGroup>
<ItemGroup>
<Folder Include="Auth\" />
</ItemGroup>
<ItemGroup> <ItemGroup>
<ProjectReference Include="..\TomatenMusicCore\TomatenMusicCore.csproj" /> <ProjectReference Include="..\TomatenMusicCore\TomatenMusicCore.csproj" />
</ItemGroup> </ItemGroup>
<ItemGroup>
<Folder Include="Auth\" />
</ItemGroup>
</Project> </Project>

0
TomatenMusic/appsettings.Development.json → TomatenMusic Api/appsettings.Development.json
View File

0
TomatenMusic/appsettings.json → TomatenMusic Api/appsettings.json
View File

8
TomatenMusic Api/config.json Normal file
View File

@ -0,0 +1,8 @@
{
"TOKEN"´: "YOUR_BOT_TOKEN",
"LavaLinkPassword": "",
"SpotifyClientId": "",
"SpotifyClientSecret": "",
"YoutubeApiKey": ""
}

25
TomatenMusic V2.sln
View File

@ -3,30 +3,29 @@ Microsoft Visual Studio Solution File, Format Version 12.00
# Visual Studio Version 17 # Visual Studio Version 17
VisualStudioVersion = 17.1.32228.430 VisualStudioVersion = 17.1.32228.430
MinimumVisualStudioVersion = 10.0.40219.1 MinimumVisualStudioVersion = 10.0.40219.1
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TomatenMusic Api", "TomatenMusic Api\TomatenMusic Api.csproj", "{DC429A00-E2CC-4E66-A3B9-AE5F6B37E93A}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TomatenMusicCore", "TomatenMusicCore\TomatenMusicCore.csproj", "{54481E45-9FE3-4CF3-9CE9-489B678AE472}"
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{A3F84EF2-B7C2-44F0-B392-6824AE96530A}" Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{A3F84EF2-B7C2-44F0-B392-6824AE96530A}"
ProjectSection(SolutionItems) = preProject ProjectSection(SolutionItems) = preProject
GitVersion.yml = GitVersion.yml
Readme.md = Readme.md Readme.md = Readme.md
EndProjectSection EndProjectSection
EndProject EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TomatenMusic", "TomatenMusic\TomatenMusic.csproj", "{E612AAB3-9A73-47F3-ACA0-D3A4CC627D4E}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TomatenMusicCore", "TomatenMusicCore\TomatenMusicCore.csproj", "{40B1E82B-656D-413B-B636-EB0AE84391E2}"
EndProject
Global Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU Debug|Any CPU = Debug|Any CPU
Release|Any CPU = Release|Any CPU Release|Any CPU = Release|Any CPU
EndGlobalSection EndGlobalSection
GlobalSection(ProjectConfigurationPlatforms) = postSolution GlobalSection(ProjectConfigurationPlatforms) = postSolution
{E612AAB3-9A73-47F3-ACA0-D3A4CC627D4E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU {DC429A00-E2CC-4E66-A3B9-AE5F6B37E93A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{E612AAB3-9A73-47F3-ACA0-D3A4CC627D4E}.Debug|Any CPU.Build.0 = Debug|Any CPU {DC429A00-E2CC-4E66-A3B9-AE5F6B37E93A}.Debug|Any CPU.Build.0 = Debug|Any CPU
{E612AAB3-9A73-47F3-ACA0-D3A4CC627D4E}.Release|Any CPU.ActiveCfg = Release|Any CPU {DC429A00-E2CC-4E66-A3B9-AE5F6B37E93A}.Release|Any CPU.ActiveCfg = Release|Any CPU
{E612AAB3-9A73-47F3-ACA0-D3A4CC627D4E}.Release|Any CPU.Build.0 = Release|Any CPU {DC429A00-E2CC-4E66-A3B9-AE5F6B37E93A}.Release|Any CPU.Build.0 = Release|Any CPU
{40B1E82B-656D-413B-B636-EB0AE84391E2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU {54481E45-9FE3-4CF3-9CE9-489B678AE472}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{40B1E82B-656D-413B-B636-EB0AE84391E2}.Debug|Any CPU.Build.0 = Debug|Any CPU {54481E45-9FE3-4CF3-9CE9-489B678AE472}.Debug|Any CPU.Build.0 = Debug|Any CPU
{40B1E82B-656D-413B-B636-EB0AE84391E2}.Release|Any CPU.ActiveCfg = Release|Any CPU {54481E45-9FE3-4CF3-9CE9-489B678AE472}.Release|Any CPU.ActiveCfg = Release|Any CPU
{40B1E82B-656D-413B-B636-EB0AE84391E2}.Release|Any CPU.Build.0 = Release|Any CPU {54481E45-9FE3-4CF3-9CE9-489B678AE472}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection EndGlobalSection
GlobalSection(SolutionProperties) = preSolution GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE HideSolutionNode = FALSE

7
TomatenMusic/Models/ChannelDisconnectRequest.cs
View File

@ -1,7 +0,0 @@
namespace TomatenMusic_Api.Models.EventArgs
{
public class ChannelDisconnectRequest
{
public ulong GuildId { get; set; }
}
}

18
TomatenMusic/Models/EventArgs/ChannelConnectArgs.cs
View File

@ -1,18 +0,0 @@
using DSharpPlus.Entities;
using Emzi0767.Utilities;
namespace TomatenMusic_Api.Models.EventArgs
{
public class ChannelConnectArgs : AsyncEventArgs
{
public ulong Guild_Id { get; set; }
public DiscordChannel Channel { get; set; }
public ChannelConnectArgs(ulong guild_Id, DiscordChannel channel)
{
Guild_Id = guild_Id;
Channel = channel;
}
}
}

13
TomatenMusic/Models/EventArgs/ChannelDisconnectArgs.cs
View File

@ -1,13 +0,0 @@
using Emzi0767.Utilities;
namespace TomatenMusic_Api.Models.EventArgs
{
public class ChannelDisconnectArgs : AsyncEventArgs
{
public ulong GuildId { get; set; }
public ChannelDisconnectArgs(ulong guildId) { GuildId = guildId; }
}
}

22
TomatenMusic/Models/EventArgs/TrackPlayArgs.cs
View File

@ -1,22 +0,0 @@
using Emzi0767.Utilities;
using Lavalink4NET.Player;
using TomatenMusic.Music;
namespace TomatenMusic_Api.Models.EventArgs
{
public class TrackPlayArgs : AsyncEventArgs
{
public MusicActionResponse Response { get; set; }
public ulong GuildId { get; set; }
public TimeSpan StartTime { get; set; }
public bool Now { get; set; }
public TrackPlayArgs(MusicActionResponse response, ulong guildId, TimeSpan startTime, bool now)
{
Response = response;
GuildId = guildId;
StartTime = startTime;
Now = now;
}
}
}

10
TomatenMusic/Models/TrackPlayRequest.cs
View File

@ -1,10 +0,0 @@
namespace TomatenMusic_Api.Models
{
public class TrackPlayRequest
{
public ulong GuildId { get; set; }
public string TrackUri { get; set; }
public bool Now { get; set; }
public int StartTimeSeconds { get; set; }
}
}

31
TomatenMusic/Services/EventBus.cs
View File

@ -1,31 +0,0 @@
using DSharpPlus.Entities;
using Emzi0767.Utilities;
using Microsoft.AspNetCore.Mvc;
using TomatenMusic_Api.Models;
using TomatenMusic_Api.Models.EventArgs;
namespace TomatenMusic_Api;
public class InProcessEventBus
{
public event AsyncEventHandler<InProcessEventBus, ChannelConnectArgs>? OnConnectRequest;
public event AsyncEventHandler<InProcessEventBus, ChannelDisconnectArgs>? OnDisconnectRequest;
public event AsyncEventHandler<InProcessEventBus, TrackPlayArgs> OnPlayRequest;
public void OnConnectRequestEvent(ChannelConnectArgs e)
{
_ = OnConnectRequest?.Invoke(this, e);
}
public void OnDisconnectRequestEvent(ChannelDisconnectArgs e)
{
_ = OnDisconnectRequest?.Invoke(this, e);
}
public void OnPlayRequestEvent(TrackPlayArgs e)
{
_ = OnPlayRequest?.Invoke(this, e);
}
}

8
TomatenMusic/config.json
View File

@ -1,8 +0,0 @@
{
"TOKEN": "TOKEN",
"LavaLinkPassword": " ",
"SpotifyClientId": " ",
"SpotifyClientSecret": " ",
"YoutubeApiKey": " "
}

35
TomatenMusicCore/Commands/MusicCommands.cs
View File

@ -17,7 +17,6 @@ using TomatenMusic.Prompt.Option;
using System.Linq; using System.Linq;
using Lavalink4NET; using Lavalink4NET;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using TomatenMusicCore.Prompt.Implementation;
namespace TomatenMusic.Commands namespace TomatenMusic.Commands
{ {
@ -105,40 +104,18 @@ namespace TomatenMusic.Commands
response = await _trackProvider.SearchAsync(query, true); response = await _trackProvider.SearchAsync(query, true);
}catch (Exception e) }catch (Exception e)
{ {
await ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent($"❌ Search failed: ``{e.Message}``, ```{e.StackTrace}```")); await ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent($"❌ Search failed: ``{e.Message}``"));
return; return;
} }
DiscordPromptBase prompt; var prompt = new SongSelectorPrompt($"Search results for {query}", response.Tracks);
prompt.ConfirmCallback = async (tracks) =>
if (!response.IsPlaylist && response.Tracks.Count() == 1)
{
var sPrompt = new SongActionPrompt(response.Tracks.First(), ctx.Member);
prompt = sPrompt;
}
else if (response.IsPlaylist)
{
var sPrompt = new PlaylistSongSelectorPrompt(response.Playlist);
sPrompt.ConfirmCallback = async (tracks) =>
{ {
var selectPrompt = new SongListActionPrompt(tracks, ctx.Member, sPrompt); var selectPrompt = new SongListActionPrompt(tracks, ctx.Member, prompt);
await selectPrompt.UseAsync(sPrompt.Interaction, sPrompt.Message); await selectPrompt.UseAsync(prompt.Interaction, prompt.Message);
}; };
prompt = sPrompt;
}
else
{
var sPrompt = new SongSelectorPrompt($"Search results for {query}", response.Tracks);
sPrompt.ConfirmCallback = async (tracks) =>
{
var selectPrompt = new SongListActionPrompt(tracks, ctx.Member, sPrompt);
await selectPrompt.UseAsync(sPrompt.Interaction, sPrompt.Message);
};
prompt = sPrompt;
}
await prompt.UseAsync(ctx.Interaction, await ctx.GetOriginalResponseAsync());
await prompt.UseAsync(ctx.Interaction, await ctx.GetOriginalResponseAsync());
} }
[SlashCommand("time", "Sets the playing position of the current Song.")] [SlashCommand("time", "Sets the playing position of the current Song.")]

115
TomatenMusicCore/Commands/PlayCommandGroup.cs
View File

@ -5,27 +5,28 @@ using Lavalink4NET.Player;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Diagnostics;
using System.Text; using System.Text;
using System.Threading.Tasks; using System.Threading.Tasks;
using TomatenMusic.Commands.Checks; using TomatenMusic.Commands.Checks;
using TomatenMusic.Music; using TomatenMusic.Music;
using TomatenMusic.Music.Entitites; using TomatenMusic.Music.Entitites;
using TomatenMusic.Util; using TomatenMusic.Util;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Commands namespace TomatenMusic.Commands
{ {
[SlashCommandGroup("playnow", "Plays the specified Song now and prepends the Current song to the Queue.")] [SlashCommandGroup("play", "Play a song.")]
public class PlayCommandGroup : ApplicationCommandModule
{
[SlashCommandGroup("now", "Plays the specified Song now and prepends the Current song to the Queue.")]
public class PlayNowGroup : ApplicationCommandModule public class PlayNowGroup : ApplicationCommandModule
{ {
public IAudioService _audioService { get; set; } public IAudioService _audioService { get; set; }
public ILogger<PlayNowGroup> _logger { get; set; } public ILogger<PlayCommandGroup> _logger { get; set; }
public TrackProvider _trackProvider { get; set; } public TrackProvider _trackProvider { get; set; }
public PlayNowGroup(IAudioService audioService, ILogger<PlayNowGroup> logger, TrackProvider trackProvider) public PlayNowGroup(IAudioService audioService, ILogger<PlayCommandGroup> logger, TrackProvider trackProvider)
{ {
_audioService = audioService; _audioService = audioService;
_logger = logger; _logger = logger;
@ -38,8 +39,6 @@ namespace TomatenMusic.Commands
[OnlyGuildCheck] [OnlyGuildCheck]
public async Task PlayQueryCommand(InteractionContext ctx, [Option("query", "The song search query.")] string query) public async Task PlayQueryCommand(InteractionContext ctx, [Option("query", "The song search query.")] string query)
{ {
var sw = Stopwatch.StartNew();
await ctx.DeferAsync(true); await ctx.DeferAsync(true);
GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id); GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id);
@ -53,11 +52,9 @@ namespace TomatenMusic.Commands
catch (Exception ex) catch (Exception ex)
{ {
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while resolving your query: ``{ex.Message}``, ```{ex.StackTrace}```") .WithContent($"❌ An error occured while resolving your query: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
try try
@ -73,18 +70,16 @@ namespace TomatenMusic.Commands
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``") .WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
} }
try try
{ {
if (response.IsPlaylist) if (response.isPlaylist)
{ {
ILavalinkPlaylist playlist = response.Playlist; LavalinkPlaylist playlist = response.Playlist;
await player.PlayNowAsync(playlist); await player.PlayPlaylistNowAsync(playlist);
_ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent("Now Playing:").AddEmbed( _ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent("Now Playing:").AddEmbed(
Common.AsEmbed(playlist) Common.AsEmbed(playlist)
@ -93,7 +88,7 @@ namespace TomatenMusic.Commands
} }
else else
{ {
TomatenMusicTrack track = response.Track; LavalinkTrack track = response.Track;
_ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent("Playing Now") _ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent("Playing Now")
.AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, 0))); .AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, 0)));
@ -106,13 +101,9 @@ namespace TomatenMusic.Commands
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while playing your Query: ``{ex.Message}``") .WithContent($"❌ An error occured while playing your Query: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
sw.Stop(); }
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
}
[SlashCommand("file", "Play a song file. (mp3/mp4)")] [SlashCommand("file", "Play a song file. (mp3/mp4)")]
[UserInVoiceChannelCheck] [UserInVoiceChannelCheck]
@ -120,9 +111,8 @@ namespace TomatenMusic.Commands
[OnlyGuildCheck] [OnlyGuildCheck]
public async Task PlayFileCommand(InteractionContext ctx, [Option("File", "The File that should be played.")] DiscordAttachment file) public async Task PlayFileCommand(InteractionContext ctx, [Option("File", "The File that should be played.")] DiscordAttachment file)
{ {
var sw = Stopwatch.StartNew();
await ctx.DeferAsync(true); await ctx.DeferAsync(true);
GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id); GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id);
@ -137,9 +127,7 @@ namespace TomatenMusic.Commands
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while resolving your file: ``{ex.Message}``") .WithContent($"❌ An error occured while resolving your file: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
try try
@ -154,9 +142,7 @@ namespace TomatenMusic.Commands
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``") .WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
} }
@ -166,19 +152,17 @@ namespace TomatenMusic.Commands
.AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, 0))); .AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, 0)));
await player.PlayNowAsync(response.Track); await player.PlayNowAsync(response.Track);
sw.Stop(); }
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
}
} }
[SlashCommandGroup("play", "Queues or plays the Song")] [SlashCommandGroup("queue", "Queues or plays the Song")]
public class PlayQueueGroup : ApplicationCommandModule public class PlayQueueGroup : ApplicationCommandModule
{ {
public IAudioService _audioService { get; set; } public IAudioService _audioService { get; set; }
public ILogger<PlayQueueGroup> _logger { get; set; } public ILogger<PlayCommandGroup> _logger { get; set; }
public TrackProvider _trackProvider { get; set; } public TrackProvider _trackProvider { get; set; }
public PlayQueueGroup(IAudioService audioService, ILogger<PlayQueueGroup> logger, TrackProvider trackProvider) public PlayQueueGroup(IAudioService audioService, ILogger<PlayCommandGroup> logger, TrackProvider trackProvider)
{ {
_audioService = audioService; _audioService = audioService;
_logger = logger; _logger = logger;
@ -192,9 +176,7 @@ namespace TomatenMusic.Commands
[OnlyGuildCheck] [OnlyGuildCheck]
public async Task PlayQueryCommand(InteractionContext ctx, [Option("query", "The song search query.")] string query) public async Task PlayQueryCommand(InteractionContext ctx, [Option("query", "The song search query.")] string query)
{ {
var sw = Stopwatch.StartNew(); await ctx.DeferAsync(true);
await ctx.DeferAsync(true);
GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id); GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id);
@ -207,11 +189,9 @@ namespace TomatenMusic.Commands
catch (Exception ex) catch (Exception ex)
{ {
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while resolving your query: ``{ex.Message}``, ```{ex.StackTrace}```") .WithContent($"❌ An error occured while resolving your query: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
try try
@ -226,20 +206,18 @@ namespace TomatenMusic.Commands
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``") .WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
} }
try try
{ {
if (response.IsPlaylist) if (response.isPlaylist)
{ {
ILavalinkPlaylist playlist = response.Playlist; LavalinkPlaylist playlist = response.Playlist;
await player.PlayItemAsync(playlist); await player.PlayPlaylistAsync(playlist);
await ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent("Now Playing:").AddEmbed( _ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent("Now Playing:").AddEmbed(
Common.AsEmbed(playlist) Common.AsEmbed(playlist)
)); ));
@ -251,21 +229,17 @@ namespace TomatenMusic.Commands
_ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent(player.State == PlayerState.NotPlaying ? "Now Playing:" : "Added to Queue") _ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent(player.State == PlayerState.NotPlaying ? "Now Playing:" : "Added to Queue")
.AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, player.State == PlayerState.NotPlaying ? 0 : player.PlayerQueue.Queue.Count + 1))); .AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, player.State == PlayerState.NotPlaying ? 0 : player.PlayerQueue.Queue.Count + 1)));
await player.PlayItemAsync(response.Track); await player.PlayAsync(response.Track);
} }
} }
catch (Exception ex) catch (Exception ex)
{ {
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while playing your Track: ``{ex.Message}``, ```{ex.StackTrace}```") .WithContent($"❌ An error occured while playing your Track: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
sw.Stop(); }
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
}
[SlashCommand("file", "Play a song file. (mp3/mp4)")] [SlashCommand("file", "Play a song file. (mp3/mp4)")]
[UserInVoiceChannelCheck] [UserInVoiceChannelCheck]
@ -273,9 +247,8 @@ namespace TomatenMusic.Commands
[OnlyGuildCheck] [OnlyGuildCheck]
public async Task PlayFileCommand(InteractionContext ctx, [Option("File", "The File that should be played.")] DiscordAttachment file) public async Task PlayFileCommand(InteractionContext ctx, [Option("File", "The File that should be played.")] DiscordAttachment file)
{ {
var sw = Stopwatch.StartNew();
await ctx.DeferAsync(true); await ctx.DeferAsync(true);
GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id); GuildPlayer player = (GuildPlayer)_audioService.GetPlayer(ctx.Guild.Id);
@ -290,9 +263,7 @@ namespace TomatenMusic.Commands
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while resolving your file: ``{ex.Message}``") .WithContent($"❌ An error occured while resolving your file: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
try try
@ -307,9 +278,7 @@ namespace TomatenMusic.Commands
await ctx.EditResponseAsync(new DiscordWebhookBuilder() await ctx.EditResponseAsync(new DiscordWebhookBuilder()
.WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``") .WithContent($"❌ An error occured while connecting to your Channel: ``{ex.Message}``")
); );
sw.Stop(); return;
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
return;
} }
} }
@ -318,10 +287,8 @@ namespace TomatenMusic.Commands
_ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent(player.State == PlayerState.NotPlaying ? "Now Playing:" : "Added to Queue") _ = ctx.EditResponseAsync(new DiscordWebhookBuilder().WithContent(player.State == PlayerState.NotPlaying ? "Now Playing:" : "Added to Queue")
.AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, player.State == PlayerState.NotPlaying ? 0 : player.PlayerQueue.Queue.Count + 1))); .AddEmbed(Common.AsEmbed(track, player.PlayerQueue.LoopType, player.State == PlayerState.NotPlaying ? 0 : player.PlayerQueue.Queue.Count + 1)));
await player.PlayItemAsync(response.Track); await player.PlayAsync(response.Track);
sw.Stop();
_logger.LogDebug($"Command {ctx.CommandName} took {sw.ElapsedMilliseconds}ms to execute.");
} }
} }
}
} }

19
TomatenMusicCore/Music/Entitites/FullTrackContext.cs
View File

@ -8,8 +8,6 @@ using SpotifyAPI.Web;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Lavalink4NET; using Lavalink4NET;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music.Entitites namespace TomatenMusic.Music.Entitites
{ {
@ -17,10 +15,11 @@ namespace TomatenMusic.Music.Entitites
{ {
public bool IsFile { get; set; } public bool IsFile { get; set; }
public string YoutubeDescription { get; set; } public string YoutubeDescription { get; set; }
public Uri YoutubeUri { get; set; }
public IEnumerable<string> YoutubeTags { get; set; } public IEnumerable<string> YoutubeTags { get; set; }
public ulong YoutubeViews { get; set; } public ulong YoutubeViews { get; set; }
public ulong YoutubeLikes { get; set; } public ulong YoutubeLikes { get; set; }
public Uri? YoutubeThumbnail { get; set; } = null; public Uri YoutubeThumbnail { get; set; }
public DateTime YoutubeUploadDate { get; set; } public DateTime YoutubeUploadDate { get; set; }
// //
// Summary: // Summary:
@ -35,7 +34,7 @@ namespace TomatenMusic.Music.Entitites
public int SpotifyPopularity { get; set; } public int SpotifyPopularity { get; set; }
public Uri SpotifyUri { get; set; } public Uri SpotifyUri { get; set; }
public static async Task<TomatenMusicTrack> PopulateAsync(TomatenMusicTrack track, FullTrack spotifyTrack = null, string spotifyId = null) public static async Task<LavalinkTrack> PopulateAsync(LavalinkTrack track, string spotifyIdentifier = null)
{ {
FullTrackContext context = (FullTrackContext)track.Context; FullTrackContext context = (FullTrackContext)track.Context;
@ -44,19 +43,17 @@ namespace TomatenMusic.Music.Entitites
var spotifyService = TomatenMusicBot.ServiceProvider.GetRequiredService<ISpotifyService>(); var spotifyService = TomatenMusicBot.ServiceProvider.GetRequiredService<ISpotifyService>();
var youtubeService = TomatenMusicBot.ServiceProvider.GetRequiredService<YoutubeService>(); var youtubeService = TomatenMusicBot.ServiceProvider.GetRequiredService<YoutubeService>();
if (spotifyId != null) context.SpotifyIdentifier = spotifyIdentifier;
context.SpotifyIdentifier = spotifyId; context.YoutubeUri = new Uri($"https://youtu.be/{track.TrackIdentifier}");
else if (spotifyTrack != null)
context.SpotifyIdentifier = spotifyTrack.Id;
track.Context = context; track.Context = context;
Console.WriteLine(context);
await youtubeService.PopulateTrackInfoAsync(track); await youtubeService.PopulateTrackInfoAsync(track);
await spotifyService.PopulateTrackAsync(track, spotifyTrack); await spotifyService.PopulateTrackAsync(track);
return track; return track;
} }
public static async Task<TrackList> PopulateTracksAsync(TrackList tracks) public static async Task<IEnumerable<LavalinkTrack>> PopulateTracksAsync(IEnumerable<LavalinkTrack> tracks)
{ {
foreach (var trackItem in tracks) foreach (var trackItem in tracks)
{ {

17
TomatenMusicCore/Music/Entitites/IPlayableItem.cs
View File

@ -1,17 +0,0 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TomatenMusic.Music;
namespace TomatenMusicCore.Music.Entities
{
public interface IPlayableItem
{
public string Title { get; }
Task Play(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool noReplace = true);
Task PlayNow(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool withoutQueuePrepend = false);
}
}

8
TomatenMusicCore/Music/Entitites/ILavalinkPlaylist.cs → TomatenMusicCore/Music/Entitites/LavalinkPlaylist.cs
View File

@ -5,15 +5,13 @@ using System.Linq;
using TomatenMusic.Util; using TomatenMusic.Util;
using DSharpPlus.Entities; using DSharpPlus.Entities;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music.Entitites namespace TomatenMusic.Music.Entitites
{ {
public interface ILavalinkPlaylist : IPlayableItem public interface LavalinkPlaylist
{ {
public string Title { get; } public string Name { get; }
public TrackList Tracks { get; } public IEnumerable<LavalinkTrack> Tracks { get; }
public Uri Url { get; } public Uri Url { get; }
public string AuthorName { get; set; } public string AuthorName { get; set; }
public Uri AuthorUri { get; set; } public Uri AuthorUri { get; set; }

48
TomatenMusicCore/Music/Entitites/SpotifyPlaylist.cs
View File

@ -2,15 +2,13 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Text; using System.Text;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music.Entitites namespace TomatenMusic.Music.Entitites
{ {
public class SpotifyPlaylist : ILavalinkPlaylist public class SpotifyPlaylist : LavalinkPlaylist
{ {
public string Title { get; } public string Name { get; }
public TrackList Tracks { get; } public IEnumerable<LavalinkTrack> Tracks { get; }
public Uri Url { get; set; } public Uri Url { get; set; }
public string AuthorName { get; set; } public string AuthorName { get; set; }
public Uri AuthorUri { get; set; } public Uri AuthorUri { get; set; }
@ -19,47 +17,13 @@ namespace TomatenMusic.Music.Entitites
public string Identifier { get; } public string Identifier { get; }
public Uri AuthorThumbnail { get; set; } public Uri AuthorThumbnail { get; set; }
public SpotifyPlaylist(string name, string id, TrackList tracks, Uri uri)
public SpotifyPlaylist(string name, string id, IEnumerable<LavalinkTrack> tracks, Uri uri)
{ {
Title = name; Name = name;
Identifier = id; Identifier = id;
Tracks = tracks; Tracks = tracks;
Url = uri; Url = uri;
} }
public async Task Play(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool noReplace = true)
{
await player.PlayerQueue.QueuePlaylistAsync(this);
if (player.State == PlayerState.NotPlaying)
{
LavalinkTrack nextTrack = player.PlayerQueue.NextTrack().Track;
await player.PlayAsync(nextTrack);
}
}
public async Task PlayNow(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool withoutQueuePrepend = false)
{
if (!player.PlayerQueue.Queue.Any())
player.PlayerQueue.CurrentPlaylist = this;
if (!withoutQueuePrepend && player.State == PlayerState.Playing)
player.PlayerQueue.Queue = new Queue<TomatenMusicTrack>(player.PlayerQueue.Queue.Prepend(new TomatenMusicTrack(player.PlayerQueue.LastTrack.WithPosition(player.TrackPosition))));
Queue<TomatenMusicTrack> reversedTracks = new Queue<TomatenMusicTrack>(Tracks);
TomatenMusicTrack track = reversedTracks.Dequeue();
player.PlayerQueue.LastTrack = track;
await player.PlayAsync(track);
reversedTracks.Reverse();
foreach (var item in reversedTracks)
{
player.PlayerQueue.Queue = new Queue<TomatenMusicTrack>(player.PlayerQueue.Queue.Prepend(item));
}
}
} }
} }

50
TomatenMusicCore/Music/Entitites/TomatenMusicTrack.cs
View File

@ -1,50 +0,0 @@
using Lavalink4NET.Player;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TomatenMusic.Music;
using TomatenMusic.Prompt.Implementation;
namespace TomatenMusicCore.Music.Entities
{
public class TomatenMusicTrack : LavalinkTrack, IPlayableItem
{
public override TimeSpan Position { get; }
public TomatenMusicTrack
(LavalinkTrack track)
: base(track.Identifier, track.Author, track.Duration, track.IsLiveStream, track.IsSeekable, track.Source, track.Title, track.TrackIdentifier, track.Provider)
{
Context = track.Context;
Position = track.Position;
}
public string Title => base.Title;
public async Task Play(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool noReplace = true)
{
if (player.State == PlayerState.NotPlaying)
{
player.PlayerQueue.LastTrack = this;
await player.PlayAsync(this, startTime, endTime, noReplace);
}
else
player.PlayerQueue.QueueTrack(this);
}
public async Task PlayNow(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool withoutQueuePrepend = false)
{
if (!withoutQueuePrepend && player.State == PlayerState.Playing)
player.PlayerQueue.Queue = new Queue<TomatenMusicTrack>(player.PlayerQueue.Queue.Prepend(new TomatenMusicTrack(player.PlayerQueue.LastTrack.WithPosition(player.TrackPosition))));
player.PlayerQueue.LastTrack = this;
await player.PlayAsync(this, startTime, endTime);
}
}
}

567
TomatenMusicCore/Music/Entitites/TrackList.cs
View File

@ -1,567 +0,0 @@

using Lavalink4NET.Player;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Linq;
using TomatenMusic.Music;
namespace TomatenMusicCore.Music.Entities
{
//
// Summary:
// A thread-safe queue for Lavalink4NET.Player.LavalinkTrack.
public sealed class TrackList : IList<TomatenMusicTrack>, ICollection<TomatenMusicTrack>, IEnumerable<TomatenMusicTrack>, IEnumerable, IPlayableItem
{
private readonly List<TomatenMusicTrack> _list;
private readonly object _syncRoot;
//
// Summary:
// Gets the number of queued tracks.
//
// Remarks:
// This property is thread-safe, so it can be used from multiple threads at once
// safely.
public int Count
{
get
{
lock (_syncRoot)
{
return _list.Count;
}
}
}
//
// Summary:
// Gets a value indicating whether the queue is empty.
//
// Remarks:
// This property is thread-safe, so it can be used from multiple threads at once
// safely.
public bool IsEmpty => Count == 0;
//
// Summary:
// Gets a value indicating whether the queue is read-only.
//
// Remarks:
// This property is thread-safe, so it can be used from multiple threads at once
// safely.
public bool IsReadOnly => false;
//
// Summary:
// Gets or sets the enqueued tracks.
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public IReadOnlyList<TomatenMusicTrack> Tracks
{
get
{
lock (_syncRoot)
{
return _list.ToArray();
}
}
set
{
lock (_syncRoot)
{
_list.Clear();
_list.AddRange(value);
}
}
}
public string Title => $"Track List with {Count} Tracks";
//
// Summary:
// Gets or sets the track at the specified index.
//
// Parameters:
// index:
// the zero-based position
//
// Returns:
// the track at the specified index
//
// Remarks:
// This indexer property is thread-safe, so it can be used from multiple threads
// at once safely.
public TomatenMusicTrack this[int index]
{
get
{
lock (_syncRoot)
{
return _list[index];
}
}
set
{
if (value == null)
{
throw new ArgumentNullException("value");
}
lock (_syncRoot)
{
_list[index] = value;
}
}
}
public TrackList()
{
_list = new List<TomatenMusicTrack>();
_syncRoot = new object();
}
public TrackList(IEnumerable<LavalinkTrack> tracks)
{
_list = new List<TomatenMusicTrack>();
_syncRoot = new object();
foreach (var track in tracks)
Add(new TomatenMusicTrack(track));
}
//
// Summary:
// Adds a track at the end of the queue.
//
// Parameters:
// track:
// the track to add
//
// Exceptions:
// T:System.ArgumentNullException:
// thrown if the specified track is null.
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void Add(TomatenMusicTrack track)
{
if (track == null)
{
throw new ArgumentNullException("track");
}
lock (_syncRoot)
{
_list.Add(track);
}
}
//
// Summary:
// Adds all specified tracks to the queue.
//
// Parameters:
// tracks:
// the tracks to enqueue
//
// Exceptions:
// T:System.ArgumentNullException:
// thrown if the specified tracks enumerable is null.
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void AddRange(IEnumerable<TomatenMusicTrack> tracks)
{
if (tracks == null)
{
throw new ArgumentNullException("tracks");
}
lock (_syncRoot)
{
_list.AddRange(tracks);
}
}
//
// Summary:
// Clears all tracks from the queue.
//
// Returns:
// the number of tracks removed
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public int Clear()
{
lock (_syncRoot)
{
int count = _list.Count;
_list.Clear();
return count;
}
}
//
// Summary:
// Gets a value indicating whether the specified track is in the queue.
//
// Parameters:
// track:
// the track to find
//
// Returns:
// a value indicating whether the specified track is in the queue
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public bool Contains(TomatenMusicTrack track)
{
if (track == null)
{
throw new ArgumentNullException("track");
}
lock (_syncRoot)
{
return _list.Contains(track);
}
}
//
// Summary:
// Copies all tracks to the specified array at the specified index.
//
// Parameters:
// array:
// the array to the tracks to
//
// index:
// the zero-based writing start index
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void CopyTo(TomatenMusicTrack[] array, int index)
{
lock (_syncRoot)
{
_list.CopyTo(array, index);
}
}
//
// Summary:
// Dequeues a track using the FIFO method.
//
// Returns:
// the dequeued track
//
// Exceptions:
// T:System.InvalidOperationException:
// thrown if no tracks were in the queue
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public TomatenMusicTrack Dequeue()
{
lock (_syncRoot)
{
if (_list.Count <= 0)
{
throw new InvalidOperationException("No tracks in to dequeue.");
}
TomatenMusicTrack result = _list[0];
_list.RemoveAt(0);
return result;
}
}
//
// Summary:
// Deletes all duplicate tracks from the queue.
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void Distinct()
{
lock (_syncRoot)
{
if (_list.Count > 1)
{
TomatenMusicTrack[] collection = (from track in _list
group track by track.Identifier into s
select s.First()).ToArray();
_list.Clear();
_list.AddRange(collection);
}
}
}
//
// Summary:
// Gets the track enumerator.
//
// Returns:
// the track enumerator
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public IEnumerator<TomatenMusicTrack> GetEnumerator()
{
lock (_syncRoot)
{
return _list.ToList().GetEnumerator();
}
}
//
// Summary:
// Gets the zero-based index of the specified track.
//
// Parameters:
// track:
// the track to locate
//
// Returns:
// the zero-based index of the specified track
//
// Exceptions:
// T:System.ArgumentNullException:
// thrown if the specified track is null.
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public int IndexOf(TomatenMusicTrack track)
{
if (track == null)
{
throw new ArgumentNullException("track");
}
lock (_syncRoot)
{
return _list.IndexOf(track);
}
}
//
// Summary:
// Inserts the specified track at the specified index.
//
// Parameters:
// index:
// the zero-based index to insert (e.g. 0 = top)
//
// track:
// the track to insert
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void Insert(int index, TomatenMusicTrack track)
{
lock (_syncRoot)
{
_list.Insert(index, track);
}
}
//
// Summary:
// Tries to remove the specified track from the queue.
//
// Parameters:
// track:
// the track to remove
//
// Returns:
// a value indicating whether the track was found and removed from the queue
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public bool Remove(TomatenMusicTrack track)
{
lock (_syncRoot)
{
return _list.Remove(track);
}
}
//
// Summary:
// Removes all tracks that matches the specified predicate.
//
// Parameters:
// predicate:
// the track predicate
//
// Returns:
// the number of tracks removed
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public int RemoveAll(Predicate<TomatenMusicTrack> predicate)
{
lock (_syncRoot)
{
return _list.RemoveAll(predicate);
}
}
//
// Summary:
// Removes a track at the specified index.
//
// Parameters:
// index:
// the index to remove the track
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void RemoveAt(int index)
{
lock (_syncRoot)
{
_list.RemoveAt(index);
}
}
//
// Summary:
// Removes all count tracks from the specified index.
//
// Parameters:
// index:
// the start index (zero-based)
//
// count:
// the number of tracks to remove
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void RemoveRange(int index, int count)
{
lock (_syncRoot)
{
_list.RemoveRange(index, count);
}
}
//
// Summary:
// Shuffles / mixes all tracks in the queue.
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public void Shuffle()
{
lock (_syncRoot)
{
if (_list.Count > 2)
{
TomatenMusicTrack[] collection = _list.OrderBy((TomatenMusicTrack s) => Guid.NewGuid()).ToArray();
_list.Clear();
_list.AddRange(collection);
}
}
}
//
// Summary:
// Tries to dequeue a track using the FIFO method.
//
// Parameters:
// track:
// the dequeued track; or default is the result is false.
//
// Returns:
// a value indicating whether a track was dequeued.
//
// Exceptions:
// T:System.InvalidOperationException:
// thrown if no tracks were in the queue
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
public bool TryDequeue(out TomatenMusicTrack? track)
{
lock (_syncRoot)
{
if (_list.Count <= 0)
{
track = null;
return false;
}
track = _list[0];
_list.RemoveAt(0);
return true;
}
}
//
// Summary:
// Clears the queue.
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
void ICollection<TomatenMusicTrack>.Clear()
{
lock (_syncRoot)
{
_list.Clear();
}
}
//
// Summary:
// Gets the track enumerator.
//
// Returns:
// the track enumerator
//
// Remarks:
// This method is thread-safe, so it can be used from multiple threads at once safely.
IEnumerator IEnumerable.GetEnumerator()
{
lock (_syncRoot)
{
return _list.ToArray().GetEnumerator();
}
}
public async Task Play(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool noReplace = true)
{
await player.PlayerQueue.QueueTracksAsync(this);
if (player.State == PlayerState.NotPlaying)
{
LavalinkTrack nextTrack = player.PlayerQueue.NextTrack().Track;
await player.PlayAsync(nextTrack, startTime, endTime, noReplace);
}
}
public async Task PlayNow(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool withoutQueuePrepend = false)
{
Queue<TomatenMusicTrack> reversedTracks = new Queue<TomatenMusicTrack>(this);
player.PlayerQueue.Queue = new Queue<TomatenMusicTrack>(player.PlayerQueue.Queue.Prepend(new TomatenMusicTrack(player.PlayerQueue.LastTrack.WithPosition(player.TrackPosition))));
TomatenMusicTrack track = reversedTracks.Dequeue();
player.PlayerQueue.LastTrack = track;
await player.PlayAsync(track, startTime, endTime);
reversedTracks.Reverse();
foreach (var item in reversedTracks)
{
player.PlayerQueue.Queue = new Queue<TomatenMusicTrack>(player.PlayerQueue.Queue.Prepend(item));
}
}
}
}

55
TomatenMusicCore/Music/Entitites/YoutubePlaylist.cs
View File

@ -4,18 +4,14 @@ using System.Text;
using System.Linq; using System.Linq;
using Google.Apis.YouTube.v3.Data; using Google.Apis.YouTube.v3.Data;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using Microsoft.Extensions.DependencyInjection;
using TomatenMusic.Services;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music.Entitites namespace TomatenMusic.Music.Entitites
{ {
public class YoutubePlaylist : ILavalinkPlaylist public class YoutubePlaylist : LavalinkPlaylist
{ {
public string Title { get; } public string Name { get; }
public TrackList Tracks { get; } public IEnumerable<LavalinkTrack> Tracks { get; }
public int TrackCount { get; } public int TrackCount { get; }
@ -30,50 +26,13 @@ namespace TomatenMusic.Music.Entitites
public Playlist YoutubeItem { get; set; } public Playlist YoutubeItem { get; set; }
public Uri AuthorThumbnail { get; set; } public Uri AuthorThumbnail { get; set; }
public YoutubePlaylist(string name, TrackList tracks, string id) public YoutubePlaylist(string name, IEnumerable<LavalinkTrack> tracks, Uri uri)
{ {
Identifier = id; Identifier = uri.ToString().Replace("https://www.youtube.com/playlist?list=", "");
Title = name; Name = name;
Tracks = tracks; Tracks = tracks;
Url = new Uri($"https://youtube.com/playlist?list={id}"); Url = uri;
TrackCount = tracks.Count(); TrackCount = tracks.Count();
}
public async Task Play(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool noReplace = true)
{
await player.PlayerQueue.QueuePlaylistAsync(this);
if (player.State == PlayerState.NotPlaying)
{
LavalinkTrack nextTrack = player.PlayerQueue.NextTrack().Track;
await player.PlayAsync(nextTrack);
}
}
public async Task PlayNow(GuildPlayer player, TimeSpan? startTime = null, TimeSpan? endTime = null, bool withoutQueuePrepend = false)
{
if (!player.PlayerQueue.Queue.Any())
player.PlayerQueue.CurrentPlaylist = this;
if (!withoutQueuePrepend && player.State == PlayerState.Playing)
player.PlayerQueue.Queue = new Queue<TomatenMusicTrack>(player.PlayerQueue.Queue.Prepend(new TomatenMusicTrack(player.PlayerQueue.LastTrack.WithPosition(player.TrackPosition))));
Queue<TomatenMusicTrack> reversedTracks = new Queue<TomatenMusicTrack>(Tracks);
TomatenMusicTrack track = reversedTracks.Dequeue();
player.PlayerQueue.LastTrack = track;
await player.PlayAsync(track);
reversedTracks.Reverse();
foreach (var item in reversedTracks)
{
player.PlayerQueue.Queue = new Queue<TomatenMusicTrack>(player.PlayerQueue.Queue.Prepend(item));
}
} }
} }
} }

183
TomatenMusicCore/Music/GuildPlayer.cs
View File

@ -15,8 +15,6 @@ using Lavalink4NET;
using Lavalink4NET.Rest; using Lavalink4NET.Rest;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Lavalink4NET.Decoding; using Lavalink4NET.Decoding;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music namespace TomatenMusic.Music
{ {
@ -41,39 +39,124 @@ namespace TomatenMusic.Music
_spotify = serviceProvider.GetRequiredService<ISpotifyService>(); _spotify = serviceProvider.GetRequiredService<ISpotifyService>();
_audioService = serviceProvider.GetRequiredService<IAudioService>(); _audioService = serviceProvider.GetRequiredService<IAudioService>();
} }
public async Task PlayItemAsync(IPlayableItem item, TimeSpan? startTime = null, TimeSpan? endTime = null, bool noReplace = true)
public async override Task PlayAsync(LavalinkTrack track, TimeSpan? startTime = null, TimeSpan? endTime = null, bool noReplace = true)
{ {
EnsureConnected(); EnsureConnected();
EnsureNotDestroyed(); EnsureNotDestroyed();
_ = item.Play(this, startTime, endTime, noReplace); if (State == PlayerState.NotPlaying)
_logger.LogInformation("Started playing Item {0} on Guild {1}", item.Title, (await GetGuildAsync()).Name); {
PlayerQueue.LastTrack = track;
await base.PlayAsync(track, startTime, endTime, noReplace);
_logger.LogInformation("Started playing Track {0} on Guild {1}", track.Title, (await GetGuildAsync()).Name);
}else
PlayerQueue.QueueTrack(track);
QueuePrompt.UpdateFor(GuildId); QueuePrompt.UpdateFor(GuildId);
} }
public async Task PlayNowAsync(IPlayableItem item, TimeSpan? startTime = null, TimeSpan? endTime = null, bool withoutQueuePrepend = false) public async Task PlayNowAsync(LavalinkTrack track, TimeSpan? startTime = null, TimeSpan? endTime = null, bool withoutQueuePrepend = false)
{ {
EnsureConnected(); EnsureConnected();
EnsureNotDestroyed(); EnsureNotDestroyed();
_ = item.PlayNow(this, startTime, endTime, withoutQueuePrepend); if (!withoutQueuePrepend)
_logger.LogInformation("Started playing Item {0} now on Guild {1}", item.Title, (await GetGuildAsync()).Name); PlayerQueue.Queue = new Queue<LavalinkTrack>(PlayerQueue.Queue.Prepend(PlayerQueue.LastTrack));
PlayerQueue.LastTrack = track;
await base.PlayAsync(track, startTime, endTime);
_logger.LogInformation("Started playing Track {0} now on Guild {1}", track.Title, (await GetGuildAsync()).Name);
QueuePrompt.UpdateFor(GuildId);
}
public async Task PlayTracksAsync(List<LavalinkTrack> tracks)
{
EnsureNotDestroyed();
EnsureConnected();
_logger.LogInformation("Started playing TrackList {0} on Guild {1}", tracks.ToString(), (await GetGuildAsync()).Name);
await PlayerQueue.QueueTracksAsync(tracks);
if (State == PlayerState.NotPlaying)
{
LavalinkTrack nextTrack = PlayerQueue.NextTrack().Track;
await base.PlayAsync(nextTrack);
}
QueuePrompt.UpdateFor(GuildId);
}
public async Task PlayTracksNowAsync(IEnumerable<LavalinkTrack> tracks)
{
EnsureConnected();
EnsureNotDestroyed();
Queue<LavalinkTrack> reversedTracks = new Queue<LavalinkTrack>(tracks);
LavalinkTrack track = reversedTracks.Dequeue();
PlayerQueue.LastTrack = track;
await base.PlayAsync(track);
_logger.LogInformation("Started playing Track {0} on Guild {1}", track.Title, (await GetGuildAsync()).Name);
reversedTracks.Reverse();
foreach (var item in reversedTracks)
{
PlayerQueue.Queue = new Queue<LavalinkTrack>(PlayerQueue.Queue.Prepend(PlayerQueue.LastTrack));
}
QueuePrompt.UpdateFor(GuildId);
}
public async Task PlayPlaylistAsync(LavalinkPlaylist playlist)
{
EnsureNotDestroyed();
EnsureConnected();
_logger.LogInformation("Started playing Playlist {0} on Guild {1}", playlist.Name, (await GetGuildAsync()).Name);
await PlayerQueue.QueuePlaylistAsync(playlist);
if (State == PlayerState.NotPlaying)
{
LavalinkTrack nextTrack = PlayerQueue.NextTrack().Track;
await base.PlayAsync(nextTrack);
}
QueuePrompt.UpdateFor(GuildId);
}
public async Task PlayPlaylistNowAsync(LavalinkPlaylist playlist)
{
EnsureConnected();
EnsureNotDestroyed();
if (!PlayerQueue.Queue.Any())
PlayerQueue.CurrentPlaylist = playlist;
Queue<LavalinkTrack> reversedTracks = new Queue<LavalinkTrack>(playlist.Tracks);
LavalinkTrack track = reversedTracks.Dequeue();
PlayerQueue.LastTrack = track;
await base.PlayAsync(track);
_logger.LogInformation("Started playing Track {0} on Guild {1}", track.Title, (await GetGuildAsync()).Name);
reversedTracks.Reverse();
foreach (var item in reversedTracks)
{
PlayerQueue.Queue = new Queue<LavalinkTrack>(PlayerQueue.Queue.Prepend(PlayerQueue.LastTrack));
}
QueuePrompt.UpdateFor(GuildId); QueuePrompt.UpdateFor(GuildId);
} }
public async Task RewindAsync() public async Task RewindAsync()
{ {
EnsureNotDestroyed();
EnsureConnected();
if (Position.Position.Seconds > 5)
{
await ReplayAsync();
return;
}
MusicActionResponse response = PlayerQueue.Rewind(); MusicActionResponse response = PlayerQueue.Rewind();
_logger.LogInformation($"Rewinded Track {CurrentTrack.Title} for Track {response.Track.Title}"); _logger.LogInformation($"Rewinded Track {CurrentTrack.Title} for Track {response.Track.Title}");
@ -83,25 +166,10 @@ namespace TomatenMusic.Music
public async Task SkipAsync() public async Task SkipAsync()
{ {
EnsureNotDestroyed(); MusicActionResponse response = PlayerQueue.NextTrack(true);
EnsureConnected();
MusicActionResponse response;
try
{
response = PlayerQueue.NextTrack(true, Autoplay);
}catch (Exception ex)
{
if (Autoplay)
{
_ = OnAutoPlay(CurrentTrack);
return;
}
throw ex;
}
_logger.LogInformation($"Skipped Track {CurrentTrack.Title} for Track {response.Track.Title}"); _logger.LogInformation($"Skipped Track {CurrentTrack.Title} for Track {response.Track.Title}");
await PlayNowAsync(response.Track, withoutQueuePrepend: true); await base.PlayAsync(response.Track);
QueuePrompt.UpdateFor(GuildId); QueuePrompt.UpdateFor(GuildId);
} }
@ -159,16 +227,10 @@ namespace TomatenMusic.Music
if (channel.Type == ChannelType.Stage) if (channel.Type == ChannelType.Stage)
{ {
DiscordStageInstance stageInstance; DiscordStageInstance stageInstance = await channel.GetStageInstanceAsync();
try
{
stageInstance = await channel.GetStageInstanceAsync();
}catch (Exception ex) if (stageInstance == null)
{
stageInstance = await channel.CreateStageInstanceAsync("Music"); stageInstance = await channel.CreateStageInstanceAsync("Music");
}
await stageInstance.Channel.UpdateCurrentUserVoiceStateAsync(false); await stageInstance.Channel.UpdateCurrentUserVoiceStateAsync(false);
} }
@ -194,16 +256,10 @@ namespace TomatenMusic.Music
await base.SeekPositionAsync(timeSpan); await base.SeekPositionAsync(timeSpan);
QueuePrompt.UpdateFor(GuildId); QueuePrompt.UpdateFor(GuildId);
} }
protected override void Dispose(bool disposing)
{
QueuePrompt.InvalidateFor(GuildId);
base.Dispose(disposing);
}
public async override Task OnTrackEndAsync(TrackEndEventArgs eventArgs) public async override Task OnTrackEndAsync(TrackEndEventArgs eventArgs)
{ {
DisconnectOnStop = false; DisconnectOnStop = false;
YoutubeService youtube = TomatenMusicBot.ServiceProvider.GetRequiredService<YoutubeService>();
var oldTrack = CurrentTrack; var oldTrack = CurrentTrack;
if (eventArgs.Reason != TrackEndReason.Finished) if (eventArgs.Reason != TrackEndReason.Finished)
@ -221,35 +277,30 @@ namespace TomatenMusic.Music
if (!Autoplay) if (!Autoplay)
{ {
_logger.LogInformation("Track has ended and Queue was Empty... Idling"); _logger.LogInformation("Track has ended and Queue was Empty... Idling");
QueuePrompt.UpdateFor(GuildId);
await base.OnTrackEndAsync(eventArgs); await base.OnTrackEndAsync(eventArgs);
return; return;
} }
await base.OnTrackEndAsync(eventArgs); LavalinkTrack newTrack = await youtube.GetRelatedTrackAsync(oldTrack.TrackIdentifier);
_ = OnAutoPlay(oldTrack); _logger.LogInformation($"Autoplaying for track {oldTrack.TrackIdentifier} with Track {newTrack.TrackIdentifier}");
await PlayNowAsync(newTrack, withoutQueuePrepend: true);
/* try
{
LavalinkTrack track = await youtube.GetRelatedTrackAsync(eventArgs.TrackIdentifier);
_logger.LogInformation($"Autoplaying for track {eventArgs.TrackIdentifier} with Track {track.TrackIdentifier}");
await PlayAsync(track);
}
catch (Exception ex2)
{
await base.OnTrackEndAsync(eventArgs);
}*/
} }
} }
} }
public async Task OnAutoPlay(LavalinkTrack oldTrack)
{
YoutubeService youtube = TomatenMusicBot.ServiceProvider.GetRequiredService<YoutubeService>();
TomatenMusicTrack newTrack;
if (oldTrack.Provider != StreamProvider.YouTube)
newTrack = await youtube.GetRelatedTrackAsync(PlayerQueue.PlayedTracks.First(x => x.Provider == StreamProvider.YouTube).TrackIdentifier, PlayerQueue.PlayedTracks.Take(5).ToList().ConvertAll(x => x.TrackIdentifier));
else
newTrack = await youtube.GetRelatedTrackAsync(oldTrack.TrackIdentifier, PlayerQueue.PlayedTracks.Take(5).ToList().ConvertAll(x => x.TrackIdentifier));
_logger.LogInformation($"Autoplaying for track {oldTrack.TrackIdentifier} with Track {newTrack.TrackIdentifier}");
PlayerQueue.LastTrack = newTrack;
await newTrack.PlayNow(this, withoutQueuePrepend: true);
QueuePrompt.UpdateFor(GuildId);
}
public async Task<DiscordChannel> GetChannelAsync() public async Task<DiscordChannel> GetChannelAsync()
{ {
EnsureConnected(); EnsureConnected();

20
TomatenMusicCore/Music/MusicActionResponse.cs
View File

@ -3,29 +3,21 @@ using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Text; using System.Text;
using TomatenMusic.Music.Entitites; using TomatenMusic.Music.Entitites;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music namespace TomatenMusic.Music
{ {
public class MusicActionResponse public class MusicActionResponse
{ {
public ILavalinkPlaylist Playlist { get; } public LavalinkPlaylist Playlist { get; }
public TomatenMusicTrack Track { get; } public LavalinkTrack Track { get; }
public TrackList Tracks { get; } public IEnumerable<LavalinkTrack> Tracks { get; }
public bool IsPlaylist { get; } public bool isPlaylist { get; }
public MusicActionResponse(TomatenMusicTrack track = null, ILavalinkPlaylist playlist = null, TrackList tracks = null) public MusicActionResponse(LavalinkTrack track = null, LavalinkPlaylist playlist = null, IEnumerable<LavalinkTrack> tracks = null)
{ {
Playlist = playlist; Playlist = playlist;
Track = track; Track = track;
IsPlaylist = playlist != null; isPlaylist = playlist != null;
Tracks = tracks; Tracks = tracks;
if (track != null)
{
var list = new TrackList();
list.Add(track);
Tracks = list;
}
} }
} }
} }

50
TomatenMusicCore/Music/PlayerQueue.cs
View File

@ -9,26 +9,24 @@ using TomatenMusic.Util;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music namespace TomatenMusic.Music
{ {
public class PlayerQueue public class PlayerQueue
{ {
public Queue<TomatenMusicTrack> Queue { get; set; } = new Queue<TomatenMusicTrack>(); public Queue<LavalinkTrack> Queue { get; set; } = new Queue<LavalinkTrack>();
public Queue<TomatenMusicTrack> PlayedTracks { get; set; } = new Queue<TomatenMusicTrack>(); public Queue<LavalinkTrack> PlayedTracks { get; set; } = new Queue<LavalinkTrack>();
public ILogger<PlayerQueue> _logger { get; set; } = TomatenMusicBot.ServiceProvider.GetRequiredService<ILogger<PlayerQueue>>(); public ILogger<PlayerQueue> _logger { get; set; } = TomatenMusicBot.ServiceProvider.GetRequiredService<ILogger<PlayerQueue>>();
public ILavalinkPlaylist CurrentPlaylist { get; set; } public LavalinkPlaylist CurrentPlaylist { get; set; }
public LoopType LoopType { get; private set; } = LoopType.NONE; public LoopType LoopType { get; private set; } = LoopType.NONE;
public TomatenMusicTrack LastTrack { get; set; } public LavalinkTrack LastTrack { get; set; }
public List<TomatenMusicTrack> QueueLoopList { get; private set; } = new List<TomatenMusicTrack>(); public List<LavalinkTrack> QueueLoopList { get; private set; }
public void QueueTrack(TomatenMusicTrack track) public void QueueTrack(LavalinkTrack track)
{ {
CurrentPlaylist = null; CurrentPlaylist = null;
Queue.Enqueue(track); Queue.Enqueue(track);
@ -38,17 +36,15 @@ namespace TomatenMusic.Music
QueueLoopList.Add(track); QueueLoopList.Add(track);
} }
public Task QueuePlaylistAsync(ILavalinkPlaylist playlist) public Task QueuePlaylistAsync(LavalinkPlaylist playlist)
{ {
return Task.Run(() => return Task.Run(() =>
{ {
if (CurrentPlaylist == null && Queue.Count == 0) if (CurrentPlaylist == null)
CurrentPlaylist = playlist; CurrentPlaylist = playlist;
else
CurrentPlaylist = null;
_logger.LogInformation("Queued Playlist {0}", playlist.Title); _logger.LogInformation("Queued Playlist {0}", playlist.Name);
foreach (var track in playlist.Tracks) foreach (LavalinkTrack track in playlist.Tracks)
{ {
Queue.Enqueue(track); Queue.Enqueue(track);
} }
@ -61,13 +57,13 @@ namespace TomatenMusic.Music
} }
public Task QueueTracksAsync(TrackList tracks) public Task QueueTracksAsync(List<LavalinkTrack> tracks)
{ {
return Task.Run(() => return Task.Run(() =>
{ {
CurrentPlaylist = null; CurrentPlaylist = null;
_logger.LogInformation("Queued TrackList {0}", tracks.ToString()); _logger.LogInformation("Queued TrackList {0}", tracks.ToString());
foreach (var track in tracks) foreach (LavalinkTrack track in tracks)
{ {
Queue.Enqueue(track); Queue.Enqueue(track);
} }
@ -86,17 +82,16 @@ namespace TomatenMusic.Music
public void RemoveAt(int index) public void RemoveAt(int index)
{ {
if (Queue.Count == 0) throw new InvalidOperationException("Queue was Empty"); if (Queue.Count == 0) throw new InvalidOperationException("Queue was Empty");
List<TomatenMusicTrack> tracks = Queue.ToList(); List<LavalinkTrack> tracks = Queue.ToList();
tracks.RemoveAt(index); tracks.RemoveAt(index);
Queue = new Queue<TomatenMusicTrack>(tracks); Queue = new Queue<LavalinkTrack>(tracks);
} }
public MusicActionResponse NextTrack(bool ignoreLoop = false, bool autoplay = false) public MusicActionResponse NextTrack(bool ignoreLoop = false)
{ {
if (LastTrack != null) if (LastTrack != null)
if (LoopType != LoopType.TRACK || (ignoreLoop && (Queue.Any() || autoplay))) PlayedTracks = new Queue<LavalinkTrack>(PlayedTracks.Prepend(LastTrack));
PlayedTracks = new Queue<TomatenMusicTrack>(PlayedTracks.Prepend(new TomatenMusicTrack(LastTrack.WithPosition(TimeSpan.Zero))));
switch (LoopType) switch (LoopType)
{ {
@ -118,9 +113,9 @@ namespace TomatenMusic.Music
if (!Queue.Any()) if (!Queue.Any())
{ {
if (CurrentPlaylist != null) if (CurrentPlaylist != null)
Queue = new Queue<TomatenMusicTrack>(CurrentPlaylist.Tracks); Queue = new Queue<LavalinkTrack>(CurrentPlaylist.Tracks);
else else
Queue = new Queue<TomatenMusicTrack>(QueueLoopList); Queue = new Queue<LavalinkTrack>(QueueLoopList);
} }
LastTrack = Queue.Dequeue(); LastTrack = Queue.Dequeue();
@ -136,7 +131,7 @@ namespace TomatenMusic.Music
if (!PlayedTracks.Any()) throw new InvalidOperationException("There are no songs that could be rewinded to yet."); if (!PlayedTracks.Any()) throw new InvalidOperationException("There are no songs that could be rewinded to yet.");
Queue = new Queue<TomatenMusicTrack>(Queue.Prepend(LastTrack)); Queue = new Queue<LavalinkTrack>(Queue.Prepend(LastTrack));
LastTrack = PlayedTracks.Dequeue(); LastTrack = PlayedTracks.Dequeue();
return new MusicActionResponse(LastTrack); return new MusicActionResponse(LastTrack);
@ -146,9 +141,9 @@ namespace TomatenMusic.Music
{ {
if (Queue.Count == 0) throw new InvalidOperationException("Queue is Empty"); if (Queue.Count == 0) throw new InvalidOperationException("Queue is Empty");
List<TomatenMusicTrack> tracks = new List<TomatenMusicTrack>(Queue); List<LavalinkTrack> tracks = new List<LavalinkTrack>(Queue);
tracks.Shuffle(); tracks.Shuffle();
Queue = new Queue<TomatenMusicTrack>(tracks); Queue = new Queue<LavalinkTrack>(tracks);
return Task.CompletedTask; return Task.CompletedTask;
} }
@ -158,7 +153,8 @@ namespace TomatenMusic.Music
if (type == LoopType.QUEUE) if (type == LoopType.QUEUE)
{ {
QueueLoopList = new List<TomatenMusicTrack>(Queue.Prepend(LastTrack)); QueueLoopList = new List<LavalinkTrack>(Queue);
QueueLoopList.Add(LastTrack);
} }
} }
} }

66
TomatenMusicCore/Services/TrackProvider.cs → TomatenMusicCore/Music/TrackProvider.cs
View File

@ -5,11 +5,8 @@ using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Text; using System.Text;
using System.Threading.Tasks; using System.Threading.Tasks;
using System.Web;
using TomatenMusic.Music.Entitites; using TomatenMusic.Music.Entitites;
using TomatenMusic.Services; using TomatenMusic.Services;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Music namespace TomatenMusic.Music
{ {
@ -17,13 +14,11 @@ namespace TomatenMusic.Music
{ {
public ISpotifyService _spotifyService { get; set; } public ISpotifyService _spotifyService { get; set; }
public IAudioService _audioService { get; set; } public IAudioService _audioService { get; set; }
public YoutubeService _youtubeService { get; set; }
public TrackProvider(ISpotifyService spotify, IAudioService audioService, YoutubeService youtubeService) public TrackProvider(ISpotifyService spotify, IAudioService audioService)
{ {
_audioService = audioService; _audioService = audioService;
_spotifyService = spotify; _spotifyService = spotify;
_youtubeService = youtubeService;
} }
public async Task<MusicActionResponse> SearchAsync(string query, bool withSearchResults = false) public async Task<MusicActionResponse> SearchAsync(string query, bool withSearchResults = false)
@ -46,34 +41,28 @@ namespace TomatenMusic.Music
else else
loadResult = await _audioService.LoadTracksAsync(query, SearchMode.YouTube); loadResult = await _audioService.LoadTracksAsync(query, SearchMode.YouTube);
if (uri != null && uri.AbsolutePath.Contains("."))
return await SearchAsync(uri);
if (loadResult.LoadType == TrackLoadType.LoadFailed) throw new ArgumentException("Track loading failed"); if (loadResult.LoadType == TrackLoadType.LoadFailed) throw new ArgumentException("Track loading failed");
if (loadResult.LoadType == TrackLoadType.NoMatches) throw new FileNotFoundException("Query resulted in no Matches"); if (loadResult.LoadType == TrackLoadType.NoMatches) throw new FileNotFoundException("Query resulted in no Matches");
if (ParseTimestamp(query) != null)
loadResult.Tracks[0] = loadResult.Tracks[0].WithPosition((TimeSpan)ParseTimestamp(query));
if (withSearchResults && loadResult.LoadType == TrackLoadType.SearchResult) if (withSearchResults && loadResult.LoadType == TrackLoadType.SearchResult)
{ {
return new MusicActionResponse(tracks: await FullTrackContext.PopulateTracksAsync(new TrackList(loadResult.Tracks))); return new MusicActionResponse(tracks: await FullTrackContext.PopulateTracksAsync(loadResult.Tracks));
} }
if (loadResult.LoadType == TrackLoadType.PlaylistLoaded && !isSearch) if (loadResult.LoadType == TrackLoadType.PlaylistLoaded && !isSearch)
return new MusicActionResponse( return new MusicActionResponse(
playlist: await _youtubeService.PopulatePlaylistAsync( playlist: new YoutubePlaylist(loadResult.PlaylistInfo.Name, await FullTrackContext.PopulateTracksAsync(loadResult.Tracks), uri));
new YoutubePlaylist(loadResult.PlaylistInfo.Name, await FullTrackContext.PopulateTracksAsync(new TrackList(loadResult.Tracks)), ParseListId(query))));
else else
return new MusicActionResponse(await FullTrackContext.PopulateAsync(new TomatenMusicTrack(loadResult.Tracks.First()))); return new MusicActionResponse(await FullTrackContext.PopulateAsync(loadResult.Tracks.First()));
} }
public async Task<MusicActionResponse> SearchAsync(Uri fileUri) public async Task<MusicActionResponse> SearchAsync(Uri fileUri)
{ {
var loadResult = new TomatenMusicTrack(await _audioService.GetTrackAsync(fileUri.ToString())); var loadResult = await _audioService.GetTrackAsync(fileUri.ToString());
loadResult.Context = new FullTrackContext loadResult.Context = new FullTrackContext
{ {
IsFile = true IsFile = true
@ -86,50 +75,5 @@ namespace TomatenMusic.Music
} }
public string ParseListId(string url)
{
var uri = new Uri(url, UriKind.Absolute);
var query = HttpUtility.ParseQueryString(uri.Query);
var videoId = string.Empty;
if (query.AllKeys.Contains("list"))
{
videoId = query["list"];
}
else
{
videoId = uri.Segments.Last();
}
return videoId;
}
public TimeSpan? ParseTimestamp(string url)
{
Uri uri;
try
{
uri = new Uri(url, UriKind.Absolute);
}catch (UriFormatException)
{
return null;
}
var query = HttpUtility.ParseQueryString(uri.Query);
int seconds;
if (query.AllKeys.Contains("t"))
{
seconds = int.Parse(query["t"]);
}
else
return null;
return TimeSpan.FromSeconds(seconds);
}
} }
} }

13
TomatenMusicCore/Prompt/Buttons/AddToQueueButton.cs
View File

@ -9,22 +9,19 @@ using System.Threading.Tasks;
using TomatenMusic.Music; using TomatenMusic.Music;
using TomatenMusic.Music.Entitites; using TomatenMusic.Music.Entitites;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
using TomatenMusic.Prompt.Option;
namespace TomatenMusic.Prompt.Buttons namespace TomatenMusic.Prompt.Buttons
{ {
class AddToQueueButton : ButtonPromptOption class AddToQueueButton : ButtonPromptOption
{ {
public TrackList Tracks { get; set; } public List<LavalinkTrack> Tracks { get; set; }
public AddToQueueButton(TrackList tracks, int row, DiscordMember requestMember) public AddToQueueButton(List<LavalinkTrack> tracks, int row, DiscordMember requestMember)
{ {
Tracks = tracks; Tracks = tracks;
Emoji = new DiscordComponentEmoji("▶️"); Emoji = new DiscordComponentEmoji("▶️");
Row = row; Row = row;
Style = DSharpPlus.ButtonStyle.Secondary; Style = DSharpPlus.ButtonStyle.Primary;
UpdateMethod = (prompt) => UpdateMethod = (prompt) =>
{ {
if (requestMember.VoiceState == null || requestMember.VoiceState.Channel == null) if (requestMember.VoiceState == null || requestMember.VoiceState.Channel == null)
@ -35,7 +32,7 @@ namespace TomatenMusic.Prompt.Buttons
Run = async (args, sender, option) => Run = async (args, sender, option) =>
{ {
IAudioService audioService = TomatenMusicBot.ServiceProvider.GetRequiredService<IAudioService>(); IAudioService audioService = TomatenMusicBot.ServiceProvider.GetRequiredService<IAudioService>();
GuildPlayer player; GuildPlayer player;player = audioService.GetPlayer<GuildPlayer>(args.Guild.Id);
try try
{ {
@ -47,7 +44,7 @@ namespace TomatenMusic.Prompt.Buttons
{ {
player = audioService.GetPlayer<GuildPlayer>(args.Guild.Id); player = audioService.GetPlayer<GuildPlayer>(args.Guild.Id);
} }
await player.PlayItemAsync(Tracks); await player.PlayTracksAsync(Tracks);
} }
catch (Exception ex) catch (Exception ex)
{ {

60
TomatenMusicCore/Prompt/Buttons/PlayNowButton.cs
View File

@ -1,60 +0,0 @@
using DSharpPlus.Entities;
using Lavalink4NET;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TomatenMusic;
using TomatenMusic.Music;
using TomatenMusic.Prompt;
using TomatenMusic.Prompt.Option;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusicCore.Prompt.Buttons
{
class PlayNowButton : ButtonPromptOption
{
public TrackList Tracks { get; set; }
public PlayNowButton(TrackList tracks, int row, DiscordMember requestMember)
{
Tracks = tracks;
Emoji = new DiscordComponentEmoji("▶");
Content = "Now";
Row = row;
Style = DSharpPlus.ButtonStyle.Secondary;
UpdateMethod = (prompt) =>
{
if (requestMember.VoiceState == null || requestMember.VoiceState.Channel == null)
prompt.Disabled = true;
return Task.FromResult(prompt);
};
Run = async (args, sender, option) =>
{
IAudioService audioService = TomatenMusicBot.ServiceProvider.GetRequiredService<IAudioService>();
GuildPlayer player;
try
{
try
{
player = await audioService.JoinAsync<GuildPlayer>(args.Guild.Id, ((DiscordMember)args.User).VoiceState.Channel.Id, true);
}
catch (Exception ex)
{
player = audioService.GetPlayer<GuildPlayer>(args.Guild.Id);
}
await player.PlayNowAsync(Tracks);
}
catch (Exception ex)
{
}
};
}
}
}

105
TomatenMusicCore/Prompt/Implementation/PlaylistSongSelectorPrompt.cs
View File

@ -1,105 +0,0 @@
using DSharpPlus;
using DSharpPlus.Entities;
using DSharpPlus.EventArgs;
using Lavalink4NET.Player;
using Microsoft.Extensions.Logging;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TomatenMusic.Music.Entitites;
using TomatenMusic.Prompt;
using TomatenMusic.Prompt.Model;
using TomatenMusic.Prompt.Option;
using TomatenMusic.Util;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusicCore.Prompt.Implementation
{
class PlaylistSongSelectorPrompt : PaginatedSelectPrompt<TomatenMusicTrack>
{
public bool IsConfirmed { get; set; }
public Func<TrackList, Task> ConfirmCallback { get; set; } = (tracks) =>
{
return Task.CompletedTask;
};
public ILavalinkPlaylist Playlist { get; private set; }
public PlaylistSongSelectorPrompt(ILavalinkPlaylist playlist, DiscordPromptBase lastPrompt = null, List<DiscordEmbed> embeds = null) : base(playlist.Title, playlist.Tracks.ToList(), lastPrompt, embeds)
{
Playlist = playlist;
AddOption(new ButtonPromptOption
{
Emoji = new DiscordComponentEmoji("✔️"),
Row = 3,
Style = ButtonStyle.Success,
Run = async (args, client, option) =>
{
if (SelectedItems.Count == 0)
{
await args.Interaction.CreateFollowupMessageAsync(new DiscordFollowupMessageBuilder().WithContent("Please Select a Song!").AsEphemeral(true));
return;
}
IsConfirmed = true;
_ = ConfirmCallback.Invoke(new TrackList(SelectedItems));
}
});
}
public override Task<PaginatedSelectMenuOption<TomatenMusicTrack>> ConvertToOption(TomatenMusicTrack item)
{
return Task.FromResult<PaginatedSelectMenuOption<TomatenMusicTrack>>(new PaginatedSelectMenuOption<TomatenMusicTrack>
{
Label = item.Title,
Description = item.Author
});
}
public override Task OnSelect(TomatenMusicTrack item, ComponentInteractionCreateEventArgs args, DiscordClient sender)
{
_logger.LogDebug($"Added {item.Title}, {SelectedItems}");
return Task.CompletedTask;
}
public override Task OnUnselect(TomatenMusicTrack item, ComponentInteractionCreateEventArgs args, DiscordClient sender)
{
_logger.LogDebug($"Removed {item.Title}");
return Task.CompletedTask;
}
public async Task<TrackList> AwaitSelectionAsync()
{
return await Task.Run(() =>
{
while (!IsConfirmed)
{
if (State == PromptState.INVALID)
throw new InvalidOperationException("Prompt has been Invalidated");
}
IsConfirmed = false;
return new TrackList(SelectedItems);
});
}
protected override DiscordMessageBuilder PopulateMessage(DiscordEmbedBuilder builder)
{
builder.WithTitle(Title);
builder.WithDescription(Common.TrackListString(PageManager.GetPage(CurrentPage), 4000));
builder.WithUrl(Playlist.Url);
builder.WithAuthor(Playlist.AuthorName, Playlist.AuthorUri.ToString(), Playlist.AuthorThumbnail.ToString());
List<DiscordEmbed> embeds = new List<DiscordEmbed>();
embeds.Add(builder.Build());
if (Embeds != null)
embeds.AddRange(Embeds);
return new DiscordMessageBuilder().AddEmbeds(embeds);
}
}
}

25
TomatenMusicCore/Prompt/Implementation/QueuePrompt.cs
View File

@ -32,7 +32,7 @@ namespace TomatenMusic.Prompt.Implementation
} }
public static void UpdateFor(ulong guildId) public static void UpdateFor(ulong guildId)
{ {
_ = Task.Delay(400).ContinueWith(async (task) => _ = Task.Delay(600).ContinueWith(async (task) =>
{ {
foreach (var prompt in ActivePrompts) foreach (var prompt in ActivePrompts)
{ {
@ -93,15 +93,11 @@ namespace TomatenMusic.Prompt.Implementation
_ = args.Interaction.EditOriginalResponseAsync(new DiscordWebhookBuilder().WithContent("Please connect to the bots Channel to use this Interaction")); _ = args.Interaction.EditOriginalResponseAsync(new DiscordWebhookBuilder().WithContent("Please connect to the bots Channel to use this Interaction"));
return; return;
} }
try try
{ {
await Player.RewindAsync(); await Player.RewindAsync();
} }catch (Exception ex)
catch (Exception ex)
{ {
Console.WriteLine(ex);
} }
} }
@ -135,18 +131,8 @@ namespace TomatenMusic.Prompt.Implementation
_ = args.Interaction.EditOriginalResponseAsync(new DiscordWebhookBuilder().WithContent("Please connect to the bots Channel to use this Interaction")); _ = args.Interaction.EditOriginalResponseAsync(new DiscordWebhookBuilder().WithContent("Please connect to the bots Channel to use this Interaction"));
return; return;
} }
try
{
await Player.SkipAsync();
} await Player.SkipAsync();
catch (Exception ex)
{
_ = args.Interaction.CreateResponseAsync(
DSharpPlus.InteractionResponseType.ChannelMessageWithSource,
new DiscordInteractionResponseBuilder()
.WithContent($"An Error occurred during this Interaction {ex.Message}"));
}
System.Timers.Timer timer = new System.Timers.Timer(800); System.Timers.Timer timer = new System.Timers.Timer(800);
timer.Elapsed += (s, args) => timer.Elapsed += (s, args) =>
@ -283,10 +269,7 @@ namespace TomatenMusic.Prompt.Implementation
protected async override Task<DiscordMessageBuilder> GetMessageAsync() protected async override Task<DiscordMessageBuilder> GetMessageAsync()
{ {
return new DiscordMessageBuilder() return new DiscordMessageBuilder().AddEmbed(Common.GetQueueEmbed(Player)).AddEmbed(await Common.CurrentSongEmbedAsync(Player)).AddEmbeds(Embeds);
.AddEmbed(Common.GetQueueEmbed(Player))
.AddEmbed(await Common.CurrentSongEmbedAsync(Player))
.AddEmbeds(Embeds);
} }
} }
} }

14
TomatenMusicCore/Prompt/Implementation/SongActionPrompt.cs
View File

@ -7,29 +7,23 @@ using System.Threading.Tasks;
using TomatenMusic.Music.Entitites; using TomatenMusic.Music.Entitites;
using TomatenMusic.Prompt.Buttons; using TomatenMusic.Prompt.Buttons;
using TomatenMusic.Prompt.Model; using TomatenMusic.Prompt.Model;
using TomatenMusic.Util;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
using TomatenMusicCore.Prompt.Buttons;
namespace TomatenMusic.Prompt.Implementation namespace TomatenMusic.Prompt.Implementation
{ {
class SongActionPrompt : ButtonPrompt class SongActionPrompt : ButtonPrompt
{ {
public LavalinkTrack Track { get; set; } public LavalinkTrack Track { get; set; }
public SongActionPrompt(TomatenMusicTrack track, DiscordMember requestMember, List<DiscordEmbed> embeds = null) public SongActionPrompt(LavalinkTrack track, DiscordMember requestMember, List<DiscordEmbed> embeds = null)
{ {
Embeds = embeds == null ? new List<DiscordEmbed>() : embeds; Embeds = embeds;
Track = track; Track = track;
AddOption(new AddToQueueButton(new TrackList() { track }, 1, requestMember)); AddOption(new AddToQueueButton(new List<LavalinkTrack>() { track }, 1, requestMember));
AddOption(new PlayNowButton(new TrackList() { track }, 1, requestMember));
} }
protected async override Task<DiscordMessageBuilder> GetMessageAsync() protected async override Task<DiscordMessageBuilder> GetMessageAsync()
{ {
return new DiscordMessageBuilder().AddEmbed(Common.AsEmbed(Track)).AddEmbeds(Embeds); return new DiscordMessageBuilder().AddEmbeds(Embeds);
} }
} }
} }

11
TomatenMusicCore/Prompt/Implementation/SongListActionPrompt.cs
View File

@ -11,24 +11,19 @@ using TomatenMusic.Music;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using TomatenMusic.Prompt.Buttons; using TomatenMusic.Prompt.Buttons;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
using TomatenMusicCore.Prompt.Buttons;
namespace TomatenMusic.Prompt.Implementation namespace TomatenMusic.Prompt.Implementation
{ {
class SongListActionPrompt : ButtonPrompt class SongListActionPrompt : ButtonPrompt
{ {
//TODO //TODO
public TrackList Tracks { get; private set; } public List<LavalinkTrack> Tracks { get; private set; }
public SongListActionPrompt(TrackList tracks, DiscordMember requestMember, DiscordPromptBase lastPrompt = null) : base(lastPrompt) public SongListActionPrompt(List<LavalinkTrack> tracks, DiscordMember requestMember, DiscordPromptBase lastPrompt = null) : base(lastPrompt)
{ {
Tracks = tracks; Tracks = tracks;
AddOption(new AddToQueueButton(tracks, 1, requestMember)); AddOption(new AddToQueueButton(tracks, 1, requestMember));
AddOption(new PlayNowButton(tracks, 1, requestMember));
} }
protected override Task<DiscordMessageBuilder> GetMessageAsync() protected override Task<DiscordMessageBuilder> GetMessageAsync()
@ -37,7 +32,7 @@ namespace TomatenMusic.Prompt.Implementation
DiscordEmbedBuilder builder = new DiscordEmbedBuilder() DiscordEmbedBuilder builder = new DiscordEmbedBuilder()
.WithTitle("What do you want to do with these Tracks?"); .WithTitle("What do you want to do with these Tracks?");
builder.WithDescription(Common.TrackListString(Tracks, 1000)); builder.WithDescription(Common.TrackListString(Tracks));
return Task.FromResult(new DiscordMessageBuilder().WithEmbed(builder.Build())); return Task.FromResult(new DiscordMessageBuilder().WithEmbed(builder.Build()));
} }

9
TomatenMusicCore/Prompt/Implementation/SongSelectorPrompt.cs
View File

@ -12,16 +12,13 @@ using TomatenMusic.Music.Entitites;
using TomatenMusic.Music; using TomatenMusic.Music;
using System.Linq; using System.Linq;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
using TomatenMusic.Prompt.Option;
namespace TomatenMusic.Prompt.Implementation namespace TomatenMusic.Prompt.Implementation
{ {
sealed class SongSelectorPrompt : PaginatedSelectPrompt<LavalinkTrack> sealed class SongSelectorPrompt : PaginatedSelectPrompt<LavalinkTrack>
{ {
public bool IsConfirmed { get; set; } public bool IsConfirmed { get; set; }
public Func<TrackList, Task> ConfirmCallback { get; set; } = (tracks) => public Func<List<LavalinkTrack>, Task> ConfirmCallback { get; set; } = (tracks) =>
{ {
return Task.CompletedTask; return Task.CompletedTask;
}; };
@ -45,7 +42,7 @@ namespace TomatenMusic.Prompt.Implementation
return; return;
} }
IsConfirmed = true; IsConfirmed = true;
_ = ConfirmCallback.Invoke(new TrackList(SelectedItems)); _ = ConfirmCallback.Invoke(SelectedItems);
} }
}); });
} }
@ -90,7 +87,7 @@ namespace TomatenMusic.Prompt.Implementation
{ {
builder.WithTitle(Title); builder.WithTitle(Title);
builder.WithDescription(Common.TrackListString(PageManager.GetPage(CurrentPage), 4000)); builder.WithDescription(Common.TrackListString(PageManager.GetPage(CurrentPage)));
List<DiscordEmbed> embeds = new List<DiscordEmbed>(); List<DiscordEmbed> embeds = new List<DiscordEmbed>();
embeds.Add(builder.Build()); embeds.Add(builder.Build());

28
TomatenMusicCore/Prompt/Model/DiscordPromptBase.cs
View File

@ -23,7 +23,6 @@ namespace TomatenMusic.Prompt.Model
public List<IPromptOption> Options { get; protected set; } = new List<IPromptOption>(); public List<IPromptOption> Options { get; protected set; } = new List<IPromptOption>();
public DiscordClient _client { get; set; } public DiscordClient _client { get; set; }
public DiscordPromptBase LastPrompt { get; protected set; } public DiscordPromptBase LastPrompt { get; protected set; }
public System.Timers.Timer TimeoutTimer { get; set; }
protected ILogger<DiscordPromptBase> _logger { get; set; } protected ILogger<DiscordPromptBase> _logger { get; set; }
@ -133,16 +132,6 @@ namespace TomatenMusic.Prompt.Model
Interaction = interaction; Interaction = interaction;
Message = await interaction.CreateFollowupMessageAsync(builder); Message = await interaction.CreateFollowupMessageAsync(builder);
State = PromptState.OPEN; State = PromptState.OPEN;
long timeoutTime = (Interaction.CreationTimestamp.ToUnixTimeMilliseconds() + 900000) - DateTimeOffset.Now.ToUnixTimeMilliseconds();
if (TimeoutTimer != null)
TimeoutTimer.Close();
TimeoutTimer = new System.Timers.Timer(timeoutTime);
TimeoutTimer.Elapsed += OnTimeout;
TimeoutTimer.AutoReset = false;
TimeoutTimer.Start();
} }
public async Task UseAsync(DiscordMessage message) public async Task UseAsync(DiscordMessage message)
@ -175,7 +164,6 @@ namespace TomatenMusic.Prompt.Model
_client = client.GetShard((ulong)interaction.GuildId); _client = client.GetShard((ulong)interaction.GuildId);
_client.ComponentInteractionCreated += Discord_ComponentInteractionCreated; _client.ComponentInteractionCreated += Discord_ComponentInteractionCreated;
ActivePrompts.Add(this); ActivePrompts.Add(this);
AddGuids(); AddGuids();
DiscordWebhookBuilder builder = await GetWebhookMessageAsync(); DiscordWebhookBuilder builder = await GetWebhookMessageAsync();
@ -183,22 +171,6 @@ namespace TomatenMusic.Prompt.Model
Message = message; Message = message;
await EditMessageAsync(builder); await EditMessageAsync(builder);
State = PromptState.OPEN; State = PromptState.OPEN;
long timeoutTime = (Interaction.CreationTimestamp.ToUnixTimeMilliseconds() + 900000) - DateTimeOffset.Now.ToUnixTimeMilliseconds();
if (TimeoutTimer != null)
TimeoutTimer.Close();
TimeoutTimer = new System.Timers.Timer(timeoutTime);
TimeoutTimer.Elapsed += OnTimeout;
TimeoutTimer.AutoReset = false;
TimeoutTimer.Start();
}
private void OnTimeout(object? sender, System.Timers.ElapsedEventArgs e)
{
_ = InvalidateAsync();
} }
private void AddGuids() private void AddGuids()

4
TomatenMusicCore/Prompt/Model/PaginatedButtonPrompt.cs
View File

@ -7,7 +7,8 @@ using TomatenMusic.Util;
using DSharpPlus; using DSharpPlus;
using DSharpPlus.EventArgs; using DSharpPlus.EventArgs;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using TomatenMusic.Prompt.Option;
namespace TomatenMusic.Prompt.Model namespace TomatenMusic.Prompt.Model
{ {
@ -25,7 +26,6 @@ namespace TomatenMusic.Prompt.Model
for (int i = 0; i < 9; i++) for (int i = 0; i < 9; i++)
{ {
int currentNumber = i + 1; int currentNumber = i + 1;
ButtonPromptOption option = new ButtonPromptOption() ButtonPromptOption option = new ButtonPromptOption()
{ {
Style = DSharpPlus.ButtonStyle.Primary, Style = DSharpPlus.ButtonStyle.Primary,

2
TomatenMusicCore/Prompt/Model/PaginatedSelectPrompt.cs
View File

@ -24,7 +24,7 @@ namespace TomatenMusic.Prompt.Model
public PaginatedSelectPrompt(string title, List<T> items, DiscordPromptBase lastPrompt = null, List<DiscordEmbed> embeds = null) : base(lastPrompt) public PaginatedSelectPrompt(string title, List<T> items, DiscordPromptBase lastPrompt = null, List<DiscordEmbed> embeds = null) : base(lastPrompt)
{ {
Embeds = embeds; Embeds = embeds;
PageManager = new PageManager<T>(items, 10); PageManager = new PageManager<T>(items, 25);
Title = title; Title = title;
AddOption(new SelectMenuPromptOption AddOption(new SelectMenuPromptOption
{ {

2
TomatenMusicCore/Prompt/Option/ButtonPromptOption.cs
View File

@ -8,7 +8,7 @@ using TomatenMusic.Prompt.Option;
using TomatenMusic.Prompt.Model; using TomatenMusic.Prompt.Model;
namespace TomatenMusic.Prompt.Option namespace TomatenMusic.Prompt
{ {
class ButtonPromptOption : IPromptOption class ButtonPromptOption : IPromptOption
{ {

3
TomatenMusicCore/Prompt/Option/IPromptOption.cs
View File

@ -19,5 +19,8 @@ namespace TomatenMusic.Prompt.Option
public Func<IPromptOption, Task<IPromptOption>> UpdateMethod { get; set; } public Func<IPromptOption, Task<IPromptOption>> UpdateMethod { get; set; }
public Func<DSharpPlus.EventArgs.ComponentInteractionCreateEventArgs, DiscordClient, IPromptOption, Task> Run { get; set; } public Func<DSharpPlus.EventArgs.ComponentInteractionCreateEventArgs, DiscordClient, IPromptOption, Task> Run { get; set; }
} }
} }

102
TomatenMusicCore/Services/SpotifyService.cs
View File

@ -11,9 +11,6 @@ using TomatenMusic.Services;
using TomatenMusic.Music; using TomatenMusic.Music;
using Lavalink4NET; using Lavalink4NET;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using System.Runtime.Caching;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Services namespace TomatenMusic.Services
{ {
@ -21,9 +18,9 @@ namespace TomatenMusic.Services
public interface ISpotifyService public interface ISpotifyService
{ {
public Task<MusicActionResponse> ConvertURL(string url); public Task<MusicActionResponse> ConvertURL(string url);
public Task<SpotifyPlaylist> PopulateSpotifyPlaylistAsync(SpotifyPlaylist playlist, FullPlaylist spotifyPlaylist = null); public Task<SpotifyPlaylist> PopulateSpotifyPlaylistAsync(SpotifyPlaylist playlist);
public Task<SpotifyPlaylist> PopulateSpotifyAlbumAsync(SpotifyPlaylist playlist, FullAlbum spotifyAlbum = null); public Task<SpotifyPlaylist> PopulateSpotifyAlbumAsync(SpotifyPlaylist playlist);
public Task<LavalinkTrack> PopulateTrackAsync(LavalinkTrack track, FullTrack spotifyFullTrack = null); public Task<LavalinkTrack> PopulateTrackAsync(LavalinkTrack track);
} }
@ -32,13 +29,10 @@ namespace TomatenMusic.Services
public ILogger _logger { get; set; } public ILogger _logger { get; set; }
public IAudioService _audioService { get; set; } public IAudioService _audioService { get; set; }
public ObjectCache Cache { get; set; }
public SpotifyService(SpotifyClientConfig config, ILogger<SpotifyService> logger, IAudioService audioService) : base(config) public SpotifyService(SpotifyClientConfig config, ILogger<SpotifyService> logger, IAudioService audioService) : base(config)
{ {
_logger = logger; _logger = logger;
_audioService = audioService; _audioService = audioService;
Cache = MemoryCache.Default;
} }
public async Task<MusicActionResponse> ConvertURL(string url) public async Task<MusicActionResponse> ConvertURL(string url)
@ -49,59 +43,49 @@ namespace TomatenMusic.Services
.Replace("https://open.spotify.com/playlist/", "") .Replace("https://open.spotify.com/playlist/", "")
.Substring(0, 22); .Substring(0, 22);
_logger.LogDebug($"Starting spotify conversion for: {url}");
if (url.StartsWith("https://open.spotify.com/track")) if (url.StartsWith("https://open.spotify.com/track"))
{ {
FullTrack sTrack = Cache.Contains(trackId) ? Cache.Get(trackId) as FullTrack : await Tracks.Get(trackId); FullTrack sTrack = await Tracks.Get(trackId);
_logger.LogInformation($"Searching youtube from spotify with query: {sTrack.Name} {String.Join(" ", sTrack.Artists)}"); _logger.LogInformation($"Searching youtube from spotify with query: {sTrack.Name} {String.Join(" ", sTrack.Artists)}");
var track = new TomatenMusicTrack( var track = await _audioService.GetTrackAsync($"{sTrack.Name} {String.Join(" ", sTrack.Artists.ConvertAll(artist => artist.Name))}", Lavalink4NET.Rest.SearchMode.YouTube);
await _audioService.GetTrackAsync($"{sTrack.Name} {String.Join(" ", sTrack.Artists.ConvertAll(artist => artist.Name))}"
, Lavalink4NET.Rest.SearchMode.YouTube));
if (track == null) throw new ArgumentException("This Spotify Track was not found on Youtube"); if (track == null) throw new ArgumentException("This Spotify Track was not found on Youtube");
Cache.Add(trackId, sTrack, DateTimeOffset.MaxValue); return new MusicActionResponse(await FullTrackContext.PopulateAsync(track, sTrack.Uri));
return new MusicActionResponse(await FullTrackContext.PopulateAsync(track, sTrack));
} }
else if (url.StartsWith("https://open.spotify.com/album")) else if (url.StartsWith("https://open.spotify.com/album"))
{ {
TrackList tracks = new TrackList(); List<LavalinkTrack> tracks = new List<LavalinkTrack>();
FullAlbum album = Cache.Contains(trackId) ? Cache.Get(trackId) as FullAlbum : await Albums.Get(trackId); FullAlbum album = await Albums.Get(trackId);
foreach (var sTrack in await PaginateAll(album.Tracks)) foreach (var sTrack in await PaginateAll(album.Tracks))
{ {
_logger.LogInformation($"Searching youtube from spotify with query: {sTrack.Name} {String.Join(" ", sTrack.Artists.ConvertAll(artist => artist.Name))}"); _logger.LogInformation($"Searching youtube from spotify with query: {sTrack.Name} {String.Join(" ", sTrack.Artists.ConvertAll(artist => artist.Name))}");
var track = new TomatenMusicTrack(
await _audioService.GetTrackAsync($"{sTrack.Name} {String.Join(" ", sTrack.Artists.ConvertAll(artist => artist.Name))}" var track = await _audioService.GetTrackAsync($"{sTrack.Name} {String.Join(" ", sTrack.Artists.ConvertAll(artist => artist.Name))}", Lavalink4NET.Rest.SearchMode.YouTube);
, Lavalink4NET.Rest.SearchMode.YouTube));
if (track == null) throw new ArgumentException("This Spotify Track was not found on Youtube"); if (track == null) throw new ArgumentException("This Spotify Track was not found on Youtube");
tracks.Add(await FullTrackContext.PopulateAsync(track, spotifyId: sTrack.Uri.Replace("spotify:track:", ""))); tracks.Add(await FullTrackContext.PopulateAsync(track, sTrack.Uri));
} }
Uri uri; Uri uri;
Uri.TryCreate(url, UriKind.Absolute, out uri); Uri.TryCreate(url, UriKind.Absolute, out uri);
SpotifyPlaylist playlist = new SpotifyPlaylist(album.Name, album.Id, tracks, uri); SpotifyPlaylist playlist = new SpotifyPlaylist(album.Name, album.Id, tracks, uri);
await PopulateSpotifyAlbumAsync(playlist, album); await PopulateSpotifyAlbumAsync(playlist);
Cache.Add(trackId, album, DateTimeOffset.MaxValue);
return new MusicActionResponse(playlist: playlist); return new MusicActionResponse(playlist: playlist);
} }
else if (url.StartsWith("https://open.spotify.com/playlist")) else if (url.StartsWith("https://open.spotify.com/playlist"))
{ {
List<LavalinkTrack> tracks = new List<LavalinkTrack>();
TrackList tracks = new TrackList(); FullPlaylist spotifyPlaylist = await Playlists.Get(trackId);
FullPlaylist spotifyPlaylist = Cache.Contains(trackId) ? Cache.Get(trackId) as FullPlaylist : await Playlists.Get(trackId);
foreach (var sTrack in await PaginateAll(spotifyPlaylist.Tracks)) foreach (var sTrack in await PaginateAll(spotifyPlaylist.Tracks))
{ {
@ -110,84 +94,60 @@ namespace TomatenMusic.Services
FullTrack fullTrack = (FullTrack)sTrack.Track; FullTrack fullTrack = (FullTrack)sTrack.Track;
_logger.LogInformation($"Searching youtube from spotify with query: {fullTrack.Name} {String.Join(" ", fullTrack.Artists.ConvertAll(artist => artist.Name))}"); _logger.LogInformation($"Searching youtube from spotify with query: {fullTrack.Name} {String.Join(" ", fullTrack.Artists.ConvertAll(artist => artist.Name))}");
var track = new TomatenMusicTrack( var track = await _audioService.GetTrackAsync($"{fullTrack.Name} {String.Join(" ", fullTrack.Artists.ConvertAll(artist => artist.Name))}", Lavalink4NET.Rest.SearchMode.YouTube);
await _audioService.GetTrackAsync($"{fullTrack.Name} {String.Join(" ", fullTrack.Artists.ConvertAll(artist => artist.Name))}"
, Lavalink4NET.Rest.SearchMode.YouTube));
if (track == null) throw new ArgumentException("This Spotify Track was not found on Youtube"); if (track == null) throw new ArgumentException("This Spotify Track was not found on Youtube");
tracks.Add(await FullTrackContext.PopulateAsync(track, fullTrack)); tracks.Add(await FullTrackContext.PopulateAsync(track, fullTrack.Uri));
} }
} }
Uri uri; Uri uri;
Uri.TryCreate(url, UriKind.Absolute, out uri); Uri.TryCreate(url, UriKind.Absolute, out uri);
SpotifyPlaylist playlist = new SpotifyPlaylist(spotifyPlaylist.Name, spotifyPlaylist.Id, tracks, uri); SpotifyPlaylist playlist = new SpotifyPlaylist(spotifyPlaylist.Name, spotifyPlaylist.Id, tracks, uri);
await PopulateSpotifyPlaylistAsync(playlist, spotifyPlaylist); await PopulateSpotifyPlaylistAsync(playlist);
Cache.Add(trackId, spotifyPlaylist, DateTimeOffset.MaxValue);
return new MusicActionResponse(playlist: playlist); return new MusicActionResponse(playlist: playlist);
} }
return null; return null;
} }
public async Task<SpotifyPlaylist> PopulateSpotifyPlaylistAsync(SpotifyPlaylist playlist, FullPlaylist spotifyPlaylist = null) public async Task<SpotifyPlaylist> PopulateSpotifyPlaylistAsync(SpotifyPlaylist playlist)
{ {
FullPlaylist list = spotifyPlaylist; var list = await this.Playlists.Get(playlist.Identifier);
if (list == null) playlist.Description = list.Description;
list = await this.Playlists.Get(playlist.Identifier); playlist.AuthorUri = new Uri(list.Owner.Uri);
string desc = list.Description;
playlist.Description = desc.Substring(0, Math.Min(desc.Length, 1024)) + (desc.Length > 1020 ? "..." : " ");
if (playlist.Description.Length < 2)
playlist.Description = "None";
playlist.AuthorUri = new Uri($"https://open.spotify.com/user/{list.Owner.Id}");
playlist.AuthorName = list.Owner.DisplayName; playlist.AuthorName = list.Owner.DisplayName;
playlist.Followers = list.Followers.Total; playlist.Followers = list.Followers.Total;
playlist.Url = new Uri($"https://open.spotify.com/playlist/{playlist.Identifier}"); playlist.Url = new Uri(list.Uri);
try playlist.AuthorThumbnail = new Uri(list.Owner.Images.First().Url);
{
playlist.AuthorThumbnail = new Uri(list.Owner.Images.First().Url);
}
catch (Exception ex) { }
return playlist; return playlist;
} }
public async Task<SpotifyPlaylist> PopulateSpotifyAlbumAsync(SpotifyPlaylist playlist, FullAlbum spotifyAlbum = null) public async Task<SpotifyPlaylist> PopulateSpotifyAlbumAsync(SpotifyPlaylist playlist)
{ {
FullAlbum list = spotifyAlbum; var list = await this.Albums.Get(playlist.Identifier);
if (list == null) playlist.Description = list.Label;
list = await this.Albums.Get(playlist.Identifier); playlist.AuthorUri = new Uri(list.Artists.First().Uri);
string desc = list.Label;
playlist.Description = desc.Substring(0, Math.Min(desc.Length, 1024)) + (desc.Length > 1020 ? "..." : " ");
playlist.AuthorUri = new Uri($"https://open.spotify.com/user/{list.Artists.First().Uri}");
playlist.AuthorName = list.Artists.First().Name; playlist.AuthorName = list.Artists.First().Name;
playlist.Followers = list.Popularity; playlist.Followers = list.Popularity;
playlist.Url = new Uri($"https://open.spotify.com/album/{playlist.Identifier}"); playlist.Url = new Uri(list.Uri);
return playlist; return playlist;
} }
public async Task<LavalinkTrack> PopulateTrackAsync(LavalinkTrack track, FullTrack spotifyFullTrack) public async Task<LavalinkTrack> PopulateTrackAsync(LavalinkTrack track)
{ {
FullTrackContext context = (FullTrackContext)track.Context; FullTrackContext context = (FullTrackContext)track.Context;
if (context.SpotifyIdentifier == null) if (context.SpotifyIdentifier == null)
return track; return track;
FullTrack spotifyTrack = spotifyFullTrack; var spotifyTrack = await this.Tracks.Get(context.SpotifyIdentifier);
if (spotifyTrack == null)
spotifyTrack = await Tracks.Get(context.SpotifyIdentifier);
context.SpotifyAlbum = spotifyTrack.Album; context.SpotifyAlbum = spotifyTrack.Album;
context.SpotifyArtists = spotifyTrack.Artists; context.SpotifyArtists = spotifyTrack.Artists;
context.SpotifyPopularity = spotifyTrack.Popularity; context.SpotifyPopularity = spotifyTrack.Popularity;
context.SpotifyUri = new Uri($"https://open.spotify.com/track/{context.SpotifyIdentifier}"); context.SpotifyUri = new Uri(spotifyTrack.Uri);
track.Context = context; track.Context = context;
return track; return track;

51
TomatenMusicCore/Services/YoutubeService.cs
View File

@ -12,8 +12,6 @@ using static TomatenMusic.TomatenMusicBot;
using Lavalink4NET.Player; using Lavalink4NET.Player;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Lavalink4NET; using Lavalink4NET;
using TomatenMusicCore.Music;
using TomatenMusicCore.Music.Entities;
namespace TomatenMusic.Services namespace TomatenMusic.Services
{ {
@ -39,20 +37,13 @@ namespace TomatenMusic.Services
if (channel.Statistics.SubscriberCount != null) if (channel.Statistics.SubscriberCount != null)
context.YoutubeAuthorSubs = (ulong) channel.Statistics.SubscriberCount; context.YoutubeAuthorSubs = (ulong) channel.Statistics.SubscriberCount;
context.YoutubeAuthorThumbnail = new Uri(channel.Snippet.Thumbnails.Default__.Url); context.YoutubeAuthorThumbnail = new Uri(channel.Snippet.Thumbnails.High.Url);
context.YoutubeAuthorUri = new Uri($"https://www.youtube.com/channel/{channel.Id}"); context.YoutubeAuthorUri = new Uri($"https://www.youtube.com/channel/{channel.Id}");
string desc = video.Snippet.Description; context.YoutubeDescription = video.Snippet.Description;
context.YoutubeDescription = desc.Substring(0, Math.Min(desc.Length, 1024)) + (desc.Length > 1020 ? "..." : " ");
if (video.Statistics.LikeCount != null) if (video.Statistics.LikeCount != null)
context.YoutubeLikes = (ulong) video.Statistics.LikeCount; context.YoutubeLikes = (ulong) video.Statistics.LikeCount;
context.YoutubeTags = video.Snippet.Tags; context.YoutubeTags = video.Snippet.Tags;
context.YoutubeThumbnail = new Uri(video.Snippet.Thumbnails.High.Url);
try
{
context.YoutubeThumbnail = new Uri(video.Snippet.Thumbnails.High.Url);
}catch (Exception ex) { }
context.YoutubeUploadDate = (DateTime)video.Snippet.PublishedAt; context.YoutubeUploadDate = (DateTime)video.Snippet.PublishedAt;
context.YoutubeViews = (ulong)video.Statistics.ViewCount; context.YoutubeViews = (ulong)video.Statistics.ViewCount;
context.YoutubeCommentCount = video.Statistics.CommentCount; context.YoutubeCommentCount = video.Statistics.CommentCount;
@ -60,7 +51,7 @@ namespace TomatenMusic.Services
return track; return track;
} }
public async Task<List<LavalinkTrack>> PopulateTrackListAsync(IEnumerable<LavalinkTrack> tracks) public async Task<List<LavalinkTrack>> PopulateMultiTrackListAsync(IEnumerable<LavalinkTrack> tracks)
{ {
List<LavalinkTrack> newTracks = new List<LavalinkTrack>(); List<LavalinkTrack> newTracks = new List<LavalinkTrack>();
foreach (var track in tracks) foreach (var track in tracks)
@ -68,26 +59,19 @@ namespace TomatenMusic.Services
return newTracks; return newTracks;
} }
public async Task<ILavalinkPlaylist> PopulatePlaylistAsync(YoutubePlaylist playlist) public async Task<LavalinkPlaylist> PopulatePlaylistAsync(YoutubePlaylist playlist)
{ {
var list = await GetPlaylistAsync(playlist.Identifier); var list = await GetPlaylistAsync(playlist.Identifier);
var channel = await GetChannelAsync(list.Snippet.ChannelId); var channel = await GetChannelAsync(list.Snippet.ChannelId);
string desc = list.Snippet.Description; string desc = list.Snippet.Description;
playlist.Description = desc.Substring(0, Math.Min(desc.Length, 1024)) + (desc.Length > 1020 ? "..." : " "); playlist.Description = desc.Substring(0, Math.Min(desc.Length, 4092)) + (desc.Length > 4092 ? "..." : " ");
if (playlist.Description.Length < 2) playlist.Thumbnail = new Uri(list.Snippet.Thumbnails.High.Url);
playlist.Description = "None";
try
{
playlist.Thumbnail = new Uri(list.Snippet.Thumbnails.Maxres.Url);
}catch (Exception ex) { }
playlist.AuthorName = channel.Snippet.Title;
playlist.CreationTime = (DateTime)list.Snippet.PublishedAt; playlist.CreationTime = (DateTime)list.Snippet.PublishedAt;
playlist.YoutubeItem = list; playlist.YoutubeItem = list;
playlist.AuthorThumbnail = new Uri(channel.Snippet.Thumbnails.Default__.Url); playlist.AuthorThumbnail = new Uri(channel.Snippet.Thumbnails.High.Url);
playlist.AuthorUri = new Uri($"https://www.youtube.com/channels/{channel.Id}"); playlist.AuthorUri = new Uri($"https://www.youtube.com/playlist?list={playlist.Identifier}");
return playlist; return playlist;
} }
@ -117,28 +101,21 @@ namespace TomatenMusic.Services
return response.Items.First(); return response.Items.First();
} }
public async Task<IEnumerable<SearchResult>> GetRelatedVideosAsync(string id) public async Task<SearchResult> GetRelatedVideoAsync(string id)
{ {
var search = Service.Search.List("snippet"); var search = Service.Search.List("snippet");
search.RelatedToVideoId = id; search.RelatedToVideoId = id;
search.Type = "video"; search.Type = "video";
var response = await search.ExecuteAsync(); var response = await search.ExecuteAsync();
return response.Items.Where(x => x.Snippet != null); return response.Items.First(s => s.Snippet != null);
} }
public async Task<TomatenMusicTrack> GetRelatedTrackAsync(string id, List<string> excludeIds) public async Task<LavalinkTrack> GetRelatedTrackAsync(string id)
{ {
var audioService = TomatenMusicBot.ServiceProvider.GetRequiredService<IAudioService>(); var audioService = TomatenMusicBot.ServiceProvider.GetRequiredService<IAudioService>();
var videos = await GetRelatedVideosAsync(id); var video = await GetRelatedVideoAsync(id);
SearchResult video = null; var loadResult = await audioService.GetTrackAsync($"https://youtu.be/{video.Id.VideoId}");
foreach (var vid in videos)
video = videos.First(x => !excludeIds.Contains(x.Id.VideoId));
if (video == null)
video = videos.FirstOrDefault();
var loadResult = new TomatenMusicTrack(await audioService.GetTrackAsync($"https://youtu.be/{video.Id.VideoId}"));
if (loadResult == null) if (loadResult == null)
throw new Exception("An Error occurred while processing the Request"); throw new Exception("An Error occurred while processing the Request");

23
TomatenMusicCore/TomatenMusicBot.cs
View File

@ -4,6 +4,7 @@ using Microsoft.Extensions.Logging;
using DSharpPlus; using DSharpPlus;
using DSharpPlus.EventArgs; using DSharpPlus.EventArgs;
using DSharpPlus.Entities; using DSharpPlus.Entities;
using DSharpPlus.Net;
using System.Linq; using System.Linq;
using DSharpPlus.SlashCommands; using DSharpPlus.SlashCommands;
using DSharpPlus.SlashCommands.EventArgs; using DSharpPlus.SlashCommands.EventArgs;
@ -76,6 +77,7 @@ namespace TomatenMusic
}) })
// Lavalink
.AddSingleton<IDiscordClientWrapper, DiscordShardedClientWrapper>() .AddSingleton<IDiscordClientWrapper, DiscordShardedClientWrapper>()
.AddSingleton<IAudioService, LavalinkNode>() .AddSingleton<IAudioService, LavalinkNode>()
.AddSingleton(new InactivityTrackingOptions .AddSingleton(new InactivityTrackingOptions
@ -87,9 +89,9 @@ namespace TomatenMusic
.AddSingleton( .AddSingleton(
new LavalinkNodeOptions new LavalinkNodeOptions
{ {
RestUri = "http://127.0.0.1:2333", RestUri = "http://116.202.92.16:2333",
Password = config.LavaLinkPassword, Password = config.LavaLinkPassword,
WebSocketUri = "ws://127.0.0.1:2333", WebSocketUri = "ws://116.202.92.16:2333",
AllowResuming = true AllowResuming = true
}) })
@ -99,8 +101,7 @@ namespace TomatenMusic
.AddSingleton<YoutubeService>() .AddSingleton<YoutubeService>()
.AddSingleton<LyricsOptions>() .AddSingleton<LyricsOptions>()
.AddSingleton<LyricsService>() .AddSingleton<LyricsService>()
.AddSingleton( .AddSingleton(SpotifyClientConfig.CreateDefault().WithAuthenticator(new ClientCredentialsAuthenticator(config.SpotifyClientId, config.SpotifyClientSecret))))
SpotifyClientConfig.CreateDefault().WithAuthenticator(new ClientCredentialsAuthenticator(config.SpotifyClientId, config.SpotifyClientSecret))))
.Build(); .Build();
ServiceProvider = _host.Services; ServiceProvider = _host.Services;
@ -113,6 +114,7 @@ namespace TomatenMusic
{ {
await BuildServiceProvider(); await BuildServiceProvider();
//_ = _host.StartAsync();
_host.Start(); _host.Start();
var client = ServiceProvider.GetRequiredService<DiscordShardedClient>(); var client = ServiceProvider.GetRequiredService<DiscordShardedClient>();
@ -125,13 +127,8 @@ namespace TomatenMusic
Services = ServiceProvider Services = ServiceProvider
}); });
//slash.RegisterCommands<MusicCommands>(888493810554900491); slash.RegisterCommands<MusicCommands>(888493810554900491);
//slash.RegisterCommands<PlayQueueGroup>(888493810554900491); slash.RegisterCommands<PlayCommandGroup>(888493810554900491);
//slash.RegisterCommands<PlayNowGroup>(888493810554900491);
slash.RegisterCommands<MusicCommands>();
slash.RegisterCommands<PlayQueueGroup>();
slash.RegisterCommands<PlayNowGroup>();
await client.StartAsync(); await client.StartAsync();
client.Ready += Client_Ready; client.Ready += Client_Ready;
@ -146,13 +143,11 @@ namespace TomatenMusic
private Task Client_Ready(DiscordClient sender, ReadyEventArgs e) private Task Client_Ready(DiscordClient sender, ReadyEventArgs e)
{ {
var logger = ServiceProvider.GetRequiredService<ILogger<TomatenMusicBot>>();
var slash = sender.GetSlashCommands(); var slash = sender.GetSlashCommands();
slash.SlashCommandInvoked += Slash_SlashCommandInvoked; slash.SlashCommandInvoked += Slash_SlashCommandInvoked;
slash.SlashCommandErrored += Slash_SlashCommandErrored; slash.SlashCommandErrored += Slash_SlashCommandErrored;
sender.UpdateStatusAsync(new DiscordActivity($"/ commands! Shard {sender.ShardId}", ActivityType.Watching)); sender.UpdateStatusAsync(new DiscordActivity($"/ commands! Shard {sender.ShardId}", ActivityType.Watching));
return Task.CompletedTask; return Task.CompletedTask;
} }
@ -187,7 +182,7 @@ namespace TomatenMusic
if (e.Exception is NotFoundException) if (e.Exception is NotFoundException)
logger.LogDebug($"{ ((NotFoundException)e.Exception).JsonMessage }"); logger.LogDebug($"{ ((NotFoundException)e.Exception).JsonMessage }");
if (e.Exception is BadRequestException) if (e.Exception is BadRequestException)
logger.LogInformation($"{ ((BadRequestException)e.Exception).Errors }"); logger.LogDebug($"{ ((BadRequestException)e.Exception).JsonMessage }");
return Task.CompletedTask; return Task.CompletedTask;
} }

18
TomatenMusicCore/TomatenMusicCore.csproj
View File

@ -1,23 +1,27 @@
<Project Sdk="Microsoft.NET.Sdk"> <Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup> <PropertyGroup>
<TargetFramework>net6.0</TargetFramework> <TargetFramework>net6.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable> <Nullable>enable</Nullable>
<RestoreAdditionalProjectSources>
https://api.nuget.org/v3/index.json;
https://nuget.emzi0767.com/api/v3/index.json
</RestoreAdditionalProjectSources>
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="DSharpPlus" Version="4.2.0-nightly-01107" /> <PackageReference Include="DSharpPlus" Version="4.2.0-nightly-01088" />
<PackageReference Include="DSharpPlus.Interactivity" Version="4.2.0-nightly-01107" /> <PackageReference Include="DSharpPlus.Interactivity" Version="4.2.0-nightly-01084" />
<PackageReference Include="DSharpPlus.SlashCommands" Version="4.2.0-nightly-01107" /> <PackageReference Include="DSharpPlus.SlashCommands" Version="4.2.0-nightly-01088" />
<PackageReference Include="Google.Apis.YouTube.v3" Version="1.57.0.2637" /> <PackageReference Include="Google.Apis.YouTube.v3" Version="1.56.0.2617" />
<PackageReference Include="HtmlAgilityPack" Version="1.11.42" /> <PackageReference Include="HtmlAgilityPack" Version="1.11.42" />
<PackageReference Include="Lavalink4NET" Version="2.1.1" /> <PackageReference Include="Lavalink4NET" Version="2.1.1" />
<PackageReference Include="Lavalink4NET.DSharpPlus" Version="2.1.1" /> <PackageReference Include="Lavalink4NET.DSharpPlus" Version="2.1.1" />
<PackageReference Include="Lavalink4NET.Logging.Microsoft" Version="2.1.1-preview.6" /> <PackageReference Include="Lavalink4NET.Logging.Microsoft" Version="2.1.1-preview.5" />
<PackageReference Include="Lavalink4NET.MemoryCache" Version="2.1.1" /> <PackageReference Include="Lavalink4NET.MemoryCache" Version="2.1.1" />
<PackageReference Include="Microsoft.AspNet.WebApi.OwinSelfHost" Version="5.2.7" /> <PackageReference Include="Microsoft.AspNet.WebApi.OwinSelfHost" Version="5.2.7" />
<PackageReference Include="Microsoft.Extensions.Hosting" Version="7.0.0-preview.2.22152.2" /> <PackageReference Include="Microsoft.Extensions.Hosting" Version="6.0.1" />
<PackageReference Include="SpotifyAPI.Web" Version="6.2.2" /> <PackageReference Include="SpotifyAPI.Web" Version="6.2.2" />
<PackageReference Include="SpotifyAPI.Web.Auth" Version="6.2.2" /> <PackageReference Include="SpotifyAPI.Web.Auth" Version="6.2.2" />
</ItemGroup> </ItemGroup>

155
TomatenMusicCore/Util/Common.cs
View File

@ -19,46 +19,32 @@ namespace TomatenMusic.Util
{ {
public static DiscordEmbed AsEmbed(LavalinkTrack track, LoopType loopType, int position = -1) public static DiscordEmbed AsEmbed(LavalinkTrack track, LoopType loopType, int position = -1)
{
DiscordEmbedBuilder builder = new DiscordEmbedBuilder(AsEmbed(track, position));
builder.AddField("Current Queue Loop", loopType.ToString(), true);
return builder;
}
public static DiscordEmbed AsEmbed(LavalinkTrack track, int position = -1)
{ {
FullTrackContext context = (FullTrackContext)track.Context; FullTrackContext context = (FullTrackContext)track.Context;
DiscordEmbedBuilder builder = new DiscordEmbedBuilder() DiscordEmbedBuilder builder = new DiscordEmbedBuilder()
.WithTitle(track.Title) .WithTitle(track.Title)
.WithUrl(track.Source)
.WithDescription(context.YoutubeDescription)
.AddField("Length", Common.GetTimestamp(track.Duration), true); .AddField("Length", Common.GetTimestamp(track.Duration), true);
if (context.YoutubeThumbnail != null)
builder.WithImageUrl(context.YoutubeThumbnail);
if (context.IsFile) if (context.IsFile)
{ {
builder.WithAuthor(track.Author); builder.WithAuthor(track.Author);
builder.WithUrl(track.Source);
} }
else else
builder builder
.WithAuthor(track.Author, context.YoutubeAuthorUri.ToString(), context.YoutubeAuthorThumbnail.ToString()) .WithAuthor(track.Author, context.YoutubeAuthorUri.ToString(), context.YoutubeAuthorThumbnail.ToString())
.WithUrl(track.Source); .WithUrl(context.YoutubeUri)
.WithImageUrl(context.YoutubeThumbnail)
.WithDescription(context.YoutubeDescription);
if (position != -1) if (position != -1)
{ {
builder.AddField("Queue Position", (position == 0 ? "Now Playing" : position.ToString()), true); builder.AddField("Position", (position == 0 ? "Now Playing" : position.ToString()), true);
} }
builder.AddField("Current Queue Loop", loopType.ToString(), true);
if (!context.IsFile) if (!context.IsFile)
{ {
if (track.Position.Seconds > 0)
builder.AddField("Starting Position", GetTimestamp(track.Position), true);
builder.AddField("Views", $"{context.YoutubeViews:N0} Views", true); builder.AddField("Views", $"{context.YoutubeViews:N0} Views", true);
builder.AddField("Rating", $"{context.YoutubeLikes:N0} 👍", true); builder.AddField("Rating", $"{context.YoutubeLikes:N0} 👍", true);
builder.AddField("Upload Date", $"{context.YoutubeUploadDate.ToString("dd. MMMM, yyyy")}", true); builder.AddField("Upload Date", $"{context.YoutubeUploadDate.ToString("dd. MMMM, yyyy")}", true);
@ -69,7 +55,44 @@ namespace TomatenMusic.Util
return builder; return builder;
} }
public static DiscordEmbed AsEmbed(ILavalinkPlaylist playlist) public static DiscordEmbed AsEmbed(LavalinkTrack track, int position = -1)
{
FullTrackContext context = (FullTrackContext)track.Context;
DiscordEmbedBuilder builder = new DiscordEmbedBuilder()
.WithTitle(track.Title)
.WithUrl(context.YoutubeUri)
.WithImageUrl(context.YoutubeThumbnail)
.WithDescription(context.YoutubeDescription)
.AddField("Length", Common.GetTimestamp(track.Duration), true);
if (context.IsFile)
{
builder.WithAuthor(track.Author);
}
else
builder
.WithAuthor(track.Author, context.YoutubeAuthorUri.ToString(), context.YoutubeAuthorThumbnail.ToString())
.WithUrl(context.YoutubeUri);
if (position != -1)
{
builder.AddField("Position", (position == 0 ? "Now Playing" : position.ToString()), true);
}
if (!context.IsFile)
{
builder.AddField("Views", $"{context.YoutubeViews:N0} Views", true);
builder.AddField("Rating", $"{context.YoutubeLikes:N0} 👍", true);
builder.AddField("Upload Date", $"{context.YoutubeUploadDate.ToString("dd. MMMM, yyyy")}", true);
builder.AddField("Comments", context.YoutubeCommentCount == null ? "Comments Disabled" : $"{context.YoutubeCommentCount:N0} Comments", true);
builder.AddField("Channel Subscriptions", $"{context.YoutubeAuthorSubs:N0} Subscribers", true);
}
return builder;
}
public static DiscordEmbed AsEmbed(LavalinkPlaylist playlist)
{ {
DiscordEmbedBuilder builder = new DiscordEmbedBuilder(); DiscordEmbedBuilder builder = new DiscordEmbedBuilder();
@ -77,43 +100,39 @@ namespace TomatenMusic.Util
if (playlist is YoutubePlaylist) if (playlist is YoutubePlaylist)
{ {
YoutubePlaylist youtubePlaylist = (YoutubePlaylist)playlist; YoutubePlaylist youtubePlaylist = (YoutubePlaylist)playlist;
Console.WriteLine($"{playlist.AuthorName}, {playlist.AuthorUri.ToString()}, {playlist.AuthorThumbnail.ToString()}"); builder
builder.WithAuthor(playlist.AuthorName, playlist.AuthorUri.ToString(), youtubePlaylist.AuthorThumbnail.ToString()); .WithAuthor(playlist.AuthorName, playlist.AuthorUri.ToString(), youtubePlaylist.AuthorThumbnail.ToString())
builder.WithTitle(playlist.Title); .WithTitle(playlist.Name)
builder.WithUrl(playlist.Url); .WithUrl(playlist.Url)
builder.WithDescription(TrackListString(playlist.Tracks, 4000)); .WithDescription(playlist.Description)
builder.WithImageUrl(youtubePlaylist.Thumbnail); .WithImageUrl(youtubePlaylist.Thumbnail)
builder.AddField("Description", playlist.Description, false); .AddField("Tracks", TrackListString(playlist.Tracks), false)
builder.AddField("Track Count", $"{playlist.Tracks.Count()} Tracks", true); .AddField("Track Count", $"{playlist.Tracks.Count()} Tracks", true)
builder.AddField("Length", $"{Common.GetTimestamp(playlist.GetLength())}", true); .AddField("Length", $"{Common.GetTimestamp(playlist.GetLength())}", true)
builder.AddField("Create Date", $"{youtubePlaylist.CreationTime:dd. MMMM, yyyy}", true); .AddField("Create Date", $"{youtubePlaylist.CreationTime:dd. MMMM, yyyy}", true);
}else if (playlist is SpotifyPlaylist) }else if (playlist is SpotifyPlaylist)
{ {
SpotifyPlaylist spotifyPlaylist = (SpotifyPlaylist)playlist; SpotifyPlaylist spotifyPlaylist = (SpotifyPlaylist)playlist;
builder
builder.WithTitle(playlist.Title); .WithAuthor(playlist.AuthorName, playlist.AuthorUri.ToString(), spotifyPlaylist.AuthorThumbnail.ToString())
builder.WithUrl(playlist.Url); .WithTitle(playlist.Name)
builder.WithDescription(TrackListString(playlist.Tracks, 4000)); .WithUrl(playlist.Url)
builder.AddField("Description", playlist.Description, false); .WithDescription(playlist.Description)
builder.AddField("Track Count", $"{playlist.Tracks.Count()} Tracks", true); .AddField("Tracks", TrackListString(playlist.Tracks), false)
builder.AddField("Length", $"{Common.GetTimestamp(playlist.GetLength())}", true); .AddField("Track Count", $"{playlist.Tracks.Count()} Tracks", true)
builder.AddField("Spotify Followers", $"{spotifyPlaylist.Followers:N0}", true); .AddField("Length", $"{Common.GetTimestamp(playlist.GetLength())}", true)
if (spotifyPlaylist.AuthorThumbnail != null) .AddField("Spotify Followers", $"{spotifyPlaylist.Followers:N0}", true);
{
builder.WithAuthor(playlist.AuthorName, playlist.AuthorUri.ToString(), spotifyPlaylist.AuthorThumbnail.ToString());
}else
builder.WithAuthor(playlist.AuthorName, playlist.AuthorUri.ToString());
} }
return builder.Build(); return builder;
} }
public static DiscordEmbed GetQueueEmbed(GuildPlayer player) public static DiscordEmbed GetQueueEmbed(GuildPlayer player)
{ {
DiscordEmbedBuilder builder = new DiscordEmbedBuilder(); DiscordEmbedBuilder builder = new DiscordEmbedBuilder();
builder.WithDescription(TrackListString(player.PlayerQueue.Queue, 4000)); builder.WithDescription(TrackListString(player.PlayerQueue.Queue));
builder.WithTitle("Current Queue"); builder.WithTitle("Current Queue");
builder.WithAuthor($"{player.PlayerQueue.Queue.Count} Songs"); builder.WithAuthor($"{player.PlayerQueue.Queue.Count} Songs");
@ -127,37 +146,29 @@ namespace TomatenMusic.Util
builder.AddField("Length", GetTimestamp(timeSpan), true); builder.AddField("Length", GetTimestamp(timeSpan), true);
builder.AddField("Loop Type", player.PlayerQueue.LoopType.ToString(), true); builder.AddField("Loop Type", player.PlayerQueue.LoopType.ToString(), true);
builder.AddField("Autoplay", player.Autoplay ? "✅" : "❌", true); builder.AddField("Autoplay", player.Autoplay ? "✅" : "❌", true);
if (player.PlayerQueue.CurrentPlaylist != null)
builder.AddField("Current Playlist", $"[{player.PlayerQueue.CurrentPlaylist.Title}]({player.PlayerQueue.CurrentPlaylist.Url})", true);
if (player.PlayerQueue.PlayedTracks.Any()) if (player.PlayerQueue.PlayedTracks.Any())
builder.AddField("History", TrackListString(player.PlayerQueue.PlayedTracks, 1000), true); builder.AddField("History", TrackListString(player.PlayerQueue.PlayedTracks), true);
if (player.PlayerQueue.CurrentPlaylist != null)
builder.AddField("Current Playlist", $"[{player.PlayerQueue.CurrentPlaylist.Name}]({player.PlayerQueue.CurrentPlaylist.Url})", true);
return builder; return builder;
} }
public static string TrackListString(IEnumerable<LavalinkTrack> tracks, int maxCharacters) public static string TrackListString(IEnumerable<LavalinkTrack> tracks)
{ {
StringBuilder builder = new StringBuilder(); StringBuilder builder = new StringBuilder();
string lastString = " ";
int count = 1; int count = 1;
foreach (LavalinkTrack track in tracks) foreach (LavalinkTrack track in tracks)
{ {
if (builder.ToString().Length > maxCharacters) FullTrackContext context = (FullTrackContext)track.Context;
if (count > 15)
{ {
builder = new StringBuilder(lastString); builder.Append(String.Format("***And {0} more...***", tracks.Count() - 15));
builder.Append(String.Format("***And {0} more...***", tracks.Count() - count));
break; break;
} }
FullTrackContext context = (FullTrackContext)track.Context; builder.Append(count).Append(": ").Append($"[{track.Title}]({context.YoutubeUri})").Append(" [").Append(Common.GetTimestamp(track.Duration)).Append("] | ");
builder.Append($"[{track.Author}]({context.YoutubeAuthorUri})").Append("\n\n");
lastString = builder.ToString();
builder.Append(count).Append(": ").Append($"[{track.Title}]({track.Source})").Append(" [").Append(Common.GetTimestamp(track.Duration)).Append("] | ");
builder.Append($"[{track.Author}]({context.YoutubeAuthorUri})");
if (track.Position.Seconds != 0)
builder.Append($" | 🕑");
builder.Append("\n\n");
count++; count++;
} }
builder.Append(" "); builder.Append(" ");
@ -236,29 +247,19 @@ namespace TomatenMusic.Util
DiscordEmbedBuilder builder = new DiscordEmbedBuilder(); DiscordEmbedBuilder builder = new DiscordEmbedBuilder();
LavalinkTrack track = player.CurrentTrack; LavalinkTrack track = player.CurrentTrack;
if (track == null)
{
builder.WithColor(DiscordColor.Red);
builder.WithTitle("Nothing Playing");
builder.WithImageUrl("https://media.tomatentum.net/TMBanner.gif");
return builder;
}
FullTrackContext context = (FullTrackContext)track.Context; FullTrackContext context = (FullTrackContext)track.Context;
string progressBar = $"|{ProgressBar((int)player.Position.Position.TotalSeconds, (int)track.Duration.TotalSeconds)}|\n [{Common.GetTimestamp(player.Position.Position)}/{Common.GetTimestamp(track.Duration)}]"; string progressBar = $"|{ProgressBar((int)player.Position.Position.TotalSeconds, (int)track.Duration.TotalSeconds)}|\n [{Common.GetTimestamp(player.Position.Position)}/{Common.GetTimestamp(track.Duration)}]";
builder.WithAuthor(track.Author); builder.WithAuthor(track.Author, context.YoutubeAuthorUri.ToString(), context.YoutubeAuthorThumbnail.ToString());
builder.WithTitle(track.Title); builder.WithTitle(track.Title);
builder.WithUrl(track.Source); builder.WithUrl(context.YoutubeUri);
builder.WithColor(player.State == PlayerState.Paused ? DiscordColor.Orange : DiscordColor.Green); builder.WithImageUrl(context.YoutubeThumbnail);
builder.AddField("Length", Common.GetTimestamp(track.Duration), true); builder.AddField("Length", Common.GetTimestamp(track.Duration), true);
builder.AddField("Loop", player.PlayerQueue.LoopType.ToString(), true); builder.AddField("Loop", player.PlayerQueue.LoopType.ToString(), true);
builder.AddField("Progress", progressBar, true); builder.AddField("Progress", progressBar, true);
if (!context.IsFile) if (!context.IsFile)
{ {
builder.WithAuthor(track.Author, context.YoutubeAuthorUri.ToString(), context.YoutubeAuthorThumbnail.ToString());
builder.WithImageUrl(context.YoutubeThumbnail);
builder.AddField("Views", $"{context.YoutubeViews:N0} Views", true); builder.AddField("Views", $"{context.YoutubeViews:N0} Views", true);
builder.AddField("Rating", $"{context.YoutubeLikes:N0} 👍", true); builder.AddField("Rating", $"{context.YoutubeLikes:N0} 👍", true);
builder.AddField("Upload Date", $"{context.YoutubeUploadDate.ToString("dd. MMMM, yyyy")}", true); builder.AddField("Upload Date", $"{context.YoutubeUploadDate.ToString("dd. MMMM, yyyy")}", true);