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 81d4888efd monthly update of vulnerability report
add 97aecd0385 feat(#3353): Support sign and encrypt security modes in
OPC-UA adapte… (#3354)
add 21d5610b7c Move default refresh interval settings to time selection
service (#3352)
add fa6ee977d6 fix: Various cypress tests (#3368)
add 42189bde77 feat(#3355): Add new avro format parser (#3358)
add 298f0765ec fix: Reduce font size of warning boxes
add 4c6a990367 fix: Improve exception messages in OPC-UA connector
add 03acc10d4d fix: Set table as default widget type (#3374)
add 83d172bd77 fix(#3369): Add timeout to select node (#3370)
add 4c6124da20 Add env variables to cypress scripts (#3377)
add 727d146a5f fix: Reuse Influx connection pool (#3375)
add 88396aa1cf feat: Add additional properties to Kafka connectors,
improve logging (#3378)
add 55230acdb1 fix(#3380): Fix editing of data views (#3381)
add da66ce29a4 fix(#3372): Fix time range selector test (#3373)
add 839e44720f 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 (81d4888efd)
\
N -- N -- N refs/heads/create-pull-request/patch (839e44720f)
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:
VULNERABILITY.md | 5 +
pom.xml | 15 +-
.../apache/streampipes/commons/constants/Envs.java | 27 ++-
.../constants/GlobalStreamPipesConstants.java | 1 +
.../commons/environment/DefaultEnvironment.java | 69 +++++++
.../commons/environment/Environment.java | 41 ++--
.../management/AdapterMasterManagement.java | 18 +-
.../management/AdapterMasterManagementTest.java | 19 +-
.../influx/client/InfluxClientUtils.java | 4 +
streampipes-extensions-management/pom.xml | 5 +
.../connect/adapter/BrokerEventProcessor.java | 5 +-
.../connect/adapter/parser/AvroParser.java | 209 +++++++++++++++++++++
.../management/connect/adapter/parser/Parsers.java | 3 +-
.../kafka/KafkaConnectorsModuleExport.java | 12 +-
.../connectors/kafka/adapter/KafkaProtocol.java | 111 +++++------
.../kafka/migration/KafkaAdapterMigrationV1.java | 97 ++++++++++
.../kafka/migration/KafkaAdapterMigrationV2.java} | 30 +--
.../kafka/migration/KafkaSinkMigrationV1.java} | 30 +--
.../kafka/migration/KafkaSinkMigrationV2.java} | 37 ++--
.../kafka/shared/kafka/KafkaAdapterConfig.java | 17 +-
.../{KafkaConfig.java => KafkaBaseConfig.java} | 40 ++--
.../kafka/shared/kafka/KafkaConfigExtractor.java | 148 +++++++++++++++
.../kafka/shared/kafka/KafkaConfigProvider.java | 154 +++++++++++++++
.../kafka/shared/kafka/KafkaConnectUtils.java | 187 ------------------
.../connectors/kafka/sink/KafkaParameters.java | 90 ---------
.../connectors/kafka/sink/KafkaPublishSink.java | 66 +++----
.../strings.en | 34 +++-
.../documentation.md | 5 +-
.../strings.en | 12 +-
.../streampipes-connectors-opcua/pom.xml | 4 +-
.../opcua/OpcUaConnectorsModuleExport.java | 18 +-
.../connectors/opcua/adapter/OpcUaAdapter.java | 46 ++---
.../connectors/opcua/adapter/OpcUaNodeBrowser.java | 7 +-
.../opcua/adapter/OpcUaNodeMetadataExtractor.java | 6 +-
...pOpcUaClient.java => ConnectedOpcUaClient.java} | 62 ++----
.../opcua/client/OpcUaClientProvider.java | 75 ++++++++
.../connectors/opcua/client/SpOpcUaClient.java | 121 +-----------
.../config/MiloOpcUaConfigurationProvider.java | 67 +------
.../connectors/opcua/config/OpcUaConfig.java | 44 ++---
.../opcua/config/SharedUserConfiguration.java | 28 ++-
.../opcua/config/SpOpcUaConfigExtractor.java | 39 ++--
.../config/identity/AnonymousIdentityConfig.java} | 27 +--
.../opcua/config/identity/IdentityConfig.java | 9 +-
.../identity/UsernamePasswordIdentityConfig.java | 36 ++--
.../opcua/config/security/KeyStoreLoader.java | 86 +++++++++
.../opcua/config/security/SecurityConfig.java | 115 ++++++++++++
.../opcua/migration/OpcUaAdapterMigrationV4.java | 121 ++++++++++++
...rMigrationV1.java => OpcUaSinkMigrationV1.java} | 31 ++-
.../extensions/connectors/opcua/sink/OpcUa.java | 54 ++++--
.../connectors/opcua/sink/OpcUaParameters.java | 36 +---
.../connectors/opcua/sink/OpcUaSink.java | 18 +-
.../connectors/opcua/utils/OpcUaUtil.java | 51 ++---
.../connectors/opcua/utils/SecurityUtils.java} | 35 ++--
.../documentation.md | 53 +++++-
.../strings.en | 14 +-
.../documentation.md | 50 ++++-
.../strings.en | 12 ++
.../config/OpcUaAdapterVersionedConfig.java | 3 +-
.../streampipes-extensions-all-iiot/pom.xml | 8 +
.../streampipes-extensions-all-jvm/pom.xml | 9 +
.../streampipes-extensions-iiot-minimal/pom.xml | 4 +
.../integration/adapters/KafkaAdapterTester.java | 24 ++-
.../kafka/config/KafkaConfigAppender.java | 4 +-
.../kafka/config/SimpleConfigAppender.java | 17 +-
.../kafka/security/KafkaSecurityConfig.java | 25 ---
.../KafkaSecurityProtocolConfigAppender.java | 72 +++++++
...g.java => KafkaSecuritySaslConfigAppender.java} | 40 +++-
.../security/KafkaSecuritySaslPlainConfig.java | 51 -----
.../KafkaSecurityUnauthenticatedPlainConfig.java | 29 ---
.../KafkaSecurityUnauthenticatedSSLConfig.java | 32 ----
.../template/PipelineElementTemplateVisitor.java | 1 +
.../connect/RuntimeResolvableResource.java | 5 +
.../apache/streampipes/rest/ResetManagement.java | 50 ++---
.../rest/impl/AdapterMonitoringResource.java | 42 ++++-
.../streampipes/rest/impl/PipelineMonitoring.java | 33 +++-
.../streampipes/rest/impl/PipelineResource.java | 43 +++--
.../rest/impl/connect/AbstractAdapterResource.java | 15 ++
.../rest/impl/connect/AdapterResource.java | 152 +++++++++------
.../rest/impl/connect/CompactAdapterResource.java | 6 +-
.../rest/impl/connect/DescriptionResource.java | 6 +
.../rest/impl/connect/GuessResource.java | 12 ++
.../impl/connect/RuntimeResolvableResource.java | 4 +
.../rest/impl/connect/UnitResource.java | 7 +-
.../rest/security/SpPermissionEvaluator.java | 76 ++++++--
.../builder/adapter/ParserDescriptionBuilder.java | 1 +
ui/cypress/support/utils/GeneralUtils.ts | 7 +
ui/cypress/support/utils/UserUtils.ts | 19 ++
ui/cypress/support/utils/connect/ConnectUtils.ts | 9 +-
ui/cypress/support/utils/connect/OpcUaUtils.ts | 12 +-
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 8 +
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 39 +++-
.../user/PermissionUtils.ts} | 39 ++--
.../support/utils/userInput/StaticPropertyUtils.ts | 10 +-
.../deleteAdapterWithMultipleUsers.smoke.spec.ts | 75 --------
...ec.ts => enhancedAdapterDeletion.smoke.spec.ts} | 31 +--
...ec.ts => opcAdapterConfiguration.smoke.spec.ts} | 3 +-
.../tests/datalake/timeRangeSelectors.spec.ts | 20 +-
.../datalake/widgetDataConfiguration.smoke.spec.ts | 4 +-
.../pipeline/multiUser/pipelineMultiUserSupport.ts | 49 +++++
.../tests/pipeline/pipelineTest.smoke.spec.ts | 23 +--
.../pipeline/updatePipelineTest.smoke.spec.ts | 23 +--
.../tests/pipelineElement/SinglePipelineElement.ts | 2 +-
ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts | 4 +-
.../userManagement/testGroupManagement.spec.ts | 16 +-
.../userManagement/testUserRoleConnect.spec.ts | 67 ++++---
.../userManagement/testUserRolePipeline.spec.ts | 116 ++++++------
.../testVariousUserRoles.smoke.spec.ts | 31 +--
ui/package.json | 6 +-
.../src/lib/model/datalake/DateRange.ts | 6 +
.../components/sp-table/sp-table.component.html | 6 +-
.../refresh-interval-settings.component.html | 1 +
.../refresh-interval-settings.component.ts | 57 ++----
.../time-range-selector.component.html | 4 +-
.../time-selector/time-range-selector.component.ts | 56 +++++-
.../time-selector-menu.component.html | 7 +-
.../time-selector-menu.component.ts | 10 +-
.../src/lib/services/time-selection.service.ts | 59 ++++++
.../streampipes/shared-ui/src/public-api.ts | 1 +
.../general-configuration.component.scss | 3 +-
.../configuration-group.component.html | 6 +-
.../configuration-group.component.ts | 24 ++-
.../existing-adapters.component.html | 1 +
.../object-permission-dialog.component.html | 9 +-
.../object-permission-dialog.component.ts | 2 +-
.../base/abstract-static-property.ts | 20 +-
.../static-alternatives.component.html | 7 +-
.../static-alternatives.component.ts | 45 +++--
.../static-any-input/static-any-input.component.ts | 11 +-
.../static-color-picker.component.html | 2 +-
.../static-color-picker.component.ts | 19 +-
.../static-file-input.component.ts | 10 +-
.../static-free-input.component.ts | 4 +-
.../static-group/static-group.component.html | 2 +-
.../static-group/static-group.component.ts | 6 +-
.../static-mapping-nary.component.ts | 5 +-
.../static-mapping-unary.component.ts | 6 +-
.../static-one-of-input.component.html | 4 +-
.../static-one-of-input.component.ts | 4 +-
.../static-property-util.service.ts | 42 +++++
.../static-property.component.html | 94 ++++++---
.../static-properties/static-property.component.ts | 24 +--
...tatic-runtime-resolvable-any-input.component.ts | 4 +-
.../static-runtime-resolvable-group.component.ts | 2 +-
.../base-runtime-resolvable-input.ts | 45 +----
...tic-runtime-resolvable-oneof-input.component.ts | 38 +++-
.../static-secret-input.component.ts | 16 +-
.../static-slide-toggle.component.ts | 4 +-
.../overview/dashboard-overview.component.html | 6 +-
.../overview/dashboard-overview.component.scss | 5 +-
.../data-explorer-designer-panel.component.html | 4 +
...ta-explorer-widget-data-settings.component.html | 1 +
...data-explorer-widget-data-settings.component.ts | 53 +++++-
.../field-selection-panel.component.ts | 6 +-
.../order-selection-panel.component.ts | 2 +-
.../data-explorer-dashboard-widget.component.html | 16 +-
.../dialog/customize/customize.component.html | 9 +-
.../editor/dialog/customize/customize.component.ts | 23 ++-
.../pipeline-overview.component.html | 4 +-
158 files changed, 3060 insertions(+), 1875 deletions(-)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/AvroParser.java
create mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/migration/KafkaAdapterMigrationV1.java
copy
streampipes-extensions/{streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV1.java
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/migration/KafkaAdapterMigrationV2.java}
(68%)
copy
streampipes-extensions/{streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV1.java
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/migration/KafkaSinkMigrationV1.java}
(55%)
copy
streampipes-extensions/{streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/migrations/MsTeamsSinkMigrationV1.java
=>
streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/migration/KafkaSinkMigrationV2.java}
(56%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/ElementNotFoundException.java
=>
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaAdapterConfig.java
(74%)
rename
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/{KafkaConfig.java
=> KafkaBaseConfig.java} (55%)
create mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConfigExtractor.java
create mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConfigProvider.java
delete mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/shared/kafka/KafkaConnectUtils.java
delete mode 100644
streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/sink/KafkaParameters.java
copy
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client/{SpOpcUaClient.java
=> ConnectedOpcUaClient.java} (79%)
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client/OpcUaClientProvider.java
copy
streampipes-extensions/{streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/OutputFields.java
=>
streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/AnonymousIdentityConfig.java}
(65%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config/ClientConnectionUrlResolver.java
=>
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/IdentityConfig.java
(76%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/StreamPipesApiKeyCredentials.java
=>
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/identity/UsernamePasswordIdentityConfig.java
(54%)
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/security/KeyStoreLoader.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/security/SecurityConfig.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV4.java
copy
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/{OpcUaAdapterMigrationV1.java
=> OpcUaSinkMigrationV1.java} (58%)
copy
streampipes-extensions/streampipes-connectors-opcua/src/{test/java/org/apache/streampipes/extensions/connectors/opcua/utils/OpcUaUtilTest.java
=>
main/java/org/apache/streampipes/extensions/connectors/opcua/utils/SecurityUtils.java}
(50%)
copy
streampipes-dataformat/src/main/java/org/apache/streampipes/dataformat/SpDataFormatDefinition.java
=>
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/config/SimpleConfigAppender.java
(68%)
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityConfig.java
create mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityProtocolConfigAppender.java
rename
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/{KafkaSecuritySaslSSLConfig.java
=> KafkaSecuritySaslConfigAppender.java} (50%)
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecuritySaslPlainConfig.java
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityUnauthenticatedPlainConfig.java
delete mode 100644
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/security/KafkaSecurityUnauthenticatedSSLConfig.java
copy ui/cypress/support/{builder/UserInputBuilder.ts =>
utils/user/PermissionUtils.ts} (54%)
delete mode 100644
ui/cypress/tests/connect/deleteAdapterWithMultipleUsers.smoke.spec.ts
copy ui/cypress/tests/connect/{allAdapterActions.smoke.spec.ts =>
enhancedAdapterDeletion.smoke.spec.ts} (54%)
rename ui/cypress/tests/connect/opcua/{opcAdapterConfiguration.spec.ts =>
opcAdapterConfiguration.smoke.spec.ts} (98%)
create mode 100644
ui/cypress/tests/pipeline/multiUser/pipelineMultiUserSupport.ts
