This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch allow-original-file-name
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from f95c056b7 Merge branch 'dev' into allow-original-file-name
add e534038f1 monthly update of vulnerability report (#2115)
add d3b85c947 chore(deps-dev): bump webpack from 5.88.2 to 5.89.0 in /ui
(#2113)
add 0d692897a chore(deps): bump com.google.protobuf:protobuf-java (#2119)
add 509c5c08f Added two new tests for editing adapters and pipelines
(#2110)
add 2a7ac3fb2 improvement: Remove broker dependencies from extensions
management mo… (#2117)
add 2c60d526a 1980 arrays are not supported for s7 plcs (#2121)
add 552f3fed3 Improve startup behaviour (#2105)
add 62cbc71d0 chore(deps-dev): bump @angular-eslint/eslint-plugin-template
in /ui (#2127)
add 2225a7a31 chore(deps): bump org.mockito:mockito-core from 5.6.0 to
5.7.0 (#2126)
add 5c4206c4e feat(#2122): Reorganize extension modules and modify docker
images (#2124)
add dd990b7dd Use alpine-based Docker image for UI (#2129)
add f94ec1a93 improvement: Optimize startup behaviour (#2132)
add ab609ffbd chore(deps): remove org.wildfly.common:wildfly-common (#2125)
add 55a0d0e17 use os.environ dictionary to set environment variables
(#2138)
add 5a6bebad5 improvement: Harmonize minimal setup (#2134)
add 4b4fb8ef5 chore(deps-dev): bump eslint from 8.37.0 to 8.53.0 in /ui
(#2140)
add c86502114 New E2E test added for export/import pipelines (#2131)
add 72426133f feat(#2135): Max health check intervals configurable (#2136)
add 13eda3754 [prepare release] bump development version to
'0.95.0-SNAPSHOT'
add 023766f86 refactor(#2128): deprecate legacy adapters
add 0b26f5a77 refactor(#2128): remove tests as well
add e4bddb020 fix(#2002) Retry service registration in case services are
removed before migration (#2146)
add 8f0fd5039 chore(deps-dev): bump @types/node from 20.4.6 to 20.8.10 in
/ui (#2147)
add 577f40c6b chore: Maven housekeeping (#2145)
add b333351f0 chore(deps): bump swagger-ui from 4.18.0 to 5.9.1 in /ui
(#2150)
add a7d6ce56f chore(deps-dev): bump black in /streampipes-client-python
(#2159)
add b1daad120 remove deprecated methods of parameter extractor (#2156)
add e5bc3a288 [#1936] Adapter Deletion: Disallow Deletion of Pipelines
Using Adapter but Not Owned by User (#2139)
add 18b391611 dependencies(#2157): Clean up dependencies in dependency
management (#2158)
add 7f949542a chore(deps): remove org.eclipse.jetty:jetty-server (#2164)
add f31563b07 feat(#2161): Generate layered Docker images (#2162)
add 8bb9168c0 Add new test for editing dashboard (#2142)
add aa6d56966 feat: Provide default broker settings from environment
variables (#2169)
add 1306e7977 chore(deps-dev): bump mypy in /streampipes-client-python
(#2171)
add 18cdb2d4f bug(#2165): Fix migration for adapter instances (#2167)
add cf33f350a Merge remote-tracking branch 'origin/dev' into
allow-original-file-name
add e63c25f52 refactor: simplify file API
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 28 +-
VULNERABILITY.md | 5 +-
.../streampipes-archetype-extensions-jvm/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../streampipes-archetype-pe-sinks-flink/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
installer/compose/docker-compose.full.yml | 32 +-
...compose.full.yml => docker-compose.minimal.yml} | 120 +-
installer/k8s/Chart.yaml | 2 +-
installer/k8s/values.yaml | 2 +-
pom.xml | 1928 ++++-------
streampipes-client-api/pom.xml | 16 +-
.../apache/streampipes/client/api/IFileApi.java | 4 +-
...introduction-to-streampipes-python-client.ipynb | 5 +-
streampipes-client-python/poetry.lock | 97 +-
streampipes-client-python/pyproject.toml | 4 +-
streampipes-client/pom.xml | 27 +-
.../org/apache/streampipes/client/api/FileApi.java | 8 +
streampipes-commons/pom.xml | 14 +-
.../apache/streampipes/commons/constants/Envs.java | 25 +-
.../commons/environment/DefaultEnvironment.java | 60 +
.../commons/environment/Environment.java | 24 +
streampipes-config/pom.xml | 21 +-
.../streampipes/config/backend/BackendConfig.java | 6 -
streampipes-connect-management/pom.xml | 34 +-
.../management/health/AdapterHealthCheck.java | 12 +-
.../management/management/WorkerRestClient.java | 11 +-
streampipes-connect-shared/pom.xml | 10 +-
streampipes-data-explorer-commons/pom.xml | 15 +-
streampipes-data-explorer/pom.xml | 14 +-
streampipes-data-export/pom.xml | 10 +-
streampipes-dataformat-cbor/pom.xml | 6 +-
streampipes-dataformat-fst/pom.xml | 6 +-
streampipes-dataformat-json/pom.xml | 10 +-
streampipes-dataformat-smile/pom.xml | 6 +-
streampipes-dataformat/pom.xml | 4 +-
streampipes-extensions-api/pom.xml | 13 +-
.../api/declarer/IExtensionModuleExport.java | 35 +-
.../api/extractor/IParameterExtractor.java | 17 -
.../extensions/api/migration/IAdapterMigrator.java | 2 +-
...ataSinkMigrator.java => IDataSinkMigrator.java} | 2 +-
streampipes-extensions-management/pom.xml | 81 +-
.../connect/adapter/AdapterPipelineGenerator.java | 39 +-
.../elements/SendToBrokerAdapterSink.java | 44 +-
.../elements/SendToJmsAdapterSink.java | 42 -
.../elements/SendToKafkaAdapterSink.java | 43 -
.../elements/SendToMqttAdapterSink.java | 42 -
.../elements/SendToNatsAdapterSink.java | 43 -
.../elements/SendToPulsarAdapterSink.java | 43 -
.../model/SpServiceDefinitionBuilder.java | 17 +-
streampipes-extensions/pom.xml | 9 +-
.../streampipes-connect-adapters-iiot/pom.xml | 173 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 71 -
.../iiot/IIoTAdaptersExtensionModuleExport.java | 57 +
.../streampipes-connect-adapters/pom.xml | 114 +-
...a => GeneralAdaptersExtensionModuleExport.java} | 55 +-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 1 +
.../connect/adapters/coindesk/Currency.java | 1 +
.../connect/adapters/coindesk/model/Bpi.java | 1 +
.../adapters/coindesk/model/CoindeskRawModel.java | 1 +
.../connect/adapters/coindesk/model/EUR.java | 1 +
.../connect/adapters/coindesk/model/GBP.java | 1 +
.../connect/adapters/coindesk/model/Time.java | 1 +
.../connect/adapters/coindesk/model/USD.java | 1 +
.../connect/adapters/flic/FlicMQTTAdapter.java | 1 +
.../connect/adapters/flic/FlicOutput.java | 1 +
.../connect/adapters/flic/FlicUtils.java | 1 +
.../connect/adapters/gdelt/GdeltAdapter.java | 214 --
.../connect/adapters/iex/IexCloudAdapter.java | 51 -
.../connect/adapters/iex/IexCloudNewsAdapter.java | 119 -
.../connect/adapters/iex/IexCloudStockAdapter.java | 92 -
.../connect/adapters/iex/model/IexNewsData.java | 120 -
.../connect/adapters/iex/model/IexStockData.java | 410 ---
.../adapters/image/ZipFileImageIterator.java | 2 +-
.../adapters/sensemap/OpenSenseMapAdapter.java | 374 ---
.../connect/adapters/sensemap/SensorNames.java | 136 -
.../adapters/sensemap/model/CurrentLocation.java | 62 -
.../connect/adapters/sensemap/model/Geometry.java | 62 -
.../adapters/sensemap/model/LastMeasurement.java | 50 -
.../connect/adapters/sensemap/model/SenseBox.java | 122 -
.../connect/adapters/sensemap/model/Sensor.java | 90 -
.../connect/adapters/slack/SlackAdapter.java | 1 +
.../connect/adapters/slack/SlackConsumer.java | 1 +
.../connect/adapters/ti/TISensorTag.java | 1 +
.../adapters/wikipedia/WikipediaAdapter.java | 1 +
.../wikipedia/WikipediaEditedArticlesAdapter.java | 1 +
.../wikipedia/WikipediaModelConverter.java | 1 +
.../wikipedia/WikipediaNewArticlesAdapter.java | 1 +
.../adapters/wikipedia/WikipediaSseConsumer.java | 1 +
.../connect/adapters/wikipedia/model/Length.java | 1 +
.../connect/adapters/wikipedia/model/Meta.java | 1 +
.../connect/adapters/wikipedia/model/Revision.java | 1 +
.../adapters/wikipedia/model/WikipediaModel.java | 1 +
.../documentation.md | 36 -
.../icon.png | Bin 33450 -> 0 bytes
.../strings.en | 21 -
.../documentation.md | 42 -
.../icon.png | Bin 15675 -> 0 bytes
.../strings.en | 25 -
.../documentation.md | 41 -
.../icon.png | Bin 15675 -> 0 bytes
.../strings.en | 25 -
.../connect/adapters/PullAdapterTest.java | 53 -
.../generic/elements/DuplicateFilterTest.java | 130 -
.../generic/protocol/stream/HttpProtocolTest.java | 172 -
.../adapters/sensemap/OpenSenseMapAdapterTest.java | 134 -
.../connect/adapters/sensemap/SensorNamesTest.java | 56 -
.../connect/adapters/ti/TISensorTagTest.java | 58 -
.../streampipes-connectors-influx/pom.xml | 10 +-
.../connectors/influx/InfluxConnectorsInit.java | 62 -
.../influx/InfluxConnectorsModuleExport.java | 47 +
.../streampipes-connectors-kafka/pom.xml | 14 +-
.../kafka/KafkaConnectorsModuleExport.java | 50 +
.../streampipes-connectors-mqtt/pom.xml | 8 +-
.../mqtt/MqttConnectorsModuleExport.java | 50 +
.../streampipes-connectors-nats/pom.xml | 10 +-
.../nats/NatsConnectorsModuleExport.java | 50 +
.../streampipes-connectors-opcua/pom.xml | 14 +-
.../opcua/OpcUaConnectorsModuleExport.java | 52 +
.../opcua/config/SpOpcUaConfigExtractor.java | 2 +-
.../pom.xml | 46 +-
.../connectors/plc/PlcConnectorsModuleExport.java | 52 +
.../migration/Plc4xS7AdapterMigrationV1.java | 87 +
.../plc/adapter}/modbus/ModbusConfigFile.java | 4 +-
.../plc/adapter}/modbus/Plc4xModbusAdapter.java | 2 +-
.../connectors/plc/adapter}/s7/Plc4xS7Adapter.java | 194 +-
.../plc/adapter}/s7/PlcReadResponseHandler.java | 2 +-
.../plc/adapter/s7/config/ConfigurationParser.java | 101 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 14 +-
.../adapter/s7/config/ConfigurationParserTest.java | 106 +
.../streampipes-connectors-pulsar/pom.xml | 8 +-
.../pulsar/PulsarConnectorsModuleExport.java | 51 +
.../streampipes-connectors-rocketmq/pom.xml | 8 +-
.../rocketmq/RocketMqConnectorsModuleExport.java | 51 +
.../streampipes-connectors-tubemq/pom.xml | 24 +-
.../tubemq/TubeMQConnectorsModuleExport.java | 51 +
.../streampipes-extensions-all-iiot/Dockerfile | 17 +-
.../streampipes-extensions-all-iiot/pom.xml | 133 +-
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 78 +-
.../streampipes-extensions-all-jvm/Dockerfile | 14 +-
.../streampipes-extensions-all-jvm/pom.xml | 204 +-
.../extensions/all/jvm/AllExtensionsInit.java | 68 +-
.../Dockerfile | 14 +-
.../pom.xml | 170 +-
.../iiot/minimal/ExtensionsIIoTMinimalInit.java | 88 +
.../Dockerfile | 23 -
.../development/env | 26 -
.../pe/jvm/AllPipelineElementsInit.java | 84 -
.../pom.xml | 88 -
.../pe/simulator/StreamPipesSimulationRunner.java | 115 -
.../pom.xml | 16 +-
.../streampipes-pipeline-elements-shared/pom.xml | 4 +-
.../pom.xml | 8 +-
.../jvm/ChangeDetectionExtensionModuleExport.java | 48 +
.../jvm/ChangeDetectionJvmInit.java | 62 -
.../streampipes-processors-enricher-jvm/pom.xml | 8 +-
.../jvm/EnricherExtensionModuleExport.java | 55 +
.../processors/enricher/jvm/EnricherJvmInit.java | 69 -
.../streampipes-processors-filters-jvm/pom.xml | 10 +-
...mInit.java => FilterExtensionModuleExport.java} | 77 +-
.../streampipes-processors-filters-siddhi/pom.xml | 21 +-
.../processors/siddhi/FiltersSiddhiInit.java | 71 -
.../siddhi/SiddhiFilterExtensionModuleExport.java | 57 +
.../streampipes-processors-geo-jvm/pom.xml | 13 +-
.../geo/jvm/GeoExtensionModuleExport.java | 82 +
.../streampipes/processors/geo/jvm/GeoJvmInit.java | 112 -
.../pom.xml | 8 +-
.../jvm/ImageProcessingExtensionModuleExport.java | 53 +
.../jvm/ImageProcessingJvmInit.java | 62 -
.../streampipes-processors-text-mining-jvm/pom.xml | 13 +-
.../jvm/TextMiningExtensionModuleExport.java | 56 +
.../textmining/jvm/TextMiningJvmInit.java | 69 -
.../jvm/processor/chunker/ChunkerProcessor.java | 2 +-
.../language/LanguageDetectionProcessor.java | 2 +-
.../processor/namefinder/NameFinderProcessor.java | 2 +-
.../partofspeech/PartOfSpeechProcessor.java | 2 +-
.../SentenceDetectionProcessor.java | 2 +-
.../processor/tokenizer/TokenizerProcessor.java | 2 +-
.../pom.xml | 10 +-
...va => TransformationExtensionModuleExport.java} | 100 +-
.../CsvMetadataEnrichmentProcessor.java | 6 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 31 +-
.../jvm/BrokerSinksExtensionModuleExport.java | 55 +
.../sinks/brokers/jvm/BrokersJvmInit.java | 68 -
.../streampipes-sinks-databases-jvm/pom.xml | 53 +-
.../jvm/DatabaseSinksExtensionModuleExport.java | 55 +
.../sinks/databases/jvm/DatabasesJvmInit.java | 70 -
.../streampipes-sinks-internal-jvm/pom.xml | 12 +-
.../jvm/InternalSinksExtensionModuleExports.java | 49 +
.../sinks/internal/jvm/SinksInternalJvmInit.java | 60 -
.../streampipes-sinks-notifications-jvm/pom.xml | 14 +-
.../jvm/NotificationsExtensionModuleExport.java | 53 +
.../jvm/SinksNotificationsJvmInit.java | 64 -
streampipes-integration-tests/pom.xml | 33 +-
streampipes-mail/pom.xml | 15 +-
streampipes-maven-plugin/README.md | 2 +-
streampipes-maven-plugin/pom.xml | 4 +-
streampipes-measurement-units/pom.xml | 4 +-
streampipes-messaging-jms/pom.xml | 4 +-
streampipes-messaging-kafka/pom.xml | 6 +-
streampipes-messaging-mqtt/pom.xml | 4 +-
streampipes-messaging-nats/pom.xml | 4 +-
streampipes-messaging-pulsar/pom.xml | 4 +-
streampipes-messaging/pom.xml | 4 +-
streampipes-model-client/pom.xml | 6 +-
streampipes-model-shared/pom.xml | 2 +-
streampipes-model/pom.xml | 8 +-
.../configuration/DefaultMessagingSettings.java | 16 +-
.../model/configuration/SpCoreConfiguration.java | 9 +
.../configuration/SpCoreConfigurationStatus.java | 8 +-
.../adapter/migration/MigrationHelpers.java | 4 +
.../svcdiscovery/SpServiceRegistration.java | 18 +-
.../extensions/svcdiscovery/SpServiceStatus.java | 12 +-
.../model/graph/DataProcessorInvocation.java | 1 +
.../model/graph/DataSinkInvocation.java | 1 +
streampipes-pipeline-management/pom.xml | 41 +-
.../manager/endpoint/EndpointItemFetcher.java | 6 +-
.../ExtensionsServiceEndpointGenerator.java | 2 +-
.../health/CoreInitialInstallationProgress.java | 17 +-
.../manager/health/CoreServiceStatusManager.java | 59 +
.../manager/health/PipelineHealthCheck.java | 21 +-
.../manager/health/ServiceHealthCheck.java | 42 +-
.../manager/health/ServiceRegistrationManager.java | 104 +
.../migration/AdapterDescriptionMigration093.java | 73 +
.../AdapterDescriptionMigration093Provider.java | 26 +-
.../migration/PipelineElementMigrationManager.java | 143 +-
.../manager/setup/AutoInstallation.java | 2 -
.../manager/setup/SpCoreConfigurationStep.java | 10 +-
.../manager/setup/StreamPipesEnvChecker.java | 2 +-
streampipes-platform-services/pom.xml | 12 +-
streampipes-resource-management/pom.xml | 8 +-
streampipes-rest-core-base/pom.xml | 10 +-
streampipes-rest-extensions/pom.xml | 24 +-
.../migration/AdapterMigrationResource.java | 3 -
.../migration/DataProcessorMigrationResource.java | 3 -
.../migration/DataSinkMigrationResource.java | 7 +-
streampipes-rest-shared/pom.xml | 6 +-
streampipes-rest/pom.xml | 43 +-
.../org/apache/streampipes/rest/impl/Setup.java | 15 +-
.../rest/impl/admin/MigrationResource.java | 73 +-
.../impl/admin/ServiceRegistrationResource.java | 12 +-
.../rest/impl/connect/AdapterResource.java | 56 +-
streampipes-sdk-bundle/pom.xml | 22 +-
streampipes-sdk/pom.xml | 19 +-
.../apache/streampipes/sdk/StaticProperties.java | 31 +-
...AbstractConfigurablePipelineElementBuilder.java | 8 +-
.../sdk/extractor/AbstractParameterExtractor.java | 56 -
.../streampipes/sdk/StaticPropertiesTest.java | 30 +-
streampipes-security-jwt/pom.xml | 8 +-
streampipes-serializers-json/pom.xml | 8 +-
streampipes-service-base/pom.xml | 72 +-
.../Dockerfile | 14 +-
.../pom.xml | 22 +-
.../minimal/StreamPipesCoreApplicationMinimal.java | 10 +-
streampipes-service-core-nats/Dockerfile | 20 -
streampipes-service-core/Dockerfile | 14 +-
streampipes-service-core/pom.xml | 66 +-
.../streampipes/service/core/PostStartupTask.java | 7 +-
.../service/core/StreamPipesCoreApplication.java | 100 +-
.../core/migrations/v093/AdapterMigration.java | 33 +-
.../migrations/v093/ConsulConfigMigration.java | 2 +
.../v093/migrator/SpecificAdapterMigrator.java | 2 +
.../src/main/resources/openapi.yaml | 2 +-
streampipes-service-discovery-api/pom.xml | 4 +-
streampipes-service-discovery-consul/pom.xml | 10 +-
streampipes-service-discovery/pom.xml | 10 +-
.../svcdiscovery/SpServiceDiscoveryCore.java | 5 +-
streampipes-service-extensions/pom.xml | 24 +-
.../service/extensions/CoreRequestSubmitter.java | 91 +
.../extensions/ExtensionsModelSubmitter.java | 6 +-
.../StreamPipesExtensionsServiceBase.java | 27 +-
.../extensions/security/WebSecurityConfig.java | 4 +-
streampipes-storage-api/pom.xml | 8 +-
.../storage/api/ISpCoreConfigurationStorage.java | 2 +
.../streampipes/storage/api/IUserStorage.java | 2 +
streampipes-storage-couchdb/pom.xml | 19 +-
.../couchdb/impl/CoreConfigurationStorageImpl.java | 5 +
.../storage/couchdb/impl/UserStorage.java | 13 +
.../streampipes/storage/couchdb/utils/Utils.java | 17 +-
streampipes-storage-management/pom.xml | 6 +-
streampipes-test-utils/pom.xml | 8 +-
streampipes-user-management/pom.xml | 14 +-
streampipes-vocabulary/pom.xml | 2 +-
streampipes-wrapper-distributed/pom.xml | 18 +-
streampipes-wrapper-flink/pom.xml | 42 +-
streampipes-wrapper-kafka-streams/pom.xml | 4 +-
streampipes-wrapper-siddhi/pom.xml | 26 +-
streampipes-wrapper-standalone/pom.xml | 4 +-
streampipes-wrapper/pom.xml | 14 +-
ui/Dockerfile | 2 +-
.../support/builder/PipelineElementBuilder.ts | 3 +-
ui/cypress/support/utils/PipelineUtils.ts | 4 +
ui/cypress/tests/adapter/editAdapter.smoke.spec.ts | 1 -
.../adapter/editAdapterSettingsAndPipeline.spec.ts | 113 +
.../adapter/editAdapterValuesAndFields.spec.ts | 133 +
.../tests/dashboard/editDashboardTest.spec.ts | 73 +
ui/cypress/tests/pipeline/pipelineExport.spec.ts | 79 +
ui/package-lock.json | 3518 +++++++++++---------
ui/package.json | 12 +-
.../src/lib/model/gen/streampipes-model.ts | 13 +-
.../registered-extensions-services.component.html | 7 +-
...adapter-started-update-migration.component.html | 7 +-
.../delete-adapter-dialog.component.html | 29 +-
.../delete-adapter-dialog.component.ts | 10 +-
.../overview/dashboard-overview.component.html | 1 +
.../widget/dashboard-widget.component.html | 7 +-
.../add-visualization-dialog.component.html | 1 +
.../pipeline-element-options.component.html | 1 +
.../pipeline-overview.component.html | 9 +-
.../import-pipeline-dialog.component.html | 1 +
ui/src/app/pipelines/pipelines.component.html | 2 +
318 files changed, 7092 insertions(+), 9072 deletions(-)
copy installer/compose/{docker-compose.full.yml => docker-compose.minimal.yml}
(52%)
rename
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Loc.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/IExtensionModuleExport.java
(55%)
rename
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/{DataSinkMigrator.java
=> IDataSinkMigrator.java} (90%)
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToJmsAdapterSink.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToKafkaAdapterSink.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToMqttAdapterSink.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToNatsAdapterSink.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/SendToPulsarAdapterSink.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/ConnectAdapterIiotInit.java
create mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/IIoTAdaptersExtensionModuleExport.java
rename
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/{ConnectAdapterInit.java
=> GeneralAdaptersExtensionModuleExport.java} (56%)
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/gdelt/GdeltAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudNewsAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudStockAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexNewsData.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexStockData.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/SensorNames.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/CurrentLocation.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Geometry.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/LastMeasurement.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/SenseBox.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Sensor.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/PullAdapterTest.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/generic/elements/DuplicateFilterTest.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/generic/protocol/stream/HttpProtocolTest.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapterTest.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/sensemap/SensorNamesTest.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/ti/TISensorTagTest.java
delete mode 100644
streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/InfluxConnectorsInit.java
create mode 100644
streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/InfluxConnectorsModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/KafkaConnectorsModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/MqttConnectorsModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/NatsConnectorsModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/OpcUaConnectorsModuleExport.java
copy streampipes-extensions/{streampipes-connectors-opcua =>
streampipes-connectors-plc}/pom.xml (67%)
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/PlcConnectorsModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/migration/Plc4xS7AdapterMigrationV1.java
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/plc4x
=>
streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter}/modbus/ModbusConfigFile.java
(95%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/plc4x
=>
streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter}/modbus/Plc4xModbusAdapter.java
(99%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/plc4x
=>
streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter}/s7/Plc4xS7Adapter.java
(64%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/plc4x
=>
streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter}/s7/PlcReadResponseHandler.java
(93%)
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/s7/config/ConfigurationParser.java
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-plc}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-plc}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-plc}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus/strings.en
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-plc}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.s7/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-plc}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.s7/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-plc}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.s7/strings.en
(74%)
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/test/java/org/apache/streampipes/extensions/connectors/plc/adapter/s7/config/ConfigurationParserTest.java
create mode 100644
streampipes-extensions/streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/PulsarConnectorsModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/RocketMqConnectorsModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/TubeMQConnectorsModuleExport.java
rename streampipes-extensions/{streampipes-connect-adapters =>
streampipes-extensions-iiot-minimal}/Dockerfile (65%)
rename streampipes-extensions/{streampipes-pipeline-elements-all-jvm =>
streampipes-extensions-iiot-minimal}/pom.xml (51%)
create mode 100644
streampipes-extensions/streampipes-extensions-iiot-minimal/src/main/java/org/apache/streampipes/extensions/iiot/minimal/ExtensionsIIoTMinimalInit.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-all-jvm/Dockerfile
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-all-jvm/development/env
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-data-simulator/pom.xml
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/StreamPipesSimulationRunner.java
create mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/ChangeDetectionExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/ChangeDetectionJvmInit.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherJvmInit.java
rename
streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/{FiltersJvmInit.java
=> FilterExtensionModuleExport.java} (50%)
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/FiltersSiddhiInit.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/SiddhiFilterExtensionModuleExport.java
create mode 100644
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/GeoExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/GeoJvmInit.java
create mode 100644
streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/ImageProcessingExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/ImageProcessingJvmInit.java
create mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/TextMiningExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/TextMiningJvmInit.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/{TransformationJvmInit.java
=> TransformationExtensionModuleExport.java} (55%)
create mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokerSinksExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java
create mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/DatabaseSinksExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/DatabasesJvmInit.java
create mode 100644
streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/InternalSinksExtensionModuleExports.java
delete mode 100644
streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/SinksInternalJvmInit.java
create mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/NotificationsExtensionModuleExport.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/SinksNotificationsJvmInit.java
rename
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/config/ConfigKeys.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/SpCoreConfigurationStatus.java
(83%)
copy
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/svcdiscovery/SpServiceStatus.java
(85%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IFileApi.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/CoreInitialInstallationProgress.java
(71%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/CoreServiceStatusManager.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/ServiceRegistrationManager.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093.java
rename
streampipes-extensions/streampipes-pipeline-elements-data-simulator/src/main/java/org/apache/streampipes/pe/simulator/TopicAwareWorkflow.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
(59%)
rename
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/generic/elements/AddTimestampTest.java
=>
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/StaticPropertiesTest.java
(51%)
rename {streampipes-extensions/streampipes-connect-adapters-iiot =>
streampipes-service-core-minimal}/Dockerfile (66%)
rename {streampipes-service-core-nats =>
streampipes-service-core-minimal}/pom.xml (85%)
rename
streampipes-service-core-nats/src/main/java/org/apache/streampipes/service/core/nats/StreamPipesCoreApplicationNats.java
=>
streampipes-service-core-minimal/src/main/java/org/apache/streampipes/service/core/minimal/StreamPipesCoreApplicationMinimal.java
(84%)
delete mode 100644 streampipes-service-core-nats/Dockerfile
create mode 100644
streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/CoreRequestSubmitter.java
create mode 100644
ui/cypress/tests/adapter/editAdapterSettingsAndPipeline.spec.ts
create mode 100644 ui/cypress/tests/adapter/editAdapterValuesAndFields.spec.ts
create mode 100644 ui/cypress/tests/dashboard/editDashboardTest.spec.ts
create mode 100644 ui/cypress/tests/pipeline/pipelineExport.spec.ts
