using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Diagnostics;
using System.Globalization;
using System.IO;
using System.IO.Compression;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Net.WebSockets;
using System.Reflection;
using System.Runtime.CompilerServices;
using System.Runtime.Versioning;
using System.Security;
using System.Security.Cryptography;
using System.Security.Permissions;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.CodeAnalysis;
using PeakMusic.Core.Netease;
using PeakMusic.Core.Sources;

[assembly: CompilationRelaxations(8)]
[assembly: RuntimeCompatibility(WrapNonExceptionThrows = true)]
[assembly: Debuggable(DebuggableAttribute.DebuggingModes.IgnoreSymbolStoreSequencePoints)]
[assembly: TargetFramework(".NETFramework,Version=v4.7.2", FrameworkDisplayName = ".NET Framework 4.7.2")]
[assembly: AssemblyCompany("PeakMusic.Core")]
[assembly: AssemblyConfiguration("Release")]
[assembly: AssemblyFileVersion("0.1.0.0")]
[assembly: AssemblyInformationalVersion("0.1.0")]
[assembly: AssemblyProduct("PeakMusic.Core")]
[assembly: AssemblyTitle("PeakMusic.Core")]
[assembly: SecurityPermission(SecurityAction.RequestMinimum, SkipVerification = true)]
[assembly: AssemblyVersion("0.1.0.0")]
[module: UnverifiableCode]
[module: RefSafetyRules(11)]
namespace Microsoft.CodeAnalysis
{
	[CompilerGenerated]
	[Embedded]
	internal sealed class EmbeddedAttribute : Attribute
	{
	}
}
namespace System.Runtime.CompilerServices
{
	[CompilerGenerated]
	[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;
		}
	}
}
namespace PeakMusic.Core
{
	public sealed class LrcDocument
	{
		private static readonly Regex TagRegex = new Regex("\\[(\\d{1,3}):(\\d{1,2})(?:[.:](\\d{1,3}))?\\]", RegexOptions.Compiled);

		private static readonly Regex MetaRegex = new Regex("^\\[(ar|ti|al|by|offset|re|ve|length|kana|ti|tool):", RegexOptions.IgnoreCase | RegexOptions.Compiled);

		public readonly List<LrcLine> Lines = new List<LrcLine>();

		public int OffsetMs;

		public static LrcDocument Parse(string lrc)
		{
			LrcDocument lrcDocument = new LrcDocument();
			if (string.IsNullOrEmpty(lrc))
			{
				return lrcDocument;
			}
			string[] array = lrc.Replace("\r\n", "\n").Replace('\r', '\n').Split(new char[1] { '\n' });
			for (int i = 0; i < array.Length; i++)
			{
				string text = array[i].Trim();
				if (text.Length == 0 || text[0] == '{')
				{
					continue;
				}
				if (MetaRegex.IsMatch(text))
				{
					if (text.StartsWith("[offset:", StringComparison.OrdinalIgnoreCase) && int.TryParse(text.Substring(8).TrimEnd(new char[1] { ']' }), out var result))
					{
						lrcDocument.OffsetMs = result;
					}
					continue;
				}
				MatchCollection matchCollection = TagRegex.Matches(text);
				if (matchCollection.Count == 0)
				{
					continue;
				}
				string text2 = TagRegex.Replace(text, "").Trim();
				if (text2.Length == 0)
				{
					continue;
				}
				foreach (Match item in matchCollection)
				{
					int minutes = int.Parse(item.Groups[1].Value, CultureInfo.InvariantCulture);
					int seconds = int.Parse(item.Groups[2].Value, CultureInfo.InvariantCulture);
					int milliseconds = 0;
					if (item.Groups[3].Success)
					{
						string text3 = item.Groups[3].Value;
						while (text3.Length < 3)
						{
							text3 += "0";
						}
						if (text3.Length > 3)
						{
							text3 = text3.Substring(0, 3);
						}
						milliseconds = int.Parse(text3, CultureInfo.InvariantCulture);
					}
					lrcDocument.Lines.Add(new LrcLine
					{
						Time = new TimeSpan(0, 0, minutes, seconds, milliseconds),
						Text = text2
					});
				}
			}
			lrcDocument.Lines.Sort((LrcLine a, LrcLine b) => a.Time.CompareTo(b.Time));
			return lrcDocument;
		}

		public int IndexAt(float seconds)
		{
			if (Lines.Count == 0)
			{
				return -1;
			}
			double num = (double)seconds * 1000.0 + (double)OffsetMs;
			int num2 = 0;
			int num3 = Lines.Count - 1;
			int result = -1;
			while (num2 <= num3)
			{
				int num4 = (num2 + num3) / 2;
				if (Lines[num4].Time.TotalMilliseconds <= num)
				{
					result = num4;
					num2 = num4 + 1;
				}
				else
				{
					num3 = num4 - 1;
				}
			}
			return result;
		}

		public string TextAt(float seconds)
		{
			int num = IndexAt(seconds);
			if (num >= 0)
			{
				return Lines[num].Text;
			}
			return "";
		}
	}
	public sealed class LrcLine
	{
		public TimeSpan Time;

		public string Text = "";
	}
	public sealed class MusicTrack
	{
		public long id { get; set; }

		public string name { get; set; }

		public string ar { get; set; }

		public string al { get; set; }

		public string picUrl { get; set; }

		public int dt { get; set; }

		public long fee { get; set; }

		public int st { get; set; }

		public TimeSpan Duration => TimeSpan.FromMilliseconds(Math.Max(0, dt));

		public override string ToString()
		{
			if (!string.IsNullOrEmpty(ar))
			{
				return name + " - " + ar;
			}
			return name;
		}
	}
	public sealed class PlayUrlResult
	{
		public string Url { get; set; }

		public int Bitrate { get; set; }

		public string Type { get; set; }

		public int Code { get; set; }

		public bool IsTrialOnly { get; set; }

		public bool IsPlayable
		{
			get
			{
				if (Code == 200 && !IsTrialOnly)
				{
					return !string.IsNullOrEmpty(Url);
				}
				return false;
			}
		}
	}
	public sealed class Throttle : IDisposable
	{
		private readonly SemaphoreSlim _gate = new SemaphoreSlim(1, 1);

		private readonly Random _rng = new Random(Environment.TickCount * 31);

		private readonly int _minDelayMs;

		private readonly int _maxDelayMs;

		private bool _disposed;

		public int Completed { get; private set; }

		public Throttle(int minDelayMs = 200, int maxDelayMs = 500)
		{
			if (minDelayMs < 0)
			{
				minDelayMs = 0;
			}
			if (maxDelayMs < minDelayMs)
			{
				maxDelayMs = minDelayMs;
			}
			_minDelayMs = minDelayMs;
			_maxDelayMs = maxDelayMs;
		}

		public async Task<T> RunAsync<T>(Func<Task<T>> work, CancellationToken ct = default(CancellationToken))
		{
			if (work == null)
			{
				throw new ArgumentNullException("work");
			}
			await _gate.WaitAsync(ct).ConfigureAwait(continueOnCapturedContext: false);
			try
			{
				int num;
				lock (_rng)
				{
					num = _rng.Next(_minDelayMs, _maxDelayMs + 1);
				}
				if (num > 0)
				{
					await Task.Delay(num, ct).ConfigureAwait(continueOnCapturedContext: false);
				}
				T result = await work().ConfigureAwait(continueOnCapturedContext: false);
				Completed++;
				return result;
			}
			finally
			{
				_gate.Release();
			}
		}

		public Task RunAsync(Func<Task> work, CancellationToken ct = default(CancellationToken))
		{
			if (work == null)
			{
				throw new ArgumentNullException("work");
			}
			return RunAsync(async delegate
			{
				await work().ConfigureAwait(continueOnCapturedContext: false);
				return true;
			}, ct);
		}

		public void Dispose()
		{
			if (!_disposed)
			{
				_disposed = true;
				_gate.Dispose();
			}
		}
	}
}
namespace PeakMusic.Core.Sources
{
	public static class LibraryStore
	{
		private const char Sep = '\u0001';

		private const int MaxHistory = 20;

		public static string Dir => Path.Combine(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "PeakMusic");

		private static string HistoryPath => Path.Combine(Dir, "history.txt");

		private static string FavoritesPath => Path.Combine(Dir, "favorites.txt");

		public static List<string> LoadHistory()
		{
			List<string> list = new List<string>();
			try
			{
				if (!File.Exists(HistoryPath))
				{
					return list;
				}
				string[] array = File.ReadAllLines(HistoryPath, Encoding.UTF8);
				for (int i = 0; i < array.Length; i++)
				{
					string text = (array[i] ?? "").Trim();
					if (text.Length != 0 && !list.Contains(text))
					{
						list.Add(text);
					}
				}
				return list;
			}
			catch
			{
				return list;
			}
		}

		public static void AddHistory(string keyword)
		{
			if (string.IsNullOrEmpty(keyword))
			{
				return;
			}
			string i = keyword.Trim();
			if (i.Length == 0)
			{
				return;
			}
			List<string> list = LoadHistory();
			list.RemoveAll((string x) => string.Equals(x, i, StringComparison.OrdinalIgnoreCase));
			list.Insert(0, i);
			if (list.Count > 20)
			{
				list.RemoveRange(20, list.Count - 20);
			}
			try
			{
				Directory.CreateDirectory(Dir);
				File.WriteAllLines(HistoryPath, list.ToArray(), Encoding.UTF8);
			}
			catch
			{
			}
		}

		public static List<SongInfo> LoadFavorites()
		{
			List<SongInfo> list = new List<SongInfo>();
			try
			{
				if (!File.Exists(FavoritesPath))
				{
					return list;
				}
				string[] array = File.ReadAllLines(FavoritesPath, Encoding.UTF8);
				for (int i = 0; i < array.Length; i++)
				{
					SongInfo songInfo = ParseLine(array[i]);
					if (songInfo != null)
					{
						list.Add(songInfo);
					}
				}
				return list;
			}
			catch
			{
				return list;
			}
		}

		public static void AddFavorite(SongInfo song)
		{
			if (song != null)
			{
				List<SongInfo> list = LoadFavorites();
				list.RemoveAll((SongInfo x) => x.Key == song.Key);
				list.Insert(0, song);
				SaveFavorites(list);
			}
		}

		public static void RemoveFavorite(string key)
		{
			List<SongInfo> list = LoadFavorites();
			list.RemoveAll((SongInfo x) => x.Key == key);
			SaveFavorites(list);
		}

		public static bool IsFavorite(string key)
		{
			foreach (SongInfo item in LoadFavorites())
			{
				if (item.Key == key)
				{
					return true;
				}
			}
			return false;
		}

		private static void SaveFavorites(List<SongInfo> list)
		{
			try
			{
				Directory.CreateDirectory(Dir);
				List<string> list2 = new List<string>();
				foreach (SongInfo item in list)
				{
					string text = Serialize(item);
					if (text != null)
					{
						list2.Add(text);
					}
				}
				File.WriteAllLines(FavoritesPath, list2.ToArray(), Encoding.UTF8);
			}
			catch
			{
			}
		}

		private static string Serialize(SongInfo s)
		{
			if (s == null)
			{
				return null;
			}
			string text = (string.IsNullOrEmpty(s.SourceId) ? s.Id.ToString() : s.SourceId);
			return string.Join('\u0001'.ToString(), Platforms.ToInt(s.Platform).ToString(), text, Safe(s.Name), Safe(s.Artists), Safe(s.Album), s.DurationMs.ToString());
		}

		private static SongInfo ParseLine(string raw)
		{
			if (string.IsNullOrEmpty(raw))
			{
				return null;
			}
			string[] array = raw.Split(new char[1] { '\u0001' });
			if (array.Length < 6)
			{
				return null;
			}
			try
			{
				int i = int.Parse(array[0]);
				long durationMs = long.Parse(array[5]);
				SongInfo songInfo = new SongInfo
				{
					Platform = Platforms.FromInt(i),
					Name = array[2],
					Artists = array[3],
					Album = array[4],
					DurationMs = durationMs
				};
				if (long.TryParse(array[1], out var result))
				{
					songInfo.Id = result;
				}
				else
				{
					songInfo.SourceId = array[1];
				}
				return songInfo;
			}
			catch
			{
				return null;
			}
		}

		private static string Safe(string v)
		{
			return (v ?? "").Replace('\u0001', ' ').Replace("\r", " ").Replace("\n", " ");
		}
	}
	internal sealed class MqttWsClient : IDisposable
	{
		private const int SubPacketId = 1;

		private ClientWebSocket _ws;

		private readonly List<byte> _rxAcc = new List<byte>();

		private BlockingCollection<byte[]> _packets;

		private Task _rxLoop;

		private readonly SemaphoreSlim _sendLock = new SemaphoreSlim(1, 1);

		private volatile bool _disposed;

		public async Task<string> ConnectAsync(string host, int port, string path, IDictionary<string, string> headers, string clientId, IDictionary<string, string> connectUserProps, CancellationToken ct)
		{
			string cur = path;
			ClientWebSocket ws;
			string serverRef;
			for (int attempt = 0; attempt < 4; Shutdown(ws), cur = BuildRedirectPath(cur, serverRef), attempt++)
			{
				ws = new ClientWebSocket();
				try
				{
					ws.Options.AddSubProtocol("mqtt");
				}
				catch
				{
				}
				if (headers != null)
				{
					foreach (KeyValuePair<string, string> header in headers)
					{
						try
						{
							ws.Options.SetRequestHeader(header.Key, header.Value);
						}
						catch
						{
						}
					}
				}
				await ws.ConnectAsync(new Uri("wss://" + host + ":" + port + cur), ct).ConfigureAwait(continueOnCapturedContext: false);
				_packets = new BlockingCollection<byte[]>(64);
				_rxAcc.Clear();
				StartRxLoop(ws);
				await SendAsync(ws, BuildConnect(clientId, connectUserProps), ct).ConfigureAwait(continueOnCapturedContext: false);
				byte[] array = TakePacket(20000);
				if (array == null)
				{
					Shutdown(ws);
					throw new InvalidOperationException("MQTT CONNACK 超时");
				}
				int reason;
				string text = ParseConnAckProps(array, out reason, out serverRef);
				switch (reason)
				{
				case 0:
					_ws = ws;
					return cur;
				case 156:
				case 157:
					if (!string.IsNullOrEmpty(serverRef))
					{
						continue;
					}
					break;
				}
				Shutdown(ws);
				throw new InvalidOperationException("MQTT 连接被拒 reason=0x" + reason.ToString("X2") + text);
			}
			throw new InvalidOperationException("MQTT 重定向次数超限");
		}

