Compare commits
13 Commits
wpf
...
connect-vr
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
cb2435bf53 | ||
|
|
fedf8c0e5b | ||
|
|
3e5f6e46c4 | ||
|
|
97f9d863aa | ||
|
|
d6b938668f | ||
|
|
341723d1d1 | ||
|
|
0cd3753b76 | ||
|
|
4388b39be5 | ||
|
|
0dc4bb6fad | ||
|
|
3ca3c1ad78 | ||
|
|
d06d621b13 | ||
|
|
7b05fcc898 | ||
|
|
c5b9a7ec09 |
@@ -14,6 +14,7 @@ namespace Client
|
|||||||
private bool connected;
|
private bool connected;
|
||||||
private byte[] totalBuffer = new byte[1024];
|
private byte[] totalBuffer = new byte[1024];
|
||||||
private int totalBufferReceived = 0;
|
private int totalBufferReceived = 0;
|
||||||
|
private EngineConnection engineConnection;
|
||||||
|
|
||||||
|
|
||||||
public Client() : this("localhost", 5555)
|
public Client() : this("localhost", 5555)
|
||||||
@@ -28,6 +29,22 @@ namespace Client
|
|||||||
client.BeginConnect(adress, port, new AsyncCallback(OnConnect), null);
|
client.BeginConnect(adress, port, new AsyncCallback(OnConnect), null);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private void initEngine()
|
||||||
|
{
|
||||||
|
engineConnection = EngineConnection.INSTANCE;
|
||||||
|
engineConnection.OnNoTunnelId = retryEngineConnection;
|
||||||
|
if (!engineConnection.Connected) engineConnection.Connect();
|
||||||
|
}
|
||||||
|
|
||||||
|
private void retryEngineConnection()
|
||||||
|
{
|
||||||
|
Console.WriteLine("-- Could not connect to the VR engine. Please make sure you are running the simulation!");
|
||||||
|
Console.WriteLine("-- Press any key to retry connecting to the VR engine.");
|
||||||
|
Console.ReadKey();
|
||||||
|
|
||||||
|
engineConnection.CreateConnection();
|
||||||
|
}
|
||||||
|
|
||||||
private void OnConnect(IAsyncResult ar)
|
private void OnConnect(IAsyncResult ar)
|
||||||
{
|
{
|
||||||
this.client.EndConnect(ar);
|
this.client.EndConnect(ar);
|
||||||
@@ -75,6 +92,7 @@ namespace Client
|
|||||||
if (responseStatus == "OK")
|
if (responseStatus == "OK")
|
||||||
{
|
{
|
||||||
this.connected = true;
|
this.connected = true;
|
||||||
|
initEngine();
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
@@ -141,7 +159,11 @@ namespace Client
|
|||||||
Console.WriteLine("enter password");
|
Console.WriteLine("enter password");
|
||||||
string password = Console.ReadLine();
|
string password = Console.ReadLine();
|
||||||
|
|
||||||
byte[] message = DataParser.getJsonMessage(DataParser.GetLoginJson(username, 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);
|
this.stream.BeginWrite(message, 0, message.Length, new AsyncCallback(OnWrite), null);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -12,6 +12,9 @@
|
|||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<ProjectReference Include="..\Message\Message.csproj" />
|
<ProjectReference Include="..\Message\Message.csproj" />
|
||||||
<ProjectReference Include="..\ProftaakRH\ProftaakRH.csproj" />
|
<ProjectReference Include="..\ProftaakRH\ProftaakRH.csproj" />
|
||||||
|
<ProjectReference Include="..\RH-Engine\RH-Engine.csproj" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
|
<Import Project="..\Hashing\Hashing.projitems" Label="Shared" />
|
||||||
|
|
||||||
</Project>
|
</Project>
|
||||||
|
|||||||
180
Client/EngineConnection.cs
Normal file
180
Client/EngineConnection.cs
Normal file
@@ -0,0 +1,180 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Text;
|
||||||
|
using RH_Engine;
|
||||||
|
using System.Net.Sockets;
|
||||||
|
|
||||||
|
namespace Client
|
||||||
|
{
|
||||||
|
public delegate void HandleSerial(string message);
|
||||||
|
public delegate void HandleNoTunnelId();
|
||||||
|
|
||||||
|
public sealed class EngineConnection
|
||||||
|
{
|
||||||
|
private static EngineConnection instance = null;
|
||||||
|
private static readonly object padlock = new object();
|
||||||
|
public HandleNoTunnelId OnNoTunnelId;
|
||||||
|
|
||||||
|
|
||||||
|
private static PC[] PCs = {
|
||||||
|
//new PC("DESKTOP-M2CIH87", "Fabian"),
|
||||||
|
//new PC("T470S", "Shinichi"),
|
||||||
|
//new PC("DESKTOP-DHS478C", "semme"),
|
||||||
|
new PC("HP-ZBOOK-SEM", "Sem")
|
||||||
|
//new PC("DESKTOP-TV73FKO", "Wouter"),
|
||||||
|
//new PC("DESKTOP-SINMKT1", "Ralf van Aert"),
|
||||||
|
//new PC("NA", "Bart")
|
||||||
|
};
|
||||||
|
|
||||||
|
private static ServerResponseReader serverResponseReader;
|
||||||
|
private static string sessionId = string.Empty;
|
||||||
|
private static string tunnelId = string.Empty;
|
||||||
|
private static string routeId = string.Empty;
|
||||||
|
private static string panelId = string.Empty;
|
||||||
|
private static string bikeId = string.Empty;
|
||||||
|
|
||||||
|
private static NetworkStream stream;
|
||||||
|
|
||||||
|
private static Dictionary<string, HandleSerial> serialResponses = new Dictionary<string, HandleSerial>();
|
||||||
|
private Command mainCommand;
|
||||||
|
|
||||||
|
public bool Connected = false;
|
||||||
|
|
||||||
|
EngineConnection()
|
||||||
|
{
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public static EngineConnection INSTANCE
|
||||||
|
{
|
||||||
|
get
|
||||||
|
{
|
||||||
|
lock (padlock)
|
||||||
|
{
|
||||||
|
if (instance == null)
|
||||||
|
{
|
||||||
|
instance = new EngineConnection();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return instance;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public void Connect()
|
||||||
|
{
|
||||||
|
TcpClient client = new TcpClient("145.48.6.10", 6666);
|
||||||
|
stream = client.GetStream();
|
||||||
|
initReader();
|
||||||
|
CreateConnection();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// connects to the server and creates the tunnel
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="stream">the network stream to use</param>
|
||||||
|
public void CreateConnection()
|
||||||
|
{
|
||||||
|
|
||||||
|
WriteTextMessage( "{\r\n\"id\" : \"session/list\",\r\n\"serial\" : \"list\"\r\n}");
|
||||||
|
|
||||||
|
// wait until we have got a sessionId
|
||||||
|
while (sessionId == string.Empty) { }
|
||||||
|
|
||||||
|
string tunnelCreate = "{\"id\" : \"tunnel/create\", \"data\" : {\"session\" : \"" + sessionId + "\"}}";
|
||||||
|
|
||||||
|
WriteTextMessage(tunnelCreate);
|
||||||
|
|
||||||
|
// wait until we have a tunnel id
|
||||||
|
while (tunnelId == string.Empty) { }
|
||||||
|
if (tunnelId != null)
|
||||||
|
{
|
||||||
|
Write("got tunnel id! " + tunnelId);
|
||||||
|
}
|
||||||
|
mainCommand = new Command(tunnelId);
|
||||||
|
|
||||||
|
}
|
||||||
|
/// <summary>
|
||||||
|
/// initializes and starts the reading of the responses from the vr server
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="stream">the networkstream</param>
|
||||||
|
private void initReader()
|
||||||
|
{
|
||||||
|
serverResponseReader = new ServerResponseReader(stream);
|
||||||
|
serverResponseReader.callback = HandleResponse;
|
||||||
|
serverResponseReader.StartRead();
|
||||||
|
Connected = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// callback method that handles responses from the server
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="message">the response message from the server</param>
|
||||||
|
public void HandleResponse(string message)
|
||||||
|
{
|
||||||
|
string id = JSONParser.GetID(message);
|
||||||
|
|
||||||
|
// because the first messages don't have a serial, we need to check on the id
|
||||||
|
if (id == "session/list")
|
||||||
|
{
|
||||||
|
sessionId = JSONParser.GetSessionID(message, PCs);
|
||||||
|
}
|
||||||
|
else if (id == "tunnel/create")
|
||||||
|
{
|
||||||
|
tunnelId = JSONParser.GetTunnelID(message);
|
||||||
|
if (tunnelId == null)
|
||||||
|
{
|
||||||
|
Write("could not find a valid tunnel id!");
|
||||||
|
OnNoTunnelId?.Invoke();
|
||||||
|
Connected = false;
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (message.Contains("serial"))
|
||||||
|
{
|
||||||
|
//Console.WriteLine("GOT MESSAGE WITH SERIAL: " + message + "\n\n\n");
|
||||||
|
string serial = JSONParser.GetSerial(message);
|
||||||
|
//Console.WriteLine("Got serial " + serial);
|
||||||
|
if (serialResponses.ContainsKey(serial)) serialResponses[serial].Invoke(message);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// method that sends the speciefied message with the specified serial, and executes the given action upon receivind a reply from the server with this serial.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="stream">the networkstream to use</param>
|
||||||
|
/// <param name="message">the message to send</param>
|
||||||
|
/// <param name="serial">the serial to check for</param>
|
||||||
|
/// <param name="action">the code to be executed upon reveiving a reply from the server with the specified serial</param>
|
||||||
|
public void SendMessageAndOnResponse(string message, string serial, HandleSerial action)
|
||||||
|
{
|
||||||
|
serialResponses.Add(serial, action);
|
||||||
|
WriteTextMessage(message);
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// writes a message to the server
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="stream">the network stream to use</param>
|
||||||
|
/// <param name="message">the message to send</param>
|
||||||
|
public void WriteTextMessage(string message)
|
||||||
|
{
|
||||||
|
byte[] msg = Encoding.ASCII.GetBytes(message);
|
||||||
|
byte[] res = new byte[msg.Length + 4];
|
||||||
|
|
||||||
|
Array.Copy(BitConverter.GetBytes(msg.Length), 0, res, 0, 4);
|
||||||
|
Array.Copy(msg, 0, res, 4, msg.Length);
|
||||||
|
|
||||||
|
stream.Write(res);
|
||||||
|
|
||||||
|
//Write("sent message " + message);
|
||||||
|
}
|
||||||
|
public void Write(string msg)
|
||||||
|
{
|
||||||
|
Console.WriteLine( "[ENGINECONNECT] " + msg);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@@ -1,6 +1,9 @@
|
|||||||
using System;
|
using System;
|
||||||
using Hardware;
|
using Hardware;
|
||||||
using Hardware.Simulators;
|
using Hardware.Simulators;
|
||||||
|
using RH_Engine;
|
||||||
|
using System.Security.Cryptography;
|
||||||
|
using System.Text;
|
||||||
|
|
||||||
namespace Client
|
namespace Client
|
||||||
{
|
{
|
||||||
@@ -11,7 +14,6 @@ namespace Client
|
|||||||
Console.WriteLine("Hello World!");
|
Console.WriteLine("Hello World!");
|
||||||
//connect fiets?
|
//connect fiets?
|
||||||
|
|
||||||
|
|
||||||
Client client = new Client();
|
Client client = new Client();
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
27
Hashing/Hasher.cs
Normal file
27
Hashing/Hasher.cs
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
using System;
|
||||||
|
using System.Collections.Generic;
|
||||||
|
using System.Security.Cryptography;
|
||||||
|
using System.Text;
|
||||||
|
|
||||||
|
namespace Hashing
|
||||||
|
{
|
||||||
|
class Hasher
|
||||||
|
{
|
||||||
|
public static byte[] GetHash(string input)
|
||||||
|
{
|
||||||
|
using (HashAlgorithm algorithm = SHA256.Create())
|
||||||
|
{
|
||||||
|
return algorithm.ComputeHash(Encoding.UTF8.GetBytes(input));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public static string HashString(string input)
|
||||||
|
{
|
||||||
|
StringBuilder sb = new StringBuilder();
|
||||||
|
foreach (byte b in GetHash(input)) {
|
||||||
|
sb.Append(b.ToString("X2"));
|
||||||
|
}
|
||||||
|
return sb.ToString();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
14
Hashing/Hashing.projitems
Normal file
14
Hashing/Hashing.projitems
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<Project xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||||
|
<PropertyGroup>
|
||||||
|
<MSBuildAllProjects>$(MSBuildAllProjects);$(MSBuildThisFileFullPath)</MSBuildAllProjects>
|
||||||
|
<HasSharedItems>true</HasSharedItems>
|
||||||
|
<SharedGUID>70277749-d423-4871-b692-2efc5a6ed932</SharedGUID>
|
||||||
|
</PropertyGroup>
|
||||||
|
<PropertyGroup Label="Configuration">
|
||||||
|
<Import_RootNamespace>Hashing</Import_RootNamespace>
|
||||||
|
</PropertyGroup>
|
||||||
|
<ItemGroup>
|
||||||
|
<Compile Include="$(MSBuildThisFileDirectory)Hasher.cs" />
|
||||||
|
</ItemGroup>
|
||||||
|
</Project>
|
||||||
13
Hashing/Hashing.shproj
Normal file
13
Hashing/Hashing.shproj
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
<?xml version="1.0" encoding="utf-8"?>
|
||||||
|
<Project ToolsVersion="15.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||||
|
<PropertyGroup Label="Globals">
|
||||||
|
<ProjectGuid>70277749-d423-4871-b692-2efc5a6ed932</ProjectGuid>
|
||||||
|
<MinimumVisualStudioVersion>14.0</MinimumVisualStudioVersion>
|
||||||
|
</PropertyGroup>
|
||||||
|
<Import Project="$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props" Condition="Exists('$(MSBuildExtensionsPath)\$(MSBuildToolsVersion)\Microsoft.Common.props')" />
|
||||||
|
<Import Project="$(MSBuildExtensionsPath32)\Microsoft\VisualStudio\v$(VisualStudioVersion)\CodeSharing\Microsoft.CodeSharing.Common.Default.props" />
|
||||||
|
<Import Project="$(MSBuildExtensionsPath32)\Microsoft\VisualStudio\v$(VisualStudioVersion)\CodeSharing\Microsoft.CodeSharing.Common.props" />
|
||||||
|
<PropertyGroup />
|
||||||
|
<Import Project="Hashing.projitems" Label="Shared" />
|
||||||
|
<Import Project="$(MSBuildExtensionsPath32)\Microsoft\VisualStudio\v$(VisualStudioVersion)\CodeSharing\Microsoft.CodeSharing.CSharp.targets" />
|
||||||
|
</Project>
|
||||||
@@ -13,9 +13,16 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Client", "..\Client\Client.
|
|||||||
EndProject
|
EndProject
|
||||||
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Message", "..\Message\Message.csproj", "{9ED6832D-B0FB-4460-9BCD-FAA58863B0CE}"
|
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Message", "..\Message\Message.csproj", "{9ED6832D-B0FB-4460-9BCD-FAA58863B0CE}"
|
||||||
EndProject
|
EndProject
|
||||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DokterApp", "..\DokterApp\DokterApp.csproj", "{B150F08B-13DA-4D17-BD96-7E89F52727C6}"
|
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DokterApp", "..\DokterApp\DokterApp.csproj", "{B150F08B-13DA-4D17-BD96-7E89F52727C6}"
|
||||||
|
EndProject
|
||||||
|
Project("{D954291E-2A0B-460D-934E-DC6B0785DB48}") = "Hashing", "..\Hashing\Hashing.shproj", "{70277749-D423-4871-B692-2EFC5A6ED932}"
|
||||||
EndProject
|
EndProject
|
||||||
Global
|
Global
|
||||||
|
GlobalSection(SharedMSBuildProjectFiles) = preSolution
|
||||||
|
..\Hashing\Hashing.projitems*{5759dd20-7a4f-4d8d-b986-a70a7818c112}*SharedItemsImports = 5
|
||||||
|
..\Hashing\Hashing.projitems*{70277749-d423-4871-b692-2efc5a6ed932}*SharedItemsImports = 13
|
||||||
|
..\Hashing\Hashing.projitems*{b1ab6f51-a20d-4162-9a7f-b3350b7510fd}*SharedItemsImports = 5
|
||||||
|
EndGlobalSection
|
||||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||||
Debug|Any CPU = Debug|Any CPU
|
Debug|Any CPU = Debug|Any CPU
|
||||||
Release|Any CPU = Release|Any CPU
|
Release|Any CPU = Release|Any CPU
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ using System;
|
|||||||
|
|
||||||
namespace RH_Engine
|
namespace RH_Engine
|
||||||
{
|
{
|
||||||
class Command
|
public class Command
|
||||||
{
|
{
|
||||||
public const string STANDARD_HEAD = "Head";
|
public const string STANDARD_HEAD = "Head";
|
||||||
public const string STANDARD_GROUND = "GroundPlane";
|
public const string STANDARD_GROUND = "GroundPlane";
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ using System;
|
|||||||
|
|
||||||
namespace RH_Engine
|
namespace RH_Engine
|
||||||
{
|
{
|
||||||
class JSONParser
|
public class JSONParser
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// returns all the users from the given response
|
/// returns all the users from the given response
|
||||||
@@ -36,7 +36,7 @@ namespace RH_Engine
|
|||||||
{
|
{
|
||||||
if (d.clientinfo.host == pc.host && d.clientinfo.user == pc.user)
|
if (d.clientinfo.host == pc.host && d.clientinfo.user == pc.user)
|
||||||
{
|
{
|
||||||
Console.WriteLine("connecting to {0}, on {1} with id {2}", pc.user, pc.host, d.id);
|
Console.WriteLine("[JSONPARSER] connecting to {0}, on {1} with id {2}", pc.user, pc.host, d.id);
|
||||||
return d.id;
|
return d.id;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ namespace RH_Engine
|
|||||||
{
|
{
|
||||||
public delegate void HandleSerial(string message);
|
public delegate void HandleSerial(string message);
|
||||||
|
|
||||||
class Program
|
public class Program
|
||||||
{
|
{
|
||||||
private static PC[] PCs = {
|
private static PC[] PCs = {
|
||||||
//new PC("DESKTOP-M2CIH87", "Fabian"),
|
//new PC("DESKTOP-M2CIH87", "Fabian"),
|
||||||
@@ -161,23 +161,6 @@ namespace RH_Engine
|
|||||||
});
|
});
|
||||||
|
|
||||||
Console.WriteLine("id of head " + GetId(Command.STANDARD_HEAD, stream, mainCommand));
|
Console.WriteLine("id of head " + GetId(Command.STANDARD_HEAD, stream, mainCommand));
|
||||||
|
|
||||||
//command = mainCommand.AddModel("car", "data\\customModels\\TeslaRoadster.fbx");
|
|
||||||
//WriteTextMessage(stream, command);
|
|
||||||
|
|
||||||
//command = mainCommand.addPanel();
|
|
||||||
// WriteTextMessage(stream, command);
|
|
||||||
// string response = ReadPrefMessage(stream);
|
|
||||||
// Console.WriteLine("add Panel response: \n\r" + response);
|
|
||||||
// string uuidPanel = JSONParser.getPanelID(response);
|
|
||||||
// WriteTextMessage(stream, mainCommand.ClearPanel(uuidPanel));
|
|
||||||
// Console.WriteLine(ReadPrefMessage(stream));
|
|
||||||
// WriteTextMessage(stream, mainCommand.bikeSpeed(uuidPanel, 2.42));
|
|
||||||
// Console.WriteLine(ReadPrefMessage(stream));
|
|
||||||
// WriteTextMessage(stream, mainCommand.ColorPanel(uuidPanel));
|
|
||||||
// Console.WriteLine("Color panel: " + ReadPrefMessage(stream));
|
|
||||||
// WriteTextMessage(stream, mainCommand.SwapPanel(uuidPanel));
|
|
||||||
// Console.WriteLine("Swap panel: " + ReadPrefMessage(stream));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ namespace RH_Engine
|
|||||||
{
|
{
|
||||||
public delegate void OnResponse(string response);
|
public delegate void OnResponse(string response);
|
||||||
|
|
||||||
class ServerResponseReader
|
public class ServerResponseReader
|
||||||
{
|
{
|
||||||
public OnResponse callback
|
public OnResponse callback
|
||||||
{
|
{
|
||||||
@@ -31,7 +31,7 @@ namespace RH_Engine
|
|||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
Console.WriteLine("Starting loop for reading");
|
Console.WriteLine("[SERVERRESPONSEREADER] Starting loop for reading");
|
||||||
while (true)
|
while (true)
|
||||||
{
|
{
|
||||||
string res = ReadPrefMessage(Stream);
|
string res = ReadPrefMessage(Stream);
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ using System.Net.Sockets;
|
|||||||
using System.Text;
|
using System.Text;
|
||||||
using Client;
|
using Client;
|
||||||
using Newtonsoft.Json;
|
using Newtonsoft.Json;
|
||||||
|
using System.Security.Cryptography;
|
||||||
|
|
||||||
namespace Server
|
namespace Server
|
||||||
{
|
{
|
||||||
@@ -19,6 +20,7 @@ namespace Server
|
|||||||
private SaveData saveData;
|
private SaveData saveData;
|
||||||
private string username = null;
|
private string username = null;
|
||||||
private DateTime sessionStart;
|
private DateTime sessionStart;
|
||||||
|
private const string fileName = "userInfo.dat";
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -125,7 +127,8 @@ namespace Server
|
|||||||
}
|
}
|
||||||
Array.Copy(message, 5, payloadbytes, 0, message.Length - 5);
|
Array.Copy(message, 5, payloadbytes, 0, message.Length - 5);
|
||||||
dynamic json = JsonConvert.DeserializeObject(Encoding.ASCII.GetString(payloadbytes));
|
dynamic json = JsonConvert.DeserializeObject(Encoding.ASCII.GetString(payloadbytes));
|
||||||
saveData.WriteDataJSON(Encoding.ASCII.GetString(payloadbytes));
|
|
||||||
|
//saveData.WriteDataJSON(Encoding.ASCII.GetString(payloadbytes));
|
||||||
|
|
||||||
}
|
}
|
||||||
else if (DataParser.isRawData(message))
|
else if (DataParser.isRawData(message))
|
||||||
@@ -139,9 +142,58 @@ namespace Server
|
|||||||
|
|
||||||
private bool verifyLogin(string username, string password)
|
private bool verifyLogin(string username, string password)
|
||||||
{
|
{
|
||||||
return username == password;
|
Console.WriteLine("got hashes " + username + "\n" + password);
|
||||||
|
|
||||||
|
|
||||||
|
if (!File.Exists(fileName))
|
||||||
|
{
|
||||||
|
File.Create(fileName);
|
||||||
|
Console.WriteLine("file doesnt exist");
|
||||||
|
newUsers(username, password);
|
||||||
|
Console.WriteLine("true");
|
||||||
|
return true;
|
||||||
|
} else
|
||||||
|
{
|
||||||
|
Console.WriteLine("file exists, located at " + Path.GetFullPath(fileName));
|
||||||
|
string[] usernamesPasswords = File.ReadAllLines(fileName);
|
||||||
|
if (usernamesPasswords.Length == 0)
|
||||||
|
{
|
||||||
|
newUsers(username, password);
|
||||||
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
foreach (string s in usernamesPasswords)
|
||||||
|
{
|
||||||
|
string[] combo = s.Split(" ");
|
||||||
|
if (combo[0] == username)
|
||||||
|
{
|
||||||
|
Console.WriteLine("correct info");
|
||||||
|
return combo[1] == password;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
Console.WriteLine("combo was not found in file");
|
||||||
|
|
||||||
|
}
|
||||||
|
Console.WriteLine("false");
|
||||||
|
return false;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
private void newUsers(string username, string password)
|
||||||
|
{
|
||||||
|
|
||||||
|
Console.WriteLine("creating new entry in file");
|
||||||
|
using (StreamWriter sw = File.AppendText(fileName))
|
||||||
|
{
|
||||||
|
sw.WriteLine(username + " " + password);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
public static string ByteArrayToString(byte[] ba)
|
public static string ByteArrayToString(byte[] ba)
|
||||||
{
|
{
|
||||||
StringBuilder hex = new StringBuilder(ba.Length * 2);
|
StringBuilder hex = new StringBuilder(ba.Length * 2);
|
||||||
|
|||||||
@@ -13,4 +13,6 @@
|
|||||||
<ProjectReference Include="..\Client\Client.csproj" />
|
<ProjectReference Include="..\Client\Client.csproj" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
|
|
||||||
|
<Import Project="..\Hashing\Hashing.projitems" Label="Shared" />
|
||||||
|
|
||||||
</Project>
|
</Project>
|
||||||
|
|||||||
Reference in New Issue
Block a user