Method fetchFlow

libminifi/src/c2/C2Agent.cpp:729–771

}

utils::optional<std::string> C2Agent::fetchFlow(const std::string& uri) const {
  if (!utils::StringUtils::startsWith(uri, "http") || protocol_.load() == nullptr) {
    // try to open the file
    utils::optional<std::string> content = filesystem_->read(uri);
    if (content) {
      return content;
    }
  }
  // couldn't open as file and we have no protocol to request the file from
  if (protocol_.load() == nullptr) {
    return {};
  }

  std::string resolved_url = uri;
  if (!utils::StringUtils::startsWith(uri, "http")) {
    std::stringstream adjusted_url;
    std::string base;
    if (configuration_->get(minifi::Configure::nifi_c2_flow_base_url, base)) {
      adjusted_url << base;
      if (!utils::StringUtils::endsWith(base, "/")) {
        adjusted_url << "/";
      }
      adjusted_url << uri;
      resolved_url = adjusted_url.str();
    } else if (configuration_->get("c2.rest.url", base)) {
      std::string host, protocol;
      int port = -1;
      utils::parse_url(&base, &host, &port, &protocol);
      adjusted_url << protocol << host;
      if (port > 0) {
        adjusted_url << ":" << port;
      }
      adjusted_url << "/c2/api/" << uri;
      resolved_url = adjusted_url.str();
    }
  }

  C2Payload payload(Operation::TRANSFER, true);
  C2Payload &&response = protocol_.load()->consumePayload(resolved_url, payload, RECEIVE, false);

  auto raw_data = response.getRawData();
  return std::string(raw_data.data(), raw_data.size());
}

bool C2Agent::handleConfigurationUpdate(const C2ContentResponse &resp) {
  auto url = resp.operation_arguments.find("location");