diff --git a/DoctorApp/App.xaml b/DoctorApp/App.xaml new file mode 100644 index 0000000..1fcbd5c --- /dev/null +++ b/DoctorApp/App.xaml @@ -0,0 +1,22 @@ + + + + + + + + + + + + + + + + diff --git a/DoctorApp/App.xaml.cs b/DoctorApp/App.xaml.cs new file mode 100644 index 0000000..018bc45 --- /dev/null +++ b/DoctorApp/App.xaml.cs @@ -0,0 +1,17 @@ +using System; +using System.Collections.Generic; +using System.Configuration; +using System.Data; +using System.Linq; +using System.Threading.Tasks; +using System.Windows; + +namespace DoctorApp +{ + /// + /// Interaction logic for App.xaml + /// + public partial class App : Application + { + } +} diff --git a/DoctorApp/AssemblyInfo.cs b/DoctorApp/AssemblyInfo.cs new file mode 100644 index 0000000..8b5504e --- /dev/null +++ b/DoctorApp/AssemblyInfo.cs @@ -0,0 +1,10 @@ +using System.Windows; + +[assembly: ThemeInfo( + ResourceDictionaryLocation.None, //where theme specific resource dictionaries are located + //(used if a resource is not found in the page, + // or application resource dictionaries) + ResourceDictionaryLocation.SourceAssembly //where the generic resource dictionary is located + //(used if a resource is not found in the page, + // app, or any theme specific resource dictionaries) +)] diff --git a/DoctorApp/DoctorApp.csproj b/DoctorApp/DoctorApp.csproj new file mode 100644 index 0000000..516e849 --- /dev/null +++ b/DoctorApp/DoctorApp.csproj @@ -0,0 +1,22 @@ + + + + WinExe + netcoreapp3.1 + true + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/DoctorApp/FodyWeavers.xml b/DoctorApp/FodyWeavers.xml new file mode 100644 index 0000000..d5abfed --- /dev/null +++ b/DoctorApp/FodyWeavers.xml @@ -0,0 +1,3 @@ + + + \ No newline at end of file diff --git a/DoctorApp/FodyWeavers.xsd b/DoctorApp/FodyWeavers.xsd new file mode 100644 index 0000000..69dbe48 --- /dev/null +++ b/DoctorApp/FodyWeavers.xsd @@ -0,0 +1,74 @@ + + + + + + + + + + + Used to control if the On_PropertyName_Changed feature is enabled. + + + + + Used to control if the Dependent properties feature is enabled. + + + + + Used to control if the IsChanged property feature is enabled. + + + + + Used to change the name of the method that fires the notify event. This is a string that accepts multiple values in a comma separated form. + + + + + Used to control if equality checks should be inserted. If false, equality checking will be disabled for the project. + + + + + Used to control if equality checks should use the Equals method resolved from the base class. + + + + + Used to control if equality checks should use the static Equals method resolved from the base class. + + + + + Used to turn off build warnings from this weaver. + + + + + Used to turn off build warnings about mismatched On_PropertyName_Changed methods. + + + + + + + + 'true' to run assembly verification (PEVerify) on the target assembly after all weavers have been executed. + + + + + A comma-separated list of error codes that can be safely ignored in assembly verification. + + + + + 'false' to turn off automatic generation of the XML Schema file. + + + + + \ No newline at end of file diff --git a/DoctorApp/Models/Info.cs b/DoctorApp/Models/Info.cs new file mode 100644 index 0000000..4c195ca --- /dev/null +++ b/DoctorApp/Models/Info.cs @@ -0,0 +1,16 @@ +using DoctorApp.Utils; +using System; +using System.Collections.Generic; +using System.Text; + +namespace DoctorApp.Models +{ + class Info : ObservableObject + { + public bool ConnectedToServer { get; set; } + public bool ConnectedToVREngine { get; set; } + public bool DoctorConnected { get; set; } + + public bool CanConnectToVR { get; set; } + } +} diff --git a/DoctorApp/Utils/Client.cs b/DoctorApp/Utils/Client.cs new file mode 100644 index 0000000..9ce05b7 --- /dev/null +++ b/DoctorApp/Utils/Client.cs @@ -0,0 +1,269 @@ +using System; +using System.Diagnostics; +using System.Linq; +using System.Net.Sockets; +using System.Text; +using DoctorApp.ViewModels; +using ProftaakRH; + +namespace DoctorApp.Utils +{ + public delegate void EngineCallback(); + public class Client : IDataReceiver + { + private TcpClient client; + private NetworkStream stream; + private byte[] buffer = new byte[1024]; + 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; + + + public Client() : this("localhost", 5555) + { + + } + + public Client(string adress, int port) + { + this.client = new TcpClient(); + this.connected = false; + client.BeginConnect(adress, port, new AsyncCallback(OnConnect), null); + } + + /// + /// callback method for when the TCP client is connected + /// + /// the result of the async read + private void OnConnect(IAsyncResult ar) + { + this.client.EndConnect(ar); + Console.WriteLine("TCP client Verbonden!"); + + this.stream = this.client.GetStream(); + + this.stream.BeginRead(this.buffer, 0, this.buffer.Length, new AsyncCallback(OnRead), null); + } + + /// + /// callback method for when there is a message read + /// + /// the result of the async read + private void OnRead(IAsyncResult ar) + { + int receivedBytes = this.stream.EndRead(ar); + + if (totalBufferReceived + receivedBytes > 1024) + { + throw new OutOfMemoryException("buffer too small"); + } + Array.Copy(buffer, 0, totalBuffer, totalBufferReceived, receivedBytes); + totalBufferReceived += receivedBytes; + + int expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0); + while (totalBufferReceived >= expectedMessageLength) + { + //volledig packet binnen + byte[] messageBytes = new byte[expectedMessageLength]; + Array.Copy(totalBuffer, 0, messageBytes, 0, expectedMessageLength); + + + byte[] payloadbytes = new byte[BitConverter.ToInt32(messageBytes, 0) - 5]; + + Array.Copy(messageBytes, 5, payloadbytes, 0, payloadbytes.Length); + + string identifier; + bool isJson = DataParser.getJsonIdentifier(messageBytes, out identifier); + if (isJson) + { + switch (identifier) + { + case DataParser.LOGIN_RESPONSE: + string responseStatus = DataParser.getResponseStatus(payloadbytes); + if (responseStatus == "OK") + { + Debug.WriteLine("Username and password correct!"); + this.LoginViewModel.setLoginStatus(true); + this.connected = true; + + } + else + { + this.LoginViewModel.setLoginStatus(false); + Debug.WriteLine($"login failed \"{responseStatus}\""); + } + 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: + this.MainViewModel.NewConnectedUser(DataParser.getUsernameFromResponseJson(payloadbytes)); + break; + case DataParser.DISCONNECT: + this.MainViewModel.NewConnectedUser(DataParser.getUsernameFromResponseJson(payloadbytes)); + break; + default: + Console.WriteLine($"Received json with identifier {identifier}:\n{Encoding.ASCII.GetString(payloadbytes)}"); + break; + } + } + else if (DataParser.isRawData(messageBytes)) + { + Console.WriteLine($"Received data: {BitConverter.ToString(payloadbytes)}"); + } + + totalBufferReceived -= expectedMessageLength; + expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0); + } + + this.stream.BeginRead(this.buffer, 0, this.buffer.Length, new AsyncCallback(OnRead), null); + + } + + /// + /// starts sending a message to the server + /// + /// the message to send + private void sendMessage(byte[] message) + { + stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null); + } + + /// + /// callback method for when a message is fully written to the server + /// + /// the async result representing the asynchronous call + private void OnWrite(IAsyncResult ar) + { + 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 + /// + /// true if it's connected, false if not + public bool IsConnected() + { + return this.connected; + } + /// + /// tries to log in to the server by asking for a username and password + /// + public void tryLogin(string username, string password) + { + string hashUser = Hashing.Hasher.HashString(username); + string hashPassword = Hashing.Hasher.HashString(password); + + byte[] message = DataParser.getJsonMessage(DataParser.GetLoginJson(hashUser, hashPassword)); + + + 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; + } + + internal void SetMainViewModel(MainViewModel mainViewModel) + { + this.MainViewModel = mainViewModel; + } + + internal void SetClientInfoViewModel(ClientInfoViewModel clientInfoViewModel) + { + this.ClientInfoViewModel = clientInfoViewModel; + } + } +} diff --git a/DoctorApp/Utils/DataParser.cs b/DoctorApp/Utils/DataParser.cs new file mode 100644 index 0000000..ca7ca90 --- /dev/null +++ b/DoctorApp/Utils/DataParser.cs @@ -0,0 +1,231 @@ +using Newtonsoft.Json; +using Newtonsoft.Json.Serialization; +using System; +using System.Globalization; +using System.Linq; +using System.Runtime.InteropServices.WindowsRuntime; +using System.Text; + +namespace DoctorApp.Utils +{ + public class DataParser + { + public const string LOGIN = "LOGIN"; + public const string LOGIN_RESPONSE = "LOGIN RESPONSE"; + public const string START_SESSION = "START SESSION"; + public const string STOP_SESSION = "STOP SESSION"; + public const string SET_RESISTANCE = "SET RESISTANCE"; + public const string NEW_CONNECTION = "NEW CONNECTION"; + public const string DISCONNECT = "DISCONNECT"; + /// + /// makes the json object with LOGIN identifier and username and password + /// + /// username + /// password + /// json object to ASCII to bytes + public static byte[] GetLoginJson(string mUsername, string mPassword) + { + dynamic json = new + { + identifier = LOGIN, + data = new + { + username = mUsername, + password = mPassword, + } + }; + + return Encoding.ASCII.GetBytes(JsonConvert.SerializeObject(json)); + } + + public static bool GetUsernamePassword(byte[] jsonbytes, out string username, out string password) + { + dynamic json = JsonConvert.DeserializeObject(Encoding.ASCII.GetString(jsonbytes)); + try + { + username = json.data.username; + password = json.data.password; + return true; + } + catch + { + username = null; + password = null; + return false; + } + } + + private static byte[] getJsonMessage(string mIdentifier, dynamic data) + { + dynamic json = new + { + identifier = mIdentifier, + data + }; + return getMessage(Encoding.ASCII.GetBytes(JsonConvert.SerializeObject(json)), 0x01); + } + + private static byte[] getJsonMessage(string mIdentifier) + { + dynamic json = new + { + identifier = mIdentifier, + }; + return getMessage(Encoding.ASCII.GetBytes(JsonConvert.SerializeObject(json)), 0x01); + } + + public static byte[] getLoginResponse(string mStatus) + { + return getJsonMessage(LOGIN_RESPONSE, new { status = mStatus }); + } + + public static string getResponseStatus(byte[] json) + { + return ((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.status; + } + + /// + /// get the identifier from json + /// + /// json in ASCII + /// gets the identifier + /// if it sucseeded + public static bool getJsonIdentifier(byte[] bytes, out string identifier) + { + if (bytes.Length <= 5) + { + throw new ArgumentException("bytes to short"); + } + byte messageId = bytes[4]; + + if (messageId == 0x01) + { + dynamic json = JsonConvert.DeserializeObject(Encoding.ASCII.GetString(bytes.Skip(5).ToArray())); + identifier = json.identifier; + return true; + } + else + { + identifier = ""; + return false; + } + } + + /// + /// checks if the de message is raw data according to the protocol + /// + /// message + /// if message contains raw data + public static bool isRawData(byte[] bytes) + { + if (bytes.Length <= 5) + { + throw new ArgumentException("bytes to short"); + } + return bytes[4] == 0x02; + } + + /// + /// constructs a message with the payload, messageId and clientId + /// + /// + /// + /// + /// the message ready for sending + private static byte[] getMessage(byte[] payload, byte messageId) + { + byte[] res = new byte[payload.Length + 5]; + + Array.Copy(BitConverter.GetBytes(payload.Length + 5), 0, res, 0, 4); + res[4] = messageId; + Array.Copy(payload, 0, res, 5, payload.Length); + + return res; + } + + /// + /// constructs a message with the payload and clientId and assumes the payload is raw data + /// + /// + /// + /// the message ready for sending + public static byte[] GetRawDataMessage(byte[] payload) + { + return getMessage(payload, 0x02); + } + + /// + /// constructs a message with the payload and clientId and assumes the payload is json + /// + /// + /// + /// the message ready for sending + public static byte[] getJsonMessage(byte[] payload) + { + return getMessage(payload, 0x01); + } + + public static byte[] getStartSessionJson() + { + return getJsonMessage(START_SESSION); + } + + public static byte[] getStopSessionJson() + { + return getJsonMessage(STOP_SESSION); + } + + public static byte[] getSetResistanceJson(float mResistance) + { + dynamic data = new + { + resistance = mResistance + }; + return getJsonMessage(SET_RESISTANCE, data); + } + + public static byte[] getSetResistanceResponseJson(bool mWorked) + { + dynamic data = new + { + worked = mWorked + }; + return getJsonMessage(SET_RESISTANCE, data); + } + + public static byte[] getNewConnectionJson(string user) + { + dynamic data = new + { + username = user + }; + return getJsonMessage(NEW_CONNECTION, data); + } + + public static byte[] getDisconnectJson(string user) + { + dynamic data = new + { + username = user + }; + return getJsonMessage(DISCONNECT, data); + } + + public static float getResistanceFromJson(byte[] json) + { + return ((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.resistance; + } + + public static bool getResistanceFromResponseJson(byte[] json) + { + return ((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.worked; + } + + public static string getUsernameFromResponseJson(byte[] json) + { + return ((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.username; + } + + + } +} diff --git a/DoctorApp/Utils/ObservableObject.cs b/DoctorApp/Utils/ObservableObject.cs new file mode 100644 index 0000000..9b35f60 --- /dev/null +++ b/DoctorApp/Utils/ObservableObject.cs @@ -0,0 +1,12 @@ +using System; +using System.Collections.Generic; +using System.ComponentModel; +using System.Text; + +namespace DoctorApp.Utils +{ + public abstract class ObservableObject : INotifyPropertyChanged + { + public event PropertyChangedEventHandler PropertyChanged; + } +} diff --git a/DoctorApp/ViewModels/ClientInfoViewModel.cs b/DoctorApp/ViewModels/ClientInfoViewModel.cs new file mode 100644 index 0000000..54d2df0 --- /dev/null +++ b/DoctorApp/ViewModels/ClientInfoViewModel.cs @@ -0,0 +1,13 @@ +using System; +using System.Collections.Generic; +using System.Text; + +namespace DoctorApp.ViewModels +{ + + class ClientInfoViewModel + { + public string Username { get; set; } + public string TabName { get; set; } + } +} diff --git a/DoctorApp/ViewModels/LoginViewModel.cs b/DoctorApp/ViewModels/LoginViewModel.cs new file mode 100644 index 0000000..a8e26ae --- /dev/null +++ b/DoctorApp/ViewModels/LoginViewModel.cs @@ -0,0 +1,46 @@ + +using DoctorApp.Utils; +using GalaSoft.MvvmLight.Command; +using System; +using System.Collections.Generic; +using System.Text; +using System.Windows.Controls; +using System.Windows.Input; + +namespace DoctorApp.ViewModels +{ + class LoginViewModel : ObservableObject + { + public string Username { get; set; } + public ICommand LoginCommand { get; set; } + + public bool LoginStatus { get; set; } + + public bool InvertedLoginStatus { get; set; } + + private MainWindowViewModel mainWindowViewModel; + public LoginViewModel(MainWindowViewModel mainWindowViewModel) + { + this.mainWindowViewModel = mainWindowViewModel; + LoginCommand = new RelayCommand((parameter) => + { + //TODO send username and password to server + this.mainWindowViewModel.client.tryLogin(Username, ((PasswordBox)parameter).Password); + }); + } + + + + internal void setLoginStatus(bool status) + { + this.mainWindowViewModel.InfoModel.ConnectedToServer = status; + this.InvertedLoginStatus = !status; + if (status) + { + MainViewModel mainViewModel = new MainViewModel(mainWindowViewModel); + this.mainWindowViewModel.client.SetMainViewModel(mainViewModel); + this.mainWindowViewModel.SelectedViewModel = mainViewModel; + } + } + } +} diff --git a/DoctorApp/ViewModels/MainViewModel.cs b/DoctorApp/ViewModels/MainViewModel.cs new file mode 100644 index 0000000..27c8e69 --- /dev/null +++ b/DoctorApp/ViewModels/MainViewModel.cs @@ -0,0 +1,45 @@ +using DoctorApp.Utils; +using System; +using System.Collections.Generic; +using System.Collections.ObjectModel; +using System.ComponentModel; +using System.Text; +using System.Windows.Controls; + +namespace DoctorApp.ViewModels +{ + class MainViewModel : ObservableObject + { + public ObservableCollection Tabs { get; set; } + public int Selected { get; set; } + public MainWindowViewModel MainWindowViewModel { get; set; } + + Client client; + + public MainViewModel(MainWindowViewModel mainWindowViewModel) + { + this.MainWindowViewModel = mainWindowViewModel; + client = this.MainWindowViewModel.client; + Tabs= new ObservableCollection(); + } + + public void NewConnectedUser(string username) + { + App.Current.Dispatcher.Invoke((Action)delegate + { + Tabs.Add(new ClientInfoViewModel + { + Username = username, + TabName = username + }); + }); + } + + public void DisconnectedUser(string username) + { + + } + } + + +} diff --git a/DoctorApp/ViewModels/MainWindowViewModel.cs b/DoctorApp/ViewModels/MainWindowViewModel.cs new file mode 100644 index 0000000..7b41840 --- /dev/null +++ b/DoctorApp/ViewModels/MainWindowViewModel.cs @@ -0,0 +1,25 @@ +using DoctorApp.Models; +using DoctorApp.Utils; +using System; +using System.Collections.Generic; +using System.Text; + +namespace DoctorApp.ViewModels +{ + class MainWindowViewModel : ObservableObject + { + public Info InfoModel { get; set; } + + public ObservableObject SelectedViewModel { get; set; } + public Client client { get; } + + public MainWindowViewModel(Client client) + { + this.InfoModel = new Info(); + this.client = client; + LoginViewModel loginViewModel = new LoginViewModel(this); + SelectedViewModel = loginViewModel; + this.client.SetLoginViewModel(loginViewModel); + } + } +} diff --git a/DoctorApp/Views/ClientInfoView.xaml b/DoctorApp/Views/ClientInfoView.xaml new file mode 100644 index 0000000..29eda51 --- /dev/null +++ b/DoctorApp/Views/ClientInfoView.xaml @@ -0,0 +1,68 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +