This is an automated email from the ASF dual-hosted git repository. SvenO3 pushed a commit to branch 4430-chart-settings-not-correctly-migrated-after-event-schema-changes in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit cf15b535ed750ae4ef914f5031496f069c5386da Author: Sven Oehler <[email protected]> AuthorDate: Mon May 18 15:55:37 2026 +0200 Fix typescript model --- .../src/lib/model/gen/streampipes-model.ts | 141 ++++++++++++--------- .../pipeline-details/pipeline-details.component.ts | 2 +- .../measurement-update-dialog.component.ts | 6 +- ui/src/app/pipelines/model/pipeline-model.ts | 2 + 4 files changed, 85 insertions(+), 66 deletions(-) diff --git a/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts b/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts index 664bdcb10d..b2ae2c4487 100644 --- a/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts +++ b/ui/projects/streampipes/platform-services/src/lib/model/gen/streampipes-model.ts @@ -18,7 +18,7 @@ */ // @ts-nocheck -// Generated using typescript-generator version 3.2.1263 on 2026-01-15 16:03:01. +// Generated using typescript-generator version 3.2.1263 on 2026-05-18 14:42:00. export class NamedStreamPipesEntity implements Storable { '@class': @@ -112,6 +112,7 @@ export class AdapterDescription extends VersionedNamedStreamPipesEntity { 'rules': TransformationRuleDescriptionUnion[]; 'running': boolean; 'selectedEndpointUrl': string; + 'selectedServiceId': string; 'transformationConfig': TransformationConfig; static 'fromData'( @@ -143,6 +144,7 @@ export class AdapterDescription extends VersionedNamedStreamPipesEntity { )(data.rules); instance.running = data.running; instance.selectedEndpointUrl = data.selectedEndpointUrl; + instance.selectedServiceId = data.selectedServiceId; instance.transformationConfig = TransformationConfig.fromData( data.transformationConfig, ); @@ -791,6 +793,32 @@ export class ChangeDatatypeTransformationRuleDescription extends ValueTransforma } } +export class ChartSchemaUpdateInfo { + affectedFields: string[]; + canAutoMigrate: boolean; + chartId: string; + chartTitle: string; + measureName: string; + + static fromData( + data: ChartSchemaUpdateInfo, + target?: ChartSchemaUpdateInfo, + ): ChartSchemaUpdateInfo { + if (!data) { + return data; + } + const instance = target || new ChartSchemaUpdateInfo(); + instance.affectedFields = __getCopyArrayFn(__identity<string>())( + data.affectedFields, + ); + instance.canAutoMigrate = data.canAutoMigrate; + instance.chartId = data.chartId; + instance.chartTitle = data.chartTitle; + instance.measureName = data.measureName; + return instance; + } +} + export class CodeInputStaticProperty extends StaticProperty { '@class': 'org.apache.streampipes.model.staticproperty.CodeInputStaticProperty'; 'codeTemplate': string; @@ -1138,6 +1166,26 @@ export class CreateOptions { } } +export class CriticalMeasurementFieldChange { + existingType: string; + runtimeName: string; + updatedType: string; + + static fromData( + data: CriticalMeasurementFieldChange, + target?: CriticalMeasurementFieldChange, + ): CriticalMeasurementFieldChange { + if (!data) { + return data; + } + const instance = target || new CriticalMeasurementFieldChange(); + instance.existingType = data.existingType; + instance.runtimeName = data.runtimeName; + instance.updatedType = data.updatedType; + return instance; + } +} + export class CustomOutputStrategy extends OutputStrategy { '@class': 'org.apache.streampipes.model.output.CustomOutputStrategy'; 'availablePropertyKeys': string[]; @@ -1395,10 +1443,10 @@ export class InvocableStreamPipesEntity 'detachPath': string; 'inputStreams': SpDataStream[]; 'selectedEndpointUrl': string; + 'selectedServiceId': string; 'serviceTagPrefix': SpServiceTagPrefix; 'staticProperties': StaticPropertyUnion[]; 'streamRequirements': SpDataStream[]; - 'supportedGrounding': EventGrounding; 'uncompleted': boolean; static 'fromData'( @@ -1419,6 +1467,7 @@ export class InvocableStreamPipesEntity data.inputStreams, ); instance.selectedEndpointUrl = data.selectedEndpointUrl; + instance.selectedServiceId = data.selectedServiceId; instance.serviceTagPrefix = data.serviceTagPrefix; instance.staticProperties = __getCopyArrayFn( StaticProperty.fromDataUnion, @@ -1426,9 +1475,6 @@ export class InvocableStreamPipesEntity instance.streamRequirements = __getCopyArrayFn(SpDataStream.fromData)( data.streamRequirements, ); - instance.supportedGrounding = EventGrounding.fromData( - data.supportedGrounding, - ); instance.uncompleted = data.uncompleted; return instance; } @@ -1627,6 +1673,7 @@ export interface EndpointSelectable { detachPath: string; name: string; selectedEndpointUrl: string; + selectedServiceId: string; } export class ValueSpecification { @@ -2278,7 +2325,6 @@ export class GuessSchema { export class TransportProtocol { '@class': - | 'org.apache.streampipes.model.grounding.JmsTransportProtocol' | 'org.apache.streampipes.model.grounding.KafkaTransportProtocol' | 'org.apache.streampipes.model.grounding.MqttTransportProtocol' | 'org.apache.streampipes.model.grounding.NatsTransportProtocol' @@ -2311,8 +2357,6 @@ export class TransportProtocol { return data; } switch (data['@class']) { - case 'org.apache.streampipes.model.grounding.JmsTransportProtocol': - return JmsTransportProtocol.fromData(data); case 'org.apache.streampipes.model.grounding.KafkaTransportProtocol': return KafkaTransportProtocol.fromData(data); case 'org.apache.streampipes.model.grounding.MqttTransportProtocol': @@ -2325,24 +2369,6 @@ export class TransportProtocol { } } -export class JmsTransportProtocol extends TransportProtocol { - '@class': 'org.apache.streampipes.model.grounding.JmsTransportProtocol'; - 'port': number; - - static 'fromData'( - data: JmsTransportProtocol, - target?: JmsTransportProtocol, - ): JmsTransportProtocol { - if (!data) { - return data; - } - const instance = target || new JmsTransportProtocol(); - super.fromData(data, instance); - instance.port = data.port; - return instance; - } -} - export class KafkaTransportProtocol extends TransportProtocol { '@class': 'org.apache.streampipes.model.grounding.KafkaTransportProtocol'; 'acks': string; @@ -2573,6 +2599,30 @@ export class MatchingStaticProperty extends StaticProperty { } } +export class MeasurementUpdateInfo { + chartSchemaUpdateInfos: ChartSchemaUpdateInfo[]; + criticalMeasurementFieldChanges: CriticalMeasurementFieldChange[]; + measurementName: string; + + static fromData( + data: MeasurementUpdateInfo, + target?: MeasurementUpdateInfo, + ): MeasurementUpdateInfo { + if (!data) { + return data; + } + const instance = target || new MeasurementUpdateInfo(); + instance.chartSchemaUpdateInfos = __getCopyArrayFn( + ChartSchemaUpdateInfo.fromData, + )(data.chartSchemaUpdateInfos); + instance.criticalMeasurementFieldChanges = __getCopyArrayFn( + CriticalMeasurementFieldChange.fromData, + )(data.criticalMeasurementFieldChanges); + instance.measurementName = data.measurementName; + return instance; + } +} + export class MessageCounter { counter: number; lastTimestamp: number; @@ -2685,6 +2735,7 @@ export class MqttTransportProtocol extends TransportProtocol { export class NatsTransportProtocol extends TransportProtocol { '@class': 'org.apache.streampipes.model.grounding.NatsTransportProtocol'; 'port': number; + 'token': string; static 'fromData'( data: NatsTransportProtocol, @@ -2696,6 +2747,7 @@ export class NatsTransportProtocol extends TransportProtocol { const instance = target || new NatsTransportProtocol(); super.fromData(data, instance); instance.port = data.port; + instance.token = data.token; return instance; } } @@ -3320,32 +3372,6 @@ export class PipelineUpdateInfo { } } -export class ChartSchemaUpdateInfo { - affectedFields: string[]; - canAutoMigrate: boolean; - chartId: string; - chartTitle: string; - measureName: string; - - static fromData( - data: ChartSchemaUpdateInfo, - target?: ChartSchemaUpdateInfo, - ): ChartSchemaUpdateInfo { - if (!data) { - return data; - } - const instance = target || new ChartSchemaUpdateInfo(); - instance.affectedFields = __getCopyArrayFn(__identity<string>())( - data.affectedFields, - ); - instance.canAutoMigrate = data.canAutoMigrate; - instance.chartId = data.chartId; - instance.chartTitle = data.chartTitle; - instance.measureName = data.measureName; - return instance; - } -} - export class ProducedMessagesInfo extends MessagesInfo { totalProducedMessages: number; totalProducedMessagesSincePipelineStart: number; @@ -4166,7 +4192,6 @@ export class SpServiceRegistration implements Storable { providedExtensions: ExtensionItemDescription[]; rev: string; scheme: string; - serviceUrl: string; status: SpServiceStatus; supportedScriptLanguages: ScriptMetadata[]; svcGroup: string; @@ -4194,7 +4219,6 @@ export class SpServiceRegistration implements Storable { )(data.providedExtensions); instance.rev = data.rev; instance.scheme = data.scheme; - instance.serviceUrl = data.serviceUrl; instance.status = data.status; instance.supportedScriptLanguages = __getCopyArrayFn( ScriptMetadata.fromData, @@ -4629,6 +4653,8 @@ export type ConfigurationScope = | 'CONTAINER_GLOBAL_CONFIG' | 'PIPELINE_ELEMENT_CONFIG'; +export type DataExplorerWidgetHealthStatus = 'OK' | 'REQUIRES_ATTENTION'; + export type DataLakeMeasureSchemaUpdateStrategy = | 'UPDATE_SCHEMA' | 'EXTEND_EXISTING_SCHEMA'; @@ -4674,10 +4700,6 @@ export type PipelineHealthStatus = | 'HANDLE_MEASUREMENT_UPDATE' | 'FAILURE'; -export type MeasurementUpdateAction = 'edit-pipeline' | 'manage-datasets'; - -export type DataExplorerWidgetHealthStatus = 'OK' | 'REQUIRES_ATTENTION'; - export type PropertyScope = | 'HEADER_PROPERTY' | 'DIMENSION_PROPERTY' @@ -4696,8 +4718,6 @@ export type SelectionStaticPropertyUnion = export type SpLogLevel = 'INFO' | 'WARN' | 'ERROR'; -export type SpProtocol = 'KAFKA' | 'JMS' | 'MQTT' | 'NATS' | 'PULSAR'; - export type SpQueryStatus = 'OK' | 'TOO_MUCH_DATA'; export type SpServiceStatus = @@ -4780,7 +4800,6 @@ export type TransformationRuleDescriptionUnion = | CorrectionValueTransformationRuleDescription; export type TransportProtocolUnion = - | JmsTransportProtocol | KafkaTransportProtocol | MqttTransportProtocol | NatsTransportProtocol diff --git a/ui/src/app/pipeline-details/pipeline-details.component.ts b/ui/src/app/pipeline-details/pipeline-details.component.ts index eb63b3e913..229da11aeb 100644 --- a/ui/src/app/pipeline-details/pipeline-details.component.ts +++ b/ui/src/app/pipeline-details/pipeline-details.component.ts @@ -20,7 +20,6 @@ import { Component, OnDestroy, OnInit, ViewChild, inject } from '@angular/core'; import { ActivatedRoute, Router } from '@angular/router'; import { AuthService } from '../services/auth.service'; import { - MeasurementUpdateAction, Pipeline, PipelineCanvasMetadata, PipelineCanvasMetadataService, @@ -57,6 +56,7 @@ import { PipelineDetailsExpansionPanelComponent } from './components/pipeline-de import { TranslatePipe } from '@ngx-translate/core'; import { PipelineOperationsService } from '../pipelines/services/pipeline-operations.service'; import { MeasurementUpdateDialogComponent } from '../pipelines/dialog/measurement-update/measurement-update-dialog.component'; +import { MeasurementUpdateAction } from '../pipelines/model/pipeline-model'; @Component({ selector: 'sp-pipeline-details-overview-component', diff --git a/ui/src/app/pipelines/dialog/measurement-update/measurement-update-dialog.component.ts b/ui/src/app/pipelines/dialog/measurement-update/measurement-update-dialog.component.ts index 8201e57699..03abcd064b 100644 --- a/ui/src/app/pipelines/dialog/measurement-update/measurement-update-dialog.component.ts +++ b/ui/src/app/pipelines/dialog/measurement-update/measurement-update-dialog.component.ts @@ -17,10 +17,7 @@ */ import { Component, Input, inject } from '@angular/core'; -import { - MeasurementUpdateAction, - Pipeline, -} from '@streampipes/platform-services'; +import { Pipeline } from '@streampipes/platform-services'; import { DialogRef, SpAlertBannerComponent } from '@streampipes/shared-ui'; import { MatButton } from '@angular/material/button'; import { MatDivider } from '@angular/material/divider'; @@ -31,6 +28,7 @@ import { LayoutDirective, LayoutGapDirective, } from '@ngbracket/ngx-layout/flex'; +import { MeasurementUpdateAction } from '../../model/pipeline-model'; @Component({ selector: 'sp-measurement-update-dialog', diff --git a/ui/src/app/pipelines/model/pipeline-model.ts b/ui/src/app/pipelines/model/pipeline-model.ts index d77aa95b33..9100cfc7af 100644 --- a/ui/src/app/pipelines/model/pipeline-model.ts +++ b/ui/src/app/pipelines/model/pipeline-model.ts @@ -20,3 +20,5 @@ export enum PipelineAction { Start, Stop, } + +export type MeasurementUpdateAction = 'edit-pipeline' | 'manage-datasets';
