mirror of
https://github.com/BeamMP/BeamMP-Launcher.git
synced 2026-08-27 12:41:32 +00:00
Compare commits
10 Commits
add-region-tld
...
v2.8.1
| Author | SHA1 | Date | |
|---|---|---|---|
| a9faac25fc | |||
| f532e58ee0 | |||
| 8b4fefd518 | |||
| 5fc8f580f4 | |||
| 6334a0a915 | |||
| 44211e7235 | |||
| 901b7df809 | |||
| a6e3db6b08 | |||
| eeca50b37e | |||
| 2a92a08587 |
@@ -51,6 +51,10 @@ 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);
|
||||
@@ -195,6 +199,7 @@ void ParserAsync(std::string_view Data) {
|
||||
return;
|
||||
case 'U':
|
||||
magic = Data.substr(1);
|
||||
return;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
@@ -163,7 +163,12 @@ std::vector<char> TCPRcvRaw(SOCKET Sock, uint64_t& GRcv, uint64_t Size) {
|
||||
int i = 0;
|
||||
do {
|
||||
// receive at most some MB at a time
|
||||
int Len = std::min(int(Size - Rcv), 1 * 1024 * 1024);
|
||||
uint64_t Len = std::min<uint64_t>((Size - Rcv), 1 * 1024 * 1024);
|
||||
if (Len == 0) {
|
||||
error("Download size miscalculation");
|
||||
break;
|
||||
}
|
||||
|
||||
int Temp = RecvWaitAll(Sock, &File[Rcv], Len);
|
||||
if (Temp == -1 || Temp == 0) {
|
||||
debug("Recv returned: " + std::to_string(Temp));
|
||||
@@ -302,7 +307,7 @@ void InvalidResource(const std::string& File) {
|
||||
}
|
||||
|
||||
struct ModInfo {
|
||||
static std::pair<bool, std::vector<ModInfo>> ParseModInfosFromPacket(const std::string& packet) {
|
||||
static std::optional<std::pair<bool, std::vector<ModInfo>>> ParseModInfosFromPacket(const std::string& packet) {
|
||||
bool success = false;
|
||||
std::vector<ModInfo> modInfos;
|
||||
try {
|
||||
@@ -323,6 +328,12 @@ 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;
|
||||
}
|
||||
@@ -578,8 +589,17 @@ 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";
|
||||
|
||||
fs::copy_file(PathToSaveTo, std::filesystem::path(GetGamePath()) / "mods/multiplayer" / FName, fs::copy_options::overwrite_existing);
|
||||
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);
|
||||
UpdateModUsage(FName);
|
||||
}
|
||||
WaitForConfirm();
|
||||
@@ -602,7 +622,13 @@ 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 [success, modInfo] = ModInfo::ParseModInfosFromPacket(Ret);
|
||||
auto ParsedInfo = ModInfo::ParseModInfosFromPacket(Ret);
|
||||
if (!ParsedInfo.has_value()) {
|
||||
error("Invalid mod info");
|
||||
Terminate = true;
|
||||
return;
|
||||
}
|
||||
auto [success, modInfo] = ParsedInfo.value();
|
||||
|
||||
if (success) {
|
||||
NewSyncResources(Sock, Ret, modInfo);
|
||||
@@ -738,7 +764,12 @@ void SyncResources(SOCKET Sock) {
|
||||
}
|
||||
#endif
|
||||
|
||||
fs::copy_file(PathToSaveTo, GetGamePath() / beammp_wide("mods/multiplayer") / Utils::ToWString(FName), fs::copy_options::overwrite_existing);
|
||||
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);
|
||||
UpdateModUsage(FN->substr(pos));
|
||||
}
|
||||
WaitForConfirm();
|
||||
|
||||
+1
-1
@@ -86,7 +86,7 @@ std::string GetVer() {
|
||||
return "2.8";
|
||||
}
|
||||
std::string GetPatch() {
|
||||
return ".0";
|
||||
return ".1";
|
||||
}
|
||||
|
||||
beammp_fs_string GetEP(const beammp_fs_char* P) {
|
||||
|
||||
Reference in New Issue
Block a user