This is an automated email from the ASF dual-hosted git repository.
szaszm pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from a266a3047 MINIFICPP-2168 Fix Github Actions cache issues -
Environment variable for docker cache only used after defined - Fix mistake
of comparing int with string representation of PR id
new 259c53944 MINIFICPP-2154 Replace SecureSocketGetTCPTest with
utils::net::getSSLContext tests
new bf26da51a MINIFICPP-2163 Cleanup LogMetricsPublisherTests
new 6bc1965d3 MINIFICPP-1817 Use magic_enum library instead of SMART_ENUM
new e579692e6 MINIFICPP-2162 Use className instead of getClassName
new cafc3b1a0 MINIFICPP-2159 Add heterogeneous lookup to FlatMap
new 9c354aeab MINIFICPP-2169 Fix PutS3Object on Windows
new 1ef06c702 MINIFICPP-2167 Update Catch2 from 2.13.10 to 3.4.0
new fb9cfe38f MINIFICPP-2134 Do not swallow parsing exceptions
The 8 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 | 3 +
LICENSE | 24 +
NOTICE | 1 +
PROCESSORS.md | 42 +-
cmake/BuildTests.cmake | 33 +-
cmake/BundledAwsSdkCpp.cmake | 11 +-
cmake/{MiMalloc.cmake => Catch2.cmake} | 9 +-
.../{JsonSchemaValidator.cmake => MagicEnum.cmake} | 16 +-
controller/Controller.cpp | 26 +-
controller/MiNiFiController.cpp | 2 +-
controller/tests/CMakeLists.txt | 3 +-
encrypt-config/tests/CMakeLists.txt | 3 +-
extensions/aws/processors/FetchS3Object.cpp | 2 +-
extensions/aws/s3/S3Wrapper.cpp | 38 +-
extensions/aws/tests/CMakeLists.txt | 2 +-
extensions/aws/tests/PutS3ObjectTests.cpp | 98 +-
.../azure/processors/DeleteAzureBlobStorage.h | 6 +-
.../azure/processors/ListAzureBlobStorage.cpp | 5 +-
extensions/azure/processors/ListAzureBlobStorage.h | 21 +-
.../azure/processors/ListAzureDataLakeStorage.cpp | 2 +-
.../azure/processors/ListAzureDataLakeStorage.h | 23 +-
.../azure/processors/PutAzureDataLakeStorage.cpp | 8 +-
.../azure/processors/PutAzureDataLakeStorage.h | 17 +-
extensions/azure/storage/BlobStorageClient.h | 30 +-
.../ContainerInfo.h => azure/utils/AzureEnums.h} | 16 +-
extensions/civetweb/tests/CMakeLists.txt | 2 +-
extensions/coap/protocols/CoapC2Protocol.cpp | 26 +-
extensions/coap/tests/CoapC2VerifyHeartbeat.cpp | 1 -
extensions/elasticsearch/tests/CMakeLists.txt | 2 +-
.../expression-language/tests/CMakeLists.txt | 4 +-
.../tests/ExpressionLanguageTests.cpp | 28 +-
.../integration/UpdateAttributeIntegrationTest.cpp | 1 -
.../GCPCredentialsControllerService.cpp | 21 +-
.../GCPCredentialsControllerService.h | 42 +-
extensions/gcp/processors/PutGCSObject.cpp | 7 +-
extensions/gcp/processors/PutGCSObject.h | 50 +-
extensions/gcp/tests/DeleteGCSObjectTests.cpp | 14 +-
extensions/gcp/tests/FetchGCSObjectTests.cpp | 10 +-
.../tests/GCPCredentialsControllerServiceTests.cpp | 16 +-
extensions/gcp/tests/ListGCSBucketTests.cpp | 2 +-
extensions/gcp/tests/PutGCSObjectTests.cpp | 34 +-
extensions/http-curl/processors/InvokeHTTP.cpp | 33 +-
extensions/http-curl/processors/InvokeHTTP.h | 25 +-
extensions/http-curl/protocols/RESTSender.cpp | 24 +-
extensions/http-curl/protocols/RESTSender.h | 10 +-
extensions/http-curl/tests/AbsoluteTimeoutTest.cpp | 1 -
extensions/http-curl/tests/C2CompressTest.cpp | 1 -
extensions/http-curl/tests/C2DebugBundleTest.cpp | 1 -
.../tests/C2DescribeCoreComponentStateTest.cpp | 1 -
.../http-curl/tests/C2DescribeManifestTest.cpp | 1 -
extensions/http-curl/tests/C2JstackTest.cpp | 1 -
extensions/http-curl/tests/C2LogHeartbeatTest.cpp | 1 -
.../http-curl/tests/C2MultipleCommandsTest.cpp | 1 -
extensions/http-curl/tests/C2NullConfiguration.cpp | 1 -
extensions/http-curl/tests/C2PauseResumeTest.cpp | 1 -
.../http-curl/tests/C2VerifyHeartbeatAndStop.cpp | 1 -
.../tests/C2VerifyLightweightHeartbeatAndStop.cpp | 1 -
.../C2VerifyResourceConsumptionInHeartbeat.cpp | 1 -
.../http-curl/tests/C2VerifyServeResults.cpp | 1 -
extensions/http-curl/tests/CMakeLists.txt | 3 +-
extensions/http-curl/tests/HTTPHandlers.h | 20 +-
extensions/http-curl/tests/HTTPIntegrationBase.h | 1 -
extensions/http-curl/tests/HTTPSiteToSiteTests.cpp | 1 -
.../http-curl/tests/HttpPostIntegrationTest.cpp | 1 -
extensions/http-curl/tests/SiteToSiteRestTest.cpp | 1 -
.../http-curl/tests/TimeoutHTTPSiteToSiteTests.cpp | 1 -
extensions/http-curl/tests/VerifyInvokeHTTP.h | 1 -
.../http-curl/tests/{ => unit}/AlertTests.cpp | 8 +-
extensions/jni/jvm/JVMLoader.h | 12 +-
extensions/kubernetes/tests/CMakeLists.txt | 2 +-
extensions/libarchive/ArchiveStreamProvider.cpp | 4 +-
extensions/libarchive/CompressContent.cpp | 21 +-
extensions/libarchive/CompressContent.h | 64 +-
extensions/libarchive/WriteArchiveStream.h | 35 +-
extensions/librdkafka/ConsumeKafka.h | 2 +-
extensions/librdkafka/KafkaProcessorBase.cpp | 17 +-
extensions/librdkafka/KafkaProcessorBase.h | 32 +-
extensions/librdkafka/tests/CMakeLists.txt | 2 +-
extensions/lua/tests/CMakeLists.txt | 2 +-
.../mqtt/processors/AbstractMQTTProcessor.cpp | 28 +-
extensions/mqtt/processors/AbstractMQTTProcessor.h | 83 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 33 +-
extensions/mqtt/processors/ConsumeMQTT.h | 6 +
extensions/mqtt/processors/PublishMQTT.cpp | 6 +-
extensions/mqtt/processors/PublishMQTT.h | 2 +
extensions/mqtt/tests/CMakeLists.txt | 2 +-
extensions/mqtt/tests/ConsumeMQTTTests.cpp | 21 +-
extensions/mqtt/tests/PublishMQTTTests.cpp | 9 +-
extensions/opencv/tests/CMakeLists.txt | 2 +-
extensions/pdh/tests/CMakeLists.txt | 2 +-
extensions/procfs/processors/ProcFsMonitor.cpp | 29 +-
extensions/procfs/processors/ProcFsMonitor.h | 49 +-
extensions/procfs/tests/CMakeLists.txt | 2 +-
extensions/procfs/tests/CPUStatTests.cpp | 3 +-
extensions/prometheus/tests/CMakeLists.txt | 2 +-
extensions/python/tests/CMakeLists.txt | 4 +-
extensions/python/types/PyScriptFlowFile.cpp | 8 +-
.../rocksdb-repos/DatabaseContentRepository.h | 5 +-
extensions/rocksdb-repos/FlowFileRepository.h | 9 +-
extensions/rocksdb-repos/ProvenanceRepository.h | 5 +-
extensions/rocksdb-repos/RocksDbRepository.h | 5 +-
extensions/script/ExecuteScript.h | 12 +-
extensions/script/tests/CMakeLists.txt | 2 +-
extensions/sftp/client/SFTPClient.h | 48 +-
extensions/sftp/processors/FetchSFTP.cpp | 2 +-
extensions/sftp/processors/ListSFTP.cpp | 2 +-
extensions/sftp/processors/ListSFTP.h | 7 +-
extensions/sftp/tests/CMakeLists.txt | 2 +-
extensions/splunk/tests/CMakeLists.txt | 2 +-
extensions/sql/processors/ExecuteSQL.cpp | 3 +-
extensions/sql/processors/FlowFileSource.h | 35 +-
extensions/sql/processors/QueryDatabaseTable.cpp | 3 +-
.../processors/AttributesToJSON.cpp | 4 +-
.../processors/AttributesToJSON.h | 33 +-
.../processors/DefragmentText.cpp | 5 +-
.../processors/DefragmentText.h | 37 +-
.../standard-processors/processors/FetchFile.h | 92 +-
.../standard-processors/processors/GetTCP.cpp | 2 +-
.../standard-processors/processors/ListFile.cpp | 2 +-
.../standard-processors/processors/ListFile.h | 3 +-
.../processors/ListenSyslog.cpp | 7 +-
.../standard-processors/processors/ListenSyslog.h | 12 +-
.../standard-processors/processors/ListenTCP.h | 6 +-
.../processors/NetworkListenerProcessor.cpp | 2 +-
.../standard-processors/processors/PutTCP.cpp | 4 +-
.../standard-processors/processors/ReplaceText.cpp | 32 +-
.../standard-processors/processors/ReplaceText.h | 117 +-
.../standard-processors/processors/RouteText.cpp | 6 +-
.../standard-processors/processors/RouteText.h | 113 +-
.../standard-processors/processors/TailFile.cpp | 2 +-
.../standard-processors/processors/TailFile.h | 39 +-
.../standard-processors/tests/CMakeLists.txt | 18 +-
.../tests/integration/ProcessGroupTest.cpp | 1 -
.../tests/integration/SecureSocketGetTCPTest.cpp | 1 -
.../tests/unit/DefragmentTextTests.cpp | 12 +-
.../tests/unit/ExecuteProcessTests.cpp | 3 -
.../standard-processors/tests/unit/GetTCPTests.cpp | 8 +-
.../tests/unit/ListenSyslogTests.cpp | 60 +-
.../tests/unit/ListenTcpTests.cpp | 64 +-
.../tests/unit/ListenUDPTests.cpp | 16 +-
.../tests/unit/ProcessorTests.cpp | 8 +-
.../standard-processors/tests/unit/PutTCPTests.cpp | 29 +-
.../tests/unit/ReplaceTextTests.cpp | 34 +-
.../tests/unit/resources/alice_by_A.pem | 46 -
.../tests/unit/resources/alice_by_B.pem | 46 -
.../tests/unit/resources/ca_A.crt | 21 -
.../tests/unit/resources/ca_B.crt | 21 -
.../tests/unit/resources/localhost_by_A.pem | 46 -
.../tests/unit/resources/localhost_by_B.pem | 46 -
extensions/systemd/tests/CMakeLists.txt | 2 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 22 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 34 +-
extensions/windows-event-log/tests/CMakeLists.txt | 2 +-
libminifi/CMakeLists.txt | 3 +-
libminifi/include/agent/agent_docs.h | 2 +-
libminifi/include/c2/C2Payload.h | 93 +-
libminifi/include/c2/C2Protocol.h | 2 +-
libminifi/include/c2/PayloadSerializer.h | 44 +-
libminifi/include/core/Connectable.h | 5 +-
libminifi/include/core/ContentRepository.h | 3 +-
libminifi/include/core/Core.h | 30 +-
libminifi/include/core/FlowFile.h | 54 +-
libminifi/include/core/ObjectFactory.h | 8 +-
libminifi/include/core/ProcessContext.h | 16 +-
libminifi/include/core/ProcessSession.h | 4 +-
libminifi/include/core/Processor.h | 2 +-
libminifi/include/core/Repository.h | 5 +-
libminifi/include/core/SerializableComponent.h | 8 +-
.../include/core/controller/ControllerService.h | 2 +-
.../core/controller/ControllerServiceProvider.h | 12 +-
.../include/core/logging/LoggerConfiguration.h | 11 +-
libminifi/include/core/logging/LoggerFactory.h | 8 +-
.../include/core/repository/FileSystemRepository.h | 5 +-
.../core/repository/VolatileContentRepository.h | 3 +-
.../core/repository/VolatileFlowFileRepository.h | 5 +-
.../core/repository/VolatileProvenanceRepository.h | 5 +-
.../include/core/repository/VolatileRepository.h | 5 +-
.../include/core/state/nodes/SupportedOperations.h | 2 +-
libminifi/include/provenance/Provenance.h | 2 +-
libminifi/include/utils/ClassUtils.h | 3 +-
libminifi/include/utils/Enum.h | 128 +-
libminifi/include/utils/FlatMap.h | 40 +-
libminifi/include/utils/LogUtils.h | 42 +-
libminifi/include/utils/ProcessorConfigUtils.h | 22 +-
libminifi/include/utils/StringUtils.h | 8 +-
libminifi/include/utils/ValueParser.h | 31 +-
libminifi/include/utils/net/AsioSocketUtils.h | 2 +-
libminifi/include/utils/net/IpProtocol.h | 8 +-
libminifi/include/utils/net/Ssl.h | 10 +-
libminifi/src/FlowController.cpp | 2 +-
libminifi/src/c2/C2Agent.cpp | 128 +-
libminifi/src/c2/C2Payload.cpp | 4 +-
.../src/c2/ControllerSocketMetricsPublisher.cpp | 2 +-
libminifi/src/c2/ControllerSocketProtocol.cpp | 25 +-
libminifi/src/c2/HeartbeatJsonSerializer.cpp | 2 +-
libminifi/src/c2/protocols/RESTProtocol.cpp | 2 +-
libminifi/src/c2/triggers/FileUpdateTrigger.cpp | 6 +-
libminifi/src/core/Connectable.cpp | 8 +-
libminifi/src/core/Core.cpp | 4 +-
libminifi/src/core/FlowConfiguration.cpp | 2 +-
libminifi/src/core/FlowFile.cpp | 31 +-
libminifi/src/core/ProcessSession.cpp | 6 +-
libminifi/src/core/logging/LoggerConfiguration.cpp | 13 +-
libminifi/src/core/logging/LoggerFactory.cpp | 2 +-
.../core/logging/internal/CompressionManager.cpp | 18 +-
libminifi/src/core/state/LogMetricsPublisher.cpp | 4 +-
.../src/core/state/nodes/SupportedOperations.cpp | 19 +-
libminifi/src/provenance/Provenance.cpp | 2 +-
libminifi/src/utils/ClassUtils.cpp | 2 +-
libminifi/src/utils/ProcessorConfigUtils.cpp | 10 -
libminifi/src/utils/StringUtils.cpp | 11 +-
libminifi/src/utils/net/AsioSocketUtils.cpp | 6 +-
libminifi/src/utils/net/DNS.cpp | 2 +-
libminifi/src/utils/net/TcpServer.cpp | 3 +-
libminifi/test/Catch.h | 18 +-
libminifi/test/CatchMain.cpp | 20 -
libminifi/test/TestBase.cpp | 24 +-
libminifi/test/TestBase.h | 11 +-
libminifi/test/Utils.h | 2 +-
libminifi/test/archive-tests/CMakeLists.txt | 2 +-
.../test/archive-tests/CompressContentTests.cpp | 54 +-
libminifi/test/azure-tests/CMakeLists.txt | 2 +-
.../test/azure-tests/ListAzureBlobStorageTests.cpp | 6 +-
.../azure-tests/ListAzureDataLakeStorageTests.cpp | 6 +-
.../azure-tests/PutAzureDataLakeStorageTests.cpp | 6 +-
libminifi/test/bustache-tests/CMakeLists.txt | 2 +-
libminifi/test/flow-tests/CMakeLists.txt | 2 +-
libminifi/test/gps-tests/CMakeLists.txt | 2 +-
.../integration/OnScheduleErrorHandlingTests.cpp | 1 -
.../integration/StateTransactionalityTests.cpp | 1 -
libminifi/test/jni-tests/CMakeLists.txt | 2 +-
libminifi/test/keyvalue-tests/CMakeLists.txt | 2 +-
.../keyvalue-tests/PersistentStateStorageTest.cpp | 3 +-
.../keyvalue-tests/VolatileMapStateStorageTest.cpp | 3 +-
libminifi/test/persistence-tests/CMakeLists.txt | 2 +-
.../test/persistence-tests/PersistenceTests.cpp | 3 +-
libminifi/test/resources/certs/alice.key | 28 +
libminifi/test/resources/certs/alice_by_A.pem | 17 +
.../test/resources/certs/alice_by_A_with_key.pem | 45 +
libminifi/test/resources/certs/alice_by_B.pem | 17 +
libminifi/test/resources/certs/alice_encrypted.key | 30 +
.../{cn.pass => certs/alice_encryption_pass} | 0
libminifi/test/resources/certs/ca_A.crt | 16 +
libminifi/test/resources/certs/ca_B.crt | 16 +
.../test/resources/certs/empty_pass | 0
libminifi/test/resources/certs/localhost.key | 28 +
libminifi/test/resources/certs/localhost_by_A.pem | 17 +
libminifi/test/resources/certs/localhost_by_B.pem | 17 +
libminifi/test/rocksdb-tests/CMakeLists.txt | 2 +-
libminifi/test/schema-tests/CMakeLists.txt | 2 +-
libminifi/test/sql-tests/CMakeLists.txt | 3 +-
libminifi/test/sql-tests/mocks/MockConnectors.cpp | 8 +-
.../test/unit/ContentRepositoryDependentTests.h | 2 +-
libminifi/test/unit/CoreTests.cpp | 7 -
libminifi/test/unit/EnumTests.cpp | 131 -
libminifi/test/unit/FileTriggerTests.cpp | 8 +-
libminifi/test/unit/FileUtilsTests.cpp | 29 +-
libminifi/test/unit/FlatMapTests.cpp | 18 +-
libminifi/test/unit/GeneralUtilsTest.cpp | 4 +-
libminifi/test/unit/LogMetricsPublisherTests.cpp | 6 +
libminifi/test/unit/NetUtilsTest.cpp | 116 +-
libminifi/test/unit/OsUtilTests.cpp | 3 +
libminifi/test/unit/PayloadParserTests.cpp | 48 +-
libminifi/test/unit/ProcessContextTest.cpp | 20 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 25 +-
libminifi/test/unit/RegexUtilsTests.cpp | 4 +-
libminifi/test/unit/StringUtilsTests.cpp | 2 +-
libminifi/test/unit/ValueParserTests.cpp | 43 +
.../test/unit/WindowsCertStoreLocationTests.cpp | 3 -
libminifi/test/unit/tls/TLSStreamTests.cpp | 1 -
minifi_main/tests/CMakeLists.txt | 3 +-
nanofi/src/cxx/C2CallbackAgent.cpp | 18 +-
run_clang_tidy.sh | 8 +-
thirdparty/catch/catch.hpp | 17976 -------------------
274 files changed, 2359 insertions(+), 20011 deletions(-)
copy cmake/{MiMalloc.cmake => Catch2.cmake} (78%)
copy cmake/{JsonSchemaValidator.cmake => MagicEnum.cmake} (65%)
copy extensions/{kubernetes/ContainerInfo.h => azure/utils/AzureEnums.h} (78%)
rename extensions/http-curl/tests/{ => unit}/AlertTests.cpp (97%)
delete mode 100644
extensions/standard-processors/tests/unit/resources/alice_by_A.pem
delete mode 100644
extensions/standard-processors/tests/unit/resources/alice_by_B.pem
delete mode 100644 extensions/standard-processors/tests/unit/resources/ca_A.crt
delete mode 100644 extensions/standard-processors/tests/unit/resources/ca_B.crt
delete mode 100644
extensions/standard-processors/tests/unit/resources/localhost_by_A.pem
delete mode 100644
extensions/standard-processors/tests/unit/resources/localhost_by_B.pem
delete mode 100644 libminifi/test/CatchMain.cpp
create mode 100644 libminifi/test/resources/certs/alice.key
create mode 100644 libminifi/test/resources/certs/alice_by_A.pem
create mode 100644 libminifi/test/resources/certs/alice_by_A_with_key.pem
create mode 100644 libminifi/test/resources/certs/alice_by_B.pem
create mode 100644 libminifi/test/resources/certs/alice_encrypted.key
copy libminifi/test/resources/{cn.pass => certs/alice_encryption_pass} (100%)
create mode 100644 libminifi/test/resources/certs/ca_A.crt
create mode 100644 libminifi/test/resources/certs/ca_B.crt
copy docker/test/integration/__init__.py =>
libminifi/test/resources/certs/empty_pass (100%)
create mode 100644 libminifi/test/resources/certs/localhost.key
create mode 100644 libminifi/test/resources/certs/localhost_by_A.pem
create mode 100644 libminifi/test/resources/certs/localhost_by_B.pem
delete mode 100644 libminifi/test/unit/EnumTests.cpp
create mode 100644 libminifi/test/unit/ValueParserTests.cpp
delete mode 100644 thirdparty/catch/catch.hpp
