using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Net.Sockets;
using System.Reflection;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;
using System.Runtime.Versioning;
using System.Security;
using System.Security.Permissions;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using BepInEx;
using BepInEx.Configuration;
using BepInEx.Logging;
using DG.Tweening;
using DG.Tweening.Core;
using DG.Tweening.Plugins.Options;
using HarmonyLib;
using Microsoft.CodeAnalysis;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using TMPro;
using UnityEngine;
using UnityEngine.UI;
[assembly: CompilationRelaxations(8)]
[assembly: RuntimeCompatibility(WrapNonExceptionThrows = true)]
[assembly: Debuggable(DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints)]
[assembly: TargetFramework(".NETStandard,Version=v2.1", FrameworkDisplayName = ".NET Standard 2.1")]
[assembly: AssemblyCompany("WKMusic")]
[assembly: AssemblyConfiguration("Release")]
[assembly: AssemblyFileVersion("1.0.0.0")]
[assembly: AssemblyInformationalVersion("1.0.0+57e91829fcde28c0bc52c8f4a67e18ff9a2b5a5b")]
[assembly: AssemblyProduct("WKMusic")]
[assembly: AssemblyTitle("WKMusic")]
[assembly: SecurityPermission(SecurityAction.RequestMinimum, SkipVerification = true)]
[assembly: AssemblyVersion("1.0.0.0")]
[module: UnverifiableCode]
[module: RefSafetyRules(11)]
namespace Microsoft.CodeAnalysis
{
[CompilerGenerated]
[Microsoft.CodeAnalysis.Embedded]
internal sealed class EmbeddedAttribute : Attribute
{
}
}
namespace System.Runtime.CompilerServices
{
[CompilerGenerated]
[Microsoft.CodeAnalysis.Embedded]
[AttributeUsage(AttributeTargets.Class | AttributeTargets.Property | AttributeTargets.Field | AttributeTargets.Event | AttributeTargets.Parameter | AttributeTargets.ReturnValue | AttributeTargets.GenericParameter, AllowMultiple = false, Inherited = false)]
internal sealed class NullableAttribute : Attribute
{
public readonly byte[] NullableFlags;
public NullableAttribute(byte P_0)
{
NullableFlags = new byte[1] { P_0 };
}
public NullableAttribute(byte[] P_0)
{
NullableFlags = P_0;
}
}
[CompilerGenerated]
[Microsoft.CodeAnalysis.Embedded]
[AttributeUsage(AttributeTargets.Class | AttributeTargets.Struct | AttributeTargets.Method | AttributeTargets.Interface | AttributeTargets.Delegate, AllowMultiple = false, Inherited = false)]
internal sealed class NullableContextAttribute : Attribute
{
public readonly byte Flag;
public NullableContextAttribute(byte P_0)
{
Flag = P_0;
}
}
[CompilerGenerated]
[Microsoft.CodeAnalysis.Embedded]
[AttributeUsage(AttributeTargets.Module, AllowMultiple = false, Inherited = false)]
internal sealed class RefSafetyRulesAttribute : Attribute
{
public readonly int Version;
public RefSafetyRulesAttribute(int P_0)
{
Version = P_0;
}
}
internal static class IsExternalInit
{
}
}
namespace WKMusic
{
internal static class BrowserSetup
{
public sealed record SetupResult(string ClientId, string ClientSecret, SpotifyToken Token);
private sealed class FlowState
{
public string? CredId;
public string? CredSecret;
public string? OAuthState;
public Func<string, string, string, Task<SpotifyToken>>? ExchangeCode;
}
private static readonly HttpClient _http = new HttpClient();
private static readonly string[] Scopes = new string[3] { "user-read-playback-state", "user-modify-playback-state", "user-read-currently-playing" };
private const string BaseStyle = "\n<style>\n body{font-family:'Segoe UI',sans-serif;background:#121212;color:#fff;display:flex;\n align-items:center;justify-content:center;min-height:100vh;margin:0}\n .card{background:#1e1e1e;border-radius:12px;padding:36px 40px;width:400px;\n box-shadow:0 8px 32px #0008}\n h1{margin:0 0 6px;font-size:1.4rem}\n .sub{color:#888;font-size:.9rem;margin:0 0 24px}\n .err{color:#e74c3c;font-size:.85rem;margin:0 0 14px}\n label{display:block;font-size:.85rem;color:#aaa;margin-bottom:4px}\n input{width:100%;box-sizing:border-box;padding:10px 12px;border-radius:6px;\n border:1px solid #333;background:#2a2a2a;color:#fff;font-size:.95rem;margin-bottom:16px}\n input:focus{outline:none;border-color:#1db954}\n button{width:100%;padding:11px;background:#1db954;color:#000;font-weight:700;\n border:none;border-radius:6px;cursor:pointer;font-size:1rem}\n button:hover{background:#1ed760}\n .hint{font-size:.8rem;color:#666;margin-top:18px;line-height:1.6}\n a{color:#1db954}\n code{background:#2a2a2a;padding:1px 5px;border-radius:3px;font-size:.78rem}\n</style>";
public static async Task<SetupResult?> RunAsync(string workerUrl, Func<string, string, string, Task<SpotifyToken>> exchangeCode, string initialClientId = "", string initialClientSecret = "", CancellationToken ct = default(CancellationToken))
{
int port = FindFreePort();
string redirectUri = workerUrl + "/callback";
string credId = NullIfEmpty(initialClientId);
string credSecret = NullIfEmpty(initialClientSecret);
TaskCompletionSource<SetupResult?> tcs = new TaskCompletionSource<SetupResult>();
ct.Register(delegate
{
tcs.TrySetResult(null);
});
HttpListener listener = new HttpListener();
listener.Prefixes.Add($"http://localhost:{port}/");
listener.Start();
FlowState state = new FlowState
{
CredId = credId,
CredSecret = credSecret,
ExchangeCode = exchangeCode
};
Task.Run(async delegate
{
try
{
while (!tcs.Task.IsCompleted)
{
HttpListenerContext ctx;
try
{
ctx = await listener.GetContextAsync();
}
catch
{
break;
}
Task.Run(() => Handle(ctx, port, redirectUri, state, tcs));
}
}
catch
{
}
finally
{
listener.Stop();
}
});
OpenBrowser($"http://localhost:{port}/");
Plugin.Logger.LogInfo((object)$"WKMusic: setup → http://localhost:{port}/");
return await tcs.Task;
}
private static async Task Handle(HttpListenerContext ctx, int port, string redirectUri, FlowState s, TaskCompletionSource<SetupResult?> tcs)
{
HttpListenerRequest request = ctx.Request;
HttpListenerResponse res = ctx.Response;
string absolutePath = request.Url.AbsolutePath;
try
{
if (request.HttpMethod == "GET" && absolutePath == "/")
{
if (s.CredId == null || s.CredSecret == null)
{
await WriteHtml(res, PageCredentials());
return;
}
s.OAuthState = $"{Guid.NewGuid():N}:{port}";
Redirect(res, BuildAuthUrl(s.CredId, s.OAuthState, redirectUri));
}
else if (request.HttpMethod == "POST" && absolutePath == "/submit")
{
Dictionary<string, string> obj = await ReadForm(request);
obj.TryGetValue("clientId", out var id2);
obj.TryGetValue("clientSecret", out var secret2);
id2 = id2?.Trim() ?? "";
secret2 = secret2?.Trim() ?? "";
string text = ValidateCredentials(id2, secret2);
if (text == null)
{
text = await VerifyWithSpotifyAsync(id2, secret2);
}
string text2 = text;
if (text2 != null)
{
await WriteHtml(res, PageCredentials(id2, text2));
return;
}
s.CredId = id2;
s.CredSecret = secret2;
s.OAuthState = $"{Guid.NewGuid():N}:{port}";
Redirect(res, BuildAuthUrl(s.CredId, s.OAuthState, redirectUri));
}
else if (request.HttpMethod == "GET" && absolutePath == "/callback")
{
NameValueCollection queryString = request.QueryString;
string text3 = queryString["code"];
string text4 = queryString["state"];
string text5 = queryString["error"];
if (!string.IsNullOrEmpty(text5))
{
await WriteHtml(res, PageError("Spotify error: " + text5));
tcs.TrySetResult(null);
}
else if (text4 != s.OAuthState)
{
await WriteHtml(res, PageError("State mismatch — please try again."));
tcs.TrySetResult(null);
}
else if (!string.IsNullOrEmpty(text3) && s.CredId != null && s.CredSecret != null && s.ExchangeCode != null)
{
try
{
SpotifyToken token = await s.ExchangeCode(s.CredId, s.CredSecret, text3);
await WriteHtml(res, PageSuccess());
tcs.TrySetResult(new SetupResult(s.CredId, s.CredSecret, token));
}
catch (Exception ex)
{
await WriteHtml(res, PageError("Token exchange failed: " + ex.Message));
tcs.TrySetResult(null);
}
}
else
{
await WriteHtml(res, PageError("Missing authorization code."));
tcs.TrySetResult(null);
}
}
else
{
res.StatusCode = 404;
res.Close();
}
}
catch (Exception ex2)
{
Plugin.Logger.LogWarning((object)("WKMusic: BrowserSetup handler error: " + ex2.Message));
try
{
res.Abort();
}
catch
{
}
}
}
private static string? ValidateCredentials(string id, string secret)
{
if (string.IsNullOrEmpty(id) || string.IsNullOrEmpty(secret))
{
return "Both fields are required.";
}
return null;
}
private static async Task<string?> VerifyWithSpotifyAsync(string clientId, string clientSecret)
{
_ = 1;
try
{
FormUrlEncodedContent content = new FormUrlEncodedContent(new Dictionary<string, string>
{
["grant_type"] = "client_credentials",
["client_id"] = clientId,
["client_secret"] = clientSecret
});
HttpResponseMessage httpResponseMessage = await _http.PostAsync("https://accounts.spotify.com/api/token", content);
if (httpResponseMessage.IsSuccessStatusCode)
{
return null;
}
JToken obj = JObject.Parse(await httpResponseMessage.Content.ReadAsStringAsync())["error"];
string text = ((obj != null) ? Extensions.Value<string>((IEnumerable<JToken>)obj) : null) ?? "";
return (text == "invalid_client") ? "Invalid Client ID or Client Secret — check your Spotify Dashboard." : ("Spotify returned: " + text);
}
catch
{
return null;
}
}
private static string BuildAuthUrl(string clientId, string state, string redirectUri)
{
string text = string.Join("&", new Dictionary<string, string>
{
["client_id"] = clientId,
["response_type"] = "code",
["redirect_uri"] = redirectUri,
["scope"] = string.Join(" ", Scopes),
["state"] = state
}.Select((KeyValuePair<string, string> kv) => Uri.EscapeDataString(kv.Key) + "=" + Uri.EscapeDataString(kv.Value)));
return "https://accounts.spotify.com/authorize?" + text;
}
private static async Task WriteHtml(HttpListenerResponse res, string html)
{
byte[] bytes = Encoding.UTF8.GetBytes(html);
res.ContentType = "text/html; charset=utf-8";
res.ContentLength64 = bytes.Length;
await res.OutputStream.WriteAsync(bytes, 0, bytes.Length);
res.Close();
}
private static void Redirect(HttpListenerResponse res, string url)
{
res.StatusCode = 302;
res.Headers["Location"] = url;
res.Close();
}
private static async Task<Dictionary<string, string>> ReadForm(HttpListenerRequest req)
{
using StreamReader reader = new StreamReader(req.InputStream, Encoding.UTF8);
string obj = await reader.ReadToEndAsync();
Dictionary<string, string> dictionary = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
string[] array = obj.Split('&');
foreach (string text in array)
{
int num = text.IndexOf('=');
if (num >= 0)
{
string key = Uri.UnescapeDataString(text.Substring(0, num).Replace('+', ' '));
string text2 = text;
int num2 = num + 1;
dictionary[key] = Uri.UnescapeDataString(text2.Substring(num2, text2.Length - num2).Replace('+', ' '));
}
}
return dictionary;
}
private static int FindFreePort()
{
TcpListener tcpListener = new TcpListener(IPAddress.Loopback, 0);
tcpListener.Start();
int port = ((IPEndPoint)tcpListener.LocalEndpoint).Port;
tcpListener.Stop();
return port;
}
private static void OpenBrowser(string url)
{
try
{
Process.Start(new ProcessStartInfo(url)
{
UseShellExecute = true
});
}
catch
{
}
}
private static string? NullIfEmpty(string s)
{
if (!string.IsNullOrWhiteSpace(s))
{
return s.Trim();
}
return null;
}
private static string PageCredentials(string initialId = "", string error = "")
{
return "<!DOCTYPE html>\n<html lang='en'><head><meta charset='utf-8'><title>WKMusic — Spotify Setup</title>\n<style>\n body{font-family:'Segoe UI',sans-serif;background:#121212;color:#fff;display:flex;\n align-items:center;justify-content:center;min-height:100vh;margin:0}\n .card{background:#1e1e1e;border-radius:12px;padding:36px 40px;width:400px;\n box-shadow:0 8px 32px #0008}\n h1{margin:0 0 6px;font-size:1.4rem}\n .sub{color:#888;font-size:.9rem;margin:0 0 24px}\n .err{color:#e74c3c;font-size:.85rem;margin:0 0 14px}\n label{display:block;font-size:.85rem;color:#aaa;margin-bottom:4px}\n input{width:100%;box-sizing:border-box;padding:10px 12px;border-radius:6px;\n border:1px solid #333;background:#2a2a2a;color:#fff;font-size:.95rem;margin-bottom:16px}\n input:focus{outline:none;border-color:#1db954}\n button{width:100%;padding:11px;background:#1db954;color:#000;font-weight:700;\n border:none;border-radius:6px;cursor:pointer;font-size:1rem}\n button:hover{background:#1ed760}\n .hint{font-size:.8rem;color:#666;margin-top:18px;line-height:1.6}\n a{color:#1db954}\n code{background:#2a2a2a;padding:1px 5px;border-radius:3px;font-size:.78rem}\n</style></head>\n<body><div class='card'>\n <h1>\ud83c\udfb5 WKMusic — Spotify Setup</h1>\n <p class='sub'>One-time setup. Token is saved locally.</p>\n " + (string.IsNullOrEmpty(error) ? "" : ("<p class='err'>" + error + "</p>")) + "\n <form method='POST' action='/submit'>\n <label>Client ID</label>\n <input name='clientId' value='" + initialId + "' placeholder='32-character hex string' autofocus required>\n <label>Client Secret</label>\n <input name='clientSecret' type='password' placeholder='32-character hex string' required>\n <button type='submit'>Connect Spotify →</button>\n </form>\n <p class='hint'>\n Get your credentials at <a href='https://developer.spotify.com/dashboard' target='_blank'>developer.spotify.com/dashboard</a>.<br>\n Add <code>https://wkmusic.eventeventeventevent1.workers.dev/callback</code> as a Redirect URI.\n </p>\n</div></body></html>";
}
private static string PageSuccess()
{
return "<!DOCTYPE html>\n<html lang='en'><head><meta charset='utf-8'><title>WKMusic — Connected</title>\n<style>\n body{font-family:'Segoe UI',sans-serif;background:#121212;color:#fff;display:flex;\n align-items:center;justify-content:center;min-height:100vh;margin:0}\n .card{background:#1e1e1e;border-radius:12px;padding:36px 40px;width:400px;\n box-shadow:0 8px 32px #0008}\n h1{margin:0 0 6px;font-size:1.4rem}\n .sub{color:#888;font-size:.9rem;margin:0 0 24px}\n .err{color:#e74c3c;font-size:.85rem;margin:0 0 14px}\n label{display:block;font-size:.85rem;color:#aaa;margin-bottom:4px}\n input{width:100%;box-sizing:border-box;padding:10px 12px;border-radius:6px;\n border:1px solid #333;background:#2a2a2a;color:#fff;font-size:.95rem;margin-bottom:16px}\n input:focus{outline:none;border-color:#1db954}\n button{width:100%;padding:11px;background:#1db954;color:#000;font-weight:700;\n border:none;border-radius:6px;cursor:pointer;font-size:1rem}\n button:hover{background:#1ed760}\n .hint{font-size:.8rem;color:#666;margin-top:18px;line-height:1.6}\n a{color:#1db954}\n code{background:#2a2a2a;padding:1px 5px;border-radius:3px;font-size:.78rem}\n</style>\n<style>.card{text-align:center} .icon{font-size:3rem;margin-bottom:12px} h1{color:#1db954}</style>\n</head><body><div class='card'>\n <div class='icon'>\ud83c\udfb5</div>\n <h1>Connected!</h1>\n <p class='sub' style='margin:0'>Spotify is linked. You can close this tab and return to the game.</p>\n</div></body></html>";
}
private static string PageError(string message)
{
return "<!DOCTYPE html>\n<html lang='en'><head><meta charset='utf-8'><title>WKMusic — Error</title>\n<style>\n body{font-family:'Segoe UI',sans-serif;background:#121212;color:#fff;display:flex;\n align-items:center;justify-content:center;min-height:100vh;margin:0}\n .card{background:#1e1e1e;border-radius:12px;padding:36px 40px;width:400px;\n box-shadow:0 8px 32px #0008}\n h1{margin:0 0 6px;font-size:1.4rem}\n .sub{color:#888;font-size:.9rem;margin:0 0 24px}\n .err{color:#e74c3c;font-size:.85rem;margin:0 0 14px}\n label{display:block;font-size:.85rem;color:#aaa;margin-bottom:4px}\n input{width:100%;box-sizing:border-box;padding:10px 12px;border-radius:6px;\n border:1px solid #333;background:#2a2a2a;color:#fff;font-size:.95rem;margin-bottom:16px}\n input:focus{outline:none;border-color:#1db954}\n button{width:100%;padding:11px;background:#1db954;color:#000;font-weight:700;\n border:none;border-radius:6px;cursor:pointer;font-size:1rem}\n button:hover{background:#1ed760}\n .hint{font-size:.8rem;color:#666;margin-top:18px;line-height:1.6}\n a{color:#1db954}\n code{background:#2a2a2a;padding:1px 5px;border-radius:3px;font-size:.78rem}\n</style>\n<style>.card{text-align:center} h1{color:#e74c3c}</style>\n</head><body><div class='card'>\n <h1>⚠ Error</h1>\n <p class='sub' style='margin:0'>" + message + "</p>\n</div></body></html>";
}
}
public class CredentialsStorage
{
public sealed record SpotifyCredentials(string ClientId, string ClientSecret);
private static class NativeMethods
{
[StructLayout(LayoutKind.Sequential, CharSet = CharSet.Unicode)]
public struct CREDENTIAL
{
public uint Flags;
public uint Type;
public string TargetName;
public string? Comment;
public long LastWritten;
public uint CredentialBlobSize;
public IntPtr CredentialBlob;
public uint Persist;
public uint AttributeCount;
public IntPtr Attributes;
public string? TargetAlias;
public string? UserName;
}
public const uint CRED_TYPE_GENERIC = 1u;
public const uint CRED_PERSIST_LOCAL_MACHINE = 2u;
[DllImport("advapi32.dll", CharSet = CharSet.Unicode, SetLastError = true)]
public static extern bool CredWrite(ref CREDENTIAL credential, uint flags);
[DllImport("advapi32.dll", CharSet = CharSet.Unicode, SetLastError = true)]
public static extern bool CredRead(string target, uint type, uint flags, out IntPtr credential);
[DllImport("advapi32.dll")]
public static extern void CredFree(IntPtr buffer);
[DllImport("advapi32.dll", CharSet = CharSet.Unicode)]
public static extern bool CredDelete(string target, uint type, uint flags);
}
private const string CredentialName = "WKMusic/SpotifyCredentials";
public void Save(string clientId, string clientSecret)
{
string s = JsonConvert.SerializeObject((object)new
{
ClientId = clientId,
ClientSecret = clientSecret
});
byte[] bytes = Encoding.UTF8.GetBytes(s);
NativeMethods.CREDENTIAL cREDENTIAL = default(NativeMethods.CREDENTIAL);
cREDENTIAL.Type = 1u;
cREDENTIAL.TargetName = "WKMusic/SpotifyCredentials";
cREDENTIAL.CredentialBlob = Marshal.AllocHGlobal(bytes.Length);
cREDENTIAL.CredentialBlobSize = (uint)bytes.Length;
cREDENTIAL.Persist = 2u;
cREDENTIAL.UserName = "wkmusic";
NativeMethods.CREDENTIAL credential = cREDENTIAL;
Marshal.Copy(bytes, 0, credential.CredentialBlob, bytes.Length);
try
{
if (!NativeMethods.CredWrite(ref credential, 0u))
{
throw new Exception($"CredWrite failed: {Marshal.GetLastWin32Error()}");
}
}
finally
{
Marshal.FreeHGlobal(credential.CredentialBlob);
}
}
public SpotifyCredentials? Load()
{
if (!NativeMethods.CredRead("WKMusic/SpotifyCredentials", 1u, 0u, out var credential))
{
return null;
}
try
{
NativeMethods.CREDENTIAL cREDENTIAL = Marshal.PtrToStructure<NativeMethods.CREDENTIAL>(credential);
byte[] array = new byte[cREDENTIAL.CredentialBlobSize];
Marshal.Copy(cREDENTIAL.CredentialBlob, array, 0, array.Length);
var anon = JsonConvert.DeserializeAnonymousType(Encoding.UTF8.GetString(array), new
{
ClientId = "",
ClientSecret = ""
});
if (anon == null || string.IsNullOrWhiteSpace(anon.ClientId))
{
return null;
}
return new SpotifyCredentials(anon.ClientId, anon.ClientSecret);
}
catch
{
Clear();
return null;
}
finally
{
NativeMethods.CredFree(credential);
}
}
public void Clear()
{
NativeMethods.CredDelete("WKMusic/SpotifyCredentials", 1u, 0u);
}
}
public interface IMusicClient
{
Task InitializeAsync(CancellationToken ct = default(CancellationToken));
Task<PlaybackState> GetPlaybackStateAsync(CancellationToken ct = default(CancellationToken));
}
internal static class MyPluginInfo
{
public const string PLUGIN_GUID = "dev.wkmusic";
public const string PLUGIN_NAME = "WKMusic";
public const string PLUGIN_VERSION = "1.0.0";
}
[BepInPlugin("dev.wkmusic", "WKMusic", "1.0.0")]
public class Plugin : BaseUnityPlugin
{
internal static ManualLogSource Logger = null;
internal static Plugin Instance = null;
internal volatile PlaybackState State = PlaybackState.Empty;
internal volatile bool Initialized;
internal volatile bool Initializing;
internal DateTime StateUpdatedAtUtc = DateTime.UtcNow;
internal volatile byte[]? PendingCoverBytes;
internal static float PlayerScale = 0.8f;
internal static float CoverSize = 64f;
internal static float CoverOpacity = 0.6f;
private void Awake()
{
//IL_0075: Unknown result type (might be due to invalid IL or missing references)
//IL_007f: Expected O, but got Unknown
//IL_00b7: Unknown result type (might be due to invalid IL or missing references)
//IL_00c1: Expected O, but got Unknown
//IL_00f9: Unknown result type (might be due to invalid IL or missing references)
//IL_0103: Expected O, but got Unknown
//IL_0160: Unknown result type (might be due to invalid IL or missing references)
Instance = this;
Logger = ((BaseUnityPlugin)this).Logger;
string workerUrl = ((BaseUnityPlugin)this).Config.Bind<string>("Spotify", "WorkerUrl", "https://wkmusic.eventeventeventevent1.workers.dev", "Cloudflare Worker URL; change only if you host your own").Value;
PlayerScale = ((BaseUnityPlugin)this).Config.Bind<float>("HUD", "PlayerScale", 0.8f, new ConfigDescription("Overall player scale (affects font size and layout dimensions)", (AcceptableValueBase)(object)new AcceptableValueRange<float>(0.5f, 3f), Array.Empty<object>())).Value;
CoverSize = ((BaseUnityPlugin)this).Config.Bind<float>("HUD", "CoverSize", 64f, new ConfigDescription("Album cover size in pixels", (AcceptableValueBase)(object)new AcceptableValueRange<float>(20f, 300f), Array.Empty<object>())).Value;
CoverOpacity = ((BaseUnityPlugin)this).Config.Bind<float>("HUD", "CoverOpacity", 0.6f, new ConfigDescription("Album cover opacity (0 = invisible, 1 = fully opaque)", (AcceptableValueBase)(object)new AcceptableValueRange<float>(0f, 1f), Array.Empty<object>())).Value;
CredentialsStorage credStorage = new CredentialsStorage();
CredentialsStorage.SpotifyCredentials saved = credStorage.Load();
Task.Run(async delegate
{
Initializing = true;
try
{
TokenStorage tokenStorage = new TokenStorage();
string clientId;
string clientSecret;
if ((object)saved == null)
{
Logger.LogInfo((object)"WKMusic: credentials missing, opening browser setup...");
BrowserSetup.SetupResult setupResult = await BrowserSetup.RunAsync(workerUrl, delegate(string id, string secret, string code)
{
SpotifyAuth spotifyAuth2 = new SpotifyAuth(workerUrl, secret);
string redirectUri2 = workerUrl + "/callback";
return spotifyAuth2.ExchangeCodeAsync(id, code, redirectUri2, default(CancellationToken));
});
if ((object)setupResult == null)
{
Logger.LogWarning((object)"WKMusic: setup cancelled.");
return;
}
credStorage.Save(setupResult.ClientId, setupResult.ClientSecret);
tokenStorage.Save(setupResult.Token);
clientId = setupResult.ClientId;
clientSecret = setupResult.ClientSecret;
}
else
{
clientId = saved.ClientId;
clientSecret = saved.ClientSecret;
}
SpotifyClient client = new SpotifyClient(new SpotifyAuth(workerUrl, clientSecret), tokenStorage, clientId);
try
{
await client.InitializeAsync();
}
catch (SpotifyAuthException ex) when ((object)saved != null && ex.Error == "invalid_client")
{
Logger.LogWarning((object)"WKMusic: saved Spotify credentials were rejected; clearing them and reopening setup.");
tokenStorage.Clear();
credStorage.Clear();
BrowserSetup.SetupResult setupResult2 = await BrowserSetup.RunAsync(workerUrl, delegate(string id, string secret, string code)
{
SpotifyAuth spotifyAuth = new SpotifyAuth(workerUrl, secret);
string redirectUri = workerUrl + "/callback";
return spotifyAuth.ExchangeCodeAsync(id, code, redirectUri, default(CancellationToken));
}, clientId);
if ((object)setupResult2 == null)
{
Logger.LogWarning((object)"WKMusic: setup cancelled.");
return;
}
credStorage.Save(setupResult2.ClientId, setupResult2.ClientSecret);
tokenStorage.Save(setupResult2.Token);
client = new SpotifyClient(new SpotifyAuth(workerUrl, setupResult2.ClientSecret), tokenStorage, setupResult2.ClientId);
await client.InitializeAsync();
}
Initialized = true;
Logger.LogInfo((object)"WKMusic: Spotify connected.");
StartPolling(client);
}
catch (Exception ex2)
{
Logger.LogError((object)("WKMusic: init failed — " + ex2.GetType().Name + ": " + ex2.Message));
Logger.LogError((object)(ex2.StackTrace ?? ""));
}
finally
{
Initializing = false;
}
});
DOTween.Init((bool?)null, (bool?)null, (LogBehaviour?)null);
new Harmony("dev.wkmusic").PatchAll();
}
private void StartPolling(IMusicClient client)
{
IMusicClient client2 = client;
HttpClient http = new HttpClient();
string lastCoverToken = null;
Task.Run(async delegate
{
while (true)
{
int delayMs;
try
{
PlaybackState state = await client2.GetPlaybackStateAsync();
State = state;
StateUpdatedAtUtc = DateTime.UtcNow;
delayMs = 1000;
TrackInfo track = State.Track;
string text = (((object)track == null) ? null : ((track.CoverBytes != null) ? ("embedded:" + track.Id) : track.CoverUrl));
if (text != lastCoverToken)
{
lastCoverToken = text;
byte[] pendingCoverBytes;
if (track?.CoverBytes != null)
{
pendingCoverBytes = track.CoverBytes;
}
else
{
byte[] array = (((object)track == null || track.CoverUrl == null) ? Array.Empty<byte>() : (await http.GetByteArrayAsync(track.CoverUrl)));
pendingCoverBytes = array;
}
PendingCoverBytes = pendingCoverBytes;
}
}
catch (SpotifyRateLimitException ex)
{
int num = Math.Max(1000, (int)Math.Ceiling(ex.RetryAfter.TotalMilliseconds));
delayMs = ((num <= 30000) ? num : num);
string statusMessage = ((num > 30000) ? ("Spotify rate limited (" + FormatDelay(delayMs) + ")") : "Spotify rate limited");
State = State with
{
StatusMessage = statusMessage
};
StateUpdatedAtUtc = DateTime.UtcNow;
Logger.LogWarning((object)($"WKMusic: Spotify rate limited polling; retrying in {delayMs} ms. " + string.Format("Retry-After={0}, requested={1} ms.", ex.RawRetryAfter ?? "missing", num)));
}
catch (Exception ex2)
{
delayMs = 5000;
Logger.LogWarning((object)("WKMusic: poll error - " + ex2.GetType().Name + ": " + ex2.Message + "\n" + ex2.StackTrace));
}
await Task.Delay(delayMs);
}
});
}
internal static string Truncate(string s, int max)
{
if (s.Length > max)
{
return s.Substring(0, max - 3) + "...";
}
return s;
}
private static string FormatDelay(int delayMs)
{
TimeSpan timeSpan = TimeSpan.FromMilliseconds(delayMs);
if (timeSpan.TotalHours >= 1.0)
{
return $"{(int)timeSpan.TotalHours}h {timeSpan.Minutes}m";
}
if (timeSpan.TotalMinutes >= 1.0)
{
return $"{(int)timeSpan.TotalMinutes}m {timeSpan.Seconds}s";
}
return $"{timeSpan.Seconds}s";
}
}
[HarmonyPatch(typeof(CL_UIManager), "Awake")]
internal static class Patch_UIManager_Awake
{
private const float RightMargin = 10f;
private const float TextWidth = 320f;
private const float CoverGap = 10f;
private static void Postfix(CL_UIManager __instance)
{
//IL_006c: Unknown result type (might be due to invalid IL or missing references)
//IL_0071: Unknown result type (might be due to invalid IL or missing references)
//IL_007e: Unknown result type (might be due to invalid IL or missing references)
//IL_0097: Unknown result type (might be due to invalid IL or missing references)
//IL_009e: Unknown result type (might be due to invalid IL or missing references)
//IL_00b0: Unknown result type (might be due to invalid IL or missing references)
//IL_00bb: Unknown result type (might be due to invalid IL or missing references)
//IL_00c5: Unknown result type (might be due to invalid IL or missing references)
//IL_00cf: Unknown result type (might be due to invalid IL or missing references)
//IL_0111: Unknown result type (might be due to invalid IL or missing references)
//IL_013f: Unknown result type (might be due to invalid IL or missing references)
Plugin.Logger.LogInfo((object)"WKMusic: CL_UIManager.Awake fired.");
Transform canvas = __instance.canvas;
TMP_Text timer = __instance.timer;
if ((Object)(object)canvas == (Object)null || (Object)(object)timer == (Object)null)
{
Plugin.Logger.LogWarning((object)$"WKMusic: canvas={canvas}, timer={timer} - aborting.");
return;
}
float playerScale = Plugin.PlayerScale;
float coverSize = Plugin.CoverSize;
float coverRight = 10f + 320f * playerScale + 10f;
GameObject val = new GameObject("WKMusic_HUD");
val.transform.SetParent(canvas, false);
RectTransform obj = val.AddComponent<RectTransform>();
Vector2 val2 = default(Vector2);
((Vector2)(ref val2))..ctor(1f, 1f);
obj.anchorMax = val2;
obj.anchorMin = val2;
obj.pivot = new Vector2(1f, 1f);
obj.anchoredPosition = Vector2.zero;
obj.sizeDelta = Vector2.zero;
Patch_UIManager_Update.HudGroup = val.AddComponent<CanvasGroup>();
Transform transform = val.transform;
Patch_UIManager_Update.CoverA = CreateCover(transform, coverSize, coverRight);
Patch_UIManager_Update.CoverB = CreateCover(transform, coverSize, coverRight);
Patch_UIManager_Update.RestoreCover();
Patch_UIManager_Update.TrackLabel = CreateLabel(transform, timer, "WKMusic_Track", new Vector2(-10f, -10f), playerScale, (TextAlignmentOptions)258, 42f * playerScale);
Patch_UIManager_Update.ProgressLabel = CreateLabel(transform, timer, "WKMusic_Progress", new Vector2(-10f, -62f * playerScale), playerScale, (TextAlignmentOptions)257);
Patch_UIManager_Update.ResetCache();
if (!Plugin.Instance.Initialized)
{
Patch_UIManager_Update.TrackLabel.text = "WKMusic: loading...";
}
Plugin.Logger.LogInfo((object)"WKMusic: HUD created.");
}
private static RawImage CreateCover(Transform canvas, float size, float coverRight)
{
//IL_0005: Unknown result type (might be due to invalid IL or missing references)
//IL_000a: Unknown result type (might be due to invalid IL or missing references)
//IL_0017: Unknown result type (might be due to invalid IL or missing references)
//IL_0034: Unknown result type (might be due to invalid IL or missing references)
//IL_0049: Unknown result type (might be due to invalid IL or missing references)
//IL_005e: Unknown result type (might be due to invalid IL or missing references)
//IL_0070: Unknown result type (might be due to invalid IL or missing references)
//IL_007c: Unknown result type (might be due to invalid IL or missing references)
GameObject val = new GameObject("WKMusic_Cover");
val.transform.SetParent(canvas, false);
val.SetActive(false);
RawImage obj = val.AddComponent<RawImage>();
RectTransform rectTransform = ((Graphic)obj).rectTransform;
rectTransform.anchorMin = new Vector2(1f, 1f);
rectTransform.anchorMax = new Vector2(1f, 1f);
rectTransform.pivot = new Vector2(1f, 1f);
rectTransform.anchoredPosition = new Vector2(0f - coverRight, -10f);
rectTransform.sizeDelta = new Vector2(size, size);
return obj;
}
private static TMP_Text CreateLabel(Transform canvas, TMP_Text reference, string name, Vector2 offset, float scale = 1f, TextAlignmentOptions alignment = 257, float height = 30f)
{
//IL_0001: Unknown result type (might be due to invalid IL or missing references)
//IL_0006: Unknown result type (might be due to invalid IL or missing references)
//IL_003b: Unknown result type (might be due to invalid IL or missing references)
//IL_0046: Unknown result type (might be due to invalid IL or missing references)
//IL_0073: Unknown result type (might be due to invalid IL or missing references)
//IL_0088: Unknown result type (might be due to invalid IL or missing references)
//IL_009d: Unknown result type (might be due to invalid IL or missing references)
//IL_00a8: Unknown result type (might be due to invalid IL or missing references)
//IL_00b8: Unknown result type (might be due to invalid IL or missing references)
GameObject val = new GameObject(name);
val.transform.SetParent(canvas, false);
TextMeshProUGUI obj = val.AddComponent<TextMeshProUGUI>();
((TMP_Text)obj).font = reference.font;
((TMP_Text)obj).fontSize = reference.fontSize * 0.85f * scale;
((Graphic)obj).color = ((Graphic)reference).color;
((TMP_Text)obj).alignment = alignment;
((TMP_Text)obj).enableWordWrapping = false;
((TMP_Text)obj).overflowMode = (TextOverflowModes)0;
((TMP_Text)obj).richText = true;
RectTransform rectTransform = ((TMP_Text)obj).rectTransform;
rectTransform.anchorMin = new Vector2(1f, 1f);
rectTransform.anchorMax = new Vector2(1f, 1f);
rectTransform.pivot = new Vector2(1f, 1f);
rectTransform.anchoredPosition = offset;
rectTransform.sizeDelta = new Vector2(320f * scale, height);
return (TMP_Text)(object)obj;
}
}
[HarmonyPatch(typeof(CL_UIManager), "Update")]
internal static class Patch_UIManager_Update
{
internal static TMP_Text? TrackLabel;
internal static TMP_Text? ProgressLabel;
internal static CanvasGroup? HudGroup;
internal static RawImage? CoverA;
internal static RawImage? CoverB;
private static bool _aIsFront = true;
private static Texture2D? _coverTexA;
private static Texture2D? _coverTexB;
private static byte[]? _lastCoverBytes;
private static bool _wasPaused;
private static string? _lastTrackText;
private static float _trackAlpha = 1f;
private static RawImage? Front
{
get
{
if (!_aIsFront)
{
return CoverB;
}
return CoverA;
}
}
private static RawImage? Back
{
get
{
if (!_aIsFront)
{
return CoverA;
}
return CoverB;
}
}
internal static void ResetCache()
{
if ((Object)(object)TrackLabel != (Object)null)
{
TrackLabel.text = "";
}
if ((Object)(object)ProgressLabel != (Object)null)
{
ProgressLabel.text = "";
}
_wasPaused = false;
_lastTrackText = null;
_trackAlpha = 1f;
DOTween.Kill((object)"coverA", false);
DOTween.Kill((object)"coverB", false);
_aIsFront = true;
}
internal static void RestoreCover()
{
//IL_004b: Unknown result type (might be due to invalid IL or missing references)
if (_lastCoverBytes == null)
{
return;
}
RawImage front = Front;
if (!((Object)(object)front == (Object)null))
{
SetLayerTexture(front, ref _aIsFront ? ref _coverTexA : ref _coverTexB, _lastCoverBytes);
((Graphic)front).color = new Color(1f, 1f, 1f, Plugin.CoverOpacity);
((Component)front).gameObject.SetActive(true);
RawImage back = Back;
if ((Object)(object)back != (Object)null)
{
((Component)back).gameObject.SetActive(false);
}
}
}
private static void SetLayerTexture(RawImage layer, ref Texture2D? texSlot, byte[] bytes)
{
//IL_0017: Unknown result type (might be due to invalid IL or missing references)
//IL_001d: Expected O, but got Unknown
if ((Object)(object)texSlot != (Object)null)
{
Object.Destroy((Object)(object)texSlot);
}
texSlot = new Texture2D(2, 2, (TextureFormat)4, false, false);
if (ImageConversion.LoadImage(texSlot, bytes))
{
((Texture)texSlot).wrapMode = (TextureWrapMode)1;
texSlot.Apply();
}
layer.texture = (Texture)(object)texSlot;
}
internal static void ApplyCover(byte[] bytes)
{
//IL_007d: Unknown result type (might be due to invalid IL or missing references)
//IL_0104: Unknown result type (might be due to invalid IL or missing references)
//IL_013a: Unknown result type (might be due to invalid IL or missing references)
//IL_0144: Expected O, but got Unknown
RawImage back = Back;
if ((Object)(object)back == (Object)null)
{
return;
}
DOTween.Kill((object)"coverA", false);
DOTween.Kill((object)"coverB", false);
if (_aIsFront)
{
SetLayerTexture(back, ref _coverTexB, bytes);
}
else
{
SetLayerTexture(back, ref _coverTexA, bytes);
}
((Graphic)back).color = new Color(1f, 1f, 1f, 0f);
((Component)back).gameObject.SetActive(true);
((Component)back).transform.SetAsLastSibling();
RawImage front = Front;
TweenSettingsExtensions.SetId<Tweener>(DOVirtual.Float(0f, Plugin.CoverOpacity, 0.6f, (TweenCallback<float>)delegate(float v)
{
//IL_0024: Unknown result type (might be due to invalid IL or missing references)
if ((Object)(object)back != (Object)null)
{
((Graphic)back).color = new Color(1f, 1f, 1f, v);
}
}), "coverB");
if ((Object)(object)front != (Object)null && ((Component)front).gameObject.activeSelf)
{
TweenSettingsExtensions.OnComplete<Tweener>(TweenSettingsExtensions.SetId<Tweener>(DOVirtual.Float(((Graphic)front).color.a, 0f, 0.6f, (TweenCallback<float>)delegate(float v)
{
//IL_0024: Unknown result type (might be due to invalid IL or missing references)
if ((Object)(object)front != (Object)null)
{
((Graphic)front).color = new Color(1f, 1f, 1f, v);
}
}), "coverA"), (TweenCallback)delegate
{
if ((Object)(object)front != (Object)null)
{
((Component)front).gameObject.SetActive(false);
}
});
}
_aIsFront = !_aIsFront;
}
internal static void HideCover()
{
//IL_0050: Unknown result type (might be due to invalid IL or missing references)
//IL_0086: Unknown result type (might be due to invalid IL or missing references)
//IL_0090: Expected O, but got Unknown
DOTween.Kill((object)"coverA", false);
DOTween.Kill((object)"coverB", false);
RawImage front = Front;
if ((Object)(object)front == (Object)null || !((Component)front).gameObject.activeSelf)
{
return;
}
TweenSettingsExtensions.OnComplete<Tweener>(TweenSettingsExtensions.SetId<Tweener>(DOVirtual.Float(((Graphic)front).color.a, 0f, 0.5f, (TweenCallback<float>)delegate(float v)
{
//IL_0024: Unknown result type (might be due to invalid IL or missing references)
if ((Object)(object)front != (Object)null)
{
((Graphic)front).color = new Color(1f, 1f, 1f, v);
}
}), "coverA"), (TweenCallback)delegate
{
if ((Object)(object)front != (Object)null)
{
((Component)front).gameObject.SetActive(false);
}
});
}
private static void SetTrackLabel(string newText)
{
//IL_0067: Unknown result type (might be due to invalid IL or missing references)
//IL_006c: Unknown result type (might be due to invalid IL or missing references)
//IL_0072: Unknown result type (might be due to invalid IL or missing references)
//IL_0078: Unknown result type (might be due to invalid IL or missing references)
//IL_007e: Unknown result type (might be due to invalid IL or missing references)
//IL_0089: Unknown result type (might be due to invalid IL or missing references)
if (!((Object)(object)TrackLabel == (Object)null))
{
if (_lastTrackText != newText)
{
_lastTrackText = newText;
TrackLabel.text = newText;
_trackAlpha = 0f;
}
if (_trackAlpha < 1f)
{
_trackAlpha = Mathf.Min(1f, _trackAlpha + Time.deltaTime * 2.5f);
Color color = ((Graphic)TrackLabel).color;
((Graphic)TrackLabel).color = new Color(color.r, color.g, color.b, _trackAlpha);
}
}
}
private static void Postfix()
{
if ((Object)(object)TrackLabel == (Object)null || (Object)(object)ProgressLabel == (Object)null)
{
return;
}
Plugin instance = Plugin.Instance;
byte[] pendingCoverBytes = instance.PendingCoverBytes;
if (pendingCoverBytes != null)
{
instance.PendingCoverBytes = null;
if (pendingCoverBytes.Length == 0)
{
_lastCoverBytes = null;
HideCover();
}
else
{
_lastCoverBytes = pendingCoverBytes;
ApplyCover(pendingCoverBytes);
}
}
if (instance.Initializing)
{
SetTrackLabel("WKMusic: authorizing...");
ProgressLabel.text = "";
return;
}
if (!instance.Initialized)
{
SetTrackLabel("");
ProgressLabel.text = "";
return;
}
PlaybackState state = instance.State;
if (!string.IsNullOrEmpty(state.StatusMessage))
{
SetTrackLabel(state.StatusMessage);
ProgressLabel.text = "";
return;
}
if ((Object)(object)HudGroup != (Object)null)
{
bool flag = state.Track != null && !state.IsPlaying;
if (flag != _wasPaused)
{
_wasPaused = flag;
DOVirtual.Float(HudGroup.alpha, flag ? 0.3f : 1f, 0.5f, (TweenCallback<float>)delegate(float v)
{
HudGroup.alpha = v;
});
TweenSettingsExtensions.SetEase<TweenerCore<Vector3, Vector3, VectorOptions>>(ShortcutExtensions.DOScale(((Component)HudGroup).transform, flag ? 0.75f : 1f, 0.5f), (Ease)9);
}
}
if ((object)state.Track == null)
{
SetTrackLabel("Nothing playing");
ProgressLabel.text = "";
return;
}
TrackInfo track = state.Track;
int value = (state.IsPlaying ? (state.ProgressMs + (int)(DateTime.UtcNow - instance.StateUpdatedAtUtc).TotalMilliseconds) : state.ProgressMs);
value = Math.Clamp(value, 0, track.DurationMs);
TimeSpan timeSpan = TimeSpan.FromMilliseconds(value);
TimeSpan timeSpan2 = TimeSpan.FromMilliseconds(track.DurationMs);
int num = Math.Clamp((int)Math.Round(((track.DurationMs > 0) ? ((double)value / (double)track.DurationMs) : 0.0) * 50.0), 0, 50);
string arg = new string('-', num) + "|<color=#303030>" + new string('-', 50 - num) + "</color>";
SetTrackLabel(Plugin.Truncate(track.Title, 40) + "\n<line-height=65%><color=#888888><size=80%>" + Plugin.Truncate(track.Artist, 40) + "</size></color>");
ProgressLabel.text = $"<mspace=0.45em>{timeSpan:m\\:ss}</mspace> <mspace=0.22em>{arg}</mspace> <mspace=0.45em>{timeSpan2:m\\:ss}</mspace>";
}
}
public class SpotifyAuthException : Exception
{
public string? Error { get; }
public string ResponseBody { get; }
public SpotifyAuthException(string message, string? error, string responseBody)
{
Error = error;
ResponseBody = responseBody;
base..ctor(message);
}
}
public class SpotifyAuth
{
private const string TokenUrl = "https://accounts.spotify.com/api/token";
private readonly HttpClient _http = http ?? new HttpClient();
private readonly string _workerUrl = workerUrl.TrimEnd('/');
private readonly string _clientSecret;
public SpotifyAuth(string workerUrl, string clientSecret, HttpClient? http = null)
{
_clientSecret = clientSecret;
base..ctor();
}
public async Task<SpotifyToken> AuthorizeAsync(string clientId, CancellationToken ct = default(CancellationToken))
{
string redirectUri = _workerUrl + "/callback";
return ((await BrowserSetup.RunAsync(_workerUrl, (string id, string _, string code) => ExchangeCodeAsync(id, code, redirectUri, ct), clientId, "", ct)) ?? throw new OperationCanceledException("Spotify authorization cancelled.")).Token;
}
public async Task<SpotifyToken> RefreshAsync(string clientId, SpotifyToken token, CancellationToken ct = default(CancellationToken))
{
Dictionary<string, string> nameValueCollection = new Dictionary<string, string>
{
["grant_type"] = "refresh_token",
["refresh_token"] = token.RefreshToken,
["client_id"] = clientId,
["client_secret"] = _clientSecret
};
HttpResponseMessage response = await _http.PostAsync("https://accounts.spotify.com/api/token", new FormUrlEncodedContent(nameValueCollection), ct);
string text = await response.Content.ReadAsStringAsync();
if (!response.IsSuccessStatusCode)
{
string error = TryReadSpotifyError(text);
throw new SpotifyAuthException("Token refresh failed: " + text, error, text);
}
JObject val = JObject.Parse(text);
string accessToken = Extensions.Value<string>((IEnumerable<JToken>)val["access_token"]);
JToken obj = val["refresh_token"];
return new SpotifyToken(accessToken, ((obj != null) ? Extensions.Value<string>((IEnumerable<JToken>)obj) : null) ?? token.RefreshToken, Extensions.Value<int>((IEnumerable<JToken>)val["expires_in"]), DateTime.UtcNow);
}
internal async Task<SpotifyToken> ExchangeCodeAsync(string clientId, string code, string redirectUri, CancellationToken ct)
{
Dictionary<string, string> nameValueCollection = new Dictionary<string, string>
{
["grant_type"] = "authorization_code",
["code"] = code,
["redirect_uri"] = redirectUri,
["client_id"] = clientId,
["client_secret"] = _clientSecret
};
HttpResponseMessage response = await _http.PostAsync("https://accounts.spotify.com/api/token", new FormUrlEncodedContent(nameValueCollection), ct);
string text = await response.Content.ReadAsStringAsync();
if (!response.IsSuccessStatusCode)
{
string error = TryReadSpotifyError(text);
throw new SpotifyAuthException("Token exchange failed: " + text, error, text);
}
JObject val = JObject.Parse(text);
string accessToken = Extensions.Value<string>((IEnumerable<JToken>)val["access_token"]);
JToken obj = val["refresh_token"];
return new SpotifyToken(accessToken, ((obj != null) ? Extensions.Value<string>((IEnumerable<JToken>)obj) : null) ?? string.Empty, Extensions.Value<int>((IEnumerable<JToken>)val["expires_in"]), DateTime.UtcNow);
}
private static string? TryReadSpotifyError(string json)
{
try
{
JToken obj = JObject.Parse(json)["error"];
return (obj != null) ? Extensions.Value<string>((IEnumerable<JToken>)obj) : null;
}
catch
{
return null;
}
}
}
public class SpotifyRateLimitException : Exception
{
public TimeSpan RetryAfter { get; }
public string? RawRetryAfter { get; }
public SpotifyRateLimitException(TimeSpan retryAfter, string? rawRetryAfter)
{
RetryAfter = retryAfter;
RawRetryAfter = rawRetryAfter;
base..ctor($"Spotify rate limit reached. Retry after {retryAfter.TotalSeconds:0.#}s.");
}
}
public class SpotifyClient : IMusicClient
{
[CompilerGenerated]
private SpotifyAuth <auth>P;
[CompilerGenerated]
private TokenStorage <storage>P;
private const string ApiBase = "https://api.spotify.com/v1";
private readonly HttpClient _http;
private readonly string _clientId;
private SpotifyToken? _token;
public SpotifyClient(SpotifyAuth auth, TokenStorage storage, string clientId, HttpClient? http = null)
{
<auth>P = auth;
<storage>P = storage;
_http = http ?? new HttpClient();
_clientId = clientId;
base..ctor();
}
public async Task InitializeAsync(CancellationToken ct = default(CancellationToken))
{
_token = <storage>P.Load();
if ((object)_token == null)
{
_token = await <auth>P.AuthorizeAsync(_clientId, ct);
<storage>P.Save(_token);
}
else if (_token.IsExpired)
{
await ForceRefreshAsync(ct);
}
}
public async Task<PlaybackState> GetPlaybackStateAsync(CancellationToken ct = default(CancellationToken))
{
string text = await GetAsync("/me/player", ct);
if (text == null)
{
return PlaybackState.Empty;
}
JObject val = JObject.Parse(text);
JToken val2 = val["item"];
if (val2 == null || (int)val2.Type == 10)
{
return PlaybackState.Empty;
}
TrackInfo track = ParseTrack(val2);
bool isPlaying = Extensions.Value<bool>((IEnumerable<JToken>)val["is_playing"]);
int progressMs = Extensions.Value<int>((IEnumerable<JToken>)val["progress_ms"]);
return new PlaybackState(track, isPlaying, progressMs);
}
public Task PlayAsync(CancellationToken ct = default(CancellationToken))
{
return PutAsync("/me/player/play", ct);
}
public Task PauseAsync(CancellationToken ct = default(CancellationToken))
{
return PutAsync("/me/player/pause", ct);
}
public Task NextAsync(CancellationToken ct = default(CancellationToken))
{
return PostAsync("/me/player/next", ct);
}
public Task PreviousAsync(CancellationToken ct = default(CancellationToken))
{
return PostAsync("/me/player/previous", ct);
}
public Task SeekAsync(int positionMs, CancellationToken ct = default(CancellationToken))
{
return PutAsync($"/me/player/seek?position_ms={positionMs}", ct);
}
public Task SetVolumeAsync(int volumePercent, CancellationToken ct = default(CancellationToken))
{
return PutAsync($"/me/player/volume?volume_percent={Math.Clamp(volumePercent, 0, 100)}", ct);
}
private async Task<string?> GetAsync(string path, CancellationToken ct)
{
await EnsureTokenValidAsync(ct);
HttpRequestMessage httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, "https://api.spotify.com/v1" + path);
httpRequestMessage.Headers.Authorization = new AuthenticationHeaderValue("Bearer", _token.AccessToken);
HttpResponseMessage httpResponseMessage = await _http.SendAsync(httpRequestMessage, ct);
if (httpResponseMessage.StatusCode == HttpStatusCode.NoContent)
{
return null;
}
if (httpResponseMessage.StatusCode == HttpStatusCode.Unauthorized)
{
await ForceRefreshAsync(ct);
return await GetAsync(path, ct);
}
EnsureNotRateLimited(httpResponseMessage);
httpResponseMessage.EnsureSuccessStatusCode();
return await httpResponseMessage.Content.ReadAsStringAsync();
}
private async Task PutAsync(string path, CancellationToken ct)
{
await EnsureTokenValidAsync(ct);
HttpRequestMessage httpRequestMessage = new HttpRequestMessage(HttpMethod.Put, "https://api.spotify.com/v1" + path);
httpRequestMessage.Headers.Authorization = new AuthenticationHeaderValue("Bearer", _token.AccessToken);
httpRequestMessage.Content = new StringContent("", Encoding.UTF8, "application/json");
HttpResponseMessage httpResponseMessage = await _http.SendAsync(httpRequestMessage, ct);
if (httpResponseMessage.StatusCode == HttpStatusCode.Unauthorized)
{
await ForceRefreshAsync(ct);
await PutAsync(path, ct);
}
else if (httpResponseMessage.StatusCode != HttpStatusCode.NoContent)
{
EnsureNotRateLimited(httpResponseMessage);
httpResponseMessage.EnsureSuccessStatusCode();
}
}
private async Task PostAsync(string path, CancellationToken ct)
{
await EnsureTokenValidAsync(ct);
HttpRequestMessage httpRequestMessage = new HttpRequestMessage(HttpMethod.Post, "https://api.spotify.com/v1" + path);
httpRequestMessage.Headers.Authorization = new AuthenticationHeaderValue("Bearer", _token.AccessToken);
httpRequestMessage.Content = new StringContent("", Encoding.UTF8, "application/json");
HttpResponseMessage httpResponseMessage = await _http.SendAsync(httpRequestMessage, ct);
if (httpResponseMessage.StatusCode == HttpStatusCode.Unauthorized)
{
await ForceRefreshAsync(ct);
await PostAsync(path, ct);
}
else if (httpResponseMessage.StatusCode != HttpStatusCode.NoContent)
{
EnsureNotRateLimited(httpResponseMessage);
httpResponseMessage.EnsureSuccessStatusCode();
}
}
private async Task EnsureTokenValidAsync(CancellationToken ct)
{
if ((object)_token == null)
{
throw new InvalidOperationException("Client not initialized. Call InitializeAsync first.");
}
if (_token.IsExpired)
{
await ForceRefreshAsync(ct);
}
}
private async Task ForceRefreshAsync(CancellationToken ct)
{
try
{
_token = await <auth>P.RefreshAsync(_clientId, _token, ct);
}
catch (SpotifyAuthException ex) when (ex.Error == "invalid_grant")
{
<storage>P.Clear();
_token = await <auth>P.AuthorizeAsync(_clientId, ct);
}
<storage>P.Save(_token);
}
private static void EnsureNotRateLimited(HttpResponseMessage response)
{
if (response.StatusCode != HttpStatusCode.TooManyRequests)
{
return;
}
response.Headers.TryGetValues("Retry-After", out IEnumerable<string> values);
string rawRetryAfter = values?.FirstOrDefault();
TimeSpan timeSpan = response.Headers.RetryAfter?.Delta ?? (response.Headers.RetryAfter?.Date - DateTimeOffset.UtcNow) ?? TimeSpan.FromSeconds(10.0);
if (timeSpan < TimeSpan.FromSeconds(1.0))
{
timeSpan = TimeSpan.FromSeconds(1.0);
}
throw new SpotifyRateLimitException(timeSpan, rawRetryAfter);
}
private static TrackInfo ParseTrack(JToken item)
{
string id = Extensions.Value<string>((IEnumerable<JToken>)item[(object)"id"]);
string title = Extensions.Value<string>((IEnumerable<JToken>)item[(object)"name"]);
IEnumerable<string> values = ((IEnumerable<JToken>)item[(object)"artists"]).Select((JToken a) => Extensions.Value<string>((IEnumerable<JToken>)a[(object)"name"]));
string artist = string.Join(", ", values);
string album = Extensions.Value<string>((IEnumerable<JToken>)item[(object)"album"][(object)"name"]);
int durationMs = Extensions.Value<int>((IEnumerable<JToken>)item[(object)"duration_ms"]);
JToken obj = item[(object)"album"][(object)"images"];
object obj2;
if (obj == null)
{
obj2 = null;
}
else
{
JToken? obj3 = ((IEnumerable<JToken>)obj).FirstOrDefault();
if (obj3 == null)
{
obj2 = null;
}
else
{
JToken obj4 = obj3[(object)"url"];
obj2 = ((obj4 != null) ? Extensions.Value<string>((IEnumerable<JToken>)obj4) : null);
}
}
string coverUrl = (string)obj2;
return new TrackInfo(id, title, artist, album, coverUrl, durationMs);
}
}
public record SpotifyToken(string AccessToken, string RefreshToken, int ExpiresIn, DateTime ObtainedAt)
{
public bool IsExpired => DateTime.UtcNow >= ObtainedAt.AddSeconds(ExpiresIn - 30);
}
public record TrackInfo(string Id, string Title, string Artist, string Album, string? CoverUrl, int DurationMs, byte[]? CoverBytes = null);
public record PlaybackState(TrackInfo? Track, bool IsPlaying, int ProgressMs, string? StatusMessage = null)
{
public static PlaybackState Empty => new PlaybackState(null, IsPlaying: false, 0);
}
public class TokenStorage
{
private class StoredToken
{
public string AccessToken { get; set; } = "";
public string RefreshToken { get; set; } = "";
public int ExpiresIn { get; set; }
public DateTime ObtainedAt { get; set; }
public StoredToken()
{
}
public StoredToken(string access, string refresh, int expiresIn, DateTime obtainedAt)
{
AccessToken = access;
RefreshToken = refresh;
ExpiresIn = expiresIn;
ObtainedAt = obtainedAt;
}
}
private static class NativeMethods
{
[StructLayout(LayoutKind.Sequential, CharSet = CharSet.Unicode)]
public struct CREDENTIAL
{
public uint Flags;
public uint Type;
public string TargetName;
public string? Comment;
public long LastWritten;
public uint CredentialBlobSize;
public IntPtr CredentialBlob;
public uint Persist;
public uint AttributeCount;
public IntPtr Attributes;
public string? TargetAlias;
public string? UserName;
}
public const uint CRED_TYPE_GENERIC = 1u;
public const uint CRED_PERSIST_LOCAL_MACHINE = 2u;
[DllImport("advapi32.dll", CharSet = CharSet.Unicode, SetLastError = true)]
public static extern bool CredWrite(ref CREDENTIAL credential, uint flags);
[DllImport("advapi32.dll", CharSet = CharSet.Unicode, SetLastError = true)]
public static extern bool CredRead(string target, uint type, uint flags, out IntPtr credential);
[DllImport("advapi32.dll")]
public static extern void CredFree(IntPtr buffer);
[DllImport("advapi32.dll", CharSet = CharSet.Unicode)]
public static extern bool CredDelete(string target, uint type, uint flags);
}
private readonly string CredentialName;
public TokenStorage(string credentialName = "WKMusic/SpotifyToken")
{
CredentialName = credentialName;
base..ctor();
}
public void Save(SpotifyToken token)
{
string s = JsonConvert.SerializeObject((object)new StoredToken(token.AccessToken, token.RefreshToken, token.ExpiresIn, token.ObtainedAt));
byte[] bytes = Encoding.UTF8.GetBytes(s);
NativeMethods.CREDENTIAL cREDENTIAL = default(NativeMethods.CREDENTIAL);
cREDENTIAL.Type = 1u;
cREDENTIAL.TargetName = CredentialName;
cREDENTIAL.CredentialBlob = Marshal.AllocHGlobal(bytes.Length);
cREDENTIAL.CredentialBlobSize = (uint)bytes.Length;
cREDENTIAL.Persist = 2u;
cREDENTIAL.UserName = "spotify";
NativeMethods.CREDENTIAL credential = cREDENTIAL;
Marshal.Copy(bytes, 0, credential.CredentialBlob, bytes.Length);
try
{
if (!NativeMethods.CredWrite(ref credential, 0u))
{
throw new Exception($"CredWrite failed: {Marshal.GetLastWin32Error()}");
}
}
finally
{
Marshal.FreeHGlobal(credential.CredentialBlob);
}
}
public SpotifyToken? Load()
{
if (!NativeMethods.CredRead(CredentialName, 1u, 0u, out var credential))
{
return null;
}
try
{
NativeMethods.CREDENTIAL cREDENTIAL = Marshal.PtrToStructure<NativeMethods.CREDENTIAL>(credential);
byte[] array = new byte[cREDENTIAL.CredentialBlobSize];
Marshal.Copy(cREDENTIAL.CredentialBlob, array, 0, array.Length);
StoredToken storedToken = JsonConvert.DeserializeObject<StoredToken>(Encoding.UTF8.GetString(array));
if (storedToken == null)
{
return null;
}
return new SpotifyToken(storedToken.AccessToken, storedToken.RefreshToken, storedToken.ExpiresIn, storedToken.ObtainedAt);
}
catch
{
Clear();
return null;
}
finally
{
NativeMethods.CredFree(credential);
}
}
public void Clear()
{
NativeMethods.CredDelete(CredentialName, 1u, 0u);
}
}
}
