Client.cs 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. using System;
  2. using System.Linq;
  3. using System.Text;
  4. using System.Net.Sockets;
  5. using System.Threading;
  6. using Newtonsoft.Json;
  7. using Newtonsoft.Json.Converters;
  8. using Server.JSONObjecten;
  9. using JsonConverter = Server.FileIO.JsonConverter;
  10. namespace Server
  11. {
  12. public class Client
  13. {
  14. TcpClient client;
  15. NetworkStream networkStream;
  16. private readonly AppGlobal _global;
  17. private int iduser;
  18. public Client(TcpClient socket, AppGlobal global)
  19. {
  20. client = socket;
  21. networkStream = client.GetStream();
  22. _global = global;
  23. iduser = -1;
  24. Console.WriteLine("New client connected");
  25. Thread t = new Thread(recieve);
  26. t.Start();
  27. }
  28. public void recieve()
  29. {
  30. while (true)
  31. {
  32. byte[] bytesFrom = new byte[(int)client.ReceiveBufferSize];
  33. networkStream.Read(bytesFrom, 0, (int)client.ReceiveBufferSize);
  34. String response = Encoding.ASCII.GetString(bytesFrom);
  35. String[] response_parts = response.Split('|');
  36. if (response_parts.Length > 0)
  37. {
  38. User currentUser = null;
  39. switch (response_parts[0])
  40. {
  41. case "0": //login
  42. if (response_parts.Length == 4)
  43. {
  44. int admin, id;
  45. _global.CheckLogin(response_parts[1], response_parts[2], out admin, out id);
  46. if (id > -1)
  47. {
  48. if(_global.GetUsers().First(item => item.id == response_parts[1]).isDoctor)
  49. {
  50. sendString("0|1|1|"); // Doctor
  51. }
  52. else
  53. {
  54. sendString("0|1|0|"); //Patient
  55. }
  56. }
  57. else
  58. {
  59. sendString("0|0|0|");
  60. }
  61. }
  62. break;
  63. case "1": //meetsessies ophalen
  64. currentUser = _global.GetUsers().First(item => item.id == response_parts[1]);
  65. sendString("1|" + JsonConverter.GetUserSessions(currentUser));
  66. break;
  67. case "2": //Livedata opvragen
  68. currentUser = _global.GetUsers().First(item => item.id == response_parts[1]);
  69. JsonConverter.GetLastMeasurement(currentUser.tests.Last());
  70. break;
  71. case "3": //Nieuwe meetsessie aanmaken
  72. if (response_parts.Length == 6 && iduser != -1)
  73. {
  74. _global.AddSession(response_parts[1], int.Parse(response_parts[2]), response_parts[3]);
  75. }
  76. break;
  77. case "4": //Check nieuwe meetsessie
  78. break;
  79. case "5": //data pushen naar meetsessie
  80. currentUser = _global.GetUsers().First(item => item.id == response_parts[1]);
  81. currentUser.tests.Last().AddMeasurement(JsonConvert.DeserializeObject<Measurement>(response_parts[2]));
  82. break;
  83. }
  84. }
  85. }
  86. }
  87. public void sendString(string s)
  88. {
  89. byte[] b = Encoding.ASCII.GetBytes(s);
  90. networkStream.Write(b, 0, b.Length);
  91. networkStream.Flush();
  92. }
  93. }
  94. }