This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch add-dataset-permissions
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from c0c055f251 renaming
add b939d0251d fix: Fix test count array 1 (#4084)
add cfc9f8a62e chore(deps): bump urllib3 from 2.6.0 to 2.6.3 in
/streampipes-client-python (#4086)
add b28845455d fix: Imports from shared-ui (#4089)
add 50dc17b48e fix(#4093): Fix migration request deserialization problem
(#4094)
add 73241c3da7 feat(#4032): Introducing function transformation for
complex data handling in connect (#4033)
add 63dd142d4a refactor: Improve health checks (#4096)
new 592fb5de15 Merge branch 'dev' into add-dataset-permissions
new 5f797650d9 Update models
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
...tensions_iiot.xml => AllExtensionsIIoTInit.xml} | 3 +-
.idea/runConfigurations/sp_core.xml | 2 +-
pom.xml | 18 +-
.../go-client-e2e/adapter/machine.json | 576 +++++++++-------
streampipes-client-python/poetry.lock | 6 +-
.../apache/streampipes/commons/constants/Envs.java | 30 +-
.../commons/constants/GenericDocTypes.java | 3 +-
.../commons/environment/DefaultEnvironment.java | 24 +-
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/health/AdapterHealthCheck.java | 245 -------
.../management/CompactAdapterManagement.java | 3 +-
.../management/management/GuessManagement.java | 111 ++-
.../management/WorkerAdministrationManagement.java | 70 +-
.../connect/management/util/EventSchemaUtils.java | 37 +-
.../connect/management/util/WorkerPaths.java | 7 +
.../management/health/AdapterHealthCheckTest.java | 96 ---
.../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 ++
.../influx/DataExplorerInfluxQueryExecutor.java | 2 +-
.../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/init/RunningInstances.java | 10 +
.../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 +-
.../pom.xml | 26 +-
.../health/monitoring/AdapterHealthCheck.java | 168 +++++
.../health/monitoring/ExtensionHealthCheck.java | 57 ++
.../ExtensionInstanceAvailabilityCheck.java | 67 ++
.../health/monitoring/PipelineHealthCheck.java | 210 ++++++
.../health/monitoring/PostStartupRecovery.java | 62 ++
.../health/monitoring/ResourceProvider.java | 104 +++
.../health/monitoring}/ServiceHealthCheck.java | 22 +-
.../monitoring}/ServiceRegistrationManager.java | 6 +-
.../monitoring/model/ActiveCoreInstances.java | 10 +-
.../health/monitoring/model/ActiveResources.java | 12 +-
.../health/monitoring/model/HealthCheckData.java | 18 +-
.../health/monitoring/utils/HealthCheckUtils.java | 53 ++
.../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 +
.../extensions/migration/MigrationRequest.java | 5 +-
.../svcdiscovery/SpServiceRegistration.java | 23 +-
.../model/health/ExtensionInstanceHealth.java | 11 +-
.../streampipes/model/util/PropertyUtils.java | 4 -
.../connect/adapter/AdapterDescriptionTest.java | 66 --
.../execution/ExtensionServiceExecutions.java | 1 -
.../manager/execution/PipelineExecutionInfo.java | 4 +-
.../execution/PipelineExecutionTaskFactory.java | 6 +-
.../ExtensionsServiceEndpointGenerator.java | 22 +-
.../endpoint/ExtensionsServiceEndpointUtils.java | 11 +
...tter.java => BasePipelineElementSubmitter.java} | 23 +-
.../http/DetachPipelineElementSubmitter.java | 5 +-
.../http/InvokePipelineElementSubmitter.java | 9 +-
.../provider/CurrentPipelineElementProvider.java | 36 -
.../provider/StoredPipelineElementProvider.java | 42 --
.../execution/task/AfterInvocationTask.java | 13 +-
.../execution/task/DiscoverEndpointsTask.java | 37 +-
.../manager/execution/task/SubmitRequestTask.java | 16 +-
.../health/PipelineElementEndpointHealthCheck.java | 51 --
.../manager/health/PipelineHealthCheck.java | 261 -------
.../manager/setup/CouchDbInstallationStep.java | 14 +-
...java => AbstractAddGenericStorageViewTask.java} | 21 +-
.../setup/tasks/AddScriptTemplateViewTask.java | 27 +-
.../setup/tasks/CreateAssetLinkTypeTask.java | 6 +-
.../manager/storage/PipelineStorageService.java | 4 -
.../PipelineElementUtils.java} | 17 +-
...e.java => AdapterWorkerSampleDataResource.java} | 51 +-
.../extensions/monitoring/HealthCheckResource.java | 67 ++
...ionHandler.java => SpRestExceptionHandler.java} | 14 +-
streampipes-rest/pom.xml | 5 +
.../streampipes/rest/impl/ResetResource.java | 6 +
.../rest/impl/admin/MigrationResource.java | 2 +-
.../impl/admin/ServiceRegistrationResource.java | 2 +-
.../rest/impl/connect/AbstractAdapterResource.java | 4 +
.../rest/impl/connect/GuessResource.java | 82 ++-
.../impl/connect/RuntimeResolvableResource.java | 14 +-
.../TransformationScriptLanguageResource.java | 87 +++
.../TransformationScriptTemplateResource.java | 84 +++
.../sdk/builder/adapter/SampleDataBuilder.java | 87 +++
.../minimal/StreamPipesCoreApplicationMinimal.java | 8 +-
streampipes-service-core/pom.xml | 15 +
.../streampipes/service/core/PostStartupTask.java | 61 +-
.../service/core/StreamPipesCoreApplication.java | 47 +-
.../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 +-
.../transformation-jvm/countArray1/expected.csv | 8 +-
.../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 +-
.../DatasetBtns.ts => shared/SharedUtils.ts} | 8 +-
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 | 5 +-
.../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 +-
.../streampipes/shared-ui/src/public-api.ts | 1 +
.../asset-overview/asset-overview.component.ts | 4 +-
.../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 ---------------------
.../datalake-configuration.component.ts | 4 +-
.../asset-map/home-asset-map.component.ts | 4 +-
ui/src/app/home/home.component.ts | 19 +-
ui/src/scss/main.scss | 1 -
ui/src/scss/sp/_variables.scss | 1 +
400 files changed, 9000 insertions(+), 11138 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
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/health/AdapterHealthCheck.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/health/AdapterHealthCheckTest.java
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-connect-shared => streampipes-health-monitoring}/pom.xml
(74%)
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/AdapterHealthCheck.java
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionHealthCheck.java
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ExtensionInstanceAvailabilityCheck.java
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/PipelineHealthCheck.java
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/PostStartupRecovery.java
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/ResourceProvider.java
rename
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health
=>
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring}/ServiceHealthCheck.java
(83%)
rename
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health
=>
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring}/ServiceRegistrationManager.java
(95%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/RunningPipelineElementStorage.java
=>
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/model/ActiveCoreInstances.java
(75%)
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IAdapterStorage.java
=>
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/model/ActiveResources.java
(70%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/IFunctionConfig.java
=>
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/model/HealthCheckData.java
(62%)
create mode 100644
streampipes-health-monitoring/src/main/java/org/apache/streampipes/health/monitoring/utils/HealthCheckUtils.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%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/credentials/CredentialsProvider.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/health/ExtensionInstanceHealth.java
(77%)
delete mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/connect/adapter/AdapterDescriptionTest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{PipelineElementSubmitter.java
=> BasePipelineElementSubmitter.java} (71%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/provider/CurrentPipelineElementProvider.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/provider/StoredPipelineElementProvider.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineElementEndpointHealthCheck.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.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-pipeline-management/src/main/java/org/apache/streampipes/manager/{execution/provider/PipelineElementProvider.java
=> util/PipelineElementUtils.java} (66%)
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/connect/{GuessResource.java
=> AdapterWorkerSampleDataResource.java} (53%)
create mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/HealthCheckResource.java
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/cypress/support/utils/{dataset/DatasetBtns.ts =>
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
