This is an automated email from the ASF dual-hosted git repository.
martinzink pushed a change to branch minifi_rust_pgp
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit d3260c4a7 no public key should route to failure instead of rollback
omit 7b92078d0 refactor
omit 0635a15d2 minifi_pgp set version to 1.0.0
omit c27c3f53a update manifest
omit cfe10ebd9 MINIFICPP-2749 Add EncryptContentPGP and DecryptContentPGP
omit fcf1d4683 review changes
omit af99c2ce6 add anyhow error support and fold parse errors into
validation errors
omit 200d08c55 MINIFICPP-2886 Improve rust api process errors
omit f4637dcca K -> P in Property context 2
omit b82dfb753 K -> P in Property context
omit 60d8d5ffe review change + small improvement in build.rs
omit d52fcd261 is_required: K::IS_REQUIRED
omit cd85d2bd5 cargo fmt
omit 56a694ddb fix
omit c44eb1c94 manifest update
omit 72389ffed rebase NUMBER_VALIDATOR
omit 9dda01cab win fix
omit 786b6a2a1 property rework
omit afc5c0744 MINIFICPP-2869 Improve rust api property validation and
property getters
add a7419e286 MINIFICPP-2870 Lint/Check python code with ruff (#2237)
add 8be29c104 MINIFICPP-2885 Allow explictily unsetting properties with
default value (#2241)
new 3f92464be MINIFICPP-2869 Improve rust api property validation and
property getters
new 5bbfdc8ef property rework
new 64866d509 win fix
new 265f4f8a8 rebase NUMBER_VALIDATOR
new 70f91327d manifest update
new 8b847f62d fix
new d33ed267d cargo fmt
new 518b46846 is_required: K::IS_REQUIRED
new f67a0db5b review change + small improvement in build.rs
new fef93690b K -> P in Property context
new 7f6c01d0a K -> P in Property context 2
new fd73ee076 property trait comments
new fce40dbef review changes and clippy fix (for new rust warnings (rustc
upgrade))
new 6525c688d cargo fmt
new ef46ce12c MINIFICPP-2886 Improve rust api process errors
new 5f771170b add anyhow error support and fold parse errors into
validation errors
new 1026d341d review changes
new 83294bf29 MINIFICPP-2749 Add EncryptContentPGP and DecryptContentPGP
new 0dbc4dade update manifest
new 8e39e04d1 minifi_pgp set version to 1.0.0
new bba16042a refactor
new b913bef00 no public key should route to failure instead of rollback
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 (d3260c4a7)
\
N -- N -- N refs/heads/minifi_rust_pgp (b913bef00)
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.
The 22 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/conan/compatibility.py | 5 +-
.../github_scripts/github_actions_cache_cleanup.py | 52 ++-
.../github_actions_cache_cleanup_tests.py | 52 +--
.../ubuntu_22_04_clang_arm_manifest.json | 45 +++
.github/workflows/ci.yml | 14 +-
CMakeLists.txt | 3 -
CONTRIBUTING.md | 19 +-
.../minifi_behave/containers/container_linux.py | 177 +++++-----
.../minifi_behave/containers/container_protocol.py | 33 +-
.../minifi_behave/containers/container_windows.py | 104 +++---
.../src/minifi_behave/containers/directory.py | 1 +
.../containers/docker_image_builder.py | 45 ++-
.../src/minifi_behave/containers/file.py | 1 +
.../src/minifi_behave/containers/host_file.py | 1 +
.../containers/http_proxy_container.py | 58 +++-
.../minifi_behave/containers/minifi_controller.py | 33 +-
.../containers/minifi_linux_container.py | 109 ++++--
.../minifi_behave/containers/minifi_protocol.py | 15 +-
.../containers/minifi_win_container.py | 20 +-
.../src/minifi_behave/containers/nifi_container.py | 118 ++++---
behave_framework/src/minifi_behave/core/helpers.py | 48 ++-
behave_framework/src/minifi_behave/core/hooks.py | 40 ++-
.../src/minifi_behave/core/minifi_test_context.py | 27 +-
.../src/minifi_behave/core/ssl_utils.py | 17 +-
.../src/minifi_behave/minifi/controller_service.py | 7 +-
.../src/minifi_behave/minifi/flow_definition.py | 19 +-
.../src/minifi_behave/minifi/funnel.py | 5 +-
.../src/minifi_behave/minifi/input_port.py | 8 +-
.../minifi_behave/minifi/minifi_flow_definition.py | 48 ++-
.../minifi_behave/minifi/nifi_flow_definition.py | 163 ++++-----
.../src/minifi_behave/minifi/output_port.py | 8 +-
.../src/minifi_behave/minifi/parameter.py | 9 +-
.../src/minifi_behave/minifi/parameter_context.py | 6 +-
.../src/minifi_behave/minifi/processor.py | 28 +-
.../src/minifi_behave/minifi/remote_port.py | 9 +-
.../minifi_behave/minifi/remote_process_group.py | 14 +-
.../src/minifi_behave/steps/checking_steps.py | 371 ++++++++++++++------
.../src/minifi_behave/steps/configuration_steps.py | 13 +-
.../src/minifi_behave/steps/core_steps.py | 86 +++--
.../src/minifi_behave/steps/flow_building_steps.py | 385 ++++++++++++++++-----
bootstrap/cli.py | 86 +++--
bootstrap/cmake_parser.py | 26 +-
bootstrap/main.py | 77 +++--
bootstrap/minifi_option.py | 75 +++-
bootstrap/package_manager.py | 209 ++++++-----
bootstrap/system_dependency.py | 27 +-
cmake/GenericPython.cmake | 2 +-
conanfile.py | 176 ++++++++--
.../include/core/ConfigurableComponentImpl.h | 1 +
.../src/core/ConfigurableComponentImpl.cpp | 10 +
docker/rockylinux/Dockerfile | 12 +-
.../scripts/python/reverse_flow_file_content.py | 6 +-
.../containers/kinesis_server_container.py | 21 +-
.../features/containers/s3_server_container.py | 75 +++-
extensions/aws/tests/features/environment.py | 6 +-
extensions/aws/tests/features/steps/steps.py | 57 +--
.../features/containers/azure_server_container.py | 108 ++++--
extensions/azure/tests/features/environment.py | 6 +-
extensions/azure/tests/features/steps/steps.py | 31 +-
extensions/civetweb/tests/features/environment.py | 3 +-
extensions/civetweb/tests/features/steps/steps.py | 10 +-
.../containers/couchbase_server_container.py | 145 ++++++--
extensions/couchbase/tests/features/environment.py | 13 +-
extensions/couchbase/tests/features/steps/steps.py | 33 +-
.../features/containers/elastic_base_container.py | 39 ++-
.../features/containers/elasticsearch_container.py | 96 +++--
.../features/containers/opensearch_container.py | 55 ++-
.../elasticsearch/tests/features/environment.py | 6 +-
.../elasticsearch/tests/features/steps/steps.py | 62 ++--
.../containers/fake_gcs_server_container.py | 20 +-
extensions/gcp/tests/features/environment.py | 6 +-
extensions/gcp/tests/features/steps/steps.py | 17 +-
.../features/containers/grafana_loki_container.py | 59 +++-
.../features/containers/reverse_proxy_container.py | 11 +-
.../grafana-loki/tests/features/environment.py | 13 +-
.../resources/check_log_lines_on_grafana.py | 14 +-
.../grafana-loki/tests/features/steps/steps.py | 49 ++-
.../features/containers/kafka_server_container.py | 127 +++++--
extensions/kafka/tests/features/environment.py | 11 +-
extensions/kafka/tests/features/steps/steps.py | 73 ++--
.../kubernetes/tests/features/environment.py | 11 +-
.../tests/features/steps/kubernetes_proxy.py | 120 ++++---
.../steps/minifi_as_pod_in_kubernetes_cluster.py | 4 +-
.../kubernetes/tests/features/steps/steps.py | 62 +++-
extensions/llamacpp/tests/features/environment.py | 18 +-
extensions/llamacpp/tests/features/steps/steps.py | 10 +-
extensions/lua/tests/features/environment.py | 5 +-
extensions/lua/tests/features/steps/steps.py | 10 +-
.../features/containers/mqtt_broker_container.py | 49 ++-
extensions/mqtt/tests/features/environment.py | 11 +-
.../features/resources/publish_mqtt_message.py | 3 +-
extensions/mqtt/tests/features/steps/steps.py | 48 +--
.../features/containers/opc_ua_server_container.py | 14 +-
extensions/opc/tests/features/environment.py | 9 +-
extensions/opc/tests/features/steps/steps.py | 64 ++--
.../features/containers/prometheus_container.py | 114 ++++--
.../prometheus/tests/features/environment.py | 11 +-
.../tests/features/resources/prometheus_checker.py | 220 +++++++++---
.../prometheus/tests/features/steps/steps.py | 74 ++--
extensions/python/CMakeLists.txt | 10 +-
extensions/python/PYTHON.md | 24 +-
.../pythonprocessor-examples/AddPythonAttribute.py | 1 -
.../pythonprocessor-examples/CountingProcessor.py | 3 +-
.../GaussianDistributionWithNumpy.py | 2 +-
.../pythonprocessor-examples/MoveContentToJson.py | 5 +-
.../pythonprocessor-examples/RemoveFlowFile.py | 1 -
.../pythonprocessor-examples/SentimentAnalysis.py | 12 +-
.../google/SentimentAnalyzer.py | 28 +-
.../pythonprocessor-examples/h2o/ConvertDsToCsv.py | 51 ++-
.../h2o/h2o3/mojo/ExecuteH2oMojoScoring.py | 158 +++++----
.../utils/dependency_installer.py | 32 +-
.../pythonprocessors/nifiapi/componentstate.py | 10 +-
.../python/pythonprocessors/nifiapi/decorators.py | 1 +
.../pythonprocessors/nifiapi/documentation.py | 60 +++-
.../pythonprocessors/nifiapi/flowfilesource.py | 8 +-
.../pythonprocessors/nifiapi/flowfiletransform.py | 12 +-
.../pythonprocessors/nifiapi/processorbase.py | 49 ++-
.../python/pythonprocessors/nifiapi/properties.py | 106 ++++--
.../pythonprocessors/nifiapi/recordtransform.py | 62 +++-
.../pythonprocessors/nifiapi/relationship.py | 1 +
extensions/python/tests/features/environment.py | 101 +++---
.../tests/features/resources/CreateFlowFile.py | 30 +-
.../tests/features/resources/CreateNothing.py | 13 +-
.../resources/EvaluateExpressionLanguageChecker.py | 21 +-
.../ExpressionLanguagePropertyWithValidator.py | 25 +-
.../features/resources/LogDynamicProperties.py | 9 +-
.../resources/NifiStyleLogDynamicProperties.py | 27 +-
.../resources/ProcessContextInterfaceChecker.py | 30 +-
.../resources/RelativeImporterProcessor.py | 5 +-
.../tests/features/resources/RotatingForwarder.py | 1 +
.../tests/features/resources/SetRecordField.py | 27 +-
.../resources/SingleThreadedSleepForever.py | 12 +-
.../tests/features/resources/SleepForever.py | 10 +-
.../resources/SpecialPropertyTypeChecker.py | 15 +-
.../tests/features/resources/TestStateManager.py | 22 +-
.../tests/features/resources/multiplierutils.py | 1 +
.../tests/features/resources/subtractutils.py | 1 +
extensions/python/tests/features/steps/steps.py | 121 ++++---
.../tests/test_python_scripts/foo_bar_processor.py | 2 +-
.../non_transferring_processor.py | 4 +-
...passthrough_processor_transfering_to_failure.py | 4 +-
...passthrough_processor_transfering_to_success.py | 4 +-
.../test_python_scripts/stateful_processor.py | 9 +-
.../tests/features/containers/splunk_container.py | 149 +++++---
extensions/splunk/tests/features/environment.py | 6 +-
extensions/splunk/tests/features/steps/steps.py | 28 +-
.../containers/postgress_server_container.py | 27 +-
extensions/sql/tests/features/environment.py | 36 +-
extensions/sql/tests/features/steps/steps.py | 27 +-
.../stable-api-testing/ExtensionInitializer.cpp | 2 +
extensions/stable-api-testing/PropertyTester.h | 97 ++++++
.../tests/PropertyTesterTests.cpp | 221 ++++++++++++
.../features/containers/diag_slave_container.py | 17 +-
.../tests/features/containers/syslog_container.py | 2 +-
.../features/containers/tcp_client_container.py | 9 +-
.../tests/features/environment.py | 15 +-
.../features/steps/minifi_c2_server_container.py | 98 ++++--
.../features/steps/minifi_controller_steps.py | 43 ++-
.../tests/features/steps/steps.py | 82 +++--
.../src/core/flow/StructuredConfiguration.cpp | 21 +-
.../resources/TestC2DescribeCoreComponentState.yml | 4 +
.../minifi-cpp/core/ConfigurableComponent.h | 1 +
minifi-api/include/minifi-cpp/core/Property.h | 1 +
.../minifi_rs_playground/features/environment.py | 20 +-
.../minifi_rs_playground/features/steps/steps.py | 21 +-
.../src/processors/generate_flow_file.rs | 9 +-
.../src/processors/put_file/unix_permissions.rs | 17 +
.../minifi_native/src/api/process_context.rs | 9 +-
minifi_rust/minifi_native/src/api/property.rs | 12 +
ruff.toml | 17 +
run_flake8.sh | 22 --
thirdparty/google-styleguide/cpplint.py | 3 +
thirdparty/rocksdb/all/conanfile.py | 5 +-
173 files changed, 4875 insertions(+), 2222 deletions(-)
create mode 100644 extensions/stable-api-testing/PropertyTester.h
create mode 100644 extensions/stable-api-testing/tests/PropertyTesterTests.cpp
create mode 100644 ruff.toml
delete mode 100755 run_flake8.sh
