This is an automated email from the ASF dual-hosted git repository.
dominikriemer pushed a change to branch health-check-adapter
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from d135e00b11 Merge branch 'dev' into health-check-adapter
add 4c22ead95a chore(deps): bump actions/checkout from 6 to 6.0.3 (#4595)
add d7fd5039bb feat(#4568): Allow reordering and restructuring of assets
in asset view edit mode (#4605)
add 643782e2f3 fix: Flaky cypress asset filter and dataset test (#4607)
add ccfc885314 chore(deps): bump actions/setup-java from 5.2.0 to 5.3.0
(#4612)
add 9ccee555e7 chore(deps-dev): bump cypress from 14.4.1 to 15.17.0 in /ui
(#4611)
add 20332cd4d7 chore(deps-dev): bump
org.apache.maven.plugins:maven-invoker-plugin from 3.9.1 to 3.10.1 (#4610)
add 05f9340e76 chore(deps): bump org.snakeyaml:snakeyaml-engine from 2.5
to 3.0.1 (#4609)
add c790abdcd9 fix: migrate deprecated method in Python Client (#4613)
add b6820fde4c fix(#4564): Ensure correct escaping and quoting of string
values in csv export (#4616)
add 3a28f37623 fix: Properly read charts from import manifests (#4619)
add e722854732 fix(#4614): restore dashboard public link option (#4615)
add 644fd68559 fix: Properly cleanup subscriptions in kiosk mode (#4622)
add bd263a316a feat(#4577): Add last updated time to dashboard kiosk,
improve performance (#4629)
add ff1dee49c6 chore(deps): bump actions/cache from 5 to 5.0.5 (#4626)
add cc922f4e13 fix: Ignore unknown fields in ImportGenerator (#4630)
add 055ada4986 Fix VS Code JMX port conflict for dev launch (#4620)
add 8ac28303f1 chore(deps): bump actions/checkout from 6.0.3 to 7.0.0
(#4623)
add 067704522d fix: Split chart request refresh strategies (#4634)
add 0423651c77 feat(#4633): Move dataset count display into dataset
overview (#4637)
add 60d11642a8 chore(deps): bump actions/setup-python from 5 to 6.2.0
(#4636)
add 590b266bec chore: Improve startup logging (#4638)
add e7dafb922b fix: Improve retry of failed PLC connections (#4572)
add 40d0ac4229 fix(#4640): Add missing sorting to adapter and dataset
columns (#4645)
add 8d454cb075 feat: modernize Python Client syntax (PEP 585, PEP 604)
(#4628)
add fd23b5f509 Update README.md
add 39f059281e fix: consistent spacing in translation files (#4639)
add 11b7168d1e fix: Consistent Asset Create Workflow (#4644)
add b78b39657b refactor: Migrate configuration storage (#4631)
add 278567ee34 style: Harmonize button and table layout (#4608)
add f4cf5d53e2 feat(#4466): Add validation and naming warnings for
property field names in adapter schema configuration (#4643)
add 87ffcff1ae fix(#4618): Health check restarts adapter during stopping
process (#4621)
add 7efa6a6d0e chore(deps): bump actions/cache from 5.0.5 to 6.1.0 (#4662)
add 070dc0e00b Fix styling bug pipeline details (#4658)
add 9e0742b84a chore(deps): bump actions/setup-python from 6.2.0 to 6.3.0
(#4661)
add faa9e05ed4 refactor: Remove groovy support from adapter script
transformation (#4653)
add e66ae52fc3 fix: align script template access handling (#4652)
add 8ef8232a8b chore(deps): bump @sigstore/core from 3.2.0 to 3.2.1 in /ui
(#4664)
add ed67499d14 Add debug logging for adapter monitoring metrics (#4654)
add 8dd5b58b2d feat: Allow registration of new health checks (#4667)
add a85a7fee0d Optimize adapter start and stop lifecycle (#4656)
add 308637d7a0 fix: Make transformation script endpoint backwards
compatible (#4670)
add af2fe9e1dd fix: Reduce logging for time series storage and adapter
preprocessing (#4657)
add 4bf62e3df8 refactor: Fix possible chip grid form fields error (#4677)
add 984651fcf5 feat: Extend email error hints (#4676)
add 80cd72594f feat: Extend OPC UA subscription mode configuration (#4659)
add 7ea60ecf08 fix: Fix e2e test editAdapterDataLakeSchemaUpdate.spec.ts
(#4672)
add fe1521ec8c fix: Re-add mat-form-field wrapper (#4680)
add 8e47c77679 feat: Improve error messages shown for runtime-resolvable
static prop… (#4681)
add caec9b30dc fix(#4666): Asset filter is not applied when resources are
grouped (#4682)
add b96c2fce73 fix: Improve asset creation and editing workflow (#4686)
add dd42d00372 fix(#4687): kiosk mode does not show data for logged out
users (#4689)
add 67015eac37 chore: Improve query performance of latest event queries
(#4685)
add 66dc262b02 feat: refactored Asset Link Table (#4646)
add 90c926c53f refactor: Improve rest endpoints for different resources
(#4679)
add 3f1317b591 fix(#4650): File adapter string parsing fails for quoted
delimiter (#4702)
add a80b745239 fix: Improve handling of runtime-resolved configurations
(#4696)
add e2df278088 Add security threat model (THREAT_MODEL.md) + SECURITY.md
and AGENTS.md discoverability (#4547)
add c0975cd2fa docs: deprecate CLI in README docs (#4693)
add 9605d3e63e fix: Avoid tls upgrade when explicitly setting mail
protocol to SMTP (#4701)
add cc7418a9ac Add running instance dialog registered services (#4700)
add 7042b7af8b chore(deps): bump typing-extensions from 4.15.0 to 4.16.0
in /streampipes-client-python (#4704)
add 93fa173821 chore(deps-dev): bump soupsieve from 2.7 to 2.8.4 in
/streampipes-client-python (#4705)
add 3961df2671 feat: Improve dataset details and feature card views (#4703)
add 8720de38a2 feat: Make asset tree scrollable in asset edit mode (#4709)
add 6cd32d5d3a fix: Avoid action menu item line break (#4710)
add f29eb98129 test: standardize Cypress chart naming (#4711)
add 7fe14b08c9 chore(deps-dev): bump mistune from 3.2.1 to 3.3.0 in
/streampipes-client-python (#4706)
add 624d17a7b3 fix: Pipeline group test (#4713)
add 9e31c30cc5 chore(deps): Bump docker actions version
add 07d9eff639 fix: Clean up adapter and pipeline lifecycle (#4719)
add 2d44c44cc8 feat(#4721): add CSV import progress tracking (#4722)
add b70ed30a88 reaftor: migrate pyproject.toml metadata to Python standard
in PEP 621 to fix poetry deprecations (#4649)
add 807f4e3918 chore: Improve timeout handling of OPC UA adapter (#4723)
add 369a821f29 fix: PLC4X cache recovery after failed read execution
(#4648)
add f8ec4d2ae3 feat(#4690): deprecate legacy plc4x s7 and modbus adapters
(#4691)
add 6b0c0bdfe5 #4683 fix(msteams): migrate sink to Power Automate workflow
format (#4684)
add 3b776bf738 chore(deps): bump confluent-kafka from 2.14.2 to 2.15.0 in
/streampipes-client-python (#4699)
add 8634653a99 fix(#4725): Can't delete code in javascript evaluator
(#4726)
add 3e08e51f78 feat(#4718): add shared search select component (#4720)
add b12e2a43e8 chore(deps): bump actions/setup-java from 5.3.0 to 5.5.0
(#4730)
add ae8a55e4f2 chore(deps): bump actions/stale from 10.3.0 to 10.4.0
(#4728)
add c8051a4d29 feat: Keep selection after executing multi-select action
(#4743)
add 5ce0f470d4 chore(deps-dev): bump mypy from 2.1.0 to 2.3.0 in
/streampipes-client-python (#4748)
add 0cdc0a8bbc refactor(#4733): Rename application-private data lake UI
components (#4740)
add b3f76b1cb5 chore(deps): bump tar from 7.5.16 to 7.5.20 in /ui (#4751)
add 4157f1feba chore(deps): bump engine.io from 6.6.4 to 6.6.9 in /ui
(#4749)
add 73a8cc246f chore(deps): bump actions/setup-node from 6 to 7 (#4746)
add 9010ec66d9 chore(deps): bump undici from 6.25.0 to 6.27.0 in /ui
(#4741)
add 07e7b40cb1 chore(deps-dev): bump axios from 1.16.0 to 1.18.1 in /ui
(#4742)
add bc29b5f749 chore: Cleanup UI dependencies (#4752)
add badc36f2d0 fix(#4651): Adding nested objects in the adapter script
transformation causes an error (#4753)
add 9f56b5386f fix: Remove max retries health check (#4739)
add 1bcd60af06 chore(deps): bump actions/setup-java from 5.5.0 to 5.6.0
(#4756)
add adb7dddcbc chore(deps-dev): bump tar from 7.5.11 to 7.5.20 in
/streampipes-client-go/docs (#4750)
add 48b29d69a9 chore(deps-dev): bump gitpython from 3.1.50 to 3.1.52 in
/streampipes-client-python (#4758)
add 3c007d3f6e chore(deps-dev): bump cryptography from 46.0.7 to 48.0.1 in
/streampipes-client-python (#4755)
add 5e42db1cdf chore(deps-dev): bump bleach from 6.2.0 to 6.4.0 in
/streampipes-client-python (#4754)
add 817342d3b0 chore(deps): bump docker/login-action from 4.1.0 to 4.4.0
(#4747)
add 1656323d9a chore(deps): bump docker/setup-qemu-action from 4.0.0 to
4.2.0 (#4697)
add 37a6e4b007 fix: Confirm changes dialog is shown twice when navigating
from asset edit mode to another page (#4688)
add db3ae5347a fix(#4759): Adapters without a name can be created (#4762)
add f5c2367633 1357 harmonize resource creation workflow for pipelines
(#4708)
add dd43edcfb2 fix: Fix adapter script migration for file stream adapter
(#4761)
add 39a3c795d3 chore(deps): bump actions/labeler from 6 to 7 (#4760)
add 796632b807 chore(deps): bump docker/setup-buildx-action from 4.0.0 to
4.2.0 (#4714)
add e071909262 1358 harmonize resource creation workflow for connect
(#4707)
add acf6da1356 Alert Banner for asset links (#4717)
add 13924bf8ef chore(deps): bump postcss from 8.5.10 to 8.5.22 in
/streampipes-client-go/docs (#4763)
add dd9efead62 chore(deps): bump actions/checkout from 7.0.0 to 7.0.1
(#4765)
add 4916e58275 Merge branch 'dev' into health-check-adapter
add 1da643222f Migrate adapter health check to support nats transport mdoe
add 83872be0d3 Merge branch 'health-check-adapter' of
github.com:apache/streampipes into health-check-adapter
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 24 +-
.github/workflows/cypress-test.yml | 6 +-
.github/workflows/extensions-docs.yml | 4 +-
.github/workflows/go-client-e2e-test.yml | 8 +-
.github/workflows/go-client.yml | 2 +-
.github/workflows/go-docs.yml | 4 +-
.github/workflows/java-client-e2e-test.yml | 8 +-
.github/workflows/mvn-integration-test.yml | 6 +-
.github/workflows/pr-labeler.yml | 2 +-
.github/workflows/pr-validation.yml | 26 +-
.github/workflows/pypi-deployment.yml | 4 +-
.github/workflows/python-docs.yml | 6 +-
.github/workflows/stale-bot.yml | 2 +-
.vscode/launch.json | 14 +
AGENTS.md | 30 +
README.md | 16 +-
SECURITY.md | 40 +
THREAT_MODEL.md | 387 +
installer/cli/README.md | 2 +
pom.xml | 9 +-
streampipes-client-go/docs/package-lock.json | 20 +-
streampipes-client-python/poetry.lock | 611 +-
streampipes-client-python/pyproject.toml | 42 +-
.../streampipes/client/client.py | 5 +-
.../streampipes/client/config.py | 7 +-
.../streampipes/client/credential_provider.py | 13 +-
.../streampipes/endpoint/api/data_lake_measure.py | 28 +-
.../streampipes/endpoint/api/data_stream.py | 5 +-
.../streampipes/endpoint/api/version.py | 7 +-
.../streampipes/endpoint/endpoint.py | 11 +-
.../streampipes/function_zoo/river_function.py | 15 +-
.../streampipes/functions/broker/consumer.py | 2 +-
.../functions/broker/kafka/kafka_consumer.py | 2 +-
.../functions/broker/kafka/kafka_publisher.py | 4 +-
.../functions/broker/nats/nats_consumer.py | 2 +-
.../functions/broker/nats/nats_publisher.py | 4 +-
.../functions/broker/output_collector.py | 5 +-
.../streampipes/functions/broker/publisher.py | 4 +-
.../streampipes/functions/function_handler.py | 10 +-
.../streampipes/functions/registration.py | 5 +-
.../streampipes/functions/streampipes_function.py | 10 +-
.../functions/utils/async_iter_handler.py | 7 +-
.../functions/utils/data_stream_context.py | 3 +-
.../functions/utils/data_stream_generator.py | 5 +-
.../functions/utils/function_context.py | 3 +-
.../streampipes/model/common.py | 59 +-
.../model/container/data_lake_measures.py | 3 +-
.../streampipes/model/container/data_streams.py | 3 +-
.../model/container/resource_container.py | 7 +-
.../streampipes/model/container/versions.py | 3 +-
.../model/resource/data_lake_measure.py | 11 +-
.../streampipes/model/resource/data_series.py | 10 +-
.../streampipes/model/resource/data_stream.py | 31 +-
.../streampipes/model/resource/exceptions.py | 3 +-
.../model/resource/function_definition.py | 11 +-
.../streampipes/model/resource/query_result.py | 12 +-
.../streampipes/model/resource/resource.py | 3 +-
.../streampipes/model/resource/version.py | 5 +-
.../tests/client/test_endpoint.py | 3 +-
.../tests/endpoint/test_data_lake_measure.py | 4 +-
.../apache/streampipes/commons/constants/Envs.java | 2 +
.../commons/environment/DefaultEnvironment.java | 10 +
.../commons/environment/Environment.java | 4 +
.../compact/generator/AdapterSchemaGenerator.java | 31 +-
.../management/AdapterMasterManagement.java | 32 +-
.../management/AdapterMigrationManager.java | 2 +-
.../AdapterTransformationConfigDefaults.java | 23 +-
.../management/AdapterUpdateManagement.java | 5 +-
.../management/management/GuessManagement.java | 10 +-
.../management/WorkerAdministrationManagement.java | 6 +-
.../management/management/WorkerRestClient.java | 54 +-
.../streampipes/connect/management/util/Utils.java | 32 -
.../shared/AdapterPipelineGeneratorBase.java | 1 +
.../streampipes/connect/shared/DatatypeUtils.java | 124 +-
.../value/DatatypeTransformationRule.java | 10 +-
.../preprocessing/transform/DatatypeUtilsTest.java | 71 +-
.../transformer/api/TransformationEngines.java | 26 +
streampipes-connect-transformer-groovy/pom.xml | 78 -
.../transformer/groovy/GroovyScriptContext.java | 25 -
.../transformer/groovy/GroovyScriptEngine.java | 80 -
.../sandbox/RestrictedGroovyClassLoader.java | 59 -
.../transformer/groovy/sandbox/SandboxPolicy.java | 187 -
.../transformer/groovy/sandbox/ScriptSandbox.java | 51 -
.../ast/AstChecksCompilationCustomizer.java | 39 -
.../groovy/sandbox/ast/AstChecksVisitor.java | 109 -
.../sandbox/ast/SecureCustomizerFactory.java | 59 -
.../error/SandboxCompilationMessageResolver.java | 112 -
.../SandboxViolationClassNotFoundException.java | 26 -
.../sandbox/error/SandboxViolationException.java | 26 -
.../transformer/groovy/GroovyScriptEngineTest.java | 318 -
.../transformer/js/GraalJsScriptEngine.java | 2 +-
.../transformer/js/GraalJsScriptEngineTest.java | 20 +
.../api/IDataExplorerQueryManagement.java | 33 +
.../export/ConfiguredCsvOutputWriter.java | 4 +-
.../export/ConfiguredExcelOutputWriter.java | 9 +-
.../export/ConfiguredOutputWriter.java | 10 -
.../export/ConfiguredOutputWriterFactory.java | 54 +
.../dataexplorer/export/OutputFormat.java | 19 +-
.../dataexplorer/export/item/CsvItemGenerator.java | 25 +-
.../export/TestConfiguredCsvOutputWriter.java | 24 +
.../dataexplorer/export/TestCsvItemGenerator.java | 34 +
.../influx/DataExplorerInfluxQueryExecutor.java | 74 +
.../influx/DataExplorerQueryManagementInflux.java | 92 +-
.../dataexplorer/influx/PropertyHandler.java | 8 +-
.../DataExplorerInfluxQueryExecutorTest.java | 22 +-
.../influx/InfluxLatestTimestampBenchmarkTest.java | 331 +
.../dataexplorer/influx/SelectQueryParamsTest.java | 27 +
.../influx/TimeSeriesStorageInfluxTest.java | 46 +
.../iotdb/DataExplorerQueryManagementIotDb.java | 7 +-
.../dataexplorer/StreamedQueryResultProvider.java | 7 +-
.../dataexplorer/TimeSeriesStorage.java | 23 +-
.../streampipes/export/AssetLinkResolver.java | 3 +-
.../streampipes/export/DataLakeExportManager.java | 17 +-
.../export/dataimport/ImportGenerator.java | 4 +-
.../export/dataimport/PerformImportGenerator.java | 5 +-
.../export/dataimport/PreviewImportGenerator.java | 3 +-
.../export/generator/ExportPackageGenerator.java | 14 +-
.../export/resolver/AdapterResolver.java | 2 +-
.../streampipes/export/resolver/FileResolver.java | 13 +-
.../api/monitoring/SpMonitoringManager.java | 47 +-
streampipes-extensions-management/pom.xml | 5 -
.../connect/AdapterTransitionRegistry.java | 80 +
.../connect/AdapterWorkerManagement.java | 123 +-
.../connect/AdapterWorkerRequestManagement.java | 7 +-
.../management/connect/PullAdapterScheduler.java | 19 +-
.../connect/adapter/ScriptContextResolver.java | 4 -
.../connect/adapter/model/EventCollector.java | 11 +-
.../adapter/model/pipeline/AdapterPipeline.java | 14 +-
.../connect/adapter/parser/CsvParser.java | 5 +-
.../elements/SendToBrokerAdapterSink.java | 8 +-
...sSingleton.java => RunningAdapterInstance.java} | 7 +-
.../management/init/RunningAdapterInstances.java | 25 +-
.../management/init/RunningInstances.java | 4 +-
.../monitoring/HealthCheckManagement.java | 53 +-
.../monitoring/MonitoringManagement.java | 34 +-
.../pe/DataProcessorPipelineElementManagement.java | 4 +-
.../pe/DataSinkPipelineElementManagement.java | 4 +-
.../pe/InvocablePipelineElementManagement.java | 6 +-
.../connect/AdapterWorkerManagementTest.java | 58 +-
.../connect/PullAdapterSchedulerTest.java | 55 +
.../connect/adapter/parser/CsvParserTest.java | 30 +
.../iiot/protocol/stream/FileReplayAdapter.java | 31 +-
.../protocol/stream/FileReplayAdapterTest.java | 26 +
.../opcua/OpcUaConnectorsModuleExport.java | 2 +
.../connectors/opcua/adapter/OpcUaAdapter.java | 117 +-
.../connectors/opcua/adapter/OpcUaNodeBrowser.java | 2 +-
.../opcua/alarms/OpcUaAlarmEventSubscriber.java | 32 +-
.../opcua/client/ConnectedOpcUaClient.java | 66 +-
.../opcua/config/OpcUaAdapterConfig.java | 41 +
.../opcua/config/SharedUserConfiguration.java | 61 +-
.../opcua/config/SpOpcUaConfigExtractor.java | 54 +
.../opcua/config/security/SecurityConfig.java | 21 +
...grationV3.java => OpcUaAdapterMigrationV7.java} | 31 +-
.../connectors/opcua/utils/OpcUaLabels.java | 4 +
.../documentation.md | 2 +
.../strings.en | 15 +
.../documentation.md | 2 +
.../adapter/OpcUaAdapterSubscriptionTest.java | 204 +
.../alarms/OpcUaAlarmEventSubscriberTest.java | 68 +
.../opcua/client/ConnectedOpcUaClientTest.java | 66 +
.../opcua/config/SpOpcUaConfigExtractorTest.java | 48 +
.../opcua/config/security/SecurityConfigTest.java | 98 +-
.../plc/adapter/generic/GenericPlc4xAdapter.java | 9 +-
.../connection/ContinuousPlcRequestReader.java | 25 +-
.../plc/adapter/modbus/Plc4xModbusAdapter.java | 5 +
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 14 +-
.../plc/cache/SpConnectionContainer.java | 72 +-
.../plc/cache/SpLeasedPlcConnection.java | 26 +-
.../documentation.md | 3 +
.../documentation.md | 4 +
.../plc/adapter/ConnectionContainerReproTest.java | 218 +
.../notifications/jvm/msteams/MSTeamsSink.java | 518 +-
.../documentation.md | 21 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 230 +-
.../health/monitoring/AdapterHealthCheck.java | 68 +-
.../health/monitoring/ExtensionHealthCheck.java | 67 +-
.../ExtensionInstanceAvailabilityCheck.java | 7 +-
.../ExtensionInstanceDetailsProvider.java | 170 +
.../ExtensionInstanceRemovalService.java | 197 +
.../streampipes/health/monitoring/HealthCheck.java | 5 +-
.../health/monitoring/PipelineHealthCheck.java | 156 +-
.../health/monitoring/PipelineRecoveryBackoff.java | 107 +
...eInstances.java => RunningAdapterInstance.java} | 13 +-
.../model/RunningExtensionInstances.java | 10 +-
...es.java => RunningPipelineElementInstance.java} | 15 +-
.../health/monitoring/utils/HealthCheckUtils.java | 6 +
.../health/monitoring/AdapterHealthCheckTest.java | 129 +
.../health/monitoring/PipelineHealthCheckTest.java | 256 +
.../monitoring/PipelineRecoveryBackoffTest.java | 100 +
.../OpcUaAdapterReadTimeoutReproductionTest.java | 177 +
.../adapters/opcua/OpcUaAdapterTestHarness.java | 34 +-
.../containers/OpcUaDemoServerContainer.java | 7 +-
.../streampipes/loadbalance/LoadManager.java | 3 +-
.../loadbalance/ResourceUnitMigration.java | 9 +-
.../pipeline/ExtensionsLogProvider.java | 37 +
.../loadbalance/unit/InvokeHttpRequest.java | 37 +-
streampipes-mail/pom.xml | 5 +
.../apache/streampipes/mail/AbstractMailer.java | 24 +-
.../org/apache/streampipes/mail/MailSender.java | 23 +-
.../org/apache/streampipes/mail/MailTester.java | 9 +-
.../mail/config/MailConfigurationBuilder.java | 28 +-
.../mail/template/AbstractMailTemplate.java | 18 +-
.../template/AccountActiviationMailTemplate.java | 10 +-
.../mail/template/CustomMailTemplate.java | 5 +-
.../mail/template/InitialPasswordMailTemplate.java | 11 +-
.../template/PasswordRecoveryMailTemplate.java | 10 +-
.../mail/template/TestMailTemplate.java | 7 +-
.../mail/template/part/AbstractPart.java | 4 +-
.../mail/template/part/BaseUrlPart.java | 6 +-
.../streampipes/mail/template/part/LinkPart.java | 5 +-
.../streampipes/mail/template/part/LogoPart.java | 10 +-
.../apache/streampipes/mail/utils/MailUtils.java | 13 +-
.../mail/config/MailConfigurationBuilderTest.java | 96 +
streampipes-maven-plugin/pom.xml | 2 +-
.../messaging/kafka/SpKafkaProducer.java | 28 +-
.../model/client/user/UserApiToken.java | 2 +-
.../model/configuration/EmailConfig.java | 1 +
.../model/connect/TransformationConfig.java | 22 +
...IssueType.java => CsvImportJobStartResult.java} | 23 +-
...mportTargetMode.java => CsvImportJobState.java} | 7 +-
...svImportResult.java => CsvImportJobStatus.java} | 60 +-
.../datalake/importer/CsvImportPreviewResult.java | 9 +
.../export/StreamPipesApplicationPackage.java | 28 -
.../ExtensionServiceBrokerOperations.java | 2 +
.../model/health/AdapterInstanceState.java | 9 +-
.../model/health/ExtensionInstanceHealth.java | 3 +-
.../extensions/ExtensionBrokerRequestReceiver.java | 2 +
.../AdapterHealthOperationHandler.java} | 36 +-
.../extensions/ExtensionServiceRequestTargets.java | 19 +
.../api/extensions/ExtensionServiceRequests.java | 59 +-
.../streampipes/manager/assets/AssetConstants.java | 31 -
.../streampipes/manager/assets/AssetExtractor.java | 13 +-
.../streampipes/manager/assets/AssetManager.java | 31 +-
.../ExtensionsServiceEndpointGenerator.java | 2 +-
.../execution/http/InvokeExtensionRequest.java | 41 +-
.../http/InvokePipelineElementSubmitter.java | 2 +-
.../http/PipelineElementExtensionRequest.java | 5 +-
.../execution/task/StorePipelineStatusTask.java | 3 +
.../manager/extensions/ExtensionItemInstaller.java | 4 +-
.../streampipes/manager/file/FileConstants.java | 30 -
.../streampipes/manager/file/FileHandler.java | 10 +-
.../streampipes/manager/file/FileManager.java | 12 +-
.../CustomTransformOutputSchemaGenerator.java | 10 +-
.../migration/AbstractMigrationManager.java | 4 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 46 +-
.../PipelineElementUserCleaner.java} | 18 +-
.../manager/pipeline/PipelineManager.java | 4 -
.../pipeline/update/PipelineUpdateCoordinator.java | 2 +
.../remote/ContainerProvidedOptionsHandler.java | 42 +-
.../manager/setup/AutoInstallation.java | 2 +-
.../manager/setup/InstallationConfiguration.java | 8 +-
.../manager/setup/SpCoreConfigurationStep.java | 12 +-
.../manager/setup/StreamPipesEnvChecker.java | 17 +-
.../setup/UserRegistrationInstallationStep.java | 9 +-
.../tasks/ApplyDefaultRolesAndPrivilegesTask.java | 10 +-
.../manager/storage/PipelineStorageService.java | 2 +
...{AuthTokenUtils.java => AuthTokenProvider.java} | 45 +-
.../manager/verification/ElementVerifier.java | 15 +-
.../manager/verification/TypedElementVerifier.java | 13 +-
.../verification/extractor/TypeExtractor.java | 14 +-
.../execution/http/InvokeExtensionRequestTest.java | 63 +
.../http/PipelineElementRollbackTest.java | 136 +
.../CustomTransformOutputSchemaGeneratorTest.java | 73 +
.../pipeline/PipelineElementUserCleanerTest.java | 27 +-
.../manager/verification/TypeExtractorTest.java | 20 +-
.../resource/management/SpResourceManager.java | 48 +-
.../resource/management/UserResourceManager.java | 27 +-
.../resource/management/secret/SecretVisitor.java | 2 +-
.../management/secret/SecretServiceTest.java | 64 +
.../rest/core/base/impl/AbstractRestResource.java | 10 -
.../apache/streampipes/rest/ResetManagement.java | 8 +-
.../rest/impl/AdapterHealthResource.java | 107 +-
.../rest/impl/AdapterMonitoringResource.java | 7 +
.../streampipes/rest/impl/Authentication.java | 26 +-
.../rest/impl/ContainerProvidedOptions.java | 22 +-
.../streampipes/rest/impl/EmailResource.java | 19 +-
.../apache/streampipes/rest/impl/FileResource.java | 7 +-
...=> FunctionStateEndpointsEnabledCondition.java} | 4 +-
...onsResource.java => FunctionStateResource.java} | 49 +-
.../streampipes/rest/impl/FunctionsResource.java | 61 +-
.../rest/impl/PipelineCanvasMetadataResource.java | 68 +-
.../rest/impl/PipelineElementAsset.java | 8 +-
.../streampipes/rest/impl/PipelineTemplate.java | 13 +
.../streampipes/rest/impl/ResetResource.java | 8 +-
.../org/apache/streampipes/rest/impl/Setup.java | 8 +-
.../apache/streampipes/rest/impl/UserResource.java | 48 +-
.../impl/admin/EmailConfigurationResource.java | 81 +-
.../admin/ExportProviderConfigurationResource.java | 25 +-
.../impl/admin/ExtensionsInstallationResource.java | 6 +-
.../admin/ExtensionsServiceEndpointResource.java | 8 +-
.../impl/admin/GeneralConfigurationResource.java | 14 +-
.../impl/admin/LocationConfigurationResource.java | 14 +-
.../rest/impl/admin/MigrationResource.java | 7 +-
.../rest/impl/admin/PrivilegeResource.java | 6 +-
.../streampipes/rest/impl/admin/RoleResource.java | 6 +-
.../impl/admin/ServiceRegistrationResource.java | 77 +
.../rest/impl/admin/UserAdminResource.java | 13 +-
.../rest/impl/admin/UserGroupResource.java | 28 +-
.../rest/impl/connect/AdapterResource.java | 4 +-
.../rest/impl/connect/CompactAdapterResource.java | 5 +-
.../rest/impl/connect/GuessResource.java | 10 +-
.../impl/connect/RuntimeResolvableResource.java | 9 +-
.../TransformationScriptLanguageResource.java | 46 +-
.../TransformationScriptTemplateResource.java | 7 +
.../impl/datalake/DataLakeMeasureResource.java | 60 +-
.../rest/impl/datalake/DataLakeResource.java | 78 +-
.../datalake/KioskDashboardDataLakeResource.java | 43 +-
.../importer/CsvDataLakeImportService.java | 71 +-
.../datalake/importer/CsvImportJobManager.java | 162 +
.../impl/datalake/importer/CsvImportParser.java | 29 +-
.../datalake/importer/CsvImportUploadStorage.java | 20 +-
.../datalake/importer/DataLakeImportResource.java | 21 +-
.../impl/pe/PipelineElementTemplateResource.java | 27 +-
.../TransformationScriptLanguageResourceTest.java | 49 +
.../DataLakeLatestEventsBenchmarkTest.java | 108 +
.../rest/impl/datalake/DataLakeResourceTest.java | 101 +
.../importer/CsvDataLakeImportServiceTest.java | 65 +
.../datalake/importer/CsvImportParserTest.java | 1 +
.../minimal/StreamPipesCoreApplicationMinimal.java | 2 -
streampipes-service-core/pom.xml | 5 -
.../streampipes/service/core/PostStartupTask.java | 18 +-
.../service/core/StreamPipesCoreApplication.java | 56 +-
.../service/core/UnauthenticatedInterfaces.java | 2 +-
.../service/core/WebSecurityConfig.java | 35 +-
.../ExtensionServiceRequestConfiguration.java | 22 +-
.../core/filter/TokenAuthenticationFilter.java | 46 +-
.../core/migrations/AvailableMigrations.java | 23 +-
.../service/core/migrations/MigrationsHandler.java | 2 +-
.../v0980/AddDefaultExportProviderMigration.java | 8 +-
.../v099/RemoveAssetUserRoleMigration.java | 11 +-
.../v099/RemoveObsoletePrivilegesMigration.java | 5 +-
.../v099/connect/MigrateAdaptersToUseScript.java | 44 +-
.../MigratePlc4xS7AdaptersToGenericAdapter.java | 443 +
.../core/oauth2/CustomOAuth2UserService.java | 10 +-
.../service/core/oauth2/CustomOidcUserService.java | 10 +-
.../oauth2/OAuth2AuthenticationSuccessHandler.java | 146 +-
.../core/oauth2/OidcUserAccountDetails.java | 16 +-
.../service/core/oauth2/UserService.java | 35 +-
.../service/core/scheduler/DataLakeScheduler.java | 4 +-
.../CertificateExpiryEmailScheduler.java | 20 +-
...ardStorage.java => CachedPrivilegeStorage.java} | 18 +-
...hedChartStorage.java => CachedRoleStorage.java} | 24 +-
.../storage/CachedSpCoreConfigurationStorage.java | 130 +
...ardStorage.java => CachedUserGroupStorage.java} | 18 +-
.../service/core/storage/CachedUserStorage.java | 287 +
.../core/storage/StorageApiConfiguration.java | 64 +-
.../src/main/resources/application.properties | 11 +-
.../core/filter/TokenAuthenticationFilterTest.java | 44 +-
.../v099/MigrateAdaptersToUseScriptTest.java | 86 +
...MigratePlc4xS7AdaptersToGenericAdapterTest.java | 294 +
.../CachedSpCoreConfigurationStorageTest.java | 111 +
.../core/storage/CachedUserStorageTest.java | 177 +
.../core/storage/StorageApiConfigurationTest.java | 25 +-
streampipes-service-extensions/pom.xml | 5 -
.../StreamPipesExtensionsServiceBase.java | 2 -
.../storage/api/core/INoSqlStorage.java | 18 -
.../storage/couchdb/CouchDbStorageManager.java | 42 -
.../user/management/authorization/RoleManager.java | 5 +-
.../user/management/jwt/JwtTokenProvider.java | 37 +-
.../user/management/jwt/SpKeyResolver.java | 15 +-
.../management/model/PrincipalUserDetails.java | 8 +-
.../management/model/ServiceAccountDetails.java | 8 +-
.../user/management/model/UserAccountDetails.java | 8 +-
.../management/service/SpUserDetailsService.java | 29 +-
.../user/management/service/TokenService.java | 33 +-
.../management/util/GrantedAuthoritiesBuilder.java | 16 +-
.../user/management/service/TokenServiceTest.java | 128 +
.../standalone/manager/ProtocolManager.java | 32 +-
.../runtime/StandaloneEventProcessorRuntime.java | 57 +-
.../runtime/StandaloneEventSinkRuntime.java | 45 +-
.../runtime/StandalonePipelineElementRuntime.java | 77 +-
ui/STYLEGUIDE.md | 90 +
ui/angular.json | 35 +-
...aLakeFilterConfig.ts => DatasetFilterConfig.ts} | 2 +-
ui/cypress/support/utils/DashboardUtils.ts | 4 +-
.../support/utils/DataDownloadDialogUtils.ts | 2 +-
ui/cypress/support/utils/PrepareTestDataUtils.ts | 6 +-
ui/cypress/support/utils/asset/AssetBtns.ts | 5 +-
ui/cypress/support/utils/asset/AssetUtils.ts | 57 +-
ui/cypress/support/utils/chart/ChartBtns.ts | 93 +-
ui/cypress/support/utils/chart/ChartUtils.ts | 238 +-
.../support/utils/chart/ChartWidgetTableUtils.ts | 2 +-
ui/cypress/support/utils/dashboard/Inspector.ts | 94 +
ui/cypress/support/utils/dataset/DatasetBtns.ts | 32 +-
.../{DataLakeSeedUtils.ts => DatasetSeedUtils.ts} | 73 +-
ui/cypress/support/utils/dataset/DatasetUtils.ts | 182 +-
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 39 +-
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 69 +-
ui/cypress/support/utils/user/PermissionUtils.ts | 19 +
.../tests/assetManagement/assetFilterTest.spec.ts | 1 +
.../tests/chart/addAssetToDashboard.smoke.spec.ts | 18 +-
...moke.spec.ts => addAssetsToChart.smoke.spec.ts} | 12 +-
.../chart/advancedFilterExpressions.smoke.spec.ts | 6 +-
ui/cypress/tests/chart/autoAggregateTable.spec.ts | 6 +-
ui/cypress/tests/chart/chart-types/heatmap.spec.ts | 5 +-
.../tests/chart/chart-types/histogram.spec.ts | 2 +-
.../tests/chart/chart-types/indicator.spec.ts | 2 +-
ui/cypress/tests/chart/chart-types/map.spec.ts | 12 +-
.../tests/chart/chart-types/progress-bar.spec.ts | 5 +-
.../tests/chart/chart-types/scatter.smoke.spec.ts | 5 +-
ui/cypress/tests/chart/chart-types/table.spec.ts | 4 +-
.../tests/chart/chart-types/timeSeriesSave.spec.ts | 22 +-
.../tests/chart/chart-types/value-card.spec.ts | 9 +-
.../tests/chart/chartDataPreview.smoke.spec.ts | 2 +-
ui/cypress/tests/chart/configuration.smoke.spec.ts | 40 +-
...ard.spec.ts => deleteChartAndDashboard.spec.ts} | 22 +-
.../tests/chart/dynamicColumnFilter.smoke.spec.ts | 4 +-
.../chart/filterNumericalStringProperties.spec.ts | 14 +-
.../tests/chart/missingDataInDataLake.spec.ts | 6 +-
ui/cypress/tests/chart/publicDashboardLink.spec.ts | 84 +
...rderDataView.spec.ts => timeOrderChart.spec.ts} | 8 +-
ui/cypress/tests/chart/timeRangeSelectors.spec.ts | 2 +-
.../chart/widgetDataConfiguration.smoke.spec.ts | 18 +-
...itAdapter.smoke.spec.ts => editAdapter.spec.ts} | 13 +-
...c.ts => editAdapterDatasetSchemaUpdate.spec.ts} | 5 +-
.../editAdapterSettingsAndPipeline.smoke.spec.ts | 6 +-
.../tests/connect/rules/schemaRules.smoke.spec.ts | 2 +-
ui/cypress/tests/connect/rules/valueRules.spec.ts | 2 +-
.../dataDownloadDialogTest.smoke.spec.ts | 14 +-
ui/cypress/tests/dataset/csvImport.spec.ts | 18 +-
.../restartStreamPipes/restartStreamPipes2.ts | 11 +-
ui/cypress/tests/pipeline/pipelineAsset.spec.ts | 58 +-
...spec.ts => pipelineDatasetSchemaUpdate.spec.ts} | 22 +-
.../tests/pipeline/renamePipelineTest.spec.ts | 19 +-
.../pipeline/updatePipelineTest.smoke.spec.ts | 14 +-
.../testAddAssetOnResourceCreation.ts | 4 +-
.../userManagement/testUserRoleCharts.spec.ts | 4 +-
.../userManagement/testUserRoleDashboard.spec.ts | 22 +-
.../userManagement/testUserRoleDataset.spec.ts | 20 +-
ui/deployment/i18n/de.json | 70 +-
ui/deployment/i18n/en.json | 62 +-
ui/deployment/i18n/pl.json | 68 +-
ui/deployment/theme/_custom-variables.scss | 28 +-
ui/karma.conf.js | 66 -
ui/package-lock.json | 10571 +++++++------------
ui/package.json | 55 +-
.../streampipes/platform-services/README.md | 4 -
.../streampipes/platform-services/karma.conf.js | 60 -
.../streampipes/platform-services/package.json | 15 +-
.../src/lib/apis/dashboard-kiosk.service.ts | 16 +-
.../src/lib/apis/datalake-rest.service.ts | 46 +-
.../lib/apis/pipeline-canvas-metadata.service.ts | 12 +-
.../src/lib/model/datalake/csv-import.model.ts | 16 +
.../dashboard-data-request-coordinator.service.ts | 158 +
.../lib/query/data-view-query-generator.service.ts | 32 +-
.../platform-services/src/public-api.ts | 1 +
.../streampipes/platform-services/src/test.ts | 50 -
.../platform-services/tsconfig.spec.json | 10 -
ui/projects/streampipes/shared-ui/README.md | 2 +-
ui/projects/streampipes/shared-ui/karma.conf.js | 61 -
ui/projects/streampipes/shared-ui/package.json | 12 +-
.../alert-banner/alert-banner.component.scss | 5 +
.../pipeline-element.component.scss | 23 +
.../progress-bar.component.html} | 27 +-
.../progress-bar/progress-bar.component.scss} | 23 +-
.../progress-bar/progress-bar.component.ts | 57 +
.../search-select-template.directive.ts | 17 +-
.../search-select/search-select.component.html | 141 +
.../search-select/search-select.component.scss | 104 +
.../search-select/search-select.component.ts | 304 +
.../sp-spinner/sp-spinner.component.html} | 22 +-
.../sp-spinner/sp-spinner.component.scss} | 12 +-
.../components/sp-spinner/sp-spinner.component.ts} | 23 +-
.../components/sp-table/sp-table.component.html | 2 +-
.../components/sp-table/sp-table.component.scss | 129 +-
.../lib/components/sp-table/sp-table.component.ts | 71 +-
.../dialog/card-dialog/card-dialog.component.scss | 5 +-
.../confirm-dialog/confirm-dialog.component.scss | 4 +-
.../services/file-name.service.spec.ts | 2 +
.../object-manage-dialog.component.html | 168 +-
.../object-manage-dialog.component.ts | 135 +-
.../object-permission-dialog.component.html | 139 +-
.../object-permission-dialog.component.ts | 141 +-
.../panel-dialog/panel-dialog.component.scss | 17 +-
.../standard-dialog/standard-dialog.component.scss | 28 +-
.../src/lib/services/keyboard-shortcut.service.ts | 8 +-
.../streampipes/shared-ui/src/public-api.ts | 4 +
.../streampipes/shared-ui/tsconfig.spec.json | 3 +-
ui/src/app/apidocs/apidocs.component.ts | 2 +-
.../asset-details/base-asset-details.directive.ts | 29 +-
.../asset-details-basics.component.html | 58 +-
.../asset-details-basics.component.ts | 3 +
.../asset-details-labels.component.html | 77 +-
.../asset-details-labels.component.ts | 121 +-
.../asset-details-links.component.html | 21 +-
.../edit-asset/asset-details.component.html | 53 +-
.../edit-asset/asset-details.component.ts | 226 +-
.../asset-selection-panel.component.html | 400 +-
.../asset-selection-panel.component.scss | 71 +-
.../asset-selection-panel.component.ts | 232 +-
.../asset-link-table.component.html | 201 +-
.../asset-link-table/asset-link-table.component.ts | 5 +
.../view-asset-links.component.html | 6 +-
.../view-asset-links/view-asset-links.component.ts | 2 +
.../asset-overview/asset-overview.component.ts | 21 +-
.../assets/dialog/base-asset-links.directive.ts | 49 +-
.../app/assets/dialog/base-asset-links.model.ts} | 20 +-
.../create-asset-dialog.component.html | 69 -
.../create-asset/create-asset-dialog.component.ts | 72 -
.../asset-link-table.component.html | 235 +
.../asset-link-table.component.scss} | 40 +-
.../asset-link-table/asset-link-table.component.ts | 330 +
.../asset-link-table/asset-link-table.model.ts} | 12 +-
.../manage-asset-links-dialog.component.html | 403 +-
.../manage-asset-links-dialog.component.ts | 164 +-
.../chart-container/chart-container.component.html | 8 +-
.../chart-container/chart-container.component.ts | 19 +-
.../base/base-data-explorer-widget.directive.ts | 127 +-
.../no-data/no-data-in-date-range.component.html | 1 +
.../map/config/map-widget-config.component.html | 10 +-
.../models/dataview-dashboard.model.ts | 2 +
.../chart-shared/services/chart-shared.service.ts | 21 +-
.../chart-overview-table.component.html | 37 +-
.../chart-overview-table.component.ts | 10 +-
.../chart-overview/chart-overview.component.html | 2 +-
.../chart-overview/chart-overview.component.scss | 5 -
.../chart-data-settings.component.html | 84 +-
.../data-settings/chart-data-settings.component.ts | 160 +-
.../toolbar/chart-view-toolbar.component.html | 2 +-
...xtensions-service-details-dialog.component.html | 2 +-
...service-running-instances-dialog.component.html | 454 +
...ervice-running-instances-dialog.component.scss} | 33 +-
...s-service-running-instances-dialog.component.ts | 375 +
.../email-configuration.component.html | 4 +-
.../email-configuration.component.ts | 38 +-
.../data-export-dialog.component.html | 8 +-
.../export-dialog/data-export-dialog.component.ts | 4 +-
.../data-import-dialog.component.html | 8 +-
.../import-dialog/data-import-dialog.component.ts | 4 +-
.../extensions-installation.component.html | 16 +-
.../extensions-installation.component.ts | 4 +-
.../service-configs-password.component.spec.ts | 44 +-
.../registered-extensions-services.component.html | 16 +-
.../registered-extensions-services.component.ts | 17 +-
.../shared/configuration.service.spec.ts | 15 +-
.../configuration/shared/configuration.service.ts | 66 +
.../adapter-catalog/adapter-catalog.component.html | 14 +-
.../adapter-catalog/adapter-catalog.component.ts | 4 +-
.../adapter-configuration.component.html | 36 +-
.../adapter-configuration.component.ts | 131 +-
.../adapter-deployment-settings.component.html | 46 +-
.../adapter-deployment-settings.component.ts | 119 +-
...configure-fields-loading-message.component.html | 2 +-
.../configure-fields-loading-message.component.ts | 4 +-
.../configure-schema.component.html | 50 +
.../configure-schema.component.scss | 20 +-
.../configure-schema/configure-schema.component.ts | 22 +-
.../configure-schema/field-name-validation.ts | 87 +
.../adapter-result-preview.component.html | 2 +-
.../adapter-result-preview.component.ts | 4 +-
.../adapter-sample-preview.component.html | 2 +-
.../adapter-sample-preview.component.ts | 4 +-
.../start-adapter-configuration.component.html | 179 +-
.../start-adapter-configuration.component.ts | 13 +-
.../existing-adapters.component.html | 28 +-
.../existing-adapters.component.ts | 146 +-
.../adapter-code-dialog.component.html} | 8 +-
.../adapter-code-dialog.component.ts} | 15 +-
.../adapter-started-dialog.component.html | 27 +-
.../adapter-started-dialog.component.ts | 32 +-
.../adapter-started-loading.component.html | 8 +-
.../adapter-started-loading.component.ts | 4 +-
...r-transformation-template-dialog.component.html | 11 +
...ter-transformation-template-dialog.component.ts | 7 +-
.../delete-adapter-dialog.component.html | 6 +-
.../delete-adapter-dialog.component.ts | 5 +-
...r-transformation-template-dialog.component.html | 11 +
...ter-transformation-template-dialog.component.ts | 2 +
.../last-updated-formatter.service.ts | 123 +
.../loading-indicator.component.html | 3 +-
.../loading-indicator.component.scss | 5 -
.../loading-indicator.component.ts | 4 +-
.../simple-metrics/simple-metrics.component.html | 11 +-
.../simple-metrics/simple-metrics.component.scss} | 13 +-
.../simple-metrics/simple-metrics.component.ts | 2 +-
.../multi-step-status-indicator.component.html | 5 +-
.../multi-step-status-indicator.component.ts | 4 +-
.../pipeline-operation-status.component.html | 93 +-
.../pipeline-operation-status.component.scss | 119 +-
.../pipeline-operation-status.component.ts | 31 +-
.../pipeline-started-status.component.html | 2 +-
.../add-to-collection.component.spec.ts | 36 +-
...tic-runtime-resolvable-any-input.component.html | 6 +-
...tatic-runtime-resolvable-any-input.component.ts | 4 +-
...c-runtime-resolvable-oneof-input.component.html | 6 +-
...tic-runtime-resolvable-oneof-input.component.ts | 8 +-
.../static-tree-input-button-menu.component.html | 6 +-
.../static-tree-input-button-menu.component.ts | 4 +-
.../core-ui/status/status-widget.component.scss | 57 +-
.../core/components/toolbar/toolbar.component.scss | 5 +
.../kiosk/dashboard-kiosk.component.html | 13 +
.../kiosk/dashboard-kiosk.component.scss | 7 +
.../components/kiosk/dashboard-kiosk.component.ts | 115 +-
.../dashboard-overview-table.component.ts | 4 +
.../chart-preview/chart-preview.component.scss | 6 +-
.../chart-selection/chart-selection.component.html | 10 +-
.../chart-selection/chart-selection.component.scss | 5 -
.../chart-selection/chart-selection.component.ts | 6 +-
.../panel/dashboard-panel.component.html | 1 +
.../panel/dashboard-panel.component.scss | 10 +
.../components/panel/dashboard-panel.component.ts | 8 +-
.../clone-dashboard-dialog.component.html | 2 +-
.../clone-dashboard-dialog.component.ts | 9 +-
.../edit-dashboard-dialog.component.html | 2 +-
.../dataset-details-events.component.html | 19 +-
.../dataset-details-events.component.ts | 13 +-
.../daily-event-counts-chart.component.html} | 16 +-
.../daily-event-counts-chart.component.scss} | 12 +-
.../daily-event-counts-chart.component.ts | 92 +
.../dataset-details-metrics.component.html} | 51 +-
.../dataset-details-metrics.component.scss} | 4 +-
.../dataset-details-metrics.component.ts | 250 +
.../dataset-details/dataset-details-tabs.ts | 5 +
.../dataset-feature-card.component.html | 20 +
.../dataset-feature-card.component.ts | 62 +-
.../dataset-last-event-label.component.html | 15 +-
.../dataset-last-event-label.component.scss} | 5 +-
.../dataset-last-event-label.component.ts | 69 +
.../dataset-overview-entry.ts} | 9 +-
.../dataset-overview.component.html} | 104 +-
.../dataset-overview.component.scss} | 0
.../dataset-overview.component.ts} | 222 +-
ui/src/app/dataset/dataset.routes.ts | 9 +-
.../csv-import-dialog.component.html | 4 +-
.../csv-import-dialog.component.ts | 96 +-
.../csv-import-upload-state.component.html | 19 +-
.../csv-import-upload-state.component.scss | 19 +-
.../csv-import-upload-state.component.ts | 10 +-
.../data-retention-now-dialog.component.html | 6 +-
.../data-retention-now-dialog.component.ts | 9 +-
.../delete-dataset-dialog.component.html} | 5 +-
.../delete-dataset-dialog.component.ts} | 23 +-
.../delete-export-provider-dialog.component.html | 5 +-
.../delete-export-provider-dialog.component.ts | 5 +-
.../export-provider-connection-test.component.html | 6 +-
.../export-provider-connection-test.component.ts | 9 +-
.../user-defined-output.component.html | 75 +-
.../user-defined-output.component.ts | 5 +-
...-assembly-options-pipeline-cache.component.html | 6 +-
...ne-assembly-options-pipeline-cache.component.ts | 4 +-
.../pipeline-assembly-options.component.html | 51 +-
.../pipeline-assembly-options.component.ts | 42 +-
.../pipeline-assembly.component.html | 5 +-
.../pipeline-assembly.component.ts | 312 +-
.../pipeline-element-icon-stand-row.component.html | 87 +-
.../pipeline-element-icon-stand-row.component.scss | 127 +-
.../pipeline-element-icon-stand-row.component.ts | 16 +-
.../pipeline-element-icon-stand.component.scss | 17 +-
.../pipeline-element-options.component.html | 146 +-
.../pipeline-element-options.component.scss | 82 +-
.../pipeline-element-preview.component.html | 8 +-
.../pipeline-element-preview.component.ts | 4 +-
.../dropped-pipeline-element.component.html | 8 +-
.../dropped-pipeline-element.component.ts | 8 +-
.../components/pipeline/pipeline.component.html | 7 +-
.../components/pipeline/pipeline.component.scss | 41 +-
.../components/pipeline/pipeline.component.ts | 11 +
.../dialog/customize/customize.component.html | 8 +-
.../editor/dialog/customize/customize.component.ts | 2 +
.../save-pipeline-settings.component.html | 177 -
.../save-pipeline-settings.component.scss | 21 -
.../save-pipeline-settings.component.ts | 181 -
.../save-pipeline/save-pipeline.component.html | 118 +-
.../save-pipeline/save-pipeline.component.scss | 18 -
.../save-pipeline/save-pipeline.component.ts | 485 +-
ui/src/app/editor/editor.component.html | 9 +-
ui/src/app/editor/editor.component.ts | 9 +-
.../components/shortcuts/shortcuts.component.ts | 3 +-
.../welcome-tour/welcome-tour.component.html | 8 +-
.../dialog/welcome-tour/welcome-tour.component.ts | 4 +-
.../login/components/login/login.component.html | 5 +-
.../app/login/components/login/login.component.ts | 4 +-
.../components/register/register.component.html | 6 +-
.../components/register/register.component.ts | 4 +-
.../set-new-password.component.html | 6 +-
.../set-new-password/set-new-password.component.ts | 4 +-
.../login/components/setup/setup.component.html | 5 +-
.../app/login/components/setup/setup.component.ts | 4 +-
.../functions-logs/functions-logs.component.html | 4 +-
.../functions-logs/functions-logs.component.ts | 2 +
.../functions-metrics.component.html | 22 +-
.../functions-metrics.component.ts | 2 +
.../pipeline-overview.component.html | 26 +-
.../delete-pipeline-dialog.component.html | 6 +-
.../delete-pipeline-dialog.component.ts | 5 +-
.../pipeline-notifications.component.html | 2 +-
.../pipeline-notifications.component.ts | 5 +-
.../pipeline-status-dialog.component.html | 17 +-
.../pipeline-status-dialog.component.ts | 5 +-
ui/src/app/pipelines/pipelines.component.html | 29 +-
ui/src/app/pipelines/pipelines.component.ts | 11 +-
.../services/pipeline-operations.service.ts | 127 +-
ui/src/scss/sp/_variables.scss | 58 +-
ui/src/scss/sp/buttons-mat3.scss | 266 +-
ui/src/scss/sp/dialog.scss | 30 +-
ui/src/scss/sp/forms-mat3.scss | 45 +-
ui/src/scss/sp/main.scss | 140 +-
ui/src/scss/sp/mat-tab.scss | 44 +-
ui/src/scss/sp/pipeline-element-options.scss | 50 +-
ui/src/scss/sp/pipeline-element.scss | 31 +-
ui/src/scss/sp/sp-dialog.scss | 16 +-
ui/src/scss/sp/sp-theme.scss | 130 +-
.../registration.model.ts => test-setup.ts} | 14 +-
ui/src/test.ts | 41 -
ui/src/tsconfig.spec.json | 11 -
ui/tsconfig.eslint.json | 2 +-
ui/tsconfig.spec.json | 5 +-
707 files changed, 24337 insertions(+), 15566 deletions(-)
create mode 100644 SECURITY.md
create mode 100644 THREAT_MODEL.md
copy
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationTest.java
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/AdapterTransformationConfigDefaults.java
(61%)
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/Utils.java
delete mode 100644 streampipes-connect-transformer-groovy/pom.xml
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/GroovyScriptContext.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/GroovyScriptEngine.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/RestrictedGroovyClassLoader.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/SandboxPolicy.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/ScriptSandbox.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/ast/AstChecksCompilationCustomizer.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/ast/AstChecksVisitor.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/ast/SecureCustomizerFactory.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/error/SandboxCompilationMessageResolver.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/error/SandboxViolationClassNotFoundException.java
delete mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/sandbox/error/SandboxViolationException.java
delete mode 100644
streampipes-connect-transformer-groovy/src/test/java/org/apache/streampipes/connect/transformer/groovy/GroovyScriptEngineTest.java
create mode 100644
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/ConfiguredOutputWriterFactory.java
copy
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/helpers/FiletypesTest.java
=>
streampipes-data-explorer-influx/src/test/java/org/apache/streampipes/dataexplorer/influx/DataExplorerInfluxQueryExecutorTest.java
(57%)
create mode 100644
streampipes-data-explorer-influx/src/test/java/org/apache/streampipes/dataexplorer/influx/InfluxLatestTimestampBenchmarkTest.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterTransitionRegistry.java
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/init/{IDeclarersSingleton.java
=> RunningAdapterInstance.java} (80%)
copy
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/{OpcUaAdapterMigrationV3.java
=> OpcUaAdapterMigrationV7.java} (72%)
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/adapter/OpcUaAdapterSubscriptionTest.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/alarms/OpcUaAlarmEventSubscriberTest.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/client/ConnectedOpcUaClientTest.java
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionInstanceDetailsProvider.java
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionInstanceRemovalService.java
copy
streampipes-dataformat/src/main/java/org/apache/streampipes/dataformat/SpDataFormatFactory.java
=>
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/HealthCheck.java
(88%)
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/PipelineRecoveryBackoff.java
copy
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/model/{ActiveCoreInstances.java
=> RunningAdapterInstance.java} (71%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/credentials/CredentialsProvider.java
=>
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/model/RunningExtensionInstances.java
(74%)
copy
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/model/{ActiveCoreInstances.java
=> RunningPipelineElementInstance.java} (66%)
create mode 100644
streampipes-health-monitoring/src/test/java/org/apache/streampipes/health/monitoring/AdapterHealthCheckTest.java
create mode 100644
streampipes-health-monitoring/src/test/java/org/apache/streampipes/health/monitoring/PipelineHealthCheckTest.java
create mode 100644
streampipes-health-monitoring/src/test/java/org/apache/streampipes/health/monitoring/PipelineRecoveryBackoffTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/OpcUaAdapterReadTimeoutReproductionTest.java
create mode 100644
streampipes-mail/src/test/java/org/apache/streampipes/mail/config/MailConfigurationBuilderTest.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/{CsvImportSchemaIssueType.java
=> CsvImportJobStartResult.java} (73%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/{CsvImportTargetMode.java
=> CsvImportJobState.java} (93%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/{CsvImportResult.java
=> CsvImportJobStatus.java} (56%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/ISubscription.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/health/AdapterInstanceState.java
(87%)
copy
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/{monitoring/ServiceHealthOperationHandler.java
=> connect/AdapterHealthOperationHandler.java} (66%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/assets/AssetConstants.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/file/FileConstants.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{execution/task/PipelineExecutionTask.java
=> pipeline/PipelineElementUserCleaner.java} (61%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/util/{AuthTokenUtils.java
=> AuthTokenProvider.java} (59%)
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/execution/http/InvokeExtensionRequestTest.java
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/execution/http/PipelineElementRollbackTest.java
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/output/CustomTransformOutputSchemaGeneratorTest.java
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/pipeline/IPipelineStorage.java
=>
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/PipelineElementUserCleanerTest.java
(53%)
create mode 100644
streampipes-resource-management/src/test/java/org/apache/streampipes/resource/management/secret/SecretServiceTest.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{ResetEndpointEnabledCondition.java
=> FunctionStateEndpointsEnabledCondition.java} (87%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{FunctionsResource.java
=> FunctionStateResource.java} (62%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportJobManager.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/connect/TransformationScriptLanguageResourceTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/DataLakeLatestEventsBenchmarkTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/DataLakeResourceTest.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/connect/MigratePlc4xS7AdaptersToGenericAdapter.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/storage/{CachedDashboardStorage.java
=> CachedPrivilegeStorage.java} (71%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/storage/{CachedChartStorage.java
=> CachedRoleStorage.java} (62%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/storage/CachedSpCoreConfigurationStorage.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/storage/{CachedDashboardStorage.java
=> CachedUserGroupStorage.java} (71%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/storage/CachedUserStorage.java
copy
streampipes-extensions/streampipes-connectors-opcua/src/test/java/org/apache/streampipes/extensions/connectors/opcua/alarms/OpcUaAlarmEventFilterTest.java
=>
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/filter/TokenAuthenticationFilterTest.java
(53%)
create mode 100644
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/migrations/v099/connect/MigratePlc4xS7AdaptersToGenericAdapterTest.java
create mode 100644
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/storage/CachedSpCoreConfigurationStorageTest.java
create mode 100644
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/storage/CachedUserStorageTest.java
create mode 100644
streampipes-user-management/src/test/java/org/apache/streampipes/user/management/service/TokenServiceTest.java
rename ui/cypress/support/model/{DataLakeFilterConfig.ts =>
DatasetFilterConfig.ts} (96%)
create mode 100644 ui/cypress/support/utils/dashboard/Inspector.ts
rename ui/cypress/support/utils/dataset/{DataLakeSeedUtils.ts =>
DatasetSeedUtils.ts} (81%)
rename ui/cypress/tests/chart/{addAssetsToDataView.smoke.spec.ts =>
addAssetsToChart.smoke.spec.ts} (88%)
rename ui/cypress/tests/chart/{deleteViewAndDashboard.spec.ts =>
deleteChartAndDashboard.spec.ts} (76%)
create mode 100644 ui/cypress/tests/chart/publicDashboardLink.spec.ts
rename ui/cypress/tests/chart/{timeOrderDataView.spec.ts =>
timeOrderChart.spec.ts} (94%)
rename ui/cypress/tests/connect/{editAdapter.smoke.spec.ts =>
editAdapter.spec.ts} (92%)
rename ui/cypress/tests/connect/{editAdapterDataLakeSchemaUpdate.spec.ts =>
editAdapterDatasetSchemaUpdate.spec.ts} (96%)
rename ui/cypress/tests/pipeline/{pipelineDataLakeSchemaUpdate.spec.ts =>
pipelineDatasetSchemaUpdate.spec.ts} (88%)
delete mode 100644 ui/karma.conf.js
delete mode 100644 ui/projects/streampipes/platform-services/karma.conf.js
create mode 100644
ui/projects/streampipes/platform-services/src/lib/query/dashboard-data-request-coordinator.service.ts
delete mode 100644 ui/projects/streampipes/platform-services/src/test.ts
delete mode 100644 ui/projects/streampipes/platform-services/tsconfig.spec.json
delete mode 100644 ui/projects/streampipes/shared-ui/karma.conf.js
copy
ui/projects/streampipes/shared-ui/src/lib/components/{input-schema-panel/input-schema-property/input-schema-property.component.html
=> progress-bar/progress-bar.component.html} (58%)
copy
ui/projects/streampipes/shared-ui/src/lib/{dialog/data-download-dialog/components/select-data/select-data.component.scss
=> components/progress-bar/progress-bar.component.scss} (72%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/progress-bar/progress-bar.component.ts
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/user/IPasswordRecoveryTokenStorage.java
=>
ui/projects/streampipes/shared-ui/src/lib/components/search-select/search-select-template.directive.ts
(66%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/search-select/search-select.component.html
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/search-select/search-select.component.scss
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/search-select/search-select.component.ts
copy
ui/{src/app/connect/components/adapter-configuration/configure-fields/configure-fields-header/configure-fields-header.component.html
=>
projects/streampipes/shared-ui/src/lib/components/sp-spinner/sp-spinner.component.html}
(74%)
copy
ui/{src/app/chart-shared/components/charts/base/no-data/no-data-in-date-range.component.scss
=>
projects/streampipes/shared-ui/src/lib/components/sp-spinner/sp-spinner.component.scss}
(86%)
copy
ui/{src/app/core-ui/multi-step-status-indicator/multi-step-status-indicator.component.ts
=>
projects/streampipes/shared-ui/src/lib/components/sp-spinner/sp-spinner.component.ts}
(72%)
copy ui/{cypress/support/model/PipelineElementInput.ts =>
src/app/assets/dialog/base-asset-links.model.ts} (73%)
delete mode 100644
ui/src/app/assets/dialog/create-asset/create-asset-dialog.component.html
delete mode 100644
ui/src/app/assets/dialog/create-asset/create-asset-dialog.component.ts
create mode 100644
ui/src/app/assets/dialog/manage-asset-links/asset-link-table/asset-link-table.component.html
copy
ui/src/app/assets/{components/asset-details/view-asset/view-asset-links/asset-link-table/asset-link-table-link-type/asset-link-table-type.component.scss
=> dialog/manage-asset-links/asset-link-table/asset-link-table.component.scss}
(58%)
create mode 100644
ui/src/app/assets/dialog/manage-asset-links/asset-link-table/asset-link-table.component.ts
copy
ui/{projects/streampipes/shared-ui/src/lib/components/pipeline-element/pipeline-element.component.scss
=>
src/app/assets/dialog/manage-asset-links/asset-link-table/asset-link-table.model.ts}
(76%)
create mode 100644
ui/src/app/configuration/dialog/extensions-service-running-instances/extensions-service-running-instances-dialog.component.html
copy
ui/src/app/{chart/components/chart-view/designer-panel/visualisation-settings/chart-visualisation-settings.component.scss
=>
configuration/dialog/extensions-service-running-instances/extensions-service-running-instances-dialog.component.scss}
(70%)
create mode 100644
ui/src/app/configuration/dialog/extensions-service-running-instances/extensions-service-running-instances-dialog.component.ts
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-schema/field-name-validation.ts
copy
ui/src/app/{pipeline-details/dialogs/pipeline-code/pipeline-code-dialog.component.html
=> connect/dialog/adapter-code-dialog/adapter-code-dialog.component.html} (87%)
copy
ui/src/app/{editor/dialog/missing-elements-for-tutorial/missing-elements-for-tutorial.component.ts
=> connect/dialog/adapter-code-dialog/adapter-code-dialog.component.ts} (74%)
create mode 100644
ui/src/app/core-services/time-formatting/last-updated-formatter.service.ts
copy
ui/src/app/{chart-shared/components/charts/base/echarts-widget.component.scss
=> core-ui/monitoring/simple-metrics/simple-metrics.component.scss} (91%)
copy
ui/src/app/{connect/dialog/adapter-started/adapter-started-preview/adapter-started-preview.component.html
=>
dataset/components/dataset-details/dataset-details-metrics/daily-event-counts-chart/daily-event-counts-chart.component.html}
(72%)
copy
ui/src/app/{chart-shared/components/charts/base/no-data/no-data-in-date-range.component.scss
=>
dataset/components/dataset-details/dataset-details-metrics/daily-event-counts-chart/daily-event-counts-chart.component.scss}
(86%)
create mode 100644
ui/src/app/dataset/components/dataset-details/dataset-details-metrics/daily-event-counts-chart/daily-event-counts-chart.component.ts
copy
ui/src/app/{connect/components/adapter-details/adapter-details-metrics/adapter-details-metrics.component.html
=>
dataset/components/dataset-details/dataset-details-metrics/dataset-details-metrics.component.html}
(53%)
copy
ui/{projects/streampipes/shared-ui/src/lib/components/sp-exception-message/exception-details-dialog/exception-details-dialog.component.scss
=>
src/app/dataset/components/dataset-details/dataset-details-metrics/dataset-details-metrics.component.scss}
(95%)
create mode 100644
ui/src/app/dataset/components/dataset-details/dataset-details-metrics/dataset-details-metrics.component.ts
copy streampipes-client-go/docs/static/favicons/_head.html =>
ui/src/app/dataset/components/dataset-overview/dataset-last-event-label/dataset-last-event-label.component.html
(74%)
copy
ui/src/app/{configuration/extensions-service-management/certificate-configuration/certificate-configuration.component.scss
=>
dataset/components/dataset-overview/dataset-last-event-label/dataset-last-event-label.component.scss}
(93%)
create mode 100644
ui/src/app/dataset/components/dataset-overview/dataset-last-event-label/dataset-last-event-label.component.ts
rename
ui/src/app/dataset/components/{datalake-configuration/datalake-configuration-entry.ts
=> dataset-overview/dataset-overview-entry.ts} (83%)
rename
ui/src/app/dataset/components/{datalake-configuration/datalake-configuration.component.html
=> dataset-overview/dataset-overview.component.html} (81%)
rename
ui/src/app/dataset/components/{datalake-configuration/datalake-configuration.component.scss
=> dataset-overview/dataset-overview.component.scss} (100%)
rename
ui/src/app/dataset/components/{datalake-configuration/datalake-configuration.component.ts
=> dataset-overview/dataset-overview.component.ts} (70%)
rename
ui/src/app/dataset/dialog/{delete-datalake-index/delete-datalake-index-dialog.component.html
=> delete-dataset/delete-dataset-dialog.component.html} (95%)
rename
ui/src/app/dataset/dialog/{delete-datalake-index/delete-datalake-index-dialog.component.ts
=> delete-dataset/delete-dataset-dialog.component.ts} (81%)
delete mode 100644
ui/src/app/editor/dialog/save-pipeline/save-pipeline-settings/save-pipeline-settings.component.html
delete mode 100644
ui/src/app/editor/dialog/save-pipeline/save-pipeline-settings/save-pipeline-settings.component.scss
delete mode 100644
ui/src/app/editor/dialog/save-pipeline/save-pipeline-settings/save-pipeline-settings.component.ts
copy ui/src/{app/login/components/register/registration.model.ts =>
test-setup.ts} (78%)
delete mode 100644 ui/src/test.ts
delete mode 100644 ui/src/tsconfig.spec.json