Compare commits
5 Commits
gethistori
...
sendmessag
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1f163325cf | ||
|
|
1c7f9cf70a | ||
|
|
5f2e325cb1 | ||
|
|
cda8b47ca3 | ||
|
|
fab3ed7705 |
@@ -43,7 +43,7 @@ namespace ClientApp.Utils
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
private void initEngine()
|
private void initEngine()
|
||||||
{
|
{
|
||||||
Debug.WriteLine("init engine");
|
Debug.WriteLine("[CLIENT] init engine");
|
||||||
engineConnection = EngineConnection.INSTANCE;
|
engineConnection = EngineConnection.INSTANCE;
|
||||||
engineConnection.OnNoTunnelId = RetryEngineConnection;
|
engineConnection.OnNoTunnelId = RetryEngineConnection;
|
||||||
engineConnection.OnSuccessFullConnection = engineConnected;
|
engineConnection.OnSuccessFullConnection = engineConnected;
|
||||||
@@ -184,12 +184,15 @@ namespace ClientApp.Utils
|
|||||||
else if (DataParser.isRawDataBikeServer(messageBytes))
|
else if (DataParser.isRawDataBikeServer(messageBytes))
|
||||||
{
|
{
|
||||||
Console.WriteLine($"Received data: {BitConverter.ToString(payloadbytes)}");
|
Console.WriteLine($"Received data: {BitConverter.ToString(payloadbytes)}");
|
||||||
}
|
}
|
||||||
|
|
||||||
totalBufferReceived -= expectedMessageLength;
|
totalBufferReceived -= expectedMessageLength;
|
||||||
expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
|
expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (ar == null || (!ar.IsCompleted) || (!this.stream.CanRead) || !this.client.Connected)
|
||||||
|
return;
|
||||||
|
ar.AsyncWaitHandle.WaitOne();
|
||||||
this.stream.BeginRead(this.buffer, 0, this.buffer.Length, new AsyncCallback(OnRead), null);
|
this.stream.BeginRead(this.buffer, 0, this.buffer.Length, new AsyncCallback(OnRead), null);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -27,7 +27,7 @@ namespace ClientApp.Utils
|
|||||||
//new PC("DESKTOP-M2CIH87", "Fabian"),
|
//new PC("DESKTOP-M2CIH87", "Fabian"),
|
||||||
//new PC("T470S", "Shinichi"),
|
//new PC("T470S", "Shinichi"),
|
||||||
//new PC("DESKTOP-DHS478C", "semme"),
|
//new PC("DESKTOP-DHS478C", "semme"),
|
||||||
//new PC("HP-ZBOOK-SEM", "Sem")
|
new PC("HP-ZBOOK-SEM", "Sem")
|
||||||
//new PC("DESKTOP-TV73FKO", "Wouter"),
|
//new PC("DESKTOP-TV73FKO", "Wouter"),
|
||||||
//new PC("DESKTOP-SINMKT1", "Ralf van Aert"),
|
//new PC("DESKTOP-SINMKT1", "Ralf van Aert"),
|
||||||
//new PC("NA", "Bart")
|
//new PC("NA", "Bart")
|
||||||
@@ -71,7 +71,7 @@ namespace ClientApp.Utils
|
|||||||
updateTimer.AutoReset = true;
|
updateTimer.AutoReset = true;
|
||||||
updateTimer.Enabled = false;
|
updateTimer.Enabled = false;
|
||||||
|
|
||||||
noVRResponseTimer = new System.Timers.Timer(15000);
|
noVRResponseTimer = new System.Timers.Timer(30000);
|
||||||
noVRResponseTimer.Elapsed += noVRResponseTimeout;
|
noVRResponseTimer.Elapsed += noVRResponseTimeout;
|
||||||
noVRResponseTimer.AutoReset = false;
|
noVRResponseTimer.AutoReset = false;
|
||||||
noVRResponseTimer.Enabled = false;
|
noVRResponseTimer.Enabled = false;
|
||||||
@@ -236,14 +236,14 @@ namespace ClientApp.Utils
|
|||||||
Write("Starting route follow...");
|
Write("Starting route follow...");
|
||||||
FollowingRoute = true;
|
FollowingRoute = true;
|
||||||
|
|
||||||
SendMessageAndOnResponse(mainCommand.AddBikeModelAnim("bikeID", 0.01f), "bikeID",
|
SendMessageAndOnResponse(mainCommand.AddBikeModel("bikeID"), "bikeID",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
bikeId = JSONParser.GetResponseUuid(message);
|
bikeId = JSONParser.GetResponseUuid(message);
|
||||||
SendMessageAndOnResponse(mainCommand.addPanel("panelAdd", bikeId), "panelAdd",
|
SendMessageAndOnResponse(mainCommand.addPanel("panelAdd", bikeId), "panelAdd",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
|
Write("got panel id");
|
||||||
panelId = JSONParser.getPanelID(message);
|
panelId = JSONParser.getPanelID(message);
|
||||||
|
|
||||||
WriteTextMessage(mainCommand.ColorPanel(panelId));
|
WriteTextMessage(mainCommand.ColorPanel(panelId));
|
||||||
@@ -295,6 +295,7 @@ namespace ClientApp.Utils
|
|||||||
|
|
||||||
public void UpdateInfoPanel()
|
public void UpdateInfoPanel()
|
||||||
{
|
{
|
||||||
|
Write("updating info panel");
|
||||||
ShowPanel(BikeSpeed, (int)BikeBPM, (int)BikePower, (int)BikeResistance);
|
ShowPanel(BikeSpeed, (int)BikeBPM, (int)BikePower, (int)BikeResistance);
|
||||||
WriteTextMessage(mainCommand.RouteSpeed(BikeSpeed, bikeId));
|
WriteTextMessage(mainCommand.RouteSpeed(BikeSpeed, bikeId));
|
||||||
WriteTextMessage(mainCommand.RouteSpeed(BikeSpeed, cameraId));
|
WriteTextMessage(mainCommand.RouteSpeed(BikeSpeed, cameraId));
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ namespace ClientApp.ViewModels
|
|||||||
public string Username { get; set; }
|
public string Username { get; set; }
|
||||||
public ICommand LoginCommand { get; set; }
|
public ICommand LoginCommand { get; set; }
|
||||||
|
|
||||||
public bool LoginStatus { get; set; } = false;
|
public bool LoginStatus { get; set; }
|
||||||
|
|
||||||
public bool InvertedLoginStatus { get; set; }
|
public bool InvertedLoginStatus { get; set; }
|
||||||
|
|
||||||
|
|||||||
@@ -19,7 +19,9 @@
|
|||||||
<Label Content="Password" HorizontalContentAlignment="Center"/>
|
<Label Content="Password" HorizontalContentAlignment="Center"/>
|
||||||
<PasswordBox x:Name="Password" Width="120" Util:FocusAdvancement.AdvancesByEnterKey="True"/>
|
<PasswordBox x:Name="Password" Width="120" Util:FocusAdvancement.AdvancesByEnterKey="True"/>
|
||||||
<Button x:Name="Login" Content="Login" Command="{Binding LoginCommand}" CommandParameter="{Binding ElementName=Password}" Margin="0,20,0,0" Width="120"/>
|
<Button x:Name="Login" Content="Login" Command="{Binding LoginCommand}" CommandParameter="{Binding ElementName=Password}" Margin="0,20,0,0" Width="120"/>
|
||||||
<Label Content="Login failed" Foreground="Red" HorizontalAlignment="Center" HorizontalContentAlignment="Center" Background="Transparent" IsEnabled="{Binding InvertedLoginStatus}"/>
|
<Popup IsOpen="{Binding InvertedLoginStatus}" PopupAnimation = "Slide" HorizontalAlignment="Center">
|
||||||
|
<Label Content="Login failed" Foreground="Red" HorizontalAlignment="Center" HorizontalContentAlignment="Center" Background="Transparent"/>
|
||||||
|
</Popup>
|
||||||
</StackPanel>
|
</StackPanel>
|
||||||
</DockPanel>
|
</DockPanel>
|
||||||
</Page>
|
</Page>
|
||||||
|
|||||||
@@ -25,7 +25,6 @@
|
|||||||
<PackageReference Include="AsyncAwaitBestPractices.MVVM" Version="4.3.0" />
|
<PackageReference Include="AsyncAwaitBestPractices.MVVM" Version="4.3.0" />
|
||||||
<PackageReference Include="LiveCharts.Wpf" Version="0.9.7" />
|
<PackageReference Include="LiveCharts.Wpf" Version="0.9.7" />
|
||||||
<PackageReference Include="MvvmLightLibsStd10" Version="5.4.1.1" />
|
<PackageReference Include="MvvmLightLibsStd10" Version="5.4.1.1" />
|
||||||
<PackageReference Include="Prism.Wpf" Version="8.0.0.1909" />
|
|
||||||
<PackageReference Include="PropertyChanged.Fody" Version="3.2.9" />
|
<PackageReference Include="PropertyChanged.Fody" Version="3.2.9" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
|
|||||||
@@ -1,11 +1,9 @@
|
|||||||
using System;
|
using System;
|
||||||
using System.Diagnostics;
|
using System.Diagnostics;
|
||||||
using System.IO;
|
|
||||||
using System.Linq;
|
using System.Linq;
|
||||||
using System.Net.Sockets;
|
using System.Net.Sockets;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
using DoctorApp.ViewModels;
|
using DoctorApp.ViewModels;
|
||||||
using Microsoft.Win32;
|
|
||||||
using ProftaakRH;
|
using ProftaakRH;
|
||||||
using Util;
|
using Util;
|
||||||
|
|
||||||
@@ -131,24 +129,7 @@ namespace DoctorApp.Utils
|
|||||||
{
|
{
|
||||||
MainViewModel.TransferDataToClientBPM(payloadbytes);
|
MainViewModel.TransferDataToClientBPM(payloadbytes);
|
||||||
}
|
}
|
||||||
else if (DataParser.IsHistoricBikeData(messageBytes))
|
Array.Copy(totalBuffer, expectedMessageLength, totalBuffer, 0, (totalBufferReceived - expectedMessageLength)); //maybe unsafe idk
|
||||||
{
|
|
||||||
|
|
||||||
|
|
||||||
// todo change to name of patient
|
|
||||||
string name = MainViewModel.Tabs[0].PatientInfo.Username;
|
|
||||||
string result = "PATIENT INFO FOR " + name + "\n\n";
|
|
||||||
for (int i = 0; i < payloadbytes.Length; i += 8)
|
|
||||||
{
|
|
||||||
byte[] res = new byte[8];
|
|
||||||
Array.Copy(payloadbytes, i, res, 0, 8);
|
|
||||||
result += handleBikeHistory(res);
|
|
||||||
}
|
|
||||||
|
|
||||||
string path = Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments) + "/" + name + ".txt";
|
|
||||||
File.WriteAllText(path,result);
|
|
||||||
}
|
|
||||||
Array.Copy(totalBuffer, expectedMessageLength, totalBuffer, 0, (totalBufferReceived - expectedMessageLength)); //maybe unsafe idk
|
|
||||||
totalBufferReceived -= expectedMessageLength;
|
totalBufferReceived -= expectedMessageLength;
|
||||||
expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
|
expectedMessageLength = BitConverter.ToInt32(totalBuffer, 0);
|
||||||
}
|
}
|
||||||
@@ -159,40 +140,11 @@ namespace DoctorApp.Utils
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private string handleBikeHistory(byte[] bytes)
|
/// <summary>
|
||||||
{
|
/// starts sending a message to the server
|
||||||
string res = string.Empty;
|
/// </summary>
|
||||||
switch (bytes[0])
|
/// <param name="message">the message to send</param>
|
||||||
{
|
public void sendMessage(byte[] message)
|
||||||
case 0x10:
|
|
||||||
res += "Time elapsed: " + bytes[2] / 4 + "s\n";
|
|
||||||
res += "Distance traveled: " + bytes[3] + "\n";
|
|
||||||
int input = bytes[4] | (bytes[5] << 8);
|
|
||||||
res += $"Speed {input * 0.01}m/s\n";
|
|
||||||
res += $"Heart rate: { Convert.ToString(bytes[6], 10)}";
|
|
||||||
break;
|
|
||||||
case 0x19:
|
|
||||||
res += $"RPM: {bytes[2]}\n";
|
|
||||||
int accumPower = bytes[3] | (bytes[4] << 8);
|
|
||||||
res += $"Accumulated power: {accumPower} watt\n";
|
|
||||||
int instantPower = (bytes[5]) | (bytes[6] & 0b00001111) << 8;
|
|
||||||
if (instantPower != 0xFFF)
|
|
||||||
{
|
|
||||||
res += $"Instant power: {instantPower} watt\n";
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
|
|
||||||
}
|
|
||||||
return res + "\n";
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <summary>
|
|
||||||
/// starts sending a message to the server
|
|
||||||
/// </summary>
|
|
||||||
/// <param name="message">the message to send</param>
|
|
||||||
public void sendMessage(byte[] message)
|
|
||||||
{
|
{
|
||||||
stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null);
|
stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -41,16 +41,16 @@ namespace DoctorApp.ViewModels
|
|||||||
|
|
||||||
public ICommand SetResistance { get; set; }
|
public ICommand SetResistance { get; set; }
|
||||||
|
|
||||||
public ICommand SaveHistoricData { get; set; }
|
|
||||||
|
|
||||||
public MainWindowViewModel MainWindowViewModel { get; set; }
|
public MainWindowViewModel MainWindowViewModel { get; set; }
|
||||||
private Client client;
|
private Client client;
|
||||||
|
private MainViewModel parent;
|
||||||
|
|
||||||
public Chart Chart { get; set; }
|
public Chart Chart { get; set; }
|
||||||
|
|
||||||
public ClientInfoViewModel(MainWindowViewModel mainWindowViewModel, string username)
|
public ClientInfoViewModel(MainViewModel parent,MainWindowViewModel mainWindowViewModel, string username)
|
||||||
{
|
{
|
||||||
MainWindowViewModel = mainWindowViewModel;
|
MainWindowViewModel = mainWindowViewModel;
|
||||||
|
this.parent = parent;
|
||||||
this.PatientInfo = new PatientInfo() { Username = username, Status = "Waiting to start" };
|
this.PatientInfo = new PatientInfo() { Username = username, Status = "Waiting to start" };
|
||||||
this.Chart = new Chart(this.PatientInfo);
|
this.Chart = new Chart(this.PatientInfo);
|
||||||
PatientInfo.ChatLog = new ObservableCollection<string>();
|
PatientInfo.ChatLog = new ObservableCollection<string>();
|
||||||
@@ -70,12 +70,17 @@ namespace DoctorApp.ViewModels
|
|||||||
|
|
||||||
Chat = new RelayCommand<object>((parameter) =>
|
Chat = new RelayCommand<object>((parameter) =>
|
||||||
{
|
{
|
||||||
client.sendMessage(DataParser.getChatJson(PatientInfo.Username, ((TextBox)parameter).Text));
|
SendMessageToClient(PatientInfo.Username, ((TextBox)parameter).Text);
|
||||||
PatientInfo.ChatLog.Add(DateTime.Now + ": " + ((TextBox)parameter).Text);
|
|
||||||
});
|
});
|
||||||
|
|
||||||
//TODO RelayCommand ChatToAll
|
//TODO RelayCommand ChatToAll
|
||||||
|
|
||||||
|
ChatToAll = new RelayCommand<object>((parameter) =>
|
||||||
|
{
|
||||||
|
Debug.WriteLine("[CLIENTINFOVIEWMODEL] sending message to all clients");
|
||||||
|
this.parent?.SendToAllClients(((TextBox)parameter).Text);
|
||||||
|
});
|
||||||
|
|
||||||
SetResistance = new RelayCommand<object>((parameter) =>
|
SetResistance = new RelayCommand<object>((parameter) =>
|
||||||
{
|
{
|
||||||
Debug.WriteLine("resistance");
|
Debug.WriteLine("resistance");
|
||||||
@@ -83,23 +88,19 @@ namespace DoctorApp.ViewModels
|
|||||||
PatientInfo.Resistance = float.Parse(((TextBox)parameter).Text);
|
PatientInfo.Resistance = float.Parse(((TextBox)parameter).Text);
|
||||||
});
|
});
|
||||||
|
|
||||||
// request the historic data from the server
|
|
||||||
this.SaveHistoricData = new RelayCommand<object>((parameter) =>
|
|
||||||
{
|
|
||||||
this.client.sendMessage(DataParser.GetGetFileMessage(PatientInfo.Username));
|
|
||||||
// data is stored on the server
|
|
||||||
// send request to server that we want to get the current historic data from the patient
|
|
||||||
// server sends this back
|
|
||||||
// we parse it
|
|
||||||
});
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public void BPMData(byte[] bytes)
|
public void SendMessageToClient(string username, string text)
|
||||||
|
{
|
||||||
|
client.sendMessage(DataParser.getChatJson(username, text));
|
||||||
|
PatientInfo.ChatLog.Add(DateTime.Now + ": " + text);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void BPMData(byte [] bytes)
|
||||||
{
|
{
|
||||||
//TODO
|
//TODO
|
||||||
//Parsen van de data you fuck
|
//Parsen van de data you fuck
|
||||||
if (bytes[0] == 0x00)
|
if(bytes[0] == 0x00)
|
||||||
{
|
{
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -107,13 +108,13 @@ namespace DoctorApp.ViewModels
|
|||||||
{
|
{
|
||||||
PatientInfo.BPM = bytes[1];
|
PatientInfo.BPM = bytes[1];
|
||||||
if (MySelectedItem == "BPM")
|
if (MySelectedItem == "BPM")
|
||||||
{
|
{
|
||||||
Chart.NewValue(PatientInfo.BPM);
|
Chart.NewValue(PatientInfo.BPM);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public void BikeData(byte[] bytes)
|
public void BikeData(byte[] bytes)
|
||||||
|
|||||||
@@ -30,7 +30,7 @@ namespace DoctorApp.ViewModels
|
|||||||
Debug.WriteLine("new tab with name " + username);
|
Debug.WriteLine("new tab with name " + username);
|
||||||
App.Current.Dispatcher.Invoke((Action)delegate
|
App.Current.Dispatcher.Invoke((Action)delegate
|
||||||
{
|
{
|
||||||
Tabs.Add(new ClientInfoViewModel(MainWindowViewModel, username));
|
Tabs.Add(new ClientInfoViewModel(this,MainWindowViewModel, username));
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -72,6 +72,15 @@ namespace DoctorApp.ViewModels
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
internal void SendToAllClients(string text)
|
||||||
|
{
|
||||||
|
Debug.WriteLine("[MAINVIEWMODEL] Sending message to all clients: " + text);
|
||||||
|
foreach (ClientInfoViewModel item in Tabs)
|
||||||
|
{
|
||||||
|
item.SendMessageToClient(item.PatientInfo.Username, text);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ using System.Windows.Input;
|
|||||||
using DoctorApp.Models;
|
using DoctorApp.Models;
|
||||||
using DoctorApp.Utils;
|
using DoctorApp.Utils;
|
||||||
using Util.MagicCode;
|
using Util.MagicCode;
|
||||||
|
using System;
|
||||||
|
|
||||||
namespace DoctorApp.ViewModels
|
namespace DoctorApp.ViewModels
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -18,20 +18,16 @@
|
|||||||
<RowDefinition Height="180*"/>
|
<RowDefinition Height="180*"/>
|
||||||
<RowDefinition Height="180*"/>
|
<RowDefinition Height="180*"/>
|
||||||
</Grid.RowDefinitions>
|
</Grid.RowDefinitions>
|
||||||
|
<StackPanel Orientation="Horizontal" Grid.RowSpan="2" Margin="0,0,0,22">
|
||||||
<Grid Grid.RowSpan="2" Margin="0,0,0,22">
|
<StackPanel.Resources>
|
||||||
<StackPanel Orientation="Horizontal" >
|
<Style TargetType="{x:Type Label}">
|
||||||
<StackPanel.Resources>
|
<Setter Property="Margin" Value="0,0,20,0"/>
|
||||||
<Style TargetType="{x:Type Label}">
|
</Style>
|
||||||
<Setter Property="Margin" Value="0,0,20,0"/>
|
</StackPanel.Resources>
|
||||||
</Style>
|
<Label Content="{Binding Path=PatientInfo.Username}"/>
|
||||||
</StackPanel.Resources>
|
<Label Content="{Binding Path=PatientInfo.Status}"/>
|
||||||
<Label Content="{Binding Path=PatientInfo.Username}"/>
|
</StackPanel>
|
||||||
<Label Content="{Binding Path=PatientInfo.Status}"/>
|
<StackPanel Margin="0,10,0,0" Grid.RowSpan="2" Grid.Row="1">
|
||||||
</StackPanel>
|
|
||||||
<Button Content="Save Historic Data" HorizontalAlignment="Right" VerticalAlignment="Center" Padding="5" Command="{Binding SaveHistoricData}"/>
|
|
||||||
</Grid>
|
|
||||||
<StackPanel Margin="0,10,0,0" Grid.Row="2">
|
|
||||||
<StackPanel.Resources>
|
<StackPanel.Resources>
|
||||||
<Style TargetType="{x:Type DockPanel}">
|
<Style TargetType="{x:Type DockPanel}">
|
||||||
<Setter Property="Margin" Value="0,20,0,0"/>
|
<Setter Property="Margin" Value="0,20,0,0"/>
|
||||||
@@ -61,6 +57,7 @@
|
|||||||
<ListBox Name="ChatBox" ItemsSource="{Binding PatientInfo.ChatLog}" Grid.Column="1" Margin="59,41,0,0" Grid.RowSpan="3"/>
|
<ListBox Name="ChatBox" ItemsSource="{Binding PatientInfo.ChatLog}" Grid.Column="1" Margin="59,41,0,0" Grid.RowSpan="3"/>
|
||||||
<TextBox Name="textBox_Chat" Grid.Column="1" HorizontalAlignment="Left" Margin="59,10,0,0" Grid.Row="3" Text="" TextWrapping="Wrap" VerticalAlignment="Top" Width="235"/>
|
<TextBox Name="textBox_Chat" Grid.Column="1" HorizontalAlignment="Left" Margin="59,10,0,0" Grid.Row="3" Text="" TextWrapping="Wrap" VerticalAlignment="Top" Width="235"/>
|
||||||
<Button x:Name="Send" Content="Send" Grid.Column="1" HorizontalAlignment="Left" Margin="59,33,0,0" Grid.Row="3" VerticalAlignment="Top" Command="{Binding Chat}" CommandParameter="{Binding ElementName=textBox_Chat}"/>
|
<Button x:Name="Send" Content="Send" Grid.Column="1" HorizontalAlignment="Left" Margin="59,33,0,0" Grid.Row="3" VerticalAlignment="Top" Command="{Binding Chat}" CommandParameter="{Binding ElementName=textBox_Chat}"/>
|
||||||
|
<Button x:Name="SendToAll" Content="Send to all clients" Grid.Column="1" HorizontalAlignment="Left" Margin="107,33,0,0" Grid.Row="3" VerticalAlignment="Top" Command="{Binding ChatToAll}" CommandParameter="{Binding ElementName=textBox_Chat}"/>
|
||||||
<Button Content="Start Session" Grid.Column="1" HorizontalAlignment="Left" Margin="69,86,0,0" Grid.Row="3" VerticalAlignment="Top" Width="97" Command="{Binding StartSession}" CommandParameter=""/>
|
<Button Content="Start Session" Grid.Column="1" HorizontalAlignment="Left" Margin="69,86,0,0" Grid.Row="3" VerticalAlignment="Top" Width="97" Command="{Binding StartSession}" CommandParameter=""/>
|
||||||
<Button Content="Stop Session" Grid.Column="1" HorizontalAlignment="Left" Margin="187,86,0,0" Grid.Row="3" VerticalAlignment="Top" Width="97" Command="{Binding StopSession}" CommandParameter=""/>
|
<Button Content="Stop Session" Grid.Column="1" HorizontalAlignment="Left" Margin="187,86,0,0" Grid.Row="3" VerticalAlignment="Top" Width="97" Command="{Binding StopSession}" CommandParameter=""/>
|
||||||
<TextBox x:Name="textBox_SetResistance" Grid.Column="1" HorizontalAlignment="Left" Margin="69,128,0,0" Grid.Row="3" TextWrapping="Wrap" VerticalAlignment="Top" Width="97"/>
|
<TextBox x:Name="textBox_SetResistance" Grid.Column="1" HorizontalAlignment="Left" Margin="69,128,0,0" Grid.Row="3" TextWrapping="Wrap" VerticalAlignment="Top" Width="97"/>
|
||||||
|
|||||||
@@ -10,7 +10,7 @@
|
|||||||
AllowsTransparency="True"
|
AllowsTransparency="True"
|
||||||
MinHeight="{Binding MinimumHeight}"
|
MinHeight="{Binding MinimumHeight}"
|
||||||
MinWidth="{Binding MinimumWidth}"
|
MinWidth="{Binding MinimumWidth}"
|
||||||
Title="MainWindow" Height="800" Width="1500">
|
Title="MainWindow" Height="500" Width="900">
|
||||||
<Window.Resources>
|
<Window.Resources>
|
||||||
<Style TargetType="{x:Type local:MainWindow}">
|
<Style TargetType="{x:Type local:MainWindow}">
|
||||||
<Setter Property="Template">
|
<Setter Property="Template">
|
||||||
|
|||||||
@@ -4,11 +4,9 @@ using System;
|
|||||||
using System.Diagnostics;
|
using System.Diagnostics;
|
||||||
using System.Globalization;
|
using System.Globalization;
|
||||||
using System.Linq;
|
using System.Linq;
|
||||||
using System.Printing.IndexedProperties;
|
|
||||||
using System.Runtime.InteropServices.WindowsRuntime;
|
using System.Runtime.InteropServices.WindowsRuntime;
|
||||||
using System.Security.Cryptography;
|
using System.Security.Cryptography;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
using System.Windows.Media.Animation;
|
|
||||||
|
|
||||||
namespace Util
|
namespace Util
|
||||||
{
|
{
|
||||||
@@ -23,7 +21,6 @@ namespace Util
|
|||||||
public const string DISCONNECT = "DISCONNECT";
|
public const string DISCONNECT = "DISCONNECT";
|
||||||
public const string LOGIN_DOCTOR = "LOGIN DOCTOR";
|
public const string LOGIN_DOCTOR = "LOGIN DOCTOR";
|
||||||
public const string MESSAGE = "MESSAGE";
|
public const string MESSAGE = "MESSAGE";
|
||||||
public const string GET_FILE = "GET FILE";
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// makes the json object with LOGIN identifier and username and password
|
/// makes the json object with LOGIN identifier and username and password
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@@ -73,7 +70,7 @@ namespace Util
|
|||||||
return getName(bytes, 2, bytes.Length - 2);
|
return getName(bytes, 2, bytes.Length - 2);
|
||||||
}
|
}
|
||||||
|
|
||||||
private static string getName(byte[] bytes, int offset, int lenght)
|
private static string getName(byte[] bytes , int offset, int lenght)
|
||||||
{
|
{
|
||||||
byte[] nameArray = new byte[lenght];
|
byte[] nameArray = new byte[lenght];
|
||||||
Array.Copy(bytes, offset, nameArray, 0, lenght);
|
Array.Copy(bytes, offset, nameArray, 0, lenght);
|
||||||
@@ -243,12 +240,6 @@ namespace Util
|
|||||||
return bytes[4] == 0x05;
|
return bytes[4] == 0x05;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static bool IsHistoricBikeData(byte[] bytes)
|
|
||||||
{
|
|
||||||
if (bytes.Length <= 5) throw new ArgumentException("bytes too short");
|
|
||||||
return bytes[4] == 0x06;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// constructs a message with the payload, messageId and clientId
|
/// constructs a message with the payload, messageId and clientId
|
||||||
@@ -293,17 +284,13 @@ namespace Util
|
|||||||
|
|
||||||
public static byte[] GetRawBPMDataDoctor(byte[] payload, string username)
|
public static byte[] GetRawBPMDataDoctor(byte[] payload, string username)
|
||||||
{
|
{
|
||||||
return GetRawDataDoctor(payload, username, 0x05);
|
return GetRawDataDoctor(payload,username,0x05);
|
||||||
}
|
}
|
||||||
|
|
||||||
private static byte[] GetRawDataDoctor(byte[] payload, string username, byte messageID)
|
private static byte[] GetRawDataDoctor(byte[] payload, string username, byte messageID)
|
||||||
{
|
{
|
||||||
Debug.WriteLine(BitConverter.ToString(Encoding.ASCII.GetBytes(username)));
|
|
||||||
byte[] nameArray = Encoding.ASCII.GetBytes(username);
|
return getMessage(payload.Concat(Encoding.ASCII.GetBytes(username)).ToArray(), messageID);
|
||||||
byte[] total = new byte[nameArray.Length + payload.Length];
|
|
||||||
Array.Copy(payload, 0, total, 0, payload.Length);
|
|
||||||
Array.Copy(nameArray, 0, total, payload.Length, nameArray.Length);
|
|
||||||
return getMessage(total, messageID);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -344,14 +331,14 @@ namespace Util
|
|||||||
};
|
};
|
||||||
return getJsonMessage(STOP_SESSION, data);
|
return getJsonMessage(STOP_SESSION, data);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// gets the message to set the resistance of the given user with the given resistance.
|
/// gets the message to set the resistance of the given user with the given resistance.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
/// <param name="user">the username to set the resistance of.</param>
|
/// <param name="user">the username to set the resistance of.</param>
|
||||||
/// <param name="mResistance">the resistance value to set</param>
|
/// <param name="mResistance">the resistance value to set</param>
|
||||||
/// <returns>a byte array containing a json messsage to set the user's resistance, using our protocol.</returns>
|
/// <returns>a byte array containing a json messsage to set the user's resistance, using our protocol.</returns>
|
||||||
public static byte[] getSetResistanceJson(string user, float mResistance)
|
public static byte[] getSetResistanceJson(string user,float mResistance)
|
||||||
{
|
{
|
||||||
dynamic data = new
|
dynamic data = new
|
||||||
{
|
{
|
||||||
@@ -443,7 +430,7 @@ namespace Util
|
|||||||
/// <returns>the chat message in the json message</returns>
|
/// <returns>the chat message in the json message</returns>
|
||||||
public static string getChatMessageFromJson(byte[] json)
|
public static string getChatMessageFromJson(byte[] json)
|
||||||
{
|
{
|
||||||
return ((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.chat;
|
return ((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.chat;
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
@@ -479,32 +466,6 @@ namespace Util
|
|||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static byte[] GetGetFileMessage(string mUsername)
|
|
||||||
{
|
|
||||||
if (mUsername == null)
|
|
||||||
{
|
|
||||||
throw new ArgumentNullException("username null");
|
|
||||||
}
|
|
||||||
dynamic data = new
|
|
||||||
{
|
|
||||||
username = mUsername,
|
|
||||||
};
|
|
||||||
return getJsonMessage(GET_FILE, data);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static string GetUsernameFromGetFileBytes(byte[] json)
|
|
||||||
{
|
|
||||||
return ((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.username;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static string GetDateFromGetFileBytes(byte[] json)
|
|
||||||
{
|
|
||||||
return ((string)((dynamic)JsonConvert.DeserializeObject(Encoding.ASCII.GetString(json))).data.dateTime);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static byte[] GetFileMessage(byte[] file)
|
|
||||||
{
|
|
||||||
return getMessage(file, 0x06);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -124,11 +124,13 @@ namespace RH_Engine
|
|||||||
position = new float[]
|
position = new float[]
|
||||||
{
|
{
|
||||||
-1.5f, 1f, 0f
|
-1.5f, 1f, 0f
|
||||||
|
//0f,0f,0f
|
||||||
},
|
},
|
||||||
scale = 1,
|
scale = 1,
|
||||||
rotation = new int[]
|
rotation = new int[]
|
||||||
{
|
{
|
||||||
-30, 90,0
|
-30, 90,0
|
||||||
|
//0,0,0
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
panel = new
|
panel = new
|
||||||
|
|||||||
@@ -19,9 +19,9 @@ namespace RH_Engine
|
|||||||
//new PC("DESKTOP-M2CIH87", "Fabian"),
|
//new PC("DESKTOP-M2CIH87", "Fabian"),
|
||||||
//new PC("T470S", "Shinichi"),
|
//new PC("T470S", "Shinichi"),
|
||||||
//new PC("DESKTOP-DHS478C", "semme"),
|
//new PC("DESKTOP-DHS478C", "semme"),
|
||||||
//new PC("HP-ZBOOK-SEM", "Sem"),
|
new PC("HP-ZBOOK-SEM", "Sem"),
|
||||||
//new PC("DESKTOP-TV73FKO", "Wouter"),
|
//new PC("DESKTOP-TV73FKO", "Wouter"),
|
||||||
new PC("DESKTOP-SINMKT1", "Ralf van Aert"),
|
//new PC("DESKTOP-SINMKT1", "Ralf van Aert"),
|
||||||
//new PC("NA", "Bart")
|
//new PC("NA", "Bart")
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -94,7 +94,7 @@ namespace RH_Engine
|
|||||||
if (serialResponses.ContainsKey(serial))
|
if (serialResponses.ContainsKey(serial))
|
||||||
{
|
{
|
||||||
serialResponses[serial].Invoke(message);
|
serialResponses[serial].Invoke(message);
|
||||||
serialResponses.Remove(serial);
|
//serialResponses.Remove(serial);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -181,39 +181,41 @@ namespace RH_Engine
|
|||||||
//Force(stream, mainCommand.DeleteNode(handRightId, "deleteHandR"), "deleteHandR", (message) => Console.WriteLine("Right hand deleted"));
|
//Force(stream, mainCommand.DeleteNode(handRightId, "deleteHandR"), "deleteHandR", (message) => Console.WriteLine("Right hand deleted"));
|
||||||
});
|
});
|
||||||
|
|
||||||
CreateTerrain(stream, mainCommand);
|
//CreateTerrain(stream, mainCommand);
|
||||||
|
|
||||||
//Add route, bike and put camera and bike to follow route at same speed.
|
//Add route, bike and put camera and bike to follow route at same speed.
|
||||||
SendMessageAndOnResponse(stream, mainCommand.RouteCommand("routeID"), "routeID", (message) => routeId = JSONParser.GetResponseUuid(message));
|
//SendMessageAndOnResponse(stream, mainCommand.RouteCommand("routeID"), "routeID", (message) => routeId = JSONParser.GetResponseUuid(message));
|
||||||
SendMessageAndOnResponse(stream, mainCommand.AddBikeModelAnim("bikeID", 0.01f), "bikeID",
|
SendMessageAndOnResponse(stream, mainCommand.AddBikeModelAnim("bikeID",0.01f), "bikeID",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
bikeId = JSONParser.GetResponseUuid(message);
|
bikeId = JSONParser.GetResponseUuid(message);
|
||||||
|
Console.WriteLine("got bike id " + bikeId);
|
||||||
SendMessageAndOnResponse(stream, mainCommand.addPanel("panelAdd", bikeId), "panelAdd",
|
SendMessageAndOnResponse(stream, mainCommand.addPanel("panelAdd", bikeId), "panelAdd",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
bool speedReplied = false;
|
bool speedReplied = false;
|
||||||
bool moveReplied = true;
|
bool moveReplied = true;
|
||||||
|
Console.WriteLine(message);
|
||||||
panelId = JSONParser.getPanelID(message);
|
panelId = JSONParser.getPanelID(message);
|
||||||
|
Console.WriteLine("got panel id " + panelId);
|
||||||
showPanel(stream, mainCommand);
|
showPanel(stream, mainCommand);
|
||||||
|
|
||||||
|
|
||||||
//while (!(speedReplied && moveReplied)) { }
|
//while (!(speedReplied && moveReplied)) { }
|
||||||
|
|
||||||
while (cameraId == string.Empty) { }
|
//while (cameraId == string.Empty) { }
|
||||||
SetFollowSpeed(5.0f, stream, mainCommand);
|
//SetFollowSpeed(5.0f, stream, mainCommand);
|
||||||
WriteTextMessage(stream, mainCommand.RoadCommand(routeId, "road"));
|
//WriteTextMessage(stream, mainCommand.RoadCommand(routeId, "road"));
|
||||||
WriteTextMessage(stream, mainCommand.ShowRoute("showRouteFalse", false));
|
//WriteTextMessage(stream, mainCommand.ShowRoute("showRouteFalse", false));
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
string groundplaneId = GetId("GroundPlane", stream, mainCommand);
|
//string groundplaneId = GetId("GroundPlane", stream, mainCommand);
|
||||||
WriteTextMessage(stream, mainCommand.DeleteNode(groundplaneId, "none"));
|
//WriteTextMessage(stream, mainCommand.DeleteNode(groundplaneId, "none"));
|
||||||
|
|
||||||
PlaceHouses(stream, mainCommand);
|
//PlaceHouses(stream, mainCommand);
|
||||||
|
|
||||||
WriteTextMessage(stream, mainCommand.SkyboxCommand(DateTime.Now.Hour));
|
//WriteTextMessage(stream, mainCommand.SkyboxCommand(DateTime.Now.Hour));
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -343,31 +345,36 @@ namespace RH_Engine
|
|||||||
|
|
||||||
private static void showPanel(NetworkStream stream, Command mainCommand)
|
private static void showPanel(NetworkStream stream, Command mainCommand)
|
||||||
{
|
{
|
||||||
WriteTextMessage(stream, mainCommand.ColorPanel(panelId));
|
//WriteTextMessage(stream, mainCommand.ColorPanel(panelId));
|
||||||
WriteTextMessage(stream, mainCommand.ClearPanel(panelId));
|
WriteTextMessage(stream, mainCommand.ClearPanel(panelId));
|
||||||
SendMessageAndOnResponse(stream, mainCommand.showBikespeed(panelId, "bikeSpeed", bikeSpeed), "bikeSpeed",
|
SendMessageAndOnResponse(stream, mainCommand.showBikespeed(panelId, "bikeSpeed", bikeSpeed), "bikeSpeed",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
|
Console.WriteLine(message);
|
||||||
// TODO check if is drawn
|
// TODO check if is drawn
|
||||||
});
|
});
|
||||||
SendMessageAndOnResponse(stream, mainCommand.showHeartrate(panelId, "bpm", bpm), "bpm",
|
SendMessageAndOnResponse(stream, mainCommand.showHeartrate(panelId, "bpm", bpm), "bpm",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
|
Console.WriteLine(message);
|
||||||
// TODO check if is drawn
|
// TODO check if is drawn
|
||||||
});
|
});
|
||||||
SendMessageAndOnResponse(stream, mainCommand.showPower(panelId, "power", power), "power",
|
SendMessageAndOnResponse(stream, mainCommand.showPower(panelId, "power", power), "power",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
|
Console.WriteLine(message);
|
||||||
// TODO check if is drawn
|
// TODO check if is drawn
|
||||||
});
|
});
|
||||||
SendMessageAndOnResponse(stream, mainCommand.showResistance(panelId, "resistance", resistance), "resistance",
|
SendMessageAndOnResponse(stream, mainCommand.showResistance(panelId, "resistance", resistance), "resistance",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
|
Console.WriteLine(message);
|
||||||
// TODO check if is drawn
|
// TODO check if is drawn
|
||||||
});
|
});
|
||||||
SendMessageAndOnResponse(stream, mainCommand.showMessage(panelId, "message", lastMessage), "message",
|
SendMessageAndOnResponse(stream, mainCommand.showMessage(panelId, "message", lastMessage), "message",
|
||||||
(message) =>
|
(message) =>
|
||||||
{
|
{
|
||||||
|
Console.WriteLine(message);
|
||||||
// TODO check if is drawn
|
// TODO check if is drawn
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
using System;
|
using System;
|
||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.Diagnostics;
|
|
||||||
using System.IO;
|
using System.IO;
|
||||||
using System.Linq;
|
using System.Linq;
|
||||||
using System.Net.Sockets;
|
using System.Net.Sockets;
|
||||||
@@ -24,11 +23,8 @@ namespace Server
|
|||||||
private DateTime sessionStart;
|
private DateTime sessionStart;
|
||||||
private string fileName;
|
private string fileName;
|
||||||
private Timer timer;
|
private Timer timer;
|
||||||
private volatile byte[] BikeDataBuffer;
|
private byte[] BikeDataBuffer;
|
||||||
private volatile byte[] BPMDataBuffer;
|
private byte[] BPMDataBuffer;
|
||||||
private bool BPMdata = false;
|
|
||||||
private bool Bikedata = false;
|
|
||||||
private object token = new object { };
|
|
||||||
|
|
||||||
public Client(Communication communication, TcpClient tcpClient)
|
public Client(Communication communication, TcpClient tcpClient)
|
||||||
{
|
{
|
||||||
@@ -41,9 +37,8 @@ namespace Server
|
|||||||
this.BikeDataBuffer = new byte[16];
|
this.BikeDataBuffer = new byte[16];
|
||||||
this.BPMDataBuffer = new byte[2];
|
this.BPMDataBuffer = new byte[2];
|
||||||
this.timer.Interval = 1000;
|
this.timer.Interval = 1000;
|
||||||
this.timer.AutoReset = false;
|
this.timer.AutoReset = true;
|
||||||
this.timer.Elapsed += SendDataToDoctor;
|
this.timer.Elapsed += SendDataToDoctor;
|
||||||
Console.WriteLine("token is " + token);
|
|
||||||
stream.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(OnRead), null);
|
stream.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(OnRead), null);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -147,9 +142,6 @@ namespace Server
|
|||||||
case DataParser.MESSAGE:
|
case DataParser.MESSAGE:
|
||||||
communication.SendMessageToClient(DataParser.getUsernameFromJson(payloadbytes), message);
|
communication.SendMessageToClient(DataParser.getUsernameFromJson(payloadbytes), message);
|
||||||
break;
|
break;
|
||||||
case DataParser.GET_FILE:
|
|
||||||
getClientBikeData(payloadbytes);
|
|
||||||
break;
|
|
||||||
default:
|
default:
|
||||||
Console.WriteLine($"Received json with identifier {identifier}:\n{Encoding.ASCII.GetString(payloadbytes)}");
|
Console.WriteLine($"Received json with identifier {identifier}:\n{Encoding.ASCII.GetString(payloadbytes)}");
|
||||||
break;
|
break;
|
||||||
@@ -162,53 +154,16 @@ namespace Server
|
|||||||
}
|
}
|
||||||
else if (DataParser.isRawDataBikeServer(message))
|
else if (DataParser.isRawDataBikeServer(message))
|
||||||
{
|
{
|
||||||
//Bikedata = true;
|
|
||||||
saveData?.WriteDataRAWBike(payloadbytes);
|
saveData?.WriteDataRAWBike(payloadbytes);
|
||||||
lock (token)
|
Array.Copy(this.BikeDataBuffer, 0, this.BikeDataBuffer, 8, 8);
|
||||||
{
|
Array.Copy(payloadbytes, 0, this.BikeDataBuffer, 0, 8);
|
||||||
Array.Copy(this.BikeDataBuffer, 0, this.BikeDataBuffer, 8, 8);
|
|
||||||
Array.Copy(payloadbytes, 0, this.BikeDataBuffer, 0, 8);
|
|
||||||
}
|
|
||||||
//this.communication.Doctor?.sendMessage(DataParser.GetRawBikeDataDoctor(payloadbytes, this.username));
|
|
||||||
}
|
}
|
||||||
else if (DataParser.isRawDataBPMServer(message))
|
else if (DataParser.isRawDataBPMServer(message))
|
||||||
{
|
{
|
||||||
//BPMdata = true;
|
|
||||||
saveData?.WriteDataRAWBPM(payloadbytes);
|
saveData?.WriteDataRAWBPM(payloadbytes);
|
||||||
lock (token)
|
Array.Copy(payloadbytes, 0, this.BikeDataBuffer, 0, 2);
|
||||||
{
|
|
||||||
Array.Copy(payloadbytes, 0, this.BPMDataBuffer, 0, 2);
|
|
||||||
}
|
|
||||||
//this.communication.Doctor?.sendMessage(DataParser.GetRawBPMDataDoctor(payloadbytes, this.username));
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
private void getClientBikeData(byte[] payloadbytes)
|
|
||||||
{
|
|
||||||
//ugly
|
|
||||||
//get the raw bike data of the user with the specified username
|
|
||||||
string username = DataParser.GetUsernameFromGetFileBytes(payloadbytes);
|
|
||||||
string path = Directory.GetCurrentDirectory() + "/" + username + "/";
|
|
||||||
string bytes = string.Empty;
|
|
||||||
StringBuilder sb = new StringBuilder(bytes);
|
|
||||||
try
|
|
||||||
{
|
|
||||||
DirectoryInfo dirInf = new DirectoryInfo(Directory.GetCurrentDirectory() + "/" + username + "/");
|
|
||||||
DirectoryInfo[] directoryInfos = dirInf.GetDirectories();
|
|
||||||
DirectoryInfo latest = directoryInfos[directoryInfos.Length - 1];
|
|
||||||
path = path + latest.Name + "/rawBike.bin";
|
|
||||||
FileInfo fi = new FileInfo(path);
|
|
||||||
|
|
||||||
if ((int)fi.Length >= 1024) return;
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
Debug.WriteLine("[SERVER CLIENT] excetion while trying to get raw bike data: " + e.Message);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Debug.WriteLine("[SERVER CLIENT] about to send " +sb.ToString());
|
|
||||||
communication.Doctor.sendMessage(DataParser.GetFileMessage(File.ReadAllBytes(path)));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private bool handleLogin(byte[] payloadbytes)
|
private bool handleLogin(byte[] payloadbytes)
|
||||||
@@ -309,13 +264,9 @@ namespace Server
|
|||||||
|
|
||||||
private void SendDataToDoctor(object sender, ElapsedEventArgs e)
|
private void SendDataToDoctor(object sender, ElapsedEventArgs e)
|
||||||
{
|
{
|
||||||
lock (token)
|
this.communication.Doctor?.sendMessage(DataParser.GetRawBikeDataDoctor(this.BikeDataBuffer.Take(8).ToArray(), this.username));
|
||||||
{
|
this.communication.Doctor?.sendMessage(DataParser.GetRawBikeDataDoctor(this.BikeDataBuffer.Skip(8).ToArray(), this.username));
|
||||||
this.communication.Doctor?.sendMessage(DataParser.GetRawBikeDataDoctor(this.BikeDataBuffer.Take(8).ToArray(), this.username));
|
this.communication.Doctor?.sendMessage(DataParser.GetRawBikeDataDoctor(this.BikeDataBuffer, this.username));
|
||||||
this.communication.Doctor?.sendMessage(DataParser.GetRawBikeDataDoctor(this.BikeDataBuffer.Skip(8).ToArray(), this.username));
|
|
||||||
this.communication.Doctor?.sendMessage(DataParser.GetRawBPMDataDoctor(this.BPMDataBuffer, this.username));
|
|
||||||
}
|
|
||||||
this.timer.Start();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user