Client.cs 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
  1. using System;
  2. using System.Text;
  3. using System.Net.Sockets;
  4. using System.Threading;
  5. namespace Server
  6. {
  7. public class Client
  8. {
  9. TcpClient client;
  10. NetworkStream networkStream;
  11. private readonly AppGlobal _global;
  12. private int iduser;
  13. public Client(TcpClient socket, AppGlobal global)
  14. {
  15. client = socket;
  16. networkStream = client.GetStream();
  17. _global = global;
  18. iduser = -1;
  19. Console.WriteLine("New client connected");
  20. Thread t = new Thread(receive);
  21. t.Start();
  22. }
  23. public void receive()
  24. {
  25. while (true)
  26. {
  27. byte[] bytesFrom = new byte[(int)client.ReceiveBufferSize];
  28. networkStream.Read(bytesFrom, 0, (int)client.ReceiveBufferSize);
  29. String response = Encoding.ASCII.GetString(bytesFrom);
  30. String[] response_parts = response.Split('|');
  31. if (response_parts.Length > 0)
  32. {
  33. switch (response_parts[0])
  34. {
  35. case "0": //login
  36. if (response_parts.Length == 4)
  37. {
  38. int admin, id;
  39. _global.CheckLogin(response_parts[1], response_parts[2], out admin, out id);
  40. if (id > -1)
  41. {
  42. this.iduser = id;
  43. sendString("0|" + id + "|" + admin + "|");
  44. }
  45. else
  46. {
  47. sendString("0|0|0|");
  48. }
  49. }
  50. break;
  51. case "1": //meetsessies ophalen
  52. break;
  53. case "2": //Livedata opvragen
  54. break;
  55. case "3": //Nieuwe meetsessie aanmaken
  56. if (response_parts.Length == 5 && iduser != -1)
  57. {
  58. _global.addMeetsessie(response_parts[1], Int32.Parse(response_parts[2]), response_parts[3]);
  59. }
  60. break;
  61. case "4": //Check nieuwe meetsessie
  62. break;
  63. case "5": //data pushen naar meetsessie
  64. break;
  65. }
  66. }
  67. }
  68. }
  69. public void sendString(string s)
  70. {
  71. byte[] b = Encoding.ASCII.GetBytes(s);
  72. networkStream.Write(b, 0, b.Length);
  73. networkStream.Flush();
  74. }
  75. }
  76. }