using System;
using System.Threading;
using System.Threading.Tasks;
using Websocket.Client;

namespace WSDemo
{
    class Program
    {
        static void Main(string[] args)
        {
            var exitEvent = new ManualResetEvent(false);
            var url = new Uri("wss://web.cqjgjyw.cn/websocket");

            using (var client = new WebsocketClient(url))
            {
                client.ReconnectTimeout = TimeSpan.FromSeconds(30);
                client.ReconnectionHappened.Subscribe(info =>
                    Console.WriteLine($"Reconnection happened, type: {info.Type}"));

                client.MessageReceived.Subscribe(msg => Console.WriteLine($"Message received: {msg}"));
                client.StartOrFail();

                Task.Run(() => client.Send("{code:10000,nick:\"张三\",\"room\":\"push_5678\"}"));
                Task.Run(() =>
                {
                    while (true)
                    {
                        client.Send($"{{\"code\":10086,\"mess\":\"{Guid.NewGuid()}\",\"room\":\"push_5678\"}}");
                        client.Send("{code:10016}");
                        Thread.Sleep(5000);
                    }
                });

                exitEvent.WaitOne();
            }
        }
    }
}