diff --git a/DoctorApp/Utils/Client.cs b/DoctorApp/Utils/Client.cs index 26a87fb..668315b 100644 --- a/DoctorApp/Utils/Client.cs +++ b/DoctorApp/Utils/Client.cs @@ -10,7 +10,7 @@ using Util; namespace DoctorApp.Utils { public delegate void EngineCallback(); - public class Client : IDataReceiver + public class Client { private TcpClient client; private NetworkStream stream; @@ -18,8 +18,6 @@ namespace DoctorApp.Utils private bool connected; private byte[] totalBuffer = new byte[1024]; private int totalBufferReceived = 0; - private bool sessionRunning = false; - private IHandler handler = null; private LoginViewModel LoginViewModel; private MainViewModel MainViewModel; private ClientInfoViewModel ClientInfoViewModel; @@ -83,6 +81,8 @@ namespace DoctorApp.Utils string identifier; bool isJson = DataParser.getJsonIdentifier(messageBytes, out identifier); + + Debug.WriteLine("doctor " + Encoding.ASCII.GetString(payloadbytes)); if (isJson) { switch (identifier) @@ -104,28 +104,15 @@ namespace DoctorApp.Utils break; case DataParser.START_SESSION: Console.WriteLine("Session started!"); - this.sessionRunning = true; - sendMessage(DataParser.getStartSessionJson()); break; case DataParser.STOP_SESSION: Console.WriteLine("Stop session identifier"); - this.sessionRunning = false; - sendMessage(DataParser.getStopSessionJson()); break; case DataParser.SET_RESISTANCE: Console.WriteLine("Set resistance identifier"); - if (this.handler == null) - { - Console.WriteLine("handler is null"); - sendMessage(DataParser.getSetResistanceResponseJson(false)); - } - else - { - this.handler.setResistance(DataParser.getResistanceFromJson(payloadbytes)); - sendMessage(DataParser.getSetResistanceResponseJson(true)); - } break; case DataParser.NEW_CONNECTION: + Debug.WriteLine("doctor client new connection"); this.MainViewModel.NewConnectedUser(DataParser.getUsernameFromResponseJson(payloadbytes)); break; case DataParser.DISCONNECT: @@ -167,63 +154,6 @@ namespace DoctorApp.Utils this.stream.EndWrite(ar); } - #region interface - //maybe move this to other place - /// - /// bpm method for receiving the BPM value from the bluetooth bike or the simulation - /// - /// the message - public void BPM(byte[] bytes) - { - if (!sessionRunning) - { - return; - } - if (bytes == null) - { - throw new ArgumentNullException("no bytes"); - } - byte[] message = DataParser.GetRawDataMessage(bytes); - - - this.stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null); - } - - /// - /// method for receiving the bike message from the bluetooth bike or the simulation - /// - /// the message - public void Bike(byte[] bytes) - { - - if (!sessionRunning) - { - return; - } - if (bytes == null) - { - throw new ArgumentNullException("no bytes"); - } - byte[] message = DataParser.GetRawDataMessage(bytes); - - /* switch (bytes[0]) - { - - case 0x10: - - if (canSendToEngine) engineConnection.BikeSpeed = (bytes[4] | (bytes[5] << 8)) * 0.01f; - break; - case 0x19: - if (canSendToEngine) engineConnection.BikePower = (bytes[5]) | (bytes[6] & 0b00001111) << 8; - break; - }*/ - - - this.stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null); - } - - #endregion - /// /// wether or not the client stream is connected /// @@ -246,15 +176,6 @@ namespace DoctorApp.Utils this.stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null); } - /// - /// sets the handler for the client, so either the bike simulator or the bluetooth bike handler - /// - /// - public void SetHandler(IHandler handler) - { - this.handler = handler; - } - internal void SetLoginViewModel(LoginViewModel loginViewModel) { this.LoginViewModel = loginViewModel; @@ -275,7 +196,6 @@ namespace DoctorApp.Utils Debug.WriteLine("client dispose called"); this.stream.Dispose(); this.client.Dispose(); - this.handler?.stop(); } } } diff --git a/DoctorApp/ViewModels/MainViewModel.cs b/DoctorApp/ViewModels/MainViewModel.cs index 2b34b32..52bd0cf 100644 --- a/DoctorApp/ViewModels/MainViewModel.cs +++ b/DoctorApp/ViewModels/MainViewModel.cs @@ -21,11 +21,12 @@ namespace DoctorApp.ViewModels { this.MainWindowViewModel = mainWindowViewModel; client = this.MainWindowViewModel.client; - Tabs= new ObservableCollection(); + Tabs = new ObservableCollection(); } public void NewConnectedUser(string username) { + System.Diagnostics.Debug.WriteLine("CREATING TAB FOR " + username); App.Current.Dispatcher.Invoke((Action)delegate { Tabs.Add(new ClientInfoViewModel @@ -42,5 +43,5 @@ namespace DoctorApp.ViewModels } } - + } diff --git a/Server/Client.cs b/Server/Client.cs index ed8e0c0..9e87382 100644 --- a/Server/Client.cs +++ b/Server/Client.cs @@ -6,6 +6,7 @@ using Newtonsoft.Json; using ClientApp.Utils; using System.Diagnostics; using Util; +using System.Linq; namespace Server { @@ -168,7 +169,7 @@ namespace Server Console.WriteLine("Log in"); this.username = username; sendMessage(DataParser.getLoginResponse("OK")); - sendMessage(DataParser.getStartSessionJson()); + //sendMessage(DataParser.getStartSessionJson()); return true; } else @@ -185,6 +186,7 @@ namespace Server public void sendMessage(byte[] message) { + Debug.WriteLine("serverclient " + Encoding.ASCII.GetString(message.Skip(5).ToArray())); stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null); } diff --git a/Server/Communication.cs b/Server/Communication.cs index d064de4..c5bff8c 100644 --- a/Server/Communication.cs +++ b/Server/Communication.cs @@ -26,8 +26,9 @@ namespace Server this.mDoctor = value; this.clients.ForEach((client) => { - var dinges = DataParser.getNewConnectionJson(client.username); - Debug.WriteLine("foreach " + Encoding.ASCII.GetString(dinges)); + Debug.WriteLine("foreach called for " + client.username); + byte[] dinges = DataParser.getNewConnectionJson(client.username); + Debug.WriteLine("foreach " + Encoding.ASCII.GetString(dinges.Skip(5).ToArray())); this.mDoctor.sendMessage(dinges); }); } @@ -63,7 +64,8 @@ namespace Server public void NewLogin(Client client) { - clients.Add(client); + this.clients.Add(client); + Debug.WriteLine("amount of clients is now " + this.clients.Count); var dinges = DataParser.getNewConnectionJson(client.username); Debug.WriteLine("new login" + Encoding.ASCII.GetString(dinges)); Doctor?.sendMessage(dinges);