Method custom_initialize

runners/proxy/ProxyRunner.cpp:408–582

}

void ProxyRunner::custom_initialize(td::Promise<td::Unit> promise) {
  kv_ = std::make_shared<td::RocksDb>(td::RocksDb::open(db_path_).move_as_ok());

  std::shared_ptr<RunnerConfig> snapshot_runner_config;
  ton::BlockIdExt sc_init_block_id;

  td::Random::secure_bytes(session_unique_hash_.as_slice());

  {
    td::UniqueSlice value = get_from_db("config");

    if (value.size() > 0) {
      auto obj = cocoon::fetch_tl_object<cocoon_api::proxyDb_Config>(value.as_slice(), true).move_as_ok();

      cocoon_api::downcast_call(
          *obj, td::overloaded(
                    [&](cocoon_api::proxyDb_configEmpty &c) { UNREACHABLE(); },
                    [&](cocoon_api::proxyDb_configV4 &c) {
                      auto conf = RootContractConfig::load_from_tl(*c.root_contract_state_, is_testnet()).move_as_ok();

                      if (conf->version() > runner_config()->root_contract_config->version()) {
                        set_root_contract_config(std::move(conf), c.root_contract_state_block_ts_);
                        snapshot_runner_config = runner_config();
                      } else {
                        snapshot_runner_config = std::make_shared<RunnerConfig>();
                        snapshot_runner_config->root_contract_config = std::move(conf);
                        snapshot_runner_config->root_contract_ts = c.root_contract_state_block_ts_;
                        snapshot_runner_config->is_testnet = runner_config()->is_testnet;
                        snapshot_runner_config->ton_disabled = runner_config()->ton_disabled;
                      }

                      sc_init_block_id = TonScWrapper::block_id_tl_to_obj(*c.sc_block_id_);
                      last_saved_state_seqno_ = c.last_seqno_committed_to_blockchain_;

                      for (auto &e : c.pending_blockchain_seqno_commits_) {
                        CHECK(pending_blockchain_seqno_commits_.emplace(e->seqno_, e->session_hash_).second);
                      }
                    },
                    [&](cocoon_api::proxyDb_configV4Disabled &c) {
                      auto conf = RootContractConfig::load_from_tl(*c.root_contract_state_, is_testnet()).move_as_ok();

                      if (conf->version() > runner_config()->root_contract_config->version()) {
                        set_root_contract_config(std::move(conf), c.root_contract_state_block_ts_);
                        snapshot_runner_config = runner_config();
                      } else {
                        snapshot_runner_config = std::make_shared<RunnerConfig>();
                        snapshot_runner_config->root_contract_config = std::move(conf);
                        snapshot_runner_config->root_contract_ts = c.root_contract_state_block_ts_;
                        snapshot_runner_config->is_testnet = runner_config()->is_testnet;
                        snapshot_runner_config->ton_disabled = runner_config()->ton_disabled;
                      }

                      is_disabled_until_version_ = c.disabled_until_version_;
                    }));

    } else {
      snapshot_runner_config = runner_config();
      config_to_db(snapshot_runner_config);