This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch MINIFICPP-2666
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit e172fa727 MINIFICPP-2666 Move Kafka tests to modular docker tests
omit dc13c8ea5 Fix after rebase
omit 9687e7e93 Fix after rebase
omit 09cf96c82 Review update
omit 66e212a94 MINIFICPP-2665 Move OPC UA tests to modular docker tests
omit 6fa1ee3f5 add modular tests documentation to README.md
omit 7cb26f05f remove typing
omit d7469f721 fix sql tests
omit c20dd7cd4 change sleep length in wait_for_condition
omit 1fe9bd2f0 auto format via PyCharm
omit 270bc944f check dir empty
omit 82b7e6448 remove accidental WIP from syslog_listener.feature
omit 1cfb06556 fix s3.feature
omit 621be5a3e fix regex matching
omit b4557124d inject_scenario_id, flake8 fixes
omit 288a426c4 fix sql tests
omit f62a2c69d get_number_of_files return -1 instead of False
omit d1181583e use os.path.join
omit 253583677 shlex
omit 6f9dc2cec add json check for attributes_to_json.feature
omit 40b5649ba RunBehaveTests.sh with INFO
omit 4fb0b25a8 remove already rewritten tests from legacy
consumekafka.feature
omit 60da88eb3 rename consue_kafka.feature to consumekafka.feature
omit 5aeb03998 rename behavex_output_2 to behavex_output_modular
omit fcb25c7f4 move makedirs outside of loop
omit d58939bf2 review changes
omit 0671dad9c add apache license and auto format
omit 665c96e31 review changes
omit 63c6c1413 split verify-package.yml
omit d4cd850e8 MINIFICPP-2624 Modularized behave tests part 1
add a1ee3af66 MINIFICPP-2603 Add Record Reader and Record Writer
properties to MQTT processors
add 8edef4414 MINIFICPP-2649 Move expression language extension to
libminifi
add 97ffddd1f MINIFICPP-2654 Evaluate EL expressions only when it is
explicitly called in NiFi python processors
add d09012856 MINIFICPP-2656 aws-sdk-cpp: cpp23 build fix, include cstdint
add e3728f117 MINIFICPP-2613 - Move base metrics to libminifi
add cbd45bf37 MINIFICPP-2658 Handle keyboard interrupt in bootstrap and
exit
add a76bbbfd3 MINIFICPP-2657 - Explicit extension initialization
add 6c2f0f30c MINIFICPP-2660 Handle new C2 start/stop command format
add 1b37c3f65 MINIFICPP-2661 Update version number to 1.0.0
add 689397348 MINIFICPP-2662 - Remove dependent and exclusive properties
add d7ee68e74 MINIFICPP-2624 Modularized behave tests part 1
add 2390d5f06 MINIFICPP-2665 Move OPC UA tests to modular docker tests
add 3e10a9703 Review update
add f00550a35 Fix after rebase
add bd0eaeac7 Fix after rebase
add c95e6157e Add license
add 2640d9b1e MINIFICPP-2666 Move Kafka tests to modular docker tests
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e172fa727)
\
N -- N -- N refs/heads/MINIFICPP-2666 (2640d9b1e)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 3 -
.github/workflows/create-release-artifacts.yml | 2 +-
CMakeLists.txt | 5 +-
Extensions.md | 22 +-
PROCESSORS.md | 20 +-
.../minifi_test_framework/containers/container.py | 4 +-
.../src/minifi_test_framework/containers/file.py | 3 +-
.../containers/minifi_container.py | 18 +-
.../src/minifi_test_framework/core/helpers.py | 20 +-
.../src/minifi_test_framework/core/hooks.py | 1 +
.../src/minifi_test_framework/steps/core_steps.py | 4 +-
bootstrap/cli.py | 17 +-
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 | 3 +-
conf/config.yml.in | 4 +-
.../include/core/ProcessContextBuilder.h | 78 -----
core-framework/include/core/ProcessorImpl.h | 9 +-
.../include/core/PropertyDefinitionBuilder.h | 44 +--
core-framework/include/core/extension/Extension.h | 94 ------
.../include/utils/minifi-c-utils.h | 13 +-
core-framework/src/core/ProcessContextBuilder.cpp | 67 ----
core-framework/src/core/ProcessorImpl.cpp | 2 -
core-framework/src/core/Property.cpp | 19 +-
core-framework/src/core/extension/Extension.cpp | 46 ---
docker/DockerVerify.sh | 4 +-
docker/RunBehaveTests.sh | 5 +-
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 +++++
encrypt-config/FlowConfigEncryptor.cpp | 2 +-
examples/consumejournald_config.yml | 4 +-
extensions/aws/tests/CMakeLists.txt | 2 -
extensions/aws/tests/features/environment.py | 3 +
.../tests/features/steps/s3_server_container.py | 15 +
extensions/aws/tests/features/steps/steps.py | 15 +
extensions/azure/tests/CMakeLists.txt | 2 -
.../azure/tests/features/azure_storage.feature | 24 +-
extensions/azure/tests/features/environment.py | 3 +
.../tests/features/steps/azure_server_container.py | 95 ++++--
extensions/azure/tests/features/steps/steps.py | 35 +-
.../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 -
.../tests/features/steps/kafka_server_container.py | 23 +-
extensions/kafka/tests/features/steps/steps.py | 15 +
.../libarchive/tests/CompressContentTests.cpp | 2 +-
extensions/libarchive/tests/MergeFileTests.cpp | 2 +-
.../llamacpp/processors/RunLlamaCppInference.cpp | 4 +-
.../llamacpp/processors/RunLlamaCppInference.h | 24 +-
extensions/llamacpp/tests/features/environment.py | 3 +
extensions/llamacpp/tests/features/steps/steps.py | 15 +
.../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 | 76 +++--
extensions/mqtt/processors/PublishMQTT.h | 19 +-
extensions/mqtt/tests/ConsumeMQTTTests.cpp | 375 ++++++++++++++++-----
extensions/mqtt/tests/PublishMQTTTests.cpp | 134 ++++++--
extensions/opc/tests/features/steps/steps.py | 15 +
extensions/opencv/OpenCVLoader.cpp | 26 +-
extensions/python/PythonCreator.h | 20 +-
extensions/python/PythonDependencyInstaller.cpp | 15 +-
extensions/python/PythonDependencyInstaller.h | 4 +-
.../python/pythonlibloader/PythonLibLoader.cpp | 31 +-
extensions/python/pythonloader/PyProcLoader.cpp | 31 +-
.../python/pythonprocessors/nifiapi/properties.py | 33 +-
extensions/python/tests/CMakeLists.txt | 12 +-
extensions/python/tests/PythonManifestTests.cpp | 4 +-
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/SFTPLoader.cpp | 32 +-
extensions/sftp/processors/PutSFTP.cpp | 2 +-
extensions/sftp/processors/SFTPProcessorBase.cpp | 2 +-
extensions/sftp/tests/CMakeLists.txt | 3 +-
extensions/smb/PutSmb.h | 3 +-
extensions/smb/SmbConnectionControllerService.h | 2 -
extensions/splunk/SplunkHECProcessor.h | 3 +-
extensions/sql/tests/CMakeLists.txt | 1 -
extensions/sql/tests/features/environment.py | 30 +-
.../features/steps/postgress_server_container.py | 17 +
extensions/sql/tests/features/steps/steps.py | 17 +
.../processors/ConvertRecord.cpp | 13 +-
.../standard-processors/processors/ConvertRecord.h | 7 +-
.../processors/EvaluateJsonPath.cpp | 2 +-
.../standard-processors/processors/GetFile.cpp | 2 +-
.../standard-processors/processors/GetFile.h | 23 +-
.../standard-processors/processors/InvokeHTTP.h | 3 +-
.../standard-processors/processors/PutFile.h | 3 +-
.../standard-processors/processors/SplitJson.cpp | 2 +-
.../standard-processors/processors/SplitRecord.cpp | 13 +-
.../standard-processors/processors/SplitRecord.h | 8 +-
.../standard-processors/tests/CMakeLists.txt | 2 -
.../tests/features/environment.py | 3 +
.../tests/features/steps/steps.py | 17 +
.../tests/features/steps/syslog_container.py | 17 +
.../tests/features/syslog_listener.feature | 2 +-
.../ExpressionLanguageInDynamicPropertiesTests.cpp | 94 ++++++
.../tests/unit/GetFileTests.cpp | 2 +-
.../tests/unit/ManifestTests.cpp | 4 +-
.../tests/unit/ProcessorTests.cpp | 2 +-
.../tests/unit}/RouteOnAttributeTests.cpp | 0
.../tests/unit/YamlConfigurationTests.cpp | 70 ----
libminifi/CMakeLists.txt | 19 +-
libminifi/include/c2/C2Agent.h | 1 +
.../include/core/ProcessContextImpl.h | 5 +
libminifi/include/core/ProcessSession.h | 4 +-
libminifi/include/core/Processor.h | 5 +-
.../include/core/ProcessorMetrics.h | 67 ++--
libminifi/include/core/extension/Executable.h | 30 --
.../extension/{DynamicLibrary.h => Extension.h} | 33 +-
.../include/core/extension/ExtensionManager.h | 21 +-
libminifi/include/core/extension/Module.h | 61 ----
libminifi/include/core/state/nodes/MetricsBase.h | 6 +
.../include/core/state/nodes/ResponseNode.h | 0
.../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/EventDrivenSchedulingAgent.cpp | 4 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 10 +-
libminifi/src/c2/C2Agent.cpp | 63 ++--
libminifi/src/core/ClassLoader.cpp | 8 +-
libminifi/src/core/ProcessContextBuilder.cpp | 24 --
.../{ProcessContext.cpp => ProcessContextImpl.cpp} | 62 +++-
libminifi/src/core/Processor.cpp | 19 +-
.../src/core/ProcessorMetrics.cpp | 48 ++-
.../{DynamicLibrary.cpp => Extension.cpp} | 52 ++-
libminifi/src/core/extension/ExtensionManager.cpp | 129 +++----
libminifi/src/core/extension/Module.cpp | 75 -----
.../src/core/flow/StructuredConfiguration.cpp | 36 --
.../src/core/state/nodes/AgentInformation.cpp | 14 -
.../src}/expression-language/Expression.cpp | 4 +-
libminifi/src/minifi-c.cpp | 55 +++
libminifi/test/flow-tests/SessionTests.cpp | 2 +-
.../test/integration/C2VerifyHeartbeatAndStop.cpp | 17 +-
.../C2VerifyLightweightHeartbeatAndStop.cpp | 18 +-
.../integration/UpdateAttributeIntegrationTest.cpp | 4 +-
.../test/libtest/integration/HTTPHandlers.cpp | 30 +-
libminifi/test/libtest/integration/HTTPHandlers.h | 12 +-
.../test/libtest/integration/IntegrationBase.cpp | 2 +-
libminifi/test/libtest/unit/TestBase.cpp | 16 +-
libminifi/test/libtest/unit/TestBase.h | 7 +-
.../test/libtest/unit/TestControllerWithFlow.cpp | 5 +
.../test/persistence-tests/PersistenceTests.cpp | 2 +-
libminifi/test/resources/TestEmpty.yml | 4 +-
libminifi/test/resources/TestHTTPSiteToSite.yml | 4 +-
libminifi/test/resources/TestSite2SiteRest.yml | 4 +-
.../test/resources/TestSite2SiteRestSecure.yml | 4 +-
.../test/resources/TestTimeoutHTTPSiteToSite.yml | 4 +-
.../test/unit}/ExpressionLanguageTests.cpp | 74 +---
libminifi/test/unit/MetricsTests.cpp | 8 +-
.../test/unit}/ProcessContextExprTests.cpp | 9 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 6 +-
libminifi/test/unit/SchedulingAgentTests.cpp | 2 +-
minifi-api/include/minifi-c/minifi-c.h | 50 +++
.../minifi-cpp/controllers/RecordConverter.h | 12 +-
.../minifi-cpp/core/ProcessContextBuilder.h | 48 ---
.../include/minifi-cpp/core/ProcessSession.h | 3 -
minifi-api/include/minifi-cpp/core/ProcessorApi.h | 8 +-
.../include/minifi-cpp/core/ProcessorMetrics.h | 57 ----
...essionFactory.h => ProcessorMetricsExtension.h} | 14 +-
minifi-api/include/minifi-cpp/core/Property.h | 9 +-
.../include/minifi-cpp/core/PropertyDefinition.h | 17 +-
.../include/minifi-cpp/core/extension/Extension.h | 47 ---
.../minifi-cpp/core/extension/ExtensionManager.h | 32 --
.../minifi-cpp/core/state/nodes/MetricsBase.h | 6 -
minifi_main/MiNiFiMain.cpp | 2 +-
thirdparty/aws-sdk-cpp/cpp23-cstdint.patch | 11 +
192 files changed, 2157 insertions(+), 2062 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/include/core/extension/Extension.h
copy libminifi/include/core/logging/Utils.h =>
core-framework/include/utils/minifi-c-utils.h (73%)
delete mode 100644 core-framework/src/core/ProcessContextBuilder.cpp
delete mode 100644 core-framework/src/core/extension/Extension.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 {core-framework => libminifi}/include/core/ProcessorMetrics.h (59%)
delete mode 100644 libminifi/include/core/extension/Executable.h
rename libminifi/include/core/extension/{DynamicLibrary.h => Extension.h} (65%)
delete mode 100644 libminifi/include/core/extension/Module.h
rename {core-framework => libminifi}/include/core/state/nodes/ResponseNode.h
(100%)
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 {core-framework => libminifi}/src/core/ProcessorMetrics.cpp (79%)
rename libminifi/src/core/extension/{DynamicLibrary.cpp => Extension.cpp} (76%)
delete mode 100644 libminifi/src/core/extension/Module.cpp
rename {extensions => libminifi/src}/expression-language/Expression.cpp (99%)
create mode 100644 libminifi/src/minifi-c.cpp
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%)
create mode 100644 minifi-api/include/minifi-c/minifi-c.h
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
delete mode 100644 minifi-api/include/minifi-cpp/core/ProcessorMetrics.h
copy minifi-api/include/minifi-cpp/core/{ProcessSessionFactory.h =>
ProcessorMetricsExtension.h} (77%)
delete mode 100644 minifi-api/include/minifi-cpp/core/extension/Extension.h
delete mode 100644
minifi-api/include/minifi-cpp/core/extension/ExtensionManager.h
create mode 100644 thirdparty/aws-sdk-cpp/cpp23-cstdint.patch
