Method process_db_key

runners/proxy/ProxyRunner.cpp:678–721

 */

void ProxyRunner::process_db_key(td::Slice key, td::Slice value, std::shared_ptr<RunnerConfig> runner_config) {
  auto key_parts = td::split(key, '_');
  auto key_type = key_parts.first;
  key = key_parts.second;

  CHECK(value.size() >= 64);
  auto signature = value.copy().remove_prefix(value.size() - 64);
  value.remove_suffix(64);

  public_key_obj_->verify_signature(value, signature).ensure();

  if (key_type == "client") {
    block::StdAddress client_owner_address;
    CHECK(rdeserialize(client_owner_address, key));
    auto client_owner_address_str = client_owner_address.rserialize(true);

    auto obj = cocoon::fetch_tl_object<cocoon_api::proxyDb_ClientInfo>(value, true).move_as_ok();

    auto client_info = std::make_shared<ProxyClientInfo>(this, *obj, runner_config);
    CHECK(clients_.emplace(client_owner_address_str, std::move(client_info)).second);
  } else if (key_type == "worker") {
    block::StdAddress worker_owner_address;
    CHECK(rdeserialize(worker_owner_address, key));
    auto worker_owner_address_str = worker_owner_address.rserialize(true);

    auto obj = cocoon::fetch_tl_object<cocoon_api::proxyDb_workerInfo>(value, true).move_as_ok();

    auto worker_info = std::make_shared<ProxyWorkerInfo>(this, *obj, runner_config);
    CHECK(workers_.emplace(worker_owner_address_str, std::move(worker_info)).second);
  } else if (key_type == "config") {
  } else if (key_type == "oldproxycontract") {
    block::StdAddress sc_addr;
    CHECK(rdeserialize(sc_addr, key));

    auto obj = cocoon::fetch_tl_object<cocoon_api::proxyDb_oldInstance>(value, true).move_as_ok();
    auto old_instance = std::make_shared<OldProxyContract>(*obj, this);

    CHECK(old_proxy_contracts_.emplace(sc_addr.rserialize(true), std::move(old_instance)).second);
  } else if (key_type == "oldclient") {
  } else if (key_type == "oldworker") {
  } else {
    LOG(FATAL) << "unknown key type in db: " << key;
  }
}

void ProxyRunner::client_to_db(ProxyClientInfo &client) {
  auto key = PSTRING() << "client_" << client.client_owner_address().rserialize(true);