sem/Proftaak-RH-B4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connecting to doctor after works

Browse Source
This commit is contained in:
shinichi
2020-10-16 12:18:03 +02:00
parent ac11f6c53b
commit 9ef51ddeca
4 changed files with 44 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Server/Client.cs
View File

@@ -97,16 +97,17 @@ namespace Server
switch (identifier)
{
case DataParser.LOGIN:
handleLogin(payloadbytes);
if (handleLogin(payloadbytes))
communication.NewLogin(this);
break;
case DataParser.LOGIN_DOCTOR:
if (communication.doctor != null)
if (communication.Doctor != null)
return;
if (handleLogin(payloadbytes))
{
communication.doctor = this;
Console.WriteLine("Set doctor to " + communication.doctor + " , this is " + this);
communication.Doctor = this;
Console.WriteLine("Set doctor to " + communication.Doctor + " , this is " + this);
}
break;
case DataParser.START_SESSION:
@@ -168,7 +169,6 @@ namespace Server
this.username = username;
sendMessage(DataParser.getLoginResponse("OK"));
sendMessage(DataParser.getStartSessionJson());
communication.NewLogin(this);
return true;
}
else

40
Server/Communication.cs
View File

@@ -1,5 +1,6 @@
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO.Pipes;
using System.Linq;
using System.Net.Sockets;
@@ -13,7 +14,24 @@ namespace Server
{
private TcpListener listener;
private List<Client> clients;
public Client doctor;
private Client mDoctor;
public Client Doctor
{
get
{
return this.mDoctor;
}
set
{
this.mDoctor = value;
this.clients.ForEach((client) =>
{
var dinges = DataParser.getNewConnectionJson(client.username);
Debug.WriteLine("foreach " + Encoding.ASCII.GetString(dinges));
this.mDoctor.sendMessage(dinges);
});
}
}
public Communication(TcpListener listener)
{
this.listener = listener;
@@ -34,7 +52,7 @@ namespace Server
var tcpClient = listener.EndAcceptTcpClient(ar);
Console.WriteLine($"Client connected from {tcpClient.Client.RemoteEndPoint}");
clients.Add(new Client(this, tcpClient));
new Client(this, tcpClient);
listener.BeginAcceptTcpClient(new AsyncCallback(OnConnect), null);
}
@@ -45,15 +63,19 @@ namespace Server
public void NewLogin(Client client)
{
if (doctor == null)
clients.Add(client);
var dinges = DataParser.getNewConnectionJson(client.username);
Debug.WriteLine("new login" + Encoding.ASCII.GetString(dinges));
Doctor?.sendMessage(dinges);
}
public void LogOff(Client client)
{
if (this.Doctor == client)
{
doctor = client;
this.Doctor = null;
}
else
{
doctor.sendMessage(DataParser.getNewConnectionJson(client.username));
}
this.clients.Remove(client);
}
}
}