You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
104 lines
2.6 KiB
104 lines
2.6 KiB
using DataBase.Entity;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Net.Sockets;
|
|
using System.Net;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using Shared.DTO;
|
|
using System.ComponentModel;
|
|
|
|
namespace Server
|
|
{
|
|
public class Room : INotifyPropertyChanged
|
|
{
|
|
|
|
public Room(string id, bool availaible)
|
|
{
|
|
Id = id;
|
|
Availaible = availaible;
|
|
}
|
|
|
|
public bool Availaible { get; set; }
|
|
|
|
public event PropertyChangedEventHandler? PropertyChanged;
|
|
|
|
public string Id { get; set; }
|
|
|
|
public KeyValuePair <Player, UdpClient> playerHost;
|
|
public KeyValuePair <Player, UdpClient> playerJoin;
|
|
public int Port { get; set; }
|
|
|
|
|
|
public int nbPlayer = 0;
|
|
|
|
public bool maxPlayer
|
|
{
|
|
get { return nbPlayer >= 2; }
|
|
set
|
|
{
|
|
if (nbPlayer >= 2)
|
|
{
|
|
maxPlayer = true;
|
|
NotifyPropertyChanged("Ready");
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
protected void NotifyPropertyChanged(string propertyName)
|
|
{
|
|
PropertyChanged?.Invoke(this, new PropertyChangedEventArgs(propertyName));
|
|
}
|
|
|
|
|
|
|
|
public void ReceiveMessages(UdpClient clientSocket1, UdpClient clientSocket2)
|
|
{
|
|
IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0);
|
|
|
|
while (true)
|
|
{
|
|
byte[] receivedData = clientSocket1.Receive(ref remoteEndPoint);
|
|
|
|
string receivedMessage = Encoding.ASCII.GetString(receivedData);
|
|
Console.WriteLine("Received from " + remoteEndPoint.ToString() + ": " + receivedMessage);
|
|
|
|
|
|
clientSocket2.Send(receivedData, receivedData.Length, remoteEndPoint);
|
|
|
|
}
|
|
}
|
|
|
|
public void OnReadyChanged(object sender, PropertyChangedEventArgs e)
|
|
{
|
|
|
|
Room nbPlayer = sender as Room;
|
|
bool maxPlayer = nbPlayer.maxPlayer;
|
|
|
|
IPEndPoint serverEndPoint = new IPEndPoint(IPAddress.Any, Port);
|
|
UdpClient serverSocket = new UdpClient(serverEndPoint);
|
|
|
|
if (maxPlayer)
|
|
{
|
|
|
|
Thread receiveThread1 = new Thread(() => ReceiveMessages(playerHost.Value, playerJoin.Value));
|
|
|
|
|
|
Thread receiveThread2 = new Thread(() => ReceiveMessages(playerJoin.Value, playerHost.Value));
|
|
|
|
receiveThread1.Start();
|
|
receiveThread2.Start();
|
|
|
|
receiveThread1.Join();
|
|
receiveThread2.Join();
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
}
|