This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch support-service-selection-for-adapters
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 16d63a7309 Fix checkstyle
add 744bfacbef build(#2633): Enable auto fix for lint and prettier in git
pre-commit hook (#2634)
add a88c20bc7c refactor: user registration in backend (#2664)
add 68c8c1ec9f add pr-label (#2685)
add c9f407809f docs: add python tutorial about ML with ONNX (#2687)
add 7a59229848 docs: fix closing tag (#2686)
add 4bc42d7d2e chore(deps-dev): bump pillow in /streampipes-client-python
(#2690)
add 3fc9e44e3f #2545 migrated TestBooleanCounterProcessor parameterized
test to junit5 (#2683)
add 2b1838ba0f chore(deps-dev): bump pandas-stubs from 2.0.0.230412 to
2.0.2.230605 in /streampipes-client-python (#2692)
add 073deac67c chore(deps): bump com.google.protobuf:protobuf-java (#2672)
add 7fa24ca4c3 deps: Bump Angular to v17 using esbuild (#2677)
add 5e6c6d5016 chore(deps): bump katex from 0.16.9 to 0.16.10 in /ui
(#2694)
add 907fdc5d91 chore(deps-dev): bump webpack-dev-middleware from 5.3.3 to
5.3.4 in /ui (#2693)
add b86529e5d7 fix: Fix and refactor create asset e2e test (#2695)
add 2d98cf8be3 chore(deps-dev): bump mkdocs-material in
/streampipes-client-python (#2697)
add e4a004e8ec chore(deps-dev): bump prettier from 3.1.0 to 3.2.5 in /ui
(#2699)
add 223aa0ad94 fix(#2651): incorrect redirect to dashboard instead of app
module (#2689)
add 45528b25c1 refactor(#2615): Change datatypes from class to string
(#2616)
add 1b3d7dcf00 Bump Angular to v17.3.3 (#2707)
add 6c8fdc6102 chore(deps): bump typing-extensions in
/streampipes-client-python (#2713)
add 8fd0820894 chore(deps-dev): bump interrogate in
/streampipes-client-python (#2712)
add 850409f9aa chore(deps-dev): bump @types/node from 20.11.26 to 20.12.5
in /ui (#2711)
add 5b67345f54 chore(deps): bump
org.apache.maven.plugin-tools:maven-plugin-annotations (#2710)
add 34accf49b8 refactor(#2708): Make all methods of FileManager none
static (#2709)
add 72fe35939e refactor(#2128): remove deprecated adapters (#2715)
add f9eb0cc31a Fix CheckCompletedVisitor outOfBounds (#2714)
add 5db35c0c81 chore(deps): bump
org.apache.maven.plugins:maven-plugin-plugin (#2716)
add 593ed422a8 chore(deps): bump date-fns from 2.30.0 to 3.6.0 in /ui
(#2717)
add 3b934dc314 fix(#2719): Add material dependencies to asset view (#2720)
add 067ab0282c chore(deps): bump swagger-ui-dist from 5.13.0 to 5.14.0 in
/ui (#2722)
add 6df855205d chore(deps): bump org.apache.maven.plugins:maven-jar-plugin
(#2721)
add 1994fbd6de refactor: consolidate duplicate code used for secure string
generation (#2718)
add 0ded45ee5d chore(deps-dev): bump typescript from 5.3.3 to 5.4.5 in /ui
(#2724)
add f9ec199e88 chore(deps): bump jakarta.annotation:jakarta.annotation-api
(#2723)
add 558c382313 feat(#2659): Show status light in adapter overview (#2660)
add d7826dfa29 chore(deps): bump swagger-ui-dist from 5.14.0 to 5.15.1 in
/ui (#2725)
add c0439b55e3 chore(deps): bump com.rabbitmq:amqp-client from 5.20.0 to
5.21.0 (#2727)
add e222dcc84b chore(deps): bump pydantic in /streampipes-client-python
(#2726)
add d82de351ee chore(deps): bump idna from 3.6 to 3.7 in
/streampipes-client-python (#2728)
add 40f0001b1b chore(deps): bump konva from 9.2.0 to 9.3.6 in /ui (#2731)
add 1c951ec7c0 chore(deps): bump org.apache.pulsar:pulsar-client from
3.1.1 to 3.2.2 (#2732)
add 49270864c2 chore(deps-dev): bump black in /streampipes-client-python
(#2733)
add 54035b0f18 chore(deps): bump org.apache.maven.plugins:maven-jar-plugin
(#2735)
add 90fec4eda3 chore(deps): bump ngx-markdown from 17.1.1 to 17.2.0 in /ui
(#2734)
add 7fa8e2d519 add userApi (#2701)
add 4ee86147b2 chore(deps): bump org.apache:apache from 31 to 32 (#2741)
add 301a16a2d1 chore(deps): bump es-module-shims from 1.8.3 to 1.9.0 in
/ui (#2742)
add e114a8986a chore(deps): bump org.owasp:dependency-check-maven from
9.0.9 to 9.1.0 (#2740)
add ac318d7a16 refactor: Update .css files to .scss files (#2738)
add f619d82efb refactor: Remove legacy data type service in connect (#2739)
add b4086b82b3 refactor: move config model to a directory (#2743)
add 5d056e8c32 fix(#2748): Add mat icon module to pipeline module (#2749)
add 342aed5aae chore(deps-dev): bump ruff in /streampipes-client-python
(#2750)
add 63fe083556 fix: Add MatTableModule to profile module (#2751)
add 48c6b8f495 refactor: convert model classes to records (#2755)
add ea03560160 fix: OI4 adapter can only read one sensor measurement per
event (#2756)
add 4c19820189 refactor: change `FilterCondition` class to record (#2759)
add aea5a66b05 refactor: align item generator class names with parent
class (#2760)
add c9494b51a9 refactor: minor code & logging improvements (#2761)
add fd01a47219 chore(deps): bump commons-io:commons-io from 2.15.1 to
2.16.1 (#2769)
add 1df7217a43 refactor: replace gson by jackson (#2763)
add 863865afe6 fix: add proper logger usage (#2780)
add 7aeac27ad3 refactor: remove unused method (#2765)
add ad6b64ab53 refactor: convert param classes into records (#2762)
add a3038a57fa ci: use macos13 to have all python versions available
(#2792)
add ba97f15fc7 chore(deps-dev): bump mypy in /streampipes-client-python
(#2784)
add c799edb6ac chore(deps): bump com.puppycrawl.tools:checkstyle (#2785)
add c6be90d986 chore(deps): bump org.apache.commons:commons-text from
1.11.0 to 1.12.0 (#2786)
add f6dfc8735b refactor: move influx specific implementations to
`DataExplorerInfluxQueryExecutor` (#2781)
add 6a1da8dca4 refactor: replace `StorageManager` by `StorageDispatcher`
(#2766)
add 60a349466d refactor: remove direct usage of couchDB client (#2757)
add a6e7e1bc07 ci: enable macos-latest for Python unit tests again (#2797)
add 402a93dcae chore(deps): bump commons-codec:commons-codec from 1.16.0
to 1.17.0 (#2798)
add bed9a244c5 chore(deps-dev): bump pytest in /streampipes-client-python
(#2801)
add 67f375603c chore(deps): bump org.simplejavamail:simple-java-mail
(#2799)
add 1cb85220e0 chore(deps-dev): bump mkdocstrings in
/streampipes-client-python (#2800)
add ed9c5447de Merge branch 'dev' into
support-service-selection-for-adapters
No new revisions were added by this update.
Summary of changes:
.github/pr-labeler-config.yml | 7 +
.github/workflows/build.yml | 2 +-
.github/workflows/cypress-test.yml | 4 +-
.github/workflows/pr-validation.yml | 4 +-
pom.xml | 29 +-
.../internal/serializer/deserializer.go | 31 +
.../streampipes/model/streampipes_user/user.go | 50 +
.../streampipes/streampipes_client.go | 5 +
streampipes-client-go/streampipes/user_api.go | 120 +
.../docs/img/tutorial-prediction-data-stream.png | Bin 0 -> 221844 bytes
streampipes-client-python/docs/index.md | 9 -
...ine-learning-on-a-streampipes-data-stream.ipynb | 25 +-
...roperable-machine-learning-in-streampipes.ipynb | 509 +
streampipes-client-python/mkdocs.yml | 3 +-
streampipes-client-python/poetry.lock | 763 +-
streampipes-client-python/pyproject.toml | 16 +-
.../streampipes/commons/file/FileHasher.java | 7 +-
.../FileHasherTest.java} | 31 +-
.../dataexplorer/DataExplorerQueryManagement.java | 59 +-
.../dataexplorer/DataExplorerSchemaManagement.java | 50 +-
.../influx/DataExplorerInfluxQueryExecutor.java | 56 +-
.../influx/DataLakeInfluxQueryBuilder.java | 11 +-
.../dataexplorer/param/DeleteQueryParams.java | 40 +-
.../param/ProvidedRestQueryParamConverter.java | 10 +-
.../dataexplorer/param/SelectQueryParams.java | 2 +-
.../param/model/LimitClauseParams.java | 12 +-
.../param/model/OffsetClauseParams.java | 12 +-
.../param/model/SelectClauseParams.java | 4 -
.../dataexplorer/query/AutoAggregationHandler.java | 14 +-
.../query/DataExplorerQueryExecutor.java | 7 +-
.../query/writer/ConfiguredCsvOutputWriter.java | 8 +-
.../query/writer/ConfiguredJsonOutputWriter.java | 11 +-
.../{CsvItemWriter.java => CsvItemGenerator.java} | 4 +-
...{JsonItemWriter.java => JsonItemGenerator.java} | 27 +-
.../dataexplorer/querybuilder/FilterCondition.java | 25 +-
.../querybuilder/IDataLakeQueryBuilder.java | 4 -
.../param/WhereStatementParamsTest.java | 6 +-
...svItemWriter.java => TestCsvItemGenerator.java} | 6 +-
...{TestItemWriter.java => TestItemGenerator.java} | 2 +-
...nItemWriter.java => TestJsonItemGenerator.java} | 6 +-
.../export/generator/ExportPackageGenerator.java | 2 +-
streampipes-extensions/pom.xml | 2 +-
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 46 +-
.../iiot/adapters/oi4/model/DataSetMessage.java | 3 +-
.../connect/iiot/utils/FileProtocolUtils.java | 2 +-
.../documentation.md | 2 +-
.../GeneralAdaptersExtensionModuleExport.java | 17 +-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 156 -
.../connect/adapters/coindesk/Currency.java | 27 -
.../connect/adapters/coindesk/model/Bpi.java | 62 -
.../adapters/coindesk/model/CoindeskRawModel.java | 71 -
.../connect/adapters/coindesk/model/EUR.java | 82 -
.../connect/adapters/coindesk/model/GBP.java | 81 -
.../connect/adapters/coindesk/model/Time.java | 61 -
.../connect/adapters/coindesk/model/USD.java | 81 -
.../connect/adapters/flic/FlicMQTTAdapter.java | 106 -
.../connect/adapters/flic/FlicOutput.java | 62 -
.../connect/adapters/flic/FlicUtils.java | 74 -
.../connect/adapters/slack/SlackAdapter.java | 93 -
.../connect/adapters/slack/SlackConsumer.java | 80 -
.../connect/adapters/ti/TISensorTag.java | 180 -
.../adapters/wikipedia/WikipediaAdapter.java | 147 -
.../wikipedia/WikipediaEditedArticlesAdapter.java | 45 -
.../wikipedia/WikipediaModelConverter.java | 72 -
.../wikipedia/WikipediaNewArticlesAdapter.java | 45 -
.../adapters/wikipedia/WikipediaSseConsumer.java | 61 -
.../documentation.md | 38 -
.../icon.png | Bin 17868 -> 0 bytes
.../strings.en | 23 -
.../documentation.md | 53 -
.../icon.png | Bin 24457 -> 0 bytes
.../strings.en | 44 -
.../documentation.md | 33 -
.../icon.png | Bin 13079 -> 0 bytes
.../strings.en | 24 -
.../documentation.md | 33 -
.../icon.png | Bin 17473 -> 0 bytes
.../strings.en | 24 -
.../documentation.md | 51 -
.../icon.png | Bin 12579 -> 0 bytes
.../strings.en | 45 -
.../documentation.md | 33 -
.../icon.png | Bin 65221 -> 0 bytes
.../strings.en | 20 -
.../documentation.md | 33 -
.../icon.png | Bin 65221 -> 0 bytes
.../strings.en | 21 -
.../pom.xml | 4 +
.../counter/TestBooleanCounterProcessor.java | 266 +-
streampipes-integration-tests/pom.xml | 2 +-
streampipes-maven-plugin/pom.xml | 4 +-
streampipes-messaging-pulsar/pom.xml | 2 +-
.../model/client/user/ChangePasswordRequest.java | 25 +-
.../client/user/JwtAuthenticationResponse.java | 21 +-
.../model/client/user/LoginRequest.java | 33 +-
.../model/client/user/PermissionEntry.java | 29 +-
.../model/client/user/RawUserApiToken.java | 43 +-
.../model/client/user/RegistrationData.java | 68 -
.../streampipes/model/client/user/Token.java | 49 -
...rincipalType.java => UserRegistrationData.java} | 7 +-
.../streampipes/model/file/FileMetadata.java | 1 +
.../streampipes/model/schema/PropertyScope.java | 2 +-
.../streampipes/manager/file/FileManager.java | 108 +-
.../v2/pipeline/CheckCompletedVisitor.java | 6 +-
.../manager/recommender/ElementRecommender.java | 3 +-
.../manager/template/PipelineGenerator.java | 9 +-
.../template/PipelineTemplateGenerator.java | 7 +-
.../manager/verification/ElementVerifier.java | 46 +-
.../streampipes/manager/file/TestFileManager.java | 315 +-
.../resource/management/UserResourceManager.java | 57 +-
.../apache/streampipes/rest/ResetManagement.java | 5 +-
.../rest/impl/AssetDashboardResource.java | 57 +-
.../streampipes/rest/impl/Authentication.java | 20 +-
.../rest/impl/PipelineElementCategory.java | 6 +-
.../streampipes/rest/impl/PipelineElementFile.java | 18 +-
.../rest/impl/RestorePasswordResource.java | 7 +-
.../apache/streampipes/rest/impl/UserResource.java | 4 +-
.../apache/streampipes/sdk/helpers/Filetypes.java | 9 +-
.../streampipes/sdk/helpers/FiletypesTest.java | 21 +-
.../security/TokenAuthenticationFilter.java | 3 +-
.../streampipes/storage/api/IUserStorage.java | 2 +-
.../storage/couchdb/impl/UserStorage.java | 4 +-
.../storage/management/StorageManager.java | 33 -
.../user/management/service/TokenService.java | 3 +-
.../user/management/util/PasswordUtil.java | 14 +-
.../management/util/SecureStringGenerator.java} | 26 +-
.../user/management/util/TokenUtil.java | 27 +-
...ordUtil.java => TestSecureStringGenerator.java} | 12 +-
.../user/management/util/TestTokenUtil.java | 57 -
ui/.gitignore | 3 +-
ui/.lintstagedrc.json | 4 +-
ui/Dockerfile | 2 +-
ui/angular.json | 71 +-
ui/cypress/plugins/index.ts | 31 -
.../cypress/support/utils/asset/AssetUtils.ts | 8 +-
.../utils/configuration/ConfigutationUtils.ts | 9 +-
.../tests/assetManagement/createAsset.spec.ts | 34 +-
.../testVariousUserRoles.smoke.spec.ts | 2 +-
ui/deployment/appng5.module.mst | 5 -
ui/deployment/dev/config.yml | 1 -
ui/deployment/home.service.mst | 2 +-
ui/deployment/prebuild.js | 4 +-
ui/deployment/proxy.conf.json | 6 +
ui/deployment/webpack.partial.dev.js | 60 -
ui/package-lock.json | 39930 ++++---------------
ui/package.json | 109 +-
.../streampipes/platform-services/package.json | 8 +-
.../src/lib/apis/commons.service.ts | 4 -
.../src/lib/apis/general-config.service.ts | 2 +-
.../src/lib/apis/mail-config.service.ts | 2 +-
.../lib/model/{ => config}/email-config.model.ts | 0
.../lib/model/{ => config}/general-config.model.ts | 0
.../src/lib/model/gen/streampipes-model-client.ts | 42 +-
.../src/lib/model/gen/streampipes-model.ts | 2 +-
.../src/lib/model/types/data-type.ts | 43 +
.../src/lib/model/types/semantic-type.ts | 55 +
.../platform-services/src/public-api.ts | 7 +-
ui/projects/streampipes/shared-ui/package.json | 16 +-
.../streampipes/shared-ui/tsconfig.lib.prod.json | 3 +
ui/src/app/add/add.module.ts | 4 +-
ui/src/app/add/services/add.service.ts | 2 +-
ui/src/app/apidocs/apidocs.component.ts | 6 +-
.../app-asset-monitoring.component.html | 2 +-
...ent.css => app-asset-monitoring.component.scss} | 0
.../app-asset-monitoring.component.ts | 2 +-
.../app-asset-monitoring.module.ts | 9 +-
...t.component.css => create-asset.component.scss} | 0
.../create-asset/create-asset.component.ts | 2 +-
...onent.css => dashboard-overview.component.scss} | 0
.../dashboard-overview.component.ts | 2 +-
...set.component.css => view-asset.component.scss} | 0
.../components/view-asset/view-asset.component.ts | 2 +-
.../app-asset-monitoring/services/rest.service.ts | 2 +-
.../app-asset-monitoring/services/shape.service.ts | 2 +-
...w.component.css => app-overview.component.scss} | 0
ui/src/app/app-overview/app-overview.component.ts | 2 +-
ui/src/app/app-overview/app-overview.module.ts | 4 +-
ui/src/app/assets/assets.module.ts | 6 +
.../asset-details-panel.component.ts | 6 +-
.../asset-overview/asset-overview.component.html | 2 +-
.../asset-upload-dialog.component.scss | 2 +-
.../create-asset-dialog.component.scss | 2 +-
.../edit-asset-link-dialog.component.scss | 2 +-
.../manage-asset-links-dialog.component.scss | 2 +-
ui/src/app/configuration/configuration.module.ts | 2 +-
...t.css => datalake-configuration.component.scss} | 0
.../datalake-configuration.component.ts | 2 +-
...css => service-configs-password.component.scss} | 0
.../service-configs-password.component.ts | 2 +-
.../service-configs/service-configs.component.ts | 3 +-
....css => messaging-configuration.component.scss} | 0
.../messaging-configuration.component.ts | 2 +-
.../configuration/shared/configuration.service.ts | 2 +-
.../event-property-row.component.ts | 10 +-
.../event-schema/event-schema.component.ts | 12 +-
.../adapter-status-light.component.html} | 6 +-
.../adapter-status-light.component.ts} | 9 +-
.../existing-adapters.component.html | 15 +
.../existing-adapters.component.scss | 5 +-
.../existing-adapters.component.ts | 6 +-
.../new-adapter/new-adapter.component.ts | 2 -
ui/src/app/connect/connect.module.ts | 17 +-
.../adapter-started-dialog.component.scss | 2 +-
.../edit-data-type/edit-data-type.component.ts | 38 +-
.../edit-schema-transformation.component.ts | 14 +-
.../edit-event-property.component.ts | 18 +-
ui/src/app/connect/filter/adapter-filter.pipe.ts | 3 +-
ui/src/app/connect/filter/timestamp.pipe.ts | 12 +-
.../connect/services/adapter-template.service.ts | 2 +-
ui/src/app/connect/services/connect.service.ts | 52 -
ui/src/app/connect/services/data-type.service.ts | 65 -
ui/src/app/connect/services/rest.service.ts | 9 +-
.../services/transformation-rule.service.ts | 5 +-
.../app/connect/services/unit-provider.service.ts | 2 +-
.../core-services/types/semantic-type.service.ts | 72 -
ui/src/app/core-ui/core-ui.module.ts | 7 +-
.../data-download-dialog.component.scss | 2 +-
.../field-names-table.component.ts | 9 +-
.../live-preview-table.component.ts | 9 +-
...pipeline-element-template-config.component.scss | 2 +-
...nent.css => static-alternatives.component.scss} | 0
.../static-alternatives.component.ts | 2 +-
...mponent.css => static-any-input.component.scss} | 0
.../static-any-input/static-any-input.component.ts | 2 +-
.../static-code-input.component.ts | 5 +-
...ponent.css => add-to-collection.component.scss} | 0
.../add-to-collection.component.ts | 2 +-
...ponent.css => static-collection.component.scss} | 0
.../static-collection.component.ts | 2 +-
...nent.css => static-color-picker.component.scss} | 0
.../static-color-picker.component.ts | 2 +-
...ponent.css => static-file-input.component.scss} | 0
.../static-file-input.component.ts | 2 +-
.../static-free-input.component.ts | 25 +-
...p.component.css => static-group.component.scss} | 0
.../static-group/static-group.component.ts | 2 +-
.../static-mapping-nary.component.scss | 2 +-
...ent.css => static-mapping-unary.component.scss} | 0
.../static-mapping-unary.component.ts | 2 +-
...nent.css => static-one-of-input.component.scss} | 0
.../static-one-of-input.component.ts | 2 +-
.../static-property-util.service.ts | 2 +-
...omponent.css => static-property.component.scss} | 0
.../static-properties/static-property.component.ts | 2 +-
...ic-runtime-resolvable-any-input.component.scss} | 0
...tatic-runtime-resolvable-any-input.component.ts | 2 +-
.../runtime-resolvable.service.ts | 2 +-
...-runtime-resolvable-oneof-input.component.scss} | 0
...tic-runtime-resolvable-oneof-input.component.ts | 2 +-
...nent.css => static-secret-input.component.scss} | 0
.../static-secret-input.component.ts | 2 +-
....component.css => status-widget.component.scss} | 0
.../app/core-ui/status/status-widget.component.ts | 2 +-
...component.css => dashboard-grid.component.scss} | 0
.../components/grid/dashboard-grid.component.ts | 2 +-
...onent.css => dashboard-overview.component.scss} | 0
.../overview/dashboard-overview.component.ts | 2 +-
...omponent.css => dashboard-panel.component.scss} | 0
.../components/panel/dashboard-panel.component.ts | 2 +-
...ent.css => standalone-dashboard.component.scss} | 0
.../standalone/standalone-dashboard.component.ts | 2 +-
...mponent.css => dashboard-widget.component.scss} | 0
.../widget/dashboard-widget.component.ts | 2 +-
...et.component.css => area-widget.component.scss} | 0
.../widgets/area/area-widget.component.ts | 2 +-
...t.component.css => gauge-widget.component.scss} | 0
.../widgets/gauge/gauge-widget.component.ts | 2 +-
...et.component.css => html-widget.component.scss} | 0
.../widgets/html/html-widget.component.ts | 2 +-
...t.component.css => image-widget.component.scss} | 0
.../widgets/image/image-widget.component.ts | 2 +-
...et.component.css => line-widget.component.scss} | 0
.../widgets/line/line-widget.component.ts | 2 +-
...get.component.css => map-widget.component.scss} | 0
.../components/widgets/map/map-widget.component.ts | 2 +-
....component.css => number-widget.component.scss} | 0
.../widgets/number/number-widget.component.ts | 2 +-
...get.component.css => raw-widget.component.scss} | 0
.../components/widgets/raw/raw-widget.component.ts | 2 +-
...t.component.css => table-widget.component.scss} | 0
.../widgets/table/table-widget.component.ts | 13 +-
...ent.css => traffic-light-widget.component.scss} | 0
.../trafficlight/traffic-light-widget.component.ts | 2 +-
ui/src/app/dashboard/dashboard.module.ts | 11 +-
.../dashboard/registry/widget-config-builder.ts | 10 +-
ui/src/app/dashboard/sdk/ep-requirements.ts | 22 +-
.../app/dashboard/sdk/matching/datatype-match.ts | 12 +-
ui/src/app/dashboard/sdk/model/datatypes.ts | 38 -
ui/src/app/dashboard/sdk/model/vocabulary.ts | 23 -
ui/src/app/dashboard/services/edit-mode.service.ts | 2 +-
.../services/refresh-dashboard.service.ts | 2 +-
.../dashboard/services/reload-pipeline.service.ts | 2 +-
ui/src/app/dashboard/services/resize.service.ts | 2 +-
...> data-explorer-dashboard-panel.component.scss} | 0
.../data-explorer-dashboard-panel.component.ts | 2 +-
...-bar.component.css => image-bar.component.scss} | 0
.../widgets/image/image-bar/image-bar.component.ts | 2 +-
...r.component.css => image-viewer.component.scss} | 0
.../image/image-viewer/image-viewer.component.ts | 2 +-
...t.component.css => image-widget.component.scss} | 0
.../widgets/image/image-widget.component.ts | 2 +-
....css => aggregate-configuration.component.scss} | 0
.../aggregate-configuration.component.ts | 2 +-
...nent.css => group-configuration.component.scss} | 0
.../group-configuration.component.ts | 2 +-
.../invalid-configuration.component.ts | 2 +-
...ponent.css => load-data-spinner.component.scss} | 0
.../load-data-spinner.component.ts | 2 +-
...nt.css => no-data-in-date-range.component.scss} | 0
.../no-data/no-data-in-date-range.component.ts | 2 +-
...ponent.css => select-properties.component.scss} | 0
.../select-properties.component.ts | 2 +-
.../data-explorer-field-provider-service.ts | 17 +-
.../user-defined-output.component.ts | 24 +-
...css => pipeline-element-options.component.scss} | 0
.../pipeline-element-options.component.ts | 2 +-
...mponent.css => pipeline-element.component.scss} | 0
.../pipeline-element/pipeline-element.component.ts | 2 +-
...eline.component.css => pipeline.component.scss} | 0
.../components/pipeline/pipeline.component.ts | 2 +-
.../app/editor/services/object-provider.service.ts | 2 +-
.../editor/services/pipeline-validation.service.ts | 2 +-
.../file-rename/file-rename-dialog.component.scss | 2 +-
.../file-upload/file-upload-dialog.component.scss | 2 +-
...{status.component.css => status.component.scss} | 0
ui/src/app/home/components/status.component.ts | 2 +-
ui/src/app/home/home.component.ts | 2 +-
.../{about.component.css => about.component.scss} | 0
ui/src/app/info/about/about.component.ts | 2 +-
.../{info.component.css => info.component.scss} | 0
ui/src/app/info/info.component.ts | 2 +-
...icense.component.css => license.component.scss} | 0
ui/src/app/info/license/license.component.ts | 2 +-
...sions.component.css => versions.component.scss} | 0
ui/src/app/info/versions/versions.component.ts | 2 +-
ui/src/app/login/login.module.ts | 5 +-
.../login/services/account-activation.service.ts | 2 +-
ui/src/app/login/services/login.service.ts | 2 +-
.../app/login/services/restore-password.service.ts | 2 +-
ui/src/app/notifications/notifications.module.ts | 3 +-
.../notifications/service/notifications.service.ts | 2 +-
.../abstract-function-details.directive.ts | 2 +-
.../pipeline-overview.component.scss | 27 -
.../pipeline-overview.component.ts | 5 +-
ui/src/app/pipelines/pipelines.module.ts | 11 +-
.../services/pipeline-operations.service.ts | 2 +-
ui/src/app/profile/profile.module.ts | 5 +-
ui/src/app/profile/profile.service.ts | 2 +-
ui/src/app/services/auth.service.ts | 2 +-
ui/src/app/services/available-roles.service.ts | 2 +-
.../app/services/get-element-icon-text.service.ts | 2 +-
ui/src/app/services/notification-count-service.ts | 2 +-
ui/src/app/services/property-selector.service.ts | 2 +-
ui/src/app/services/rest-api.service.ts | 2 +-
ui/src/app/services/services.module.ts | 15 +-
ui/src/assets/federation.manifest.json | 1 +
ui/src/{main.ts => bootstrap.ts} | 60 +-
ui/src/federation.config.js | 57 +
ui/src/index.html | 2 +-
ui/src/main.ts | 14 +-
ui/src/proxy.conf.json | 31 -
ui/src/scss/main.scss | 33 +-
ui/src/scss/sp/buttons.scss | 9 -
ui/src/scss/sp/mat-tab.scss | 3 -
ui/src/scss/sp/sp-theme.scss | 72 +-
.../sp/status-light.scss} | 30 +-
ui/src/tsconfig.app.json | 1 -
ui/tsconfig.json | 12 +-
ui/webpack.partial.base.js | 177 -
ui/webpack.partial.js | 21 -
ui/webpack.partial.prod.js | 24 -
371 files changed, 11479 insertions(+), 35988 deletions(-)
create mode 100644
streampipes-client-go/streampipes/model/streampipes_user/user.go
create mode 100644 streampipes-client-go/streampipes/user_api.go
create mode 100644
streampipes-client-python/docs/img/tutorial-prediction-data-stream.png
create mode 100644
streampipes-client-python/docs/tutorials/5-applying-interoperable-machine-learning-in-streampipes.ipynb
copy
streampipes-commons/src/test/java/org/apache/streampipes/commons/{parser/IntegerParserTest.java
=> file/FileHasherTest.java} (57%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/writer/item/{CsvItemWriter.java
=> CsvItemGenerator.java} (91%)
rename
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/writer/item/{JsonItemWriter.java
=> JsonItemGenerator.java} (61%)
rename
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/query/writer/item/{TestCsvItemWriter.java
=> TestCsvItemGenerator.java} (90%)
rename
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/query/writer/item/{TestItemWriter.java
=> TestItemGenerator.java} (96%)
copy
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/query/writer/item/{TestJsonItemWriter.java
=> TestJsonItemGenerator.java} (87%)
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/CoindeskBitcoinAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/CoindeskRawModel.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/EUR.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/GBP.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Time.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/USD.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicMQTTAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicOutput.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicUtils.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackConsumer.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/ti/TISensorTag.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaEditedArticlesAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaModelConverter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaNewArticlesAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaSseConsumer.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.coindesk/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.coindesk/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.coindesk/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.flic.mqtt/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.flic.mqtt/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.flic.mqtt/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdatastream/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdatastream/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdatastream/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.slack/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.slack/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.slack/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ti/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ti/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ti/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.edit/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.edit/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.edit/strings.en
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.new/documentation.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.new/icon.png
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.wikipedia.new/strings.en
delete mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/RegistrationData.java
delete mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/Token.java
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/{PrincipalType.java
=> UserRegistrationData.java} (88%)
rename
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/query/writer/item/TestJsonItemWriter.java
=>
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/helpers/FiletypesTest.java
(67%)
delete mode 100644
streampipes-storage-management/src/main/java/org/apache/streampipes/storage/management/StorageManager.java
copy
streampipes-user-management/src/{test/java/org/apache/streampipes/user/management/util/TestPasswordUtil.java
=>
main/java/org/apache/streampipes/user/management/util/SecureStringGenerator.java}
(61%)
rename
streampipes-user-management/src/test/java/org/apache/streampipes/user/management/util/{TestPasswordUtil.java
=> TestSecureStringGenerator.java} (79%)
delete mode 100644
streampipes-user-management/src/test/java/org/apache/streampipes/user/management/util/TestTokenUtil.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoValidSepaStructureException.java
=> ui/cypress/support/utils/asset/AssetUtils.ts (88%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/ISubscription.java
=> ui/cypress/support/utils/configuration/ConfigutationUtils.ts (86%)
create mode 100644 ui/deployment/proxy.conf.json
delete mode 100644 ui/deployment/webpack.partial.dev.js
rename ui/projects/streampipes/platform-services/src/lib/model/{ =>
config}/email-config.model.ts (100%)
rename ui/projects/streampipes/platform-services/src/lib/model/{ =>
config}/general-config.model.ts (100%)
create mode 100644
ui/projects/streampipes/platform-services/src/lib/model/types/data-type.ts
create mode 100644
ui/projects/streampipes/platform-services/src/lib/model/types/semantic-type.ts
rename ui/src/app/app-asset-monitoring/{app-asset-monitoring.component.css =>
app-asset-monitoring.component.scss} (100%)
rename
ui/src/app/app-asset-monitoring/components/create-asset/{create-asset.component.css
=> create-asset.component.scss} (100%)
rename
ui/src/app/app-asset-monitoring/components/dashboard-overview/{dashboard-overview.component.css
=> dashboard-overview.component.scss} (100%)
rename
ui/src/app/app-asset-monitoring/components/view-asset/{view-asset.component.css
=> view-asset.component.scss} (100%)
rename ui/src/app/app-overview/{app-overview.component.css =>
app-overview.component.scss} (100%)
rename
ui/src/app/configuration/datalake-configuration/{datalake-configuration.component.css
=> datalake-configuration.component.scss} (100%)
rename
ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-password/{service-configs-password.component.css
=> service-configs-password.component.scss} (100%)
rename
ui/src/app/configuration/messaging-configuration/{messaging-configuration.component.css
=> messaging-configuration.component.scss} (100%)
copy
ui/{projects/streampipes/shared-ui/src/lib/components/basic-header-title/header-title.component.html
=>
src/app/connect/components/existing-adapters/adapter-status-light/adapter-status-light.component.html}
(82%)
copy
ui/src/app/{data-explorer/components/widgets/utils/visualization-config-outer/visualization-config-outer.component.ts
=>
connect/components/existing-adapters/adapter-status-light/adapter-status-light.component.ts}
(79%)
delete mode 100644 ui/src/app/connect/services/connect.service.ts
delete mode 100644 ui/src/app/connect/services/data-type.service.ts
delete mode 100644 ui/src/app/core-services/types/semantic-type.service.ts
rename
ui/src/app/core-ui/static-properties/static-alternatives/{static-alternatives.component.css
=> static-alternatives.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-any-input/{static-any-input.component.css
=> static-any-input.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-collection/add-to-collection/{add-to-collection.component.css
=> add-to-collection.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-collection/{static-collection.component.css
=> static-collection.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-color-picker/{static-color-picker.component.css
=> static-color-picker.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-file-input/{static-file-input.component.css
=> static-file-input.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-group/{static-group.component.css
=> static-group.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-mapping-unary/{static-mapping-unary.component.css
=> static-mapping-unary.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-one-of-input/{static-one-of-input.component.css
=> static-one-of-input.component.scss} (100%)
rename ui/src/app/core-ui/static-properties/{static-property.component.css =>
static-property.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-runtime-resolvable-any-input/{static-runtime-resolvable-any-input.component.css
=> static-runtime-resolvable-any-input.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-runtime-resolvable-oneof-input/{static-runtime-resolvable-oneof-input.component.css
=> static-runtime-resolvable-oneof-input.component.scss} (100%)
rename
ui/src/app/core-ui/static-properties/static-secret-input/{static-secret-input.component.css
=> static-secret-input.component.scss} (100%)
rename ui/src/app/core-ui/status/{status-widget.component.css =>
status-widget.component.scss} (100%)
rename ui/src/app/dashboard/components/grid/{dashboard-grid.component.css =>
dashboard-grid.component.scss} (100%)
rename
ui/src/app/dashboard/components/overview/{dashboard-overview.component.css =>
dashboard-overview.component.scss} (100%)
rename ui/src/app/dashboard/components/panel/{dashboard-panel.component.css =>
dashboard-panel.component.scss} (100%)
rename
ui/src/app/dashboard/components/standalone/{standalone-dashboard.component.css
=> standalone-dashboard.component.scss} (100%)
rename ui/src/app/dashboard/components/widget/{dashboard-widget.component.css
=> dashboard-widget.component.scss} (100%)
rename ui/src/app/dashboard/components/widgets/area/{area-widget.component.css
=> area-widget.component.scss} (100%)
rename
ui/src/app/dashboard/components/widgets/gauge/{gauge-widget.component.css =>
gauge-widget.component.scss} (100%)
rename ui/src/app/dashboard/components/widgets/html/{html-widget.component.css
=> html-widget.component.scss} (100%)
rename
ui/src/app/dashboard/components/widgets/image/{image-widget.component.css =>
image-widget.component.scss} (100%)
rename ui/src/app/dashboard/components/widgets/line/{line-widget.component.css
=> line-widget.component.scss} (100%)
rename ui/src/app/dashboard/components/widgets/map/{map-widget.component.css
=> map-widget.component.scss} (100%)
rename
ui/src/app/dashboard/components/widgets/number/{number-widget.component.css =>
number-widget.component.scss} (100%)
rename ui/src/app/dashboard/components/widgets/raw/{raw-widget.component.css
=> raw-widget.component.scss} (100%)
rename
ui/src/app/dashboard/components/widgets/table/{table-widget.component.css =>
table-widget.component.scss} (100%)
rename
ui/src/app/dashboard/components/widgets/trafficlight/{traffic-light-widget.component.css
=> traffic-light-widget.component.scss} (100%)
delete mode 100644 ui/src/app/dashboard/sdk/model/datatypes.ts
delete mode 100644 ui/src/app/dashboard/sdk/model/vocabulary.ts
rename
ui/src/app/data-explorer/components/panel/{data-explorer-dashboard-panel.component.css
=> data-explorer-dashboard-panel.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/image/image-bar/{image-bar.component.css
=> image-bar.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/image/image-viewer/{image-viewer.component.css
=> image-viewer.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/image/{image-widget.component.css
=> image-widget.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/utils/aggregate-configuration/{aggregate-configuration.component.css
=> aggregate-configuration.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/utils/group-configuration/{group-configuration.component.css
=> group-configuration.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/utils/load-data-spinner/{load-data-spinner.component.css
=> load-data-spinner.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/utils/no-data/{no-data-in-date-range.component.css
=> no-data-in-date-range.component.scss} (100%)
rename
ui/src/app/data-explorer/components/widgets/utils/select-properties/{select-properties.component.css
=> select-properties.component.scss} (100%)
rename
ui/src/app/editor/components/pipeline-element-options/{pipeline-element-options.component.css
=> pipeline-element-options.component.scss} (100%)
rename
ui/src/app/editor/components/pipeline-element/{pipeline-element.component.css
=> pipeline-element.component.scss} (100%)
rename ui/src/app/editor/components/pipeline/{pipeline.component.css =>
pipeline.component.scss} (100%)
rename ui/src/app/home/components/{status.component.css =>
status.component.scss} (100%)
rename ui/src/app/info/about/{about.component.css => about.component.scss}
(100%)
rename ui/src/app/info/{info.component.css => info.component.scss} (100%)
rename ui/src/app/info/license/{license.component.css =>
license.component.scss} (100%)
rename ui/src/app/info/versions/{versions.component.css =>
versions.component.scss} (100%)
create mode 100644 ui/src/assets/federation.manifest.json
copy ui/src/{main.ts => bootstrap.ts} (97%)
create mode 100644 ui/src/federation.config.js
delete mode 100644 ui/src/proxy.conf.json
copy
ui/src/{app/pipelines/components/pipeline-overview/pipeline-overview.component.scss
=> scss/sp/status-light.scss} (75%)
delete mode 100644 ui/webpack.partial.base.js
delete mode 100644 ui/webpack.partial.js
delete mode 100644 ui/webpack.partial.prod.js
