This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch
3927-migrate-all-data-sinks-from-streampipesdatasink-to-istreampipesdatasink
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 88cc5d7fb7 Merge branch 'dev' into
3927-migrate-all-data-sinks-from-streampipesdatasink-to-istreampipesdatasink
add 0cf87b0959 fix: Fix the test time order data view (#3929)
add 61d5090c96 refactor(#3921): Migrate dashboard to control flow syntax
(#3922)
add 62e70c9964 refactor(#3918): Migrate connect to control flow syntax
(#3919)
add dee54c7bb4 chore(deps-dev): bump pyupgrade from 3.16.0 to 3.21.1 in
/streampipes-client-python (#3925)
add 37c4ffd121 fix: Trigger backoff strategy when plc is not connected
(#3930)
add 3dd21f7934 fix(#3933): test editadaptervaluesandfields fails (#3935)
add d561cc88dd feat(#3940): Add permission support to assets (#3941)
add 6592de3773 Migrate DataStream Name in existing Pipelines when updating
an Adapter (#3947)
add 9bc44e2c8f TLS Support for MQTT Data Sink (#3895)
add a3de598bfe refactor: Remove space before client cert title in resource
add afc72791d7 feat(#3944): Improve permission handling (#3946)
add 9457a9edc4 chore(deps): bump actions/checkout from 5 to 6 (#3949)
add a7fd90c7c7 fix: broken mqtt data-cy in publisher (#3950)
add 79244dcfeb fix: Various minor improvements and bug fixes (#3953)
add e54cffaa66 fix: Various layout bugs (#3954)
add 70db85b584 refactor(#3956): Add e2e test for charts (#3957)
add 91e66456c5 fix: Use asset storage for default asset migration (#3955)
add b4f205e698 fix: Update default roles and privileges (#3959)
add e2eaa319fb fix: Align UI views with dashboard and data explorer
permissions (#3961)
add 38f7cfcc04 fix: Connect admins can see live preview (#3963)
add 8a9e3527c6 fix: Connect admins can upload files (#3964)
add 3ebe611381 feat: Add connection test to export provider (#3942)
add 96246cd2e1 fix: Align UI permissions for assets and sites (#3965)
add 588e7e0db2 feat: Remove pipeline selection from data explorer query
selector (#3958)
add 32af33024a fixes: on dev small usability fixes and fixes on filter
function (#3951)
add 6ab2d3d198 feat: Add e2e test for asset roles (#3966)
add 6a283327c2 feat: Improved Logging and Manual Trigger for Datalake
Retention (#3945)
add 2713eeb004 Enhance the filter behavior for Labels and Types on
Resources (#3962)
add 02a77a308a fix: Remove unused import
add 765d7bf524 Fix for missing pre-used labels in label selection (#3969)
add 818dcd9754 fix: Properly handle deleted labels in asset view (#3970)
add 9ebbdf82e4 fix: Title width in data explorer (#3973)
add 363157d829 fix: Use elementId in asset export
add 57cd56c079 feat: Add e2e to test asset filters (#3976)
add 93ab526e24 Merge branch 'dev' into
3927-migrate-all-data-sinks-from-streampipesdatasink-to-istreampipesdatasink
add 3c5645bbab refactor(#3927): Remove unused try catch block
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 2 +-
.github/workflows/cypress-test.yml | 2 +-
.github/workflows/extensions-docs.yml | 2 +-
.github/workflows/go-client-e2e-test.yml | 2 +-
.github/workflows/go-client.yml | 2 +-
.github/workflows/go-docs.yml | 2 +-
.github/workflows/mvn-integration-test.yml | 56 ++
.github/workflows/pr-validation.yml | 12 +-
.github/workflows/pypi-deployment.yml | 2 +-
.github/workflows/python-docs.yml | 2 +-
pom.xml | 9 +
streampipes-client-python/poetry.lock | 12 +-
streampipes-client-python/pyproject.toml | 2 +-
.../streampipes/client/api/DataStreamApi.java | 2 +-
.../apache/streampipes/commons/constants/Envs.java | 1 +
.../commons/environment/DefaultEnvironment.java | 5 +
.../commons/environment/Environment.java | 3 +-
.../management/AdapterUpdateManagement.java | 3 +-
.../export/ObjectStorge/IObjectStorage.java | 1 +
.../export/ObjectStorge/LocalFolder.java | 5 +
.../dataexplorer/export/ObjectStorge/S3.java | 5 +
.../ObjectStorge/TestExportProviderConnection.java | 71 ++
streampipes-data-export/pom.xml | 5 +
.../streampipes/export/DataLakeExportManager.java | 129 ++--
.../export/dataimport/PerformImportGenerator.java | 2 +
.../iiot/IIoTAdaptersExtensionModuleExport.java | 3 +-
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 6 +-
.../oi4/migration/Oi4AdapterMigrationV1.java | 84 +++
.../strings.en | 15 +-
.../strings.en | 2 +-
.../mqtt/MqttConnectorsModuleExport.java | 8 +-
.../connectors/mqtt/adapter/MqttProtocol.java | 6 +-
.../mqtt/migration/MQTTAdapterMigrationV1.java | 87 +++
.../mqtt/migration/MQTTSinkMigrationV1.java | 124 ++++
.../connectors/mqtt/security/SecurityUtils.java | 191 +++++
.../connectors/mqtt/shared/MqttBase.java | 113 +++
.../connectors/mqtt/shared/MqttConfig.java | 179 ++++-
.../connectors/mqtt/shared/MqttConnectUtils.java | 224 +++++-
.../connectors/mqtt/shared/MqttConsumer.java | 101 +--
.../connectors/mqtt/shared/MqttPublisher.java | 98 +++
.../connectors/mqtt/sink/MqttPublisherSink.java | 170 ++---
.../connectors/mqtt/sink/common/MqttClient.java | 165 -----
.../connectors/mqtt/sink/common/MqttOptions.java | 181 -----
.../connectors/mqtt/sink/common/MqttUtils.java | 77 --
.../documentation.md | 7 +-
.../strings.en | 15 +-
.../strings.en | 38 +-
.../connection/ContinuousPlcRequestReader.java | 19 +-
.../sinks/brokers/jvm/jms/JmsPublisherSink.java | 35 +-
streampipes-integration-tests/pom.xml | 63 +-
.../integration/adapters/AdapterTesterBase.java | 11 +-
...ptersTest.java => AdaptersIntegrationTest.java} | 37 +-
.../integration/adapters/MQTTPublisherUtils.java | 61 ++
...dapterTester.java => MqttAdapterTLSTester.java} | 37 +-
.../integration/adapters/MqttAdapterTester.java | 31 +-
...est.java => ClientLiveDataIntegrationTest.java} | 2 +-
.../integration/containers/MosquittoContainer.java | 27 +-
.../src/test/resources/cacerts.pfx | Bin 0 -> 187040 bytes
.../src/test/resources/mosquitto copy.conf | 43 ++
.../src/test/resources/mosquitto.conf | 12 +-
.../src/test/resources/mosquitto.crt | 21 +
.../src/test/resources/mosquitto.key | 28 +
.../src/test/resources/passwd | 1 +
.../model/client/user/DefaultPrivilege.java | 14 -
.../apache/streampipes/model/assets/AssetLink.java | 9 +
.../streampipes/model/assets/AssetLocation.java | 8 +-
.../apache/streampipes/model/assets/AssetSite.java | 11 +-
.../apache/streampipes/model/assets/AssetType.java | 9 +
.../apache/streampipes/model/assets/Isa95Type.java | 15 +-
.../apache/streampipes/model/assets/LatLng.java | 6 +-
.../apache/streampipes/model/assets/SpAsset.java | 33 +
.../streampipes/model/assets/SpAssetModel.java | 49 +-
.../model/datalake/RetentionExportConfig.java | 57 +-
.../streampipes/model/datalake/RetentionLog.java | 69 ++
.../manager/pipeline/PipelineManager.java | 68 +-
.../manager/setup/CouchDbInstallationStep.java | 8 +-
...ewTask.java => AddAssetManagementViewTask.java} | 19 +-
.../setup/tasks/CreateDefaultAssetTask.java | 43 --
...sourceManager.java => CrudResourceManager.java} | 6 +-
.../management/DataExplorerResourceManager.java | 2 +-
.../DataExplorerWidgetResourceManager.java | 2 +-
.../apache/streampipes/rest/ResetManagement.java | 3 +-
.../rest/impl/AssetManagementResource.java | 98 +--
.../apache/streampipes/rest/impl/FileResource.java | 5 +-
.../streampipes/rest/impl/ResetResource.java | 9 +
.../admin/ExportProviderConfigurationResource.java | 40 +-
.../rest/impl/datalake/DataLakeResource.java | 305 +++-----
.../rest/impl/pe/DataStreamResource.java | 15 +
.../streampipes/rest/security/AuthConstants.java | 4 +
.../apache/streampipes/sdk/StaticProperties.java | 15 +
.../core/migrations/AvailableMigrations.java | 12 +-
.../v0980/FixImportedPermissionsMigration.java | 24 +-
.../AddAssetManagementViewMigration.java} | 26 +-
.../v099/CreateAssetPermissionMigration.java | 68 ++
.../migrations/v099/MoveAssetContentMigration.java | 120 +++
.../RemoveObsoletePrivilegesMigration.java} | 32 +-
.../service/core/scheduler/DataLakeScheduler.java | 158 +---
.../streampipes/storage/api/INoSqlStorage.java | 3 +
.../storage/couchdb/CouchDbStorageManager.java | 11 +
...{RoleStorageImpl.java => AssetStorageImpl.java} | 14 +-
.../management/authorization/PrivilegeManager.java | 46 +-
.../user/management/authorization/RoleManager.java | 29 +-
ui/cypress/support/builder/AssetBuilder.ts | 82 +++
.../model/{TreeNodeUserInput.ts => Asset.ts} | 11 +-
ui/cypress/support/utils/DashboardUtils.ts | 22 +
ui/cypress/support/utils/UserUtils.ts | 25 +-
ui/cypress/support/utils/asset/AssetBtns.ts | 26 +
ui/cypress/support/utils/asset/AssetUtils.ts | 82 ++-
.../utils/configuration/ConfigurationUtils.ts | 8 +-
.../support/utils/configuration/SiteUtils.ts | 2 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 16 +
.../utils/connect/ConnectEventSchemaUtils.ts | 19 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 15 +-
.../support/utils/dataExplorer/DataExplorerBtns.ts | 17 +-
.../utils/dataExplorer/DataExplorerUtils.ts | 122 +++-
ui/cypress/support/utils/filter/FilterBtns.ts | 63 ++
ui/cypress/support/utils/filter/FilterUtils.ts | 97 +++
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 4 +
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 13 +-
ui/cypress/support/utils/user/PermissionUtils.ts | 31 +
ui/cypress/support/utils/user/UserBtns.ts | 16 +-
.../tests/assetManagement/assetFilterTest.spec.ts | 282 +++++++
.../assetManagement/generalAssetTest.smoke.spec.ts | 2 -
ui/cypress/tests/connect/adapterWithAssets.spec.ts | 10 +-
.../connect/editAdapterValuesAndFields.spec.ts | 122 ++--
ui/cypress/tests/connect/formats/format.spec.ts | 43 +-
.../dataDownloadDialogTest.smoke.spec.ts | 5 +-
.../dataExplorer/addAssetToDashboard.smoke.spec.ts | 14 +-
.../dataExplorer/addAssetsToDataView.smoke.spec.ts | 14 +-
.../tests/dataExplorer/charts/heatmap.spec.ts | 7 +-
.../tests/dataExplorer/charts/histogram.spec.ts | 3 +-
.../tests/dataExplorer/charts/indicator.spec.ts | 3 +-
ui/cypress/tests/dataExplorer/charts/map.spec.ts | 7 +-
.../dataExplorer/charts/scatter.smoke.spec.ts | 3 +-
ui/cypress/tests/dataExplorer/charts/table.spec.ts | 3 +-
.../dataExplorer/charts/timeSeriesSave.spec.ts | 12 +-
.../dataExplorer/deleteViewAndDashboard.spec.ts | 5 +-
.../dataExplorer/missingDataInDataLake.spec.ts | 5 +-
.../tests/dataExplorer/timeOrderDataView.spec.ts | 3 +-
.../widgetDataConfiguration.smoke.spec.ts | 5 +-
ui/cypress/tests/pipeline/pipelineAsset.spec.ts | 10 +-
ui/cypress/tests/thirdparty/Mqtt.spec.ts | 5 +-
...t.spec.ts => testAddAssetOnResourceCreation.ts} | 10 +-
.../userManagement/testGroupManagement.spec.ts | 13 +-
.../userManagement/testUserRoleAssets.spec.ts | 148 ++++
.../userManagement/testUserRoleCharts.spec.ts | 158 ++++
.../userManagement/testUserRoleConnect.spec.ts | 136 +++-
.../userManagement/testUserRoleDashboard.spec.ts | 204 ++++++
.../userManagement/testUserRolePipeline.spec.ts | 166 +++--
.../testVariousUserRoles.smoke.spec.ts | 9 +-
ui/deployment/i18n/de.json | 83 ++-
ui/deployment/i18n/en.json | 86 +--
.../src/lib/apis/asset-management.service.ts | 19 +-
.../src/lib/apis/datalake-rest.service.ts | 7 +
.../src/lib/apis/export-provider.service.ts | 10 +-
.../src/lib/model/assets/asset.model.ts | 66 +-
.../model/config/export-provider-config.model.ts | 7 +-
.../model/datalake/data-lake-query-config.model.ts | 1 -
.../src/lib/model/gen/streampipes-model-client.ts | 5 +-
.../src/lib/model/gen/streampipes-model.ts | 189 ++++-
.../src/lib/services/isa95-type.service.ts | 3 +-
.../asset-browser-hierarchy.component.ts | 5 +-
...asset-browser-filter-asset-model.component.html | 2 +
.../asset-browser-filter-labels.component.html | 2 +
.../asset-browser-filter-outer.component.html | 1 +
.../asset-browser-filter-sites.component.html | 2 +
.../asset-browser-filter-type.component.html | 2 +
.../asset-browser-filter.component.html | 14 +-
.../asset-browser-toolbar.component.html | 1 +
.../asset-browser-toolbar.component.ts | 1 +
.../asset-browser/asset-browser.component.ts | 1 +
.../asset-browser/asset-browser.service.ts | 132 +++-
.../asset-link-configuration.component.html | 24 +-
.../asset-link-configuration.component.ts | 17 +-
.../object-permission-dialog.component.html | 20 +-
.../lib/services/asset-configuration.service.ts | 36 +-
ui/src/app/_enums/user-privilege.enum.ts | 6 -
ui/src/app/_guards/page-auth.can-active.guard.ts | 18 +-
ui/src/app/assets/assets.module.ts | 6 +
.../asset-details/base-asset-details.directive.ts | 17 +-
.../asset-details-basics.component.html | 3 +
.../asset-details-labels.component.html | 9 +-
.../asset-details-labels.component.ts | 12 +-
.../asset-details-site.component.html | 7 +-
.../asset-details-site.component.ts | 1 +
.../edit-asset/asset-details.component.ts | 34 +-
.../asset-selection-panel.component.html | 9 +
.../asset-selection-panel.component.ts | 3 +
.../view-asset/view-asset.component.ts | 14 +-
.../asset-overview/asset-overview.component.html | 11 +-
.../asset-overview/asset-overview.component.ts | 103 ++-
ui/src/app/configuration/configuration.module.ts | 6 +
.../datalake-configuration.component.html | 114 +++
.../datalake-configuration.component.ts | 45 ++
.../data-retention-dialog.component.html | 13 +-
.../data-retention-dialog.component.ts | 21 +-
.../data-retention-log-dialog.component.html | 97 +++
.../data-retention-log-dialog.component.ts} | 36 +-
.../data-retention-now-dialog.component.html | 81 +++
.../data-retention-now-dialog.component.ts | 75 ++
...export-provider-connection-test.component.html} | 75 +-
.../export-provider-connection-test.component.ts | 79 ++
.../file-upload/file-upload-dialog.component.ts | 2 +-
.../manage-site/manage-site-dialog.component.ts | 10 +-
.../export/data-export-import.component.html | 4 +-
.../edit-user-dialog.component.html | 1 +
.../security-user-config.component.html | 4 +-
.../sites-configuration.component.html | 8 +-
.../sites-configuration.component.ts | 20 +-
.../adapter-catalog/adapter-catalog.component.html | 97 +++
.../adapter-catalog.component.scss} | 0
.../adapter-catalog.component.ts} | 8 +-
.../adapter-description.component.html | 36 +-
.../adapter-description.component.scss | 0
.../adapter-description.component.ts | 0
.../adapter-code-panel.component.html | 51 +-
.../adapter-configuration.component.html | 145 ++--
.../adapter-configuration.component.ts | 6 +-
.../adapter-deployment-settings.component.html | 115 ++-
.../adapter-settings.component.html | 77 +-
.../adapter-settings/adapter-settings.component.ts | 104 ++-
.../configuration-group.component.html | 43 ++
.../configuration-group.component.scss | 0
.../configuration-group.component.ts | 4 +-
.../adapter-template-configuration.directive.ts | 104 ---
.../event-property-row.component.html | 300 ++++----
.../event-schema-error-hints.component.html | 116 +--
.../event-schema/event-schema.component.html | 202 +++---
.../start-adapter-configuration.component.html | 367 +++++-----
.../adapter-details-logs.component.html | 52 +-
.../adapter-details-metrics.component.html | 54 +-
.../configuration-group.component.html | 42 --
.../create-adapter/create-adapter.component.html} | 17 +-
.../create-adapter.component.scss} | 0
.../create-adapter.component.ts} | 8 +-
.../data-marketplace.component.html | 93 ---
.../edit-adapter/edit-adapter.component.html | 45 +-
.../adapter-status-light.component.html | 40 +-
.../existing-adapters.component.html | 58 +-
.../existing-adapters.component.ts | 14 +-
.../new-adapter/new-adapter.component.html | 24 -
ui/src/app/connect/connect.module.ts | 18 +-
.../adapter-started-dialog.component.html | 100 +--
.../adapter-started-preview.component.html | 41 +-
.../adapter-started-success.component.html | 184 +++--
...adapter-started-update-migration.component.html | 84 ++-
.../can-not-edit-adapter-dialog.component.html | 53 +-
.../delete-adapter-dialog.component.html | 272 +++----
.../edit-data-type/edit-data-type.component.html | 43 +-
.../edit-schema-transformation.component.html | 183 ++---
.../edit-unit-transformation.component.html | 194 ++---
.../edit-correction-value.component.html | 40 +-
.../edit-timestamp-property.component.html | 106 ++-
.../edit-value-transformation.component.html | 138 ++--
.../edit-event-property.component.html | 78 +-
.../all-adapter-actions-dialog.component.html | 136 ++--
.../adapter-asset-configuration.service.ts | 25 +-
.../add-to-collection.component.html | 2 +-
.../static-file-input.component.ts | 2 +-
.../core/components/iconbar/iconbar.component.scss | 15 +
.../kiosk/dashboard-kiosk.component.html | 55 +-
.../slide-view/dashboard-slide-view.component.html | 137 ++--
.../dashboard-overview-table.component.html | 73 +-
.../dashboard-overview-table.component.ts | 12 +-
.../overview/dashboard-overview.component.html | 57 +-
.../chart-selection/chart-selection.component.html | 68 +-
.../chart-selection/chart-selection.component.ts | 12 +-
.../panel/dashboard-panel.component.html | 249 ++++---
.../components/panel/dashboard-panel.component.ts | 8 +-
.../dashboard-toolbar.component.html | 146 ++--
.../dashboard-toolbar.component.ts | 2 +-
.../color-mapping-options-config.component.html | 255 +++----
.../select-axis-options-config.component.html | 94 ++-
.../select-color-properties-config.component.html | 58 +-
.../time-series-item-config.component.html | 253 ++++---
...elect-multiple-properties-config.component.html | 61 +-
.../select-single-property-config.component.html | 60 +-
.../visualization-config-outer.component.html | 58 +-
.../data-explorer-chart-container.component.html | 313 ++++----
.../data-explorer-chart-container.component.scss | 2 +-
.../data-explorer-chart-container.component.ts | 4 +
.../charts/base/echarts-widget.component.html | 103 ++-
.../config/gauge-widget-config.component.html | 149 ++--
.../histogram-chart-widget-config.component.html | 145 ++--
.../image-bar-preview.component.html | 45 +-
.../image/image-bar/image-bar.component.html | 84 ++-
.../image-container/image-container.component.html | 51 +-
.../image/image-viewer/image-viewer.component.html | 49 +-
.../charts/image/image-widget.component.html | 64 +-
.../map/config/map-widget-config.component.html | 126 ++--
.../charts/map/map-widget.component.html | 77 +-
.../config/pie-chart-widget-config.component.html | 95 +--
.../config/status-widget-config.component.html | 251 +++----
.../charts/status/status-widget.component.html | 53 +-
.../charts/table/table-widget.component.html | 274 +++----
.../traffic-light-widget-config.component.html | 43 +-
.../traffic-light-widget.component.html | 55 +-
.../data-explorer-chart-view.component.html | 182 ++---
.../data-explorer-chart-view.component.ts | 26 +-
...lorer-widget-appearance-settings.component.html | 55 +-
.../data-explorer-designer-panel.component.html | 262 +++----
.../data-explorer-designer-panel.component.scss | 1 +
.../aggregate-configuration.component.html | 40 +-
...ta-explorer-widget-data-settings.component.html | 806 +++++++++------------
...data-explorer-widget-data-settings.component.ts | 113 +--
.../field-selection-panel.component.html | 86 +--
.../field-selection/field-selection.component.html | 169 +++--
.../group-selection-panel.component.html | 64 +-
...-explorer-visualisation-settings.component.html | 79 +-
...data-explorer-chart-view-toolbar.component.html | 160 ++--
.../data-explorer-overview-table.component.html | 140 ++--
.../data-explorer-overview-table.component.ts | 17 +-
.../overview/data-explorer-overview.component.html | 57 +-
ui/src/app/data-explorer/data-explorer.routes.ts | 2 +-
.../data-explorer/dialog/asset-dialog.component.ts | 4 +-
.../pipeline-element-discovery.component.html | 8 +-
.../pipeline-details-toolbar.component.html | 26 +-
.../pipeline-details-toolbar.component.ts | 3 +
.../pipeline-details.component.html | 1 +
.../pipeline-details/pipeline-details.component.ts | 12 +-
ui/src/app/pipelines/pipelines.component.ts | 10 +-
.../token/token-management-settings.component.html | 6 +-
322 files changed, 10801 insertions(+), 6989 deletions(-)
create mode 100644 .github/workflows/mvn-integration-test.yml
create mode 100644
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/ObjectStorge/TestExportProviderConnection.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/scheduler/DataLakeScheduler.java
=>
streampipes-data-export/src/main/java/org/apache/streampipes/export/DataLakeExportManager.java
(66%)
create mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/oi4/migration/Oi4AdapterMigrationV1.java
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/migration/MQTTAdapterMigrationV1.java
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/migration/MQTTSinkMigrationV1.java
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/security/SecurityUtils.java
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared/MqttBase.java
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared/MqttPublisher.java
delete mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink/common/MqttClient.java
delete mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink/common/MqttOptions.java
delete mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink/common/MqttUtils.java
rename
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/{AdaptersTest.java
=> AdaptersIntegrationTest.java} (75%)
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/MQTTPublisherUtils.java
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/{MqttAdapterTester.java
=> MqttAdapterTLSTester.java} (79%)
rename
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/client/{ClientLiveDataTest.java
=> ClientLiveDataIntegrationTest.java} (95%)
create mode 100644 streampipes-integration-tests/src/test/resources/cacerts.pfx
create mode 100644 streampipes-integration-tests/src/test/resources/mosquitto
copy.conf
create mode 100644
streampipes-integration-tests/src/test/resources/mosquitto.crt
create mode 100644
streampipes-integration-tests/src/test/resources/mosquitto.key
create mode 100644 streampipes-integration-tests/src/test/resources/passwd
copy
streampipes-client/src/main/java/org/apache/streampipes/client/paths/ApiPath.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/assets/AssetLocation.java
(85%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/EventProcessor.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/assets/AssetSite.java
(78%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/EventProcessor.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/assets/Isa95Type.java
(81%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoSuitableSepasAvailableException.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/assets/LatLng.java
(86%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/RetentionLog.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/{AddDataLakeMeasureViewTask.java
=> AddAssetManagementViewTask.java} (65%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/CreateDefaultAssetTask.java
rename
streampipes-resource-management/src/main/java/org/apache/streampipes/resource/management/{AbstractCRUDResourceManager.java
=> CrudResourceManager.java} (92%)
rename
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/{v070/CreateDefaultAssetMigration.java
=> v099/AddAssetManagementViewMigration.java} (57%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/CreateAssetPermissionMigration.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/MoveAssetContentMigration.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/{v970/AddDataLakePipelineTemplateMigration.java
=> v099/RemoveObsoletePrivilegesMigration.java} (54%)
copy
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/{RoleStorageImpl.java
=> AssetStorageImpl.java} (71%)
create mode 100644 ui/cypress/support/builder/AssetBuilder.ts
copy ui/cypress/support/model/{TreeNodeUserInput.ts => Asset.ts} (78%)
create mode 100644 ui/cypress/support/utils/filter/FilterBtns.ts
create mode 100644 ui/cypress/support/utils/filter/FilterUtils.ts
create mode 100644 ui/cypress/tests/assetManagement/assetFilterTest.spec.ts
rename ui/cypress/tests/userManagement/{testUserRoleAsset.spec.ts =>
testAddAssetOnResourceCreation.ts} (93%)
create mode 100644 ui/cypress/tests/userManagement/testUserRoleAssets.spec.ts
create mode 100644 ui/cypress/tests/userManagement/testUserRoleCharts.spec.ts
create mode 100644
ui/cypress/tests/userManagement/testUserRoleDashboard.spec.ts
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/annotation/NotYetImplemented.java
=>
ui/projects/streampipes/platform-services/src/lib/model/config/export-provider-config.model.ts
(82%)
create mode 100644
ui/src/app/configuration/dialog/data-retention-log-dialog/data-retention-log-dialog.component.html
copy
ui/src/app/{pipeline-details/dialogs/pipeline-code/pipeline-code-dialog.component.ts
=>
configuration/dialog/data-retention-log-dialog/data-retention-log-dialog.component.ts}
(58%)
create mode 100644
ui/src/app/configuration/dialog/data-retention-now-dialog/data-retention-now-dialog.component.html
create mode 100644
ui/src/app/configuration/dialog/data-retention-now-dialog/data-retention-now-dialog.component.ts
copy
ui/src/app/configuration/dialog/{delete-export-provider/delete-export-provider-dialog.component.html
=>
export-provider-connection-test/export-provider-connection-test.component.html}
(50%)
create mode 100644
ui/src/app/configuration/dialog/export-provider-connection-test/export-provider-connection-test.component.ts
create mode 100644
ui/src/app/connect/components/adapter-catalog/adapter-catalog.component.html
rename
ui/src/app/connect/components/{data-marketplace/data-marketplace.component.scss
=> adapter-catalog/adapter-catalog.component.scss} (100%)
rename
ui/src/app/connect/components/{data-marketplace/data-marketplace.component.ts
=> adapter-catalog/adapter-catalog.component.ts} (93%)
rename ui/src/app/connect/components/{data-marketplace =>
adapter-catalog}/adapter-description/adapter-description.component.html (65%)
rename ui/src/app/connect/components/{data-marketplace =>
adapter-catalog}/adapter-description/adapter-description.component.scss (100%)
rename ui/src/app/connect/components/{data-marketplace =>
adapter-catalog}/adapter-description/adapter-description.component.ts (100%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-settings/configuration-group/configuration-group.component.html
rename ui/src/app/connect/components/{ =>
adapter-configuration/adapter-settings}/configuration-group/configuration-group.component.scss
(100%)
rename ui/src/app/connect/components/{ =>
adapter-configuration/adapter-settings}/configuration-group/configuration-group.component.ts
(91%)
delete mode 100644
ui/src/app/connect/components/adapter-configuration/directives/adapter-template-configuration.directive.ts
delete mode 100644
ui/src/app/connect/components/configuration-group/configuration-group.component.html
copy ui/{cypress/fixtures/connect/format/xmlObject.xml =>
src/app/connect/components/create-adapter/create-adapter.component.html} (78%)
rename ui/src/app/connect/components/{new-adapter/new-adapter.component.scss
=> create-adapter/create-adapter.component.scss} (100%)
rename ui/src/app/connect/components/{new-adapter/new-adapter.component.ts =>
create-adapter/create-adapter.component.ts} (91%)
delete mode 100644
ui/src/app/connect/components/data-marketplace/data-marketplace.component.html
delete mode 100644
ui/src/app/connect/components/new-adapter/new-adapter.component.html
