using Newtonsoft.Json.Linq;
using System.Net.WebSockets;
using System.Text;

namespace YD_YiLu.Api.WebSockets
{
    public static class DeviceWebSocketSender
    {
        public static async Task SendAsync(WebSocket socket, string request, object data, CancellationToken ct)
        {
            var msg = new JObject
            {
                ["msgId"] = Guid.NewGuid().ToString("N"),
                ["request"] = request,
                ["data"] = JObject.FromObject(data ?? new { }),
                ["msg"] = "",
                ["code"] = 0
            }.ToString();

            var bytes = Encoding.UTF8.GetBytes(msg);
            await socket.SendAsync(bytes, WebSocketMessageType.Text, true, ct);
        }
    }
}