fgerlits commented on a change in pull request #1257:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1257#discussion_r802686280
##########
File path: extensions/standard-processors/processors/TailFile.cpp
##########
@@ -846,7 +874,28 @@ void TailFile::checkForNewFiles() {
return true;
};
- utils::file::list_dir(base_dir_, add_new_files_callback, logger_,
recursive_lookup_);
+ if (attribute_provider_service_) {
+ for (const auto& base_dir : getBaseDirectories(context)) {
+ utils::file::list_dir(base_dir, add_new_files_callback, logger_,
recursive_lookup_);
+ }
+ } else {
+ utils::file::list_dir(base_dir_, add_new_files_callback, logger_,
recursive_lookup_);
+ }
+}
+
+std::vector<std::string> TailFile::getBaseDirectories(core::ProcessContext&
context) const {
+ gsl_Expects(attribute_provider_service_);
+
+ const auto attribute_maps = attribute_provider_service_->getAttributes();
+ return attribute_maps |
+ ranges::views::transform([&context](const auto& attribute_map) {
+ auto flow_file = std::make_shared<FlowFileRecord>();
+ for (const auto& [key, value] : attribute_map) {
+ flow_file->setAttribute(key, value);
+ }
+ return context.getProperty(BaseDirectory, flow_file).value();
Review comment:
This function is only used (and really only makes sense) in `Multiple
file` mode, when `BaseDirectory` is a required property: `onSchedule()` will
throw if it is not set.
Whether the property exists or not does not depend on the attributes, only
the resolved value of the property does.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
