This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch
3099-plc-adapters-do-not-recover-from-connection-failures
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 3b25e53753 fix(#3099): Remove broken connection from connection pool
add 076a89e32b refactor(#3095): Remove deprecated processing element API
without version number (#3096)
add 3ef998bbaa feat(#3074): Support OAuth login (#3075)
add 70f989ac53 fix: Modify docker compose command in workflow (#3102)
add 2e096859dd Merge branch 'dev' into
3099-plc-adapters-do-not-recover-from-connection-failures
No new revisions were added by this update.
Summary of changes:
.github/workflows/cypress-test.yml | 2 +-
.github/workflows/pr-validation.yml | 2 +-
.../apache/streampipes/commons/constants/Envs.java | 2 +
.../commons/environment/DefaultEnvironment.java | 19 +++
.../commons/environment/Environment.java | 9 ++
.../environment/model/OAuthConfiguration.java | 150 ++++++++++++++++++++
.../parser/OAuthConfigurationParser.java | 137 ++++++++++++++++++
.../parser/OAuthConfigurationParserTest.java | 76 ++++++++++
.../connect/AdapterWorkerManagementTest.java | 2 +-
.../ConnectWorkerDescriptionProviderTest.java | 2 +-
.../management/init/DeclarersSingletonTest.java | 12 +-
.../jvm/welford/WelfordChangeDetection.java | 2 +-
.../jvm/processor/jseval/JSEvalProcessor.java | 3 +-
.../jvm/processor/math/MathOpProcessor.java | 3 +-
.../math/staticmathop/StaticMathOpProcessor.java | 3 +-
.../sizemeasure/SizeMeasureProcessor.java | 45 +++---
.../trigonometry/TrigonometryProcessor.java | 3 +-
.../valuechange/ValueChangeProcessor.java | 3 +-
.../booleanfilter/BooleanFilterProcessor.java | 3 +-
.../jvm/processor/compose/ComposeProcessor.java | 3 +-
.../processor/enrich/MergeByEnrichProcessor.java | 3 +-
.../jvm/processor/limit/RateLimitProcessor.java | 2 +-
.../jvm/processor/merge/MergeByTimeProcessor.java | 3 +-
.../movingaverage/MovingAverageProcessor.java | 3 +-
.../numericalfilter/NumericalFilterProcessor.java | 3 +-
.../NumericalTextFilterProcessor.java | 3 +-
.../processor/projection/ProjectionProcessor.java | 3 +-
.../processor/schema/MergeBySchemaProcessor.java | 3 +-
.../sdt/SwingingDoorTrendingFilterProcessor.java | 3 +-
.../processor/textfilter/TextFilterProcessor.java | 3 +-
.../threshold/ThresholdDetectionProcessor.java | 3 +-
.../throughputmon/ThroughputMonitorProcessor.java | 3 +-
.../processors/siddhi/count/CountAggregation.java | 3 +-
.../filter/NumericalFilterSiddhiProcessor.java | 3 +-
.../siddhi/frequency/FrequencySiddhiProcessor.java | 3 +-
.../FrequencyChangeSiddhiProcessor.java | 3 +-
.../siddhi/listcollector/ListCollector.java | 3 +-
.../processors/siddhi/listfilter/ListFilter.java | 3 +-
.../siddhi/sequence/SequenceSiddhiProcessor.java | 3 +-
.../siddhi/stop/StreamStopSiddhiProcessor.java | 3 +-
.../streampipes/processors/siddhi/topk/TopK.java | 3 +-
.../processors/siddhi/trend/TrendProcessor.java | 3 +-
.../buffergeometry/BufferGeomProcessor.java | 3 +-
.../bufferpoint/BufferPointProcessor.java | 3 +-
.../geo/jvm/jts/processor/epsg/EpsgProcessor.java | 3 +-
.../LatLngToJtsPointProcessor.java | 2 +-
.../reprojection/ReprojectionProcessor.java | 3 +-
.../trajectory/TrajectoryFromPointsProcessor.java | 2 +-
.../complex/TopologyValidationProcessor.java | 3 +-
.../simple/GeometryValidationProcessor.java | 3 +-
.../HaversineDistanceCalculatorProcessor.java | 2 +-
...HaversineStaticDistanceCalculatorProcessor.java | 2 +-
.../googlemaps/GoogleMapsGeocoderProcessor.java | 2 +-
.../GoogleMapsStaticGeocoderProcessor.java | 2 +-
.../geocityname/GeoCityNameRevdecodeProcessor.java | 2 +-
.../speedcalculator/SpeedCalculatorProcessor.java | 2 +-
.../GenericImageClassificationProcessor.java | 4 +-
.../imagecropper/ImageCropperProcessor.java | 3 +-
.../processor/qrreader/QrCodeReaderProcessor.java | 3 +-
.../jvm/processor/chunker/ChunkerProcessor.java | 3 +-
.../language/LanguageDetectionProcessor.java | 3 +-
.../processor/namefinder/NameFinderProcessor.java | 3 +-
.../partofspeech/PartOfSpeechProcessor.java | 3 +-
.../SentenceDetectionProcessor.java | 3 +-
.../processor/tokenizer/TokenizerProcessor.java | 4 +-
.../processor/array/count/CountArrayProcessor.java | 3 +-
.../processor/array/split/SplitArrayProcessor.java | 3 +-
.../counter/BooleanCounterProcessor.java | 3 +-
.../edge/SignalEdgeFilterProcessor.java | 4 +-
.../inverter/BooleanInverterProcessor.java | 3 +-
.../logical/BooleanOperatorProcessor.java | 3 +-
.../state/BooleanToStateProcessor.java | 4 +-
.../timekeeping/BooleanTimekeepingProcessor.java | 4 +-
.../booloperator/timer/BooleanTimerProcessor.java | 3 +-
.../CsvMetadataEnrichmentProcessor.java | 4 +-
.../fieldrename/FiledRenameProcessor.java | 3 +-
.../jvm/processor/hasher/FieldHasherProcessor.java | 3 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 3 +-
.../MeasurementUnitConverterProcessor.java | 4 +-
.../jvm/processor/round/RoundProcessor.java | 2 +-
.../state/buffer/StateBufferProcessor.java | 4 +-
.../buffer/StateBufferLabelerProcessor.java | 4 +-
.../labeler/number/NumberLabelerProcessor.java | 4 +-
.../counter/StringCounterProcessor.java | 4 +-
.../state/StringToStateProcessor.java | 4 +-
.../stringoperator/timer/StringTimerProcessor.java | 3 +-
.../jvm/processor/task/TaskDurationProcessor.java | 4 +-
.../TimestampExtractorProcessor.java | 4 +-
.../TransformToBooleanProcessor.java | 3 +-
.../change/ChangedValueDetectionProcessor.java | 3 +-
.../value/duration/CalculateDurationProcessor.java | 3 +-
streampipes-model-client/pom.xml | 3 +
.../streampipes/model/client/user/UserAccount.java | 16 +++
.../model/client/user/UserRegistrationData.java | 35 ++++-
.../resource/management/UserResourceManager.java | 17 ++-
.../rest/shared/exception/BadRequestException.java | 66 ++++-----
.../streampipes/rest/impl/Authentication.java | 31 ++++-
.../apache/streampipes/rest/impl/UserResource.java | 6 +
.../OAuth2AuthenticationProcessingException.java | 65 +++++----
.../streampipes/sdk/builder/DataSinkBuilder.java | 30 ----
.../sdk/builder/ProcessingElementBuilder.java | 46 -------
.../adapter/AdapterConfigurationBuilder.java | 14 --
.../adapter/AdapterConfigurationBuilderTest.java | 19 +--
.../extractor/AdapterParameterExtractorTest.java | 16 ++-
.../minimal/StreamPipesCoreApplicationMinimal.java | 5 +-
streampipes-service-core/pom.xml | 5 +
.../service/core/StreamPipesCoreApplication.java | 8 +-
.../service/core/WebSecurityConfig.java | 153 +++++++++++++++++++--
.../core/oauth2/CustomOAuth2UserService.java | 48 +++++++
.../service/core/oauth2/CustomOidcUserService.java | 51 +++++++
...CookieOAuth2AuthorizationRequestRepository.java | 83 +++++++++++
...h2AccessTokenResponseConverterWithDefaults.java | 89 ++++++++++++
.../oauth2/OAuth2AuthenticationFailureHandler.java | 63 +++++++++
.../oauth2/OAuth2AuthenticationSuccessHandler.java | 108 +++++++++++++++
.../service/core/oauth2/OAuthEnabledCondition.java | 26 ++--
.../core/oauth2/OidcUserAccountDetails.java | 82 +++++++++++
.../service/core/oauth2/UserService.java | 104 ++++++++++++++
.../service/core/oauth2/util/CookieUtils.java | 81 +++++++++++
.../src/lib/model/gen/streampipes-model-client.ts | 15 +-
.../src/lib/model/gen/streampipes-model.ts | 2 +-
.../warning-box/warning-box.component.html} | 4 +-
.../warning-box/warning-box.component.scss} | 10 +-
.../warning-box/warning-box.component.ts} | 9 +-
.../shared-ui/src/lib/shared-ui.module.ts | 3 +
.../streampipes/shared-ui/src/public-api.ts | 1 +
.../edit-user-dialog.component.html | 5 +-
.../edit-user-dialog/edit-user-dialog.component.ts | 30 ++--
.../security-user-config.component.html | 13 ++
.../security-user-config.component.ts | 6 +-
.../login/components/login/login.component.html | 33 ++++-
.../login/components/login/login.component.scss | 13 ++
.../app/login/components/login/login.component.ts | 12 +-
ui/src/app/login/components/login/login.model.ts | 12 ++
.../general-profile-settings.component.html | 12 +-
.../general/general-profile-settings.component.ts | 2 +
ui/src/app/services/auth.service.ts | 9 ++
136 files changed, 1796 insertions(+), 363 deletions(-)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/model/OAuthConfiguration.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/parser/OAuthConfigurationParser.java
create mode 100644
streampipes-commons/src/test/java/org/apache/streampipes/commons/environment/parser/OAuthConfigurationParserTest.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/UsernameAlreadyTakenException.java
=>
streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared/exception/BadRequestException.java
(68%)
mode change 100644 => 100755
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/StringEnvironmentVariable.java
=>
streampipes-rest/src/main/java/org/apache/streampipes/rest/security/OAuth2AuthenticationProcessingException.java
(66%)
mode change 100644 => 100755
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/CustomOAuth2UserService.java
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/CustomOidcUserService.java
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/HttpCookieOAuth2AuthorizationRequestRepository.java
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/OAuth2AccessTokenResponseConverterWithDefaults.java
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/OAuth2AuthenticationFailureHandler.java
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/OAuth2AuthenticationSuccessHandler.java
copy
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IFlinkProgram.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/OAuthEnabledCondition.java
(57%)
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/OidcUserAccountDetails.java
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/UserService.java
create mode 100755
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/oauth2/util/CookieUtils.java
copy
ui/{src/app/core-ui/pipeline-element-runtime-info/live-preview-error/live-preview-error.component.html
=>
projects/streampipes/shared-ui/src/lib/components/warning-box/warning-box.component.html}
(91%)
copy
ui/{src/app/configuration/general-configuration/general-configuration.component.scss
=>
projects/streampipes/shared-ui/src/lib/components/warning-box/warning-box.component.scss}
(90%)
copy
ui/{src/app/connect/dialog/adapter-started/adapter-started-loading/adapter-started-loading.component.ts
=>
projects/streampipes/shared-ui/src/lib/components/warning-box/warning-box.component.ts}
(82%)
