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 1976d80e4 MINIFICPP-2655 Upgrade elasticsearch container image to
v9.1.5
new a1ee3af66 MINIFICPP-2603 Add Record Reader and Record Writer
properties to MQTT processors
new 8edef4414 MINIFICPP-2649 Move expression language extension to
libminifi
new 97ffddd1f MINIFICPP-2654 Evaluate EL expressions only when it is
explicitly called in NiFi python processors
new d09012856 MINIFICPP-2656 aws-sdk-cpp: cpp23 build fix, include cstdint
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:
.github/workflows/ci.yml | 3 -
CMakeLists.txt | 3 +-
PROCESSORS.md | 20 +-
bootstrap/system_dependency.py | 6 +-
cmake/BuildTests.cmake | 1 +
cmake/BundledAwsSdkCpp.cmake | 5 +-
cmake/DockerConfig.cmake | 1 -
.../ExpressionLanguage.cmake | 39 +--
cmake/MiNiFiOptions.cmake | 1 -
conanfile.py | 1 -
.../include/core/ProcessContextBuilder.h | 78 -----
core-framework/src/core/ProcessContextBuilder.cpp | 67 ----
docker/requirements.txt | 1 +
.../test/integration/cluster/DockerTestCluster.py | 5 +
docker/test/integration/cluster/ImageStore.py | 4 +-
.../{FeatureContext.py => checkers/MqttHelper.py} | 12 +-
.../cluster/containers/FlowContainer.py | 6 +
.../cluster/containers/MqttBrokerContainer.py | 1 +
.../features/MiNiFi_integration_test_driver.py | 3 +
docker/test/integration/features/mqtt.feature | 53 +++
docker/test/integration/features/python.feature | 25 ++
docker/test/integration/features/steps/steps.py | 43 ++-
.../{JsonTreeReader.py => XMLRecordSetWriter.py} | 6 +-
.../integration/minifi/core/ControllerService.py | 3 +
...tes.py => EvaluateExpressionLanguageChecker.py} | 6 +-
.../python/EvaluateExpressionLanguageChecker.py | 83 +++++
extensions/aws/tests/CMakeLists.txt | 2 -
extensions/azure/tests/CMakeLists.txt | 2 -
.../ExpressionContextBuilder.cpp | 44 ---
.../expression-language/ExpressionContextBuilder.h | 50 ---
.../expression-language/ProcessContextExpr.cpp | 92 -----
.../expression-language/ProcessContextExpr.h | 54 ---
.../expression-language/tests/CMakeLists.txt | 64 ----
extensions/gcp/tests/CMakeLists.txt | 2 -
extensions/gcp/tests/PutGCSObjectTests.cpp | 1 -
.../libarchive/tests/CompressContentTests.cpp | 2 +-
extensions/libarchive/tests/MergeFileTests.cpp | 2 +-
.../mqtt/processors/AbstractMQTTProcessor.cpp | 14 +
extensions/mqtt/processors/AbstractMQTTProcessor.h | 18 +-
extensions/mqtt/processors/ConsumeMQTT.cpp | 78 ++++-
extensions/mqtt/processors/ConsumeMQTT.h | 42 ++-
extensions/mqtt/processors/PublishMQTT.cpp | 59 +++-
extensions/mqtt/processors/PublishMQTT.h | 13 +-
extensions/mqtt/tests/ConsumeMQTTTests.cpp | 375 ++++++++++++++++-----
extensions/mqtt/tests/PublishMQTTTests.cpp | 134 ++++++--
.../python/pythonprocessors/nifiapi/properties.py | 33 +-
extensions/python/types/PyProcessContext.cpp | 40 +++
extensions/python/types/PyProcessContext.h | 2 +
extensions/rocksdb-repos/tests/RepoTests.cpp | 2 +-
extensions/rocksdb-repos/tests/SwapTests.cpp | 2 +-
extensions/sftp/processors/PutSFTP.cpp | 2 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 2 +-
extensions/sftp/tests/CMakeLists.txt | 3 +-
extensions/sql/tests/CMakeLists.txt | 1 -
.../processors/ConvertRecord.cpp | 13 +-
.../standard-processors/processors/ConvertRecord.h | 7 +-
.../processors/EvaluateJsonPath.cpp | 2 +-
.../standard-processors/processors/SplitJson.cpp | 2 +-
.../standard-processors/processors/SplitRecord.cpp | 13 +-
.../standard-processors/processors/SplitRecord.h | 8 +-
.../standard-processors/tests/CMakeLists.txt | 2 -
.../ExpressionLanguageInDynamicPropertiesTests.cpp | 94 ++++++
.../tests/unit/GetFileTests.cpp | 2 +-
.../tests/unit/ProcessorTests.cpp | 2 +-
.../tests/unit}/RouteOnAttributeTests.cpp | 0
libminifi/CMakeLists.txt | 17 +-
.../include/core/ProcessContextImpl.h | 5 +
.../include}/expression-language/Driver.h | 2 +-
.../include/expression-language}/Expression.h | 4 +-
.../include}/expression-language/Parser.yy | 6 +-
.../include}/expression-language/Scanner.ll | 2 +-
.../include/expression-language}/Value.h | 0
libminifi/src/ThreadedSchedulingAgent.cpp | 10 +-
libminifi/src/c2/C2Agent.cpp | 2 +-
libminifi/src/core/ClassLoader.cpp | 8 +-
libminifi/src/core/ProcessContextBuilder.cpp | 24 --
.../{ProcessContext.cpp => ProcessContextImpl.cpp} | 62 +++-
.../src}/expression-language/Expression.cpp | 4 +-
libminifi/test/flow-tests/SessionTests.cpp | 2 +-
.../integration/UpdateAttributeIntegrationTest.cpp | 4 +-
.../test/libtest/integration/IntegrationBase.cpp | 2 +-
libminifi/test/libtest/unit/TestBase.cpp | 10 +-
.../test/persistence-tests/PersistenceTests.cpp | 2 +-
.../test/unit}/ExpressionLanguageTests.cpp | 74 +---
.../test/unit}/ProcessContextExprTests.cpp | 9 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 6 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 2 +-
.../minifi-cpp/controllers/RecordConverter.h | 12 +-
.../minifi-cpp/core/ProcessContextBuilder.h | 48 ---
thirdparty/aws-sdk-cpp/cpp23-cstdint.patch | 11 +
90 files changed, 1146 insertions(+), 938 deletions(-)
rename extensions/expression-language/CMakeLists.txt =>
cmake/ExpressionLanguage.cmake (74%)
delete mode 100644 core-framework/include/core/ProcessContextBuilder.h
delete mode 100644 core-framework/src/core/ProcessContextBuilder.cpp
copy docker/test/integration/cluster/{FeatureContext.py =>
checkers/MqttHelper.py} (71%)
copy docker/test/integration/minifi/controllers/{JsonTreeReader.py =>
XMLRecordSetWriter.py} (84%)
copy docker/test/integration/minifi/processors/{FailureWithAttributes.py =>
EvaluateExpressionLanguageChecker.py} (86%)
create mode 100644
docker/test/integration/resources/python/EvaluateExpressionLanguageChecker.py
delete mode 100644 extensions/expression-language/ExpressionContextBuilder.cpp
delete mode 100644 extensions/expression-language/ExpressionContextBuilder.h
delete mode 100644 extensions/expression-language/ProcessContextExpr.cpp
delete mode 100644 extensions/expression-language/ProcessContextExpr.h
delete mode 100644 extensions/expression-language/tests/CMakeLists.txt
create mode 100644
extensions/standard-processors/tests/unit/ExpressionLanguageInDynamicPropertiesTests.cpp
rename extensions/{expression-language/tests =>
standard-processors/tests/unit}/RouteOnAttributeTests.cpp (100%)
rename core-framework/include/core/ProcessContext.h =>
libminifi/include/core/ProcessContextImpl.h (96%)
rename {extensions => libminifi/include}/expression-language/Driver.h (97%)
rename {extensions/expression-language/impl/expression =>
libminifi/include/expression-language}/Expression.h (98%)
rename {extensions => libminifi/include}/expression-language/Parser.yy (98%)
rename {extensions => libminifi/include}/expression-language/Scanner.ll (98%)
rename {extensions/expression-language/common =>
libminifi/include/expression-language}/Value.h (100%)
delete mode 100644 libminifi/src/core/ProcessContextBuilder.cpp
rename libminifi/src/core/{ProcessContext.cpp => ProcessContextImpl.cpp} (69%)
rename {extensions => libminifi/src}/expression-language/Expression.cpp (99%)
rename {extensions/expression-language/tests =>
libminifi/test}/integration/UpdateAttributeIntegrationTest.cpp (97%)
rename {extensions/expression-language/tests =>
libminifi/test/unit}/ExpressionLanguageTests.cpp (95%)
rename {extensions/expression-language/tests =>
libminifi/test/unit}/ProcessContextExprTests.cpp (96%)
copy extension-framework/include/controllers/RecordSetReader.h =>
minifi-api/include/minifi-cpp/controllers/RecordConverter.h (76%)
delete mode 100644 minifi-api/include/minifi-cpp/core/ProcessContextBuilder.h
create mode 100644 thirdparty/aws-sdk-cpp/cpp23-cstdint.patch
