This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch fix/wrong-header in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 5ac14ff2d62cf98acc61535e00c30e9f8817e68b Merge: 915bcb633 97b94400a Author: bossenti <[email protected]> AuthorDate: Thu Jul 27 17:39:42 2023 +0200 Merge remote-tracking branch 'origin/dev' into fix/wrong-header .github/ISSUE_TEMPLATE/bug_report.yml | 2 +- .github/dependabot.yml | 1 + .github/workflows/build.yml | 8 + .idea/runConfigurations/core.xml | 3 +- RELEASE_NOTES.md | 131 + VULNERABILITY.md | 21 +- .../main/resources/archetype-resources/Dockerfile | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- .../archetype-resources/src/main/java/Init.java | 10 +- .../__classNamePrefix__DataProcessor.java | 52 +- .../__classNamePrefix__DataSink.java | 41 +- .../__classNamePrefix__GenericAdapter.java | 101 + .../__classNamePrefix__SpecificAdapter.java | 95 + .../documentation.md | 32 +- .../icon.png | Bin 0 -> 13563 bytes .../strings.en} | 10 +- .../documentation.md | 32 +- .../icon.png | Bin 0 -> 13563 bytes .../strings.en} | 10 +- .../main/resources/archetype-resources/Dockerfile | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- .../archetype-resources/src/main/java/Init.java | 4 +- .../main/resources/archetype-resources/Dockerfile | 2 +- .../src/main/resources/archetype-resources/pom.xml | 2 +- .../archetype-resources/src/main/java/Init.java | 4 +- installer/cli/.env | 4 +- .../cli/deploy/standalone/opcua/docker-compose.yml | 1 + .../standalone/pulsar/docker-compose.dev.yml | 13 +- .../deploy/standalone/pulsar/docker-compose.yml | 113 + .../cli/environments/backend-pulsar | 11 +- .../cli/environments/basic-pulsar | 10 +- .../cli/environments/lite-pulsar | 13 +- .../cli/environments/pipeline-element-pulsar | 12 +- installer/compose/docker-compose.pulsar.yml | 141 + .../k8s/templates/core/backend-deployment.yaml | 22 + installer/k8s/templates/core/backend-pvc.yaml | 2 +- installer/k8s/templates/core/ui-configmap.yaml | 2 +- installer/k8s/templates/core/ui-deployment.yaml | 22 + .../extensions-all-iiot-deployment.yaml | 21 +- .../external/consul/consul-deployment.yaml | 26 +- .../templates/external/consul/consul-pv-pvc.yaml | 2 +- .../external/couchdb/couchdb-deployment.yaml | 24 +- .../templates/external/couchdb/couchdb-pv-pvc.yaml | 2 +- .../external/influxdb/influxdb-deployment.yaml | 28 +- .../templates/external/influxdb/influxdb-pvc.yaml | 2 +- .../templates/external/influxdb/influxdb2-pvc.yaml | 2 +- .../templates/external/kafka/kafka-deployment.yaml | 29 +- .../templates/external/nats/nats-deployment.yaml | 21 +- .../external/zookeeper/zookeeper-deployment.yaml | 30 +- installer/k8s/values.yaml | 36 +- pom.xml | 74 +- .../streampipes/client/api/IDataProcessorApi.java | 29 +- .../streampipes/client/api/IDataSinkApi.java | 15 +- .../streampipes/client/api/IDataStreamApi.java | 18 +- .../streampipes/client/api/IStreamPipesClient.java | 3 + .../api/config/IStreamPipesClientConfig.java | 5 +- .../client/api/live/IBrokerConfigOverride.java | 11 +- ...kaConfig.java => IConfiguredEventProducer.java} | 13 +- .../live/{IKafkaConfig.java => ISubscription.java} | 5 +- streampipes-client-python/docs/index.md | 28 +- streampipes-client-python/setup.py | 24 +- .../streampipes/endpoint/api/data_lake_measure.py | 37 +- .../tests/endpoint/test_data_lake_measure.py | 110 +- streampipes-client/pom.xml | 6 +- .../streampipes/client/StreamPipesClient.java | 6 + .../streampipes/client/api/DataProcessorApi.java | 54 +- .../apache/streampipes/client/api/DataSinkApi.java | 26 +- .../streampipes/client/api/DataStreamApi.java | 28 +- .../client/live/ConfiguredEventProducer.java | 53 + .../streampipes/client/live/ProducerManager.java | 62 + .../streampipes/client/live/Subscription.java | 19 +- .../client/live/SubscriptionManager.java | 117 +- .../client/model/StreamPipesClientConfig.java | 18 +- streampipes-commons/pom.xml | 10 + .../java/org/apache/streampipes/commons/Utils.java | 6 - .../streampipes/commons/networking/Networking.java | 15 +- .../streampipes/commons/resources/Resources.java | 27 +- .../src/test/java/TestResources.java | 22 +- streampipes-commons/src/test/resources/test.txt | 1 + streampipes-config/pom.xml | 6 - .../streampipes/config/backend/BackendConfig.java | 7 +- .../config/backend/BackendConfigKeys.java | 1 + .../config/backend/DefaultMessagingSettings.java | 22 +- streampipes-connect-management/pom.xml | 10 + .../management}/AdapterEventPreviewPipeline.java | 32 +- .../management/management/GuessManagement.java | 7 +- .../connect/management/util/GroundingUtils.java | 15 +- .../management}/util/TransportFormatGenerator.java | 2 +- .../pom.xml | 19 +- .../shared/AdapterPipelineGeneratorBase.java | 110 + .../streampipes/connect/shared}/DatatypeUtils.java | 2 +- .../connect/shared}/preprocessing/Util.java | 2 +- .../elements/AddTimestampPipelineElement.java | 2 +- .../elements/AddValuePipelineElement.java | 2 +- .../TransformSchemaAdapterPipelineElement.java | 16 +- .../elements/TransformStreamAdapterElement.java | 8 +- .../TransformValueAdapterPipelineElement.java | 18 +- .../transform/TransformationRule.java | 2 +- .../schema/CreateNestedTransformationRule.java | 2 +- .../transform/schema/DeleteTransformationRule.java | 2 +- .../transform/schema/MoveTransformationRule.java | 2 +- .../transform/schema/RenameTransformationRule.java | 2 +- .../transform/schema/SchemaEventTransformer.java | 4 +- .../transform/schema/SchemaTransformationRule.java | 4 +- .../stream/DuplicateFilterPipelineElement.java | 2 +- .../stream/EventRateTransformationRule.java | 2 +- .../transform/stream/StreamEventTransformer.java | 4 +- .../transform/stream/StreamTransformationRule.java | 4 +- .../value/CorrectionValueTransformationRule.java | 2 +- .../value/DatatypeTransformationRule.java | 5 +- .../value/TimestampTranformationRule.java | 2 +- .../value/TimestampTranformationRuleMode.java | 2 +- .../transform/value/UnitTransformationRule.java | 2 +- .../transform/value/ValueEventTransformer.java | 4 +- .../transform/value/ValueTransformationRule.java | 4 +- .../transform}/DatatypeUtilsTest.java | 5 +- .../schema/CreateNestedTransformationRuleTest.java | 4 +- .../schema/DeleteTransformationRuleTest.java | 4 +- .../schema/MoveTransformationRuleTest.java | 4 +- .../schema/RenameTransformationRuleTest.java | 4 +- .../schema/SchemaEventTransformerTest.java | 11 +- .../transform/value/CorrectionValueTest.java | 3 +- .../transform/value/UnitTransformRuleTest.java | 3 +- .../transform/value/ValueEventTransformerTest.java | 5 +- streampipes-data-explorer-commons/pom.xml | 6 + .../dataexplorer/commons/DataExplorerUtils.java | 4 + .../commons/sanitizer/MeasureNameSanitizer.java | 23 +- .../sanitizer/MeasureNameSanitizerTest.java | 53 + .../param/model/SelectClauseParams.java | 6 +- .../writer/TestConfiguredCsvOutputWriter.java | 4 +- .../writer/TestConfiguredJsonOutputWriter.java | 4 +- .../export/dataimport/PerformImportGenerator.java | 4 +- .../export/dataimport/PreviewImportGenerator.java | 18 +- .../export/utils/EventGroundingProcessor.java | 14 +- .../export/utils/ImportAdapterMigrationUtils.java | 55 + .../connect/context/IAdapterRuntimeContext.java | 4 +- ...pelineElementLogger.java => FixedSizeList.java} | 42 +- ...neElementLogger.java => IExtensionsLogger.java} | 17 +- .../api/monitoring/SpMonitoringManager.java | 33 +- .../extensions/api/pe/context/RuntimeContext.java | 4 +- streampipes-extensions-management/pom.xml | 10 + .../connect/AdapterWorkerManagement.java | 17 +- .../management/connect/PullAdapterScheduler.java | 4 +- .../connect/adapter/AdapterPipelineGenerator.java | 98 +- .../connect/adapter/parser/CsvParser.java | 2 +- .../connect/adapter/parser/json/GeoJsonParser.java | 32 +- .../elements/SendToBrokerAdapterSink.java | 28 +- .../elements/SendToJmsAdapterSink.java | 8 +- .../elements/SendToKafkaAdapterSink.java | 8 +- .../elements/SendToMqttAdapterSink.java | 8 +- .../elements/SendToNatsAdapterSink.java | 8 +- ...apterSink.java => SendToPulsarAdapterSink.java} | 20 +- .../context/AdapterContextGenerator.java | 9 +- .../context/SpAdapterRuntimeContext.java | 12 +- .../management/locales/LabelGenerator.java | 4 +- .../management/monitoring/ExtensionsLogger.java | 63 + .../connect/AdapterWorkerManagementTest.java | 2 +- streampipes-extensions/pom.xml | 3 + .../iiot/adapters/iolink/IfmAlMqttAdapter.java | 6 +- .../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 20 +- .../simulator/machine/MachineDataSimulator.java | 12 +- .../iiot/protocol/stream/FileReplayAdapter.java | 5 +- .../iiot/protocol/stream/KafkaProtocol.java | 21 +- .../connect/iiot/protocol/stream/NatsProtocol.java | 14 +- .../strings.en | 12 + .../generic/elements/AddTimestampTest.java | 2 +- .../generic/elements/DuplicateFilterTest.java | 2 +- .../streampipes-connectors-opcua/pom.xml | 12 + .../connectors/opcua/adapter/OpcUaAdapter.java | 82 +- .../connectors/opcua/adapter/OpcUaNodeBrowser.java | 37 +- .../opcua/adapter/OpcUaNodeMetadataExtractor.java | 171 + .../opcua/adapter/configuration/SpOpcUaConfig.java | 148 - .../opcua/{adapter => client}/SpOpcUaClient.java | 30 +- .../MiloOpcUaConfigurationProvider.java | 7 +- .../opcua/config/OpcUaAdapterConfig.java | 17 +- .../connectors/opcua/config/OpcUaConfig.java | 70 + .../opcua/config/SharedUserConfiguration.java | 89 + .../SpOpcUaConfigExtractor.java} | 101 +- .../opcua/{adapter => model}/OpcNode.java | 2 +- .../extensions/connectors/opcua/sink/OpcUa.java | 83 +- .../connectors/opcua/sink/OpcUaParameters.java | 45 +- .../connectors/opcua/sink/OpcUaSink.java | 62 +- .../utils/ExceptionMessageExtractor.java | 2 +- .../opcua/{adapter => }/utils/OpcUaTypes.java | 2 +- .../opcua/{adapter => }/utils/OpcUaUtil.java | 39 +- .../strings.en | 42 +- .../adapter/OpcUaNodeMetadataExtractorTest.java | 258 + .../streampipes-extensions-all-iiot/pom.xml | 4 + .../extensions/all/iiot/AllExtensionsIIoTInit.java | 4 +- .../extensions/all/jvm/AllExtensionsInit.java | 4 +- .../pom.xml | 5 - .../pe/shared/config/kafka/KafkaConfig.java | 15 +- .../pe/shared/config/kafka/KafkaConnectUtils.java | 32 +- .../pe/shared/config/kafka/kafka/KafkaConfig.java | 13 +- .../config/kafka/kafka/KafkaConnectUtils.java | 35 +- .../complex/TopologyValidationProcessor.java | 4 +- .../sinks/brokers/jvm/jms/JmsPublisherSink.java | 6 +- .../streampipes-sinks-internal-jvm/pom.xml | 4 - streampipes-integration-tests/pom.xml | 16 + .../integration/adapters/AdaptersTest.java | 8 + ...tAdapterTester.java => KafkaAdapterTester.java} | 112 +- .../integration/adapters/MqttAdapterTester.java | 18 +- .../integration/adapters/PulsarAdapterTester.java | 14 +- .../integration/client/ClientLiveDataTest.java | 14 +- .../client/ClientLiveDataTesterBase.java | 117 + .../integration/client/ClientNatsTester.java | 64 + .../integration/containers/KafkaContainer.java | 42 +- .../integration/containers/KafkaDevContainer.java | 17 +- .../integration/containers/NatsContainer.java | 36 +- .../integration/containers/NatsDevContainer.java | 9 +- .../streampipes/integration/utils/Utils.java | 25 +- .../apache/streampipes/mail/utils/MailUtils.java | 7 +- streampipes-measurement-units/pom.xml | 3 +- .../java/com/github/jqudt/onto/UnitFactory.java | 24 - .../java/com/github/jqudt/onto/units/AreaUnit.java | 23 - .../github/jqudt/onto/units/ConcentrationUnit.java | 25 - .../com/github/jqudt/onto/units/CountingUnit.java | 16 - .../com/github/jqudt/onto/units/EnergyUnit.java | 16 - .../com/github/jqudt/onto/units/LengthUnit.java | 19 - .../java/com/github/jqudt/onto/units/MassUnit.java | 23 - .../jqudt/onto/units/PressureOrStressUnit.java | 15 - .../github/jqudt/onto/units/TemperatureUnit.java | 18 - .../com/github/jqudt/onto/units/VolumeUnit.java | 18 - .../messaging/jms/ActiveMQConnectionProvider.java | 8 + .../messaging/jms/ActiveMQConsumer.java | 12 +- .../messaging/jms/ActiveMQPublisher.java | 47 +- .../streampipes/messaging/jms/SpJmsProtocol.java | 15 +- .../messaging/kafka/SpKafkaConsumer.java | 14 +- .../messaging/kafka/SpKafkaProducer.java | 8 +- .../messaging/kafka/SpKafkaProtocol.java | 16 +- .../kafka/config/AutoOffsetResetConfig.java | 32 +- .../kafka/config/ConsumerConfigFactory.java | 3 +- .../messaging/mqtt/AbstractMqttConnector.java | 6 + .../streampipes/messaging/mqtt/MqttConsumer.java | 12 +- .../streampipes/messaging/mqtt/MqttPublisher.java | 12 +- .../streampipes/messaging/mqtt/SpMqttProtocol.java | 16 +- .../messaging/nats/AbstractNatsConnector.java | 8 + .../streampipes/messaging/nats/NatsConsumer.java | 22 +- .../streampipes/messaging/nats/NatsPublisher.java | 12 +- .../streampipes/messaging/nats/SpNatsProtocol.java | 16 +- streampipes-messaging-pulsar/pom.xml | 57 + .../messaging/pulsar/PulsarConsumer.java | 86 + .../messaging/pulsar/PulsarProducer.java | 78 + .../messaging/pulsar/SpPulsarProtocol.java | 28 +- .../messaging/pulsar/SpPulsarProtocolFactory.java | 28 +- .../streampipes/messaging/EventConsumer.java | 6 +- .../streampipes/messaging/EventProducer.java | 5 +- .../messaging/SpProtocolDefinition.java | 5 +- streampipes-model/pom.xml | 12 +- .../apache/streampipes/model/ShortUserInfo.java | 70 + .../streampipes/model/config/SpProtocol.java | 3 +- .../adapter/migration/GenericAdapterConverter.java | 94 +- .../adapter/migration/IAdapterConverter.java | 6 +- .../adapter/migration}/MigrationHelpers.java | 11 +- .../migration/SpecificAdapterConverter.java | 17 +- .../migration}/format/CsvFormatMigrator.java | 2 +- .../migration}/format/EmptyFormatMigrator.java | 2 +- .../adapter/migration}/format/FormatMigrator.java | 2 +- .../migration}/format/JsonFormatMigrator.java | 12 +- .../migration}/format/XmlFormatMigrator.java | 2 +- .../adapter/migration/utils/AdapterModels.java | 28 +- .../adapter/migration}/utils/DocumentKeys.java | 2 +- .../adapter/migration}/utils/FormatIds.java | 2 +- .../migration}/utils/GenericAdapterUtils.java | 8 +- .../model/connect/guess/AdapterEventPreview.java | 7 +- .../model/connect/guess/AdapterGuessInfo.java | 55 - .../model/connect/guess/GuessSchema.java | 8 +- .../model/connect/guess/GuessTypeInfo.java | 72 - .../model/datalake/DataLakeMeasure.java | 2 + .../model/file/GenericStorageAttachment.java | 36 +- .../model/grounding/PulsarTransportProtocol.java | 26 +- .../model/grounding/TransportProtocol.java | 3 +- .../streampipes/model/monitoring/SpLogEntry.java | 16 +- ...{StreamPipesStatistics.java => SpLogLevel.java} | 6 +- .../SpLogMessage.java} | 79 +- .../streampipes/model/schema/EventProperty.java | 2 +- .../streampipes/model/schema/EventSchema.java | 3 +- .../RuntimeResolvableTreeInputStaticProperty.java | 10 + .../org/apache/streampipes/model/util/Cloner.java | 3 + .../apache/streampipes/model/util/ListUtils.java | 49 +- streampipes-pipeline-management/pom.xml | 30 +- .../manager/assets/DocumentationParser.java | 6 +- .../manager/endpoint/EndpointItemFetcher.java | 3 +- .../manager/endpoint/EndpointItemParser.java | 3 +- .../manager/matching/ProtocolSelector.java | 6 + .../monitoring/pipeline/ExtensionsLogProvider.java | 6 +- .../manager/pipeline/PipelineManager.java | 23 +- .../runtime/PipelineElementRuntimeInfoFetcher.java | 101 +- .../streampipes/ps/DataLakeMeasureResourceV4.java | 9 +- .../apache/streampipes/ps/DataLakeResourceV4.java | 4 +- .../management/NotificationsResourceManager.java | 75 + .../extensions/connect/AdapterWorkerResource.java | 10 +- .../extensions/monitoring/MonitoringResource.java | 2 +- .../shared/impl/AbstractSharedRestInterface.java | 4 + streampipes-rest/pom.xml | 7 +- .../apache/streampipes/rest/impl/UserResource.java | 40 +- .../rest/impl/admin/UserAdminResource.java | 61 + .../rest/impl/connect/AdapterResource.java | 6 +- .../rest/impl/connect/GuessResource.java | 15 +- .../impl/connect/RuntimeResolvableResource.java | 8 +- .../impl/datalake/PersistedDataStreamResource.java | 7 +- .../rest/impl/pe/DataProcessorResource.java | 4 +- .../streampipes/rest/impl/pe/DataSinkResource.java | 4 +- .../rest/impl/pe/DataStreamResource.java | 4 +- .../org/apache/streampipes/rest/utils/Utils.java | 22 +- streampipes-sdk/pom.xml | 9 +- .../apache/streampipes/sdk/StaticProperties.java | 5 +- ...AbstractConfigurablePipelineElementBuilder.java | 12 +- .../sdk/builder/adapter/GuessSchemaBuilder.java | 50 +- .../org/apache/streampipes/sdk/helpers/Labels.java | 17 +- .../sdk/helpers/SupportedProtocols.java | 5 + streampipes-service-base/pom.xml | 4 - .../service/base/StreamPipesServiceBase.java | 2 +- .../Dockerfile | 4 +- streampipes-service-core-nats/pom.xml | 94 + .../core/nats/StreamPipesCoreApplicationNats.java | 53 + streampipes-service-core/Dockerfile | 4 +- streampipes-service-core/pom.xml | 39 +- ...cation.java => StreamPipesCoreApplication.java} | 40 +- .../service/core/StreamPipesResourceConfig.java | 2 + ...FormatMigrator.java => SupportedProtocols.java} | 11 +- .../service/core/WebSecurityConfig.java | 2 +- .../core}/filter/TokenAuthenticationFilter.java | 2 +- .../core/migrations/v093/AdapterBackupWriter.java | 2 +- .../core/migrations/v093/AdapterMigration.java | 36 +- .../v093/migrator/GenericAdapterMigrator.java | 102 +- .../v093/migrator/SpecificAdapterMigrator.java | 11 +- streampipes-service-discovery-consul/pom.xml | 4 - .../streampipes/storage/api/IGenericStorage.java | 7 + .../storage/api/INotificationStorage.java | 2 + streampipes-storage-couchdb/pom.xml | 8 +- .../couchdb/impl/ConnectionStorageImpl.java | 5 +- .../storage/couchdb/impl/DataLakeStorageImpl.java | 3 +- .../storage/couchdb/impl/GenericStorageImpl.java | 25 +- .../couchdb/impl/NotificationStorageImpl.java | 28 +- .../streampipes/storage/couchdb/utils/Utils.java | 11 + .../storage/couchdb/utils/TestUrlEscapers.java | 44 + streampipes-user-management/pom.xml | 4 +- .../wrapper/flink/consumer/JmsFlinkConsumer.java | 12 +- .../wrapper/flink/consumer/MqttFlinkConsumer.java | 12 +- .../wrapper/flink/sink/JmsFlinkProducer.java | 4 +- .../wrapper/flink/sink/MqttFlinkProducer.java | 4 +- .../flink/status/PipelineElementStatusSender.java | 46 - .../status/PipelineElementStatusSenderFactory.java | 42 - .../kafka/KafkaStreamsDataProcessorRuntime.java | 18 +- .../wrapper/kafka/KafkaStreamsOutputCollector.java | 14 +- .../standalone/function/FunctionContext.java | 10 +- .../standalone/function/StreamPipesFunction.java | 4 +- .../routing/StandaloneSpInputCollector.java | 14 +- .../routing/StandaloneSpOutputCollector.java | 20 +- .../runtime/StandaloneEventProcessorRuntime.java | 4 +- .../runtime/StandaloneEventSinkRuntime.java | 4 +- .../runtime/StandalonePipelineElementRuntime.java | 20 +- .../context/SpEventProcessorRuntimeContext.java | 19 +- .../wrapper/context/SpEventSinkRuntimeContext.java | 14 +- .../wrapper/context/SpRuntimeContext.java | 34 +- .../generator/DataProcessorContextGenerator.java | 4 +- .../generator/DataSinkContextGenerator.java | 4 +- .../support/utils/ConnectEventSchemaUtils.ts | 2 +- .../support/utils/DataDownloadDialogUtils.ts | 16 +- ui/cypress/support/utils/PrepareTestDataUtils.ts | 2 +- .../support/utils/ProcessingElementTestUtils.ts | 2 +- ui/cypress/support/utils/StaticPropertyUtils.ts | 28 +- ui/cypress/support/utils/connect/ConnectUtils.ts | 5 +- ui/cypress/support/utils/datalake/DataLakeUtils.ts | 9 +- ui/cypress/tests/adapter/formats/format.spec.ts | 8 +- ui/cypress/tests/thirdparty/InfluxDb.smoke.spec.ts | 4 +- ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts | 12 +- ui/deployment/appng5.module.mst | 5 +- ui/deployment/base-navigation.component.mst | 4 +- ui/deployment/prebuild.js | 8 +- ui/package-lock.json | 12417 +++++++++---------- ui/package.json | 70 +- .../streampipes/platform-services/package.json | 8 +- .../src/lib/apis/user-admin.service.ts} | 54 +- .../platform-services/src/lib/apis/user.service.ts | 15 +- .../src/lib/model/gen/streampipes-model.ts | 134 +- .../platform-services/src/public-api.ts | 1 + ui/projects/streampipes/shared-ui/package.json | 16 +- .../basic-nav-tabs/basic-nav-tabs.component.html | 5 +- .../basic-view/basic-view.component.html | 1 - .../basic-view/basic-view.component.scss | 2 +- .../exception-details-dialog.component.html | 6 +- .../exception-details-dialog.component.ts | 4 +- .../sp-exception-message.component.html | 4 +- .../sp-exception-message.component.ts | 4 +- .../confirm-dialog/confirm-dialog.component.html | 42 +- .../panel-dialog/panel-dialog.component.html | 2 +- .../standard-dialog/standard-dialog.component.html | 2 +- .../src/lib/services/current-user.service.ts} | 50 +- .../src/lib}/services/jwt-token-storage.service.ts | 2 + .../shared-ui/src/lib/shared-ui.module.ts | 4 +- .../streampipes/shared-ui/src/public-api.ts | 2 + ui/src/app/add/add.component.html | 89 +- ui/src/app/add/add.module.ts | 2 +- ui/src/app/apidocs/apidocs.module.ts | 2 +- .../app-asset-monitoring.module.ts | 2 +- .../create-asset/create-asset.component.html | 7 +- .../add-pipeline-dialog.component.html | 10 +- .../app/app-overview/app-overview.component.html | 2 +- ui/src/app/app-overview/app-overview.module.ts | 2 +- ui/src/app/assets/assets.module.ts | 2 +- .../asset-link-item/asset-link-item.component.html | 3 - .../asset-selection-panel.component.html | 3 - .../asset-overview/asset-overview.component.html | 5 - ui/src/app/configuration/configuration.module.ts | 2 +- .../consul-configs-password.component.spec.ts | 2 +- .../datalake-configuration.component.html | 4 - .../general-configuration.component.html | 3 +- .../edit-label/edit-label.component.html | 13 +- .../label-configuration.component.html | 2 - .../abstract-security-principal-config.ts | 2 + .../edit-user-dialog/edit-user-dialog.component.ts | 5 +- .../security-service-config.component.ts | 2 +- .../security-user-config.component.ts | 2 +- .../error-message/error-message.component.ts | 4 +- .../event-property-row.component.html | 9 +- .../event-property-row.component.ts | 17 +- .../event-schema-preview.component.ts | 27 +- .../event-schema/event-schema.component.html | 1 - .../event-schema/event-schema.component.ts | 11 +- .../schema-editor-header.component.html | 2 - .../abstract-adapter-details.directive.ts | 12 +- .../adapter-details-logs.component.html | 1 - .../adapter-details-logs.component.ts | 11 +- .../adapter-details-metrics.component.html | 1 - .../adapter-details-metrics.component.ts | 9 +- .../adapter-details-overview.component.ts | 10 +- .../existing-adapters.component.html | 9 - .../existing-adapters.component.scss | 9 +- .../existing-adapters.component.ts | 12 +- .../filter-toolbar/filter-toolbar.component.html | 53 +- ui/src/app/connect/connect.module.ts | 2 +- ui/src/app/connect/services/rest.service.ts | 5 +- ui/src/app/core-ui/core-ui.module.ts | 2 +- .../select-data-range.component.ts | 8 +- .../image-labeling/image-labeling.component.html | 1 - .../object-permission-dialog.component.ts | 6 +- .../static-color-picker.component.html | 28 +- .../static-file-input.component.html | 1 - .../static-free-input.component.html | 8 +- .../static-free-input.component.scss | 4 +- .../static-mapping-unary.component.html | 2 +- .../static-property.component.html | 2 +- .../static-properties/static-property.component.ts | 5 +- .../base-runtime-resolvable-input.ts | 7 +- .../core/components/iconbar/iconbar.component.html | 2 - .../core/components/iconbar/iconbar.component.scss | 7 +- .../core/components/iconbar/iconbar.component.ts | 4 +- .../streampipes/streampipes.component.ts | 5 +- .../core/components/toolbar/toolbar.component.html | 2 - .../core/components/toolbar/toolbar.component.ts | 17 +- ui/src/app/core/core.module.ts | 2 +- .../overview/dashboard-overview.component.css | 4 +- .../overview/dashboard-overview.component.html | 6 - .../overview/dashboard-overview.component.ts | 4 +- .../panel/dashboard-panel.component.html | 4 +- .../components/panel/dashboard-panel.component.ts | 4 +- .../widget/dashboard-widget.component.html | 18 +- .../widgets/status/status-widget.component.html | 3 + .../widgets/status/status-widget.component.ts | 22 +- ui/src/app/dashboard/dashboard.module.ts | 2 +- .../add-visualization-dialog.component.html | 29 +- .../add-visualization-dialog.component.scss | 5 + .../add-visualization-dialog.component.ts | 2 +- ...lorer-widget-appearance-settings.component.html | 60 +- .../data-explorer-designer-panel.component.html | 1 - ...ta-explorer-widget-data-settings.component.html | 147 +- .../field-selection-panel.component.html | 2 - .../field-selection/field-selection.component.html | 2 +- .../field-selection/field-selection.component.scss | 2 +- .../filter-selection-panel.component.html | 16 +- ...-explorer-visualisation-settings.component.html | 19 +- ...data-explorer-dashboard-overview.component.html | 5 - ...data-explorer-dashboard-overview.component.scss | 6 +- .../data-explorer-dashboard-overview.component.ts | 24 +- .../data-explorer-dashboard-panel.component.html | 9 +- .../data-explorer-dashboard-panel.component.ts | 4 +- .../time-selector/timeRangeSelector.component.html | 18 +- .../time-selector/timeRangeSelector.component.scss | 23 +- .../data-explorer-dashboard-widget.component.html | 5 +- .../data-explorer-dashboard-widget.component.ts | 23 +- .../base/base-data-explorer-widget.directive.ts | 6 +- .../widgets/base/data-explorer-widget-data.ts | 4 +- .../correlation-chart-widget-config.component.html | 9 +- ...distribution-chart-widget-config.component.html | 9 +- .../map/config/map-widget-config.component.html | 7 +- .../config/table-widget-config.component.html | 9 +- .../aggregate-configuration.component.html | 16 +- .../select-color-properties.component.html | 58 +- .../select-color-properties.component.scss | 6 + .../select-property/select-property.component.html | 7 +- ui/src/app/data-explorer/data-explorer.module.ts | 2 +- ...a-explorer-edit-data-view-dialog.component.html | 4 +- .../user-defined-output.component.html | 7 +- .../pipeline-assembly.component.html | 3 - .../pipeline-element-icon-stand-row.component.html | 3 +- .../pipeline-element-icon-stand.component.html | 48 +- .../pipeline-element-icon-stand.component.scss | 2 +- .../pipeline-element-options.component.css | 53 + .../pipeline-element-options.component.html | 6 - ui/src/app/editor/editor.component.ts | 4 +- ui/src/app/editor/editor.module.ts | 2 +- .../file-overview/file-overview.component.html | 1 - ui/src/app/files/files.module.ts | 2 +- ui/src/app/home/home.component.html | 15 +- ui/src/app/home/home.component.scss | 5 + ui/src/app/home/home.component.ts | 8 +- ui/src/app/home/home.module.ts | 2 +- ui/src/app/http-interceptor.ts | 8 +- ui/src/app/info/info.module.ts | 2 +- .../login/components/login/login.component.html | 2 +- .../components/startup/startup.component.scss | 4 +- ui/src/app/login/login.module.ts | 2 +- .../app/notifications/notifications.component.html | 11 +- ui/src/app/notifications/notifications.module.ts | 2 +- .../notifications/service/notifications.service.ts | 6 + .../actions/pipeline-actions.component.ts | 13 +- .../components/edit/quickedit.component.ts | 14 +- .../monitoring/pipeline-monitoring.component.html | 1 - .../monitoring/pipeline-monitoring.component.ts | 14 +- .../pipeline-details-overview.component.ts | 14 +- .../pipeline-logs/pipeline-logs.component.html | 1 - .../pipeline-logs/pipeline-logs.component.ts | 14 +- .../components/sp-pipeline-details.directive.ts | 8 +- .../pipeline-details/pipeline-details.module.ts | 2 +- .../functions-logs/functions-logs.component.html | 1 - .../functions-metrics.component.html | 1 - .../functions-overview.component.html | 1 - .../pipeline-overview.component.html | 92 +- .../pipeline-overview.component.scss | 9 +- .../pipeline-overview.component.ts | 4 +- .../pipeline-categories-dialog.component.html | 8 - ui/src/app/pipelines/pipelines.component.html | 3 - ui/src/app/pipelines/pipelines.component.ts | 4 +- ui/src/app/pipelines/pipelines.module.ts | 2 +- .../profile/components/basic-profile-settings.ts | 6 +- .../general-profile-settings.component.html | 2 +- .../general/general-profile-settings.component.ts | 20 +- ui/src/app/profile/profile.module.ts | 2 +- ui/src/app/services/auth.service.ts | 47 +- ui/src/app/services/secure.pipe.ts | 6 +- ui/src/app/services/services.module.ts | 4 - ui/src/scss/sp/buttons.scss | 44 +- ui/src/scss/sp/colors.scss | 2 - ui/src/scss/sp/data-explorer.scss | 4 +- ui/src/scss/sp/forms.scss | 170 +- ui/src/scss/sp/layout.scss | 30 +- ui/src/scss/sp/mat-tab.scss | 8 +- ui/src/scss/sp/pipeline-element-options.scss | 52 - ui/src/scss/sp/sp-theme.scss | 94 +- ui/src/scss/sp/widgets.scss | 6 +- 552 files changed, 12341 insertions(+), 10432 deletions(-)
