This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch add-dataset-permissions in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 592fb5de15f78cfe96ad98e1a1518c33389c5af0 Merge: c0c055f251 63dd142d4a Author: Dominik Riemer <[email protected]> AuthorDate: Thu Jan 15 16:00:32 2026 +0100 Merge branch 'dev' into add-dataset-permissions .../{sp_core.xml => AllExtensionsIIoTInit.xml} | 7 +- .idea/runConfigurations/sp_core.xml | 2 +- pom.xml | 18 +- .../go-client-e2e/adapter/machine.json | 576 +++++++++------- streampipes-client-python/poetry.lock | 6 +- .../apache/streampipes/commons/constants/Envs.java | 30 +- .../commons/constants/GenericDocTypes.java | 3 +- .../commons/environment/DefaultEnvironment.java | 24 +- streampipes-connect-management/pom.xml | 6 + .../management/AdapterEventPreviewPipeline.java | 30 +- .../management/compact/AdapterGenerationSteps.java | 6 +- .../management/compact/SchemaMetadataEnricher.java | 29 +- .../generator/AdapterEnrichmentRuleGenerator.java | 43 -- .../compact/generator/AdapterSchemaGenerator.java | 81 ++- .../AdapterTransformationRuleGenerator.java | 85 --- .../compact/generator/CompactAdapterGenerator.java | 65 +- .../management/health/AdapterHealthCheck.java | 245 ------- .../management/CompactAdapterManagement.java | 3 +- .../management/management/GuessManagement.java | 111 ++- .../management/WorkerAdministrationManagement.java | 70 +- .../connect/management/util/EventSchemaUtils.java | 37 +- .../connect/management/util/WorkerPaths.java | 7 + .../management/health/AdapterHealthCheckTest.java | 96 --- .../generator/AdapterSchemaGeneratorTest.java | 77 --- .../AdapterTransformationRuleGeneratorTest.java | 94 --- streampipes-connect-shared/pom.xml | 11 + .../shared/AdapterPipelineGeneratorBase.java | 123 +++- .../streampipes/connect/shared/DatatypeUtils.java | 3 +- .../preprocessing/convert/SchemaConverter.java | 67 -- .../convert/ToOriginalSchemaConverter.java | 141 ---- .../convert/ToTransformedSchemaConverter.java | 187 ----- .../AdapterTransformationPipelineElement.java | 11 +- ...va => ScriptTransformationPipelineElement.java} | 35 +- ...StatefulTransformationRuleGeneratorVisitor.java | 99 --- ...tatelessTransformationRuleGeneratorVisitor.java | 138 ---- .../schema/AddValueTransformationRule.java | 47 -- .../transform/schema/MoveTransformationRule.java | 105 --- ...ava => RemoveDuplicatesTransformationRule.java} | 4 +- .../value/CorrectionValueTransformationRule.java | 75 -- .../value/DatatypeTransformationRule.java | 2 +- .../transform/value/RegexTransformationRule.java | 70 -- .../value/TimestampTransformationRule.java | 90 --- .../transform/value/UnitTransformationRule.java | 3 +- .../preprocessing/utils/ConversionUtils.java | 93 --- .../shared/preprocessing/convert/Helpers.java | 113 --- .../convert/ToOriginalSchemaConverterTest.java | 122 ---- .../convert/ToTransformedSchemaConverterTest.java | 160 ----- .../AdapterTransformationPipelineElementTest.java | 58 -- .../schema/DeleteTransformationRuleTest.java | 144 ---- .../schema/MoveTransformationRuleTest.java | 97 --- .../schema/RenameTransformationRuleTest.java | 70 -- .../schema/SchemaEventTransformerTest.java | 81 --- .../transform/value/CorrectionValueTest.java | 138 ---- .../value/RegexTransformationRuleTest.java | 96 --- .../transform/value/ValueEventTransformerTest.java | 62 -- streampipes-connect-transformer-api/pom.xml | 45 ++ .../connect/transformer/api/ScriptTransformer.java | 39 +- .../transformer/api/TransformationEngine.java | 34 +- .../transformer/api/TransformationEngines.java | 26 +- .../api/exception/ScriptCompilationException.java | 9 +- .../api/exception/ScriptExecutionException.java | 14 +- .../utils/TransformationEngineConversionUtils.java | 26 +- streampipes-connect-transformer-groovy/pom.xml | 63 ++ .../transformer/groovy/GroovyScriptEngine.java | 74 ++ .../pom.xml | 63 +- .../transformer/js/GraalJsScriptEngine.java | 101 +++ .../transformer/js/PolyglotResultConverter.java | 72 ++ .../influx/DataExplorerInfluxQueryExecutor.java | 2 +- .../extensions/api/connect/IParser.java | 5 +- .../extensions/api/connect/StreamPipesAdapter.java | 32 +- .../connect/AdapterWorkerSampleDataManagement.java | 79 +++ .../management/connect/GuessManagement.java | 100 --- .../management/connect/SchemaUpdateManagement.java | 116 ---- .../connect/TransformationRuleUpdateVisitor.java | 153 ----- .../connect/adapter/AdapterPipelineGenerator.java | 4 +- .../connect/adapter/parser/AvroParser.java | 18 +- .../connect/adapter/parser/CsvParser.java | 43 +- .../connect/adapter/parser/ImageParser.java | 20 +- .../connect/adapter/parser/JsonParsers.java | 6 +- .../connect/adapter/parser/ParserUtils.java | 48 -- .../connect/adapter/parser/json/GeoJsonParser.java | 145 ++-- .../adapter/parser/json/JsonArrayKeyParser.java | 9 +- .../adapter/parser/json/JsonArrayParser.java | 22 +- .../adapter/parser/json/JsonObjectParser.java | 10 +- .../connect/adapter/parser/json/JsonParser.java | 7 +- .../adapter/parser/util/JsonEventProperty.java | 2 + .../connect/adapter/parser/xml/XmlParser.java | 20 +- .../management/init/RunningInstances.java | 10 + .../management/connect/GuessManagementTest.java | 51 -- .../management/connect/adapter/TestUtils.java | 10 - .../connect/adapter/parser/CsvParserTest.java | 101 --- .../connect/adapter/parser/XmlParserTest.java | 39 -- .../parser/json/JsonArrayKeyParserTest.java | 53 -- .../adapter/parser/json/JsonArrayParserTest.java | 35 - .../adapter/parser/json/JsonObjectParsersTest.java | 29 - .../model/SpServiceDefinitionBuilderTest.java | 9 +- .../connect/iiot/adapters/oi4/Oi4Adapter.java | 12 +- .../machine/MachineDataSimulatorAdapter.java | 10 +- .../machine/event/DiagnosticSimulator.java | 9 + .../simulator/machine/event/EventSimulator.java | 3 + .../simulator/machine/event/FlowSimulator.java | 9 + .../simulator/machine/event/PressureSimulator.java | 9 + .../machine/event/WaterlevelSimulator.java | 9 + .../iiot/protocol/stream/FileReplayAdapter.java | 30 +- .../iiot/protocol/stream/HttpServerProtocol.java | 28 +- .../iiot/protocol/stream/HttpStreamProtocol.java | 8 +- .../protocol/stream/FileReplayAdapterTest.java | 136 ---- .../adapters/image/stream/ImageStreamAdapter.java | 18 +- .../connect/adapters/iss/IssAdapter.java | 34 +- .../connectors/influx/adapter/InfluxDbClient.java | 38 +- .../influx/adapter/InfluxDbStreamAdapter.java | 132 +++- .../connectors/kafka/adapter/KafkaProtocol.java | 8 +- .../connectors/mqtt/adapter/MqttProtocol.java | 8 +- .../connectors/nats/adapter/NatsProtocol.java | 67 +- .../connectors/opcua/adapter/OpcUaAdapter.java | 24 +- .../opcua/adapter/OpcUaSchemaProvider.java | 22 +- .../plc/adapter/generic/GenericPlc4xAdapter.java | 18 +- .../plc/adapter/modbus/Plc4xModbusAdapter.java | 141 ++-- .../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 126 ++-- .../connectors/pulsar/adapter/PulsarProtocol.java | 8 +- .../rocketmq/adapter/RocketMQProtocol.java | 8 +- .../connectors/ros/adapter/RosBridgeAdapter.java | 13 +- .../connectors/tubemq/adapter/TubeMQProtocol.java | 8 +- .../streampipes-processors-enricher-jvm/pom.xml | 10 +- .../pom.xml | 26 +- .../health/monitoring/AdapterHealthCheck.java | 168 +++++ .../health/monitoring/ExtensionHealthCheck.java | 57 ++ .../ExtensionInstanceAvailabilityCheck.java | 67 ++ .../health/monitoring/PipelineHealthCheck.java | 210 ++++++ .../health/monitoring/PostStartupRecovery.java | 62 ++ .../health/monitoring/ResourceProvider.java | 104 +++ .../health/monitoring}/ServiceHealthCheck.java | 22 +- .../monitoring}/ServiceRegistrationManager.java | 6 +- .../monitoring/model/ActiveCoreInstances.java | 10 +- .../health/monitoring/model/ActiveResources.java | 13 +- .../health/monitoring/model/HealthCheckData.java | 22 +- .../health/monitoring/utils/HealthCheckUtils.java | 53 ++ .../streampipes/model/assets/SpAssetModel.java | 2 +- .../ConnectTransformationScriptTemplate.java} | 63 +- ...pactTransport.java => ReduceEventRateRule.java} | 4 +- .../model/connect/RemoveDuplicateRule.java | 7 +- ...ansformationConfig.java => ScriptMetadata.java} | 10 +- .../model/connect/TransformationConfig.java | 95 +++ .../model/connect/adapter/AdapterDescription.java | 49 +- .../connect/adapter/compact/CompactAdapter.java | 4 +- .../adapter/compact/CompactEventProperty.java | 5 +- .../model/connect/guess/FieldStatus.java | 3 +- .../model/connect/guess/FieldStatusInfo.java | 22 +- .../{AdapterEventPreview.java => SampleData.java} | 27 +- .../connect/rules/ITransformationRuleVisitor.java | 25 +- .../rules/TransformationRuleDescription.java | 3 +- .../connect/rules/TransformationRulePriority.java | 1 + .../rules/schema/DeleteRuleDescription.java | 7 +- .../connect/rules/schema/MoveRuleDescription.java | 7 +- .../rules/schema/RenameRuleDescription.java | 7 +- .../SchemaTransformationRuleDescription.java | 1 + .../EventRateTransformationRuleDescription.java | 14 +- ...oveDuplicatesTransformationRuleDescription.java | 13 +- .../StreamTransformationRuleDescription.java | 1 + .../rules/value/AddTimestampRuleDescription.java | 7 +- .../AddValueTransformationRuleDescription.java | 14 +- ...hangeDatatypeTransformationRuleDescription.java | 13 +- ...rrectionValueTransformationRuleDescription.java | 7 +- .../value/RegexTransformationRuleDescription.java | 7 +- .../TimestampTranfsformationRuleDescription.java | 7 +- .../rules/value/UnitTransformRuleDescription.java | 7 +- .../value/ValueTransformationRuleDescription.java | 1 + .../extensions/migration/MigrationRequest.java | 5 +- .../svcdiscovery/SpServiceRegistration.java | 23 +- .../model/health/ExtensionInstanceHealth.java | 15 +- .../streampipes/model/util/PropertyUtils.java | 4 - .../connect/adapter/AdapterDescriptionTest.java | 66 -- .../execution/ExtensionServiceExecutions.java | 1 - .../manager/execution/PipelineExecutionInfo.java | 4 +- .../execution/PipelineExecutionTaskFactory.java | 6 +- .../ExtensionsServiceEndpointGenerator.java | 22 +- .../endpoint/ExtensionsServiceEndpointUtils.java | 11 + ...tter.java => BasePipelineElementSubmitter.java} | 23 +- .../http/DetachPipelineElementSubmitter.java | 5 +- .../http/InvokePipelineElementSubmitter.java | 9 +- .../provider/StoredPipelineElementProvider.java | 42 -- .../execution/task/AfterInvocationTask.java | 13 +- .../execution/task/DiscoverEndpointsTask.java | 37 +- .../manager/execution/task/SubmitRequestTask.java | 16 +- .../health/PipelineElementEndpointHealthCheck.java | 51 -- .../manager/health/PipelineHealthCheck.java | 261 ------- .../manager/setup/CouchDbInstallationStep.java | 14 +- .../tasks/AbstractAddGenericStorageViewTask.java | 49 ++ .../tasks/AddScriptTemplateViewTask.java} | 26 +- .../setup/tasks/CreateAssetLinkTypeTask.java | 6 +- .../manager/storage/PipelineStorageService.java | 4 - .../PipelineElementUtils.java} | 17 +- ...e.java => AdapterWorkerSampleDataResource.java} | 51 +- .../extensions/monitoring/HealthCheckResource.java | 67 ++ ...ionHandler.java => SpRestExceptionHandler.java} | 14 +- streampipes-rest/pom.xml | 5 + .../streampipes/rest/impl/ResetResource.java | 6 + .../rest/impl/admin/MigrationResource.java | 2 +- .../impl/admin/ServiceRegistrationResource.java | 2 +- .../rest/impl/connect/AbstractAdapterResource.java | 4 + .../rest/impl/connect/GuessResource.java | 82 ++- .../impl/connect/RuntimeResolvableResource.java | 14 +- .../TransformationScriptLanguageResource.java | 87 +++ .../TransformationScriptTemplateResource.java | 84 +++ .../sdk/builder/adapter/SampleDataBuilder.java | 87 +++ .../minimal/StreamPipesCoreApplicationMinimal.java | 8 +- streampipes-service-core/pom.xml | 15 + .../streampipes/service/core/PostStartupTask.java | 61 +- .../service/core/StreamPipesCoreApplication.java | 47 +- .../core/migrations/AvailableMigrations.java | 8 +- .../AddGenericStorageViewMigration.java} | 26 +- .../v0980/ModifyAssetLinksMigration.java | 2 +- .../v099/AddAssetManagementViewMigration.java | 26 +- .../v099/AddScriptTemplateViewMigration.java | 27 +- .../v099/ModifyAssetLinkIconMigration.java | 110 +++ .../v099/connect/AdapterRuleConverter.java | 202 ++++++ .../v099/connect/MigrateAdaptersToUseScript.java | 154 +++++ .../v099/connect/TransformationScriptBuilder.java | 56 ++ .../v099/MigrateAdaptersToUseScriptTest.java | 398 +++++++++++ .../svcdiscovery/api/ISpServiceDiscovery.java | 4 + .../svcdiscovery/SpServiceDiscoveryCore.java | 12 +- streampipes-service-extensions/pom.xml | 15 + .../StreamPipesExtensionsServiceBase.java | 21 +- .../streampipes/storage/api/INoSqlStorage.java | 3 + .../storage/couchdb/CouchDbStorageManager.java | 10 + .../connect/addNumericalStaticValue/expected.json | 17 - .../connect/addNumericalStaticValue/input.csv | 4 - ui/cypress/fixtures/connect/compact/fileReplay.yml | 3 - .../deleteTransformationRule/nestedInput.json | 1 + .../deleteTransformationRule/prefixInput.csv | 2 - .../connect/regexRule/expectedReplaceAllFalse.csv | 2 - .../connect/regexRule/expectedReplaceAllTrue.csv | 2 - .../expectedReplaceAllTrueWithEmptyString.csv | 2 - ui/cypress/fixtures/connect/regexRule/input.csv | 2 - .../fixtures/connect/schemaRules/expected.csv | 4 +- .../fixtures/connect/valueRules/expected.csv | 4 +- .../transformation-jvm/countArray1/expected.csv | 8 +- .../support/builder/CompactAdapterBuilder.ts | 49 +- ui/cypress/support/utils/FileManagementUtils.ts | 4 +- .../support/utils/ThirdPartyIntegrationUtils.ts | 8 +- ui/cypress/support/utils/UserUtils.ts | 3 +- .../support/utils/connect/CompactAdapterUtils.ts | 3 + ui/cypress/support/utils/connect/ConnectBtns.ts | 117 +++- .../utils/connect/ConnectEventSchemaUtils.ts | 216 +----- ui/cypress/support/utils/connect/ConnectUtils.ts | 166 +++-- ui/cypress/support/utils/connect/OpcUaUtils.ts | 1 + .../support/utils/dataExplorer/DataExplorerBtns.ts | 14 +- .../utils/dataExplorer/DataExplorerUtils.ts | 11 +- .../support/utils/shared/SharedBtns.ts} | 41 +- .../support/utils/shared/SharedUtils.ts} | 21 +- ui/cypress/support/utils/user/UserBtns.ts | 6 - ...rTest.smoke.spec.ts => assetFilterTest.spec.ts} | 0 ui/cypress/tests/connect/adapterWithAssets.spec.ts | 9 +- .../connect/compact/addCompactAdapter.spec.ts | 2 + .../compactAdapterWithTransformation.spec.ts | 10 +- .../tests/connect/compact/uiConfiguration.spec.ts | 1 + .../connect/createAdapterWithoutStarting.spec.ts | 1 + ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 40 +- .../editAdapterSettingsAndPipeline.smoke.spec.ts | 9 +- .../editAdapterTransformationRulesAreKept.spec.ts | 19 +- .../connect/editAdapterValuesAndFields.spec.ts | 48 +- ui/cypress/tests/connect/fileStream.spec.ts | 204 +++--- ui/cypress/tests/connect/formats/format.spec.ts | 55 +- .../connect/machineDataSimulator.smoke.spec.ts | 10 +- .../opcua/startAndEditOpcAdapters.smoke.spec.ts | 11 +- .../connect/opcua/staticPropertyTreeNodesTest.ts | 85 --- .../connect/rules/addNumericalStaticValue.spec.ts | 87 --- .../connect/rules/deleteTransformationRule.spec.ts | 80 +-- ui/cypress/tests/connect/rules/regexRule.spec.ts | 107 --- .../tests/connect/rules/schemaRules.smoke.spec.ts | 25 +- ui/cypress/tests/connect/rules/streamRules.spec.ts | 29 +- ui/cypress/tests/connect/rules/valueRules.spec.ts | 20 +- ui/cypress/tests/connect/scriptTemplate.spec.ts | 81 +++ .../connect/validateConfigurationChanges.spec.ts | 85 +++ ui/cypress/tests/thirdparty/InfluxDb.smoke.spec.ts | 1 + .../userManagement/testGroupManagement.spec.ts | 3 +- ui/package-lock.json | 24 +- ui/package.json | 3 +- .../lib/apis/connect-script-languages.service.ts | 47 ++ .../lib/apis/connect-script-templates.service.ts | 56 ++ .../platform-services/src/public-api.ts | 2 + .../basic-inner-panel.component.html | 8 +- .../basic-inner-panel.component.scss | 12 +- .../form-label/form-label.component.html | 25 +- .../form-label/form-label.component.scss | 2 +- .../confirm-dialog/confirm-dialog.component.html | 2 +- .../streampipes/shared-ui/src/public-api.ts | 1 + .../asset-overview/asset-overview.component.ts | 4 +- .../AdapterConfigurationState.ts | 61 ++ .../adapter-configuration-state.service.ts | 394 +++++++++++ .../adapter-configuration.component.html | 164 +++-- .../adapter-configuration.component.ts | 117 ++-- .../adapter-event-preview-node.component.html | 77 +++ .../adapter-event-preview-node.component.scss | 108 +++ .../adapter-event-preview-node.component.ts | 113 +++ .../adapter-event-preview.component.html} | 34 +- .../adapter-event-preview.component.scss} | 44 +- .../adapter-event-preview.component.ts | 59 ++ .../adapter-settings.component.html | 29 +- .../adapter-settings/adapter-settings.component.ts | 29 +- .../configure-fields-header.component.html} | 23 +- .../configure-fields-header.component.ts} | 17 +- ...onfigure-fields-loading-message.component.html} | 23 +- .../configure-fields-loading-message.component.ts} | 12 +- .../configure-fields-preview.component.html} | 20 +- .../configure-fields-preview.component.scss} | 8 +- .../configure-fields-preview.component.ts} | 20 +- .../configure-fields.component.html | 116 ++++ .../configure-fields.component.scss} | 8 + .../configure-fields/configure-fields.component.ts | 121 ++++ .../configure-fields-error-message.component.html} | 9 +- .../configure-fields-error-message.component.scss} | 2 +- .../configure-fields-error-message.component.ts} | 12 +- .../event-property-row.component.html | 131 ++++ .../event-property-row.component.scss | 52 +- .../event-property-row.component.ts | 188 +++++ .../event-property-scope.component.html | 56 ++ .../event-property-scope.component.ts | 90 +++ .../no-timestamp-error-hint.component.html} | 16 +- .../no-timestamp-error-hint.component.ts | 10 +- .../configure-schema.component.html | 287 ++++++++ .../configure-schema.component.scss} | 35 +- .../configure-schema/configure-schema.component.ts | 309 +++++++++ .../show-field-status-infos.component.html | 58 ++ .../show-field-status-infos.component.scss | 62 +- .../show-field-status-infos.component.ts} | 31 +- .../event-property-row.component.html | 171 ----- .../event-property-row.component.ts | 253 ------- .../event-schema-error-hints.component.cy.ts | 105 --- .../event-schema-error-hints.component.html | 71 -- .../event-schema-preview.component.ts | 48 -- .../event-schema/event-schema.component.html | 151 ---- .../event-schema/event-schema.component.ts | 382 ----------- .../loading-message/loading-message.component.scss | 17 - .../schema-editor-header.component.html | 100 --- .../schema-editor-header.component.scss | 17 - .../schema-editor-header.component.ts | 66 -- .../adapter-options-panel.component.html | 10 +- .../start-adapter-configuration.component.html | 304 ++++---- .../start-adapter-configuration.component.ts | 130 ++-- .../create-adapter/create-adapter.component.html | 2 +- .../edit-adapter/edit-adapter.component.html | 2 +- ui/src/app/connect/connect.module.ts | 58 +- .../adapter-started-dialog.component.html | 1 + .../adapter-started-success.component.html | 8 +- ...adapter-started-update-migration.component.html | 8 +- ...r-transformation-template-dialog.component.html | 57 ++ ...-transformation-template-dialog.component.scss} | 16 +- ...ter-transformation-template-dialog.component.ts | 62 ++ .../edit-regex-transformation.component.html | 52 -- .../edit-regex-transformation.component.scss | 17 - .../edit-data-type/edit-data-type.component.html | 3 +- .../edit-data-type/edit-data-type.component.scss | 20 - .../edit-data-type/edit-data-type.component.ts | 30 +- .../edit-schema-transformation.component.html | 175 ++--- .../edit-schema-transformation.component.ts | 31 +- .../edit-unit-transformation.component.html | 23 +- .../edit-unit-transformation.component.scss | 23 - .../edit-unit-transformation.component.ts | 8 +- .../edit-correction-value.component.html | 66 -- .../edit-correction-value.component.ts | 37 - .../edit-timestamp-property.component.html | 72 -- .../edit-value-transformation.component.html | 77 --- .../edit-value-transformation.component.scss | 17 - .../edit-value-transformation.component.ts | 70 -- .../edit-event-property.component.html | 83 ++- .../edit-event-property.component.ts | 159 ++--- ...r-transformation-template-dialog.component.html | 122 ++++ ...-transformation-template-dialog.component.scss} | 16 +- ...ter-transformation-template-dialog.component.ts | 61 ++ .../all-adapter-actions-dialog.component.html | 1 + .../services/event-property-utils.service.ts | 10 +- ui/src/app/connect/services/rest.service.ts | 49 +- .../services/static-value-transform.service.ts | 15 - .../services/transformation-rule.service.ts | 762 --------------------- .../datalake-configuration.component.ts | 4 +- .../asset-map/home-asset-map.component.ts | 4 +- ui/src/app/home/home.component.ts | 19 +- ui/src/scss/main.scss | 1 - ui/src/scss/sp/_variables.scss | 1 + 380 files changed, 9109 insertions(+), 10401 deletions(-) diff --cc streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/AvailableMigrations.java index 74348ffb13,1df07fd3df..45fa34a026 --- a/streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/AvailableMigrations.java +++ b/streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/AvailableMigrations.java @@@ -31,9 -31,10 +31,11 @@@ import org.apache.streampipes.service.c import org.apache.streampipes.service.core.migrations.v0980.ModifyAssetLinkTypesMigration; import org.apache.streampipes.service.core.migrations.v0980.ModifyAssetLinksMigration; import org.apache.streampipes.service.core.migrations.v099.AddAssetManagementViewMigration; + import org.apache.streampipes.service.core.migrations.v099.AddScriptTemplateViewMigration; import org.apache.streampipes.service.core.migrations.v099.ComputeCertificateThumbprintMigration; import org.apache.streampipes.service.core.migrations.v099.CreateAssetPermissionMigration; + import org.apache.streampipes.service.core.migrations.v099.ModifyAssetLinkIconMigration; +import org.apache.streampipes.service.core.migrations.v099.CreateDatasetPermissionMigration; import org.apache.streampipes.service.core.migrations.v099.MoveAssetContentMigration; import org.apache.streampipes.service.core.migrations.v099.RemoveObsoletePrivilegesMigration; import org.apache.streampipes.service.core.migrations.v099.UniqueDashboardIdMigration; @@@ -71,10 -73,12 +74,13 @@@ public class AvailableMigrations new AddAssetManagementViewMigration(), new MoveAssetContentMigration(), new CreateAssetPermissionMigration(), + new CreateDatasetPermissionMigration(), new RemoveObsoletePrivilegesMigration(), new UniqueDashboardIdMigration(), - new ComputeCertificateThumbprintMigration() + new AddScriptTemplateViewMigration(), + new ComputeCertificateThumbprintMigration(), + new MigrateAdaptersToUseScript(), + new ModifyAssetLinkIconMigration() ); } } diff --cc ui/src/app/dataset/components/datalake-configuration/datalake-configuration.component.ts index 4573edee7c,dd3677e50f..5746518797 --- a/ui/src/app/dataset/components/datalake-configuration/datalake-configuration.component.ts +++ b/ui/src/app/dataset/components/datalake-configuration/datalake-configuration.component.ts @@@ -41,7 -38,7 +40,8 @@@ import DataDownloadDialogComponent, DialogRef, DialogService, + ObjectPermissionDialogComponent, + LocalStorageService, PanelType, SpBreadcrumbService, SpTableComponent, @@@ -54,9 -51,6 +54,8 @@@ import { DeleteExportProviderComponent import { TranslateService } from '@ngx-translate/core'; import { ExportProviderConnectionTestComponent } from '../../dialog/export-provider-connection-test/export-provider-connection-test.component'; import { DataRetentionLogDialogComponent } from '../../dialog/data-retention-log-dialog/data-retention-log-dialog.component'; +import { UserRole } from 'src/app/_enums/user-role.enum'; +import { UserPrivilege } from 'src/app/_enums/user-privilege.enum'; - import { LocalStorageService } from '../../../../../projects/streampipes/shared-ui/src/lib/services/local-storage-settings.service'; @Component({ selector: 'sp-datalake-configuration', @@@ -76,8 -70,6 +75,7 @@@ export class DatalakeConfigurationCompo private breadcrumbService = inject(SpBreadcrumbService); private exportProviderRestService = inject(ExportProviderService); private translateService = inject(TranslateService); + private currentUserService = inject(CurrentUserService); - private translate = inject(TranslateService); dataSource: MatTableDataSource<DataLakeConfigurationEntry> = new MatTableDataSource([]);
