You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2024/03/29 21:25:23 UTC
(streampipes) 01/04: Merge branch 'dev' into bump-angular-eslint
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch bump-angular-eslint
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 07799401ee05b7b10d456b2f9a4b1b62c110efba
Merge: fe26d5187a aaf6018ae3
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Sun Mar 17 21:47:37 2024 +0100
Merge branch 'dev' into bump-angular-eslint
docker-compose.yml | 3 +
pom.xml | 54 +-
.../apache/streampipes/client/api/IFileApi.java | 3 +
streampipes-client-python/docs/index.md | 13 -
streampipes-client-python/poetry.lock | 7351 +++++++++++---------
streampipes-client-python/pyproject.toml | 6 +-
.../streampipes/endpoint/api/data_lake_measure.py | 2 +-
.../streampipes/endpoint/endpoint.py | 4 +-
.../streampipes/functions/function_handler.py | 24 +-
.../streampipes/functions/streampipes_function.py | 3 +-
.../streampipes/model/common.py | 2 +-
.../model/container/resource_container.py | 2 +-
.../model/resource/data_lake_measure.py | 2 +-
.../streampipes/model/resource/data_series.py | 2 +-
.../streampipes/model/resource/data_stream.py | 7 +-
.../model/resource/function_definition.py | 2 +-
.../streampipes/model/resource/query_result.py | 2 +-
.../streampipes/model/resource/version.py | 2 +-
.../tests/client/test_endpoint.py | 2 +-
streampipes-client/pom.xml | 4 +-
.../org/apache/streampipes/client/api/FileApi.java | 44 +-
.../client/util/StreamPipesApiPathTest.java | 13 +-
streampipes-commons/pom.xml | 9 +-
.../streampipes/commons/file/FileHasher.java} | 22 +-
.../commons/parser/BooleanParserTest.java | 16 +-
.../commons/parser/FloatParserTest.java | 12 +-
.../commons/parser/IntegerParserTest.java | 12 +-
.../commons/parser/StringParserTest.java | 4 +-
.../prometheus/adapter/AdapterMetricsTest.java | 13 +-
.../commons/resources/TestResources.java | 7 +-
streampipes-connect-management/pom.xml | 4 +-
.../management/health/AdapterHealthCheck.java | 8 +-
.../management/health/AdapterHealthCheckTest.java | 17 +-
.../management/AdapterMasterManagementTest.java | 25 +-
.../management/SourcesManagementTest.java | 16 +-
streampipes-connect-shared/pom.xml | 6 +-
.../connect/shared/preprocessing/UtilsTest.java | 11 +-
.../convert/ToOriginalSchemaConverterTest.java | 25 +-
.../convert/ToTransformedSchemaConverterTest.java | 30 +-
.../AdapterTransformationPipelineElementTest.java | 14 +-
.../preprocessing/transform/DatatypeUtilsTest.java | 31 +-
.../schema/CreateNestedTransformationRuleTest.java | 21 +-
.../schema/DeleteTransformationRuleTest.java | 11 +-
.../schema/MoveTransformationRuleTest.java | 28 +-
.../schema/RenameTransformationRuleTest.java | 18 +-
.../schema/SchemaEventTransformerTest.java | 23 +-
.../transform/value/CorrectionValueTest.java | 38 +-
.../transform/value/UnitTransformRuleTest.java | 36 +-
.../transform/value/ValueEventTransformerTest.java | 7 +-
streampipes-data-explorer-commons/pom.xml | 4 +-
.../commons/influx/InfluxClientProviderTest.java | 17 +-
.../commons/influx/InfluxStoreTest.java | 13 +-
.../influx/serializer/TestRawFieldSerializer.java | 6 +-
.../sanitizer/MeasureNameSanitizerTest.java | 11 +-
streampipes-data-explorer/pom.xml | 17 +-
.../param/ProvidedRestQueryParams.java | 2 +-
.../DataExplorerSchemaManagementTest.java | 12 +-
.../dataexplorer/param/SelectQueryParamsTest.java | 4 +-
.../param/WhereStatementParamsTest.java | 4 +-
.../writer/TestConfiguredCsvOutputWriter.java | 4 +-
.../writer/TestConfiguredJsonOutputWriter.java | 4 +-
.../query/writer/TestConfiguredOutputWriter.java | 4 +-
.../query/writer/item/TestCsvItemWriter.java | 4 +-
.../query/writer/item/TestItemWriter.java | 4 +-
.../query/writer/item/TestJsonItemWriter.java | 4 +-
.../dataexplorer/sdk/DataLakeQueryBuilderTest.java | 4 +-
streampipes-extensions-management/pom.xml | 19 +-
.../connect/adapter/BrokerEventProcessor.java | 12 +-
.../connect/AdapterWorkerManagementTest.java | 8 +-
.../ConnectWorkerDescriptionProviderTest.java | 19 +-
.../management/connect/GuessManagementTest.java | 10 +-
.../management/connect/adapter/TestUtils.java | 9 -
.../connect/adapter/parser/CsvParserTest.java | 14 +-
.../connect/adapter/parser/XmlParserTest.java | 4 +-
.../adapter/parser/json/GeoJsonParserTest.java | 9 +-
.../parser/json/JsonArrayKeyParserTest.java | 21 +-
.../adapter/parser/json/JsonArrayParserTest.java | 9 +-
.../adapter/parser/json/JsonObjectParsersTest.java | 17 +-
.../management/init/DeclarersSingletonTest.java | 9 +-
.../management/locales/LabelGeneratorTest.java | 10 +-
.../model/SpServiceDefinitionBuilderTest.java | 27 +-
.../management/util/EventSchemaUtilsTest.java | 17 +-
.../streampipes-connect-adapters-iiot/pom.xml | 31 +-
.../iiot/IIoTAdaptersExtensionModuleExport.java | 2 +
.../iiot/adapters/oi4/OI4AdapterLabels.java | 35 +
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 388 ++
.../iiot/adapters/oi4/model/DataSetMessage.java | 39 +-
.../iiot/adapters/oi4/model/NetworkMessage.java | 35 +-
.../iiot/protocol/stream/FileReplayAdapter.java | 171 +-
.../connect/iiot/utils/FileProtocolUtils.java | 40 +-
.../documentation.md | 81 +
.../icon.png | Bin 0 -> 2747 bytes
.../strings.en | 74 +
.../adapters/iolink}/sensor/SensorVVB001Test.java | 28 +-
.../RosBridgeAdapterMigrationV1Test.java | 10 +-
.../streampipes-connect-adapters/pom.xml | 27 +-
.../streampipes-connectors-opcua/pom.xml | 8 +-
.../adapter/OpcUaNodeMetadataExtractorTest.java | 69 +-
.../migration/OpcUaAdapterMigrationV2Test.java | 10 +-
.../connectors/opcua/utils/OpcUaUtilTest.java | 9 +-
.../streampipes-connectors-plc/pom.xml | 4 +-
.../migration/Plc4xModbusAdapterMigrationTest.java | 8 +-
.../adapter/s7/config/ConfigurationParserTest.java | 11 +-
.../streampipes-connectors-pulsar/pom.xml | 6 +-
.../connectors/pulsar/TestPulsarParameters.java | 25 +-
.../connectors/pulsar/TestPulsarPublisherSink.java | 44 +-
.../streampipes-connectors-rocketmq/pom.xml | 5 +-
.../rocketmq/TestRocketMQPublisherSink.java | 2 +-
.../streampipes-processors-enricher-jvm/pom.xml | 12 +
.../sizemeasure/TestSizeMeasureProcessor.java | 221 +-
.../streampipes-processors-filters-jvm/pom.xml | 17 +
.../booleanfilter/BooleanFilterProcessor.java | 8 +-
.../booleanfilter/TestBooleanFilterProcessor.java | 140 +-
.../processor/compose/TestComposeProcessor.java | 257 +-
.../processor/merge/TestMergeByTimeProcessor.java | 312 +-
.../TestSwingingDoorTrendingFilterProcessor.java | 287 +-
.../textfilter/TestTextFilterProcessor.java | 220 +-
.../streampipes-processors-filters-siddhi/pom.xml | 4 +-
.../siddhi/trend/TestTrendProcessor.java | 302 +-
.../pom.xml | 4 +-
.../counter/TestBooleanCounterProcessor.java | 279 +-
.../inverter/TestBooleanInverterProcessor.java | 244 +-
.../datetime/TestDateTimeFromStringProcessor.java | 423 +-
.../StaticMetaDataEnrichmentProcessorTest.java | 10 +-
.../counter/TestStringCounterProcessor.java | 288 +-
.../state/TestStringToStateProcessor.java | 339 +-
.../timer/TestStringTimerProcessor.java | 349 +-
.../change/TestChangedValueDetectionProcessor.java | 17 +-
.../streampipes-sinks-databases-jvm/pom.xml | 4 +-
.../streampipes-sinks-internal-jvm/pom.xml | 4 +-
.../migrations/DataLakeSinkMigrationV1Test.java | 19 +-
.../streampipes-sinks-notifications-jvm/pom.xml | 5 +
.../jvm/NotificationsExtensionModuleExport.java | 9 +-
.../migrations/INotificationDataSinkMigrator.java | 44 +
.../jvm/migrations/OneSignalSinkMigrationV1.java | 30 +-
.../SlackNotificationSinkMigrationV1.java | 30 +-
.../jvm/migrations/TelegramSinkMigrationV1.java | 30 +-
.../notifications/jvm/onesignal/OneSignalSink.java | 18 +-
.../jvm/slack/SlackNotificationSink.java | 18 +-
.../notifications/jvm/telegram/TelegramSink.java | 17 +-
.../INotificationDataSinkMigratorTest.java | 55 +
.../notifications/jvm/msteams/TestMSTeamsSink.java | 28 +-
streampipes-integration-tests/pom.xml | 37 +-
.../integration/adapters/AdapterTesterBase.java | 4 +-
.../integration/adapters/AdaptersTest.java | 2 +-
.../integration/client/ClientLiveDataTest.java | 2 +-
.../client/ClientLiveDataTesterBase.java | 4 +-
streampipes-maven-plugin/pom.xml | 32 +-
.../smp/generator/TestMarkdownTitleRemover.java | 2 +-
.../smp/parser/TestDocumentationParser.java | 4 +-
streampipes-measurement-units/pom.xml | 5 +-
.../streampipes/units/test/TestUnitProvider.java | 9 +-
streampipes-model/pom.xml | 6 +-
.../model/graph/PipelineElementContainer.java | 49 -
.../model/assets/AssetLinkBuilderTest.java | 27 +-
.../model/builder/TestStreamBuilder.java | 23 -
.../connect/adapter/AdapterDescriptionTest.java | 18 +-
.../model/datalake/DataLakeMeasureTest.java | 11 +-
.../model/datalake/DataSeriesBuilderTest.java | 33 +-
.../model/datalake/SpQueryResultBuilderTest.java | 41 +-
.../model/migration/ModelMigratorConfigTest.java | 33 +-
.../streampipes/model/runtime/TestEvent.java | 48 +-
.../model/runtime/TestEventConverter.java | 24 +-
.../model/runtime/TestEventFactory.java | 25 +-
.../model/runtime/TestFieldAddition.java | 17 +-
.../streampipes/model/runtime/TestListField.java | 13 +-
.../model/runtime/TestPropertyRenaming.java | 25 +-
.../streampipes/model/runtime/TestSubset.java | 28 +-
streampipes-pipeline-management/pom.xml | 19 +-
.../streampipes/manager/file/FileManager.java | 35 +-
.../migration/AdapterDescriptionMigration093.java | 73 -
.../manager/assets/TestImagePathReplacer.java | 7 +-
.../streampipes/manager/file/TestFileManager.java | 11 +-
.../manager/matching/v2/ListPropertyMatchTest.java | 9 +-
.../manager/matching/v2/TestDatatypeMatch.java | 12 +-
.../matching/v2/TestDomainPropertyMatch.java | 10 +-
.../manager/matching/v2/TestFormatMatch.java | 10 +-
.../manager/matching/v2/TestGroundingMatch.java | 14 +-
.../matching/v2/TestMeasurementUnitMatch.java | 7 +-
.../matching/v2/TestPrimitivePropertyMatch.java | 12 +-
.../manager/matching/v2/TestProtocolMatch.java | 10 +-
.../manager/matching/v2/TestSchemaMatch.java | 14 +-
.../manager/migration/MigrationUtilsTest.java | 28 +-
.../manager/pipeline/TestPipelineManager.java | 80 -
.../manager/selector/TestPropertyRenaming.java | 7 +-
.../streampipes/manager/selector/TestSelector.java | 38 +-
.../manager/selector/TestSelectorGenerator.java | 10 +-
.../apache/streampipes/ps/DataLakeResourceV3.java | 46 -
.../apache/streampipes/ps/DataLakeResourceV4.java | 3 +-
.../ps/PipelineElementTemplateResource.java | 166 +-
streampipes-resource-management/pom.xml | 4 +-
.../management/AdapterResourceManagerTest.java | 2 +-
.../management/DataStreamResourceManagerTest.java | 2 +-
streampipes-rest-extensions/pom.xml | 7 +
.../migration/MigrateExtensionsResourceTest.java | 31 +-
streampipes-rest-shared/pom.xml | 4 +-
streampipes-rest/pom.xml | 14 +-
.../streampipes/rest/impl/PipelineElementFile.java | 38 +-
.../admin/ExtensionsServiceEndpointResource.java | 30 +-
.../rest/impl/admin/MigrationResource.java | 6 +-
streampipes-sdk/pom.xml | 4 +-
.../streampipes/sdk/StaticPropertiesTest.java | 11 +-
.../sdk/builder/NestedPropertyBuilderTest.java | 38 +-
.../adapter/AdapterConfigurationBuilderTest.java | 23 +-
.../builder/adapter/AdapterConfigurationTest.java | 7 +-
.../extractor/AdapterParameterExtractorTest.java | 6 +-
.../apache/streampipes/sdk/helpers/LabelsTest.java | 9 +-
streampipes-serializers-json/pom.xml | 4 +-
.../serializers/json/TestJacksonSerializer.java | 27 +-
streampipes-service-core/pom.xml | 10 +-
.../streampipes/service/core/PostStartupTask.java | 2 +
...eFilenamesAndRenameDuplicatesMigrationTest.java | 28 +-
streampipes-storage-couchdb/pom.xml | 4 +-
.../couchdb/serializer/TestGsonSerializer.java | 27 +-
.../storage/couchdb/utils/TestUrlEscapers.java | 9 +-
streampipes-test-utils/pom.xml | 13 +-
streampipes-user-management/pom.xml | 4 +-
.../user/management/util/TestPasswordUtil.java | 12 +-
.../user/management/util/TestTokenUtil.java | 23 +-
.../standalone/StreamPipesNotificationSink.java | 4 +-
ui/Dockerfile | 7 +
.../tests/datalake/timeRangeSelectors.spec.ts | 125 +
.../userManagement/testUserRoleConnect.spec.ts | 62 +
ui/deployment/app-routing.module.mst | 2 +-
ui/docker-entrypoint.sh | 19 +-
ui/package-lock.json | 8 +-
ui/package.json | 2 +-
ui/src/app/_guards/page-auth.can-active.guard.ts | 7 +-
ui/src/app/add/add.module.ts | 2 +-
ui/src/app/app-overview/app-overview.module.ts | 2 +-
ui/src/app/assets/assets.module.ts | 2 +-
ui/src/app/configuration/configuration.module.ts | 2 +-
.../existing-adapters.component.html | 1 +
.../existing-adapters.component.ts | 2 +-
ui/src/app/connect/connect.module.ts | 8 +-
ui/src/app/core-ui/core-ui.module.ts | 11 +
.../dialog => core-ui}/help/help.component.html | 0
.../dialog => core-ui}/help/help.component.scss | 2 +-
.../dialog => core-ui}/help/help.component.ts | 9 +-
.../pipeline-element-documentation.component.html | 0
.../pipeline-element-documentation.component.scss | 0
.../pipeline-element-documentation.component.ts | 0
.../pipeline-element-runtime-info.component.html | 0
.../pipeline-element-runtime-info.component.scss | 0
.../pipeline-element-runtime-info.component.ts | 2 +-
ui/src/app/dashboard/dashboard.module.ts | 2 +-
.../time-selector/timeRangeSelector.component.html | 8 +-
.../time-selector/timeRangeSelector.component.ts | 2 +-
ui/src/app/data-explorer/data-explorer.module.ts | 2 +-
ui/src/app/editor/editor.module.ts | 9 -
ui/src/app/editor/services/editor.service.ts | 2 +-
ui/src/app/files/files.module.ts | 2 +-
ui/src/app/pipelines/pipelines.module.ts | 2 +-
253 files changed, 8059 insertions(+), 7340 deletions(-)