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 dde4eb1b31 monthly update of vulnerability report
add 6c083b0a4f chore(deps): bump commons-io:commons-io from 2.16.1 to
2.17.0 (#3273)
add 94b68e7147 fix(#3256): Show error message when uploading unsupported
filetypes (#3269)
add c9b36444c4 fix(#3252): Add validation error message (#3270)
add 6fa47bfb41 fix(#3237): Remove selector prefix from output event (#3271)
add beada3a0b4 refactor: Add javadoc to class FunctionRegistrationHandler
(#3277)
add 8d157015af fix: Add spring boot to AllExtensionsIIoTInit (#3265)
add dd68567334 feat(#3266): Add API to programmatically create pipelines
(#3267)
add 50989f4730 feat(#3285): Introduce environment variable to define
allowed extensions for file upload (#3286)
add 72555fb0ac refactor: Refactor unit tests for transformation rules
(#3287)
add 8e5ed5a05d feat(#3283): Allow incomplete events in OPC-UA adapter
(#3284)
add c9ed89ee50 refactor: Remove unused event emitter (#3289)
add f8a96ec002 feat(#3282): regex based preprocessing rule to adapters
(#3288)
add 1d58e08e7b fix: Display location for sites in asset management (#3291)
add aa05e38a8b fix: Modify cypress selector in OPC tests
add 76e8c67558 fix: Support dynamic assets in Maven plugin to generate
docs (#3294)
add 59773aa316 fix: Modify config in OpcAdapterConfiguration test
add 359b86308d feat(#3280): Add support for pipeline templates (#3281)
add eaff2a96e7 fix: Properly delete pipeline templates from canvas (#3309)
add b31b9b31bf Add color mapping for pie chart (#3305)
add 46de302e90 feat: implement the e2e testing framework of go-client
(#3261)
add 9d070d9eb8 feat: add go-client docs (#3263)
add 370bc71cf5 feat(#3298): add cypress e2e tests for compact adapter
feature (#3308)
add 7783d88030 Support output strategies in pipeline code (#3312)
add 2f886104c2 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 (dde4eb1b31)
\
N -- N -- N refs/heads/create-pull-request/patch (2f886104c2)
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/go-client-e2e-test.yml | 66 ++
VULNERABILITY.md | 708 ++-------------
pom.xml | 2 +-
streampipes-client-e2e/README.md | 46 +
streampipes-client-e2e/docker-compose.yml | 135 +++
.../go-client-e2e/adapter/machine.json | 225 +++++
.../go-client-e2e/adapter_test.go | 134 +++
.../go-client-e2e/datalake_test.go | 52 ++
streampipes-client-e2e/go-client-e2e/go.mod | 23 +
.../go-client-e2e/pipeline_test.go | 138 +++
.../go-client-e2e/pipelines/pipelines.json | 960 +++++++++++++++++++++
.../go-client-e2e/utils/create_machine_apadter.go | 37 +
.../go-client-e2e/utils/streampipes_client.go | 36 +
streampipes-client-e2e/tool/go-client-e2e.sh | 61 ++
streampipes-client-e2e/tool/install-element.sh | 113 +++
.../tool/start-streampipes-client-e2e.sh | 148 ++++
streampipes-client-go/docs/content/en/_index.md | 30 +-
.../docs/content/en/docs/_index.md | 30 +-
.../content/en/docs/contribution-guidelines.md | 30 +-
.../docs/content/en/docs/getting-started/_index.md | 30 +-
.../content/en/docs/getting-started/first-steps.md | 41 +-
.../content/en/docs/getting-started/quickstart.md | 30 +-
.../docs/content/en/docs/overview.md | 30 +-
.../docs/content/en/docs/reference/_index.md | 30 +-
.../en/docs/reference/parameter-reference.md | 30 +-
.../tutorials/Introduction-to-streampipes-go.md | 32 +-
.../content/en/docs/tutorials/ManageAdapter.md | 72 ++
.../content/en/docs/tutorials/ManagePipeline.md | 72 ++
.../docs/content/en/docs/tutorials/_index.md | 30 +-
streampipes-client-go/docs/content/en/search.md | 30 +-
streampipes-client-go/streampipes/adapter_api.go | 11 +-
.../internal/serializer/deserializer.go | 158 ++--
.../model/adapter/adapter_description.go | 1 +
streampipes-client-go/streampipes/model/common.go | 45 +
.../streampipes/model/pipeline/pipeline.go | 34 +-
streampipes-client-go/streampipes/pipeline_api.go | 14 +-
.../apache/streampipes/commons/constants/Envs.java | 3 +-
.../commons/environment/DefaultEnvironment.java | 5 +
.../commons/environment/Environment.java | 2 +
.../management/compact/PersistPipelineHandler.java | 114 ++-
.../generator/AdapterEnrichmentRuleGenerator.java | 4 +-
.../compact/generator/CompactAdapterGenerator.java | 123 +++
.../management/AdapterMasterManagement.java | 58 +-
.../management/AdapterUpdateManagement.java | 2 +-
.../management/CompactAdapterManagement.java | 17 +
.../management/AdapterMasterManagementTest.java | 34 +-
.../convert/ToOriginalSchemaConverter.java | 6 +
.../convert/ToTransformedSchemaConverter.java | 12 +
...StatefulTransformationRuleGeneratorVisitor.java | 6 +
...tatelessTransformationRuleGeneratorVisitor.java | 11 +
.../transform/value/RegexTransformationRule.java | 70 ++
.../shared/preprocessing/convert/Helpers.java | 31 +-
.../convert/ToOriginalSchemaConverterTest.java | 20 +-
.../convert/ToTransformedSchemaConverterTest.java | 75 +-
.../transform/value/CorrectionValueTest.java | 69 +-
.../value/RegexTransformationRuleTest.java | 96 +++
.../transform/value/UnitTransformRuleTest.java | 160 ++--
.../transform/value/ValueEventTransformerTest.java | 41 +-
.../extensions/api/assets/AssetResolver.java | 14 +-
.../api/assets/DefaultAssetResolver.java | 17 +-
.../connect/TransformationRuleUpdateVisitor.java | 8 +
.../opcua/OpcUaConnectorsModuleExport.java | 4 +-
.../connectors/opcua/adapter/OpcUaAdapter.java | 17 +-
.../opcua/config/OpcUaAdapterConfig.java | 9 +
.../opcua/config/SharedUserConfiguration.java | 31 +
.../opcua/config/SpOpcUaConfigExtractor.java | 4 +
.../opcua/migration/OpcUaAdapterMigrationV2.java | 3 +-
.../opcua/migration/OpcUaAdapterMigrationV3.java | 68 ++
.../strings.en | 3 +
.../generic/assets/PlcAdapterAssetResolver.java | 12 +-
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 3 +
.../streampipes-extensions-all-jvm/pom.xml | 20 +
.../TransformToBooleanProcessor.java | 21 +-
.../TransformToBooleanProcessorTest.java | 62 ++
.../smp/extractor/ExtensionsFinder.java | 32 +-
.../smp/extractor/LocalesExtractor.java | 10 +-
.../smp/generator/ResourceGenerator.java | 11 +-
.../apache/streampipes/smp/model/AssetModel.java | 12 +
.../connect/adapter/compact/CompactAdapter.java | 3 +
.../adapter/compact/CompactEventProperty.java | 3 +
.../connect/adapter/compact/CreateOptions.java | 7 +-
.../connect/rules/ITransformationRuleVisitor.java | 3 +
.../rules/TransformationRuleDescription.java | 2 +
.../connect/rules/TransformationRulePriority.java | 1 +
.../value/RegexTransformationRuleDescription.java | 75 ++
.../value/ValueTransformationRuleDescription.java | 1 +
.../streampipes/model/message/Notifications.java | 6 +-
.../model/output/AppendOutputStrategy.java | 7 +-
.../model/output/CustomOutputStrategy.java | 7 +-
.../output/CustomTransformOutputStrategy.java | 6 +-
.../model/output/FixedOutputStrategy.java | 4 +
.../model/output/KeepOutputStrategy.java | 5 +
.../model/output/ListOutputStrategy.java | 4 +
.../streampipes/model/output/OutputStrategy.java | 2 +
.../OutputStrategyVisitor.java} | 32 +-
.../model/output/TransformOutputStrategy.java | 5 +
.../model/output/UserDefinedOutputStrategy.java | 5 +
.../ExtendedPipelineElementValidationInfo.java | 23 +-
.../model/pipeline/PipelineModification.java | 17 +-
.../model/pipeline/PipelineModificationResult.java | 15 +-
.../model/pipeline/PipelineVerificationResult.java | 13 +-
.../compact/CompactPipeline.java} | 20 +-
.../compact/CompactPipelineElement.java} | 14 +-
.../compact/CreateOptions.java} | 7 +-
.../pipeline/compact/OutputConfiguration.java | 14 +-
.../compact/UserDefinedOutput.java} | 7 +-
.../DefaultStaticPropertyVisitor.java | 10 +
.../model/template/BoundPipelineElement.java | 57 --
.../model/template/CompactPipelineTemplate.java | 106 +++
.../template/PipelineElementTemplateConfig.java | 67 --
.../PipelinePlaceholderConfig.java} | 6 +-
.../PipelinePlaceholders.java} | 8 +-
.../template/PipelineTemplateDescription.java | 87 --
.../PipelineTemplateGenerationRequest.java} | 11 +-
.../model/template/PipelineTemplateInvocation.java | 97 ---
.../org/apache/streampipes/model/util/Cloner.java | 8 -
.../matching/PipelineModificationGenerator.java | 7 +-
.../matching/PipelineVerificationHandlerV2.java | 32 +-
.../v2/pipeline/CheckCompletedVisitor.java | 70 +-
.../compact/CompactPipelineManagement.java | 65 ++
.../generation/CompactPipelineConverter.java | 116 +++
.../generation/CompactPipelineGenerator.java | 14 +-
.../DataProcessorPipelineElementGenerator.java | 47 +
.../DataSinkPipelineElementGenerator.java | 40 +
.../DataStreamPipelineElementGenerator.java | 17 +-
.../InvocablePipelineElementGenerator.java | 51 ++
.../generation/OutputStrategyGenerator.java | 108 +++
.../PipelineElementConfigurationStep.java | 74 ++
.../manager/preview/PipelinePreview.java | 1 +
.../manager/setup/CouchDbInstallationStep.java | 5 +
.../tasks/AddDefaultPipelineTemplatesTask.java | 29 +-
.../manager/template/CompactConfigGenerator.java | 211 +++++
.../template/PipelineElementTemplateVisitor.java | 43 +-
.../manager/template/PipelineGenerator.java | 139 ---
.../template/PipelineTemplateGenerator.java | 75 --
.../PipelineTemplateInvocationGenerator.java | 66 --
.../PipelineTemplateInvocationHandler.java | 101 ---
.../template/PipelineTemplateManagement.java | 80 --
.../compact/CompactPipelineTemplateManagement.java | 99 +++
.../template/compact/MatchingStreamFinder.java | 77 ++
.../instances/DataLakePipelineTemplate.java | 44 -
.../instances/DefaultPipelineTemplateProvider.java | 9 +-
.../instances/PersistDataLakePipelineTemplate.java | 71 ++
.../management/AdapterResourceManager.java | 29 +-
.../management/AdapterResourceManagerTest.java | 40 +-
.../rest/core/base/impl/CRUDResource.java | 29 +-
.../rest/shared/constants/SpMediaType.java | 8 +-
.../rest/impl/CompactPipelineResource.java | 100 +++
.../streampipes/rest/impl/PipelineElementFile.java | 16 +-
.../streampipes/rest/impl/PipelineResource.java | 21 +
.../streampipes/rest/impl/PipelineTemplate.java | 116 ++-
.../rest/impl/connect/AdapterResource.java | 62 +-
.../rest/impl/connect/CompactAdapterResource.java | 40 +-
.../sdk/builder/BoundPipelineElementBuilder.java | 63 --
.../sdk/builder/PipelineTemplateBuilder.java | 61 --
.../apache/streampipes/sdk/helpers/Filetypes.java | 25 +-
.../streampipes/sdk/helpers/FiletypesTest.java | 4 +-
.../core/migrations/AvailableMigrations.java | 4 +-
.../v970/AddDataLakePipelineTemplateMigration.java | 51 ++
.../function/FunctionRegistrationHandler.java | 13 +-
.../streampipes/storage/api/INoSqlStorage.java | 3 +
.../storage/couchdb/CouchDbStorageManager.java | 9 +
.../storage/couchdb/serializer/GsonSerializer.java | 3 +
.../standalone/StreamPipesNotificationSink.java | 2 +-
.../runtime/StandaloneEventProcessorRuntime.java | 3 +
.../connect/compact/machineDataSimulator.yml | 24 +
.../connect/regexRule/expectedReplaceAllFalse.csv | 2 +
.../connect/regexRule/expectedReplaceAllTrue.csv | 2 +
.../expectedReplaceAllTrueWithEmptyString.csv | 2 +
ui/cypress/fixtures/connect/regexRule/input.csv | 2 +
.../support/builder/CompactAdapterBuilder.ts | 93 ++
ui/cypress/support/utils/CompactUtils.ts | 27 +
ui/cypress/support/utils/GeneralUtils.ts | 23 +
.../support/utils/ProcessingElementTestUtils.ts | 2 +-
.../support/utils/ThirdPartyIntegrationUtils.ts | 2 +-
.../support/utils/connect/CompactAdapterUtils.ts | 81 ++
ui/cypress/support/utils/connect/ConnectBtns.ts | 10 +-
.../utils/connect/ConnectEventSchemaUtils.ts | 17 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 55 +-
ui/cypress/support/utils/connect/OpcUaUtils.ts | 6 +-
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 23 +
.../support/utils/{ => pipeline}/PipelineUtils.ts | 48 +-
.../connect/compact/addCompactAdapter.spec.ts | 99 +++
.../compactAdapterWithTransformation.spec.ts | 73 ++
.../tests/connect/compact/uiConfiguration.spec.ts | 55 ++
.../deleteAdapterWithMultipleUsers.smoke.spec.ts | 2 +-
ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 2 +
.../connect/editAdapterSettingsAndPipeline.spec.ts | 2 +-
.../connect/opcua/opcAdapterConfiguration.spec.ts | 6 +-
.../tests/connect/persistInDataLake.smoke.spec.ts | 2 +-
.../connect/rules/deleteTransformationRule.spec.ts | 12 +-
ui/cypress/tests/connect/rules/regexRule.spec.ts | 107 +++
.../tests/datalake/configuration.smoke.spec.ts | 2 +-
.../restartStreamPipes/restartStreamPipes1.ts | 2 +-
.../testJvmArchetype/testJvmArchetype.ts | 2 +-
.../tests/pipeline/pipelineTest.smoke.spec.ts | 2 +-
.../pipeline/updatePipelineTest.smoke.spec.ts | 2 +-
.../PipelineElementDocumentation.spec.ts | 2 +-
.../pipelineElementConfigurationTemplate.ts | 2 +-
.../userManagement/testGroupManagement.spec.ts | 2 +-
.../userManagement/testUserRolePipeline.spec.ts | 2 +-
.../src/lib/apis/adapter.service.ts | 10 +
.../src/lib/apis/compact-pipeline.service.ts} | 28 +-
.../src/lib/apis/pipeline-template.service.ts | 105 +--
.../src/lib/apis/pipeline.service.ts | 8 +
.../src/lib/model/gen/streampipes-model-client.ts | 3 +-
.../src/lib/model/gen/streampipes-model.ts | 400 +++++++--
.../src/lib/model/types/data-type.ts | 4 +
.../platform-services/src/public-api.ts | 1 +
.../basic-nav-tabs/basic-nav-tabs.component.html | 1 +
.../asset-details/base-asset-details.directive.ts | 10 +
.../asset-details-labels.component.html | 93 +-
.../asset-details-labels.component.ts | 4 +
.../asset-details-site.component.html | 43 +-
ui/src/app/configuration/configuration.module.ts | 2 +
.../file-upload/file-upload-dialog.component.html | 7 +-
.../file-upload/file-upload-dialog.component.ts | 14 +-
.../adapter-code-panel.component.html | 18 +-
.../adapter-code-panel.component.scss | 17 +-
.../adapter-code-panel.component.ts} | 38 +-
.../adapter-options-panel.component.html | 22 +-
.../start-adapter-configuration.component.html | 16 +
.../start-adapter-configuration.component.ts | 1 +
.../abstract-adapter-details.directive.ts | 2 +
.../adapter-details-code.component.html | 32 +-
.../adapter-details-code.component.ts} | 22 +-
.../adapter-details/adapter-details-tabs.ts | 5 +
ui/src/app/connect/connect.module.ts | 12 +-
.../adapter-started-dialog.component.ts | 154 ++--
.../edit-regex-transformation.component.html | 52 ++
.../edit-regex-transformation.component.scss | 0
.../edit-regex-transformation.component.ts} | 18 +-
.../edit-correction-value.component.html | 2 -
.../edit-correction-value.component.ts | 19 +-
.../edit-value-transformation.component.html | 10 +
.../edit-value-transformation.component.ts | 1 +
.../edit-event-property.component.html | 12 +-
.../edit-event-property.component.ts | 18 +
.../services/transformation-rule.service.ts | 63 ++
.../configuration-code-panel.component.html | 30 +-
.../configuration-code-panel.component.scss | 17 +-
.../configuration-code-panel.component.ts} | 21 +-
ui/src/app/core-ui/core-ui.module.ts | 9 +
ui/src/app/core-ui/help/help.component.html | 24 +-
ui/src/app/core-ui/help/help.component.scss | 10 +
ui/src/app/core-ui/help/help.component.ts | 4 +
.../live-preview-table.component.html | 11 +-
.../pipes}/json-pretty-print.pipe.ts | 0
.../pipes/yaml-pretty-print.pipe.ts} | 11 +-
.../config/pie-chart-widget-config.component.html | 106 ++-
.../config/pie-chart-widget-config.component.ts | 59 ++
.../widgets/pie/model/pie-chart-widget.model.ts | 2 +
.../components/widgets/pie/pie-renderer.service.ts | 19 +
.../services/color-mapping.service.ts | 63 ++
.../pipeline-assembly-options.component.html | 20 +-
.../pipeline-assembly-options.component.ts | 26 +-
.../pipeline-assembly.component.html | 2 +
.../pipeline-assembly.component.ts | 17 +-
.../add-template-dialog.component.html} | 37 +-
.../add-template-dialog.component.ts | 62 ++
.../template-selection.component.html | 37 +-
.../template-selection.component.scss | 13 +-
.../template-selection.component.ts} | 24 +-
.../save-pipeline-settings.component.html | 18 +
.../save-pipeline-settings.component.scss | 4 +
.../save-pipeline-settings.component.ts | 17 +-
ui/src/app/editor/editor.module.ts | 4 +
.../services/pipeline-positioning.service.ts | 1 +
ui/src/app/files/files.module.ts | 83 --
ui/src/app/files/files.routes.ts | 27 -
.../pipeline-details-toolbar.component.html | 12 +
.../pipeline-details-toolbar.component.ts | 3 +
.../pipeline-code-dialog.component.html | 34 +-
.../pipeline-code-dialog.component.ts} | 41 +-
.../pipeline-details.component.html | 1 +
.../pipeline-details/pipeline-details.component.ts | 15 +
.../pipeline-details/pipeline-details.module.ts | 2 +
277 files changed, 7950 insertions(+), 3142 deletions(-)
create mode 100644 .github/workflows/go-client-e2e-test.yml
create mode 100644 streampipes-client-e2e/README.md
create mode 100644 streampipes-client-e2e/docker-compose.yml
create mode 100644 streampipes-client-e2e/go-client-e2e/adapter/machine.json
create mode 100644 streampipes-client-e2e/go-client-e2e/adapter_test.go
create mode 100644 streampipes-client-e2e/go-client-e2e/datalake_test.go
create mode 100644 streampipes-client-e2e/go-client-e2e/go.mod
create mode 100644 streampipes-client-e2e/go-client-e2e/pipeline_test.go
create mode 100644
streampipes-client-e2e/go-client-e2e/pipelines/pipelines.json
create mode 100644
streampipes-client-e2e/go-client-e2e/utils/create_machine_apadter.go
create mode 100644
streampipes-client-e2e/go-client-e2e/utils/streampipes_client.go
create mode 100644 streampipes-client-e2e/tool/go-client-e2e.sh
create mode 100644 streampipes-client-e2e/tool/install-element.sh
create mode 100644 streampipes-client-e2e/tool/start-streampipes-client-e2e.sh
create mode 100644
streampipes-client-go/docs/content/en/docs/tutorials/ManageAdapter.md
create mode 100644
streampipes-client-go/docs/content/en/docs/tutorials/ManagePipeline.md
create mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/CompactAdapterGenerator.java
create mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/RegexTransformationRule.java
create mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/RegexTransformationRuleTest.java
create mode 100644
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV3.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBooleanProcessorTest.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/rules/value/RegexTransformationRuleDescription.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/rules/TransformationRulePriority.java
=> output/OutputStrategyVisitor.java} (58%)
copy
streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/config/OpcUaAdapterConfig.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/ExtendedPipelineElementValidationInfo.java
(52%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/instances/PipelineTemplate.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/PipelineModificationResult.java
(68%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/assets/AssetResolver.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/PipelineVerificationResult.java
(70%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/adapter/compact/CompactEventProperty.java
=> pipeline/compact/CompactPipeline.java} (68%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/adapter/compact/CompactConfiguration.java
=> pipeline/compact/CompactPipelineElement.java} (61%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/adapter/compact/CompactConfiguration.java
=> pipeline/compact/CreateOptions.java} (84%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/assets/AssetResolver.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/compact/OutputConfiguration.java
(72%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/adapter/compact/CreateOptions.java
=> pipeline/compact/UserDefinedOutput.java} (79%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/template/BoundPipelineElement.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/template/CompactPipelineTemplate.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/template/PipelineElementTemplateConfig.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/adapter/compact/CreateOptions.java
=> template/PipelinePlaceholderConfig.java} (84%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/adapter/compact/CompactConfiguration.java
=> template/PipelinePlaceholders.java} (78%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/template/PipelineTemplateDescription.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{connect/adapter/compact/CompactConfiguration.java
=> template/PipelineTemplateGenerationRequest.java} (66%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/template/PipelineTemplateInvocation.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/CompactPipelineManagement.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/CompactPipelineConverter.java
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/assets/AssetResolver.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/CompactPipelineGenerator.java
(70%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataProcessorPipelineElementGenerator.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataSinkPipelineElementGenerator.java
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/assets/AssetResolver.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/DataStreamPipelineElementGenerator.java
(64%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/InvocablePipelineElementGenerator.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/OutputStrategyGenerator.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/compact/generation/PipelineElementConfigurationStep.java
rename
streampipes-model/src/main/java/org/apache/streampipes/model/template/PipelineTemplateDescriptionContainer.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/AddDefaultPipelineTemplatesTask.java
(56%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/CompactConfigGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineTemplateGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineTemplateInvocationGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineTemplateInvocationHandler.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineTemplateManagement.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/compact/CompactPipelineTemplateManagement.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/compact/MatchingStreamFinder.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/instances/DataLakePipelineTemplate.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactConfiguration.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/instances/DefaultPipelineTemplateProvider.java
(78%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/instances/PersistDataLakePipelineTemplate.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactConfiguration.java
=>
streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared/constants/SpMediaType.java
(80%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/CompactPipelineResource.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/BoundPipelineElementBuilder.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/PipelineTemplateBuilder.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v970/AddDataLakePipelineTemplateMigration.java
create mode 100644 ui/cypress/fixtures/connect/compact/machineDataSimulator.yml
create mode 100644
ui/cypress/fixtures/connect/regexRule/expectedReplaceAllFalse.csv
create mode 100644
ui/cypress/fixtures/connect/regexRule/expectedReplaceAllTrue.csv
create mode 100644
ui/cypress/fixtures/connect/regexRule/expectedReplaceAllTrueWithEmptyString.csv
create mode 100644 ui/cypress/fixtures/connect/regexRule/input.csv
create mode 100644 ui/cypress/support/builder/CompactAdapterBuilder.ts
create mode 100644 ui/cypress/support/utils/CompactUtils.ts
create mode 100644 ui/cypress/support/utils/GeneralUtils.ts
create mode 100644 ui/cypress/support/utils/connect/CompactAdapterUtils.ts
create mode 100644 ui/cypress/support/utils/pipeline/PipelineBtns.ts
rename ui/cypress/support/utils/{ => pipeline}/PipelineUtils.ts (72%)
create mode 100644 ui/cypress/tests/connect/compact/addCompactAdapter.spec.ts
create mode 100644
ui/cypress/tests/connect/compact/compactAdapterWithTransformation.spec.ts
create mode 100644 ui/cypress/tests/connect/compact/uiConfiguration.spec.ts
create mode 100644 ui/cypress/tests/connect/rules/regexRule.spec.ts
copy ui/{src/app/connect/filter/json-pretty-print.pipe.ts =>
projects/streampipes/platform-services/src/lib/apis/compact-pipeline.service.ts}
(54%)
copy streampipes-client-go/docs/content/en/docs/tutorials/_index.md =>
ui/src/app/connect/components/adapter-code-panel/adapter-code-panel.component.html
(79%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CreateOptions.java
=>
ui/src/app/connect/components/adapter-code-panel/adapter-code-panel.component.scss
(76%)
copy
ui/src/app/{data-explorer/components/widgets/pie/model/pie-chart-widget.model.ts
=> connect/components/adapter-code-panel/adapter-code-panel.component.ts} (53%)
copy
streampipes-client-go/docs/content/en/docs/tutorials/Introduction-to-streampipes-go.md
=>
ui/src/app/connect/components/adapter-details/adapter-details-code/adapter-details-code.component.html
(57%)
copy ui/src/app/connect/{filter/json-pretty-print.pipe.ts =>
components/adapter-details/adapter-details-code/adapter-details-code.component.ts}
(65%)
create mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-regex-transformation/edit-regex-transformation.component.html
copy tools/maven/checkstyle-header.txt =>
ui/src/app/connect/dialog/edit-event-property/components/edit-regex-transformation/edit-regex-transformation.component.scss
(100%)
copy ui/src/app/connect/{filter/json-pretty-print.pipe.ts =>
dialog/edit-event-property/components/edit-regex-transformation/edit-regex-transformation.component.ts}
(67%)
copy
streampipes-client-go/docs/content/en/docs/tutorials/Introduction-to-streampipes-go.md
=>
ui/src/app/core-ui/configuration-code-panel/configuration-code-panel.component.html
(59%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CreateOptions.java
=>
ui/src/app/core-ui/configuration-code-panel/configuration-code-panel.component.scss
(76%)
copy ui/src/app/{connect/filter/json-pretty-print.pipe.ts =>
core-ui/configuration-code-panel/configuration-code-panel.component.ts} (69%)
copy ui/src/app/{connect/filter => core-ui/pipes}/json-pretty-print.pipe.ts
(100%)
rename ui/src/app/{connect/filter/json-pretty-print.pipe.ts =>
core-ui/pipes/yaml-pretty-print.pipe.ts} (80%)
create mode 100644 ui/src/app/data-explorer/services/color-mapping.service.ts
copy ui/src/app/{core-ui/help/help.component.html =>
editor/dialog/add-template-dialog/add-template-dialog.component.html} (55%)
create mode 100644
ui/src/app/editor/dialog/add-template-dialog/add-template-dialog.component.ts
copy streampipes-client-go/docs/content/en/docs/contribution-guidelines.md =>
ui/src/app/editor/dialog/add-template-dialog/template-selection/template-selection.component.html
(52%)
rename
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactConfiguration.java
=>
ui/src/app/editor/dialog/add-template-dialog/template-selection/template-selection.component.scss
(84%)
copy
ui/src/app/{pipeline-details/components/pipeline-details-toolbar/pipeline-details-toolbar.component.ts
=>
editor/dialog/add-template-dialog/template-selection/template-selection.component.ts}
(63%)
delete mode 100644 ui/src/app/files/files.module.ts
delete mode 100644 ui/src/app/files/files.routes.ts
copy
streampipes-client-go/docs/content/en/docs/tutorials/Introduction-to-streampipes-go.md
=>
ui/src/app/pipeline-details/dialogs/pipeline-code/pipeline-code-dialog.component.html
(58%)
copy ui/src/app/{core-ui/help/help.component.ts =>
pipeline-details/dialogs/pipeline-code/pipeline-code-dialog.component.ts} (55%)
