Function handleReadFile

src/client/cli/admin/ReadFile.cc:38–127

}

CoTryTask<Dispatcher::OutputTable> handleReadFile(IEnv &ienv,
                                                  const argparse::ArgumentParser &parser,
                                                  const Dispatcher::Args &args) {
  [[maybe_unused]] auto &env = dynamic_cast<AdminEnv &>(ienv);
  ENSURE_USAGE(args.empty());
  Dispatcher::OutputTable table;

  // 1. parse arguments.
  Path src = parser.get<std::string>("path");
  auto stat = parser.get<bool>("--stat");
  auto enableChecksum = !parser.get<bool>("--disableChecksum");
  auto fillZero = parser.get<bool>("--fillZero");
  auto verbose = parser.get<bool>("--verbose");
  auto output = parser.present<std::string>("--output");
  auto hex = parser.get<bool>("--hex");

  size_t offset = 0;
  if (auto o = parser.present("--offset")) {
    auto offsetResult = Size::from(*o);
    CO_RETURN_AND_LOG_ON_ERROR(offsetResult);
    offset = *offsetResult;
  }
  std::optional<size_t> lengthIn;
  if (auto l = parser.present<std::string>("--length")) {
    auto lengthResult = Size::from(*l);
    CO_RETURN_AND_LOG_ON_ERROR(lengthResult);
    lengthIn = *lengthResult;
  }
  storage::client::TargetSelectionMode mode = storage::client::TargetSelectionMode::Default;
  uint32_t targetIndex = 0;
  if (auto m = parser.present("--mode")) {
    auto result = magic_enum::enum_cast<storage::client::TargetSelectionMode>(*m);
    if (result) {
      mode = *result;
    } else if (auto idx = scn::scan_value<uint32_t>(*m)) {
      mode = storage::client::TargetSelectionMode::ManualMode;
      targetIndex = idx.value();
    } else {
      co_return makeError(StatusCode::kInvalidArg, fmt::format("invalid mode", *m));
    }
  }

  // 2. refresh routing info.
  CO_RETURN_AND_LOG_ON_ERROR(co_await env.mgmtdClientGetter()->refreshRoutingInfo(true));
  auto routingInfo = env.mgmtdClientGetter()->getRoutingInfo()->raw();
  if (routingInfo == nullptr) {
    co_return makeError(StorageClientCode::kRoutingError, "routing info is null");
  }

  // 3. open file.
  auto openResult = co_await FileWrapper::openOrCreateFile(env, src);
  CO_RETURN_AND_LOG_ON_ERROR(openResult);
  auto &file = *openResult;

  // 4. calc chain and chunk id.
  if (file.length() <= offset) {
    co_return makeError(StatusCode::kInvalidArg, fmt::format("offset {} exceed file length {}", offset, file.length()));
  }