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

fix login message, implemented IDatareceiver, added Raw and json message

Browse Source
This commit is contained in:
shinichi
2020-09-23 13:46:38 +02:00
parent fd36e420d1
commit f899c90ff7
5 changed files with 67 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
Client/Client.cs
View File

@@ -2,10 +2,11 @@
using System.Globalization;
using System.Linq;
using System.Net.Sockets;
using ProftaakRH;
namespace Client
{
class Client
class Client : IDataReceiver
{
private TcpClient client;
private NetworkStream stream;
@@ -47,14 +48,14 @@ namespace Client
Console.WriteLine("enter password");
string password = Console.ReadLine();
byte[] payload = DataParser.GetLoginJson(username, password);
byte[] message = DataParser.getJsonMessage(DataParser.GetLoginJson(username, password));
this.stream.BeginWrite(payload, 0, payload.Length, new AsyncCallback(onWrite), null);
this.stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null);
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);
}
private void onRead(IAsyncResult ar)
private void OnRead(IAsyncResult ar)
{
int receivedBytes = this.stream.EndRead(ar);
byte[] lengthBytes = new byte[4];
@@ -72,7 +73,7 @@ namespace Client
{
//message hasn't completely arrived yet
this.bytesReceived += receivedBytes;
this.stream.BeginRead(this.buffer, this.bytesReceived, this.buffer.Length - this.bytesReceived, new AsyncCallback(onRead), null);
this.stream.BeginRead(this.buffer, this.bytesReceived, this.buffer.Length - this.bytesReceived, new AsyncCallback(OnRead), null);
}
else
@@ -96,10 +97,34 @@ namespace Client
}
}
private void onWrite(IAsyncResult ar)
private void OnWrite(IAsyncResult ar)
{
this.stream.EndWrite(ar);
//stuff idk
}
#region interface
//maybe move this to other place
public void BPM(byte[] bytes)
{
if (bytes == null)
{
throw new ArgumentNullException("no bytes");
}
byte[] message = DataParser.GetRawDataMessage(bytes);
this.stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null);
}
public void Bike(byte[] bytes)
{
if (bytes == null)
{
throw new ArgumentNullException("no bytes");
}
byte[] message = DataParser.GetRawDataMessage(bytes);
this.stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null);
}
#endregion
}
}