This is an automated email from the ASF dual-hosted git repository.
fgerlits pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from 73ccd5eef MINIFICPP-2223 Add .asf.yaml file to configure repository
labels
new 1dfab222d MINIFICPP-1774 Set properties from command line arguments
new 9ec2010a0 MINIFICPP-2193 - Add manifest to debug bundle
new 4780b541b MINIFICPP-2218 Refactor expected monadic functions
new 1bf566ca8 MINIFICPP-2146 Add support for SMB networking protocol
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CMakeLists.txt | 9 +-
CPPLINT.cfg | 2 +-
LICENSE | 32 +-
NOTICE | 1 +
PROCESSORS.md | 100 +++++
README.md | 1 +
cmake/{Catch2.cmake => ArgParse.cmake} | 12 +-
cmake/CxxOpts.cmake | 33 --
cmake/MiNiFiOptions.cmake | 1 +
controller/CMakeLists.txt | 6 +-
controller/MiNiFiController.cpp | 140 +++---
encrypt-config/ArgParser.cpp | 164 -------
encrypt-config/ArgParser.h | 74 ----
encrypt-config/CMakeLists.txt | 3 +-
encrypt-config/CommandException.h | 36 --
encrypt-config/EncryptConfigMain.cpp | 33 +-
extensions/ExtensionHeader.txt | 2 +-
extensions/aws/processors/FetchS3Object.cpp | 2 +-
extensions/aws/s3/S3Wrapper.cpp | 10 +-
extensions/bustache/tests/ApplyTemplateTests.cpp | 144 ++++---
extensions/expression-language/Expression.cpp | 4 +-
.../tests/ExpressionLanguageTests.cpp | 2 +-
extensions/http-curl/processors/InvokeHTTP.cpp | 10 +-
extensions/http-curl/tests/C2DebugBundleTest.cpp | 5 +-
extensions/http-curl/tests/unit/AlertTests.cpp | 2 +-
.../mqtt/processors/AbstractMQTTProcessor.cpp | 6 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 12 +-
extensions/mqtt/processors/PublishMQTT.cpp | 4 +-
extensions/python/ExecutePythonProcessor.h | 2 +-
.../python/tests/ExecutePythonProcessorTests.cpp | 1 -
.../rocksdb-repos/DatabaseContentRepository.cpp | 8 +-
extensions/rocksdb-repos/RocksDbRepository.cpp | 8 +-
extensions/sftp/processors/ListSFTP.cpp | 2 +-
extensions/sftp/tests/FetchSFTPTests.cpp | 2 +-
extensions/sftp/tests/ListSFTPTests.cpp | 2 +-
extensions/sftp/tests/ListThenFetchSFTPTests.cpp | 4 +-
extensions/sftp/tests/PutSFTPTests.cpp | 2 +-
extensions/{pdh => smb}/CMakeLists.txt | 12 +-
extensions/smb/FetchSmb.cpp | 73 ++++
extensions/smb/FetchSmb.h | 89 ++++
extensions/smb/ListSmb.cpp | 144 +++++++
.../processors/ListFile.h => smb/ListSmb.h} | 119 +++---
extensions/smb/PutSmb.cpp | 94 ++++
extensions/smb/PutSmb.h | 94 ++++
extensions/smb/SmbConnectionControllerService.cpp | 121 ++++++
extensions/smb/SmbConnectionControllerService.h | 103 +++++
extensions/{pdh => smb}/tests/CMakeLists.txt | 16 +-
extensions/smb/tests/FetchSmbTests.cpp | 108 +++++
extensions/smb/tests/ListAndFetchSmbTests.cpp | 72 ++++
extensions/smb/tests/ListSmbTests.cpp | 146 +++++++
extensions/smb/tests/PutSmbTests.cpp | 184 ++++++++
.../tests/SmbConnectionControllerServiceTests.cpp | 71 ++++
.../utils/MockSmbConnectionControllerService.h | 106 +++++
extensions/smb/tests/utils/TempSmbShare.h | 76 ++++
.../processors/DefragmentText.cpp | 2 +-
.../standard-processors/processors/FetchFile.cpp | 6 +-
.../standard-processors/processors/GetFile.cpp | 2 +-
.../standard-processors/processors/ListFile.cpp | 137 ++----
.../standard-processors/processors/ListFile.h | 25 +-
.../standard-processors/processors/PutFile.cpp | 220 +++-------
.../standard-processors/processors/PutFile.h | 55 +--
.../standard-processors/processors/PutUDP.cpp | 4 +-
.../standard-processors/processors/RouteText.cpp | 2 +-
.../tests/unit/PutFileTests.cpp | 12 -
extensions/systemd/ConsumeJournald.cpp | 14 +-
.../CollectorInitiatedSubscription.cpp | 2 +-
.../windows-event-log/wel/MetadataWalker.cpp | 4 -
libminifi/CMakeLists.txt | 6 +-
libminifi/include/DiskSpaceWatchdog.h | 16 +-
libminifi/include/EventDrivenSchedulingAgent.h | 2 +-
libminifi/include/SchedulingAgent.h | 2 +-
libminifi/include/c2/triggers/FileUpdateTrigger.h | 6 +-
libminifi/include/core/logging/Logger.h | 11 +
.../include/core/logging/LoggerConfiguration.h | 2 +-
libminifi/include/properties/Decryptor.h | 2 +-
libminifi/include/utils/LogUtils.h | 6 +
libminifi/include/utils/OptionalUtils.h | 10 +-
libminifi/include/utils/OsUtils.h | 4 +
.../utils/detail/MonadicOperationWrappers.h | 16 +-
libminifi/include/utils/expected.h | 124 +++---
.../include/utils/{ => file}/FileReaderCallback.h | 0
libminifi/include/utils/file/FileUtils.h | 29 +-
.../utils/{Hash.h => file/FileWriterCallback.h} | 23 +-
libminifi/include/utils/file/ListedFile.h | 104 +++++
libminifi/src/DiskSpaceWatchdog.cpp | 17 +-
libminifi/src/RootProcessGroupWrapper.cpp | 4 +-
libminifi/src/c2/C2Agent.cpp | 25 +-
libminifi/src/c2/C2MetricsPublisher.cpp | 2 +-
libminifi/src/c2/triggers/FileUpdateTrigger.cpp | 4 +-
libminifi/src/core/FlowConfiguration.cpp | 2 +-
libminifi/src/core/logging/Logger.cpp | 2 +-
libminifi/src/utils/NetworkInterfaceInfo.cpp | 18 +-
libminifi/src/utils/OsUtils.cpp | 48 ++-
libminifi/src/utils/crypto/EncryptionManager.cpp | 4 +-
libminifi/src/utils/crypto/EncryptionProvider.cpp | 2 +-
.../src/utils/{ => file}/FileReaderCallback.cpp | 2 +-
libminifi/src/utils/file/FileUtils.cpp | 27 +-
libminifi/src/utils/file/FileWriterCallback.cpp | 66 +++
libminifi/test/Utils.h | 2 +-
libminifi/test/archive-tests/FocusArchiveTests.cpp | 113 ++---
.../test/archive-tests/ManipulateArchiveTests.cpp | 472 +++++++++++----------
libminifi/test/integration/IntegrationBase.h | 2 +-
libminifi/test/unit/ExpectedTest.cpp | 155 ++++---
libminifi/test/unit/OptionalTest.cpp | 14 +-
libminifi/test/unit/OsUtilTests.cpp | 20 +
libminifi/test/unit/TimeUtilTests.cpp | 24 ++
minifi_main/CMakeLists.txt | 6 +-
minifi_main/MiNiFiMain.cpp | 150 ++++---
nanofi/CMakeLists.txt | 2 +-
nanofi/ecu/CMakeLists.txt | 2 +-
nanofi/examples/CMakeLists.txt | 2 +-
run_clang_tidy.sh | 2 +-
win_build_vs.bat | 6 +-
113 files changed, 3024 insertions(+), 1528 deletions(-)
copy cmake/{Catch2.cmake => ArgParse.cmake} (78%)
delete mode 100644 cmake/CxxOpts.cmake
delete mode 100644 encrypt-config/ArgParser.cpp
delete mode 100644 encrypt-config/ArgParser.h
delete mode 100644 encrypt-config/CommandException.h
copy extensions/{pdh => smb}/CMakeLists.txt (69%)
create mode 100644 extensions/smb/FetchSmb.cpp
create mode 100644 extensions/smb/FetchSmb.h
create mode 100644 extensions/smb/ListSmb.cpp
copy extensions/{standard-processors/processors/ListFile.h => smb/ListSmb.h}
(60%)
create mode 100644 extensions/smb/PutSmb.cpp
create mode 100644 extensions/smb/PutSmb.h
create mode 100644 extensions/smb/SmbConnectionControllerService.cpp
create mode 100644 extensions/smb/SmbConnectionControllerService.h
copy extensions/{pdh => smb}/tests/CMakeLists.txt (82%)
create mode 100644 extensions/smb/tests/FetchSmbTests.cpp
create mode 100644 extensions/smb/tests/ListAndFetchSmbTests.cpp
create mode 100644 extensions/smb/tests/ListSmbTests.cpp
create mode 100644 extensions/smb/tests/PutSmbTests.cpp
create mode 100644 extensions/smb/tests/SmbConnectionControllerServiceTests.cpp
create mode 100644
extensions/smb/tests/utils/MockSmbConnectionControllerService.h
create mode 100644 extensions/smb/tests/utils/TempSmbShare.h
rename libminifi/include/utils/{ => file}/FileReaderCallback.h (100%)
copy libminifi/include/utils/{Hash.h => file/FileWriterCallback.h} (65%)
create mode 100644 libminifi/include/utils/file/ListedFile.h
rename libminifi/src/utils/{ => file}/FileReaderCallback.cpp (98%)
create mode 100644 libminifi/src/utils/file/FileWriterCallback.cpp