using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using Fleck;
namespace FlekTest
{
class Program
{
static void Main(string[] args)
{
FleckLog.Level = LogLevel.Debug;
var allSockets = new List<IWebSocketConnection>();
var server = new WebSocketServer("ws://0.0.0.0:509");
server.Start(socket =>
{
socket.OnOpen = () =>
{
Console.WriteLine("Socket Opened");
allSockets.Add(socket);
};
socket.OnClose = () =>
{
Console.WriteLine("Socket" + socket.ConnectionInfo + "Closed");
allSockets.Remove(socket);
};
socket.OnMessage = message =>
{
Console.WriteLine(message);
foreach(IWebSocketConnection sc in allSockets.Where(sc => socket.ConnectionInfo.ClientIpAddress != sc.ConnectionInfo.ClientIpAddress))
{
sc.Send(message);
}
};
});
string input = "";
while (input != "q")
{
foreach (var socket in allSockets.ToList())
{
socket.Send(input);
}
input = Console.ReadLine();
}
server.Dispose();
Console.WriteLine("Server Closed");
Console.ReadKey();
}
}
}
