This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch
2964-timestamp-conversion-is-broken-in-adapters
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 8b80cddbf3 chore(#2964): Refactor FileReplayAdapter and add unit tests
add 93ff89f810 chore(deps): bump io.nats:jnats from 2.18.0 to 2.19.1
(#2965)
add 28795a5f66 chore(deps): bump nats-py in /streampipes-client-python
(#2966)
add 5f501e888c chore: Reduce complexity of couchdb persistence layer
(#2961)
add 6fb1fe1f7f chore(#2962): Remove deprecated static properties (#2963)
add bcdb18c15c chore: Remove remainings of pipeline category feature
(#2967)
add 0275a60269 chore(deps): bump
org.apache.maven.plugins:maven-surefire-plugin (#2970)
add a38a06e8bc chore: Cleanup persistence layer (#2968)
add 4b1d9e7368 fix(#2971): Improve token generation and URL-enode tokens
(#2972)
new 6a889d8a9a Merge branch 'dev' into
2964-timestamp-conversion-is-broken-in-adapters
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
pom.xml | 2 +-
streampipes-client-python/poetry.lock | 4 +-
.../dataexplorer/DataExplorerSchemaManagement.java | 26 ++---
.../dataexplorer/utils/DataExplorerUtils.java | 2 +-
.../DataExplorerSchemaManagementTest.java | 31 +++--
.../export/resolver/DashboardResolver.java | 10 +-
.../export/resolver/DashboardWidgetResolver.java | 6 +-
.../export/resolver/DataSourceResolver.java | 4 +-
.../export/resolver/DataViewResolver.java | 10 +-
.../export/resolver/DataViewWidgetResolver.java | 6 +-
.../streampipes/export/resolver/FileResolver.java | 4 +-
.../export/resolver/MeasurementResolver.java | 4 +-
.../api/extractor/IParameterExtractor.java | 3 -
.../siddhi/trend/TrendConfigurationVisitor.java | 12 --
.../mail/template/AbstractMailTemplate.java | 7 ++
.../template/AccountActiviationMailTemplate.java | 2 +-
.../template/PasswordRecoveryMailTemplate.java | 2 +-
streampipes-maven-plugin/pom.xml | 2 +-
.../assetdashboard/AssetDashboardConfig.java | 14 ++-
.../model/client/user/AbstractMailToken.java | 14 ++-
.../streampipes/model/client/user/Group.java | 27 +++--
.../model/client/user/PasswordRecoveryToken.java | 3 +
.../model/client/user/UserActivationToken.java | 3 +
.../streampipes/model/shared/api/Storable.java | 13 +--
.../model/base/NamedStreamPipesEntity.java | 11 +-
.../model/dashboard/DashboardEntity.java | 35 +++---
.../model/dashboard/DashboardModel.java | 55 +++++----
.../model/datalake/DataLakeMeasure.java | 12 +-
.../configuration/SpServiceConfiguration.java | 13 ++-
.../svcdiscovery/SpServiceRegistration.java | 13 ++-
.../streampipes/model/file/FileMetadata.java | 13 ++-
.../streampipes/model/pipeline/Pipeline.java | 12 --
.../model/pipeline/PipelineCategory.java | 81 -------------
.../model/staticproperty/DomainStaticProperty.java | 76 ------------
.../staticproperty/RemoteOneOfStaticProperty.java | 123 --------------------
.../model/staticproperty/StaticProperty.java | 1 -
.../staticproperty/StaticPropertyVisitor.java | 4 -
.../model/template/PipelineElementTemplate.java | 44 ++++---
.../org/apache/streampipes/model/util/Cloner.java | 6 -
.../extensions/AvailableExtensionsProvider.java | 8 +-
.../streampipes/manager/file/FileManager.java | 14 +--
.../manager/health/ServiceRegistrationManager.java | 10 +-
.../v2/pipeline/CheckCompletedVisitor.java | 12 --
.../v2/pipeline/UpdateStaticPropertiesVisitor.java | 12 --
.../manager/setup/CouchDbInstallationStep.java | 10 --
.../template/PipelineElementTemplateVisitor.java | 14 +--
.../streampipes/manager/file/TestFileManager.java | 22 ++--
.../ps/PipelineElementTemplateResource.java | 4 +-
.../AbstractDashboardResourceManager.java | 23 ++--
.../AbstractPipelineElementResourceManager.java | 8 +-
.../resource/management/UserResourceManager.java | 13 +--
.../resource/management/secret/SecretVisitor.java | 12 --
.../rest/core/base/impl/AbstractRestResource.java | 17 ---
.../apache/streampipes/rest/ResetManagement.java | 29 +++--
.../rest/impl/AccountActivationResource.java | 1 -
.../rest/impl/AssetDashboardResource.java | 16 +--
.../rest/impl/PipelineCanvasMetadataResource.java | 4 +-
.../streampipes/rest/impl/PipelineCategory.java | 77 ------------
.../streampipes/rest/impl/PipelineResource.java | 1 -
.../rest/impl/admin/MigrationResource.java | 2 +-
.../impl/admin/ServiceConfigurationResource.java | 6 +-
.../impl/admin/ServiceRegistrationResource.java | 8 +-
.../rest/impl/admin/UserGroupResource.java | 8 +-
.../impl/dashboard/AbstractDashboardResource.java | 2 +-
.../rest/impl/dashboard/DashboardWidget.java | 19 +--
.../rest/impl/datalake/DataLakeWidgetResource.java | 22 ++--
...AbstractConfigurablePipelineElementBuilder.java | 39 -------
.../sdk/extractor/AbstractParameterExtractor.java | 18 ---
.../apache/streampipes/sdk/helpers/Groundings.java | 43 -------
.../sdk/helpers/OntologyProperties.java | 36 ------
.../org/apache/streampipes/sdk/helpers/Tuple3.java | 55 ---------
.../streampipes/service/core/PostStartupTask.java | 2 +-
...MergeFilenamesAndRenameDuplicatesMigration.java | 18 +--
.../svcdiscovery/SpServiceDiscoveryCore.java | 4 +-
.../streampipes/storage/api/CRUDStorage.java | 19 ++-
.../streampipes/storage/api/IAdapterStorage.java | 2 +-
.../storage/api/IAssetDashboardStorage.java | 35 ------
.../streampipes/storage/api/IDashboardStorage.java | 36 ------
.../storage/api/IDashboardWidgetStorage.java | 36 ------
.../storage/api/IDataExplorerWidgetStorage.java | 36 ------
.../streampipes/storage/api/IDataLakeStorage.java | 36 ------
.../storage/api/IDataProcessorStorage.java | 2 +-
.../streampipes/storage/api/IDataSinkStorage.java | 2 +-
.../storage/api/IDataStreamStorage.java | 2 +-
.../storage/api/IFileMetadataStorage.java | 37 ------
.../streampipes/storage/api/INoSqlStorage.java | 35 +++---
.../storage/api/IPasswordRecoveryTokenStorage.java | 25 ----
.../api/IPipelineCanvasMetadataStorage.java | 2 +-
.../storage/api/IPipelineCategoryStorage.java | 33 ------
.../api/IPipelineElementTemplateStorage.java | 2 +-
.../streampipes/storage/api/IPipelineStorage.java | 7 --
.../storage/api/IUserActivationTokenStorage.java | 23 ----
.../streampipes/storage/api/IUserGroupStorage.java | 23 ----
.../storage/couchdb/CouchDbStorageManager.java | 129 ++++++++++++---------
.../impl/AdapterDescriptionStorageImpl.java | 14 +--
.../couchdb/impl/AdapterInstanceStorageImpl.java | 14 +--
.../couchdb/impl/AssetDashboardStorageImpl.java | 57 ---------
.../storage/couchdb/impl/DashboardStorageImpl.java | 58 ---------
.../couchdb/impl/DashboardWidgetStorageImpl.java | 58 ---------
.../impl/DataExplorerDashboardStorageImpl.java | 58 ---------
.../impl/DataExplorerWidgetStorageImpl.java | 60 ----------
.../storage/couchdb/impl/DataLakeStorageImpl.java | 58 ---------
.../couchdb/impl/DataProcessorStorageImpl.java | 14 +--
.../storage/couchdb/impl/DataSinkStorageImpl.java | 14 +--
.../couchdb/impl/DataStreamStorageImpl.java | 14 +--
...oryStorageImpl.java => DefaultCrudStorage.java} | 30 ++---
...torageImpl.java => DefaultViewCrudStorage.java} | 22 ++--
.../impl/ExtensionsServiceConfigStorageImpl.java | 60 ----------
.../couchdb/impl/ExtensionsServiceStorageImpl.java | 61 ----------
.../couchdb/impl/FileMetadataStorageImpl.java | 73 ------------
.../couchdb/impl/NotificationStorageImpl.java | 6 +-
.../couchdb/impl/PasswordRecoveryTokenImpl.java | 61 ----------
.../impl/PipelineCanvasMetadataStorageImpl.java | 12 --
.../PipelineElementDescriptionStorageImpl.java | 12 +-
.../impl/PipelineElementTemplateStorageImpl.java | 12 +-
.../storage/couchdb/impl/PipelineStorageImpl.java | 30 -----
.../couchdb/impl/UserActivationTokenImpl.java | 60 ----------
.../storage/couchdb/impl/UserGroupStorageImpl.java | 60 ----------
.../streampipes/storage/couchdb/utils/Utils.java | 58 +--------
.../management/util/SecureStringGenerator.java | 12 ++
.../src/lib/apis/dashboard.service.ts | 47 +-------
.../lib/apis/data-view-data-explorer.service.ts | 2 +-
.../src/lib/apis/pipeline.service.ts | 26 +----
.../src/lib/apis/shared-dashboard.service.ts | 4 +-
.../src/lib/model/dashboard/dashboard.model.ts | 4 +-
.../src/lib/model/gen/streampipes-model.ts | 127 ++++++--------------
.../dashboard-overview.component.ts | 1 -
.../adapter-template-configuration.directive.ts | 2 +-
...pipeline-element-template-config.component.html | 2 +-
.../overview/dashboard-overview.component.ts | 11 +-
.../components/panel/dashboard-panel.component.ts | 10 +-
.../components/widgets/base/base-widget.ts | 4 +-
.../add-visualization-dialog.component.ts | 4 +-
.../data-explorer-designer-panel.component.html | 4 +-
...ta-explorer-visualisation-settings.component.ts | 2 +-
.../data-explorer-dashboard-overview.component.ts | 6 +-
.../data-explorer-dashboard-panel.component.ts | 22 ++--
.../widget-view/abstract-widget-view.directive.ts | 10 +-
...ta-explorer-dashboard-slide-view.component.html | 2 +-
.../data-explorer-dashboard-widget.component.html | 9 +-
.../data-explorer-dashboard-widget.component.ts | 8 +-
.../base/base-data-explorer-widget.directive.ts | 8 +-
.../components/widgets/base/base-widget-config.ts | 18 ++-
.../select-color-properties.component.ts | 2 +-
.../editor/dialog/customize/customize.component.ts | 4 +-
.../save-pipeline/save-pipeline.component.ts | 18 +--
.../pipeline-overview.component.html | 4 +-
.../pipeline-overview.component.ts | 32 +----
.../start-all-pipelines-dialog.component.ts | 22 +---
ui/src/app/pipelines/pipelines.component.html | 1 -
ui/src/app/pipelines/pipelines.component.ts | 26 +----
151 files changed, 673 insertions(+), 2578 deletions(-)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/PeConfig.java
=>
streampipes-model-shared/src/main/java/org/apache/streampipes/model/shared/api/Storable.java
(81%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/PipelineCategory.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/staticproperty/DomainStaticProperty.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/staticproperty/RemoteOneOfStaticProperty.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCategory.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Groundings.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/OntologyProperties.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/Tuple3.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IAssetDashboardStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDashboardStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDashboardWidgetStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataExplorerWidgetStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataLakeStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IFileMetadataStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IPasswordRecoveryTokenStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IPipelineCategoryStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IUserActivationTokenStorage.java
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IUserGroupStorage.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/AssetDashboardStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DashboardStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DashboardWidgetStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataExplorerDashboardStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataExplorerWidgetStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataLakeStorageImpl.java
rename
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/{PipelineCategoryStorageImpl.java
=> DefaultCrudStorage.java} (57%)
copy
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/{ImageStorageImpl.java
=> DefaultViewCrudStorage.java} (62%)
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/ExtensionsServiceConfigStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/ExtensionsServiceStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/FileMetadataStorageImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/PasswordRecoveryTokenImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/UserActivationTokenImpl.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/UserGroupStorageImpl.java
