This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch improve-health-management
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 6bb9852e2c Fix checkstyle
add 73241c3da7 feat(#4032): Introducing function transformation for
complex data handling in connect (#4033)
add 605535089c Merge branch 'dev' into improve-health-management
No new revisions were added by this update.
Summary of changes:
...tensions_iiot.xml => AllExtensionsIIoTInit.xml} | 3 +-
.idea/runConfigurations/sp_core.xml | 2 +-
pom.xml | 17 +-
.../go-client-e2e/adapter/machine.json | 576 +++++++++-------
.../commons/constants/GenericDocTypes.java | 3 +-
streampipes-connect-management/pom.xml | 6 +
.../management/AdapterEventPreviewPipeline.java | 30 +-
.../management/compact/AdapterGenerationSteps.java | 6 +-
.../management/compact/SchemaMetadataEnricher.java | 29 +-
.../generator/AdapterEnrichmentRuleGenerator.java | 43 --
.../compact/generator/AdapterSchemaGenerator.java | 81 ++-
.../AdapterTransformationRuleGenerator.java | 85 ---
.../compact/generator/CompactAdapterGenerator.java | 65 +-
.../management/CompactAdapterManagement.java | 3 +-
.../management/management/GuessManagement.java | 111 ++-
.../connect/management/util/EventSchemaUtils.java | 37 +-
.../connect/management/util/WorkerPaths.java | 7 +
.../generator/AdapterSchemaGeneratorTest.java | 77 ---
.../AdapterTransformationRuleGeneratorTest.java | 94 ---
streampipes-connect-shared/pom.xml | 11 +
.../shared/AdapterPipelineGeneratorBase.java | 123 +++-
.../streampipes/connect/shared/DatatypeUtils.java | 3 +-
.../convert/ProvidesConversionResult.java | 29 -
.../preprocessing/convert/SchemaConverter.java | 67 --
.../convert/ToOriginalSchemaConverter.java | 141 ----
.../convert/ToTransformedSchemaConverter.java | 187 -----
.../AdapterTransformationPipelineElement.java | 11 +-
...va => ScriptTransformationPipelineElement.java} | 35 +-
...StatefulTransformationRuleGeneratorVisitor.java | 99 ---
...tatelessTransformationRuleGeneratorVisitor.java | 138 ----
.../TransformationRuleGeneratorVisitor.java | 38 -
.../schema/AddValueTransformationRule.java | 47 --
.../transform/schema/DeleteTransformationRule.java | 45 --
.../transform/schema/MoveTransformationRule.java | 105 ---
.../transform/schema/RenameTransformationRule.java | 47 --
...ava => RemoveDuplicatesTransformationRule.java} | 4 +-
.../value/AddTimestampTransformationRule.java | 38 -
.../value/CorrectionValueTransformationRule.java | 75 --
.../value/DatatypeTransformationRule.java | 2 +-
.../transform/value/RegexTransformationRule.java | 70 --
.../value/TimestampTransformationRule.java | 90 ---
.../transform/value/UnitTransformationRule.java | 3 +-
.../preprocessing/utils/ConversionUtils.java | 93 ---
.../shared/preprocessing/convert/Helpers.java | 113 ---
.../convert/ToOriginalSchemaConverterTest.java | 122 ----
.../convert/ToTransformedSchemaConverterTest.java | 160 -----
.../AdapterTransformationPipelineElementTest.java | 58 --
.../schema/DeleteTransformationRuleTest.java | 144 ----
.../schema/MoveTransformationRuleTest.java | 97 ---
.../schema/RenameTransformationRuleTest.java | 70 --
.../schema/SchemaEventTransformerTest.java | 81 ---
.../transform/value/CorrectionValueTest.java | 138 ----
.../value/RegexTransformationRuleTest.java | 96 ---
.../transform/value/ValueEventTransformerTest.java | 62 --
.../pom.xml | 24 +-
.../connect/transformer/api/ScriptTransformer.java | 21 +-
.../transformer/api/TransformationEngine.java | 28 +-
.../transformer/api/TransformationEngines.java | 31 +-
.../api/exception/ScriptCompilationException.java | 9 +-
.../api/exception/ScriptExecutionException.java | 10 +-
.../utils/TransformationEngineConversionUtils.java | 39 +-
.../pom.xml | 29 +-
.../transformer/groovy/GroovyScriptEngine.java | 74 ++
.../pom.xml | 40 +-
.../transformer/js/GraalJsScriptEngine.java | 101 +++
.../transformer/js/PolyglotResultConverter.java | 72 ++
.../extensions/api/connect/IParser.java | 5 +-
.../extensions/api/connect/StreamPipesAdapter.java | 32 +-
.../connect/AdapterWorkerSampleDataManagement.java | 79 +++
.../management/connect/GuessManagement.java | 100 ---
.../management/connect/SchemaUpdateManagement.java | 116 ----
.../connect/TransformationRuleUpdateVisitor.java | 153 -----
.../connect/adapter/AdapterPipelineGenerator.java | 4 +-
.../connect/adapter/parser/AvroParser.java | 18 +-
.../connect/adapter/parser/CsvParser.java | 43 +-
.../connect/adapter/parser/ImageParser.java | 20 +-
.../connect/adapter/parser/JsonParsers.java | 6 +-
.../connect/adapter/parser/ParserUtils.java | 48 --
.../connect/adapter/parser/json/GeoJsonParser.java | 145 ++--
.../adapter/parser/json/JsonArrayKeyParser.java | 9 +-
.../adapter/parser/json/JsonArrayParser.java | 22 +-
.../adapter/parser/json/JsonObjectParser.java | 10 +-
.../connect/adapter/parser/json/JsonParser.java | 7 +-
.../adapter/parser/util/JsonEventProperty.java | 2 +
.../connect/adapter/parser/xml/XmlParser.java | 20 +-
.../management/connect/GuessManagementTest.java | 51 --
.../management/connect/adapter/TestUtils.java | 10 -
.../connect/adapter/parser/CsvParserTest.java | 101 ---
.../connect/adapter/parser/XmlParserTest.java | 39 --
.../parser/json/JsonArrayKeyParserTest.java | 53 --
.../adapter/parser/json/JsonArrayParserTest.java | 35 -
.../adapter/parser/json/JsonObjectParsersTest.java | 29 -
.../model/SpServiceDefinitionBuilderTest.java | 9 +-
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 12 +-
.../machine/MachineDataSimulatorAdapter.java | 10 +-
.../machine/event/DiagnosticSimulator.java | 9 +
.../simulator/machine/event/EventSimulator.java | 3 +
.../simulator/machine/event/FlowSimulator.java | 9 +
.../simulator/machine/event/PressureSimulator.java | 9 +
.../machine/event/WaterlevelSimulator.java | 9 +
.../iiot/protocol/stream/FileReplayAdapter.java | 30 +-
.../iiot/protocol/stream/HttpServerProtocol.java | 28 +-
.../iiot/protocol/stream/HttpStreamProtocol.java | 8 +-
.../protocol/stream/FileReplayAdapterTest.java | 136 ----
.../adapters/image/stream/ImageStreamAdapter.java | 18 +-
.../connect/adapters/iss/IssAdapter.java | 34 +-
.../connectors/influx/adapter/InfluxDbClient.java | 38 +-
.../influx/adapter/InfluxDbStreamAdapter.java | 132 +++-
.../connectors/kafka/adapter/KafkaProtocol.java | 8 +-
.../connectors/mqtt/adapter/MqttProtocol.java | 8 +-
.../connectors/nats/adapter/NatsProtocol.java | 67 +-
.../connectors/opcua/adapter/OpcUaAdapter.java | 24 +-
.../opcua/adapter/OpcUaSchemaProvider.java | 22 +-
.../plc/adapter/generic/GenericPlc4xAdapter.java | 18 +-
.../plc/adapter/modbus/Plc4xModbusAdapter.java | 141 ++--
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 126 ++--
.../connectors/pulsar/adapter/PulsarProtocol.java | 8 +-
.../rocketmq/adapter/RocketMQProtocol.java | 8 +-
.../connectors/ros/adapter/RosBridgeAdapter.java | 13 +-
.../connectors/tubemq/adapter/TubeMQProtocol.java | 8 +-
.../streampipes-processors-enricher-jvm/pom.xml | 10 +-
.../streampipes/model/assets/SpAssetModel.java | 2 +-
.../ConnectTransformationScriptTemplate.java} | 84 ++-
.../model/connect/ReduceEventRateRule.java | 6 +-
.../model/connect/RemoveDuplicateRule.java | 6 +-
.../streampipes/model/connect/ScriptMetadata.java | 7 +-
.../model/connect/TransformationConfig.java | 95 +++
.../model/connect/adapter/AdapterDescription.java | 49 +-
.../connect/adapter/compact/CompactAdapter.java | 4 +-
.../adapter/compact/CompactEventProperty.java | 5 +-
.../connect/adapter/compact/CompactTransport.java | 22 -
.../connect/adapter/compact/EnrichmentConfig.java | 21 -
.../adapter/compact/TransformationConfig.java | 25 -
.../model/connect/guess/FieldStatus.java | 3 +-
.../model/connect/guess/FieldStatusInfo.java | 22 +-
.../{AdapterEventPreview.java => SampleData.java} | 27 +-
.../connect/rules/ITransformationRuleVisitor.java | 25 +-
.../rules/TransformationRuleDescription.java | 3 +-
.../connect/rules/TransformationRulePriority.java | 1 +
.../rules/schema/DeleteRuleDescription.java | 7 +-
.../connect/rules/schema/MoveRuleDescription.java | 7 +-
.../rules/schema/RenameRuleDescription.java | 7 +-
.../SchemaTransformationRuleDescription.java | 1 +
.../EventRateTransformationRuleDescription.java | 14 +-
...oveDuplicatesTransformationRuleDescription.java | 13 +-
.../StreamTransformationRuleDescription.java | 1 +
.../rules/value/AddTimestampRuleDescription.java | 7 +-
.../AddValueTransformationRuleDescription.java | 14 +-
...hangeDatatypeTransformationRuleDescription.java | 13 +-
...rrectionValueTransformationRuleDescription.java | 7 +-
.../value/RegexTransformationRuleDescription.java | 7 +-
.../TimestampTranfsformationRuleDescription.java | 7 +-
.../rules/value/UnitTransformRuleDescription.java | 7 +-
.../value/ValueTransformationRuleDescription.java | 1 +
.../svcdiscovery/SpServiceRegistration.java | 23 +-
.../connect/adapter/AdapterDescriptionTest.java | 66 --
.../ExtensionsServiceEndpointGenerator.java | 10 +-
.../endpoint/ExtensionsServiceEndpointUtils.java | 11 +
.../manager/setup/CouchDbInstallationStep.java | 14 +-
...java => AbstractAddGenericStorageViewTask.java} | 21 +-
.../setup/tasks/AddScriptTemplateViewTask.java | 27 +-
.../setup/tasks/CreateAssetLinkTypeTask.java | 6 +-
...e.java => AdapterWorkerSampleDataResource.java} | 51 +-
...ionHandler.java => SpRestExceptionHandler.java} | 14 +-
.../streampipes/rest/impl/ResetResource.java | 6 +
.../rest/impl/connect/GuessResource.java | 82 ++-
.../TransformationScriptLanguageResource.java | 87 +++
.../TransformationScriptTemplateResource.java | 84 +++
.../sdk/builder/adapter/SampleDataBuilder.java | 87 +++
.../minimal/StreamPipesCoreApplicationMinimal.java | 8 +-
streampipes-service-core/pom.xml | 10 +
.../service/core/StreamPipesCoreApplication.java | 20 +-
.../core/migrations/AvailableMigrations.java | 8 +-
.../AddGenericStorageViewMigration.java} | 26 +-
.../v0980/ModifyAssetLinksMigration.java | 2 +-
.../v099/AddAssetManagementViewMigration.java | 26 +-
.../v099/AddScriptTemplateViewMigration.java | 28 +-
.../v099/ModifyAssetLinkIconMigration.java | 110 +++
.../v099/connect/AdapterRuleConverter.java | 202 ++++++
.../v099/connect/MigrateAdaptersToUseScript.java | 154 +++++
.../v099/connect/TransformationScriptBuilder.java | 47 +-
.../v099/MigrateAdaptersToUseScriptTest.java | 398 +++++++++++
.../svcdiscovery/api/ISpServiceDiscovery.java | 4 +
.../svcdiscovery/SpServiceDiscoveryCore.java | 12 +-
streampipes-service-extensions/pom.xml | 15 +
.../StreamPipesExtensionsServiceBase.java | 21 +-
.../streampipes/storage/api/INoSqlStorage.java | 3 +
.../storage/couchdb/CouchDbStorageManager.java | 10 +
.../connect/addNumericalStaticValue/expected.json | 17 -
.../connect/addNumericalStaticValue/input.csv | 4 -
ui/cypress/fixtures/connect/compact/fileReplay.yml | 3 -
.../deleteTransformationRule/nestedInput.json | 1 +
.../deleteTransformationRule/prefixInput.csv | 2 -
.../connect/regexRule/expectedReplaceAllFalse.csv | 2 -
.../connect/regexRule/expectedReplaceAllTrue.csv | 2 -
.../expectedReplaceAllTrueWithEmptyString.csv | 2 -
ui/cypress/fixtures/connect/regexRule/input.csv | 2 -
.../fixtures/connect/schemaRules/expected.csv | 4 +-
.../fixtures/connect/valueRules/expected.csv | 4 +-
.../support/builder/CompactAdapterBuilder.ts | 49 +-
ui/cypress/support/utils/FileManagementUtils.ts | 4 +-
.../support/utils/ThirdPartyIntegrationUtils.ts | 8 +-
ui/cypress/support/utils/UserUtils.ts | 3 +-
.../support/utils/connect/CompactAdapterUtils.ts | 3 +
ui/cypress/support/utils/connect/ConnectBtns.ts | 117 +++-
.../utils/connect/ConnectEventSchemaUtils.ts | 216 +-----
ui/cypress/support/utils/connect/ConnectUtils.ts | 166 +++--
ui/cypress/support/utils/connect/OpcUaUtils.ts | 1 +
.../support/utils/dataExplorer/DataExplorerBtns.ts | 14 +-
.../utils/dataExplorer/DataExplorerUtils.ts | 11 +-
.../{CompactUtils.ts => shared/SharedBtns.ts} | 15 +-
.../support/utils/shared/SharedUtils.ts} | 9 +-
ui/cypress/support/utils/user/UserBtns.ts | 6 -
...rTest.smoke.spec.ts => assetFilterTest.spec.ts} | 0
ui/cypress/tests/connect/adapterWithAssets.spec.ts | 9 +-
.../connect/compact/addCompactAdapter.spec.ts | 2 +
.../compactAdapterWithTransformation.spec.ts | 10 +-
.../tests/connect/compact/uiConfiguration.spec.ts | 1 +
.../connect/createAdapterWithoutStarting.spec.ts | 1 +
ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 40 +-
.../editAdapterSettingsAndPipeline.smoke.spec.ts | 9 +-
.../editAdapterTransformationRulesAreKept.spec.ts | 19 +-
.../connect/editAdapterValuesAndFields.spec.ts | 48 +-
ui/cypress/tests/connect/fileStream.spec.ts | 204 +++---
ui/cypress/tests/connect/formats/format.spec.ts | 55 +-
.../connect/machineDataSimulator.smoke.spec.ts | 10 +-
.../opcua/startAndEditOpcAdapters.smoke.spec.ts | 11 +-
.../connect/opcua/staticPropertyTreeNodesTest.ts | 85 ---
.../connect/rules/addNumericalStaticValue.spec.ts | 87 ---
.../connect/rules/deleteTransformationRule.spec.ts | 80 +--
ui/cypress/tests/connect/rules/regexRule.spec.ts | 107 ---
.../tests/connect/rules/schemaRules.smoke.spec.ts | 25 +-
ui/cypress/tests/connect/rules/streamRules.spec.ts | 29 +-
ui/cypress/tests/connect/rules/valueRules.spec.ts | 20 +-
ui/cypress/tests/connect/scriptTemplate.spec.ts | 81 +++
.../connect/validateConfigurationChanges.spec.ts | 85 +++
ui/cypress/tests/thirdparty/InfluxDb.smoke.spec.ts | 1 +
.../userManagement/testGroupManagement.spec.ts | 3 +-
ui/package-lock.json | 24 +-
ui/package.json | 3 +-
...vice.ts => connect-script-languages.service.ts} | 18 +-
...vice.ts => connect-script-templates.service.ts} | 32 +-
.../src/lib/model/gen/streampipes-model-client.ts | 2 +-
.../src/lib/model/gen/streampipes-model.ts | 250 +++++--
.../platform-services/src/public-api.ts | 2 +
.../basic-inner-panel.component.html | 8 +-
.../basic-inner-panel.component.scss | 12 +-
.../form-label/form-label.component.html | 25 +-
.../form-label/form-label.component.scss | 2 +-
.../confirm-dialog/confirm-dialog.component.html | 2 +-
.../AdapterConfigurationState.ts | 61 ++
.../adapter-configuration-state.service.ts | 394 +++++++++++
.../adapter-configuration.component.html | 164 +++--
.../adapter-configuration.component.ts | 117 ++--
.../adapter-event-preview-node.component.html | 77 +++
.../adapter-event-preview-node.component.scss | 108 +++
.../adapter-event-preview-node.component.ts | 113 +++
.../adapter-event-preview.component.html} | 40 +-
.../adapter-event-preview.component.scss} | 37 +-
.../adapter-event-preview.component.ts | 59 ++
.../adapter-settings.component.html | 29 +-
.../adapter-settings/adapter-settings.component.ts | 29 +-
.../configure-fields-header.component.html} | 17 +-
.../configure-fields-header.component.ts} | 16 +-
...onfigure-fields-loading-message.component.html} | 5 +-
.../configure-fields-loading-message.component.ts} | 8 +-
.../configure-fields-preview.component.html} | 20 +-
.../configure-fields-preview.component.scss} | 8 +-
.../configure-fields-preview.component.ts} | 22 +-
.../configure-fields.component.html | 116 ++++
.../configure-fields.component.scss} | 8 +
.../configure-fields/configure-fields.component.ts | 121 ++++
.../configure-fields-error-message.component.html} | 9 +-
.../configure-fields-error-message.component.scss} | 2 +-
.../configure-fields-error-message.component.ts} | 12 +-
.../event-property-row.component.html | 131 ++++
.../event-property-row.component.scss | 52 +-
.../event-property-row.component.ts | 188 +++++
.../event-property-scope.component.html | 56 ++
.../event-property-scope.component.ts | 90 +++
.../no-timestamp-error-hint.component.html} | 19 +-
.../no-timestamp-error-hint.component.ts} | 8 +-
.../configure-schema.component.html | 287 ++++++++
.../configure-schema.component.scss} | 42 +-
.../configure-schema/configure-schema.component.ts | 309 +++++++++
.../show-field-status-infos.component.html | 58 ++
.../show-field-status-infos.component.scss} | 56 +-
.../show-field-status-infos.component.ts} | 32 +-
.../event-property-row.component.html | 171 -----
.../event-property-row.component.ts | 253 -------
.../event-schema-error-hints.component.cy.ts | 105 ---
.../event-schema-error-hints.component.html | 71 --
.../event-schema-error-hints.component.scss | 49 --
.../event-schema-error-hints.component.ts | 36 -
.../event-schema-preview.component.ts | 48 --
.../event-schema/event-schema.component.html | 151 ----
.../event-schema/event-schema.component.ts | 382 -----------
.../loading-message/loading-message.component.html | 32 -
.../loading-message/loading-message.component.scss | 17 -
.../schema-editor-header.component.html | 100 ---
.../schema-editor-header.component.scss | 17 -
.../schema-editor-header.component.ts | 66 --
.../adapter-options-panel.component.html | 10 +-
.../start-adapter-configuration.component.html | 304 ++++----
.../start-adapter-configuration.component.ts | 130 ++--
.../create-adapter/create-adapter.component.html | 2 +-
.../edit-adapter/edit-adapter.component.html | 2 +-
ui/src/app/connect/connect.module.ts | 58 +-
.../adapter-started-dialog.component.html | 1 +
.../adapter-started-success.component.html | 8 +-
...adapter-started-update-migration.component.html | 8 +-
...r-transformation-template-dialog.component.html | 57 ++
...-transformation-template-dialog.component.scss} | 13 +-
...ter-transformation-template-dialog.component.ts | 62 ++
.../edit-regex-transformation.component.html | 52 --
.../edit-regex-transformation.component.scss | 17 -
.../edit-regex-transformation.component.ts | 30 -
.../edit-data-type/edit-data-type.component.html | 3 +-
.../edit-data-type/edit-data-type.component.scss | 20 -
.../edit-data-type/edit-data-type.component.ts | 30 +-
.../edit-schema-transformation.component.html | 175 ++---
.../edit-schema-transformation.component.ts | 31 +-
.../edit-unit-transformation.component.html | 23 +-
.../edit-unit-transformation.component.scss | 23 -
.../edit-unit-transformation.component.ts | 8 +-
.../edit-correction-value.component.html | 66 --
.../edit-correction-value.component.ts | 37 -
.../edit-timestamp-property.component.html | 72 --
.../edit-timestamp-property.component.scss | 22 -
.../edit-timestamp-property.component.ts | 41 --
.../edit-value-transformation.component.html | 77 ---
.../edit-value-transformation.component.scss | 17 -
.../edit-value-transformation.component.ts | 70 --
.../ep-settings-section.component.html | 37 -
.../ep-settings-section.component.scss | 32 -
.../ep-settings-section.component.ts | 33 -
.../edit-event-property.component.html | 83 ++-
.../edit-event-property.component.ts | 159 ++---
...r-transformation-template-dialog.component.html | 122 ++++
...-transformation-template-dialog.component.scss} | 13 +-
...ter-transformation-template-dialog.component.ts | 61 ++
.../all-adapter-actions-dialog.component.html | 1 +
.../services/event-property-utils.service.ts | 10 +-
ui/src/app/connect/services/rest.service.ts | 49 +-
.../services/static-value-transform.service.ts | 15 -
.../services/transformation-rule.service.ts | 762 ---------------------
ui/src/app/home/home.component.ts | 17 +
ui/src/scss/main.scss | 1 -
ui/src/scss/sp/_variables.scss | 1 +
349 files changed, 7952 insertions(+), 10118 deletions(-)
copy .idea/runConfigurations/{sp_extensions_iiot.xml =>
AllExtensionsIIoTInit.xml} (77%)
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterEnrichmentRuleGenerator.java
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/compact/generator/AdapterTransformationRuleGenerator.java
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/util/JsonEventProperty.java
=>
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/EventSchemaUtils.java
(78%)
delete mode 100644
streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/compact/generator/AdapterSchemaGeneratorTest.java
delete mode 100644
streampipes-connect-management/src/test/java/org/apache/streampipes/connect/management/management/compact/generator/AdapterTransformationRuleGeneratorTest.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ProvidesConversionResult.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/SchemaConverter.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToOriginalSchemaConverter.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverter.java
copy
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/elements/{AdapterTransformationPipelineElement.java
=> ScriptTransformationPipelineElement.java} (52%)
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatefulTransformationRuleGeneratorVisitor.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/StatelessTransformationRuleGeneratorVisitor.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/generator/TransformationRuleGeneratorVisitor.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/AddValueTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/DeleteTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/MoveTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/RenameTransformationRule.java
rename
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/stream/{DuplicateFilterPipelineElement.java
=> RemoveDuplicatesTransformationRule.java} (94%)
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/AddTimestampTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/CorrectionValueTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/RegexTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/TimestampTransformationRule.java
delete mode 100644
streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/utils/ConversionUtils.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/Helpers.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToOriginalSchemaConverterTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/convert/ToTransformedSchemaConverterTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/elements/AdapterTransformationPipelineElementTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/DeleteTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/MoveTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/RenameTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/schema/SchemaEventTransformerTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/CorrectionValueTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/RegexTransformationRuleTest.java
delete mode 100644
streampipes-connect-shared/src/test/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/ValueEventTransformerTest.java
copy {streampipes-messaging => streampipes-connect-transformer-api}/pom.xml
(68%)
copy
streampipes-data-explorer-api/src/main/java/org/apache/streampipes/dataexplorer/api/IDataLakeMeasurementCounter.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/ScriptTransformer.java
(55%)
copy
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadBalancer.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/TransformationEngine.java
(52%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/preview/ActivePipelinePreviews.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/TransformationEngines.java
(52%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/parser/PrimitiveTypeParser.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/exception/ScriptCompilationException.java
(78%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/connect/AdapterException.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/exception/ScriptExecutionException.java
(77%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/util/SchemaUtils.java
=>
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/utils/TransformationEngineConversionUtils.java
(51%)
copy {streampipes-wrapper-distributed =>
streampipes-connect-transformer-groovy}/pom.xml (68%)
create mode 100644
streampipes-connect-transformer-groovy/src/main/java/org/apache/streampipes/connect/transformer/groovy/GroovyScriptEngine.java
copy {streampipes-extensions-api =>
streampipes-connect-transformer-js}/pom.xml (65%)
create mode 100644
streampipes-connect-transformer-js/src/main/java/org/apache/streampipes/connect/transformer/js/GraalJsScriptEngine.java
create mode 100644
streampipes-connect-transformer-js/src/main/java/org/apache/streampipes/connect/transformer/js/PolyglotResultConverter.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerSampleDataManagement.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/GuessManagement.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/SchemaUpdateManagement.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/TransformationRuleUpdateVisitor.java
delete mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/ParserUtils.java
delete mode 100644
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/GuessManagementTest.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{template/CompactPipelineTemplate.java
=> connect/ConnectTransformationScriptTemplate.java} (65%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/paths/ApiPath.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/ReduceEventRateRule.java
(85%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/SepaParseException.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/RemoveDuplicateRule.java
(88%)
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/RawUserApiToken.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/ScriptMetadata.java
(82%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/TransformationConfig.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/CompactTransport.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/EnrichmentConfig.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/compact/TransformationConfig.java
rename
streampipes-model/src/main/java/org/apache/streampipes/model/connect/guess/{AdapterEventPreview.java
=> SampleData.java} (62%)
delete mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/connect/adapter/AdapterDescriptionTest.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/{AddAssetManagementViewTask.java
=> AbstractAddGenericStorageViewTask.java} (71%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/PulsarTransportProtocol.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/tasks/AddScriptTemplateViewTask.java
(59%)
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect/{GuessResource.java
=> AdapterWorkerSampleDataResource.java} (53%)
rename
streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared/exception/{RestResponseLogMessageExceptionHandler.java
=> SpRestExceptionHandler.java} (68%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/TransformationScriptLanguageResource.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/TransformationScriptTemplateResource.java
create mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/SampleDataBuilder.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/{v099/AddAssetManagementViewMigration.java
=> templates/AddGenericStorageViewMigration.java} (66%)
copy
streampipes-security-jwt/src/main/java/org/apache/streampipes/security/jwt/PublicKeyResolver.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/AddScriptTemplateViewMigration.java
(58%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/ModifyAssetLinkIconMigration.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/connect/AdapterRuleConverter.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/connect/MigrateAdaptersToUseScript.java
copy
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/objectstorage/ExportProviderFactory.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/connect/TransformationScriptBuilder.java
(50%)
create mode 100644
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/migrations/v099/MigrateAdaptersToUseScriptTest.java
delete mode 100644
ui/cypress/fixtures/connect/addNumericalStaticValue/expected.json
delete mode 100644
ui/cypress/fixtures/connect/addNumericalStaticValue/input.csv
delete mode 100644
ui/cypress/fixtures/connect/deleteTransformationRule/prefixInput.csv
delete mode 100644
ui/cypress/fixtures/connect/regexRule/expectedReplaceAllFalse.csv
delete mode 100644
ui/cypress/fixtures/connect/regexRule/expectedReplaceAllTrue.csv
delete mode 100644
ui/cypress/fixtures/connect/regexRule/expectedReplaceAllTrueWithEmptyString.csv
delete mode 100644 ui/cypress/fixtures/connect/regexRule/input.csv
copy ui/cypress/support/utils/{CompactUtils.ts => shared/SharedBtns.ts} (69%)
copy
ui/{src/app/dataset/dialog/data-retention-dialog/model/data-retention-provider.model.ts
=> cypress/support/utils/shared/SharedUtils.ts} (82%)
rename ui/cypress/tests/assetManagement/{assetFilterTest.smoke.spec.ts =>
assetFilterTest.spec.ts} (100%)
delete mode 100644
ui/cypress/tests/connect/opcua/staticPropertyTreeNodesTest.ts
delete mode 100644
ui/cypress/tests/connect/rules/addNumericalStaticValue.spec.ts
delete mode 100644 ui/cypress/tests/connect/rules/regexRule.spec.ts
create mode 100644 ui/cypress/tests/connect/scriptTemplate.spec.ts
create mode 100644
ui/cypress/tests/connect/validateConfigurationChanges.spec.ts
copy
ui/projects/streampipes/platform-services/src/lib/apis/{compact-pipeline.service.ts
=> connect-script-languages.service.ts} (72%)
copy
ui/projects/streampipes/platform-services/src/lib/apis/{certificate.service.ts
=> connect-script-templates.service.ts} (58%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-configuration-state-service/AdapterConfigurationState.ts
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-configuration-state-service/adapter-configuration-state.service.ts
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-event-preview/adapter-event-preview-node/adapter-event-preview-node.component.html
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-event-preview/adapter-event-preview-node/adapter-event-preview-node.component.scss
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-event-preview/adapter-event-preview-node/adapter-event-preview-node.component.ts
copy
ui/src/app/{dashboard/components/panel/chart-selection-panel/chart-selection-panel.component.html
=>
connect/components/adapter-configuration/adapter-event-preview/adapter-event-preview.component.html}
(53%)
copy
ui/src/app/{configuration/security-configuration/edit-role-dialog/edit-role-dialog.component.scss
=>
connect/components/adapter-configuration/adapter-event-preview/adapter-event-preview.component.scss}
(62%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-event-preview/adapter-event-preview.component.ts
copy
ui/src/app/{core-ui/pipeline-element-template-config/pipeline-element-template-config-item/pipeline-element-template-config-item.component.html
=>
connect/components/adapter-configuration/configure-fields/configure-fields-header/configure-fields-header.component.html}
(75%)
rename
ui/src/app/connect/components/adapter-configuration/{schema-editor/loading-message/loading-message.component.ts
=>
configure-fields/configure-fields-header/configure-fields-header.component.ts}
(70%)
copy
ui/{projects/streampipes/shared-ui/src/lib/dialog/card-dialog/card-dialog.component.html
=>
src/app/connect/components/adapter-configuration/configure-fields/configure-fields-loading-message/configure-fields-loading-message.component.html}
(84%)
copy
ui/{projects/streampipes/shared-ui/src/lib/components/feature-card-host/feature-card-meta-section/feature-card-meta-section.component.ts
=>
src/app/connect/components/adapter-configuration/configure-fields/configure-fields-loading-message/configure-fields-loading-message.component.ts}
(82%)
rename
ui/src/app/connect/components/adapter-configuration/{schema-editor/event-schema-preview/event-schema-preview.component.html
=>
configure-fields/configure-fields-preview/configure-fields-preview.component.html}
(79%)
rename
ui/src/app/connect/components/adapter-configuration/{schema-editor/event-schema-preview/event-schema-preview.component.scss
=>
configure-fields/configure-fields-preview/configure-fields-preview.component.scss}
(86%)
copy
ui/src/app/{chart-shared/components/charts/base/too-much-data/too-much-data.component.ts
=>
connect/components/adapter-configuration/configure-fields/configure-fields-preview/configure-fields-preview.component.ts}
(67%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-fields/configure-fields.component.html
rename
ui/src/app/connect/components/adapter-configuration/{schema-editor/event-schema/event-schema.component.scss
=> configure-fields/configure-fields.component.scss} (96%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-fields/configure-fields.component.ts
rename
ui/src/app/connect/components/adapter-configuration/{schema-editor/error-message/error-message.component.html
=>
configure-fields/error-message/configure-fields-error-message.component.html}
(85%)
rename
ui/src/app/connect/components/adapter-configuration/{schema-editor/error-message/error-message.component.scss
=>
configure-fields/error-message/configure-fields-error-message.component.scss}
(95%)
rename
ui/src/app/connect/components/adapter-configuration/{schema-editor/error-message/error-message.component.ts
=> configure-fields/error-message/configure-fields-error-message.component.ts}
(80%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-fields/event-property-row/event-property-row.component.html
rename ui/src/app/connect/components/adapter-configuration/{schema-editor =>
configure-fields}/event-property-row/event-property-row.component.scss (68%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-fields/event-property-row/event-property-row.component.ts
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-fields/event-property-row/event-property-scope/event-property-scope.component.html
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-fields/event-property-row/event-property-scope/event-property-scope.component.ts
copy ui/{cypress/fixtures/connect/format/xmlObject.xml =>
src/app/connect/components/adapter-configuration/configure-fields/no-timestamp-error-hint/no-timestamp-error-hint.component.html}
(74%)
copy
ui/{projects/streampipes/shared-ui/src/lib/components/pipeline-element-runtime-info/live-preview-error/live-preview-error.component.ts
=>
src/app/connect/components/adapter-configuration/configure-fields/no-timestamp-error-hint/no-timestamp-error-hint.component.ts}
(82%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-schema/configure-schema.component.html
copy
ui/src/app/connect/components/adapter-configuration/{adapter-configuration.component.scss
=> configure-schema/configure-schema.component.scss} (59%)
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-schema/configure-schema.component.ts
create mode 100644
ui/src/app/connect/components/adapter-configuration/configure-schema/show-field-status-infos/show-field-status-infos.component.html
copy
ui/{projects/streampipes/shared-ui/src/lib/components/alert-banner/alert-banner.component.scss
=>
src/app/connect/components/adapter-configuration/configure-schema/show-field-status-infos/show-field-status-infos.component.scss}
(66%)
copy
ui/{projects/streampipes/shared-ui/src/lib/components/asset-browser/asset-browser-toolbar/asset-browser-filter/asset-browser-filter-outer/asset-browser-filter-outer.component.ts
=>
src/app/connect/components/adapter-configuration/configure-schema/show-field-status-infos/show-field-status-infos.component.ts}
(55%)
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-property-row/event-property-row.component.html
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-property-row/event-property-row.component.ts
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.cy.ts
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.html
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.scss
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-error-hints/event-schema-error-hints.component.ts
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema-preview/event-schema-preview.component.ts
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema/event-schema.component.html
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/event-schema/event-schema.component.ts
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/loading-message/loading-message.component.html
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/loading-message/loading-message.component.scss
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/schema-editor-header/schema-editor-header.component.html
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/schema-editor-header/schema-editor-header.component.scss
delete mode 100644
ui/src/app/connect/components/adapter-configuration/schema-editor/schema-editor-header/schema-editor-header.component.ts
create mode 100644
ui/src/app/connect/dialog/create-adapter-transformation-template-dialog/create-adapter-transformation-template-dialog.component.html
copy
ui/src/app/connect/{components/adapter-code-panel/adapter-code-panel.component.scss
=>
dialog/create-adapter-transformation-template-dialog/create-adapter-transformation-template-dialog.component.scss}
(81%)
create mode 100644
ui/src/app/connect/dialog/create-adapter-transformation-template-dialog/create-adapter-transformation-template-dialog.component.ts
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-regex-transformation/edit-regex-transformation.component.html
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-regex-transformation/edit-regex-transformation.component.scss
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-regex-transformation/edit-regex-transformation.component.ts
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-schema-transformation/edit-data-type/edit-data-type.component.scss
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-correction-value/edit-correction-value.component.html
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-correction-value/edit-correction-value.component.ts
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-timestamp-property/edit-timestamp-property.component.html
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-timestamp-property/edit-timestamp-property.component.scss
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-timestamp-property/edit-timestamp-property.component.ts
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-value-transformation.component.html
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-value-transformation.component.scss
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-value-transformation/edit-value-transformation.component.ts
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/ep-settings-section/ep-settings-section.component.html
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/ep-settings-section/ep-settings-section.component.scss
delete mode 100644
ui/src/app/connect/dialog/edit-event-property/components/ep-settings-section/ep-settings-section.component.ts
create mode 100644
ui/src/app/connect/dialog/select-adapter-transformation-template-dialog/select-adapter-transformation-template-dialog.component.html
copy
ui/src/app/connect/{components/adapter-code-panel/adapter-code-panel.component.scss
=>
dialog/select-adapter-transformation-template-dialog/select-adapter-transformation-template-dialog.component.scss}
(81%)
create mode 100644
ui/src/app/connect/dialog/select-adapter-transformation-template-dialog/select-adapter-transformation-template-dialog.component.ts
delete mode 100644 ui/src/app/connect/services/transformation-rule.service.ts
