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 5a6853076 MINIFICPP-2432 Move the python processors to the examples
directory
new 5c058ce70 MINIFICPP-2349 FetchModbusTcp
new 5777a3b8f MINIFICPP-2411 Extend NiFi Python API to support source
processors
new 4ff993eb6 MINIFICPP-2374 Add python bootstrap support for fedora,
debian and openSUSE
new 68e09fa1b MINIFICPP-2428 Add targetUris field support for JSON flow
config
new e3fdae692 MINIFICPP-2438 Do not parse json response for acknowledge on
C2
The 5 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:
.gitignore | 1 +
PROCESSORS.md | 30 +++
bootstrap/package_manager.py | 47 +++-
docker/requirements.txt | 2 +-
docker/test/integration/cluster/ContainerStore.py | 9 +
.../test/integration/cluster/DockerTestCluster.py | 5 +
docker/test/integration/cluster/ImageStore.py | 9 +-
.../checkers/{GcsChecker.py => ModbusChecker.py} | 16 +-
.../{MqttBrokerContainer.py => DiagSlave.py} | 13 +-
.../features/MiNiFi_integration_test_driver.py | 3 +
.../integration/features/fetch_modbus_tcp.feature | 43 ++++
.../integration/features/minifi_c2_server.feature | 1 +
docker/test/integration/features/python.feature | 13 +
docker/test/integration/features/steps/steps.py | 23 ++
.../{ODBCService.py => JsonRecordSetWriter.py} | 13 +-
.../{RotatingForwarder.py => CreateFlowFile.py} | 11 +-
.../{PutGCSObject.py => FetchModbusTcp.py} | 10 +-
.../validators/SingleJSONFileOutputValidator.py | 2 +
.../integration/resources/diagslave/Dockerfile | 5 +
.../integration/resources/python/CreateFlowFile.py | 58 +++++
extensions/python/PYTHON.md | 2 +-
.../pythonprocessors/nifiapi/flowfilesource.py | 77 ++++++
.../pythonprocessors/nifiapi/flowfiletransform.py | 45 +---
.../{flowfiletransform.py => processorbase.py} | 62 +----
extensions/python/types/PyProcessSession.cpp | 51 +++-
extensions/python/types/PyProcessSession.h | 2 +
extensions/standard-processors/CMakeLists.txt | 2 +-
.../controllers/JsonRecordSetReader.cpp | 2 +-
.../standard-processors/modbus/ByteConverters.h | 50 ++++
extensions/standard-processors/modbus/Error.h | 77 ++++++
.../standard-processors/modbus/FetchModbusTcp.cpp | 275 +++++++++++++++++++++
.../standard-processors/modbus/FetchModbusTcp.h | 143 +++++++++++
.../modbus/ReadModbusFunctions.cpp | 238 ++++++++++++++++++
.../modbus/ReadModbusFunctions.h | 172 +++++++++++++
.../standard-processors/processors/PutTCP.cpp | 228 +++--------------
extensions/standard-processors/processors/PutTCP.h | 27 +-
.../standard-processors/tests/CMakeLists.txt | 4 +-
.../tests/unit/FlowJsonTests.cpp | 106 ++++++++
.../tests/unit/JsonRecordTests.cpp | 26 +-
.../tests/unit/modbus/ModbusTests.cpp | 259 +++++++++++++++++++
libminifi/include/core/Record.h | 11 +-
libminifi/include/core/RecordField.h | 24 +-
libminifi/include/utils/StringUtils.h | 17 ++
libminifi/include/utils/net/AsioSocketUtils.h | 8 +-
libminifi/include/utils/net/ConnectionHandler.h | 173 +++++++++++++
.../include/utils/net/ConnectionHandlerBase.h | 41 +++
libminifi/src/c2/protocols/RESTProtocol.cpp | 5 +-
libminifi/src/core/flow/FlowSchema.cpp | 2 +-
.../src/core/flow/StructuredConfiguration.cpp | 14 +-
libminifi/test/libtest/unit/Catch.h | 2 +-
libminifi/test/libtest/unit/TestRecord.h | 51 ++--
msi/WixWin.wsi.in | 2 +
52 files changed, 2112 insertions(+), 400 deletions(-)
copy docker/test/integration/cluster/checkers/{GcsChecker.py =>
ModbusChecker.py} (69%)
copy docker/test/integration/cluster/containers/{MqttBrokerContainer.py =>
DiagSlave.py} (79%)
create mode 100644 docker/test/integration/features/fetch_modbus_tcp.feature
copy docker/test/integration/minifi/controllers/{ODBCService.py =>
JsonRecordSetWriter.py} (71%)
copy docker/test/integration/minifi/processors/{RotatingForwarder.py =>
CreateFlowFile.py} (79%)
copy docker/test/integration/minifi/processors/{PutGCSObject.py =>
FetchModbusTcp.py} (77%)
create mode 100644 docker/test/integration/resources/diagslave/Dockerfile
create mode 100644 docker/test/integration/resources/python/CreateFlowFile.py
create mode 100644 extensions/python/pythonprocessors/nifiapi/flowfilesource.py
copy extensions/python/pythonprocessors/nifiapi/{flowfiletransform.py =>
processorbase.py} (58%)
create mode 100644 extensions/standard-processors/modbus/ByteConverters.h
create mode 100644 extensions/standard-processors/modbus/Error.h
create mode 100644 extensions/standard-processors/modbus/FetchModbusTcp.cpp
create mode 100644 extensions/standard-processors/modbus/FetchModbusTcp.h
create mode 100644
extensions/standard-processors/modbus/ReadModbusFunctions.cpp
create mode 100644 extensions/standard-processors/modbus/ReadModbusFunctions.h
create mode 100644
extensions/standard-processors/tests/unit/modbus/ModbusTests.cpp
create mode 100644 libminifi/include/utils/net/ConnectionHandler.h
create mode 100644 libminifi/include/utils/net/ConnectionHandlerBase.h
