1 files changed, 126 insertions, 0 deletions
diff --git a/protocols/Telegram/tdlib/td/td/telegram/ConfigShared.cpp b/protocols/Telegram/tdlib/td/td/telegram/ConfigShared.cpp
new file mode 100644
index 0000000000..637d9fcdbc
--- /dev/null
+++ b/protocols/Telegram/tdlib/td/td/telegram/ConfigShared.cpp
@@ -0,0 +1,126 @@
+//
+// Copyright Aliaksei Levin (levlam@telegram.org), Arseny Smirnov (arseny30@gmail.com) 2014-2018
+//
+// Distributed under the Boost Software License, Version 1.0. (See accompanying
+// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
+//
+#include "td/telegram/ConfigShared.h"
+
+#include "td/telegram/td_api.h"
+
+#include "td/utils/logging.h"
+#include "td/utils/misc.h"
+
+namespace td {
+ConfigShared::ConfigShared(BinlogPmcPtr config_pmc, unique_ptr<Callback> callback)
+    : config_pmc_(config_pmc), callback_(std::move(callback)) {
+  for (auto key_value : config_pmc_->get_all()) {
+    on_option_updated(key_value.first);
+  }
+}
+void ConfigShared::set_option_boolean(Slice name, bool value) {
+  if (set_option(name, value ? Slice("Btrue") : Slice("Bfalse"))) {
+    on_option_updated(name);
+  }
+}
+
+void ConfigShared::set_option_empty(Slice name) {
+  if (set_option(name, Slice())) {
+    on_option_updated(name);
+  }
+}
+
+void ConfigShared::set_option_integer(Slice name, int32 value) {
+  if (set_option(name, PSLICE() << "I" << value)) {
+    on_option_updated(name);
+  }
+}
+
+void ConfigShared::set_option_string(Slice name, Slice value) {
+  if (set_option(name, PSLICE() << "S" << value)) {
+    on_option_updated(name);
+  }
+}
+
+bool ConfigShared::have_option(Slice name) const {
+  return config_pmc_->isset(name.str());
+}
+
+string ConfigShared::get_option(Slice name) const {
+  return config_pmc_->get(name.str());
+}
+
+std::unordered_map<string, string> ConfigShared::get_options(Slice prefix) const {
+  return config_pmc_->prefix_get(prefix);
+}
+
+std::unordered_map<string, string> ConfigShared::get_options() const {
+  return config_pmc_->get_all();
+}
+
+bool ConfigShared::get_option_boolean(Slice name) const {
+  auto value = get_option(name);
+  if (value.empty()) {
+    return false;
+  }
+  if (value == "Btrue") {
+    return true;
+  }
+  if (value == "Bfalse") {
+    return false;
+  }
+  LOG(ERROR) << "Found \"" << value << "\" instead of boolean option";
+  return false;
+}
+
+int32 ConfigShared::get_option_integer(Slice name, int32 default_value) const {
+  auto str_value = get_option(name);
+  if (str_value.empty()) {
+    return default_value;
+  }
+  if (str_value[0] != 'I') {
+    LOG(ERROR) << "Found \"" << str_value << "\" instead of integer option";
+    return default_value;
+  }
+  return to_integer<int32>(str_value.substr(1));
+}
+
+tl_object_ptr<td_api::OptionValue> ConfigShared::get_option_value(Slice value) const {
+  return get_option_value_object(get_option(value));
+}
+
+bool ConfigShared::set_option(Slice name, Slice value) {
+  if (value.empty()) {
+    return config_pmc_->erase(name.str()) != 0;
+  } else {
+    return config_pmc_->set(name.str(), value.str()) != 0;
+  }
+}
+
+tl_object_ptr<td_api::OptionValue> ConfigShared::get_option_value_object(Slice value) {
+  if (value.empty()) {
+    return make_tl_object<td_api::optionValueEmpty>();
+  }
+
+  switch (value[0]) {
+    case 'B':
+      if (value == "Btrue") {
+        return make_tl_object<td_api::optionValueBoolean>(true);
+      }
+      if (value == "Bfalse") {
+        return make_tl_object<td_api::optionValueBoolean>(false);
+      }
+      break;
+    case 'I':
+      return make_tl_object<td_api::optionValueInteger>(to_integer<int32>(value.substr(1)));
+    case 'S':
+      return make_tl_object<td_api::optionValueString>(value.substr(1).str());
+  }
+
+  return make_tl_object<td_api::optionValueString>(value.str());
+}
+
+void ConfigShared::on_option_updated(Slice name) {
+  callback_->on_option_updated(name.str());
+}
+}  // namespace td