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 bfb906345 MINIFICPP-2300 Fix transient failures of kubernetes tests new 1815c018c MINIFICPP-2297 Remove unmaintained iOS build support new 2c46147cf MINIFICPP-2231 Replace global CXX flags with target specific ones new b0767d8d4 MINIFICPP-2276 Support FlowFileTransform NiFi Python processors new 21dcd4d09 MINIFICPP-2278 Add custom relationship support for python processors 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 | 50 ++-- CONFIGURE.md | 3 + LICENSE | 31 --- README.md | 2 +- cmake/BuildTests.cmake | 10 +- cmake/CivetWeb.cmake | 4 - cmake/Date.cmake | 6 - cmake/GoogleCloudCpp.cmake | 13 - cmake/Grpc.cmake | 19 -- cmake/JsonSchemaValidator.cmake | 3 - cmake/VerifyPythonCompatibility.cmake | 8 +- cmake/iOS.cmake | 226 ---------------- controller/CMakeLists.txt | 2 +- controller/tests/CMakeLists.txt | 2 +- docker/python-verify/conda.Dockerfile | 9 +- docker/python-verify/venv.Dockerfile | 2 +- docker/test/integration/cluster/ContainerStore.py | 3 + .../test/integration/cluster/DockerTestCluster.py | 3 + docker/test/integration/cluster/ImageStore.py | 62 ++++- .../cluster/containers/MinifiC2ServerContainer.py | 6 +- .../cluster/containers/MinifiContainer.py | 3 + .../cluster/containers/NifiContainer.py | 2 +- .../features/MiNiFi_integration_test_driver.py | 3 + docker/test/integration/features/environment.py | 8 + .../integration/features/minifi_c2_server.feature | 2 +- docker/test/integration/features/python.feature | 39 +++ docker/test/integration/features/steps/steps.py | 3 +- .../{ReplaceText.py => ChunkDocument.py} | 11 +- .../{ReplaceText.py => ParseDocument.py} | 11 +- .../{ReplaceText.py => RotatingForwarder.py} | 11 +- .../resources/minifi-c2-server/config-ssl.json | 53 ---- .../resources/minifi-c2-server/config.json | 41 --- .../config.yml | 5 +- .../python/RotatingForwarder.py} | 35 +-- encrypt-config/CMakeLists.txt | 2 +- encrypt-config/tests/CMakeLists.txt | 2 +- examples/iOSPort/iOSPortREADME.md | 23 -- extensions/aws/CMakeLists.txt | 3 +- extensions/aws/tests/CMakeLists.txt | 2 +- extensions/azure/CMakeLists.txt | 2 +- extensions/azure/tests/CMakeLists.txt | 2 +- extensions/bustache/CMakeLists.txt | 2 +- extensions/bustache/tests/CMakeLists.txt | 2 +- extensions/civetweb/CMakeLists.txt | 2 +- extensions/civetweb/tests/CMakeLists.txt | 2 +- extensions/coap/CMakeLists.txt | 4 +- extensions/coap/tests/CMakeLists.txt | 2 +- extensions/elasticsearch/CMakeLists.txt | 2 +- extensions/elasticsearch/tests/CMakeLists.txt | 2 +- extensions/expression-language/CMakeLists.txt | 2 +- .../expression-language/tests/CMakeLists.txt | 4 +- extensions/gcp/CMakeLists.txt | 2 +- extensions/gcp/tests/CMakeLists.txt | 2 +- extensions/gps/CMakeLists.txt | 2 +- extensions/gps/tests/CMakeLists.txt | 2 +- extensions/grafana-loki/CMakeLists.txt | 7 +- extensions/grafana-loki/PushGrafanaLokiGrpc.h | 2 +- extensions/grafana-loki/tests/CMakeLists.txt | 4 +- extensions/http-curl/CMakeLists.txt | 2 +- extensions/http-curl/client/HTTPClient.h | 6 +- extensions/http-curl/tests/CMakeLists.txt | 4 +- extensions/jni/CMakeLists.txt | 2 +- extensions/kubernetes/CMakeLists.txt | 2 +- extensions/kubernetes/tests/CMakeLists.txt | 2 +- extensions/libarchive/CMakeLists.txt | 2 +- extensions/libarchive/tests/CMakeLists.txt | 2 +- extensions/librdkafka/CMakeLists.txt | 2 +- extensions/librdkafka/tests/CMakeLists.txt | 2 +- extensions/lua/CMakeLists.txt | 2 +- extensions/lua/LuaScriptExecutor.cpp | 1 + extensions/lua/LuaScriptExecutor.h | 1 + extensions/lua/tests/CMakeLists.txt | 2 +- extensions/mqtt/CMakeLists.txt | 2 +- extensions/mqtt/tests/CMakeLists.txt | 2 +- extensions/opc/CMakeLists.txt | 2 +- extensions/opencv/CMakeLists.txt | 2 +- extensions/opencv/tests/CMakeLists.txt | 2 +- extensions/openwsman/CMakeLists.txt | 2 +- extensions/pcap/CMakeLists.txt | 2 +- extensions/pcap/tests/CMakeLists.txt | 2 +- extensions/pdh/CMakeLists.txt | 2 +- extensions/pdh/tests/CMakeLists.txt | 2 +- extensions/procfs/CMakeLists.txt | 2 +- extensions/procfs/tests/CMakeLists.txt | 2 +- extensions/prometheus/CMakeLists.txt | 2 +- extensions/prometheus/tests/CMakeLists.txt | 2 +- extensions/python/CMakeLists.txt | 21 +- extensions/python/ExecutePythonProcessor.cpp | 54 +++- extensions/python/ExecutePythonProcessor.h | 29 ++- extensions/python/{README.md => PYTHON.md} | 61 ++++- extensions/python/PythonBindings.cpp | 9 +- extensions/python/PythonCreator.h | 42 ++- extensions/python/PythonObjectFactory.h | 28 +- extensions/python/PythonProcessor.cpp | 5 +- extensions/python/PythonProcessor.h | 4 +- extensions/python/PythonScriptEngine.cpp | 92 ++++++- extensions/python/PythonScriptEngine.h | 51 +++- extensions/python/PythonScriptExecutor.cpp | 5 +- extensions/python/PythonScriptExecutor.h | 1 + .../nifi_python_processors/__init__.py | 9 - .../python/pythonprocessors/nifiapi/__init__.py | 9 - .../pythonprocessors/nifiapi/documentation.py | 142 +++++++++++ .../pythonprocessors/nifiapi/flowfiletransform.py | 122 +++++++++ .../python/pythonprocessors/nifiapi/properties.py | 283 +++++++++++++++++++++ extensions/python/tests/CMakeLists.txt | 4 +- extensions/python/tests/PythonManifestTests.cpp | 4 +- .../PyDataConverter.cpp} | 33 +-- .../{PythonBindings.h => types/PyDataConverter.h} | 13 +- extensions/python/types/PyProcessContext.cpp | 30 ++- extensions/python/types/PyProcessSession.cpp | 134 +++++++++- extensions/python/types/PyProcessSession.h | 6 + extensions/python/types/PyProcessor.cpp | 29 ++- extensions/python/types/PyScriptFlowFile.cpp | 47 +++- extensions/python/types/PyScriptFlowFile.h | 2 + extensions/python/types/Types.h | 14 +- extensions/rocksdb-repos/CMakeLists.txt | 2 +- extensions/rocksdb-repos/tests/CMakeLists.txt | 2 +- extensions/script/CMakeLists.txt | 2 +- extensions/script/ExecuteScript.cpp | 2 +- extensions/script/ExecuteScript.h | 3 +- extensions/script/ScriptExecutor.h | 1 + extensions/script/tests/CMakeLists.txt | 2 +- extensions/sensors/CMakeLists.txt | 2 +- extensions/sensors/tests/CMakeLists.txt | 2 +- extensions/sftp/CMakeLists.txt | 2 +- extensions/sftp/tests/CMakeLists.txt | 2 +- extensions/sftp/tests/tools/CMakeLists.txt | 2 +- extensions/smb/CMakeLists.txt | 2 +- extensions/smb/tests/CMakeLists.txt | 2 +- extensions/splunk/CMakeLists.txt | 2 +- extensions/splunk/tests/CMakeLists.txt | 2 +- extensions/sql/CMakeLists.txt | 2 +- extensions/sql/tests/CMakeLists.txt | 4 +- extensions/standard-processors/CMakeLists.txt | 2 +- .../standard-processors/tests/CMakeLists.txt | 6 +- extensions/systemd/CMakeLists.txt | 2 +- extensions/systemd/tests/CMakeLists.txt | 2 +- extensions/test-processors/CMakeLists.txt | 2 +- extensions/usb-camera/CMakeLists.txt | 2 +- extensions/windows-event-log/CMakeLists.txt | 2 +- extensions/windows-event-log/tests/CMakeLists.txt | 2 +- libminifi/CMakeLists.txt | 16 +- libminifi/cmake/iOS.cmake | 225 ---------------- libminifi/include/FlowController.h | 5 +- libminifi/include/c2/C2Agent.h | 9 +- libminifi/include/controllers/SSLContextService.h | 2 +- libminifi/include/core/ConfigurableComponent.h | 11 +- libminifi/include/core/ProcessSession.h | 1 + libminifi/include/core/PropertyType.h | 14 + libminifi/include/core/TypedValues.h | 1 + libminifi/include/utils/SystemCpuUsageTracker.h | 14 +- libminifi/src/core/ConfigurableComponent.cpp | 52 ++-- libminifi/src/core/ProcessSession.cpp | 4 + libminifi/src/core/PropertyType.cpp | 25 ++ libminifi/src/provenance/Provenance.cpp | 4 +- libminifi/src/utils/SystemCpuUsageTracker.cpp | 5 +- libminifi/test/flow-tests/CMakeLists.txt | 2 +- libminifi/test/keyvalue-tests/CMakeLists.txt | 2 +- libminifi/test/persistence-tests/CMakeLists.txt | 2 +- libminifi/test/schema-tests/CMakeLists.txt | 2 +- minifi_main/CMakeLists.txt | 2 +- minifi_main/tests/CMakeLists.txt | 2 +- msi/WixWin.wsi | 69 ++++- msi/WixWinMergeModules.wsi | 85 +++++-- nanofi/CMakeLists.txt | 2 +- nanofi/ecu/CMakeLists.txt | 6 +- nanofi/examples/CMakeLists.txt | 10 +- run_flake8.sh | 2 +- 168 files changed, 1725 insertions(+), 1022 deletions(-) delete mode 100644 cmake/iOS.cmake copy docker/test/integration/minifi/processors/{ReplaceText.py => ChunkDocument.py} (78%) copy docker/test/integration/minifi/processors/{ReplaceText.py => ParseDocument.py} (78%) copy docker/test/integration/minifi/processors/{ReplaceText.py => RotatingForwarder.py} (80%) delete mode 100644 docker/test/integration/resources/minifi-c2-server/config-ssl.json delete mode 100644 docker/test/integration/resources/minifi-c2-server/config.json copy docker/test/integration/resources/{minifi-controller => minifi-c2-server}/config.yml (87%) copy docker/test/integration/{minifi/validators/EmptyFilesOutPutValidator.py => resources/python/RotatingForwarder.py} (52%) delete mode 100644 examples/iOSPort/iOSPortREADME.md rename extensions/python/{README.md => PYTHON.md} (52%) copy docker/test/integration/resources/python/sleep_forever.py => extensions/python/pythonprocessors/nifi_python_processors/__init__.py (86%) copy docker/test/integration/resources/python/sleep_forever.py => extensions/python/pythonprocessors/nifiapi/__init__.py (86%) create mode 100644 extensions/python/pythonprocessors/nifiapi/documentation.py create mode 100644 extensions/python/pythonprocessors/nifiapi/flowfiletransform.py create mode 100644 extensions/python/pythonprocessors/nifiapi/properties.py copy extensions/python/{PythonProcessor.cpp => types/PyDataConverter.cpp} (55%) copy extensions/python/{PythonBindings.h => types/PyDataConverter.h} (82%) delete mode 100644 libminifi/cmake/iOS.cmake