mirror of
https://github.com/BeamMP/BeamMP-Launcher.git
synced 2026-08-28 13:00:36 +00:00
Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 5db5561a30 | |||
| 626f919df0 | |||
| d38d8ffce3 |
@@ -51,10 +51,6 @@ int KillSocket(uint64_t Dead) {
|
||||
}
|
||||
|
||||
void GameSend(std::string_view Data) {
|
||||
if (!GConnected) {
|
||||
debug("Tried to call GameSend but socket was not connected. Data: " + std::string(Data));
|
||||
return;
|
||||
}
|
||||
static std::mutex Lock;
|
||||
std::scoped_lock Guard(Lock);
|
||||
auto ToSend = Utils::PrependHeader<std::string_view>(Data);
|
||||
@@ -65,6 +61,10 @@ void GameSend(std::string_view Data) {
|
||||
}
|
||||
|
||||
void ServerSend(std::string Data, bool Rel) {
|
||||
if (Data.length() > 1 && Data[0] == 't') {
|
||||
debug("hey");
|
||||
}
|
||||
|
||||
if (Terminate || Data.empty())
|
||||
return;
|
||||
if (Data.find("Zp") != std::string::npos && Data.size() > 500) {
|
||||
@@ -77,7 +77,7 @@ void ServerSend(std::string Data, bool Rel) {
|
||||
C = Data.at(0);
|
||||
if (C == 'O' || C == 'T')
|
||||
Ack = true;
|
||||
if (C == 'N' || C == 'W' || C == 'Y' || C == 'V' || C == 'E' || C == 'C')
|
||||
if (C == 'N' || C == 'W' || C == 'Y' || C == 'V' || C == 'E' || C == 'C' || C == 't')
|
||||
Rel = true;
|
||||
if (compressBound(Data.size()) > 1024)
|
||||
Rel = true;
|
||||
@@ -199,10 +199,13 @@ void ParserAsync(std::string_view Data) {
|
||||
return;
|
||||
case 'U':
|
||||
magic = Data.substr(1);
|
||||
return;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
if (Data.length() > 1 && Data[0] == 't') {
|
||||
debug("omg?");
|
||||
debug(Data.data());
|
||||
}
|
||||
GameSend(Data);
|
||||
}
|
||||
void ServerParser(std::string_view Data) {
|
||||
|
||||
@@ -163,12 +163,7 @@ std::vector<char> TCPRcvRaw(SOCKET Sock, uint64_t& GRcv, uint64_t Size) {
|
||||
int i = 0;
|
||||
do {
|
||||
// receive at most some MB at a time
|
||||
uint64_t Len = std::min<uint64_t>((Size - Rcv), 1 * 1024 * 1024);
|
||||
if (Len == 0) {
|
||||
error("Download size miscalculation");
|
||||
break;
|
||||
}
|
||||
|
||||
int Len = std::min(int(Size - Rcv), 1 * 1024 * 1024);
|
||||
int Temp = RecvWaitAll(Sock, &File[Rcv], Len);
|
||||
if (Temp == -1 || Temp == 0) {
|
||||
debug("Recv returned: " + std::to_string(Temp));
|
||||
@@ -307,7 +302,7 @@ void InvalidResource(const std::string& File) {
|
||||
}
|
||||
|
||||
struct ModInfo {
|
||||
static std::optional<std::pair<bool, std::vector<ModInfo>>> ParseModInfosFromPacket(const std::string& packet) {
|
||||
static std::pair<bool, std::vector<ModInfo>> ParseModInfosFromPacket(const std::string& packet) {
|
||||
bool success = false;
|
||||
std::vector<ModInfo> modInfos;
|
||||
try {
|
||||
@@ -328,12 +323,6 @@ struct ModInfo {
|
||||
modInfo.Protected = entry["protected"];
|
||||
}
|
||||
|
||||
if (auto fsFile = std::filesystem::path(modInfo.FileName);
|
||||
!fsFile.has_filename() || fsFile.filename().string() != modInfo.FileName ||
|
||||
!fsFile.filename().has_extension() || fsFile.filename().extension() != ".zip"){
|
||||
return std::nullopt;
|
||||
}
|
||||
|
||||
modInfos.push_back(modInfo);
|
||||
success = true;
|
||||
}
|
||||
@@ -589,17 +578,8 @@ void NewSyncResources(SOCKET Sock, const std::string& Mods, const std::vector<Mo
|
||||
c = ::tolower(c);
|
||||
}
|
||||
#endif
|
||||
auto name = std::filesystem::path(GetGamePath()) / "mods/multiplayer" / FName;
|
||||
auto tmp_name = name;
|
||||
tmp_name += ".tmp";
|
||||
|
||||
std::error_code ec;
|
||||
fs::copy_file(PathToSaveTo, tmp_name, fs::copy_options::overwrite_existing, ec);
|
||||
if (ec) {
|
||||
error(beammp_wide("Error in copy_file during download of ") + beammp_fs_string(PathToSaveTo) + beammp_wide(": ") + Utils::ToWString(ec.message()));
|
||||
break;
|
||||
}
|
||||
fs::rename(tmp_name, name);
|
||||
fs::copy_file(PathToSaveTo, std::filesystem::path(GetGamePath()) / "mods/multiplayer" / FName, fs::copy_options::overwrite_existing);
|
||||
UpdateModUsage(FName);
|
||||
}
|
||||
WaitForConfirm();
|
||||
@@ -622,13 +602,7 @@ void SyncResources(SOCKET Sock) {
|
||||
if (Ret.starts_with("R")) {
|
||||
debug("This server is likely outdated, not trying to parse new mod info format");
|
||||
} else {
|
||||
auto ParsedInfo = ModInfo::ParseModInfosFromPacket(Ret);
|
||||
if (!ParsedInfo.has_value()) {
|
||||
error("Invalid mod info");
|
||||
Terminate = true;
|
||||
return;
|
||||
}
|
||||
auto [success, modInfo] = ParsedInfo.value();
|
||||
auto [success, modInfo] = ModInfo::ParseModInfosFromPacket(Ret);
|
||||
|
||||
if (success) {
|
||||
NewSyncResources(Sock, Ret, modInfo);
|
||||
@@ -764,12 +738,7 @@ void SyncResources(SOCKET Sock) {
|
||||
}
|
||||
#endif
|
||||
|
||||
auto name = GetGamePath() / beammp_wide("mods/multiplayer") / Utils::ToWString(FName);
|
||||
auto tmp_name = name;
|
||||
tmp_name += L".tmp";
|
||||
|
||||
fs::copy_file(PathToSaveTo, tmp_name, fs::copy_options::overwrite_existing);
|
||||
fs::rename(tmp_name, name);
|
||||
fs::copy_file(PathToSaveTo, GetGamePath() / beammp_wide("mods/multiplayer") / Utils::ToWString(FName), fs::copy_options::overwrite_existing);
|
||||
UpdateModUsage(FN->substr(pos));
|
||||
}
|
||||
WaitForConfirm();
|
||||
|
||||
+1
-1
@@ -86,7 +86,7 @@ std::string GetVer() {
|
||||
return "2.8";
|
||||
}
|
||||
std::string GetPatch() {
|
||||
return ".1";
|
||||
return ".0";
|
||||
}
|
||||
|
||||
beammp_fs_string GetEP(const beammp_fs_char* P) {
|
||||
|
||||
Reference in New Issue
Block a user