		public async Task SubscribeAsync(string topic, IDictionary<string, string> subUserProps, CancellationToken ct)
		{
			ClientWebSocket ws = _ws;
			if (ws == null)
			{
				throw new InvalidOperationException("MQTT 未连接");
			}
			await SendAsync(ws, BuildSubscribe(topic, subUserProps), ct).ConfigureAwait(continueOnCapturedContext: false);
			DateTime dateTime = DateTime.UtcNow.AddSeconds(10.0);
			while (DateTime.UtcNow < dateTime)
			{
				byte[] array = TakePacket(2000);
				if (array == null || ((array[0] >> 4) & 0xF) != 9)
				{
					continue;
				}
				int pos = 1;
				ReadVarint(array, ref pos);
				pos += 2;
				int num = ReadVarint(array, ref pos);
				pos += num;
				for (int i = pos; i < array.Length; i++)
				{
					if (array[i] >= 128)
					{
						throw new InvalidOperationException("MQTT SUBACK 拒绝 reason=0x" + array[i].ToString("X2"));
					}
				}
				return;
			}
			throw new InvalidOperationException("MQTT SUBACK 超时");
		}

		public MqttWsMessage ReceiveMessage(TimeSpan wait)
		{
			DateTime dateTime = DateTime.UtcNow + wait;
			byte[] array;
			do
			{
				int num = (int)(dateTime - DateTime.UtcNow).TotalMilliseconds;
				if (num <= 0)
				{
					return null;
				}
				array = TakePacket(num);
				if (array == null)
				{
					return null;
				}
			}
			while (((array[0] >> 4) & 0xF) != 3);
			return ParsePublish(array);
		}

		public Task PingAsync(CancellationToken ct)
		{
			ClientWebSocket ws = _ws;
			if (ws == null)
			{
				throw new InvalidOperationException("MQTT 未连接");
			}
			return SendAsync(ws, new byte[2] { 192, 0 }, ct);
		}

		private void StartRxLoop(ClientWebSocket ws)
		{
			_rxLoop = Task.Run(async delegate
			{
				byte[] buf = new byte[8192];
				try
				{
					while (!_disposed)
					{
						WebSocketReceiveResult webSocketReceiveResult = await ws.ReceiveAsync(new ArraySegment<byte>(buf), CancellationToken.None).ConfigureAwait(continueOnCapturedContext: false);
						if (webSocketReceiveResult.MessageType == WebSocketMessageType.Close)
						{
							break;
						}
						for (int i = 0; i < webSocketReceiveResult.Count; i++)
						{
							_rxAcc.Add(buf[i]);
						}
						byte[] item;
						while ((item = TryTakePacket()) != null)
						{
							if (_packets != null && !_packets.IsAddingCompleted)
							{
								try
								{
									_packets.Add(item);
								}
								catch
								{
									return;
								}
							}
						}
					}
				}
				catch
				{
				}
			});
		}

		private byte[] TakePacket(int timeoutMs)
		{
			BlockingCollection<byte[]> packets = _packets;
			if (packets == null)
			{
				return null;
			}
			if (!packets.TryTake(out var item, timeoutMs))
			{
				return null;
			}
			return item;
		}

		private byte[] TryTakePacket()
		{
			if (_rxAcc.Count < 2)
			{
				return null;
			}
			int num = 1;
			int num2 = 0;
			int i = 1;
			bool flag = false;
			for (; i < _rxAcc.Count && i <= 4; i++)
			{
				int num3 = _rxAcc[i];
				num2 += (num3 & 0x7F) * num;
				num *= 128;
				if ((num3 & 0x80) == 0)
				{
					flag = true;
					break;
				}
			}
			if (!flag)
			{
				return null;
			}
			int num4 = i + 1;
			if (_rxAcc.Count < num4 + num2)
			{
				return null;
			}
			byte[] array = new byte[num4 + num2];
			_rxAcc.CopyTo(0, array, 0, array.Length);
			_rxAcc.RemoveRange(0, array.Length);
			return array;
		}

		private void Shutdown(ClientWebSocket ws)
		{
			try
			{
				if (_packets != null)
				{
					_packets.CompleteAdding();
				}
			}
			catch
			{
			}
			try
			{
				ws.Dispose();
			}
			catch
			{
			}
		}

		private Task SendAsync(ClientWebSocket ws, byte[] packet, CancellationToken ct)
		{
			return _sendLock.WaitAsync(ct).ContinueWith((Func<Task, Task>)async delegate
			{
				try
				{
					await ws.SendAsync(new ArraySegment<byte>(packet), WebSocketMessageType.Binary, endOfMessage: true, ct).ConfigureAwait(continueOnCapturedContext: false);
				}
				finally
				{
					try
					{
						_sendLock.Release();
					}
					catch
					{
					}
				}
			}, CancellationToken.None).Unwrap();
		}

		private static byte[] BuildConnect(string clientId, IDictionary<string, string> userProps)
		{
			List<byte> list = new List<byte>();
			list.AddRange(new byte[10] { 0, 4, 77, 81, 84, 84, 5, 2, 0, 45 });
			List<byte> list2 = new List<byte>();
			list2.Add(21);
			AddUtf8(list2, "pass");
			if (userProps != null)
			{
				foreach (KeyValuePair<string, string> userProp in userProps)
				{
					list2.Add(38);
					AddUtf8(list2, userProp.Key);
					AddUtf8(list2, userProp.Value);
				}
			}
			AddVarint(list, list2.Count);
			list.AddRange(list2);
			AddUtf8(list, clientId);
			return Wrap(16, list);
		}

		private static byte[] BuildSubscribe(string topic, IDictionary<string, string> userProps)
		{
			List<byte> list = new List<byte>();
			list.Add(0);
			list.Add(1);
			List<byte> list2 = new List<byte>();
			if (userProps != null)
			{
				foreach (KeyValuePair<string, string> userProp in userProps)
				{
					list2.Add(38);
					AddUtf8(list2, userProp.Key);
					AddUtf8(list2, userProp.Value);
				}
			}
			AddVarint(list, list2.Count);
			list.AddRange(list2);
			AddUtf8(list, topic);
			list.Add(0);
			return Wrap(130, list);
		}

		private static byte[] Wrap(int typeFlags, List<byte> body)
		{
			List<byte> obj = new List<byte> { (byte)typeFlags };
			AddVarint(obj, body.Count);
			obj.AddRange(body);
			return obj.ToArray();
		}

		private static void AddUtf8(List<byte> buf, string s)
		{
			byte[] bytes = Encoding.UTF8.GetBytes(s ?? "");
			buf.Add((byte)(bytes.Length >> 8));
			buf.Add((byte)(bytes.Length & 0xFF));
			buf.AddRange(bytes);
		}

		private static void AddVarint(List<byte> buf, int value)
		{
			do
			{
				int num = value % 128;
				value /= 128;
				if (value > 0)
				{
					num |= 0x80;
				}
				buf.Add((byte)num);
			}
			while (value > 0);
		}

		private static string ParseConnAckProps(byte[] ack, out int reason, out string serverRef)
		{
			serverRef = null;
			reason = -1;
			if (ack.Length < 3)
			{
				return null;
			}
			int pos = 1;
			ReadVarint(ack, ref pos);
			if (pos + 2 > ack.Length)
			{
				return null;
			}
			pos++;
			reason = ack[pos++];
			int num = ReadVarint(ack, ref pos);
			string text = "";
			int num2 = Math.Min(ack.Length, pos + num);
			while (pos < num2)
			{
				switch (ack[pos++])
				{
				case 19:
					pos += 2;
					break;
				case 28:
					serverRef = ReadUtf8(ack, ref pos);
					break;
				case 31:
					text = text + " reason=" + ReadUtf8(ack, ref pos);
					break;
				case 38:
				{
					string text2 = ReadUtf8(ack, ref pos);
					string text3 = ReadUtf8(ack, ref pos);
					text = text + " " + text2 + "=" + text3;
					break;
				}
				default:
					pos = num2;
					break;
				}
			}
			return text;
		}

		private static MqttWsMessage ParsePublish(byte[] pkt)
		{
			int num = ((pkt[0] & 0xF) >> 1) & 3;
			int pos = 1;
			ReadVarint(pkt, ref pos);
			MqttWsMessage mqttWsMessage = new MqttWsMessage
			{
				Topic = ReadUtf8(pkt, ref pos)
			};
			if (num > 0)
			{
				pos += 2;
			}
			int num2 = ReadVarint(pkt, ref pos);
			int num3 = Math.Min(pkt.Length, pos + num2);
			while (pos < num3)
			{
				switch (pkt[pos++])
				{
				case 1:
					pos++;
					break;
				case 2:
				case 17:
				case 24:
				case 39:
					pos += 4;
					break;
				case 3:
				case 8:
				case 18:
				case 21:
				case 26:
				case 28:
				case 31:
					ReadUtf8(pkt, ref pos);
					break;
				case 9:
				case 22:
				{
					int num4 = (pkt[pos] << 8) | pkt[pos + 1];
					pos += 2 + num4;
					break;
				}
				case 11:
					ReadVarint(pkt, ref pos);
					break;
				case 19:
				case 33:
				case 34:
				case 35:
					pos += 2;
					break;
				case 23:
				case 25:
				case 36:
				case 37:
				case 40:
				case 41:
				case 42:
					pos++;
					break;
				case 38:
				{
					string key = ReadUtf8(pkt, ref pos);
					string value = ReadUtf8(pkt, ref pos);
					mqttWsMessage.UserProps[key] = value;
					break;
				}
				default:
					pos = num3;
					break;
				}
			}
			if (pos < pkt.Length)
			{
				mqttWsMessage.Payload = Encoding.UTF8.GetString(pkt, pos, pkt.Length - pos);
			}
			return mqttWsMessage;
		}

		private static int ReadVarint(byte[] buf, ref int pos)
		{
			int num = 1;
			int num2 = 0;
			for (int i = 0; i < 4; i++)
			{
				if (pos >= buf.Length)
				{
					break;
				}
				int num3 = buf[pos++];
				num2 += (num3 & 0x7F) * num;
				num *= 128;
				if ((num3 & 0x80) == 0)
				{
					break;
				}
			}
			return num2;
		}

		private static string ReadUtf8(byte[] buf, ref int pos)
		{
			if (pos + 2 > buf.Length)
			{
				pos = buf.Length;
				return "";
			}
			int num = (buf[pos] << 8) | buf[pos + 1];
			pos += 2;
			if (pos + num > buf.Length)
			{
				num = buf.Length - pos;
			}
			string result = Encoding.UTF8.GetString(buf, pos, num);
			pos += num;
			return result;
		}

		private static string BuildRedirectPath(string path, string serverRef)
		{
			string text = path.TrimEnd(new char[1] { '/' });
			string[] array = text.Split(new char[1] { '/' });
			if (array.Length != 0 && array[^1].Contains(":"))
			{
				array[^1] = serverRef;
				return string.Join("/", array);
			}
			return text + "/" + serverRef;
		}

		public void Dispose()
		{
			_disposed = true;
			try
			{
				if (_packets != null)
				{
					_packets.CompleteAdding();
				}
			}
			catch
			{
			}
			try
			{
				if (_ws != null)
				{
					_ws.Dispose();
				}
			}
			catch
			{
			}
			_ws = null;
		}
	}
	internal sealed class MqttWsMessage
	{
		public string Topic = "";

		public Dictionary<string, string> UserProps = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);

