Nuno_Teixeira / SkyFrontier-Project-IADE-UE4-3D
Transfer to URL with SHA Find file
Newer
Older
SkyFrontier-Project-IADE-UE4-3D / Source / SkyFrontier / Private / TCPClient.cpp
@Genexuz Genexuz on 6 Dec 2022 3 KB idk matchmaking
Raw Blame History 
  1. // Fill out your copyright notice in the Description page of Project Settings.
  4. #include "TCPClient.h"
  6. #include "MyPlayerState.h"
  7. #include "Sockets.h"
  8. #include "SocketSubsystem.h"
  9. #include "Interfaces/IPv4/IPv4Address.h"
  10. #include "TraceServices/Model/Diagnostics.h"
  12. TCPClient::TCPClient(AMyPlayerState* pState)
  13. {
  14. 	Thread = FRunnableThread::Create(this, TEXT("TCPClientThread"), 0,  TPri_Normal);  PlayerState = pState;
  15. }
  16. TCPClient::~TCPClient()
  17. {
  18. 	TCPClient::Stop();  delete Thread;
  19. }
  20. void TCPClient::Stop()
  21. {
  22. 	running = false;
  23. }
  24. bool TCPClient::IsConnected()
  25. {
  26. 	return connected;
  27. }
  29. bool TCPClient::Init()
  30. {
  31. 	Socket = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateSocket(NAME_Stream, TEXT("default"), false);
  32. 	int32 NewSize = 0;
  33. 	Socket->SetReceiveBufferSize(1024, NewSize);
  34. 	FIPv4Address matchmakingServerIP(127, 0, 0, 1);
  35. 	TSharedRef<FInternetAddr> matchmakingServer = ISocketSubsystem::Get(PLATFORM_SOCKETSUBSYSTEM)->CreateInternetAddr();
  36. 	matchmakingServer->SetIp(matchmakingServerIP.Value);
  37. 	matchmakingServer->SetPort(8856);
  38. 	
  39. 	connected = Socket->Connect(*matchmakingServer);
  40. 	if (connected)
  41. 	{
  42. 		UE_LOG(LogTemp, Log, TEXT("CONNECTED!"));
  43. 		FString serialized = TEXT("g|#");
  44. 		TCHAR *serializedChar = serialized.GetCharArray().GetData();
  45. 		int32 size = FCString::Strlen(serializedChar);
  46. 		int32 sent = 0;
  47. 		bool successful = Socket->Send((uint8*)TCHAR_TO_UTF8(serializedChar), size, sent);
  48. 		if (successful)
  49. 			{UE_LOG(LogTemp, Log, TEXT("MESSAGE SENT!"));
  50. 			return true;
  51. 		}
  52. 		else
  53. 		{
  54. 			UE_LOG(LogTemp, Log, TEXT("ERROR: NOT CONNECTED!"));return false;
  55. 		}
  56. 	}
  57. 	return 0;
  58. }
  59. 	uint32 TCPClient::Run()
  60. 	{
  61. 		running = true;
  62. 		TArray<uint8> ReceivedData;
  63. 		while (running)
  64. 		{
  65. 			uint32 Size = 0;
  66. 			if (Socket->HasPendingData(Size))
  67. 			{
  68. 				ReceivedData.Init(0, Size);
  69. 				int32 Read = 0;
  70. 				Socket->Recv(ReceivedData.GetData(), ReceivedData.Num(), Read);
  71. 				FString ServerMessage = FString(UTF8_TO_TCHAR(ReceivedData.GetData()));
  72. 				UE_LOG(LogTemp, Log, TEXT("RECEIVED: %s"), *ServerMessage);
  73. 				if ((ServerMessage[0] == 's') && (PlayerState))
  74. 				{
  75. 					PlayerState->UpdateSessionsList(ServerMessage);
  76. 				}
  77. 				else if((ServerMessage[0] == 'o') && (PlayerState))
  78. 				{
  79. 					TArray<FString> Out;
  80. 					ServerMessage.ParseIntoArray(Out, TEXT("|"), true);
  81. 					FSessionInfo session;
  82. 					session.id = -1;
  83. 					session.name = "";
  84. 					session.serverip = Out[1];
  85. 					session.serverport = FCString::Atoi(*Out[2]);
  86. 					PlayerState->ConnectToGameServer(session);
  87. 				}
  88. 			}
  89. 		}
  90. 		return 0;
  91. 	}
  92. 	
  93. 	void TCPClient::CreateNewGameSession(FString sname)
  94. 	{
  95. 		FString serialized = "c|" + sname + "|#";
  96. 		TCHAR *serializedChar = serialized.GetCharArray().GetData();
  97. 		int32 size = FCString::Strlen(serializedChar);
  98. 		int32 sent = 0;
  99. 		bool successful = Socket->Send((uint8*)  TCHAR_TO_UTF8(serializedChar), size, sent);
  100. 		if (successful)
  101. 			UE_LOG(LogTemp, Log, TEXT("MESSAGE SENT!!!!"));
  102. 	}
  103. 	void TCPClient::JoinGameSession(int sID)
  104. 	{
  105. 		FString serialized = "j|" + FString::FromInt(sID) + "|#";
  106. 		TCHAR *serializedChar = serialized.GetCharArray().GetData();
  107. 		int32 size = FCString::Strlen(serializedChar);
  108. 		int32 sent = 0;
  109. 		bool successful = Socket->Send((uint8*)  TCHAR_TO_UTF8(serializedChar), size, sent);
  110. 		if (successful)
  111. 			UE_LOG(LogTemp, Log, TEXT("MESSAGE SENT!!!!"));
  112. 	}