Untitled

#include "httplib.hpp"
#include "json.hpp"
#include <future>
#include <filesystem>
using namespace std;
httplib::SSLServer server("cert.pem", "key.pem");
vector<thread> backtasks;
string server_ip = "45.87.173.220";
int server_port = 17091;
string server_data = "server|"+ server_ip + "\nport|"+ to_string(server_port) + "\ntype|1\nmeta|cmeta\nRTENDMARKERBS1001";

const char* gov =
R"(<style>h1 { text-align: center; }
</style>
<body>
<h1><b><big>Unauthorized Access</big></b></h1>
</body>)";
class connection {
public:
	string ip = "";
	int attempts = 0;
}; map<string, connection> connection_data;

void SaveConnectionData(connection data, string ip) {
	nlohmann::json j;
	ofstream w("logged/" + ip);
	j.dump(1);
	j["ip"] = data.ip;
	j["attempts"] = data.attempts;
	w << setw(2) << j;
}
connection LoadConnectionData(string ip) {
	nlohmann::json j;
	ifstream r("logged/" + ip); r >> j;
	connection data;
	data.ip = j["ip"];
	data.attempts = j["attempts"];
	return data;
}
void append_reset(string ip) {
	while (true) {
		for (auto it = connection_data.begin(); it not_eq connection_data.end(); ++it)
			if (it->first == ip)
				if (it->second.attempts > 3) {
					this_thread::sleep_for(4s);
					it->second.attempts -= 3;
					connection data = LoadConnectionData(ip);
					data.attempts = it->second.attempts;
					SaveConnectionData(data, it->second.ip);
				}
				else {
					if (it->second.attempts <= 0) continue; // skip
					this_thread::sleep_for(1800ms);
					it->second.attempts -= 1;
					connection data = LoadConnectionData(ip);
					data.attempts = it->second.attempts;
					SaveConnectionData(data, it->second.ip);
				}
		this_thread::sleep_for(5ms);
	}
}
bool request(const httplib::Request req)
{
	ifstream r("logged/" + req.remote_addr);
	if (not r.is_open()) {
		connection new_data;
		new_data.ip = req.remote_addr;
		new_data.attempts = 1;
		SaveConnectionData(new_data, req.remote_addr);
		connection_data.emplace(req.remote_addr, new_data);
	}
	else for (auto it = connection_data.begin(); it not_eq connection_data.end(); ++it) if (it->first == req.remote_addr)
	{
		it->second.attempts++;
		if (it->second.attempts > 3) {
			backtasks.emplace_back(append_reset, req.remote_addr);
			return false;
		}
		connection data = LoadConnectionData(req.remote_addr);
		data.attempts = it->second.attempts;
		SaveConnectionData(data, it->second.ip);
	}
	return true;
}
int main()
{
	cout << "Growtopia HTTPS developed by Ametsa77" << endl;
	for (const auto& i : filesystem::directory_iterator("logged/")) {
		if (i.path().filename().string() == "tmp" or filesystem::is_directory(i.path())) continue;
		connection_data.emplace(i.path().filename().string(), LoadConnectionData(i.path().filename().string()));
	}
	server.Post(("/growtopia/server_data.php"), [&](const auto& req, auto& res) {
		future<bool> Request = async(request, req); Request.wait();
	if (not Request.get()) {
		SetConsoleTextAttribute(GetStdHandle(STD_OUTPUT_HANDLE), 12);
		cout << req.remote_addr << " has blocked due to attack suspicion" << endl;
		SetConsoleTextAttribute(GetStdHandle(STD_OUTPUT_HANDLE), 7);
		return;
	}
	SetConsoleTextAttribute(GetStdHandle(STD_OUTPUT_HANDLE), 10);
	cout << req.remote_addr << " has connected to server" << endl;
	SetConsoleTextAttribute(GetStdHandle(STD_OUTPUT_HANDLE), 7);
	res.set_content(server_data, "text/plain");
		});
	server.Get(("/growtopia/server_data.php"), [&](const auto& req, auto& res) { res.set_content(gov, "text/html"); });
	server.listen("0.0.0.0", 443);
	return 0;
}
Editor is loading...