		public string Payload = "";
	}
	public sealed class MusicSources : IDisposable
	{
		private readonly Throttle _throttle;

		public NeteaseClient Netease { get; private set; }

		public QqClient QQ { get; private set; }

		public MusicSources()
		{
			_throttle = new Throttle();
			Netease = new NeteaseClient(_throttle);
			QQ = new QqClient(_throttle);
		}

		public string LoginLine(Platform p)
		{
			if (p == Platform.QQ)
			{
				if (!QQ.HasLogin)
				{
					return "QQ音乐未登录（付费曲会取不到）";
				}
				return "QQ音乐已登录";
			}
			if (!Netease.HasLogin)
			{
				return "网易云未登录（会员曲会 -110）";
			}
			if (!Netease.VipKnown)
			{
				Netease.RefreshAccount();
			}
			if (Netease.VipKnown && !Netease.AccountValid)
			{
				return "网易云登录态已失效（面板里退出后重新扫码）";
			}
			if (Netease.VipKnown && Netease.HasVip)
			{
				return "网易云已登录 · " + ((Netease.VipType == 11) ? "黑胶VIP" : "会员");
			}
			if (Netease.VipKnown)
			{
				return "网易云已登录 · 非会员（会员曲只能试听）";
			}
			return "网易云已登录";
		}

		public Task<List<SongInfo>> SearchAsync(Platform platform, string keyword, int limit, int offset, CancellationToken ct = default(CancellationToken))
		{
			if (platform == Platform.QQ)
			{
				return QQ.SearchAsync(keyword, limit, offset, ct);
			}
			return Netease.SearchAsync(keyword, limit, offset, ct);
		}

		public Task<SongUrlResult> GetUrlAsync(SongInfo song, CancellationToken ct = default(CancellationToken))
		{
			if (song == null)
			{
				return Task.FromResult(new SongUrlResult
				{
					Code = -1,
					Message = "song 为空"
				});
			}
			if (song.Platform == Platform.QQ)
			{
				return QQ.GetSongUrlAsync(song, ct);
			}
			return Netease.GetSongUrlAsync(song.Id, "exhigh", ct);
		}

		public Task<LyricResult> GetLyricAsync(SongInfo song, CancellationToken ct = default(CancellationToken))
		{
			if (song == null)
			{
				return Task.FromResult(new LyricResult());
			}
			if (song.Platform == Platform.QQ)
			{
				return QQ.GetLyricAsync(song, ct);
			}
			return Netease.GetLyricAsync(song.Id, ct);
		}

		public void Dispose()
		{
			try
			{
				if (Netease != null)
				{
					Netease.Dispose();
				}
			}
			catch
			{
			}
			try
			{
				if (QQ != null)
				{
					QQ.Dispose();
				}
			}
			catch
			{
			}
			try
			{
				_throttle.Dispose();
			}
			catch
			{
			}
		}
	}
	public enum Platform
	{
		Netease,
		QQ
	}
	public static class Platforms
	{
		public static readonly Platform[] All = new Platform[2]
		{
			Platform.Netease,
			Platform.QQ
		};

		public static string DisplayName(Platform p)
		{
			if (p == Platform.QQ)
			{
				return "QQ音乐";
			}
			return "网易云";
		}

		public static int BrandRgb(Platform p)
		{
			if (p == Platform.QQ)
			{
				return 3261052;
			}
			return 15288135;
		}

		public static string BrandHex(Platform p)
		{
			return "#" + BrandRgb(p).ToString("X6");
		}

		public static void BrandColor(Platform p, out float r, out float g, out float b)
		{
			int num = BrandRgb(p);
			r = (float)((num >> 16) & 0xFF) / 255f;
			g = (float)((num >> 8) & 0xFF) / 255f;
			b = (float)(num & 0xFF) / 255f;
		}

		public static Platform FromInt(int i)
		{
			if (i < 0 || i >= All.Length)
			{
				return Platform.Netease;
			}
			return All[i];
		}

		public static int ToInt(Platform p)
		{
			for (int i = 0; i < All.Length; i++)
			{
				if (All[i] == p)
				{
					return i;
				}
			}
			return 0;
		}
	}
	public sealed class PlaylistInfo
	{
		public string Id = "";

		public string Name = "";

		public string CoverUrl = "";

		public int TrackCount;

		public string Creator = "";

		public bool IsFavorites;

		public Platform Platform;

		public int DirId;

		public string Key => Platform.ToString() + ":" + Id;

		public string Subtitle
		{
			get
			{
				string text = ((TrackCount > 0) ? (TrackCount + " 首") : "歌单");
				if (!string.IsNullOrEmpty(Creator))
				{
					return text + " · " + Creator;
				}
				return text;
			}
		}

		public override string ToString()
		{
			return Platform.ToString() + "/" + Name + "(" + Id + ")";
		}
	}
	public static class PngDecoder
	{
		public sealed class Image
		{
			public int Width;

			public int Height;

			public byte[] Pixels;
		}

		public static Image Decode(byte[] png)
		{
			if (png == null || png.Length < 8)
			{
				return null;
			}
			if (png[0] != 137 || png[1] != 80 || png[2] != 78 || png[3] != 71)
			{
				return null;
			}
			int num = 8;
			int num2 = 0;
			int num3 = 0;
			int num4 = 0;
			int num5 = 0;
			byte[] array = null;
			byte[] array2 = null;
			byte[] array3 = null;
			int num6;
			int num7;
			for (; num + 8 <= png.Length; num = num7 + num6 + 4)
			{
				num6 = ReadInt32(png, num);
				string text = new string(new char[4]
				{
					(char)png[num + 4],
					(char)png[num + 5],
					(char)png[num + 6],
					(char)png[num + 7]
				});
				num7 = num + 8;
				switch (text)
				{
				case "IHDR":
					num2 = ReadInt32(png, num7);
					num3 = ReadInt32(png, num7 + 4);
					num4 = png[num7 + 8];
					num5 = png[num7 + 9];
					continue;
				case "IDAT":
					array = Append(array, png, num7, num6);
					continue;
				case "PLTE":
					array2 = new byte[num6];
					Array.Copy(png, num7, array2, 0, num6);
					continue;
				case "tRNS":
					array3 = new byte[num6];
					Array.Copy(png, num7, array3, 0, num6);
					continue;
				default:
					continue;
				case "IEND":
					break;
				}
				break;
			}
			if (num2 <= 0 || num3 <= 0 || array == null)
			{
				return null;
			}
			int num8;
			switch (num5)
			{
			case 0:
				num8 = 1;
				break;
			case 2:
				num8 = 3;
				break;
			case 3:
				num8 = 1;
				break;
			case 4:
				num8 = 2;
				break;
			case 6:
				num8 = 4;
				break;
			default:
				return null;
			}
			if (num4 != 1 && num4 != 2 && num4 != 4 && num4 != 8 && num4 != 16)
			{
				return null;
			}
			int num9 = ((num4 < 8) ? 1 : (num8 * num4 / 8));
			int num10 = ((num4 >= 8) ? (num2 * num9) : ((num2 * num8 * num4 + 7) / 8));
			int num11 = 0;
			if (array.Length >= 2 && (array[0] & 0xF) == 8 && ((array[0] << 8) + array[1]) % 31 == 0)
			{
				num11 = 2;
			}
			byte[] array4;
			using (MemoryStream stream = new MemoryStream(array, num11, array.Length - num11))
			{
				using DeflateStream s = new DeflateStream(stream, CompressionMode.Decompress);
				array4 = ReadAll(s, (num10 + 1) * num3);
			}
			if (array4 == null || array4.Length < (num10 + 1) * num3)
			{
				return null;
			}
			byte[] array5 = new byte[num10 * num3];
			int num12 = 0;
			for (int i = 0; i < num3; i++)
			{
				int num13 = array4[num12++];
				int num14 = i * num10;
				for (int j = 0; j < num10; j++)
				{
					int num15 = ((j >= num9) ? array5[num14 + j - num9] : 0);
					int num16 = ((i > 0) ? array5[num14 - num10 + j] : 0);
					int c = ((j >= num9 && i > 0) ? array5[num14 - num10 + j - num9] : 0);
					int num17 = array4[num12++];
					switch (num13)
					{
					case 1:
						num17 = (num17 + num15) & 0xFF;
						break;
					case 2:
						num17 = (num17 + num16) & 0xFF;
						break;
					case 3:
						num17 = (num17 + (num15 + num16 >> 1)) & 0xFF;
						break;
					case 4:
						num17 = (num17 + Paeth(num15, num16, c)) & 0xFF;
						break;
					}
					array5[num14 + j] = (byte)num17;
				}
			}
			byte[] array6 = new byte[num2 * num3 * 4];
			int num18 = 0;
			for (int k = 0; k < num3; k++)
			{
				for (int l = 0; l < num2; l++)
				{
					int num19 = k * num2 + l;
					byte b = byte.MaxValue;
					byte b2;
					byte b3;
					byte b4;
					if (num4 < 8)
					{
						int num20 = Sample(array5, k * num10, l * num8, num4);
						if (num5 == 3)
						{
							if (array2 != null && num20 * 3 + 2 < array2.Length)
							{
								b2 = array2[num20 * 3];
								b3 = array2[num20 * 3 + 1];
								b4 = array2[num20 * 3 + 2];
							}
							else
							{
								b2 = (b3 = (b4 = 0));
							}
							if (array3 != null && num20 < array3.Length)
							{
								b = array3[num20];
							}
						}
						else
						{
							int num21 = (1 << num4) - 1;
							b2 = (b3 = (b4 = (byte)((num21 > 0) ? ((byte)(num20 * 255 / num21)) : 0)));
						}
					}
					else if (num5 == 3)
					{
						int num22 = array5[num19 * num8];
						if (array2 != null && num22 * 3 + 2 < array2.Length)
						{
							b2 = array2[num22 * 3];
							b3 = array2[num22 * 3 + 1];
							b4 = array2[num22 * 3 + 2];
						}
						else
						{
							b2 = (b3 = (b4 = 0));
						}
						if (array3 != null && num22 < array3.Length)
						{
							b = array3[num22];
						}
					}
					else if (num8 >= 3)
					{
						int num23 = num19 * num8 * (num4 / 8);
						b2 = array5[num23];
						b3 = array5[num23 + num4 / 8];
						b4 = array5[num23 + 2 * (num4 / 8)];
						if (num8 == 4)
						{
							b = array5[num23 + 3 * (num4 / 8)];
						}
					}
					else
					{
						int num24 = (k * num10 + l * num8) * (num4 / 8);
						b2 = (b3 = (b4 = array5[num24]));
						if (num8 == 2)
						{
							b = array5[num24 + num4 / 8];
						}
					}
					array6[num18++] = b2;
					array6[num18++] = b3;
					array6[num18++] = b4;
					array6[num18++] = b;
				}
			}
			return new Image
			{
				Width = num2,
				Height = num3,
				Pixels = array6
			};
		}

		private static int Sample(byte[] data, int rowStart, int col, int bitDepth)
		{
			int num = rowStart * 8 + col * bitDepth;
			int num2 = num >> 3;
			int num3 = 8 - bitDepth - (num & 7);
			return (data[num2] >> num3) & ((1 << bitDepth) - 1);
		}

		private static int Paeth(int a, int b, int c)
		{
			int num = a + b - c;
			int num2 = Math.Abs(num - a);
			int num3 = Math.Abs(num - b);
			int num4 = Math.Abs(num - c);
			if (num2 <= num3 && num2 <= num4)
			{
				return a;
			}
			if (num3 <= num4)
			{
				return b;
			}
			return c;
		}

		private static int ReadInt32(byte[] buf, int off)
		{
			return (buf[off] << 24) | (buf[off + 1] << 16) | (buf[off + 2] << 8) | buf[off + 3];
		}

		private static byte[] Append(byte[] dst, byte[] src, int off, int len)
		{
			if (dst == null)
			{
				dst = new byte[0];
			}
			byte[] array = new byte[dst.Length + len];
			Array.Copy(dst, 0, array, 0, dst.Length);
			Array.Copy(src, off, array, dst.Length, len);
			return array;
		}

		private static byte[] ReadAll(Stream s, int expected)
		{
			using MemoryStream memoryStream = new MemoryStream();
			byte[] array = new byte[8192];
			int count;
			while ((count = s.Read(array, 0, array.Length)) > 0)
			{
				memoryStream.Write(array, 0, count);
				if (memoryStream.Length > expected * 2)
				{
					break;
				}
			}
			return memoryStream.ToArray();
		}
	}
	public sealed class QqClient : IDisposable
	{
		private sealed class RedirectResult
		{
			public string Location;

			public string Body;
		}

		private const string SearchUrl = "https://c.y.qq.com/soso/fcgi-bin/client_search_cp";

		private const string FcgUrl = "https://u.y.qq.com/cgi-bin/musicu.fcg";

		private const string LyricUrl = "https://c.y.qq.com/lyric/fcgi-bin/fcg_query_lyric_new.fcg";

		private const string CoverUrl = "https://y.gtimg.cn/music/photo_new/T002R300x300M000";

		private const string PtXLogin = "https://xui.ptlogin2.qq.com/cgi-bin/xlogin";

		private const string PtQrShow = "https://ssl.ptlogin2.qq.com/ptqrshow";

		private const string PtQrLogin = "https://ssl.ptlogin2.qq.com/ptqrlogin";

		private const string Mp3Prefix = "M500";

		private const string Mp3PrefixHi = "M800";

		private const string Referer = "https://y.qq.com/portal/player.html";

		private const string PtReferer = "https://xui.ptlogin2.qq.com/";

		private string _lastSetCookie = "";

		private const string UserAgent = "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36";

		private HttpClient _http;

		private HttpClient _cookielessHttp;

		private HttpClientHandler _handler;

		private CookieContainer _cookies = new CookieContainer();

		private readonly Throttle _throttle;

		private readonly Random _rng = new Random(Environment.TickCount * 17);

		private string _savedCookie;

		private string _uin = "";

		private string _guid = "";

		private readonly Dictionary<string, string> _mediaMidCache = new Dictionary<string, string>(StringComparer.Ordinal);

		private string _qrsig = "";

		private string _loginSig = "";

		private string _lastOauthTrace = "";

		private string _appQrId = "";

		private MqttWsClient _appMqtt;

		private CancellationTokenSource _appCts;

		private readonly object _appLock = new object();

		private QqLoginResult _appState = new QqLoginResult
		{
			State = QqLoginResult.QqLoginState.Unknown
		};

		private int _loginType = 2;

		private string _lastDesktopError = "";

		private string _encryptUin;

		public string CookieText => HarvestCookies() ?? _savedCookie ?? "";

		public bool HasLogin
		{
			get
			{
				if (string.IsNullOrEmpty(_uin))
				{
					return false;
				}
				if (!string.IsNullOrEmpty(LookupCookie("qm_keyst")))
				{
					return true;
				}
				if (!string.IsNullOrEmpty(LookupCookie("qqmusic_key")))
				{
					return true;
				}
				return !string.IsNullOrEmpty(LookupCookie("musickey"));
			}
		}

		public string Uin
		{
			get
			{
				if (!string.IsNullOrEmpty(_uin))
				{
					return _uin;
				}
				return "0";
			}
		}

		private string Authst
		{
			get
			{
				string text = LookupCookie("qqmusic_key");
				if (string.IsNullOrEmpty(text))
				{
					text = LookupCookie("qm_keyst");
				}
				if (string.IsNullOrEmpty(text))
				{
					text = LookupCookie("musickey");
				}
				return text ?? "";
			}
		}

		public QqClient(Throttle throttle = null)
		{
			//IL_00d0: Unknown result type (might be due to invalid IL or missing references)
			//IL_00d5: Unknown result type (might be due to invalid IL or missing references)
			//IL_00dc: Unknown result type (might be due to invalid IL or missing references)
			//IL_00e8: Expected O, but got Unknown
			//IL_00e3: Unknown result type (might be due to invalid IL or missing references)
			//IL_00e9: Expected O, but got Unknown
			NewSession();
			_throttle = throttle ?? new Throttle();
			HttpClient val = new HttpClient((HttpMessageHandler)new HttpClientHandler
			{
				AutomaticDecompression = (DecompressionMethods.GZip | DecompressionMethods.Deflate),
				UseCookies = false
			});
			val.Timeout = TimeSpan.FromSeconds(20.0);
			_cookielessHttp = val;
			((HttpHeaders)_cookielessHttp.DefaultRequestHeaders).TryAddWithoutValidation("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36");
			((HttpHeaders)_cookielessHttp.DefaultRequestHeaders).TryAddWithoutValidation("Referer", "https://y.qq.com/portal/player.html");
			_savedCookie = EnsureComplete(QqCookieStore.Load());
			if (!string.IsNullOrEmpty(_savedCookie) && _savedCookie != QqCookieStore.Load())
			{
				QqCookieStore.Save(_savedCookie);
			}
			LoadCookiesIntoContainer(_savedCookie);
			RefreshUin();
			string text = LookupKey();
			_loginType = ((!string.IsNullOrEmpty(text) && text.StartsWith("W_X", StringComparison.Ordinal)) ? 1 : 2);
			EnsureGuid();
		}

		private void NewSession()
		{
			//IL_0007: Unknown result type (might be due to invalid IL or missing references)
			//IL_000d: Expected O, but got Unknown
			//IL_0040: Unknown result type (might be due to invalid IL or missing references)
			//IL_004a: Expected O, but got Unknown
			//IL_0045: Unknown result type (might be due to invalid IL or missing references)
			//IL_004a: Unknown result type (might be due to invalid IL or missing references)
			//IL_005f: Expected O, but got Unknown
			HttpClient http = _http;
			HttpClientHandler val = new HttpClientHandler();
			val.AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate;
			val.UseCookies = true;
			val.CookieContainer = new CookieContainer();
			HttpClientHandler val2 = (_handler = val);
			_cookies = val2.CookieContainer;
			HttpClient val3 = new HttpClient((HttpMessageHandler)val2)
			{
				Timeout = TimeSpan.FromSeconds(20.0)
			};
			((HttpHeaders)val3.DefaultRequestHeaders).TryAddWithoutValidation("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36");
			((HttpHeaders)val3.DefaultRequestHeaders).TryAddWithoutValidation("Referer", "https://y.qq.com/portal/player.html");
			_http = val3;
			if (http != null)
			{
				try
				{
					((HttpMessageInvoker)http).Dispose();
				}
				catch
				{
				}
			}
		}

		private string LookupCookie(string name)
		{
			if (!QqCookieStore.Parse(CookieText).TryGetValue(name, out var value))
			{
				return null;
			}
			return value;
		}

		private void RefreshUin()
		{
			_uin = Digits(LookupCookie("uin") ?? LookupCookie("p_uin") ?? LookupCookie("wxuin") ?? "");
		}

		private static string Digits(string raw)
		{
			string text = (raw ?? "").Trim();
			if (text.Length == 0)
			{
				return "";
			}
			if (text[0] == 'o' || text[0] == 'O')
			{
				text = text.Substring(1);
			}
			text = text.TrimStart(new char[1] { '0' });
			if (text.Length != 0)
			{
				return text;
			}
			return "0";
		}

		private static string OFormat(string digits)
		{
			if (!string.IsNullOrEmpty(digits))
			{
				return "o0" + digits;
			}
			return "";
		}

		private static string EnsureComplete(string cookieText)
		{
			Dictionary<string, string> dictionary = QqCookieStore.Parse(cookieText);
			if (dictionary.Count == 0)
			{
				return cookieText;
			}
			string value = null;
			string[] array = new string[3] { "qm_keyst", "qqmusic_key", "musickey" };
			for (int i = 0; i < array.Length; i++)
			{
				if (dictionary.TryGetValue(array[i], out var value2) && !string.IsNullOrEmpty(value2))
				{
					value = value2;
					break;
				}
			}
			if (!string.IsNullOrEmpty(value))
			{
				dictionary["qm_keyst"] = value;
				dictionary["qqmusic_key"] = value;
				dictionary["musickey"] = value;
			}
			string raw = null;
			string[] array2 = new string[3] { "uin", "p_uin", "wxuin" };
			for (int j = 0; j < array2.Length; j++)
			{
				if (dictionary.TryGetValue(array2[j], out var value3) && !string.IsNullOrEmpty(value3))
				{
					raw = value3;
					break;
				}
			}
			string text = Digits(raw);
			if (!string.IsNullOrEmpty(text))
			{
				dictionary["uin"] = OFormat(text);
				dictionary["p_uin"] = OFormat(text);
				dictionary["pt2gguin"] = OFormat(text);
				dictionary["qqmusic_uin"] = text;
			}
			return QqCookieStore.Normalize(dictionary);
		}

		private string EnsureGuid()
		{
			if (!string.IsNullOrEmpty(_guid))
			{
				return _guid;
			}
			try
			{
				string path = Path.Combine(QqCookieStore.Dir, "qq_guid.txt");
				if (File.Exists(path))
				{
					string text = File.ReadAllText(path, Encoding.UTF8).Trim();
					if (text.Length >= 6)
					{
						_guid = text;
						return _guid;
					}
				}
				_guid = _rng.Next(100000000, 2000000000).ToString();
				Directory.CreateDirectory(QqCookieStore.Dir);
				File.WriteAllText(path, _guid, Encoding.UTF8);
			}
			catch
			{
				_guid = "10000";
			}
			return _guid;
		}

		public void SetCookie(string cookieText)
		{
			cookieText = EnsureComplete(cookieText);
			ClearCookieContainer();
			LoadCookiesIntoContainer(cookieText);
			QqCookieStore.Save(QqCookieStore.Normalize(QqCookieStore.Parse(cookieText)));
			_savedCookie = QqCookieStore.Load();
			RefreshUin();
			EnsureGuid();
		}

		private void ClearCookieContainer()
		{
			try
			{
				foreach (Cookie cookie in _cookies.GetCookies(new Uri("https://y.qq.com")))
				{
					cookie.Expired = true;
				}
				foreach (Cookie cookie2 in _cookies.GetCookies(new Uri("https://u.y.qq.com")))
				{
					cookie2.Expired = true;
				}
			}
			catch
			{
			}
		}

		public void Logout()
		{
			QqCookieStore.Clear();
			_savedCookie = "";
			_uin = "";
			_qrsig = "";
			_loginSig = "";
			ClearCookieContainer();
			try
			{
				foreach (Cookie cookie in _cookies.GetCookies(new Uri("https://ptlogin2.qq.com/")))
				{
					cookie.Expired = true;
				}
			}
			catch
			{
			}
		}

		public Task<List<SongInfo>> SearchAsync(string keyword, int limit = 40, int offset = 0, CancellationToken ct = default(CancellationToken))
		{
			return _throttle.RunAsync(async delegate
			{
				int num = offset / Math.Max(1, limit) + 1;
				string url = "https://c.y.qq.com/soso/fcgi-bin/client_search_cp?format=json&t=0&p=" + num + "&n=" + limit + "&w=" + Uri.EscapeDataString(keyword ?? "");
				return ParseSearch(await GetAsync(url, ct).ConfigureAwait(continueOnCapturedContext: false));
			}, ct);
		}

		private static List<SongInfo> ParseSearch(string json)
		{
			List<SongInfo> list = new List<SongInfo>();
			Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(json));
			if (dictionary == null)
			{
				return list;
			}
			Dictionary<string, object> dictionary2 = MiniJson.Dict(dictionary, "data");
			Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "song") : null);
			List<object> list2 = ((dictionary3 != null) ? MiniJson.List(dictionary3, "list") : null);
			if (list2 == null)
			{
				return list;
			}
			foreach (object item in list2)
			{
				Dictionary<string, object> dictionary4 = MiniJson.AsObject(item);
				if (dictionary4 == null)
				{
					continue;
				}
				string text = MiniJson.Str(dictionary4, "songmid", "");
				if (string.IsNullOrEmpty(text))
				{
					continue;
				}
				SongInfo songInfo = new SongInfo
				{
					Platform = Platform.QQ,
					SourceId = text,
					Id = StableId(text),
					Name = MiniJson.Str(dictionary4, "songname", "?"),
					Album = MiniJson.Str(dictionary4, "albumname", ""),
					DurationMs = MiniJson.Lng(dictionary4, "interval", 0L) * 1000
				};
				string text2 = MiniJson.Str(dictionary4, "media_mid", "");
				songInfo.MediaMid = (string.IsNullOrEmpty(text2) ? text : text2);
				List<object> list3 = MiniJson.List(dictionary4, "singer");
				if (list3 != null)
				{
					List<string> list4 = new List<string>();
					foreach (object item2 in list3)
					{
						Dictionary<string, object> dictionary5 = MiniJson.AsObject(item2);
						string text3 = ((dictionary5 != null) ? MiniJson.Str(dictionary5, "name", "") : "");
						if (!string.IsNullOrEmpty(text3))
						{
							list4.Add(text3);
						}
					}
					songInfo.Artists = string.Join(" / ", list4.ToArray());
				}
				string text4 = MiniJson.Str(dictionary4, "albummid", "");
				if (!string.IsNullOrEmpty(text4))
				{
					songInfo.AlbumPicUrl = "https://y.gtimg.cn/music/photo_new/T002R300x300M000" + text4 + ".jpg?max_age=2592000";
				}
				Dictionary<string, object> dictionary6 = MiniJson.Dict(dictionary4, "pay");
				int num = (int)((dictionary6 != null) ? MiniJson.Lng(dictionary6, "payplay", 0L) : 0);
				songInfo.Fee = ((num != 0) ? 1 : 0);
				songInfo.PrivilegeSt = 0;
				list.Add(songInfo);
			}
			return list;
		}

		private void LoadCookiesIntoContainer(string cookieText)
		{
			foreach (KeyValuePair<string, string> item in QqCookieStore.Parse(cookieText))
			{
				try
				{
					_cookies.Add(new Uri("https://y.qq.com/"), new Cookie(item.Key, item.Value)
					{
						Domain = ".qq.com",
						Path = "/"
					});
				}
				catch
				{
				}
			}
		}

		private string HarvestCookies()
		{
			try
			{
				Dictionary<string, string> dictionary = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
				Uri[] array = new Uri[6]
				{
					new Uri("https://y.qq.com/"),
					new Uri("https://qq.com/"),
					new Uri("https://ptlogin2.qq.com/"),
					new Uri("https://ssl.ptlogin2.qq.com/"),
					new Uri("https://ssl.ptlogin2.graph.qq.com/"),
					new Uri("https://graph.qq.com/")
				};
				foreach (Uri uri in array)
				{
					foreach (Cookie cookie in _cookies.GetCookies(uri))
					{
						if (!string.IsNullOrEmpty(cookie.Value))
						{
							dictionary[cookie.Name] = cookie.Value;
						}
					}
				}
				string text = QqCookieStore.Normalize(dictionary);
				if (string.IsNullOrEmpty(text))
				{
					return null;
				}
				if (text != _savedCookie && QqCookieStore.Parse(text).ContainsKey("qqmusic_key"))
				{
					QqCookieStore.Save(text);
					_savedCookie = text;
				}
				return text;
			}
			catch
			{
				return null;
			}
		}

		private static int Hash33(string s)
		{
			return Hash33(s, 0);
		}

		private static int Hash33(string s, int seed)
		{
			int num = seed;
			if (string.IsNullOrEmpty(s))
			{
				return num & 0x7FFFFFFF;
			}
			for (int i = 0; i < s.Length; i++)
			{
				num = (num << 5) + num + s[i];
			}
			return num & 0x7FFFFFFF;
		}

		public Task<byte[]> QrBeginAsync(CancellationToken ct = default(CancellationToken))
		{
			return _throttle.RunAsync(async delegate
			{
				NewSession();
				_qrsig = "";
				_loginSig = "";
				string url = "https://xui.ptlogin2.qq.com/cgi-bin/xlogin?appid=716027609&daid=383&style=33&login_text=授权并登录&hide_title_bar=1&hide_border=1&target=self&s_url=" + Uri.EscapeDataString(OAuthAuthorizeUrl()) + "&pt_3rd_aid=100497308&pt_feedback_link=" + Uri.EscapeDataString("https://support.qq.com/products/77942");
				try
				{
					await GetWithCaptureAsync(url, ct).ConfigureAwait(continueOnCapturedContext: false);
					string text = ExtractSetCookie(_lastSetCookie, "pt_login_sig");
					if (!string.IsNullOrEmpty(text))
					{
						_loginSig = text;
					}
				}
				catch
				{
				}
				if (string.IsNullOrEmpty(_loginSig))
				{
					_loginSig = LookupCookie("pt_login_sig") ?? "";
				}
				string text2 = _rng.NextDouble().ToString("R");
				string url2 = "https://ssl.ptlogin2.qq.com/ptqrshow?appid=716027609&e=2&l=M&s=3&d=72&v=4&t=" + text2 + "&daid=383&pt_3rd_aid=100497308";
				byte[] array = await GetWithCaptureAsync(url2, ct).ConfigureAwait(continueOnCapturedContext: false);
				string text3 = ExtractSetCookie(_lastSetCookie, "qrsig");
				_qrsig = ((!string.IsNullOrEmpty(text3)) ? text3 : (LookupCookie("qrsig") ?? ""));
				if (array == null || array.Length == 0)
				{
					throw new InvalidOperationException("ptqrshow 没返回二维码图片");
				}
				return array;
			}, ct);
		}

		public Task<QqLoginResult> QrPollAsync(CancellationToken ct = default(CancellationToken))
		{
			return _throttle.RunAsync(async delegate
			{
				QqLoginResult r = new QqLoginResult();
				int num = Hash33(_qrsig);
				string stringToEscape = "0-0-" + DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
				string loginSig = (string.IsNullOrEmpty(_loginSig) ? "" : _loginSig);
				string url = "https://ssl.ptlogin2.qq.com/ptqrlogin?u1=" + Uri.EscapeDataString(OAuthAuthorizeUrl()) + "&ptqrtoken=" + num + "&ptredirect=0&h=1&t=1&g=1&from_ui=1&ptlang=2052&action=" + Uri.EscapeDataString(stringToEscape) + "&js_ver=20102616&js_type=1&login_sig=" + Uri.EscapeDataString(loginSig) + "&pt_uistyle=40&aid=716027609&daid=383&pt_3rd_aid=100497308";
				string text;
				try
				{
					text = await GetRawAsync(url, ct, "https://xui.ptlogin2.qq.com/").ConfigureAwait(continueOnCapturedContext: false);
				}
				catch (Exception ex)
				{
					r.State = QqLoginResult.QqLoginState.Failed;
					r.RawMessage = ex.Message;
					return r;
				}
				string state = "";
				string url2 = "";
				string msg = "";
				ParsePtuiCb(text, ref state, ref url2, ref msg);
				switch (state)
				{
				case "0":
				{
					string text2 = await AuthorizeQq(url2, ct).ConfigureAwait(continueOnCapturedContext: false);
					if (string.IsNullOrEmpty(text2))
					{
						r.State = QqLoginResult.QqLoginState.Failed;
						r.RawMessage = "登录成功但没拿到 OAuth code。轨迹：" + _lastOauthTrace;
						return r;
					}
					string value = await MusicuLogin(text2, ct).ConfigureAwait(continueOnCapturedContext: false);
					if (string.IsNullOrEmpty(value))
					{
						r.State = QqLoginResult.QqLoginState.Failed;
						r.RawMessage = "OAuth code 拿到了但没换到 musickey";
						return r;
					}
					Dictionary<string, string> dictionary = new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase);
					foreach (KeyValuePair<string, string> item in QqCookieStore.Parse(HarvestCookies() ?? ""))
					{
						dictionary[item.Key] = item.Value;
					}
					dictionary["qqmusic_key"] = value;
					dictionary["musickey"] = value;
					if (!dictionary.ContainsKey("uin") && !string.IsNullOrEmpty(_uin))
					{
						dictionary["uin"] = _uin;
					}
					string text3 = QqCookieStore.Normalize(dictionary);
					if (!string.IsNullOrEmpty(text3))
					{
						SetCookie(text3);
					}
					r.State = QqLoginResult.QqLoginState.Success;
					r.CookieText = text3;
					return r;
				}
				case "66":
					r.State = QqLoginResult.QqLoginState.Waiting;
					return r;
				case "67":
					r.State = QqLoginResult.QqLoginState.Scanned;
					return r;
				case "65":
					r.State = QqLoginResult.QqLoginState.Expired;
					return r;
				default:
					r.State = QqLoginResult.QqLoginState.Failed;
					r.RawMessage = (string.IsNullOrEmpty(text) ? ("ptqrlogin 空响应（qrsig " + _qrsig.Length + " 字符，login_sig " + loginSig.Length + " 字符；为 0 说明二维码会话没建立，请点「换一张」重拉）") : ("ptqrlogin 未知响应[" + ((state.Length > 0) ? state : "?") + "] " + Summarize(text)));
					return r;
				}
			}, ct);
		}

		private static string OAuthAuthorizeUrl()
		{
			return "https://graph.qq.com/oauth2.0/authorize?client_id=100497308&response_type=code&redirect_uri=" + Uri.EscapeDataString("https://y.qq.com/portal/wx_redirect.html") + "&scope=" + Uri.EscapeDataString("get_user_basic,get_vip_info,get_user_detail") + "&state=peak";
		}

		private static void ParsePtuiCb(string text, ref string state, ref string url, ref string msg)
		{
			if (string.IsNullOrEmpty(text))
			{
				return;
			}
			int num = text.IndexOf("ptuiCB", StringComparison.Ordinal);
			if (num < 0)
			{
				return;
			}
			int num2 = text.IndexOf('(', num);
			int num3 = text.LastIndexOf(')');
			if (num2 < 0 || num3 <= num2)
			{
				return;
			}
			string text2 = text.Substring(num2 + 1, num3 - num2 - 1);
			List<string> list = new List<string>();
			int num4 = 0;
			while (num4 < text2.Length && list.Count < 8)
			{
				char c = text2[num4];
				if ("'\"‘“".IndexOf(c) < 0)
				{
					num4++;
					continue;
				}
				string text3 = text2;
				int num5 = text3.IndexOf(c switch
				{
					'‘' => '’', 
					'“' => '”', 
					_ => c, 
				}, num4 + 1);
				if (num5 < 0)
				{
					break;
				}
				list.Add(text2.Substring(num4 + 1, num5 - num4 - 1));
				num4 = num5 + 1;
			}
			if (list.Count > 0)
			{
				state = list[0] ?? "";
			}
			if (list.Count > 2)
			{
				url = list[2] ?? "";
			}
			if (list.Count > 4)
			{
				msg = list[4] ?? "";
			}
		}

		private static string Summarize(string text)
		{
			if (string.IsNullOrEmpty(text))
			{
				return "(空)";
			}
			string text2 = text.Replace("\r", " ").Replace("\n", " ").Trim();
			if (text2.Length > 150)
			{
				return text2.Substring(0, 150) + "…";
			}
			return text2;
		}

		private async Task<string> AuthorizeQq(string checkSigUrl, CancellationToken ct)
		{
			StringBuilder trace = new StringBuilder();
			try
			{
				string text = ExtractParam(checkSigUrl, "ptsigx");
				string text2 = ExtractParam(checkSigUrl, "uin");
				if (string.IsNullOrEmpty(text) || string.IsNullOrEmpty(text2))
				{
					_lastOauthTrace = "check_sig URL 里缺 ptsigx/uin：" + ShortHost(checkSigUrl);
					return "";
				}
				trace.Append("ptsigx/uin ✓ ");
				string url = "https://ssl.ptlogin2.graph.qq.com/check_sig?uin=" + text2 + "&pttype=1&service=ptqrlogin&nodirect=0&ptsigx=" + Uri.EscapeDataString(text) + "&s_url=" + Uri.EscapeDataString("https://graph.qq.com/oauth2.0/login_jump") + "&ptlang=2052&ptredirect=100&aid=716027609&daid=383&j_later=0&low_login_hour=0&regmaster=0&pt_login_type=3&pt_aid=0&pt_aaid=16&pt_light=0&pt_3rd_aid=100497308";
				await GetRawAsync(url, ct, "https://xui.ptlogin2.qq.com/").ConfigureAwait(continueOnCapturedContext: false);
				if (!FlattenCookies().TryGetValue("p_skey", out var value) || string.IsNullOrEmpty(value))
				{
					_lastOauthTrace = trace?.ToString() + "check_sig 后没拿到 p_skey cookie";
					return "";
				}
				trace.Append("p_skey ✓(len=").Append(value.Length).Append(") ");
				string value2 = Hash33(value, 5381).ToString();
				trace.Append("gtk=").Append(value2).Append(' ');
				Dictionary<string, string> form = new Dictionary<string, string>
				{
					{ "response_type", "code" },
					{ "client_id", "100497308" },
					{ "redirect_uri", "https://y.qq.com/portal/wx_redirect.html?login_type=1&surl=https://y.qq.com/" },
					{ "scope", "get_user_info,get_app_friends" },
					{ "state", "state" },
					{ "switch", "" },
					{ "from_ptlogin", "1" },
					{ "src", "1" },
					{ "update_auth", "1" },
					{ "openapi", "1010_1030" },
					{ "g_tk", value2 },
					{
						"auth_time",
						((long)(DateTime.UtcNow - new DateTime(1970, 1, 1)).TotalMilliseconds).ToString()
					},
					{
						"ui",
						Guid.NewGuid().ToString()
					}
				};
				List<string> list = new List<string>(FlattenCookies().Keys);
				list.Sort(StringComparer.Ordinal);
				trace.Append("cookies[").Append(string.Join(",", list.ToArray())).Append("] ");
				RedirectResult redirectResult = await PostFormRedirectAsync("https://graph.qq.com/oauth2.0/authorize", form, "https://graph.qq.com/", ct).ConfigureAwait(continueOnCapturedContext: false);
				string text3 = ExtractCodeParam(redirectResult.Location) ?? ExtractCodeParam(redirectResult.Body);
				if (!string.IsNullOrEmpty(text3))
				{
					trace.Append("authorize→code ✓");
					_lastOauthTrace = trace.ToString();
					return text3;
				}
				_lastOauthTrace = trace?.ToString() + "authorize 没回 code，Location=" + (((redirectResult.Location ?? "(无)").Length > 220) ? redirectResult.Location.Substring(0, 220) : (redirectResult.Location ?? "(无)")) + " 正文前80字=" + ((redirectResult.Body != null && redirectResult.Body.Length > 80) ? redirectResult.Body.Substring(0, 80).Replace("\n", " ") : redirectResult.Body);
				return "";
			}
			catch (Exception ex)
			{
				_lastOauthTrace = trace?.ToString() + "异常：" + ex.Message;
				return "";
			}
		}

		private static string ExtractParam(string url, string name)
		{
			if (string.IsNullOrEmpty(url) || string.IsNullOrEmpty(name))
			{
				return "";
			}
			int num = url.IndexOf(name + "=", StringComparison.Ordinal);
			if (num < 0)
			{
				return "";
			}
			int num2 = num + name.Length + 1;
			int num3 = url.IndexOf('&', num2);
			return Uri.UnescapeDataString((num3 < 0) ? url.Substring(num2) : url.Substring(num2, num3 - num2));
		}

		private static string ShortHost(string url)
		{
			if (string.IsNullOrEmpty(url))
			{
				return "(空)";
			}
			int num = url.IndexOf("://", StringComparison.Ordinal);
			string text = ((num >= 0) ? url.Substring(num + 3) : url);
			int num2 = text.IndexOf('/');
			string obj = ((num2 > 0) ? text.Substring(0, num2) : text);
			string text2 = ((num2 > 0) ? text.Substring(num2, Math.Min(40, text.Length - num2)) : "");
			return obj + text2;
		}

		private static string ExtractCodeParam(string text)
		{
			if (string.IsNullOrEmpty(text))
			{
				return "";
			}
			int num = text.IndexOf("code=", StringComparison.Ordinal);
			if (num < 0)
			{
				return "";
			}
			int num2 = num + "code=".Length;
			int i;
			for (i = num2; i < text.Length; i++)
			{
				char c = text[i];
				if (c == '&' || c == '\'' || c == '"' || c == ',' || c == ')' || c == ']' || char.IsWhiteSpace(c))
				{
					break;
				}
			}
			if (i <= num2)
			{
				return "";
			}
			return text.Substring(num2, i - num2);
		}

		private async Task<string> MusicuLogin(string code, CancellationToken ct)
		{
			try
			{
				string text = _rng.Next(100000000, 999999999).ToString();
				string body = "{\"req_0\":{\"module\":\"QQConnectLogin.LoginServer\",\"method\":\"QQLogin\",\"param\":{\"code\":\"" + code + "\",\"strAppid\":\"100497308\"}},\"comm\":{\"ct\":11,\"cv\":14090008,\"v\":14090008,\"chid\":\"10003505\",\"tmeAppID\":\"qqmusic\",\"QIMEI\":\"\",\"QIMEI36\":\"\",\"OpenUDID\":\"" + text + "\",\"udid\":\"" + text + "\",\"OpenUDID2\":\"" + text + "\",\"aid\":\"" + text + "\",\"os_ver\":\"10\",\"phonetype\":\"MI 6\",\"devicelevel\":\"29\",\"newdevicelevel\":\"29\",\"tmeLoginType\":2}}";
				Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(await PostJsonAsync("https://u.y.qq.com/cgi-bin/musicu.fcg", body, ct).ConfigureAwait(continueOnCapturedContext: false)));
				Dictionary<string, object> dictionary2 = ((dictionary != null) ? MiniJson.Dict(dictionary, "req_0") : null);
				Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "data") : null);
				if (dictionary3 != null)
				{
					string text2 = MiniJson.Str(dictionary3, "musickey", "");
					if (!string.IsNullOrEmpty(text2))
					{
						return text2;
					}
				}
				return LookupCookie("musickey") ?? "";
			}
			catch
			{
				return "";
			}
		}

		public Task<byte[]> AppQrBeginAsync(CancellationToken ct = default(CancellationToken))
		{
			return _throttle.RunAsync(async delegate
			{
				AppQrStop();
				string body = "{\"req_0\":{\"module\":\"music.login.LoginServer\",\"method\":\"CreateQRCode\",\"param\":{\"tmeAppID\":\"qqmusic\",\"ct\":11,\"cv\":20090008}},\"comm\":{\"ct\":23,\"cv\":0,\"tmeAppID\":\"qqmusic\"}}";
				Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(await PostJsonAsync("https://u.y.qq.com/cgi-bin/musicu.fcg", body, ct).ConfigureAwait(continueOnCapturedContext: false)));
				Dictionary<string, object> dictionary2 = ((dictionary != null) ? MiniJson.Dict(dictionary, "req_0") : null);
				Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "data") : null);
				string text = ((dictionary3 != null) ? MiniJson.Str(dictionary3, "qrcode", "") : "");
				string text2 = ((dictionary3 != null) ? MiniJson.Str(dictionary3, "qrcodeID", "") : "");
				if (string.IsNullOrEmpty(text) || string.IsNullOrEmpty(text2))
				{
					throw new InvalidOperationException("CreateQRCode 没返回二维码");
				}
				_appQrId = text2;
				SetAppState(new QqLoginResult
				{
					State = QqLoginResult.QqLoginState.Waiting
				});
				int num = text.IndexOf(',');
				byte[] result = Convert.FromBase64String((num >= 0) ? text.Substring(num + 1) : text);
				CancellationTokenSource cts = new CancellationTokenSource();
				lock (_appLock)
				{
					_appCts = cts;
				}
				string id = text2;
				Task.Run(() => RunAppMqttAsync(id, cts.Token));
				return result;
			}, ct);
		}

		public QqLoginResult AppQrPoll()
		{
			lock (_appLock)
			{
				return new QqLoginResult
				{
					State = _appState.State,
					CookieText = _appState.CookieText,
					RawMessage = _appState.RawMessage
				};
			}
		}

		public void AppQrStop()
		{
			CancellationTokenSource appCts;
			MqttWsClient appMqtt;
			lock (_appLock)
			{
				appCts = _appCts;
				_appCts = null;
				appMqtt = _appMqtt;
				_appMqtt = null;
			}
			try
			{
				appCts?.Cancel();
			}
			catch
			{
			}
			try
			{
				appMqtt?.Dispose();
			}
			catch
			{
			}
		}

		private void SetAppState(QqLoginResult r)
		{
			lock (_appLock)
			{
				_appState = r;
			}
		}

		private async Task RunAppMqttAsync(string qrId, CancellationToken ct)
		{
			_ = 3;
			try
			{
				MqttWsClient mqtt = new MqttWsClient();
				lock (_appLock)
				{
					_appMqtt = mqtt;
				}
				Dictionary<string, string> headers = new Dictionary<string, string>
				{
					{ "Origin", "https://y.qq.com" },
					{ "Referer", "https://y.qq.com/" },
					{ "User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36" }
				};
				Dictionary<string, string> connectUserProps = new Dictionary<string, string>
				{
					{ "tmeAppID", "qqmusic" },
					{ "business", "management" },
					{ "hashTag", qrId },
					{ "clientTag", "management.user" },
					{ "userID", qrId }
				};
				string clientId = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds().ToString() + _rng.Next(1000, 10000);
				await mqtt.ConnectAsync("mu.y.qq.com", 443, "/ws/handshake", headers, clientId, connectUserProps, ct).ConfigureAwait(continueOnCapturedContext: false);
				Dictionary<string, string> subUserProps = new Dictionary<string, string>
				{
					{ "authorization", "tmelogin" },
					{ "pubsub", "unicast" }
				};
				await mqtt.SubscribeAsync("management.qrcode_login/" + qrId, subUserProps, ct).ConfigureAwait(continueOnCapturedContext: false);
				while (!ct.IsCancellationRequested)
				{
					MqttWsMessage mqttWsMessage = mqtt.ReceiveMessage(TimeSpan.FromSeconds(15.0));
					if (mqttWsMessage == null)
					{
						try
						{
							await mqtt.PingAsync(ct).ConfigureAwait(continueOnCapturedContext: false);
						}
						catch
						{
							break;
						}
						continue;
					}
					string value = "";
					mqttWsMessage.UserProps.TryGetValue("type", out value);
					switch (value)
					{
					case "scanned":
						SetAppState(new QqLoginResult
						{
							State = QqLoginResult.QqLoginState.Scanned
						});
						break;
					case "canceled":
						SetAppState(new QqLoginResult
						{
							State = QqLoginResult.QqLoginState.Failed,
							RawMessage = "手机上取消了登录"
						});
						return;
					case "timeout":
						SetAppState(new QqLoginResult
						{
							State = QqLoginResult.QqLoginState.Expired
						});
						return;
					case "loginFailed":
					{
						string text = mqttWsMessage.Payload ?? "";
						SetAppState(new QqLoginResult
						{
							State = QqLoginResult.QqLoginState.Failed,
							RawMessage = "手机端登录失败" + ((text.Length > 0) ? ("：" + ((text.Length > 60) ? text.Substring(0, 60) : text)) : "")
						});
						return;
					}
					case "cookies":
						SetAppState(await FinishAppLoginAsync(qrId, mqttWsMessage.Payload ?? "", ct).ConfigureAwait(continueOnCapturedContext: false));
						return;
					}
				}
			}
			catch (OperationCanceledException)
			{
			}
			catch (Exception ex2)
			{
				SetAppState(new QqLoginResult
				{
					State = QqLoginResult.QqLoginState.Failed,
					RawMessage = "App 扫码通道异常：" + ex2.Message
				});
			}
		}

		private async Task<QqLoginResult> FinishAppLoginAsync(string qrId, string payload, CancellationToken ct)
		{
			QqLoginResult r = new QqLoginResult();
			try
			{
				Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(payload));
				Dictionary<string, object> dictionary2 = ((dictionary != null) ? MiniJson.Dict(dictionary, "cookies") : null);
				Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "qqmusic_uin") : null);
				Dictionary<string, object> dictionary4 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "qqmusic_key") : null);
				string text = ((dictionary3 != null) ? MiniJson.Str(dictionary3, "value", "") : "");
				string text2 = ((dictionary4 != null) ? MiniJson.Str(dictionary4, "value", "") : "");
				Dictionary<string, object> dictionary5 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "euin") : null);
				string euin = ((dictionary5 != null) ? MiniJson.Str(dictionary5, "value", "") : "");
				if (string.IsNullOrEmpty(text) || string.IsNullOrEmpty(text2))
				{
					r.State = QqLoginResult.QqLoginState.Failed;
					r.RawMessage = "cookies 推送里缺 qqmusic_uin / qqmusic_key";
					return r;
				}
				string digits2 = text.Trim();
				if (digits2.StartsWith("o") || digits2.StartsWith("O"))
				{
					digits2 = digits2.Substring(1);
				}
				digits2 = digits2.TrimStart(new char[1] { '0' });
				if (digits2.Length == 0)
				{
					digits2 = "0";
				}
				string musickey = text2;
				string loginKey = "";
				try
				{
					string[] bodies = new string[2]
					{
						"{\"req_0\":{\"module\":\"music.login.LoginServer\",\"method\":\"Login\",\"param\":{\"musicid\":" + digits2 + ",\"qrCodeID\":\"" + qrId + "\",\"token\":\"" + text2 + "\",\"loginType\":6,\"needCookie\":1}},\"comm\":{\"ct\":11,\"cv\":20090008,\"tmeAppID\":\"qqmusic\",\"tmeLoginType\":6}}",
						"{\"req_0\":{\"module\":\"music.login.LoginServer\",\"method\":\"Login\",\"param\":{\"musicid\":" + digits2 + ",\"qrCodeID\":\"" + qrId + "\",\"token\":\"" + text2 + "\"}},\"comm\":{\"ct\":11,\"cv\":20090008,\"tmeAppID\":\"qqmusic\",\"tmeLoginType\":6}}"
					};
					int bi;
					for (bi = 0; bi < bodies.Length; bi++)
					{
						Dictionary<string, object> dictionary6 = MiniJson.AsObject(MiniJson.Parse(await _throttle.RunAsync(() => PostJsonAsync("https://u.y.qq.com/cgi-bin/musicu.fcg", bodies[bi], ct), ct).ConfigureAwait(continueOnCapturedContext: false)));
						Dictionary<string, object> dictionary7 = ((dictionary6 != null) ? MiniJson.Dict(dictionary6, "req_0") : null);
						Dictionary<string, object> dictionary8 = ((dictionary7 != null) ? MiniJson.Dict(dictionary7, "data") : null);
						string text3 = ((dictionary8 != null) ? MiniJson.Str(dictionary8, "musickey", "") : "");
						if (!string.IsNullOrEmpty(text3))
						{
							musickey = text3;
							loginKey = text3;
						}
						long num = ((dictionary8 != null) ? MiniJson.Lng(dictionary8, "loginType", 0L) : 0);
						if (num > 0 && num < 10)
						{
							_loginType = (int)num;
						}
						if (!string.IsNullOrEmpty(loginKey))
						{
							break;
						}
					}
				}
				catch
				{
				}
				string text4 = QqCookieStore.Normalize(new Dictionary<string, string>(StringComparer.OrdinalIgnoreCase)
				{
					["uin"] = OFormat(digits2),
					["p_uin"] = OFormat(digits2),
					["pt2gguin"] = OFormat(digits2),
					["qqmusic_uin"] = digits2,
					["euin"] = euin,
					["qqmusic_key"] = musickey,
					["qm_keyst"] = musickey,
					["musickey"] = musickey
				});
				if (!string.IsNullOrEmpty(text4))
				{
					SetCookie(text4);
				}
				try
				{
					string checkBody = "{\"comm\":{\"ct\":19,\"cv\":2201,\"uin\":\"" + digits2 + "\",\"authst\":\"" + musickey + "\",\"g_tk\":" + Hash33(musickey) + ",\"tmeLoginType\":" + ((!string.IsNullOrEmpty(musickey) && musickey.StartsWith("W_X", StringComparison.Ordinal)) ? 1 : 2) + "},\"req_0\":{\"module\":\"music.UserInfo.userInfoServer\",\"method\":\"GetLoginUserInfo\",\"param\":{}}}";
					Dictionary<string, object> dictionary9 = MiniJson.AsObject(MiniJson.Parse(await PostJsonWithCookieAsync("https://u.y.qq.com/cgi-bin/musicu.fcg", checkBody, CookieText, ct).ConfigureAwait(continueOnCapturedContext: false)));
					Dictionary<string, object> dictionary10 = ((dictionary9 != null) ? MiniJson.Dict(dictionary9, "req_0") : null);
					long num2 = ((dictionary10 != null) ? MiniJson.Lng(dictionary10, "code", -1L) : (-1));
					Dictionary<string, object> dictionary11 = ((dictionary10 != null) ? MiniJson.Dict(dictionary10, "data") : null);
					string value = ((dictionary11 != null) ? MiniJson.Str(dictionary11, "nick", "") : "");
					if (string.IsNullOrEmpty(value) && dictionary11 != null)
					{
						Dictionary<string, object> dictionary12 = MiniJson.Dict(dictionary11, "info");
						if (dictionary12 != null)
						{
							value = MiniJson.Str(dictionary12, "nick", "");
							if (string.IsNullOrEmpty(value))
							{
								Dictionary<string, object> dictionary13 = MiniJson.Dict(dictionary12, "base");
								if (dictionary13 != null)
								{
									value = MiniJson.Str(dictionary13, "nick", "");
								}
							}
						}
					}
					if (num2 != 0L || string.IsNullOrEmpty(value))
					{
						await Task.Delay(900, ct).ConfigureAwait(continueOnCapturedContext: false);
						Dictionary<string, object> dictionary14 = MiniJson.AsObject(MiniJson.Parse(await PostJsonWithCookieAsync("https://u.y.qq.com/cgi-bin/musicu.fcg", checkBody, CookieText, ct).ConfigureAwait(continueOnCapturedContext: false)));
						Dictionary<string, object> dictionary15 = ((dictionary14 != null) ? MiniJson.Dict(dictionary14, "req_0") : null);
						num2 = ((dictionary15 != null) ? MiniJson.Lng(dictionary15, "code", -1L) : (-1));
						Dictionary<string, object> dictionary16 = ((dictionary15 != null) ? MiniJson.Dict(dictionary15, "data") : null);
						value = ((dictionary16 != null) ? MiniJson.Str(dictionary16, "nick", "") : "");
					}
					if (num2 != 0L || string.IsNullOrEmpty(value))
					{
						r.State = QqLoginResult.QqLoginState.Failed;
						r.RawMessage = "登录已提交，但服务器不认这把 key（code=" + num2 + "），请重新扫码";
						r.CookieText = text4;
						return r;
					}
				}
				catch
				{
				}
				r.State = QqLoginResult.QqLoginState.Success;
				r.CookieText = text4;
			}
			catch (Exception ex)
			{
				r.State = QqLoginResult.QqLoginState.Failed;
				r.RawMessage = "处理 cookies 推送失败：" + ex.Message;
			}
			return r;
		}

		public async Task<SongUrlResult> GetSongUrlAsync(SongInfo song, CancellationToken ct = default(CancellationToken))
		{
			string mid = ((song == null) ? "" : (string.IsNullOrEmpty(song.SourceId) ? song.Id.ToString() : song.SourceId));
			if (string.IsNullOrEmpty(mid))
			{
				return new SongUrlResult
				{
					Code = -1,
					Message = "缺少 QQ songmid"
				};
			}
			long id = song?.Id ?? 0;
			string text = QqCookieStore.Load();
			if (!string.IsNullOrEmpty(text))
			{
				string text2 = EnsureComplete(text);
				if (!string.IsNullOrEmpty(text2) && text2 != text)
				{
					SetCookie(text2);
				}
			}
			EnsureGuid();
			bool logged = HasLogin;
			string fileMid = ((song != null && !string.IsNullOrEmpty(song.MediaMid)) ? song.MediaMid : null);
			if (string.IsNullOrEmpty(fileMid))
			{
				fileMid = await ResolveMediaMidAsync(mid, ct).ConfigureAwait(continueOnCapturedContext: false);
			}
			if (song != null && string.IsNullOrEmpty(song.MediaMid))
			{
				song.MediaMid = fileMid;
			}
			if (logged)
			{
				try
				{
					SongUrlResult songUrlResult = await GetSongUrlDesktopAsync(song, mid, fileMid, ct).ConfigureAwait(continueOnCapturedContext: false);
					if (songUrlResult != null && songUrlResult.Ok)
					{
						return songUrlResult;
					}
					if (songUrlResult != null && !string.IsNullOrEmpty(songUrlResult.Message))
					{
						_lastDesktopError = songUrlResult.Message;
					}
				}
				catch (Exception ex)
				{
					_lastDesktopError = "桌面通道异常：" + ex.Message;
				}
			}
			List<string[]> tries = new List<string[]>();
			if (logged)
			{
				tries.Add(new string[3] { "M800.mp3", "320k", "320000" });
			}
			tries.Add(new string[3] { "M500.mp3", "128k", "128000" });
			tries.Add(new string[3] { "M500.mp4", "96k aac", "96000" });
			tries.Add(new string[3] { "C400.m4a", "48k aac", "48000" });
			SongUrlResult last = null;
			for (int i = 0; i < tries.Count; i++)
			{
				string[] array = tries[i];
				SongUrlResult songUrlResult2 = await GetSongUrlOnceAsync(song, mid, fileMid, array[0], array[1], int.Parse(array[2]), null, ct).ConfigureAwait(continueOnCapturedContext: false);
				if (songUrlResult2.Ok)
				{
					return songUrlResult2;
				}
				last = songUrlResult2;
				if (songUrlResult2.Code == -104004)
				{
					break;
				}
			}
			if (last == null)
			{
				last = new SongUrlResult
				{
					Id = id,
					Code = -112,
					Message = "QQ 取流没有任何返回"
				};
			}
			string probe = null;
			if (logged)
			{
				probe = await ProbeAccountAsync(ct).ConfigureAwait(continueOnCapturedContext: false);
			}
			string reason = last.Message ?? "";
			if (logged && string.IsNullOrEmpty(probe))
			{
				SongUrlResult songUrlResult3 = await GetSongUrlOnceAsync(song, mid, fileMid, "M500.mp3", "128k(游客)", 128000, "", ct).ConfigureAwait(continueOnCapturedContext: false);
				if (!songUrlResult3.Ok)
				{
					songUrlResult3 = await GetSongUrlOnceAsync(song, mid, fileMid, "M500.mp4", "96k(游客)", 96000, "", ct).ConfigureAwait(continueOnCapturedContext: false);
				}
				if (songUrlResult3.Ok)
				{
					songUrlResult3.Message = "登录态已失效，已按游客身份播放（会员曲要重新扫码登录才能放）";
					return songUrlResult3;
				}
			}
			if (!logged)
			{
				last.Message = "QQ音乐未登录：会员曲 / 付费曲必须有登录态才能取流，扫码登录后再点这首歌";
			}
			else if (string.IsNullOrEmpty(probe))
			{
				last.Message = "QQ音乐没认出登录态（cookie 不完整或已过期）：面板里退出登录后重新扫码；服务器返回 " + reason;
			}
			else
			{
				string text3 = (string.IsNullOrEmpty(_lastDesktopError) ? "" : ("；桌面通道：" + _lastDesktopError));
				last.Message = "账号 " + probe + " 取不到直链：" + reason + text3 + "（确认绿钻未过期，或这首确实无版权）";
			}
			last.Code = -112;
			last.Fee = song?.Fee ?? 1;
			return last;
		}

		private Task<string> ResolveMediaMidAsync(string songmid, CancellationToken ct)
		{
			if (string.IsNullOrEmpty(songmid))
			{
				return Task.FromResult(songmid ?? "");
			}
			if (_mediaMidCache.TryGetValue(songmid, out var value))
			{
				return Task.FromResult(value);
			}
			return _throttle.RunAsync(async delegate
			{
				try
				{
					string url = "https://c.y.qq.com/v8/fcg-bin/fcg_play_single_song.fcg?songmid=" + Uri.EscapeDataString(songmid) + "&format=json&platform=yqq&needNewCode=0";
					Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(await GetAsync(url, ct).ConfigureAwait(continueOnCapturedContext: false)));
					List<object> list = ((dictionary != null) ? MiniJson.List(dictionary, "data") : null);
					if (list != null && list.Count > 0)
					{
						Dictionary<string, object> dictionary2 = MiniJson.AsObject(list[0]);
						Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "file") : null);
						string text = ((dictionary3 != null) ? MiniJson.Str(dictionary3, "media_mid", "") : "");
						if (!string.IsNullOrEmpty(text))
						{
							_mediaMidCache[songmid] = text;
							return text;
						}
					}
				}
				catch
				{
				}
				_mediaMidCache[songmid] = songmid;
				return songmid;
			}, ct);
		}

		private Task<SongUrlResult> GetSongUrlOnceAsync(SongInfo song, string mid, string fileMid, string suffix, string level, int br, string cookieOverride, CancellationToken ct)
		{
			string guid = EnsureGuid();
			bool flag = cookieOverride != null && cookieOverride.Length == 0;
			string uin = (flag ? "0" : Uin);
			string cookie = ((cookieOverride != null) ? cookieOverride : CookieText);
			int loginflag = ((!flag) ? 1 : 0);
			return _throttle.RunAsync(async delegate
			{
				string text = suffix.Substring(0, 4) + fileMid + suffix.Substring(4);
				string text2 = "{\"uin\":\"" + uin + "\",\"format\":\"json\",\"ct\":\"24\",\"cv\":\"0\",\"platform\":\"yqq.json\",\"guid\":\"" + guid + "\"}";
				string text3 = "{\"module\":\"CDN.SrfCdnDispatchServer\",\"method\":\"GetCdnDispatch\",\"param\":{\"guid\":\"" + guid + "\",\"calltype\":0,\"userip\":\"\"}}";
				string text4 = "{\"module\":\"vkey.GetVkeyServer\",\"method\":\"CgiGetVkey\",\"param\":{\"guid\":\"" + guid + "\",\"songmid\":[\"" + mid + "\"],\"songtype\":[0],\"filename\":[\"" + text + "\"],\"uin\":\"" + uin + "\",\"loginflag\":" + loginflag + ",\"platform\":\"20\"}}";
				string body = "{\"comm\":" + text2 + ",\"req\":" + text3 + ",\"req_0\":" + text4 + "}";
				Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(await PostJsonWithCookieAsync("https://u.y.qq.com/cgi-bin/musicu.fcg?format=json&platform=yqq.json", body, cookie, ct).ConfigureAwait(continueOnCapturedContext: false)));
				Dictionary<string, object> dictionary2 = ((dictionary != null) ? MiniJson.Dict(dictionary, "req_0") : null);
				Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "data") : null);
				if (dictionary3 == null)
				{
					return Fail(song, -500, "QQ 取流响应异常");
				}
				string text5 = "";
				List<object> list = MiniJson.List(dictionary3, "sip");
				if (list != null && list.Count > 0)
				{
					text5 = Convert.ToString(list[0]);
				}
				string text6 = "";
				long num = 0L;
				string text7 = "";
				long num2 = 0L;
				List<object> list2 = MiniJson.List(dictionary3, "midurlinfo");
				if (list2 != null && list2.Count > 0)
				{
					Dictionary<string, object> dictionary4 = MiniJson.AsObject(list2[0]);
					if (dictionary4 != null)
					{
						text6 = MiniJson.Str(dictionary4, "purl", "");
						num = MiniJson.Lng(dictionary4, "result", 0L);
						text7 = MiniJson.Str(dictionary4, "errtype", "");
						num2 = MiniJson.Lng(dictionary4, "code", 0L);
					}
				}
				if (string.IsNullOrEmpty(text6))
				{
					int code = -112;
					string text8 = "QQ 音乐没返回直链";
					switch (num)
					{
					case 104003L:
						code = -104003;
						text8 = "该账号下没有这首歌的播放权限（result=104003：无版权 / 需会员）";
						break;
					case 104004L:
						code = -104004;
						text8 = "需要单独付费购买（result=104004）";
						break;
					default:
						text8 = "QQ 音乐拒绝取流 result=" + num;
						break;
					case 0L:
						if (num2 != 0L)
						{
							text8 = "QQ 音乐拒绝取流 code=" + num2;
						}
						break;
					}
					if (!string.IsNullOrEmpty(text7))
					{
						text8 = text8 + " errtype=" + text7;
					}
					return Fail(song, code, text8);
				}
				string text9 = ((text5.Length > 0) ? text5 : "http://ws.stream.qqmusic.qq.com/");
				string url = NeteaseClient.ForceHttps(text9.TrimEnd(new char[1] { '/' }) + "/" + text6.TrimStart(new char[1] { '/' }));
				return (!(await VerifyUrlAsync(url, ct).ConfigureAwait(continueOnCapturedContext: false))) ? Fail(song, -112, "拿到直链但 CDN 拒绝下载（" + level + "），换档重试") : new SongUrlResult
				{
					Id = ((song != null) ? song.Id : 0),
					Url = url,
					Code = 200,
					Br = br,
					Level = level,
					Fee = ((song != null) ? song.Fee : 0)
				};
			}, ct);
		}

		private async Task<bool> VerifyUrlAsync(string url, CancellationToken ct)
		{
			try
			{
				HttpRequestMessage val = new HttpRequestMessage(HttpMethod.Get, url);
				((HttpHeaders)val.Headers).TryAddWithoutValidation("Range", "bytes=0-2048");
				HttpResponseMessage val2 = await _cookielessHttp.SendAsync(val, (HttpCompletionOption)1, ct).ConfigureAwait(continueOnCapturedContext: false);
				try
				{
					int statusCode = (int)val2.StatusCode;
					return statusCode == 200 || statusCode == 206 || statusCode == 416;
				}
				finally
				{
					val2.Dispose();
				}
			}
			catch
			{
				return true;
			}
		}

		private Task<SongUrlResult> GetSongUrlDesktopAsync(SongInfo song, string mid, string fileMid, CancellationToken ct)
		{
			string guid = EnsureGuid();
			string uin = Uin;
			string key = Authst;
			string cookie = CookieText;
			int loginType = _loginType;
			if (string.IsNullOrEmpty(key) || uin == "0" || string.IsNullOrEmpty(fileMid))
			{
				_lastDesktopError = "缺少登录态（authst/uin/media_mid）";
				return Task.FromResult(Fail(song, -112, _lastDesktopError));
			}
			int gtk = Hash33(key);
			return _throttle.RunAsync(async delegate
			{
				string text = "{\"ct\":19,\"cv\":2201,\"uin\":\"" + uin + "\",\"authst\":\"" + key + "\",\"g_tk\":" + gtk + ",\"tmeLoginType\":" + loginType + "}";
				string text2 = "{\"module\":\"music.vkey.GetVkey\",\"method\":\"UrlGetVkey\",\"param\":{\"guid\":\"" + guid + "\",\"uin\":\"" + uin + "\",\"ctx\":0,\"filename\":[\"M500" + fileMid + ".mp3\",\"M800" + fileMid + ".mp3\"],\"songmid\":[\"" + mid + "\",\"" + mid + "\"],\"songtype\":[0,0]}}";
				string body = "{\"comm\":" + text + ",\"req_0\":" + text2 + "}";
				Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(await PostJsonWithCookieAsync("https://u.y.qq.com/cgi-bin/musicu.fcg", body, cookie, ct).ConfigureAwait(continueOnCapturedContext: false)));
				Dictionary<string, object> dictionary2 = ((dictionary != null) ? MiniJson.Dict(dictionary, "req_0") : null);
				Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "data") : null);
				if (dictionary3 == null)
				{
					long num = ((dictionary != null) ? MiniJson.Lng(dictionary, "code", 0L) : 0);
					long num2 = ((dictionary2 != null) ? MiniJson.Lng(dictionary2, "code", 0L) : 0);
					_lastDesktopError = "桌面端响应异常 code=" + ((num2 != 0L) ? num2 : num);
					return Fail(song, -112, _lastDesktopError);
				}
				string text3 = "";
				List<object> list = MiniJson.List(dictionary3, "sip");
				if (list != null && list.Count > 0)
				{
					text3 = Convert.ToString(list[0]);
				}
				string text4 = "";
				string hit = "";
				long num3 = 0L;
				List<object> list2 = MiniJson.List(dictionary3, "midurlinfo");
				if (list2 != null)
				{
					string text5 = "";
					string text6 = "";
					foreach (object item in list2)
					{
						Dictionary<string, object> dictionary4 = MiniJson.AsObject(item);
						if (dictionary4 != null)
						{
							long num4 = MiniJson.Lng(dictionary4, "result", 0L);
							if (num4 != 0L)
							{
								num3 = num4;
							}
							else
							{
								string text7 = MiniJson.Str(dictionary4, "purl", "");
								if (!string.IsNullOrEmpty(text7))
								{
									string text8 = MiniJson.Str(dictionary4, "filename", "");
									if (text8.IndexOf("M800", StringComparison.OrdinalIgnoreCase) >= 0)
									{
										text4 = text7;
										hit = text8;
										break;
									}
									if (string.IsNullOrEmpty(text5))
									{
										text5 = text7;
										text6 = text8;
									}
								}
							}
						}
					}
					if (string.IsNullOrEmpty(text4) && !string.IsNullOrEmpty(text5))
					{
						text4 = text5;
						hit = text6;
					}
				}
				if (string.IsNullOrEmpty(text4))
				{
					switch (num3)
					{
					case 104004L:
						_lastDesktopError = "需要单独付费购买（result=104004）";
						return Fail(song, -104004, _lastDesktopError);
					case 104003L:
						_lastDesktopError = "账号没有这首歌的播放权限（result=104003）";
						return Fail(song, -104003, _lastDesktopError);
					default:
						_lastDesktopError = "桌面端没返回直链 result=" + num3;
						return Fail(song, -112, _lastDesktopError);
					}
				}
				string text9 = ((text3.Length > 0) ? text3 : "https://isure.stream.qqmusic.qq.com/");
				string url = NeteaseClient.ForceHttps(text9.TrimEnd(new char[1] { '/' }) + "/" + text4.TrimStart(new char[1] { '/' }));
				if (!(await VerifyUrlAsync(url, ct).ConfigureAwait(continueOnCapturedContext: false)))
				{
					_lastDesktopError = "桌面端直链 CDN 拒绝下载";
					return Fail(song, -112, _lastDesktopError);
				}
				bool flag = hit.IndexOf("M800", StringComparison.OrdinalIgnoreCase) >= 0;
				return new SongUrlResult
				{
					Id = ((song != null) ? song.Id : 0),
					Url = url,
					Code = 200,
					Br = (flag ? 320000 : 128000),
					Level = (flag ? "320k · 桌面通道" : "128k · 桌面通道"),
					Fee = ((song != null) ? song.Fee : 0)
				};
			}, ct);
		}

		private Task<string> ProbeAccountAsync(CancellationToken ct)
		{
			EnsureGuid();
			string uin = Uin;
			string key = Authst;
			string cookie = CookieText;
			int loginType = _loginType;
			return _throttle.RunAsync(async delegate
			{
				try
				{
					string text = "{\"ct\":19,\"cv\":2201,\"uin\":\"" + uin + "\",\"authst\":\"" + key + "\",\"g_tk\":" + Hash33(key) + ",\"tmeLoginType\":" + loginType + "}";
					string text2 = "{\"module\":\"music.UserInfo.userInfoServer\",\"method\":\"GetLoginUserInfo\",\"param\":{}}";
					string body = "{\"comm\":" + text + ",\"req_0\":" + text2 + "}";
					Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(await PostJsonWithCookieAsync("https://u.y.qq.com/cgi-bin/musicu.fcg", body, cookie, ct).ConfigureAwait(continueOnCapturedContext: false)));
					Dictionary<string, object> dictionary2 = ((dictionary != null) ? MiniJson.Dict(dictionary, "req_0") : null);
					long num = ((dictionary2 != null) ? MiniJson.Lng(dictionary2, "code", 0L) : 0);
					if (num == 1000 || num == 104400 || num == 104401)
					{
						return (string)null;
					}
					Dictionary<string, object> dictionary3 = ((dictionary2 != null) ? MiniJson.Dict(dictionary2, "data") : null);
					if (dictionary3 == null || dictionary3.Count == 0)
					{
						return (string)null;
					}
					string text3 = MiniJson.Str(dictionary3, "nick", "");
					string text4 = MiniJson.Str(dictionary3, "str_musicid", "");
					long result = MiniJson.Lng(dictionary3, "musicid", 0L);
					if (result == 0L && !string.IsNullOrEmpty(text4))
					{
						long.TryParse(text4, out result);
					}
					if (result == 0L)
					{
						result = MiniJson.Lng(dictionary3, "uin", 0L);
					}
					if (result == 0L)
					{
						return (string)null;
					}
					return string.IsNullOrEmpty(text3) ? ("uin=" + result) : (text3 + "(uin=" + result + ")");
				}
				catch
				{
					return (string)null;
				}
			}, ct);
		}

		private static SongUrlResult Fail(SongInfo song, int code, string message)
		{
			return new SongUrlResult
			{
				Id = (song?.Id ?? 0),
				Code = code,
				Fee = (song?.Fee ?? 1),
				Message = message
			};
		}

		private static string Trim(string text, int max)
		{
			string text2 = (text ?? "").Replace("\r", " ").Replace("\n", " ").Trim();
			if (text2.Length <= max)
			{
				return text2;
			}
			return text2.Substring(0, max);
		}

		public Task<LyricResult> GetLyricAsync(SongInfo song, CancellationToken ct = default(CancellationToken))
		{
			string mid = ((song == null) ? "" : (string.IsNullOrEmpty(song.SourceId) ? song.Id.ToString() : song.SourceId));
			long id = song?.Id ?? 0;
			if (string.IsNullOrEmpty(mid))
			{
				return Task.FromResult(new LyricResult
				{
					Id = id
				});
			}
			return _throttle.RunAsync(async delegate
			{
				string url = "https://c.y.qq.com/lyric/fcgi-bin/fcg_query_lyric_new.fcg?songmid=" + Uri.EscapeDataString(mid) + "&format=json&nobase64=0&g_tk=5381&loginUin=0&hostUin=0&platform=yqq&needNewCode=0";
				Dictionary<string, object> dictionary = MiniJson.AsObject(MiniJson.Parse(await GetAsync(url, ct).ConfigureAwait(continueOnCapturedContext: false)));
				return (dictionary == null) ? new LyricResult
				{
					Id = id
				} : new LyricResult
				{
					Id = id,
					Lrc = DecodeBase64(MiniJson.Str(dictionary, "lyric", "")),
					Translated = DecodeBase64(MiniJson.Str(dictionary, "trans", ""))
				};
			}, ct);
		}

		private static string DecodeBase64(string b64)
		{
			if (string.IsNullOrEmpty(b64))
			{
				return "";
			}
			try
			{
				return Encoding.UTF8.GetString(Convert.FromBase64String(b64));
			}
			catch
			{
				return (b64.IndexOf('[') >= 0) ? b64 : "";
			}
		}

		private async Task<string> GetAsync(string url, CancellationToken ct)
		{
			HttpRequestMessage req = new HttpRequestMessage(HttpMethod.Get, url);
			try
			{
				((HttpHeaders)req.Headers).TryAddWithoutValidation("Referer", "https://y.qq.com/portal/player.html");
				HttpResponseMessage resp = await ((HttpMessageInvoker)_http).SendAsync(req, ct).ConfigureAwait(continueOnCapturedContext: false);
				try
				{
					resp.EnsureSuccessStatusCode();
					return await resp.Content.ReadAsStringAsync().ConfigureAwait(continueOnCapturedContext: false);
				}
				finally
				{
					((IDisposable)resp)?.Dispose();
				}
			}
			finally
			{
				((IDisposable)req)?.Dispose();
			}
		}

		private async Task<string> GetRawAsync(string url, CancellationToken ct, string referer = null)
		{
			HttpRequestMessage req = new HttpRequestMessage(HttpMethod.Get, url);
			try
			{
				((HttpHeaders)req.Headers).TryAddWithoutValidation("Referer", referer ?? "https://y.qq.com/portal/player.html");
				HttpResponseMessage resp = await ((HttpMessageInvoker)_http).SendAsync(req, ct).ConfigureAwait(continueOnCapturedContext: false);
				try
				{
					return await resp.Content.ReadAsStringAsync().ConfigureAwait(continueOnCapturedContext: false);
				}
				finally
				{
					((IDisposable)resp)?.Dispose();
				}
			}
			finally
			{
				((IDisposable)req)?.Dispose();
			}
		}

		private async Task<byte[]> GetWithCaptureAsync(string url, CancellationToken ct)
		{
			_lastSetCookie = "";
			HttpRequestMessage req = new HttpRequestMessage(HttpMethod.Get, url);
			try
			{
				((HttpHeaders)req.Headers).TryAddWithoutValidation("Referer", "https://xui.ptlogin2.qq.com/");
				HttpResponseMessage resp = await ((HttpMessageInvoker)_http).SendAsync(req, ct).ConfigureAwait(continueOnCapturedContext: false);
				try
				{
					try
					{
						if (((HttpHeaders)resp.Headers).Contains("Set-Cookie"))
						{
							_lastSetCookie = string.Join("\n", ((HttpHeaders)resp.Headers).GetValues("Set-Cookie"));
						}
					}
					catch
					{
					}
					return await resp.Content.ReadAsByteArrayAsync().ConfigureAwait(continueOnCapturedContext: false);
				}
				finally
				{
					((IDisposable)resp)?.Dispose();
				}
			}
			finally
			{
				((IDisposable)req)?.Dispose();
			}
		}

		private static string ExtractSetCookie(string setCookieText, string name)
		{
			if (string.IsNullOrEmpty(setCookieText) || string.IsNullOrEmpty(name))
			{
				return null;
			}
			string[] array = setCookieText.Split(new char[1] { '\n' });
			foreach (string text in array)
			{
				int num = text.IndexOf(name + "=", StringComparison.Ordinal);
				if (num == 0 || (num > 0 && (text[num - 1] == ' ' || text[num - 1] == ';')))
				{
					int num2 = num + name.Length + 1;
					int num3 = text.IndexOf(';', num2);
					string text2 = ((num3 < 0) ? text.Substring(num2) : text.Substring(num2, num3 - num2)).Trim();
					if (text2.Length > 0)
					{
						return text2;
					}
				}
			}
			return null;
		}

		private async Task<byte[]> GetBinaryAsync(string url, CancellationToken ct)
		{
			HttpRequestMessage req = new HttpRequestMessage(HttpMethod.Get, url);
			try
			{
				((HttpHeaders)req.Headers).TryAddWithoutValidation("Referer", "https://y.qq.com/portal/player.html");
				HttpResponseMessage resp = await ((HttpMessageInvoker)_http).SendAsync(req, ct).ConfigureAwait(continueOnCapturedContext: false);
				try
				{
					resp.EnsureSuccessStatusCode();
					return await resp.Content.ReadAsByteArrayAsync().ConfigureAwait(continueOnCapturedContext: false);
				}
				finally
				{
					((IDisposable)resp)?.Dispose();
				}
			}
			finally
			{
				((IDisposable)req)?.Dispose();
			}
		}

		private async Task<string> PostJsonAsync(string url, string body, CancellationToken ct)
		{
			StringContent content = new StringContent(body, Encoding.UTF8, "application/json");
			try
			{
				HttpRequestMessage val = new HttpRequestMessage(HttpMethod.Post, url);
				val.Content = (HttpContent)content;
				HttpRequestMessage req = val;
				try
				{
					((HttpHeaders)req.Headers).TryAddWithoutValidation("Referer", "https://y.qq.com/");
					HttpResponseMessage resp = await ((HttpMessageInvoker)_http).SendAsync(req, ct).ConfigureAwait(continueOnCapturedContext: false);
					try
					{
						resp.EnsureSuccessStatusCode();
						return await resp.Content.ReadAsStringAsync().ConfigureAwait(continueOnCapturedContext: false);
					}
					finally
					{
						((IDisposable)resp)?.Dispose();
					}
				}
				finally
				{
					((IDisposable)req)?.Dispose();
				}
			}
			finally
			{
				((IDisposable)content)?.Dispose();
			}
		}

		private async Task<string> PostJsonWithCookieAsync(string url, string body, string cookieHeader, CancellationToken ct)
		{
			StringContent content = new StringContent(body, Encoding.UTF8, "application/json");
			try
			{
				HttpRequestMessage val = new HttpRequestMessage(HttpMethod.Post, url);
				val.Content = (HttpContent)content;
				HttpRequestMessage req = val;
				try
				{
					((HttpHeaders)req.Headers).TryAddWithoutValidation("Referer", "https://y.qq.com/");
					if (!string.IsNullOrEmpty(cookieHeader))
					{
						((HttpHeaders)req.Headers).TryAddWithoutValidation("Cookie", cookieHeader);
					}
					HttpResponseMessage resp = await ((HttpMessageInvoker)_cookielessHttp).SendAsync(req, ct).ConfigureAwait(continueOnCapturedContext: false);
					try
					{
						resp.EnsureSuccessStatusCode();
						return await resp.Content.ReadAsStringAsync().ConfigureAwait(continueOnCapturedContext: false);
					}
					finally
					{
						((IDisposable)resp)?.Dispose();
					}
				}
				finally
				{
					((IDisposable)req)?.Dispose();
				}
			}
			finally
			{
				((IDisposable)content)?.Dispose();
			}
		}

		private Dictionary<string, string> FlattenCookies()
		{
			Dictionary<string, string> dictionary = new Dictionary<string, string>(StringComparer.Ordinal);
			Uri[] array = new Uri[7]
			{
				new Uri("https://ssl.ptlogin2.graph.qq.com/"),
				new Uri("https://graph.qq.com/"),
				new Uri("https://ssl.ptlogin2.qq.com/"),
				new Uri("https://ptlogin2.qq.com/"),
				new Uri("https://xui.ptlogin2.qq.com/"),
				new Uri("https://y.qq.com/"),
				new Uri("https://qq.com/")
			};
			foreach (Uri uri in array)
			{
				try
				{
					foreach (Cookie cookie in _cookies.GetCookies(uri))
					{
						if (!string.IsNullOrEmpty(cookie.Name) && !string.IsNullOrEmpty(cookie.Value) && !dictionary.ContainsKey(cookie.Name))
						{
							dictionary[cookie.Name] = cookie.Value;
						}
					}
				}
				catch
				{
				}
			}
			return dictionary;
		}

		private string BuildCookieHeader()
		{
			StringBuilder stringBuilder = new StringBuilder();
			foreach (KeyValuePair<string, string> item in FlattenCookies())
			{
				if (stringBuilder.Length > 0)
				{
					stringBuilder.Append("; ");
				}
				stringBuilder.Append(item.Key).Append('=').Append(item.Value);
			}
			return stringBuilder.ToString();
		}

		private async Task<RedirectResult> PostFormRedirectAsync(string url, Dictionary<string, string> form, string referer, CancellationToken ct)
		{
			HttpClientHandler val = new HttpClientHandler();
			val.UseCookies = false;
			val.AllowAutoRedirect = false;
			HttpClientHandler handler = val;
			try
			{
				HttpClient val2 = new HttpClient((HttpMessageHandler)handler);
				val2.Timeout = TimeSpan.FromSeconds(20.0);
				HttpClient client = val2;
				try
				{
					((HttpHeaders)client.DefaultRequestHeaders).TryAddWithoutValidation("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36");
					((HttpHeaders)client.DefaultRequestHeaders).TryAddWithoutValidation("Referer", referer);
					FormUrlEncodedContent content = new FormUrlEncodedContent((IEnumerable<KeyValuePair<string, string>>)form);
					try
					{
						HttpRequestMessage val3 = new HttpRequestMessage(HttpMethod.Post, url);
						val3.Content = (HttpContent)content;
						HttpRequestMessage req = val3;
						try
						{
							string text = BuildCookieHeader();
							if (text.Length > 0)
							{
								((HttpHeaders)req.Headers).TryAddWithoutValidation("Cookie", text);
							}
							HttpResponseMessage resp = await ((HttpMessageInvoker)client).SendAsync(req, ct).ConfigureAwait(continueOnCapturedContext: false);
							try
							{
								RedirectResult r = new RedirectResult();
								Uri location = resp.Headers.Location;
								if (location != null)
								{
									r.Location = (location.IsAbsoluteUri ? location.ToString() : new Uri(new Uri(url), location).ToString());
								}
								RedirectResult redirectResult = r;
								redirectResult.Body = await resp.Content.ReadAsStringAsync().ConfigureAwait(continueOnCapturedContext: false);
								return r;
							}
							finally
							{
								((IDisposable)resp)?.Dispose();
							}
						}
						finally
						{
							((IDisposable)req)?.Dispose();
						}
					}
					finally
					{
						((IDisposable)content)?.Dispose();
					}
				}
				finally
				{
					((IDisposable)client)?.Dispose();
				}
			}
			finally
			{
				((IDisposable)handler)?.Dispose();
			}
		}

		private static long StableId(string mid)
		{
			ulong num = 1469598103934665603uL;
			for (int i = 0; i < mid.Length; i++)
			{
				num ^= mid[i];
				num *= 1099511628211L;
			}
			return (long)(num & 0x7FFFFFFFFFFFFFFFL);
		}

		public void Dispose()
		{
			try
			{
				((HttpMessageInvoker)_http).Dispose();
			}
			catch
			{
			}
		}

		private string DesktopComm()
		{
			string text = LookupKey();
			int num = Hash33(text);
			return "{\"ct\":19,\"cv\":2201,\"uin\":\"" + Uin + "\",\"authst\":\"" + text + "\",\"g_tk\":" + num + ",\"tmeLoginType\":" + _loginType + "}";
		}

		private string LookupKey()
		{
			string text = LookupCookie("qqmusic_key");
			if (string.IsNullOrEmpty(text))
			{
				text = LookupCookie("qm_keyst");
			}
			if (string.IsNullOrEmpty(text))
			{
				text = LookupCookie("musickey");
			}
			return text ?? "";
		}

		private async Task<Dictionary<string, object>> CgiAsync(string module, string method, string paramJson, CancellationToken ct)
		{
			string body = "{\"comm\":" + DesktopComm() + ",\"req_0\":{\"module\":\"" + module + "\",\"method\":\"" + method + "\",\"param\":" + paramJson + "}}";
			Dictionary<string, object> dictionary = MiniJson.Dict(MiniJson.AsObject(MiniJson.Parse(await PostJsonWithCookieAsync("https://u.y.qq.com/cgi-bin/musicu.fcg?format=json&platform=yqq.json", body, CookieText, ct).ConfigureAwait(continueOnCapturedContext: false))), "req_0");
			if (dictionary == null)
			{
				return null;
			}
			long num = MiniJson.Lng(dictionary, "code", 0L);
			if (num != 0L)
			{
				throw new InvalidOperationException("QQ " + module + " 返回 " + num);
			}
			return MiniJson.Dict(dictionary, "data");
		}

		public async Task<string> GetEncryptUinAsync(CancellationToken ct = default(CancellationToken))
		{
			if (!string.IsNullOrEmpty(_encryptUin))
			{
				return _encryptUin;
			}
			try
			{
				Dictionary<string, object> dictionary = await CgiAsync("music.UserInfo.userInfoServer", "GetLoginUserInfo", "{}", ct).ConfigureAwait(continueOnCapturedContext: false);
				Dictionary<string, object>[] array = new Dictionary<string, object>[3]
				{
					MiniJson.Dict(dictionary, "info"),
					MiniJson.Dict(MiniJson.Dict(dictionary, "info"), "base"),
					dictionary
				};
				foreach (Dictionary<string, object> dictionary2 in array)
				{
					if (dictionary2 != null)
					{
						string text = MiniJson.Str(dictionary2, "encrypt_uin", "");
						if (string.IsNullOrEmpty(text))
						{
							text = MiniJson.Str(dictionary2, "encryptUin", "");
						}
						if (!string.IsNullOrEmpty(text))
						{
							_encryptUin = text;
							return text;
						}
					}
				}
			}
			catch
			{
			}
			return "";
		}

		public async Task<List<PlaylistInfo>> GetPlaylistsAsync(CancellationToken ct = default(CancellationToken))
		{
			List<PlaylistInfo> list = new List<PlaylistInfo>();
			if (!HasLogin)
			{
				return list;
			}
			list.Add(new PlaylistInfo
			{
				Id = "201",
				Name = "我喜欢的音乐",
				IsFavorites = true,
				DirId = 201,
				Platform = Platform.QQ,
				Creator = "QQ音乐"
			});
			try
			{
				List<object> list2 = MiniJson.List(await CgiAsync("music.musicasset.PlaylistBaseRead", "GetPlaylistByUin", "{\"uin\":\"" + Uin + "\"}", ct).ConfigureAwait(continueOnCapturedContext: false), "v_playlist");
				if (list2 != null