Make account sync hooks config-aware

src/AccountSync.hh

@@ -5,18 +5,79 @@
 #include <cstdio>
 #include <string>
 
+#include <phosg/JSON.hh>
+
 namespace AccountSync {
 
+struct Config {
+  bool enabled = false;
+  std::string region;
+  std::string coordinator_url;
+  std::string shared_secret;
+  uint64_t request_timeout_usecs = 3000000;
+  bool fail_open = false;
+  bool notify_account_saves = true;
+  bool notify_player_saves = true;
+  bool notify_backup_saves = true;
+  bool enable_login_locks = false;
+};
+
+inline Config& mutable_config() {
+  static Config cfg;
+  return cfg;
+}
+
+inline const Config& config() {
+  return mutable_config();
+}
+
+inline void configure(const Config& cfg) {
+  mutable_config() = cfg;
+
+  if (cfg.enabled) {
+    std::fprintf(stderr,
+        "[AccountSync] config enabled region=%s coordinator_url=%s login_locks=%s\n",
+        cfg.region.c_str(),
+        cfg.coordinator_url.c_str(),
+        cfg.enable_login_locks ? "true" : "false");
+  }
+}
+
+inline void configure_from_json(const phosg::JSON& json) {
+  Config cfg;
+  cfg.enabled = json.get_bool("Enabled", false);
+  cfg.region = json.get_string("Region", "");
+  cfg.coordinator_url = json.get_string("CoordinatorURL", "");
+  cfg.shared_secret = json.get_string("SharedSecret", "");
+  cfg.request_timeout_usecs = json.get_int("RequestTimeoutUsecs", 3000000);
+  cfg.fail_open = json.get_bool("FailOpen", false);
+  cfg.notify_account_saves = json.get_bool("NotifyAccountSaves", true);
+  cfg.notify_player_saves = json.get_bool("NotifyPlayerSaves", true);
+  cfg.notify_backup_saves = json.get_bool("NotifyBackupSaves", true);
+  cfg.enable_login_locks = json.get_bool("EnableLoginLocks", false);
+  configure(cfg);
+}
+
 inline void notify_account_saved(uint32_t account_id, const std::string& filename) {
+  const auto& cfg = config();
+  if (!cfg.enabled || !cfg.notify_account_saves) {
+    return;
+  }
   std::fprintf(stderr,
-      "[AccountSync] event=account_saved account_id=%010u filename=%s\n",
+      "[AccountSync] event=account_saved region=%s account_id=%010u filename=%s\n",
+      cfg.region.c_str(),
       static_cast<unsigned int>(account_id),
       filename.c_str());
 }
 
 inline void notify_backup_saved(uint32_t account_id, size_t slot, const std::string& filename) {
+  const auto& cfg = config();
+  if (!cfg.enabled || !cfg.notify_backup_saves) {
+    return;
+  }
   std::fprintf(stderr,
-      "[AccountSync] event=backup_saved account_id=%010u slot=%zu filename=%s\n",
+      "[AccountSync] event=backup_saved region=%s account_id=%010u slot=%zu filename=%s\n",
+      cfg.region.c_str(),
       static_cast<unsigned int>(account_id),
       slot,
       filename.c_str());
@@ -27,8 +88,13 @@ inline void notify_player_state_saved(
     uint32_t account_id,
     const std::string& bb_username,
     const std::string& filename) {
+  const auto& cfg = config();
+  if (!cfg.enabled || !cfg.notify_player_saves) {
+    return;
+  }
   std::fprintf(stderr,
-      "[AccountSync] event=player_state_saved reason=%s account_id=%010u bb_username=%s filename=%s\n",
+      "[AccountSync] event=player_state_saved region=%s reason=%s account_id=%010u bb_username=%s filename=%s\n",
+      cfg.region.c_str(),
       reason,
       static_cast<unsigned int>(account_id),
       bb_username.c_str(),
@@ -40,8 +106,13 @@ inline void notify_bb_login_start(
     const std::string& bb_username,
     int64_t character_slot,
     uint8_t connection_phase) {
+  const auto& cfg = config();
+  if (!cfg.enabled || !cfg.enable_login_locks) {
+    return;
+  }
   std::fprintf(stderr,
-      "[AccountSync] event=bb_login_start account_id=%010u bb_username=%s character_slot=%lld connection_phase=%u\n",
+      "[AccountSync] event=bb_login_start region=%s account_id=%010u bb_username=%s character_slot=%lld connection_phase=%u\n",
+      cfg.region.c_str(),
       static_cast<unsigned int>(account_id),
       bb_username.c_str(),
       static_cast<long long>(character_slot),
@@ -52,8 +123,13 @@ inline void notify_bb_login_end(
     uint32_t account_id,
     const std::string& bb_username,
     int64_t character_slot) {
+  const auto& cfg = config();
+  if (!cfg.enabled || !cfg.enable_login_locks) {
+    return;
+  }
   std::fprintf(stderr,
-      "[AccountSync] event=bb_login_end account_id=%010u bb_username=%s character_slot=%lld\n",
+      "[AccountSync] event=bb_login_end region=%s account_id=%010u bb_username=%s character_slot=%lld\n",
+      cfg.region.c_str(),
       static_cast<unsigned int>(account_id),
       bb_username.c_str(),
       static_cast<long long>(character_slot));

src/ServerState.cc

@@ -18,6 +18,7 @@
 #include "SendCommands.hh"
 #include "Text.hh"
 #include "TextIndex.hh"
+#include "AccountSync.hh"
 
 #ifdef PHOSG_WINDOWS
 static constexpr bool IS_WINDOWS = true;
@@ -879,6 +880,7 @@ void ServerState::load_config_early() {
   this->client_ping_interval_usecs = this->config_json->get_int("ClientPingInterval", 30000000);
   this->client_idle_timeout_usecs = this->config_json->get_int("ClientIdleTimeout", 60000000);
   this->patch_client_idle_timeout_usecs = this->config_json->get_int("PatchClientIdleTimeout", 300000000);
+  AccountSync::configure_from_json(this->config_json->get("AccountSync", phosg::JSON::dict()));
   this->psopeeps_dcv2_exp_multiplier = this->config_json->get_int("PsoPeepsDCV2EXPMultiplier", 5);
   if ((this->psopeeps_dcv2_exp_multiplier != 5) && (this->psopeeps_dcv2_exp_multiplier != 10)) {
     throw std::runtime_error("PsoPeepsDCV2EXPMultiplier must be 5 or 10");