| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * https://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| package model |
| |
| import ( |
| "context" |
| stdErrors "errors" |
| "fmt" |
| |
| "github.com/rs/zerolog" |
| |
| . "github.com/apache/plc4x/plc4go/spi/codegen/fields" |
| . "github.com/apache/plc4x/plc4go/spi/codegen/io" |
| "github.com/apache/plc4x/plc4go/spi/errors" |
| "github.com/apache/plc4x/plc4go/spi/utils" |
| ) |
| |
| // Code generated by code-generation. DO NOT EDIT. |
| |
| // Constant values. |
| const AmsPacket_INITCOMMAND bool = bool(false) |
| const AmsPacket_UPDCOMMAND bool = bool(false) |
| const AmsPacket_TIMESTAMPADDED bool = bool(false) |
| const AmsPacket_HIGHPRIORITYCOMMAND bool = bool(false) |
| const AmsPacket_SYSTEMCOMMAND bool = bool(false) |
| const AmsPacket_ADSCOMMAND bool = bool(true) |
| const AmsPacket_NORETURN bool = bool(false) |
| const AmsPacket_BROADCAST bool = bool(false) |
| |
| // AmsPacket is the corresponding interface of AmsPacket |
| type AmsPacket interface { |
| AmsPacketContract |
| AmsPacketRequirements |
| fmt.Stringer |
| utils.LengthAware |
| utils.Serializable |
| utils.Copyable |
| // IsAmsPacket is a marker method to prevent unintentional type checks (interfaces of same signature) |
| IsAmsPacket() |
| // CreateBuilder creates a AmsPacketBuilder |
| CreateAmsPacketBuilder() AmsPacketBuilder |
| } |
| |
| // AmsPacketContract provides a set of functions which can be overwritten by a sub struct |
| type AmsPacketContract interface { |
| // GetTargetAmsNetId returns TargetAmsNetId (property field) |
| // AMS Header 32 bytes The AMS/TCP-Header contains the addresses of the transmitter and receiver. In addition the AMS error code , the ADS command Id and some other information. |
| // This is the AmsNetId of the station, for which the packet is intended. Remarks see below. |
| GetTargetAmsNetId() AmsNetId |
| // GetTargetAmsPort returns TargetAmsPort (property field) |
| // This is the AmsPort of the station, for which the packet is intended. |
| GetTargetAmsPort() uint16 |
| // GetSourceAmsNetId returns SourceAmsNetId (property field) |
| // This contains the AmsNetId of the station, from which the packet was sent. |
| GetSourceAmsNetId() AmsNetId |
| // GetSourceAmsPort returns SourceAmsPort (property field) |
| // This contains the AmsPort of the station, from which the packet was sent. |
| GetSourceAmsPort() uint16 |
| // GetErrorCode returns ErrorCode (property field) |
| // 4 bytes AMS error number. See ADS Return Codes. |
| GetErrorCode() ReturnCode |
| // GetInvokeId returns InvokeId (property field) |
| // free usable field of 4 bytes |
| // 4 bytes Free usable 32 bit array. Usually this array serves to send an Id. This Id makes is possible to assign a received response to a request, which was sent before. |
| GetInvokeId() uint32 |
| // IsAmsPacket is a marker method to prevent unintentional type checks (interfaces of same signature) |
| IsAmsPacket() |
| // CreateBuilder creates a AmsPacketBuilder |
| CreateAmsPacketBuilder() AmsPacketBuilder |
| } |
| |
| // AmsPacketRequirements provides a set of functions which need to be implemented by a sub struct |
| type AmsPacketRequirements interface { |
| GetLengthInBits(ctx context.Context) uint16 |
| GetLengthInBytes(ctx context.Context) uint16 |
| // GetCommandId returns CommandId (discriminator field) |
| GetCommandId() CommandId |
| // GetErrorCode returns ErrorCode (discriminator field) |
| GetErrorCode() ReturnCode |
| // GetResponse returns Response (discriminator field) |
| GetResponse() bool |
| } |
| |
| // _AmsPacket is the data-structure of this message |
| type _AmsPacket struct { |
| _SubType interface { |
| AmsPacketContract |
| AmsPacketRequirements |
| } |
| TargetAmsNetId AmsNetId |
| TargetAmsPort uint16 |
| SourceAmsNetId AmsNetId |
| SourceAmsPort uint16 |
| ErrorCode ReturnCode |
| InvokeId uint32 |
| // Reserved Fields |
| reservedField0 *int8 |
| } |
| |
| var _ AmsPacketContract = (*_AmsPacket)(nil) |
| |
| // NewAmsPacket factory function for _AmsPacket |
| func NewAmsPacket(targetAmsNetId AmsNetId, targetAmsPort uint16, sourceAmsNetId AmsNetId, sourceAmsPort uint16, errorCode ReturnCode, invokeId uint32) *_AmsPacket { |
| if targetAmsNetId == nil { |
| panic("targetAmsNetId of type AmsNetId for AmsPacket must not be nil") |
| } |
| if sourceAmsNetId == nil { |
| panic("sourceAmsNetId of type AmsNetId for AmsPacket must not be nil") |
| } |
| return &_AmsPacket{TargetAmsNetId: targetAmsNetId, TargetAmsPort: targetAmsPort, SourceAmsNetId: sourceAmsNetId, SourceAmsPort: sourceAmsPort, ErrorCode: errorCode, InvokeId: invokeId} |
| } |
| |
| /////////////////////////////////////////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////// Builder |
| /////////////////////// |
| |
| // AmsPacketBuilder is a builder for AmsPacket |
| type AmsPacketBuilder interface { |
| utils.Copyable |
| // WithMandatoryFields adds all mandatory fields (convenience for using multiple builder calls) |
| WithMandatoryFields(targetAmsNetId AmsNetId, targetAmsPort uint16, sourceAmsNetId AmsNetId, sourceAmsPort uint16, errorCode ReturnCode, invokeId uint32) AmsPacketBuilder |
| // WithTargetAmsNetId adds TargetAmsNetId (property field) |
| WithTargetAmsNetId(AmsNetId) AmsPacketBuilder |
| // WithTargetAmsNetIdBuilder adds TargetAmsNetId (property field) which is build by the builder |
| WithTargetAmsNetIdBuilder(func(AmsNetIdBuilder) AmsNetIdBuilder) AmsPacketBuilder |
| // WithTargetAmsPort adds TargetAmsPort (property field) |
| WithTargetAmsPort(uint16) AmsPacketBuilder |
| // WithSourceAmsNetId adds SourceAmsNetId (property field) |
| WithSourceAmsNetId(AmsNetId) AmsPacketBuilder |
| // WithSourceAmsNetIdBuilder adds SourceAmsNetId (property field) which is build by the builder |
| WithSourceAmsNetIdBuilder(func(AmsNetIdBuilder) AmsNetIdBuilder) AmsPacketBuilder |
| // WithSourceAmsPort adds SourceAmsPort (property field) |
| WithSourceAmsPort(uint16) AmsPacketBuilder |
| // WithErrorCode adds ErrorCode (property field) |
| WithErrorCode(ReturnCode) AmsPacketBuilder |
| // WithInvokeId adds InvokeId (property field) |
| WithInvokeId(uint32) AmsPacketBuilder |
| // AsAdsInvalidRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsInvalidRequest() AdsInvalidRequestBuilder |
| // AsAdsInvalidResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsInvalidResponse() AdsInvalidResponseBuilder |
| // AsAdsReadDeviceInfoRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadDeviceInfoRequest() AdsReadDeviceInfoRequestBuilder |
| // AsAdsReadDeviceInfoResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadDeviceInfoResponse() AdsReadDeviceInfoResponseBuilder |
| // AsAdsReadRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadRequest() AdsReadRequestBuilder |
| // AsAdsReadResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadResponse() AdsReadResponseBuilder |
| // AsAdsWriteRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsWriteRequest() AdsWriteRequestBuilder |
| // AsAdsWriteResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsWriteResponse() AdsWriteResponseBuilder |
| // AsAdsReadStateRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadStateRequest() AdsReadStateRequestBuilder |
| // AsAdsReadStateResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadStateResponse() AdsReadStateResponseBuilder |
| // AsAdsWriteControlRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsWriteControlRequest() AdsWriteControlRequestBuilder |
| // AsAdsWriteControlResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsWriteControlResponse() AdsWriteControlResponseBuilder |
| // AsAdsAddDeviceNotificationRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsAddDeviceNotificationRequest() AdsAddDeviceNotificationRequestBuilder |
| // AsAdsAddDeviceNotificationResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsAddDeviceNotificationResponse() AdsAddDeviceNotificationResponseBuilder |
| // AsAdsDeleteDeviceNotificationRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsDeleteDeviceNotificationRequest() AdsDeleteDeviceNotificationRequestBuilder |
| // AsAdsDeleteDeviceNotificationResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsDeleteDeviceNotificationResponse() AdsDeleteDeviceNotificationResponseBuilder |
| // AsAdsDeviceNotificationRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsDeviceNotificationRequest() AdsDeviceNotificationRequestBuilder |
| // AsAdsDeviceNotificationResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsDeviceNotificationResponse() AdsDeviceNotificationResponseBuilder |
| // AsAdsReadWriteRequest converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadWriteRequest() AdsReadWriteRequestBuilder |
| // AsAdsReadWriteResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsReadWriteResponse() AdsReadWriteResponseBuilder |
| // AsAdsErrorResponse converts this build to a subType of AmsPacket. It is always possible to return to current builder using Done() |
| AsAdsErrorResponse() AdsErrorResponseBuilder |
| // Build builds the AmsPacket or returns an error if something is wrong |
| PartialBuild() (AmsPacketContract, error) |
| // MustBuild does the same as Build but panics on error |
| PartialMustBuild() AmsPacketContract |
| // Build builds the AmsPacket or returns an error if something is wrong |
| Build() (AmsPacket, error) |
| // MustBuild does the same as Build but panics on error |
| MustBuild() AmsPacket |
| } |
| |
| // NewAmsPacketBuilder() creates a AmsPacketBuilder |
| func NewAmsPacketBuilder() AmsPacketBuilder { |
| return &_AmsPacketBuilder{_AmsPacket: new(_AmsPacket)} |
| } |
| |
| type _AmsPacketChildBuilder interface { |
| utils.Copyable |
| setParent(AmsPacketContract) |
| buildForAmsPacket() (AmsPacket, error) |
| } |
| |
| type _AmsPacketBuilder struct { |
| *_AmsPacket |
| |
| childBuilder _AmsPacketChildBuilder |
| |
| collectedErr []error |
| } |
| |
| var _ (AmsPacketBuilder) = (*_AmsPacketBuilder)(nil) |
| |
| func (b *_AmsPacketBuilder) WithMandatoryFields(targetAmsNetId AmsNetId, targetAmsPort uint16, sourceAmsNetId AmsNetId, sourceAmsPort uint16, errorCode ReturnCode, invokeId uint32) AmsPacketBuilder { |
| return b.WithTargetAmsNetId(targetAmsNetId).WithTargetAmsPort(targetAmsPort).WithSourceAmsNetId(sourceAmsNetId).WithSourceAmsPort(sourceAmsPort).WithErrorCode(errorCode).WithInvokeId(invokeId) |
| } |
| |
| func (b *_AmsPacketBuilder) WithTargetAmsNetId(targetAmsNetId AmsNetId) AmsPacketBuilder { |
| b.TargetAmsNetId = targetAmsNetId |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) WithTargetAmsNetIdBuilder(builderSupplier func(AmsNetIdBuilder) AmsNetIdBuilder) AmsPacketBuilder { |
| builder := builderSupplier(b.TargetAmsNetId.CreateAmsNetIdBuilder()) |
| var err error |
| b.TargetAmsNetId, err = builder.Build() |
| if err != nil { |
| b.collectedErr = append(b.collectedErr, errors.Wrap(err, "AmsNetIdBuilder failed")) |
| } |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) WithTargetAmsPort(targetAmsPort uint16) AmsPacketBuilder { |
| b.TargetAmsPort = targetAmsPort |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) WithSourceAmsNetId(sourceAmsNetId AmsNetId) AmsPacketBuilder { |
| b.SourceAmsNetId = sourceAmsNetId |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) WithSourceAmsNetIdBuilder(builderSupplier func(AmsNetIdBuilder) AmsNetIdBuilder) AmsPacketBuilder { |
| builder := builderSupplier(b.SourceAmsNetId.CreateAmsNetIdBuilder()) |
| var err error |
| b.SourceAmsNetId, err = builder.Build() |
| if err != nil { |
| b.collectedErr = append(b.collectedErr, errors.Wrap(err, "AmsNetIdBuilder failed")) |
| } |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) WithSourceAmsPort(sourceAmsPort uint16) AmsPacketBuilder { |
| b.SourceAmsPort = sourceAmsPort |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) WithErrorCode(errorCode ReturnCode) AmsPacketBuilder { |
| b.ErrorCode = errorCode |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) WithInvokeId(invokeId uint32) AmsPacketBuilder { |
| b.InvokeId = invokeId |
| return b |
| } |
| |
| func (b *_AmsPacketBuilder) PartialBuild() (AmsPacketContract, error) { |
| if b.TargetAmsNetId == nil { |
| b.collectedErr = append(b.collectedErr, errors.New("mandatory field 'targetAmsNetId' not set")) |
| } |
| if b.SourceAmsNetId == nil { |
| b.collectedErr = append(b.collectedErr, errors.New("mandatory field 'sourceAmsNetId' not set")) |
| } |
| if err := stdErrors.Join(b.collectedErr...); err != nil { |
| return nil, errors.Wrap(err, "error occurred during build") |
| } |
| return b._AmsPacket.deepCopy(), nil |
| } |
| |
| func (b *_AmsPacketBuilder) PartialMustBuild() AmsPacketContract { |
| build, err := b.PartialBuild() |
| if err != nil { |
| panic(err) |
| } |
| return build |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsInvalidRequest() AdsInvalidRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsInvalidRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsInvalidRequestBuilder().(*_AdsInvalidRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsInvalidResponse() AdsInvalidResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsInvalidResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsInvalidResponseBuilder().(*_AdsInvalidResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadDeviceInfoRequest() AdsReadDeviceInfoRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsReadDeviceInfoRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadDeviceInfoRequestBuilder().(*_AdsReadDeviceInfoRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadDeviceInfoResponse() AdsReadDeviceInfoResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsReadDeviceInfoResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadDeviceInfoResponseBuilder().(*_AdsReadDeviceInfoResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadRequest() AdsReadRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsReadRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadRequestBuilder().(*_AdsReadRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadResponse() AdsReadResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsReadResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadResponseBuilder().(*_AdsReadResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsWriteRequest() AdsWriteRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsWriteRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsWriteRequestBuilder().(*_AdsWriteRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsWriteResponse() AdsWriteResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsWriteResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsWriteResponseBuilder().(*_AdsWriteResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadStateRequest() AdsReadStateRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsReadStateRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadStateRequestBuilder().(*_AdsReadStateRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadStateResponse() AdsReadStateResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsReadStateResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadStateResponseBuilder().(*_AdsReadStateResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsWriteControlRequest() AdsWriteControlRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsWriteControlRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsWriteControlRequestBuilder().(*_AdsWriteControlRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsWriteControlResponse() AdsWriteControlResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsWriteControlResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsWriteControlResponseBuilder().(*_AdsWriteControlResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsAddDeviceNotificationRequest() AdsAddDeviceNotificationRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsAddDeviceNotificationRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsAddDeviceNotificationRequestBuilder().(*_AdsAddDeviceNotificationRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsAddDeviceNotificationResponse() AdsAddDeviceNotificationResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsAddDeviceNotificationResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsAddDeviceNotificationResponseBuilder().(*_AdsAddDeviceNotificationResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsDeleteDeviceNotificationRequest() AdsDeleteDeviceNotificationRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsDeleteDeviceNotificationRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsDeleteDeviceNotificationRequestBuilder().(*_AdsDeleteDeviceNotificationRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsDeleteDeviceNotificationResponse() AdsDeleteDeviceNotificationResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsDeleteDeviceNotificationResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsDeleteDeviceNotificationResponseBuilder().(*_AdsDeleteDeviceNotificationResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsDeviceNotificationRequest() AdsDeviceNotificationRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsDeviceNotificationRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsDeviceNotificationRequestBuilder().(*_AdsDeviceNotificationRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsDeviceNotificationResponse() AdsDeviceNotificationResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsDeviceNotificationResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsDeviceNotificationResponseBuilder().(*_AdsDeviceNotificationResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadWriteRequest() AdsReadWriteRequestBuilder { |
| if cb, ok := b.childBuilder.(AdsReadWriteRequestBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadWriteRequestBuilder().(*_AdsReadWriteRequestBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsReadWriteResponse() AdsReadWriteResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsReadWriteResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsReadWriteResponseBuilder().(*_AdsReadWriteResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) AsAdsErrorResponse() AdsErrorResponseBuilder { |
| if cb, ok := b.childBuilder.(AdsErrorResponseBuilder); ok { |
| return cb |
| } |
| cb := NewAdsErrorResponseBuilder().(*_AdsErrorResponseBuilder) |
| cb.parentBuilder = b |
| b.childBuilder = cb |
| return cb |
| } |
| |
| func (b *_AmsPacketBuilder) Build() (AmsPacket, error) { |
| v, err := b.PartialBuild() |
| if err != nil { |
| return nil, errors.Wrap(err, "error occurred during partial build") |
| } |
| if b.childBuilder == nil { |
| return nil, errors.New("no child builder present") |
| } |
| b.childBuilder.setParent(v) |
| return b.childBuilder.buildForAmsPacket() |
| } |
| |
| func (b *_AmsPacketBuilder) MustBuild() AmsPacket { |
| build, err := b.Build() |
| if err != nil { |
| panic(err) |
| } |
| return build |
| } |
| |
| func (b *_AmsPacketBuilder) DeepCopy() any { |
| _copy := b.CreateAmsPacketBuilder().(*_AmsPacketBuilder) |
| _copy.childBuilder = b.childBuilder.DeepCopy().(_AmsPacketChildBuilder) |
| _copy.childBuilder.setParent(_copy) |
| if b.collectedErr != nil { |
| copy(_copy.collectedErr, b.collectedErr) |
| } |
| return _copy |
| } |
| |
| // CreateAmsPacketBuilder creates a AmsPacketBuilder |
| func (b *_AmsPacket) CreateAmsPacketBuilder() AmsPacketBuilder { |
| if b == nil { |
| return NewAmsPacketBuilder() |
| } |
| return &_AmsPacketBuilder{_AmsPacket: b.deepCopy()} |
| } |
| |
| /////////////////////// |
| /////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////////////////////////////////////////// |
| |
| /////////////////////////////////////////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////// Accessors for property fields. |
| /////////////////////// |
| |
| func (m *_AmsPacket) GetTargetAmsNetId() AmsNetId { |
| return m.TargetAmsNetId |
| } |
| |
| func (m *_AmsPacket) GetTargetAmsPort() uint16 { |
| return m.TargetAmsPort |
| } |
| |
| func (m *_AmsPacket) GetSourceAmsNetId() AmsNetId { |
| return m.SourceAmsNetId |
| } |
| |
| func (m *_AmsPacket) GetSourceAmsPort() uint16 { |
| return m.SourceAmsPort |
| } |
| |
| func (m *_AmsPacket) GetErrorCode() ReturnCode { |
| return m.ErrorCode |
| } |
| |
| func (m *_AmsPacket) GetInvokeId() uint32 { |
| return m.InvokeId |
| } |
| |
| /////////////////////// |
| /////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////// Accessors for const fields. |
| /////////////////////// |
| |
| func (m *_AmsPacket) GetInitCommand() bool { |
| return AmsPacket_INITCOMMAND |
| } |
| |
| func (m *_AmsPacket) GetUpdCommand() bool { |
| return AmsPacket_UPDCOMMAND |
| } |
| |
| func (m *_AmsPacket) GetTimestampAdded() bool { |
| return AmsPacket_TIMESTAMPADDED |
| } |
| |
| func (m *_AmsPacket) GetHighPriorityCommand() bool { |
| return AmsPacket_HIGHPRIORITYCOMMAND |
| } |
| |
| func (m *_AmsPacket) GetSystemCommand() bool { |
| return AmsPacket_SYSTEMCOMMAND |
| } |
| |
| func (m *_AmsPacket) GetAdsCommand() bool { |
| return AmsPacket_ADSCOMMAND |
| } |
| |
| func (m *_AmsPacket) GetNoReturn() bool { |
| return AmsPacket_NORETURN |
| } |
| |
| func (m *_AmsPacket) GetBroadcast() bool { |
| return AmsPacket_BROADCAST |
| } |
| |
| /////////////////////// |
| /////////////////////// |
| /////////////////////////////////////////////////////////// |
| /////////////////////////////////////////////////////////// |
| |
| // Deprecated: use the interface for direct cast |
| func CastAmsPacket(structType any) AmsPacket { |
| if casted, ok := structType.(AmsPacket); ok { |
| return casted |
| } |
| if casted, ok := structType.(*AmsPacket); ok { |
| return *casted |
| } |
| return nil |
| } |
| |
| func (m *_AmsPacket) GetPlx4xTypeName() string { |
| return "AmsPacket" |
| } |
| |
| func (m *_AmsPacket) getLengthInBits(ctx context.Context) uint16 { |
| lengthInBits := uint16(0) |
| |
| // Simple field (targetAmsNetId) |
| lengthInBits += m.TargetAmsNetId.GetLengthInBits(ctx) |
| |
| // Simple field (targetAmsPort) |
| lengthInBits += 16 |
| |
| // Simple field (sourceAmsNetId) |
| lengthInBits += m.SourceAmsNetId.GetLengthInBits(ctx) |
| |
| // Simple field (sourceAmsPort) |
| lengthInBits += 16 |
| // Discriminator Field (commandId) |
| lengthInBits += 16 |
| |
| // Const Field (initCommand) |
| lengthInBits += 1 |
| |
| // Const Field (updCommand) |
| lengthInBits += 1 |
| |
| // Const Field (timestampAdded) |
| lengthInBits += 1 |
| |
| // Const Field (highPriorityCommand) |
| lengthInBits += 1 |
| |
| // Const Field (systemCommand) |
| lengthInBits += 1 |
| |
| // Const Field (adsCommand) |
| lengthInBits += 1 |
| |
| // Const Field (noReturn) |
| lengthInBits += 1 |
| // Discriminator Field (response) |
| lengthInBits += 1 |
| |
| // Const Field (broadcast) |
| lengthInBits += 1 |
| |
| // Reserved Field (reserved) |
| lengthInBits += 7 |
| |
| // Implicit Field (length) |
| lengthInBits += 32 |
| |
| // Simple field (errorCode) |
| lengthInBits += 32 |
| |
| // Simple field (invokeId) |
| lengthInBits += 32 |
| |
| return lengthInBits |
| } |
| |
| func (m *_AmsPacket) GetLengthInBits(ctx context.Context) uint16 { |
| return m._SubType.GetLengthInBits(ctx) |
| } |
| |
| func (m *_AmsPacket) GetLengthInBytes(ctx context.Context) uint16 { |
| return m._SubType.GetLengthInBits(ctx) / 8 |
| } |
| |
| func AmsPacketParse[T AmsPacket](ctx context.Context, theBytes []byte) (T, error) { |
| return AmsPacketParseWithBuffer[T](ctx, utils.NewReadBufferByteBased(theBytes)) |
| } |
| |
| func AmsPacketParseWithBufferProducer[T AmsPacket]() func(ctx context.Context, readBuffer utils.ReadBuffer) (T, error) { |
| return func(ctx context.Context, readBuffer utils.ReadBuffer) (T, error) { |
| v, err := AmsPacketParseWithBuffer[T](ctx, readBuffer) |
| if err != nil { |
| var zero T |
| return zero, err |
| } |
| return v, nil |
| } |
| } |
| |
| func AmsPacketParseWithBuffer[T AmsPacket](ctx context.Context, readBuffer utils.ReadBuffer) (T, error) { |
| v, err := (new(_AmsPacket)).parse(ctx, readBuffer) |
| if err != nil { |
| var zero T |
| return zero, err |
| } |
| vc, ok := v.(T) |
| if !ok { |
| var zero T |
| return zero, errors.Errorf("Unexpected type %T. Expected type %T", v, *new(T)) |
| } |
| return vc, nil |
| } |
| |
| func (m *_AmsPacket) parse(ctx context.Context, readBuffer utils.ReadBuffer) (__amsPacket AmsPacket, err error) { |
| positionAware := readBuffer |
| _ = positionAware |
| if pullErr := readBuffer.PullContext("AmsPacket"); pullErr != nil { |
| return nil, errors.Wrap(pullErr, "Error pulling for AmsPacket") |
| } |
| currentPos := positionAware.GetPos() |
| _ = currentPos |
| |
| targetAmsNetId, err := ReadSimpleField[AmsNetId](ctx, "targetAmsNetId", ReadComplex[AmsNetId](AmsNetIdParseWithBuffer, readBuffer)) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'targetAmsNetId' field")) |
| } |
| m.TargetAmsNetId = targetAmsNetId |
| |
| targetAmsPort, err := ReadSimpleField(ctx, "targetAmsPort", ReadUnsignedShort(readBuffer, uint8(16))) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'targetAmsPort' field")) |
| } |
| m.TargetAmsPort = targetAmsPort |
| |
| sourceAmsNetId, err := ReadSimpleField[AmsNetId](ctx, "sourceAmsNetId", ReadComplex[AmsNetId](AmsNetIdParseWithBuffer, readBuffer)) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'sourceAmsNetId' field")) |
| } |
| m.SourceAmsNetId = sourceAmsNetId |
| |
| sourceAmsPort, err := ReadSimpleField(ctx, "sourceAmsPort", ReadUnsignedShort(readBuffer, uint8(16))) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'sourceAmsPort' field")) |
| } |
| m.SourceAmsPort = sourceAmsPort |
| |
| commandId, err := ReadDiscriminatorEnumField[CommandId](ctx, "commandId", "CommandId", ReadEnum(CommandIdByValue, ReadUnsignedShort(readBuffer, uint8(16)))) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'commandId' field")) |
| } |
| |
| initCommand, err := ReadConstField[bool](ctx, "initCommand", ReadBoolean(readBuffer), AmsPacket_INITCOMMAND) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'initCommand' field")) |
| } |
| _ = initCommand |
| |
| updCommand, err := ReadConstField[bool](ctx, "updCommand", ReadBoolean(readBuffer), AmsPacket_UPDCOMMAND) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'updCommand' field")) |
| } |
| _ = updCommand |
| |
| timestampAdded, err := ReadConstField[bool](ctx, "timestampAdded", ReadBoolean(readBuffer), AmsPacket_TIMESTAMPADDED) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'timestampAdded' field")) |
| } |
| _ = timestampAdded |
| |
| highPriorityCommand, err := ReadConstField[bool](ctx, "highPriorityCommand", ReadBoolean(readBuffer), AmsPacket_HIGHPRIORITYCOMMAND) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'highPriorityCommand' field")) |
| } |
| _ = highPriorityCommand |
| |
| systemCommand, err := ReadConstField[bool](ctx, "systemCommand", ReadBoolean(readBuffer), AmsPacket_SYSTEMCOMMAND) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'systemCommand' field")) |
| } |
| _ = systemCommand |
| |
| adsCommand, err := ReadConstField[bool](ctx, "adsCommand", ReadBoolean(readBuffer), AmsPacket_ADSCOMMAND) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'adsCommand' field")) |
| } |
| _ = adsCommand |
| |
| noReturn, err := ReadConstField[bool](ctx, "noReturn", ReadBoolean(readBuffer), AmsPacket_NORETURN) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'noReturn' field")) |
| } |
| _ = noReturn |
| |
| response, err := ReadDiscriminatorField[bool](ctx, "response", ReadBoolean(readBuffer)) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'response' field")) |
| } |
| |
| broadcast, err := ReadConstField[bool](ctx, "broadcast", ReadBoolean(readBuffer), AmsPacket_BROADCAST) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'broadcast' field")) |
| } |
| _ = broadcast |
| |
| reservedField0, err := ReadReservedField(ctx, "reserved", ReadSignedByte(readBuffer, uint8(7)), int8(0x0)) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing reserved field")) |
| } |
| m.reservedField0 = reservedField0 |
| |
| length, err := ReadImplicitField[uint32](ctx, "length", ReadUnsignedInt(readBuffer, uint8(32))) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'length' field")) |
| } |
| _ = length |
| |
| errorCode, err := ReadEnumField[ReturnCode](ctx, "errorCode", "ReturnCode", ReadEnum(ReturnCodeByValue, ReadUnsignedInt(readBuffer, uint8(32)))) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'errorCode' field")) |
| } |
| m.ErrorCode = errorCode |
| |
| invokeId, err := ReadSimpleField(ctx, "invokeId", ReadUnsignedInt(readBuffer, uint8(32))) |
| if err != nil { |
| return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'invokeId' field")) |
| } |
| m.InvokeId = invokeId |
| |
| // Switch Field (Depending on the discriminator values, passes the instantiation to a sub-type) |
| var _child AmsPacket |
| switch { |
| case errorCode == ReturnCode_OK && commandId == CommandId_INVALID && response == bool(false): // AdsInvalidRequest |
| if _child, err = new(_AdsInvalidRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsInvalidRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_INVALID && response == bool(true): // AdsInvalidResponse |
| if _child, err = new(_AdsInvalidResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsInvalidResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ_DEVICE_INFO && response == bool(false): // AdsReadDeviceInfoRequest |
| if _child, err = new(_AdsReadDeviceInfoRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadDeviceInfoRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ_DEVICE_INFO && response == bool(true): // AdsReadDeviceInfoResponse |
| if _child, err = new(_AdsReadDeviceInfoResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadDeviceInfoResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ && response == bool(false): // AdsReadRequest |
| if _child, err = new(_AdsReadRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ && response == bool(true): // AdsReadResponse |
| if _child, err = new(_AdsReadResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_WRITE && response == bool(false): // AdsWriteRequest |
| if _child, err = new(_AdsWriteRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsWriteRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_WRITE && response == bool(true): // AdsWriteResponse |
| if _child, err = new(_AdsWriteResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsWriteResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ_STATE && response == bool(false): // AdsReadStateRequest |
| if _child, err = new(_AdsReadStateRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadStateRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ_STATE && response == bool(true): // AdsReadStateResponse |
| if _child, err = new(_AdsReadStateResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadStateResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_WRITE_CONTROL && response == bool(false): // AdsWriteControlRequest |
| if _child, err = new(_AdsWriteControlRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsWriteControlRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_WRITE_CONTROL && response == bool(true): // AdsWriteControlResponse |
| if _child, err = new(_AdsWriteControlResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsWriteControlResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_ADD_DEVICE_NOTIFICATION && response == bool(false): // AdsAddDeviceNotificationRequest |
| if _child, err = new(_AdsAddDeviceNotificationRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsAddDeviceNotificationRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_ADD_DEVICE_NOTIFICATION && response == bool(true): // AdsAddDeviceNotificationResponse |
| if _child, err = new(_AdsAddDeviceNotificationResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsAddDeviceNotificationResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_DELETE_DEVICE_NOTIFICATION && response == bool(false): // AdsDeleteDeviceNotificationRequest |
| if _child, err = new(_AdsDeleteDeviceNotificationRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsDeleteDeviceNotificationRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_DELETE_DEVICE_NOTIFICATION && response == bool(true): // AdsDeleteDeviceNotificationResponse |
| if _child, err = new(_AdsDeleteDeviceNotificationResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsDeleteDeviceNotificationResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_DEVICE_NOTIFICATION && response == bool(false): // AdsDeviceNotificationRequest |
| if _child, err = new(_AdsDeviceNotificationRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsDeviceNotificationRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_DEVICE_NOTIFICATION && response == bool(true): // AdsDeviceNotificationResponse |
| if _child, err = new(_AdsDeviceNotificationResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsDeviceNotificationResponse for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ_WRITE && response == bool(false): // AdsReadWriteRequest |
| if _child, err = new(_AdsReadWriteRequest).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadWriteRequest for type-switch of AmsPacket") |
| } |
| case errorCode == ReturnCode_OK && commandId == CommandId_ADS_READ_WRITE && response == bool(true): // AdsReadWriteResponse |
| if _child, err = new(_AdsReadWriteResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsReadWriteResponse for type-switch of AmsPacket") |
| } |
| case true: // AdsErrorResponse |
| if _child, err = new(_AdsErrorResponse).parse(ctx, readBuffer, m); err != nil { |
| return nil, errors.Wrap(err, "Error parsing sub-type AdsErrorResponse for type-switch of AmsPacket") |
| } |
| default: |
| return nil, errors.Errorf("Unmapped type for parameters [errorCode=%v, commandId=%v, response=%v]", errorCode, commandId, response) |
| } |
| |
| if closeErr := readBuffer.CloseContext("AmsPacket"); closeErr != nil { |
| return nil, errors.Wrap(closeErr, "Error closing for AmsPacket") |
| } |
| |
| return _child, nil |
| } |
| |
| func (pm *_AmsPacket) serializeParent(ctx context.Context, writeBuffer utils.WriteBuffer, child AmsPacket, serializeChildFunction func() error) error { |
| // We redirect all calls through client as some methods are only implemented there |
| m := child |
| _ = m |
| positionAware := writeBuffer |
| _ = positionAware |
| log := zerolog.Ctx(ctx) |
| _ = log |
| if pushErr := writeBuffer.PushContext("AmsPacket"); pushErr != nil { |
| return errors.Wrap(pushErr, "Error pushing for AmsPacket") |
| } |
| |
| if err := WriteSimpleField[AmsNetId](ctx, "targetAmsNetId", m.GetTargetAmsNetId(), WriteComplex[AmsNetId](writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'targetAmsNetId' field") |
| } |
| |
| if err := WriteSimpleField[uint16](ctx, "targetAmsPort", m.GetTargetAmsPort(), WriteUnsignedShort(writeBuffer, 16)); err != nil { |
| return errors.Wrap(err, "Error serializing 'targetAmsPort' field") |
| } |
| |
| if err := WriteSimpleField[AmsNetId](ctx, "sourceAmsNetId", m.GetSourceAmsNetId(), WriteComplex[AmsNetId](writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'sourceAmsNetId' field") |
| } |
| |
| if err := WriteSimpleField[uint16](ctx, "sourceAmsPort", m.GetSourceAmsPort(), WriteUnsignedShort(writeBuffer, 16)); err != nil { |
| return errors.Wrap(err, "Error serializing 'sourceAmsPort' field") |
| } |
| |
| if err := WriteDiscriminatorEnumField(ctx, "commandId", "CommandId", m.GetCommandId(), WriteEnum[CommandId, uint16](CommandId.GetValue, CommandId.PLC4XEnumName, WriteUnsignedShort(writeBuffer, 16))); err != nil { |
| return errors.Wrap(err, "Error serializing 'commandId' field") |
| } |
| |
| if err := WriteConstField(ctx, "initCommand", AmsPacket_INITCOMMAND, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'initCommand' field") |
| } |
| |
| if err := WriteConstField(ctx, "updCommand", AmsPacket_UPDCOMMAND, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'updCommand' field") |
| } |
| |
| if err := WriteConstField(ctx, "timestampAdded", AmsPacket_TIMESTAMPADDED, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'timestampAdded' field") |
| } |
| |
| if err := WriteConstField(ctx, "highPriorityCommand", AmsPacket_HIGHPRIORITYCOMMAND, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'highPriorityCommand' field") |
| } |
| |
| if err := WriteConstField(ctx, "systemCommand", AmsPacket_SYSTEMCOMMAND, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'systemCommand' field") |
| } |
| |
| if err := WriteConstField(ctx, "adsCommand", AmsPacket_ADSCOMMAND, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'adsCommand' field") |
| } |
| |
| if err := WriteConstField(ctx, "noReturn", AmsPacket_NORETURN, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'noReturn' field") |
| } |
| |
| if err := WriteDiscriminatorField(ctx, "response", m.GetResponse(), WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'response' field") |
| } |
| |
| if err := WriteConstField(ctx, "broadcast", AmsPacket_BROADCAST, WriteBoolean(writeBuffer)); err != nil { |
| return errors.Wrap(err, "Error serializing 'broadcast' field") |
| } |
| |
| if err := WriteReservedField[int8](ctx, "reserved", int8(0x0), WriteSignedByte(writeBuffer, 7)); err != nil { |
| return errors.Wrap(err, "Error serializing 'reserved' field number 1") |
| } |
| length := uint32(uint32(uint32(m.GetLengthInBytes(ctx))) - uint32(uint32(32))) |
| if err := WriteImplicitField(ctx, "length", length, WriteUnsignedInt(writeBuffer, 32)); err != nil { |
| return errors.Wrap(err, "Error serializing 'length' field") |
| } |
| |
| if err := WriteSimpleEnumField[ReturnCode](ctx, "errorCode", "ReturnCode", m.GetErrorCode(), WriteEnum[ReturnCode, uint32](ReturnCode.GetValue, ReturnCode.PLC4XEnumName, WriteUnsignedInt(writeBuffer, 32))); err != nil { |
| return errors.Wrap(err, "Error serializing 'errorCode' field") |
| } |
| |
| if err := WriteSimpleField[uint32](ctx, "invokeId", m.GetInvokeId(), WriteUnsignedInt(writeBuffer, 32)); err != nil { |
| return errors.Wrap(err, "Error serializing 'invokeId' field") |
| } |
| |
| // Switch field (Depending on the discriminator values, passes the serialization to a sub-type) |
| if _typeSwitchErr := serializeChildFunction(); _typeSwitchErr != nil { |
| return errors.Wrap(_typeSwitchErr, "Error serializing sub-type field") |
| } |
| |
| if popErr := writeBuffer.PopContext("AmsPacket"); popErr != nil { |
| return errors.Wrap(popErr, "Error popping for AmsPacket") |
| } |
| return nil |
| } |
| |
| func (m *_AmsPacket) IsAmsPacket() {} |
| |
| func (m *_AmsPacket) DeepCopy() any { |
| return m.deepCopy() |
| } |
| |
| func (m *_AmsPacket) deepCopy() *_AmsPacket { |
| if m == nil { |
| return nil |
| } |
| _AmsPacketCopy := &_AmsPacket{ |
| nil, // will be set by child |
| utils.DeepCopy[AmsNetId](m.TargetAmsNetId), |
| m.TargetAmsPort, |
| utils.DeepCopy[AmsNetId](m.SourceAmsNetId), |
| m.SourceAmsPort, |
| m.ErrorCode, |
| m.InvokeId, |
| m.reservedField0, |
| } |
| return _AmsPacketCopy |
| } |