Files
ReSkate/Extension/Multiplayer/developer_identity_fetch.cpp
T
AyeZeeBB 70128cf2d7 Chat word lists from the backend, and warnings for words not allowed
The bad-word list now comes from the ReSkate backend's Words page, in
the same /api/v1/steam-ids answer the game and servers already read.
It has two lists: filtered words, and words not allowed in chat at
all. Until the backend has any words the built-in list stays in use;
once it does, its lists replace the built-in one.

Filtered words work as before: masked for players with the chat filter
on, and not allowed in server or lobby names. Words not allowed at all
are filtered the same way, and a chat message with one is not passed
on. Its player is warned each time, and after three warnings the next
one gets them kicked.

Dedicated servers: new players setting word_warnings (default 3, 1 to
10, 0 switches the rule off). The count lasts while the server runs,
so a kicked player who joins again is kicked at their next one. Party
chat and commands are checked too, and each warning and kick is logged
under [words]. The lists are read whenever global bans or word
warnings are on.

Player lobbies: the host's game applies the same rule to its guests,
with three warnings.
2026-10-09 21:54:40 -05:00

67 lines
3.0 KiB
C++

#include "developer_identity.h"
#include "word_lists.h"
#include "Engine/Core/Log/logging.h"
#include "Engine/Vfs/https_download.h"
#include <Windows.h>
#include <atomic>
#include <string>
#include <thread>
// The game's way of reading the lists: in the background, driven by the client tick.
namespace dingosdk::multiplayer {
namespace {
constexpr std::uint64_t max_bytes = 256 * 1024, refresh_ms = 10 * 60 * 1000, retry_ms = 60 * 1000;
std::atomic<bool> fetching{};
std::atomic<std::uint64_t> next_fetch{}; // GetTickCount64 time
void fetch() noexcept {
// The log says when the lists arrive, change or stop arriving, not every refresh.
static bool failing{};
bool ok{};
try {
https::Download download;
const auto answer = https::get_text(std::wstring(identity_lists_url.begin(), identity_lists_url.end()), max_bytes, 10,
L"ReSkate-Identity/1", &download);
if (answer) {
auto lists = parse_identity_lists(*answer);
server_tokens_rule = parse_server_tokens_required(*answer);
const auto developers = lists[0].size(), homies = lists[1].size(), creators = lists[2].size(),
bans = lists[static_cast<std::size_t>(IdentityList::banned)].size();
if (publish_identity_lists(std::move(lists)) || failing)
logging::log(logging::Level::info, logging::Channel::runtime,
"Identity lists: {} developer(s), {} homie(s), {} content creator(s), {} banned.", developers,
homies, creators, bans);
// The chat word lists come in the same answer (word_lists.h).
if (const auto words = use_word_lists(*answer); words.changed)
logging::log(logging::Level::info, logging::Channel::runtime,
"Word lists: {} filtered and {} not allowed at all, from the ReSkate backend.", words.filtered,
words.forbidden);
ok = true;
} else if (!failing) {
logging::log(logging::Level::info, logging::Channel::runtime,
"Identity lists unavailable (HTTP {}, error {}); trying again every minute.", download.http_status,
download.error);
}
} catch (const std::exception &e) {
if (!failing)
logging::log(logging::Level::warning, logging::Channel::runtime,
"Identity lists are invalid ({}); trying again every minute.", e.what());
} catch (...) {}
failing = !ok;
// A failure keeps the lists already in use.
next_fetch = GetTickCount64() + (ok ? refresh_ms : retry_ms);
fetching = false;
}
} // namespace
void refresh_identity_lists() noexcept {
if (GetTickCount64() < next_fetch || fetching.exchange(true)) return;
try {
std::thread(fetch).detach();
} catch (...) {
next_fetch = GetTickCount64() + retry_ms;
fetching = false;
}
}
} // namespace dingosdk::multiplayer