Method putFile

extensions/standard-processors/processors/PutFile.cpp:206–273

}

bool PutFile::putFile(core::ProcessSession *session, std::shared_ptr<core::FlowFile> flowFile, const std::string &tmpFile, const std::string &destFile, const std::string &destDir) {
  struct stat dir_stat;

  if (stat(destDir.c_str(), &dir_stat) && try_mkdirs_) {
    // Attempt to create directories in file's path
    std::stringstream dir_path_stream;

    logger_->log_debug("Destination directory does not exist; will attempt to create: ", destDir);
    size_t i = 0;
    auto pos = destFile.find(utils::file::FileUtils::get_separator());

    while (pos != std::string::npos) {
      auto dir_path_component = destFile.substr(i, pos - i);
      dir_path_stream << dir_path_component;
      auto dir_path = dir_path_stream.str();

      if (!dir_path_component.empty()) {
        logger_->log_debug("Attempting to create directory if it does not already exist: %s", dir_path);
        if (!utils::file::FileUtils::exists(dir_path)) {
          utils::file::FileUtils::create_dir(dir_path, false);
#ifndef WIN32
          if (directory_permissions_.valid()) {
            utils::file::FileUtils::set_permissions(dir_path, directory_permissions_.getValue());
          }
#endif
        }

        dir_path_stream << utils::file::FileUtils::get_separator();
      } else if (pos == 0) {
        // Support absolute paths
        dir_path_stream << utils::file::FileUtils::get_separator();
      }

      i = pos + 1;
      pos = destFile.find(utils::file::FileUtils::get_separator(), pos + 1);
    }
  }

  bool success = false;

  if (flowFile->getSize() > 0) {
    ReadCallback cb(tmpFile, destFile);
    session->read(flowFile, &cb);
    logger_->log_debug("Committing %s", destFile);
    success = cb.commit();
  } else {
    std::ofstream outfile(destFile, std::ios::out | std::ios::binary);
    if (!outfile.good()) {
      logger_->log_error("Failed to create empty file: %s", destFile);
    } else {
      success = true;
    }
  }

#ifndef WIN32
  if (permissions_.valid()) {
    utils::file::FileUtils::set_permissions(destFile, permissions_.getValue());
  }