This commit is contained in:
2015-10-02 13:40:02 +02:00
parent 5049bd3a38
commit 9c8c87efaa
4 changed files with 36 additions and 8 deletions
+1 -1
View File
@@ -22,7 +22,7 @@ namespace ErgometerLibrary
string[] existingSessions = Directory.GetDirectories(DataFolder); string[] existingSessions = Directory.GetDirectories(DataFolder);
Random rand = new Random(); Random rand = new Random();
int sessionID = rand.Next(int.MinValue, int.MaxValue); int sessionID = rand.Next(0, int.MaxValue);
while (existingSessions.Contains(sessionID.ToString())) while (existingSessions.Contains(sessionID.ToString()))
+5 -1
View File
@@ -52,7 +52,7 @@ namespace ErgometerLibrary
ChatMessage = chat; ChatMessage = chat;
} }
public NetCommand(string name, bool doctor, int session) public NetCommand(string name, bool doctor, string password, int session)
{ {
Type = CommandType.LOGIN; Type = CommandType.LOGIN;
Session = session; Session = session;
@@ -60,12 +60,16 @@ namespace ErgometerLibrary
DisplayName = name; DisplayName = name;
IsDoctor = doctor; IsDoctor = doctor;
Password = password;
} }
public static NetCommand Parse(string command) public static NetCommand Parse(string command)
{ {
string[] com = command.Split('»'); string[] com = command.Split('»');
Console.WriteLine(command);
Console.WriteLine(com[0]);
int comType = int.Parse(com[0]); int comType = int.Parse(com[0]);
int session = 0; int session = 0;
if (com[1].StartsWith("ses")) if (com[1].StartsWith("ses"))
+28 -4
View File
@@ -1,4 +1,5 @@
using System; using System;
using System.IO;
using System.Net; using System.Net;
using System.Net.Sockets; using System.Net.Sockets;
using System.Text; using System.Text;
@@ -9,33 +10,56 @@ namespace ErgometerLibrary
{ {
public static void SendNetCommand(TcpClient client, NetCommand command) public static void SendNetCommand(TcpClient client, NetCommand command)
{ {
byte[] b = Encoding.ASCII.GetBytes(command.ToString()); /*
byte[] b = Encoding.Unicode.GetBytes(command.ToString());
client.GetStream().Write(b, 0, b.Length); client.GetStream().Write(b, 0, b.Length);
client.GetStream().Flush(); client.GetStream().Flush();
*/
SendString(client, command.ToString());
} }
public static void SendString(TcpClient client, string command) public static void SendString(TcpClient client, string command)
{ {
byte[] b = Encoding.ASCII.GetBytes(command); /*
byte[] b = Encoding.Unicode.GetBytes(command);
client.GetStream().Write(b, 0, b.Length); client.GetStream().Write(b, 0, b.Length);
client.GetStream().Flush(); client.GetStream().Flush();
*/
StreamWriter wr = new StreamWriter(client.GetStream(), Encoding.Unicode);
wr.WriteLine(command);
Console.WriteLine("sent " + command);
wr.Flush();
} }
public static NetCommand ReadNetCommand(TcpClient client) public static NetCommand ReadNetCommand(TcpClient client)
{ {
/*
byte[] bytesFrom = new byte[(int) client.ReceiveBufferSize]; byte[] bytesFrom = new byte[(int) client.ReceiveBufferSize];
client.GetStream().Read(bytesFrom, 0, (int)client.ReceiveBufferSize); client.GetStream().Read(bytesFrom, 0, (int)client.ReceiveBufferSize);
string response = Encoding.ASCII.GetString(bytesFrom); string response = Encoding.Unicode.GetString(bytesFrom);
NetCommand net = NetCommand.Parse(response); NetCommand net = NetCommand.Parse(response);
return net; return net;
*/
string str = ReadString(client);
NetCommand net = NetCommand.Parse(str);
return net;
} }
public static string ReadString(TcpClient client) public static string ReadString(TcpClient client)
{ {
/*
byte[] bytesFrom = new byte[(int)client.ReceiveBufferSize]; byte[] bytesFrom = new byte[(int)client.ReceiveBufferSize];
client.GetStream().Read(bytesFrom, 0, (int)client.ReceiveBufferSize); client.GetStream().Read(bytesFrom, 0, (int)client.ReceiveBufferSize);
string response = Encoding.ASCII.GetString(bytesFrom); string response = Encoding.Unicode.GetString(bytesFrom);
return response; return response;
*/
StreamReader rd = new StreamReader(client.GetStream(), Encoding.Unicode);
string str = rd.ReadLine();
Console.WriteLine("rec " + str);
return str;
} }
public static IPAddress GetIP(string ipstring) public static IPAddress GetIP(string ipstring)
+2 -2
View File
@@ -32,5 +32,5 @@ using System.Runtime.InteropServices;
// You can specify all the values or you can default the Build and Revision Numbers // You can specify all the values or you can default the Build and Revision Numbers
// by using the '*' as shown below: // by using the '*' as shown below:
// [assembly: AssemblyVersion("1.0.*")] // [assembly: AssemblyVersion("1.0.*")]
[assembly: AssemblyVersion("1.0.2.1")] [assembly: AssemblyVersion("1.0.2.2")]
[assembly: AssemblyFileVersion("1.0.2.1")] [assembly: AssemblyFileVersion("1.0.2.2")]