This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch create-pull-request/patch
in repository https://gitbox.apache.org/repos/asf/streampipes.git
omit 89e35070ee monthly update of vulnerability report
add bb8c4a385a fix(#3201): Remove data type xsd number and replace with
semantic type so number (#3202)
add 09df1580bc fix: Migrate command-line tool config to pyproject.toml
(#3205)
add 02b60f7692 fix: Assign new elementIds in pipeline preview (#3211)
add 755ca49b3f chore(#3207): Remove pipeline element recommender (#3210)
add 970ccf499a feat(#3208): Add math expression evaluator, UI fixes (#3209)
add bf2266c2e0 feat(#3212): Show input fields in customization dialog
(#3213)
add b145f9d72a Move data view name input field to toolbar and simplified
data explorer appearance (#3217)
add 157eae772a feat: add more support for adapter API to Go client (#3204)
add c16cf41d6f Add new traffic light widget to data explorer (#3223)
add 7b8da89c89 feat(#3218): Support custom roles (#3219)
add 19cdd22432 Add status widget to data explorer (#3226)
add 1b7774b9f1 feat(#3227): Move file management to settings (#3228)
add 362216ebf3 feat(#3224): Add API for programmatic adapter creation
(#3225)
add f9e2539573 Add dialog window for deletion of assets (#3236)
add 88b67652ff Add doughnut chart to pie chart (#3235)
add 878e68d697 fix: Modify navigation icon length in cypress tests (#3234)
add eb8d8664f7 fix: Correct regex in pre commit config (#3244)
add ee5fe8c484 chore(deps): bump com.google.protobuf:protobuf-java (#3242)
add c224904980 chore(deps): bump com.google.protobuf:protobuf-java (#3243)
add ea2ecceeeb fix(#3249): Reload component on init (#3250)
add efe8020993 Minor bug fix doughnut chart (#3241)
add 5f9646f35b chore(deps): bump peter-evans/create-pull-request from 6 to
7 (#3215)
add c0dd74c55a fix(#3247): Add waiting time and add test to smoke tests
(#3248)
add ff21060192 fix: Properly update output streams in functions (#3238)
add b0c90d11a4 fix(#3257): Synchronously trigger deregistration handler
(#3258)
add af40c47f44 fix(#3253): Change linting back to check instead of write
(#3254)
add 472569d5e1 feat: Add time selection menu for single widgets in
dashboard (#3240)
add c1e15fe099 docs:Modify the README file of K8S and note that the port
does not match the document use case (#3262)
add 6e5ea81974 feat: Manually override dimensions in data lake sink (#3231)
add 57994127fc refactor: Rename domain properties to semantic type (#3251)
add ca8f2e8f04 chore(deps-dev): bump express from 4.19.2 to 4.21.0 in /ui
(#3230)
add 888b47a5b5 chore(deps): bump body-parser and express in /ui (#3229)
add 8f0d9ecb74 chore(deps): bump org.apache.commons:commons-compress
(#3239)
add d00b775d5b chore(deps-dev): bump cryptography in
/streampipes-client-python (#3214)
add dde4eb1b31 monthly update of vulnerability report
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (89e35070ee)
\
N -- N -- N refs/heads/create-pull-request/patch (dde4eb1b31)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/osv-scanner.yml | 2 +-
VULNERABILITY.md | 136 ++++++++++---
installer/k8s/README.md | 3 +-
pom.xml | 20 +-
streampipes-client-go/streampipes/adapter_api.go | 175 +++++++++++++++++
.../internal/serializer/deserializer.go | 75 ++++---
.../streampipes/internal/serializer/serializer.go | 15 ++
.../model/adapter/adapter_description.go | 51 +++++
streampipes-client-go/streampipes/model/common.go | 59 +++---
.../streampipes/streampipes_client.go | 4 +
streampipes-client-python/.pre-commit-config.yaml | 12 +-
streampipes-client-python/poetry.lock | 63 +++---
streampipes-client-python/pyproject.toml | 10 +
.../streampipes/endpoint/api/data_lake_measure.py | 6 +-
.../functions/utils/data_stream_generator.py | 5 +-
.../streampipes/model/common.py | 4 +-
.../streampipes/model/resource/data_stream.py | 2 +-
.../tests/client/test_endpoint.py | 8 +-
streampipes-client/pom.xml | 5 +
.../management/compact/AdapterGenerationSteps.java | 45 +++++
.../management/compact/PersistPipelineHandler.java | 106 ++++++++++
.../management/compact/SchemaMetadataEnricher.java | 66 +++++++
.../compact/generator/AdapterBasicsGenerator.java | 31 ++-
.../compact/generator/AdapterConfigGenerator.java | 31 +--
.../generator/AdapterEnrichmentRuleGenerator.java | 41 ++++
.../compact/generator/AdapterModelGenerator.java | 14 +-
.../compact/generator/AdapterSchemaGenerator.java | 61 ++++++
.../AdapterTransformationRuleGenerator.java | 85 ++++++++
.../management/AdapterMasterManagement.java | 13 +-
.../management/CompactAdapterManagement.java | 70 +++++++
.../generator/AdapterSchemaGeneratorTest.java | 77 ++++++++
.../AdapterTransformationRuleGeneratorTest.java | 94 +++++++++
.../convert/ToOriginalSchemaConverter.java | 2 +-
.../convert/ToTransformedSchemaConverter.java | 4 +-
.../dataexplorer/api/IDataExplorerManager.java | 10 +-
.../influx/DataExplorerManagerInflux.java | 23 ++-
.../influx/PropertyDuplicateFilter.java | 45 +++++
.../dataexplorer/influx/PropertyHandler.java | 51 ++---
.../influx/TimeSeriesStorageInflux.java | 10 +-
.../influx/PropertyDuplicateFilterTest.java | 63 ++++++
.../iotdb/DataExplorerManagerIotDb.java | 2 +-
.../iotdb/IotDbPropertyConverterTest.java | 13 +-
.../streampipes/dataexplorer/ImageStoreUtils.java | 5 +-
.../api/extractor/IParameterExtractor.java | 4 +
.../connect/adapter/parser/json/GeoJsonParser.java | 10 +-
.../management/util/EventSchemaUtils.java | 3 +-
.../iiot/protocol/stream/FileReplayAdapter.java | 5 +-
.../iiot/protocol/stream/HttpServerProtocol.java | 5 +-
.../connectors/opcua/utils/OpcUaUtil.java | 2 +
.../streampipes-processors-enricher-jvm/pom.xml | 6 +
.../jvm/EnricherExtensionModuleExport.java | 4 +-
.../processor/expression/JexlContextGenerator.java | 39 ++--
.../jvm/processor/expression/JexlDescription.java | 15 +-
.../processor/expression/JexlEngineProvider.java | 24 ++-
.../jvm/processor/expression/JexlEvaluator.java | 37 ++--
.../expression/MathExpressionFieldExtractor.java | 72 +++++++
.../expression/MathExpressionProcessor.java | 131 +++++++++++++
.../documentation.md | 50 +++--
.../icon.png | Bin 0 -> 2484 bytes
.../strings.en | 27 +--
.../processor/expression/JexlEvaluatorTest.java | 95 +++++++++
.../expression/MathExpressionProcessorTest.java | 77 ++++++++
.../siddhi/listcollector/ListCollector.java | 6 +-
.../jvm/InternalSinksExtensionModuleExports.java | 5 +-
.../jvm/datalake/DataLakeDimensionProvider.java | 69 +++++++
.../sinks/internal/jvm/datalake/DataLakeSink.java | 81 +++++---
.../migrations/DataLakeSinkMigrationV2.java | 83 ++++++++
.../documentation.md | 29 +++
.../strings.en | 6 +
.../migrations/DataLakeSinkMigrationV2Test.java | 95 +++++++++
.../integration/adapters/KafkaAdapterTester.java | 13 +-
.../integration/adapters/MqttAdapterTester.java | 12 +-
.../integration/adapters/PulsarAdapterTester.java | 17 +-
.../model/client/matching/MatchingResultType.java | 4 +-
.../user/{Privilege.java => DefaultPrivilege.java} | 14 +-
.../streampipes/model/client/user/DefaultRole.java | 53 +++++
.../streampipes/model/client/user/Group.java | 6 +-
.../streampipes/model/client/user/Principal.java | 6 +-
.../streampipes/model/client/user/Privilege.java | 116 ++++-------
.../apache/streampipes/model/client/user/Role.java | 165 +++++++---------
.../model/client/user/ServiceAccount.java | 2 +-
.../streampipes/model/client/user/UserAccount.java | 6 +-
.../connect/adapter/compact/CompactAdapter.java | 52 +++++
.../adapter/compact/CompactConfiguration.java | 6 +-
.../adapter/compact/CompactEventProperty.java | 15 +-
.../connect/adapter/compact/CompactTransport.java | 5 +-
.../connect/adapter/compact/CreateOptions.java | 6 +-
.../connect/adapter/compact/EnrichmentConfig.java | 4 +-
.../adapter/compact/TransformationConfig.java | 13 +-
.../streampipes/model/dashboard/DashboardItem.java | 10 +
.../pipeline/PipelineElementRecommendation.java | 17 --
.../PipelineElementRecommendationMessage.java | 13 --
.../model/preview/PipelinePreviewModel.java | 14 +-
.../streampipes/model/schema/EventProperty.java | 41 ++--
.../model/schema/EventPropertyList.java | 7 +-
.../model/schema/EventPropertyPrimitive.java | 25 ++-
.../model/staticproperty/StaticPropertyGroup.java | 2 +-
.../model/template/PipelineElementTemplate.java | 11 +-
.../manager/matching/ConnectionStorageHandler.java | 70 -------
.../matching/PipelineModificationGenerator.java | 8 +-
.../matching/PipelineVerificationHandlerV2.java | 4 +-
.../matching/output/PropertyDuplicateRemover.java | 14 +-
.../output/TransformOutputSchemaGenerator.java | 3 +-
.../manager/matching/v2/ListPropertyMatch.java | 6 +-
.../matching/v2/PrimitivePropertyMatch.java | 12 +-
.../manager/matching/v2/PropertyMatch.java | 2 +-
...inPropertyMatch.java => SemanticTypeMatch.java} | 23 +--
.../pipeline/AbstractPipelineValidationStep.java | 10 +-
...Validator.java => IPipelineValidationStep.java} | 20 +-
.../v2/pipeline/PipelineValidationSteps.java | 2 +-
.../matching/v2/pipeline/PipelineValidator.java | 11 +-
.../manager/preview/PipelinePreview.java | 29 ++-
.../manager/recommender/ElementRecommender.java | 82 +-------
.../remote/ContainerProvidedOptionsHandler.java | 3 +-
.../manager/setup/CouchDbInstallationStep.java | 28 ---
.../setup/UserRegistrationInstallationStep.java | 6 +-
.../manager/setup/design/UserDesignDocument.java | 13 ++
.../tasks/ApplyDefaultRolesAndPrivilegesTask.java | 67 +++++++
.../manager/storage/PipelineStorageService.java | 5 +-
.../manager/template/AbstractTemplateHandler.java | 7 +-
.../template/PipelineElementTemplateVisitor.java | 215 ++++++++++++++-------
.../template/PipelineTemplateManagement.java | 80 ++++++++
.../manager/matching/v2/ListPropertyMatchTest.java | 10 +-
...opertyMatch.java => TestSemanticTypeMatch.java} | 23 +--
.../PipelineElementTemplateVisitorTest.java | 153 ++++++++++++++-
.../ps/PipelineElementTemplateResource.java | 2 +-
.../resource/management/UserResourceManager.java | 6 +-
streampipes-rest-core-base/pom.xml | 4 +
.../base/impl/AbstractAuthGuardedRestResource.java | 6 +-
.../rest/core/base/impl/CRUDResource.java | 50 +++++
.../core/base/impl/DefaultCRUDRestResource.java | 64 ++++++
.../base/impl/converter/YamlConfiguration.java | 56 ++++++
streampipes-rest/pom.xml | 4 +
.../rest/impl/GenericStorageResource.java | 2 +-
.../streampipes/rest/impl/PipelineTemplate.java | 54 ++----
.../apache/streampipes/rest/impl/UserResource.java | 4 +-
.../PrivilegeResource.java} | 28 +--
.../Dashboard.java => admin/RoleResource.java} | 30 ++-
.../rest/impl/connect/AdapterResource.java | 73 +++----
.../rest/impl/connect/CompactAdapterResource.java | 147 ++++++++++++++
.../streampipes/rest/impl/dashboard/Dashboard.java | 6 +-
.../impl/datalake/DataLakeDashboardResource.java | 6 +-
.../rest/impl/datalake/DataLakeWidgetResource.java | 6 +-
.../streampipes/rest/security/AuthConstants.java | 42 ++--
.../rest/security/SpPermissionEvaluator.java | 5 +-
.../apache/streampipes/sdk/StaticProperties.java | 47 ++---
.../sdk/builder/PrimitivePropertyBuilder.java | 23 ++-
.../sdk/builder/PropertyRequirementsBuilder.java | 11 --
.../sdk/extractor/AbstractParameterExtractor.java | 22 ++-
.../streampipes/sdk/helpers/EpProperties.java | 39 ++--
.../streampipes/sdk/helpers/EpRequirements.java | 35 +++-
.../serializers/json/TestJacksonSerializer.java | 20 +-
.../service/core/StreamPipesCoreApplication.java | 3 +
.../core/migrations/AvailableMigrations.java | 4 +-
.../migrations/v970/AddRolesToUserDbMigration.java | 64 ++++++
.../service/core/oauth2/UserService.java | 5 +-
.../function/StreamPipesFunctionHandler.java | 47 +++--
.../streampipes/storage/api/INoSqlStorage.java | 8 +-
.../storage/couchdb/CouchDbStorageManager.java | 21 +-
.../couchdb/impl/ConnectionStorageImpl.java | 108 -----------
.../storage/couchdb/impl/PrivilegeStorageImpl.java | 15 +-
.../storage/couchdb/impl/RoleStorageImpl.java | 16 +-
.../serializer/EventPropertySerializer.java | 58 ++++++
.../storage/couchdb/serializer/GsonSerializer.java | 2 +-
.../streampipes/storage/couchdb/utils/Utils.java | 6 +-
.../couchdb/serializer/TestGsonSerializer.java | 30 ++-
.../executors/ProcessingElementTestExecutor.java | 38 ++--
.../EventPropertyPrimitiveTestBuilder.java | 3 +-
.../test/generator/EventStreamGenerator.java | 3 +-
.../template/PipelineElementTemplateHelpers.java | 13 +-
.../management/authorization/PrivilegeManager.java | 57 ++++++
.../user/management/authorization/RoleManager.java | 108 +++++++++++
.../management/util/GrantedAuthoritiesBuilder.java | 15 +-
ui/.lintstagedrc.json | 4 +-
ui/cypress/support/utils/FileManagementUtils.ts | 6 +-
ui/cypress/support/utils/datalake/DataLakeUtils.ts | 6 +-
.../connect/opcua/startAndEditOpcAdapters.spec.ts | 2 -
.../tests/datalake/timeRangeSelectors.spec.ts | 5 +-
.../userManagement/testGroupManagement.spec.ts | 2 +-
.../userManagement/testUserRolePipeline.spec.ts | 2 +-
.../testVariousUserRoles.smoke.spec.ts | 8 +-
ui/deployment/app-routing.module.mst | 5 +-
ui/deployment/base-navigation.component.mst | 34 ++--
ui/deployment/dev/config.yml | 1 -
ui/deployment/home.service.mst | 9 +-
ui/deployment/modules.yml | 44 ++---
ui/deployment/prebuild.js | 1 +
ui/package-lock.json | 105 ++++++----
.../src/lib/apis/privilege.service.ts} | 35 ++--
.../platform-services/src/lib/apis/role.service.ts | 60 ++++++
.../src/lib/model/dashboard/dashboard.model.ts | 1 +
.../src/lib/model/datalake/DateRange.ts | 5 +
.../src/lib/model/gen/streampipes-model-client.ts | 67 +++++--
.../src/lib/model/gen/streampipes-model.ts | 54 ++----
.../src/lib/model/types/data-type.ts | 5 +-
.../src/lib/model/types/semantic-type.ts | 16 +-
.../platform-services/src/public-api.ts | 2 +
.../asset-browser/asset-browser.component.html | 106 +++++-----
.../asset-browser/asset-browser.component.ts | 23 ++-
.../src/lib/models/sp-navigation.model.ts | 1 +
.../src/lib/services/current-user.service.ts | 17 ++
ui/src/app/_enums/user-privilege.enum.ts | 26 ++-
ui/src/app/_guards/page-auth.can-active.guard.ts | 5 +-
ui/src/app/_models/auth.model.ts | 3 -
.../asset-overview/asset-overview.component.html | 3 +
.../asset-overview/asset-overview.component.ts | 45 ++++-
.../configuration-route.guard.ts} | 31 ++-
.../configuration/configuration-tabs.service.ts | 114 +++++++++++
ui/src/app/configuration/configuration-tabs.ts | 76 --------
ui/src/app/configuration/configuration.module.ts | 34 ++++
.../datalake-configuration.component.ts | 11 +-
.../file-rename/file-rename-dialog.component.html | 0
.../file-rename/file-rename-dialog.component.scss} | 0
.../file-rename/file-rename-dialog.component.ts | 0
.../file-upload/file-upload-dialog.component.html | 0
.../file-upload/file-upload-dialog.component.scss | 0
.../file-upload/file-upload-dialog.component.ts | 0
.../email-configuration.component.ts | 10 +-
.../export/data-export-import.component.ts | 9 +-
.../extensions-installation.component.ts | 9 +-
.../service-configs-item.component.html} | 40 ++--
.../service-configs-item.component.ts} | 28 +--
.../service-configs/service-configs.component.html | 37 +---
.../extensions-service-management.component.ts | 14 +-
.../file-overview/file-overview.component.html | 0
.../file-overview/file-overview.component.scss | 0
.../file-overview/file-overview.component.ts | 0
.../{ => configuration}/files/files.component.html | 48 ++---
.../{ => configuration}/files/files.component.scss | 0
.../{ => configuration}/files/files.component.ts | 17 +-
.../general-configuration.component.html | 14 +-
.../general-configuration.component.ts | 23 ++-
.../edit-label/edit-label.component.html | 3 +-
.../label-configuration.component.html | 48 ++---
.../label-configuration.component.ts | 10 +-
.../messaging-configuration.component.ts | 10 +-
.../edit-group-dialog.component.html | 8 +-
.../edit-group-dialog.component.ts | 22 ++-
.../edit-role-dialog.component.html | 121 ++++++++++++
.../edit-role-dialog.component.scss} | 27 ++-
.../edit-role-dialog/edit-role-dialog.component.ts | 136 +++++++++++++
.../edit-user-dialog.component.html | 10 +-
.../edit-user-dialog/edit-user-dialog.component.ts | 26 +--
.../role-configuration.component.html} | 57 +++---
.../role-configuration.component.scss} | 6 +-
.../role-configuration.component.ts} | 63 +++---
.../security-configuration.component.html | 6 +
.../security-configuration.component.ts | 14 +-
.../security-service-config.component.html | 14 +-
.../security-user-config.component.html | 16 +-
.../user-group-configuration.component.html | 14 +-
.../user-group-configuration.component.scss | 4 +
.../user-group-configuration.component.ts | 8 +-
.../sites-configuration.component.ts | 17 +-
.../event-property-row.component.ts | 5 +-
.../event-schema/event-schema.component.ts | 6 +-
.../adapter-template-dialog.component.ts | 20 +-
.../edit-schema-transformation.component.html | 2 +-
.../edit-schema-transformation.component.ts | 11 +-
.../edit-event-property.component.ts | 4 +-
ui/src/app/connect/filter/timestamp.pipe.ts | 4 +-
.../services/transformation-rule.service.ts | 8 +-
ui/src/app/core-ui/core-ui.module.ts | 2 +
.../pipeline-element-runtime-info.component.ts | 45 ++---
.../pipeline-element-schema.service.ts | 61 ++++++
...ne-element-template-config-item.component.html} | 21 +-
...eline-element-template-config-item.component.ts | 59 ++++++
...pipeline-element-template-config.component.html | 17 +-
.../pipeline-element-template-config.component.ts | 44 +----
.../pipeline-element-template-generator.ts | 87 +++++----
.../pipeline-started-status.component.html | 1 +
.../static-file-input.component.ts | 4 +-
.../static-property-util.service.ts | 7 +
.../static-property.component.html | 1 +
...tic-runtime-resolvable-any-input.component.html | 54 ++++--
...tatic-runtime-resolvable-any-input.component.ts | 31 ++-
...atic-runtime-resolvable-tree-input.component.ts | 12 +-
.../static-slide-toggle.component.html | 1 -
.../static-slide-toggle.component.ts | 1 +
.../core/components/iconbar/iconbar.component.html | 42 +---
.../core/components/iconbar/iconbar.component.ts | 4 -
.../widgets/table/table-widget.component.ts | 2 +-
ui/src/app/dashboard/sdk/ep-requirements.ts | 6 +-
.../app/dashboard/sdk/matching/datatype-match.ts | 4 +-
.../sdk/matching/domain-property-match.ts | 15 +-
.../sdk/matching/primitive-property-match.ts | 4 +-
.../data-explorer-data-view.component.html | 1 +
.../data-explorer-data-view.component.scss | 5 +
...lorer-widget-appearance-settings.component.html | 14 --
.../data-explorer-designer-panel.component.html | 10 -
.../data-explorer-data-view-toolbar.component.html | 34 +++-
.../data-explorer-data-view-toolbar.component.ts | 9 +-
.../custom-time-range-selection.component.html | 1 +
.../time-selector-menu.component.html | 1 +
.../data-explorer-dashboard-widget.component.html | 28 +++
.../data-explorer-dashboard-widget.component.ts | 61 +++++-
.../base/base-data-explorer-widget.directive.ts | 26 ++-
.../config/pie-chart-widget-config.component.html | 72 ++++---
.../config/pie-chart-widget-config.component.ts | 7 +
.../widgets/pie/model/pie-chart-widget.model.ts | 1 +
.../components/widgets/pie/pie-renderer.service.ts | 2 +
.../config/status-widget-config.component.html | 158 +++++++++++++++
.../config/status-widget-config.component.scss | 38 ++++
.../config/status-widget-config.component.ts | 91 +++++++++
.../model/status-widget.model.ts} | 15 +-
.../widgets/status/status-widget.component.html | 60 ++++++
.../widgets/status/status-widget.component.scss | 57 ++++++
.../widgets/status/status-widget.component.ts | 164 ++++++++++++++++
.../traffic-light-widget-config.component.html | 130 +++++++++++++
.../traffic-light-widget-config.component.scss | 27 +++
.../traffic-light-widget-config.component.ts | 183 ++++++++++++++++++
.../model/traffic-light-widget.model.ts} | 15 +-
.../traffic-light-widget.component.html | 79 ++++++++
.../traffic-light-widget.component.scss | 89 +++++++++
.../traffic-light-widget.component.ts | 185 ++++++++++++++++++
ui/src/app/data-explorer/data-explorer.module.ts | 8 +
...a-explorer-edit-dashboard-dialog.component.html | 3 +-
.../models/dataview-dashboard.model.ts | 1 +
.../registry/data-explorer-widget-registry.ts | 16 ++
.../data-explorer-field-provider-service.ts | 4 +-
.../services/time-selection.service.ts | 10 +-
.../custom-output-strategy.component.html | 1 +
.../user-defined-output.component.html | 2 +-
.../user-defined-output.component.ts | 2 +-
.../pipeline-assembly-drawing-area.component.ts | 4 +-
.../pipeline-element-options.component.html | 27 ---
.../pipeline-element-options.component.scss | 9 +-
.../pipeline-element-options.component.ts | 15 --
.../pipeline-element-preview.component.ts | 8 +-
.../pipeline-element-recommendation.component.html | 51 -----
.../pipeline-element-recommendation.component.ts | 187 ------------------
.../dropped-pipeline-element.component.html | 6 +-
.../dialog/customize/customize.component.html | 4 +
.../editor/dialog/customize/customize.component.ts | 18 +-
.../input-schema-panel.component.html | 48 +++++
.../input-schema-panel.component.scss} | 19 +-
.../input-schema-panel.component.ts} | 24 +--
.../input-schema-property.component.html} | 21 +-
.../input-schema-property.component.ts} | 28 +--
.../save-pipeline/save-pipeline.component.ts | 2 +-
ui/src/app/editor/editor.module.ts | 10 +-
.../app/editor/pipes/sort-by-runtime-name.pipe.ts | 24 +--
.../pipeline-element-recommendation.service.ts | 19 --
ui/src/app/files/files.module.ts | 12 +-
ui/src/app/home/models/home.model.ts | 6 +-
...pipeline-details-expansion-panel.component.html | 2 +-
.../pipeline-element-details-row.component.html | 2 +-
.../pipeline-logs-dialog.component.html | 2 +-
ui/src/app/pipelines/pipelines.component.html | 1 +
ui/src/app/services/auth.service.ts | 81 +-------
ui/src/app/services/available-roles.service.ts | 84 +++-----
ui/src/app/services/live-preview.service.ts | 8 +-
ui/src/scss/sp/main.scss | 87 ---------
ui/src/scss/sp/pipeline-element-options.scss | 2 +-
354 files changed, 7307 insertions(+), 3136 deletions(-)
create mode 100644 streampipes-client-go/streampipes/adapter_api.go
create mode 100644
streampipes-client-go/streampipes/model/adapter/adapter_description.go
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/AdapterGenerationSteps.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/PersistPipelineHandler.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/SchemaMetadataEnricher.java
copy
ui/src/app/configuration/extensions-service-management/extensions-service-management.component.ts
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterBasicsGenerator.java
(50%)
copy
streampipes-test-utils/src/main/java/org/apache/streampipes/test/generator/template/PipelineElementTemplateHelpers.java
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterConfigGenerator.java
(53%)
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterEnrichmentRuleGenerator.java
copy ui/src/app/_models/auth.model.ts =>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterModelGenerator.java
(68%)
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterSchemaGenerator.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterTransformationRuleGenerator.java
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/management/CompactAdapterManagement.java
create mode 100644
streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/compact/generator/AdapterSchemaGeneratorTest.java
create mode 100644
streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/compact/generator/AdapterTransformationRuleGeneratorTest.java
create mode 100644
streampipes-data-explorer-influx/src/main/java/org/apache/streampipes/dataexplorer/influx/PropertyDuplicateFilter.java
create mode 100644
streampipes-data-explorer-influx/src/test/java/org/apache/streampipes/dataexplorer/influx/PropertyDuplicateFilterTest.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/preview/PipelinePreviewModel.java
=>
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/JexlContextGenerator.java
(51%)
copy ui/src/app/_models/auth.model.ts =>
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/JexlDescription.java
(71%)
copy ui/src/app/_models/auth.model.ts =>
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/JexlEngineProvider.java
(58%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/preview/PipelinePreviewModel.java
=>
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/JexlEvaluator.java
(52%)
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/MathExpressionFieldExtractor.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/MathExpressionProcessor.java
copy
ui/src/app/core-ui/static-properties/static-slide-toggle/static-slide-toggle.component.html
=>
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/resources/org.apache.streampipes.processors.enricher.jvm.processor.expression/documentation.md
(51%)
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/resources/org.apache.streampipes.processors.enricher.jvm.processor.expression/icon.png
copy ui/deployment/dev/config.yml =>
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/resources/org.apache.streampipes.processors.enricher.jvm.processor.expression/strings.en
(61%)
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/JexlEvaluatorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/expression/MathExpressionProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/DataLakeDimensionProvider.java
create mode 100644
streampipes-extensions/streampipes-sinks-internal-jvm/src/main/java/org/apache/streampipes/sinks/internal/jvm/datalake/migrations/DataLakeSinkMigrationV2.java
create mode 100644
streampipes-extensions/streampipes-sinks-internal-jvm/src/test/java/org/apache/streampipes/sinks/internal/jvm/datalake/migrations/DataLakeSinkMigrationV2Test.java
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/{Privilege.java
=> DefaultPrivilege.java} (92%)
create mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/DefaultRole.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactAdapter.java
copy ui/src/app/files/dialog/file-rename/file-rename-dialog.component.scss =>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactConfiguration.java
(84%)
copy ui/projects/streampipes/shared-ui/src/lib/models/sp-navigation.model.ts
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactEventProperty.java
(80%)
rename ui/src/app/files/dialog/file-upload/file-upload-dialog.component.scss
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactTransport.java
(87%)
copy ui/src/app/files/dialog/file-rename/file-rename-dialog.component.scss =>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CreateOptions.java
(83%)
copy ui/src/app/files/dialog/file-rename/file-rename-dialog.component.scss =>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/EnrichmentConfig.java
(87%)
copy ui/src/app/files/components/file-overview/file-overview.component.scss =>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/TransformationConfig.java
(78%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/ConnectionStorageHandler.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/{DomainPropertyMatch.java
=> SemanticTypeMatch.java} (62%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/{PipelineValidator.java
=> IPipelineValidationStep.java} (65%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/ApplyDefaultRolesAndPrivilegesTask.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineTemplateManagement.java
rename
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/{TestDomainPropertyMatch.java
=> TestSemanticTypeMatch.java} (63%)
create mode 100644
streampipes-rest-core-base/src/main/java/org/apache/streampipes/rest/core/base/impl/CRUDResource.java
create mode 100644
streampipes-rest-core-base/src/main/java/org/apache/streampipes/rest/core/base/impl/DefaultCRUDRestResource.java
create mode 100644
streampipes-rest-core-base/src/main/java/org/apache/streampipes/rest/core/base/impl/converter/YamlConfiguration.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{dashboard/Dashboard.java
=> admin/PrivilegeResource.java} (58%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{dashboard/Dashboard.java
=> admin/RoleResource.java} (54%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/CompactAdapterResource.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v970/AddRolesToUserDbMigration.java
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/ConnectionStorageImpl.java
copy ui/src/app/_models/auth.model.ts =>
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/PrivilegeStorageImpl.java
(68%)
copy ui/src/app/_models/auth.model.ts =>
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/RoleStorageImpl.java
(70%)
create mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/serializer/EventPropertySerializer.java
create mode 100644
streampipes-user-management/src/main/java/org/apache/streampipes/user/management/authorization/PrivilegeManager.java
create mode 100644
streampipes-user-management/src/main/java/org/apache/streampipes/user/management/authorization/RoleManager.java
copy ui/{src/app/services/live-preview.service.ts =>
projects/streampipes/platform-services/src/lib/apis/privilege.service.ts} (51%)
create mode 100644
ui/projects/streampipes/platform-services/src/lib/apis/role.service.ts
copy ui/src/app/{connect/filter/timestamp.pipe.ts =>
configuration/configuration-route.guard.ts} (57%)
create mode 100644 ui/src/app/configuration/configuration-tabs.service.ts
delete mode 100644 ui/src/app/configuration/configuration-tabs.ts
rename ui/src/app/{files =>
configuration}/dialog/file-rename/file-rename-dialog.component.html (100%)
rename
ui/src/app/{editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.scss
=> configuration/dialog/file-rename/file-rename-dialog.component.scss} (100%)
copy ui/src/app/{files =>
configuration}/dialog/file-rename/file-rename-dialog.component.ts (100%)
rename ui/src/app/{files =>
configuration}/dialog/file-upload/file-upload-dialog.component.html (100%)
copy tools/maven/checkstyle-header.txt =>
ui/src/app/configuration/dialog/file-upload/file-upload-dialog.component.scss
(100%)
rename ui/src/app/{files =>
configuration}/dialog/file-upload/file-upload-dialog.component.ts (100%)
copy
ui/src/app/{core-ui/static-properties/static-slide-toggle/static-slide-toggle.component.html
=>
configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-item/service-configs-item.component.html}
(59%)
copy
ui/src/app/configuration/extensions-service-management/{extensions-service-management.component.ts
=>
extensions-service-configuration/service-configs/service-configs-item/service-configs-item.component.ts}
(54%)
rename ui/src/app/{files/components =>
configuration/files}/file-overview/file-overview.component.html (100%)
copy ui/src/app/{files/components =>
configuration/files}/file-overview/file-overview.component.scss (100%)
rename ui/src/app/{files/components =>
configuration/files}/file-overview/file-overview.component.ts (100%)
rename ui/src/app/{ => configuration}/files/files.component.html (54%)
copy ui/src/app/{ => configuration}/files/files.component.scss (100%)
rename ui/src/app/{ => configuration}/files/files.component.ts (75%)
create mode 100644
ui/src/app/configuration/security-configuration/edit-role-dialog/edit-role-dialog.component.html
rename ui/src/app/{files/components/file-overview/file-overview.component.scss
=>
configuration/security-configuration/edit-role-dialog/edit-role-dialog.component.scss}
(72%)
create mode 100644
ui/src/app/configuration/security-configuration/edit-role-dialog/edit-role-dialog.component.ts
copy
ui/src/app/configuration/security-configuration/{security-service-configuration/security-service-config.component.html
=> role-configuration/role-configuration.component.html} (66%)
rename ui/src/app/{files/dialog/file-rename/file-rename-dialog.component.scss
=>
configuration/security-configuration/role-configuration/role-configuration.component.scss}
(94%)
copy
ui/src/app/configuration/security-configuration/{user-group-configuration/user-group-configuration.component.ts
=> role-configuration/role-configuration.component.ts} (58%)
create mode 100644
ui/src/app/core-ui/pipeline-element-runtime-info/pipeline-element-schema.service.ts
copy
ui/src/app/core-ui/{static-properties/static-slide-toggle/static-slide-toggle.component.html
=>
pipeline-element-template-config/pipeline-element-template-config-item/pipeline-element-template-config-item.component.html}
(68%)
create mode 100644
ui/src/app/core-ui/pipeline-element-template-config/pipeline-element-template-config-item/pipeline-element-template-config-item.component.ts
create mode 100644
ui/src/app/data-explorer/components/widgets/status/config/status-widget-config.component.html
create mode 100644
ui/src/app/data-explorer/components/widgets/status/config/status-widget-config.component.scss
create mode 100644
ui/src/app/data-explorer/components/widgets/status/config/status-widget-config.component.ts
copy
ui/src/app/data-explorer/components/widgets/{pie/model/pie-chart-widget.model.ts
=> status/model/status-widget.model.ts} (74%)
create mode 100644
ui/src/app/data-explorer/components/widgets/status/status-widget.component.html
create mode 100644
ui/src/app/data-explorer/components/widgets/status/status-widget.component.scss
create mode 100644
ui/src/app/data-explorer/components/widgets/status/status-widget.component.ts
create mode 100644
ui/src/app/data-explorer/components/widgets/traffic-light/config/traffic-light-widget-config.component.html
create mode 100644
ui/src/app/data-explorer/components/widgets/traffic-light/config/traffic-light-widget-config.component.scss
create mode 100644
ui/src/app/data-explorer/components/widgets/traffic-light/config/traffic-light-widget-config.component.ts
copy
ui/src/app/data-explorer/components/widgets/{pie/model/pie-chart-widget.model.ts
=> traffic-light/model/traffic-light-widget.model.ts} (74%)
create mode 100644
ui/src/app/data-explorer/components/widgets/traffic-light/traffic-light-widget.component.html
create mode 100644
ui/src/app/data-explorer/components/widgets/traffic-light/traffic-light-widget.component.scss
create mode 100644
ui/src/app/data-explorer/components/widgets/traffic-light/traffic-light-widget.component.ts
delete mode 100644
ui/src/app/editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.html
delete mode 100644
ui/src/app/editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.ts
create mode 100644
ui/src/app/editor/dialog/customize/input-schema-panel/input-schema-panel.component.html
rename ui/src/app/{files/files.component.scss =>
editor/dialog/customize/input-schema-panel/input-schema-panel.component.scss}
(77%)
copy ui/src/app/{connect/filter/timestamp.pipe.ts =>
editor/dialog/customize/input-schema-panel/input-schema-panel.component.ts}
(67%)
copy
ui/src/app/{core-ui/static-properties/static-slide-toggle/static-slide-toggle.component.html
=>
editor/dialog/customize/input-schema-panel/input-schema-property/input-schema-property.component.html}
(69%)
rename ui/src/app/{files/dialog/file-rename/file-rename-dialog.component.ts =>
editor/dialog/customize/input-schema-panel/input-schema-property/input-schema-property.component.ts}
(53%)
rename
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IPipelineElementConnectionStorage.java
=> ui/src/app/editor/pipes/sort-by-runtime-name.pipe.ts (64%)
