Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| ab2385fc2f | |||
| 510241e311 | |||
| 5e701e1e1b | |||
| edc4a8b500 | |||
| 7e878a1ac1 | |||
| 5f7ab419b0 | |||
| 38b98bc3ab | |||
| fd0f55bd5e | |||
| 502a35357c | |||
| f3020200a0 |
@@ -13,6 +13,7 @@
|
|||||||
#include <ctime>
|
#include <ctime>
|
||||||
|
|
||||||
#include <processthreadsapi.h>
|
#include <processthreadsapi.h>
|
||||||
|
#include <cstring>
|
||||||
|
|
||||||
std::string randomizeString(size_t length)
|
std::string randomizeString(size_t length)
|
||||||
{
|
{
|
||||||
@@ -133,9 +134,11 @@ bool CertManager::GenerateCA()
|
|||||||
|
|
||||||
Log::info("Generated new CA key and certificate files. Installing to Windows Root CA store automatically...");
|
Log::info("Generated new CA key and certificate files. Installing to Windows Root CA store automatically...");
|
||||||
|
|
||||||
STARTUPINFOA si = {0};
|
STARTUPINFOA si;
|
||||||
|
memset(&si, 0, sizeof(si));
|
||||||
si.cb = sizeof(si);
|
si.cb = sizeof(si);
|
||||||
PROCESS_INFORMATION pi = {0};
|
PROCESS_INFORMATION pi;
|
||||||
|
memset(&pi, 0, sizeof(pi));
|
||||||
char cmd[] = "certutil.exe -user -addstore root ca_cert.pem";
|
char cmd[] = "certutil.exe -user -addstore root ca_cert.pem";
|
||||||
if (CreateProcessA(NULL, cmd, NULL, NULL, FALSE, CREATE_NO_WINDOW, NULL, NULL, &si, &pi))
|
if (CreateProcessA(NULL, cmd, NULL, NULL, FALSE, CREATE_NO_WINDOW, NULL, NULL, &si, &pi))
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -335,6 +335,10 @@ void Proxy::handleClient(SOCKET hClientSocket)
|
|||||||
{
|
{
|
||||||
std::string emptyBody = "";
|
std::string emptyBody = "";
|
||||||
OnClientRequest.run(url, emptyBody, headers);
|
OnClientRequest.run(url, emptyBody, headers);
|
||||||
|
|
||||||
|
if (!pendingUrls.empty())
|
||||||
|
pendingUrls.back() = url;
|
||||||
|
|
||||||
SSL_write(remoteSSL, headers.data(), (int)headers.size());
|
SSL_write(remoteSSL, headers.data(), (int)headers.size());
|
||||||
clientStream.buffer.erase(0, clientStream.headersEnd + 4);
|
clientStream.buffer.erase(0, clientStream.headersEnd + 4);
|
||||||
clientStream.reset();
|
clientStream.reset();
|
||||||
@@ -383,6 +387,9 @@ void Proxy::handleClient(SOCKET hClientSocket)
|
|||||||
if (complete)
|
if (complete)
|
||||||
{
|
{
|
||||||
OnClientRequest.run(url, body, headers);
|
OnClientRequest.run(url, body, headers);
|
||||||
|
if (!pendingUrls.empty() && pendingUrls.back() != url)
|
||||||
|
pendingUrls.back() = url;
|
||||||
|
|
||||||
SSL_write(remoteSSL, headers.data(), (int)headers.size());
|
SSL_write(remoteSSL, headers.data(), (int)headers.size());
|
||||||
SSL_write(remoteSSL, clientStream.buffer.data() + bodyStart,
|
SSL_write(remoteSSL, clientStream.buffer.data() + bodyStart,
|
||||||
(int)(clientStream.buffer.size() - bodyStart));
|
(int)(clientStream.buffer.size() - bodyStart));
|
||||||
@@ -534,10 +541,6 @@ void Proxy::handleClient(SOCKET hClientSocket)
|
|||||||
if (!pendingUrls.empty()) pendingUrls.pop_front();
|
if (!pendingUrls.empty()) pendingUrls.pop_front();
|
||||||
|
|
||||||
std::string respHeaders = serverStream.buffer.substr(0, bStart);
|
std::string respHeaders = serverStream.buffer.substr(0, bStart);
|
||||||
size_t firstSpace = respHeaders.find(' ');
|
|
||||||
int sc =
|
|
||||||
(firstSpace != std::string::npos) ? safe_stoi(respHeaders.substr(firstSpace + 1, 3)) : 0;
|
|
||||||
|
|
||||||
OnServerResponse.run(url, body, respHeaders);
|
OnServerResponse.run(url, body, respHeaders);
|
||||||
|
|
||||||
removeHeader(respHeaders, "Transfer-Encoding");
|
removeHeader(respHeaders, "Transfer-Encoding");
|
||||||
|
|||||||
@@ -25,7 +25,7 @@ class Proxy
|
|||||||
bool Init();
|
bool Init();
|
||||||
void Shutdown();
|
void Shutdown();
|
||||||
|
|
||||||
CallbackEvent<const std::string&, const std::string&, std::string&> OnClientRequest;
|
CallbackEvent<std::string&, const std::string&, std::string&> OnClientRequest;
|
||||||
CallbackEvent<const std::string&, std::string&, std::string&> OnServerResponse;
|
CallbackEvent<const std::string&, std::string&, std::string&> OnServerResponse;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
|
|||||||
@@ -34,10 +34,9 @@ void Spoofer::registerListeners(Proxy* proxy)
|
|||||||
this->serverResponseHandler(url, body, respHeaders);
|
this->serverResponseHandler(url, body, respHeaders);
|
||||||
});
|
});
|
||||||
|
|
||||||
proxy->OnClientRequest.addListener(
|
proxy->OnClientRequest.addListener([this](std::string& url, const std::string& body, std::string& reqHeaders) {
|
||||||
[this](const std::string& url, const std::string& body, std::string& reqHeaders) {
|
this->clientRequestHandler(url, body, reqHeaders);
|
||||||
this->clientRequestHandler(url, body, reqHeaders);
|
});
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void Spoofer::loadData()
|
void Spoofer::loadData()
|
||||||
@@ -217,6 +216,7 @@ void Spoofer::modifyCharacterData(json& js)
|
|||||||
stackableIds.insert(_camperOfferingIds.begin(), _camperOfferingIds.end());
|
stackableIds.insert(_camperOfferingIds.begin(), _camperOfferingIds.end());
|
||||||
stackableIds.insert(_camperAddonIds.begin(), _camperAddonIds.end());
|
stackableIds.insert(_camperAddonIds.begin(), _camperAddonIds.end());
|
||||||
stackableIds.insert(_slasherAddonIds.begin(), _slasherAddonIds.end());
|
stackableIds.insert(_slasherAddonIds.begin(), _slasherAddonIds.end());
|
||||||
|
stackableIds.insert(_slasherOfferingIds.begin(), _slasherOfferingIds.end());
|
||||||
|
|
||||||
if (js.contains("characterItems") && js["characterItems"].is_array())
|
if (js.contains("characterItems") && js["characterItems"].is_array())
|
||||||
{
|
{
|
||||||
@@ -266,7 +266,9 @@ void Spoofer::modifyCharacterData(json& js)
|
|||||||
|
|
||||||
void Spoofer::serverResponseHandler(const std::string& url, std::string& body, std::string& respHeaders)
|
void Spoofer::serverResponseHandler(const std::string& url, std::string& body, std::string& respHeaders)
|
||||||
{
|
{
|
||||||
|
#ifdef _DEBUG
|
||||||
if (url.find("bhvrdbd.com") != std::string::npos) Log::verbose("BHVR api res @ {}", url);
|
if (url.find("bhvrdbd.com") != std::string::npos) Log::verbose("BHVR api res @ {}", url);
|
||||||
|
#endif
|
||||||
|
|
||||||
if (url.find("api/v1/extensions/store/getCatalogItems") != std::string::npos) return parseAndDumpCatalog(body);
|
if (url.find("api/v1/extensions/store/getCatalogItems") != std::string::npos) return parseAndDumpCatalog(body);
|
||||||
|
|
||||||
@@ -382,11 +384,19 @@ void Spoofer::serverResponseHandler(const std::string& url, std::string& body, s
|
|||||||
|
|
||||||
for (auto& charInfo : charList)
|
for (auto& charInfo : charList)
|
||||||
{
|
{
|
||||||
charInfo["isEntitled"] = true;
|
if (charInfo["isEntitled"] == false)
|
||||||
if (charInfo.contains("bloodWebLevel") && charInfo["bloodWebLevel"] <= 1)
|
|
||||||
{
|
{
|
||||||
charInfo["bloodWebLevel"] = 15;
|
charInfo["isEntitled"] = true;
|
||||||
if (charInfo["bloodWebData"].contains("level")) charInfo["bloodWebData"]["level"] = 1;
|
if (charInfo.contains("bloodWebLevel")) charInfo["bloodWebLevel"] = 15;
|
||||||
|
if (charInfo.contains("bloodWebData")) charInfo["bloodWebData"]["level"] = 1;
|
||||||
|
if (charInfo.contains("origin"))
|
||||||
|
{
|
||||||
|
charInfo["purchaseInfo"] = {{"quantity", 1},
|
||||||
|
{"origin", "PlayerInventory"},
|
||||||
|
{"reason", "Item(s) added via Purchase"},
|
||||||
|
{"lastUpdateAt", 1770702482},
|
||||||
|
{"objectId", charInfo["characterName"]}};
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
modifyCharacterData(charInfo);
|
modifyCharacterData(charInfo);
|
||||||
@@ -444,7 +454,7 @@ void Spoofer::serverResponseHandler(const std::string& url, std::string& body, s
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void Spoofer::clientRequestHandler(const std::string& url, const std::string& body, std::string& /*reqHeaders*/)
|
void Spoofer::clientRequestHandler(std::string& url, const std::string& body, std::string& /*reqHeaders*/)
|
||||||
{
|
{
|
||||||
if (url.find("api/v1/dbd-character-data/bloodweb") != std::string::npos ||
|
if (url.find("api/v1/dbd-character-data/bloodweb") != std::string::npos ||
|
||||||
url.find("api/v1/dbd-character-data/bulk-spending-bloodweb") != std::string::npos)
|
url.find("api/v1/dbd-character-data/bulk-spending-bloodweb") != std::string::npos)
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ class Spoofer
|
|||||||
void modifyCharacterData(nlohmann::json& js);
|
void modifyCharacterData(nlohmann::json& js);
|
||||||
|
|
||||||
void serverResponseHandler(const std::string& url, std::string& body, std::string& respHeaders);
|
void serverResponseHandler(const std::string& url, std::string& body, std::string& respHeaders);
|
||||||
void clientRequestHandler(const std::string& url, const std::string& body, std::string& reqHeaders);
|
void clientRequestHandler(std::string& url, const std::string& body, std::string& reqHeaders);
|
||||||
|
|
||||||
std::unordered_set<std::string> _camperItemIds;
|
std::unordered_set<std::string> _camperItemIds;
|
||||||
std::unordered_set<std::string> _slasherPowerIds;
|
std::unordered_set<std::string> _slasherPowerIds;
|
||||||
|
|||||||
Reference in New Issue
Block a user