This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch SP-1132 in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit ec9ee297e0ab107dd24b9829863f0795541f5d47 Merge: 73422d4a4 a7276c291 Author: Philipp Zehnder <[email protected]> AuthorDate: Mon Jan 23 15:48:54 2023 +0100 Merge branch 'dev' into SP-1132 pom.xml | 6 - streampipes-client-python/README.md | 13 +- streampipes-client-python/mkdocs.yml | 2 +- streampipes-client-python/setup.py | 2 +- .../apache/streampipes/client/api/AdminApi.java | 12 + .../streampipes/client/api/DataStreamApi.java | 9 +- streampipes-config/pom.xml | 5 + .../streampipes/config/backend/BackendConfig.java | 3 +- ...Settings.java => DefaultMessagingSettings.java} | 83 +--- .../connect/management/util/GroundingUtils.java | 2 +- ...sFunctionDeclarer.java => IFunctionConfig.java} | 11 +- .../api/declarer/IStreamPipesFunctionDeclarer.java | 4 +- .../connect/adapter/AdapterPipelineGenerator.java | 2 +- .../adapter/util/TransportFormatGenerator.java | 2 +- .../management/init/DeclarersSingleton.java | 2 +- .../streampipes-sinks-databases-jvm/pom.xml | 4 - .../org/apache/streampipes/model/SpDataSet.java | 15 +- .../streampipes/model/api/EndpointSelectable.java | 69 +++ .../model/base/InvocableStreamPipesEntity.java | 18 +- .../model/config}/MessagingSettings.java | 32 +- .../streampipes/model/config}/SpDataFormat.java | 2 +- .../streampipes/model/config}/SpProtocol.java | 2 +- .../model/message/PipelineStatusMessage.java | 9 +- .../model/pipeline/PipelineOperationStatus.java | 10 +- .../manager/execution/PipelineExecutionInfo.java | 106 +++++ .../execution/PipelineExecutionTaskFactory.java | 60 +++ .../manager/execution/PipelineExecutor.java | 57 +++ .../ExtensionsServiceEndpointProvider.java | 62 +++ .../manager/execution/http/DetachHttpRequest.java | 33 +- .../http/DetachPipelineElementSubmitter.java | 53 +++ .../manager/execution/http/GraphSubmitter.java | 132 ------ .../manager/execution/http/HttpRequestBuilder.java | 98 ---- .../manager/execution/http/InvokeHttpRequest.java | 54 +++ .../http/InvokePipelineElementSubmitter.java | 81 ++++ .../execution/http/PipelineElementHttpRequest.java | 73 +++ .../execution/http/PipelineElementSubmitter.java | 82 ++++ .../manager/execution/http/PipelineExecutor.java | 243 ---------- .../provider/CurrentPipelineElementProvider.java} | 21 +- .../provider/PipelineElementProvider.java} | 12 +- .../provider/StoredPipelineElementProvider.java} | 22 +- .../execution/task/AfterInvocationTask.java | 65 +++ .../execution/task/DiscoverEndpointsTask.java | 88 ++++ .../execution/task/PipelineExecutionTask.java | 21 +- .../execution/task/SecretEncryptionTask.java | 25 +- .../execution/task/StorePipelineStatusTask.java | 80 ++++ .../manager/execution/task/SubmitRequestTask.java | 51 +++ .../manager/execution/task/UpdateGroupIdTask.java | 46 ++ .../manager/health/PipelineHealthCheck.java | 13 +- .../manager/matching/DataSetGroundingSelector.java | 2 +- .../manager/matching/FormatSelector.java | 2 +- .../manager/matching/ProtocolSelector.java | 2 +- .../streampipes/manager/operations/Operations.java | 22 +- .../manager/preview/PipelinePreview.java | 10 +- .../http => storage}/PipelineStorageService.java | 2 +- .../RunningPipelineElementStorage.java} | 8 +- .../streampipes/manager/storage/UserService.java | 101 ----- .../AbstractPipelineElementResourceManager.java | 12 + .../rest/core/base/impl/AbstractRestResource.java | 5 - .../streampipes/rest/impl/admin/ConsulConfig.java | 2 +- .../rest/impl/pe/DataStreamResource.java | 17 + .../streampipes/rest/security/AuthConstants.java | 4 + .../function/StreamPipesFunctionHandler.java | 36 +- .../standalone/function/FunctionConfig.java | 30 +- .../standalone/function/FunctionConfigBuilder.java | 25 +- .../standalone/function/FunctionContext.java | 9 + .../function/FunctionContextGenerator.java | 10 +- .../standalone/function/StreamPipesFunction.java | 64 ++- ui/.eslintignore | 4 - ui/.prettierignore | 4 - .../_guards/auth.can-activate-children.guard.ts | 4 +- .../configuration-group.component.html | 4 +- .../adapter-template-dialog.component.html | 4 +- ui/src/app/core-ui/core-ui.module.ts | 256 ++++++----- .../components/download/download.component.html | 34 +- .../components/download/download.component.scss | 1 - .../components/download/download.component.ts | 57 +-- .../select-data-missing-values.component.html | 29 +- .../select-data-missing-values.component.scss | 2 - .../select-data-missing-values.component.ts | 24 +- .../select-data-range.component.html | 128 +++--- .../select-data-range.component.scss | 1 - .../select-data-range.component.ts | 59 +-- .../select-data/select-data.component.html | 14 +- .../select-data/select-data.component.scss | 11 +- .../select-data/select-data.component.ts | 26 +- .../select-format/select-format.component.html | 64 +-- .../select-format/select-format.component.scss | 1 - .../select-format/select-format.component.ts | 23 +- .../data-download-dialog.component.html | 116 ++--- .../data-download-dialog.component.scss | 12 +- .../data-download-dialog.component.ts | 92 ++-- .../model/data-download-dialog.model.ts | 17 +- .../model/data-export-config.model.ts | 9 +- .../model/download-progress.model.ts | 4 +- .../model/export-config.model.ts | 5 +- .../model/format-export-config.model.ts | 8 +- .../services/data-export.service.ts | 203 +++++---- .../services/file-name.service.spec.ts | 170 +++---- .../services/file-name.service.ts | 55 ++- .../core-ui/error-hint/error-hint.component.html | 49 +- .../core-ui/error-hint/error-hint.component.scss | 4 +- .../app/core-ui/error-hint/error-hint.component.ts | 30 +- .../image-annotations.component.css | 6 +- .../image-annotations.component.html | 35 +- .../image-annotations.component.ts | 54 ++- .../image-bar-preview.component.html | 7 +- .../image-bar-preview.component.scss | 9 +- .../image-bar-preview.component.ts | 47 +- .../components/image-bar/image-bar.component.css | 2 - .../components/image-bar/image-bar.component.html | 75 ++-- .../components/image-bar/image-bar.component.ts | 106 ++--- .../image-container/image-container.component.css | 3 +- .../image-container/image-container.component.html | 14 +- .../image-container/image-container.component.ts | 68 +-- .../image-labeling/image-labeling.component.css | 2 +- .../image-labeling/image-labeling.component.html | 169 +++++-- .../image-labeling/image-labeling.component.ts | 492 ++++++++++++--------- .../image/image-viewer/image-viewer.component.css | 2 +- .../image/image-viewer/image-viewer.component.html | 32 +- .../image/image-viewer/image-viewer.component.ts | 41 +- ui/src/app/core-ui/image/image.component.css | 2 +- ui/src/app/core-ui/image/image.component.html | 10 +- ui/src/app/core-ui/image/image.component.ts | 25 +- ui/src/app/core-ui/image/model/coordinates.ts | 4 +- ui/src/app/core-ui/image/model/labeling-mode.ts | 8 +- .../image/services/BrushLabeling.service.ts | 255 ++++++----- .../core-ui/image/services/CocoFormat.service.ts | 208 +++++---- .../core-ui/image/services/LabelingMode.service.ts | 86 ++-- .../image/services/PolygonLabeling.service.ts | 482 +++++++++++--------- .../image/services/ReactLabeling.service.ts | 375 +++++++++------- ui/src/app/core-ui/image/services/color.service.ts | 28 +- ui/src/app/core-ui/image/util/color.util.ts | 28 +- .../core-ui/image/util/imageTranslation.util.ts | 39 +- .../classification/imageClassification.ts | 57 ++- .../configure-labels.component.css | 2 +- .../configure-labels.component.html | 49 +- .../configure-labels/configure-labels.component.ts | 170 +++---- .../label-list-item/label-list-item.component.css | 2 +- .../label-list-item/label-list-item.component.html | 34 +- .../label-list-item/label-list-item.component.ts | 54 ++- .../select-label/select-label.component.css | 6 +- .../select-label/select-label.component.html | 54 ++- .../select-label/select-label.component.ts | 97 ++-- .../app/core-ui/labels/services/label.service.ts | 135 +++--- .../simple-logs/simple-logs.component.html | 33 +- .../simple-logs/simple-logs.component.ts | 15 +- .../simple-metrics/simple-metrics.component.html | 40 +- .../simple-metrics/simple-metrics.component.ts | 27 +- .../object-permission-dialog.component.html | 122 +++-- .../object-permission-dialog.component.scss | 5 +- .../object-permission-dialog.component.ts | 416 +++++++++-------- ...pipeline-element-template-config.component.html | 77 ++-- ...pipeline-element-template-config.component.scss | 12 +- .../pipeline-element-template-config.component.ts | 128 +++--- .../pipeline-element-template-generator.ts | 146 +++--- .../pipeline-element-template.pipe.ts | 29 +- .../pipeline-started-status.component.html | 92 +++- .../pipeline-started-status.component.scss | 8 +- .../pipeline-started-status.component.ts | 43 +- .../split-section/split-section.component.html | 4 +- .../split-section/split-section.component.scss | 18 +- .../split-section/split-section.component.ts | 16 +- .../base/abstract-static-property.ts | 56 +-- .../base/abstract-validated-static-property.ts | 65 +-- .../filter/display-recommended.pipe.ts | 45 +- .../core-ui/static-properties/input.validator.ts | 36 +- .../static-alternatives.component.css | 17 +- .../static-alternatives.component.html | 98 ++-- .../static-alternatives.component.ts | 23 +- .../static-any-input.component.css | 1 - .../static-any-input.component.html | 24 +- .../static-any-input/static-any-input.component.ts | 31 +- .../static-code-input.component.html | 43 +- .../static-code-input.component.scss | 5 +- .../static-code-input.component.ts | 136 +++--- .../add-to-collection.component.css | 2 +- .../add-to-collection.component.html | 36 +- .../add-to-collection.component.spec.ts | 25 +- .../add-to-collection.component.ts | 258 ++++++----- .../static-collection.component.css | 2 +- .../static-collection.component.html | 46 +- .../static-collection.component.ts | 64 ++- .../static-color-picker.component.css | 2 +- .../static-color-picker.component.html | 21 +- .../static-color-picker.component.ts | 44 +- .../static-file-input.component.css | 2 +- .../static-file-input.component.html | 113 +++-- .../static-file-input.component.ts | 101 +++-- .../static-free-input.component.html | 80 ++-- .../static-free-input.component.scss | 7 +- .../static-free-input.component.ts | 175 ++++---- .../static-group/static-group.component.css | 2 +- .../static-group/static-group.component.html | 61 +-- .../static-group/static-group.component.ts | 15 +- .../static-mapping-nary.component.html | 41 +- .../static-mapping-nary.component.scss | 3 +- .../static-mapping-nary.component.ts | 39 +- .../static-mapping-unary.component.css | 9 +- .../static-mapping-unary.component.html | 26 +- .../static-mapping-unary.component.ts | 24 +- .../static-mapping/static-mapping.ts | 46 +- .../static-one-of-input.component.css | 4 +- .../static-one-of-input.component.html | 32 +- .../static-one-of-input.component.ts | 71 +-- .../static-property-util.service.ts | 88 ++-- .../static-property.component.css | 20 +- .../static-property.component.html | 323 ++++++++------ .../static-properties/static-property.component.ts | 215 +++++---- ...tic-runtime-resolvable-any-input.component.html | 49 +- ...tatic-runtime-resolvable-any-input.component.ts | 25 +- .../base-runtime-resolvable-input.ts | 186 ++++---- .../base-runtime-resolvable-selection-input.ts | 35 +- .../runtime-resolvable.service.ts | 63 +-- ...ic-runtime-resolvable-oneof-input.component.css | 6 +- ...c-runtime-resolvable-oneof-input.component.html | 46 +- ...tic-runtime-resolvable-oneof-input.component.ts | 43 +- .../static-tree-input.component.html | 69 ++- .../static-tree-input.component.scss | 16 +- .../static-tree-input.component.ts | 198 +++++---- .../static-secret-input.component.css | 1 - .../static-secret-input.component.html | 22 +- .../static-secret-input.component.ts | 27 +- .../static-slide-toggle.component.html | 13 +- .../static-slide-toggle.component.ts | 46 +- .../app/core-ui/status/status-widget.component.css | 10 +- .../core-ui/status/status-widget.component.html | 18 +- .../app/core-ui/status/status-widget.component.ts | 21 +- .../add-visualization-dialog.component.html | 4 +- .../dialog/customize/customize.component.html | 8 +- .../file-overview/file-overview.component.html | 54 ++- .../file-overview/file-overview.component.scss | 16 +- .../file-overview/file-overview.component.ts | 95 ++-- .../file-upload/file-upload-dialog.component.html | 94 +++- .../file-upload/file-upload-dialog.component.scss | 2 +- .../file-upload/file-upload-dialog.component.ts | 108 +++-- ui/src/app/files/files.component.html | 34 +- ui/src/app/files/files.component.scss | 12 +- ui/src/app/files/files.component.ts | 56 +-- ui/src/app/files/files.module.ts | 82 ++-- ui/src/app/files/files.routes.ts | 10 +- ui/src/app/info/about/about.component.css | 10 +- ui/src/app/info/about/about.component.html | 87 +++- ui/src/app/info/about/about.component.ts | 10 +- ui/src/app/info/info.component.css | 4 +- ui/src/app/info/info.component.html | 17 +- ui/src/app/info/info.component.ts | 25 +- ui/src/app/info/info.module.ts | 9 +- ui/src/app/info/license/license.component.css | 2 +- ui/src/app/info/license/license.component.html | 348 ++++++++------- ui/src/app/info/license/license.component.ts | 10 +- .../info/versions/service/version-info.model.ts | 12 +- ui/src/app/info/versions/versions.component.css | 8 +- ui/src/app/info/versions/versions.component.html | 91 +++- ui/src/app/info/versions/versions.component.ts | 26 +- .../activate-account.component.html | 13 +- .../activate-account/activate-account.component.ts | 61 +-- .../components/auth-box/auth-box.component.ts | 23 +- .../login/components/login/login.component.html | 82 ++-- .../login/components/login/login.component.scss | 20 +- .../app/login/components/login/login.component.ts | 84 ++-- ui/src/app/login/components/login/login.model.ts | 4 +- .../components/register/register.component.html | 62 ++- .../components/register/register.component.ts | 95 ++-- .../components/register/registration.model.ts | 4 +- .../restore-password.component.html | 41 +- .../restore-password/restore-password.component.ts | 72 +-- .../set-new-password.component.html | 61 ++- .../set-new-password/set-new-password.component.ts | 131 +++--- .../login/components/setup/setup.component.html | 165 +++++-- .../login/components/setup/setup.component.scss | 54 +-- .../app/login/components/setup/setup.component.ts | 113 ++--- .../components/startup/startup.component.html | 40 +- .../components/startup/startup.component.scss | 5 +- .../login/components/startup/startup.component.ts | 40 +- ui/src/app/login/login.module.ts | 11 +- .../login/services/account-activation.service.ts | 18 +- ui/src/app/login/services/login.service.ts | 69 +-- .../app/login/services/restore-password.service.ts | 30 +- ui/src/app/login/utils/check-password.ts | 16 +- .../components/edit/quickedit.component.html | 4 +- 280 files changed, 8344 insertions(+), 6068 deletions(-)
