plc4go/protocols/eip/readwrite/model/CipConnectionManagerRequest.go (699 lines of code) (raw):

/* * 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" "fmt" "github.com/pkg/errors" "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/utils" ) // Code generated by code-generation. DO NOT EDIT. // CipConnectionManagerRequest is the corresponding interface of CipConnectionManagerRequest type CipConnectionManagerRequest interface { fmt.Stringer utils.LengthAware utils.Serializable utils.Copyable CipService // GetClassSegment returns ClassSegment (property field) GetClassSegment() PathSegment // GetInstanceSegment returns InstanceSegment (property field) GetInstanceSegment() PathSegment // GetPriority returns Priority (property field) GetPriority() uint8 // GetTickTime returns TickTime (property field) GetTickTime() uint8 // GetTimeoutTicks returns TimeoutTicks (property field) GetTimeoutTicks() uint8 // GetOtConnectionId returns OtConnectionId (property field) GetOtConnectionId() uint32 // GetToConnectionId returns ToConnectionId (property field) GetToConnectionId() uint32 // GetConnectionSerialNumber returns ConnectionSerialNumber (property field) GetConnectionSerialNumber() uint16 // GetOriginatorVendorId returns OriginatorVendorId (property field) GetOriginatorVendorId() uint16 // GetOriginatorSerialNumber returns OriginatorSerialNumber (property field) GetOriginatorSerialNumber() uint32 // GetTimeoutMultiplier returns TimeoutMultiplier (property field) GetTimeoutMultiplier() uint8 // GetOtRpi returns OtRpi (property field) GetOtRpi() uint32 // GetOtConnectionParameters returns OtConnectionParameters (property field) GetOtConnectionParameters() NetworkConnectionParameters // GetToRpi returns ToRpi (property field) GetToRpi() uint32 // GetToConnectionParameters returns ToConnectionParameters (property field) GetToConnectionParameters() NetworkConnectionParameters // GetTransportType returns TransportType (property field) GetTransportType() TransportType // GetConnectionPathSize returns ConnectionPathSize (property field) GetConnectionPathSize() uint8 // GetConnectionPaths returns ConnectionPaths (property field) GetConnectionPaths() []PathSegment // IsCipConnectionManagerRequest is a marker method to prevent unintentional type checks (interfaces of same signature) IsCipConnectionManagerRequest() // CreateBuilder creates a CipConnectionManagerRequestBuilder CreateCipConnectionManagerRequestBuilder() CipConnectionManagerRequestBuilder } // _CipConnectionManagerRequest is the data-structure of this message type _CipConnectionManagerRequest struct { CipServiceContract ClassSegment PathSegment InstanceSegment PathSegment Priority uint8 TickTime uint8 TimeoutTicks uint8 OtConnectionId uint32 ToConnectionId uint32 ConnectionSerialNumber uint16 OriginatorVendorId uint16 OriginatorSerialNumber uint32 TimeoutMultiplier uint8 OtRpi uint32 OtConnectionParameters NetworkConnectionParameters ToRpi uint32 ToConnectionParameters NetworkConnectionParameters TransportType TransportType ConnectionPathSize uint8 ConnectionPaths []PathSegment // Reserved Fields reservedField0 *uint32 } var _ CipConnectionManagerRequest = (*_CipConnectionManagerRequest)(nil) var _ CipServiceRequirements = (*_CipConnectionManagerRequest)(nil) // NewCipConnectionManagerRequest factory function for _CipConnectionManagerRequest func NewCipConnectionManagerRequest(classSegment PathSegment, instanceSegment PathSegment, priority uint8, tickTime uint8, timeoutTicks uint8, otConnectionId uint32, toConnectionId uint32, connectionSerialNumber uint16, originatorVendorId uint16, originatorSerialNumber uint32, timeoutMultiplier uint8, otRpi uint32, otConnectionParameters NetworkConnectionParameters, toRpi uint32, toConnectionParameters NetworkConnectionParameters, transportType TransportType, connectionPathSize uint8, connectionPaths []PathSegment, serviceLen uint16) *_CipConnectionManagerRequest { if classSegment == nil { panic("classSegment of type PathSegment for CipConnectionManagerRequest must not be nil") } if instanceSegment == nil { panic("instanceSegment of type PathSegment for CipConnectionManagerRequest must not be nil") } if otConnectionParameters == nil { panic("otConnectionParameters of type NetworkConnectionParameters for CipConnectionManagerRequest must not be nil") } if toConnectionParameters == nil { panic("toConnectionParameters of type NetworkConnectionParameters for CipConnectionManagerRequest must not be nil") } if transportType == nil { panic("transportType of type TransportType for CipConnectionManagerRequest must not be nil") } _result := &_CipConnectionManagerRequest{ CipServiceContract: NewCipService(serviceLen), ClassSegment: classSegment, InstanceSegment: instanceSegment, Priority: priority, TickTime: tickTime, TimeoutTicks: timeoutTicks, OtConnectionId: otConnectionId, ToConnectionId: toConnectionId, ConnectionSerialNumber: connectionSerialNumber, OriginatorVendorId: originatorVendorId, OriginatorSerialNumber: originatorSerialNumber, TimeoutMultiplier: timeoutMultiplier, OtRpi: otRpi, OtConnectionParameters: otConnectionParameters, ToRpi: toRpi, ToConnectionParameters: toConnectionParameters, TransportType: transportType, ConnectionPathSize: connectionPathSize, ConnectionPaths: connectionPaths, } _result.CipServiceContract.(*_CipService)._SubType = _result return _result } /////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////// /////////////////////// Builder /////////////////////// // CipConnectionManagerRequestBuilder is a builder for CipConnectionManagerRequest type CipConnectionManagerRequestBuilder interface { utils.Copyable // WithMandatoryFields adds all mandatory fields (convenience for using multiple builder calls) WithMandatoryFields(classSegment PathSegment, instanceSegment PathSegment, priority uint8, tickTime uint8, timeoutTicks uint8, otConnectionId uint32, toConnectionId uint32, connectionSerialNumber uint16, originatorVendorId uint16, originatorSerialNumber uint32, timeoutMultiplier uint8, otRpi uint32, otConnectionParameters NetworkConnectionParameters, toRpi uint32, toConnectionParameters NetworkConnectionParameters, transportType TransportType, connectionPathSize uint8, connectionPaths []PathSegment) CipConnectionManagerRequestBuilder // WithClassSegment adds ClassSegment (property field) WithClassSegment(PathSegment) CipConnectionManagerRequestBuilder // WithClassSegmentBuilder adds ClassSegment (property field) which is build by the builder WithClassSegmentBuilder(func(PathSegmentBuilder) PathSegmentBuilder) CipConnectionManagerRequestBuilder // WithInstanceSegment adds InstanceSegment (property field) WithInstanceSegment(PathSegment) CipConnectionManagerRequestBuilder // WithInstanceSegmentBuilder adds InstanceSegment (property field) which is build by the builder WithInstanceSegmentBuilder(func(PathSegmentBuilder) PathSegmentBuilder) CipConnectionManagerRequestBuilder // WithPriority adds Priority (property field) WithPriority(uint8) CipConnectionManagerRequestBuilder // WithTickTime adds TickTime (property field) WithTickTime(uint8) CipConnectionManagerRequestBuilder // WithTimeoutTicks adds TimeoutTicks (property field) WithTimeoutTicks(uint8) CipConnectionManagerRequestBuilder // WithOtConnectionId adds OtConnectionId (property field) WithOtConnectionId(uint32) CipConnectionManagerRequestBuilder // WithToConnectionId adds ToConnectionId (property field) WithToConnectionId(uint32) CipConnectionManagerRequestBuilder // WithConnectionSerialNumber adds ConnectionSerialNumber (property field) WithConnectionSerialNumber(uint16) CipConnectionManagerRequestBuilder // WithOriginatorVendorId adds OriginatorVendorId (property field) WithOriginatorVendorId(uint16) CipConnectionManagerRequestBuilder // WithOriginatorSerialNumber adds OriginatorSerialNumber (property field) WithOriginatorSerialNumber(uint32) CipConnectionManagerRequestBuilder // WithTimeoutMultiplier adds TimeoutMultiplier (property field) WithTimeoutMultiplier(uint8) CipConnectionManagerRequestBuilder // WithOtRpi adds OtRpi (property field) WithOtRpi(uint32) CipConnectionManagerRequestBuilder // WithOtConnectionParameters adds OtConnectionParameters (property field) WithOtConnectionParameters(NetworkConnectionParameters) CipConnectionManagerRequestBuilder // WithOtConnectionParametersBuilder adds OtConnectionParameters (property field) which is build by the builder WithOtConnectionParametersBuilder(func(NetworkConnectionParametersBuilder) NetworkConnectionParametersBuilder) CipConnectionManagerRequestBuilder // WithToRpi adds ToRpi (property field) WithToRpi(uint32) CipConnectionManagerRequestBuilder // WithToConnectionParameters adds ToConnectionParameters (property field) WithToConnectionParameters(NetworkConnectionParameters) CipConnectionManagerRequestBuilder // WithToConnectionParametersBuilder adds ToConnectionParameters (property field) which is build by the builder WithToConnectionParametersBuilder(func(NetworkConnectionParametersBuilder) NetworkConnectionParametersBuilder) CipConnectionManagerRequestBuilder // WithTransportType adds TransportType (property field) WithTransportType(TransportType) CipConnectionManagerRequestBuilder // WithTransportTypeBuilder adds TransportType (property field) which is build by the builder WithTransportTypeBuilder(func(TransportTypeBuilder) TransportTypeBuilder) CipConnectionManagerRequestBuilder // WithConnectionPathSize adds ConnectionPathSize (property field) WithConnectionPathSize(uint8) CipConnectionManagerRequestBuilder // WithConnectionPaths adds ConnectionPaths (property field) WithConnectionPaths(...PathSegment) CipConnectionManagerRequestBuilder // Done is used to finish work on this child and return (or create one if none) to the parent builder Done() CipServiceBuilder // Build builds the CipConnectionManagerRequest or returns an error if something is wrong Build() (CipConnectionManagerRequest, error) // MustBuild does the same as Build but panics on error MustBuild() CipConnectionManagerRequest } // NewCipConnectionManagerRequestBuilder() creates a CipConnectionManagerRequestBuilder func NewCipConnectionManagerRequestBuilder() CipConnectionManagerRequestBuilder { return &_CipConnectionManagerRequestBuilder{_CipConnectionManagerRequest: new(_CipConnectionManagerRequest)} } type _CipConnectionManagerRequestBuilder struct { *_CipConnectionManagerRequest parentBuilder *_CipServiceBuilder err *utils.MultiError } var _ (CipConnectionManagerRequestBuilder) = (*_CipConnectionManagerRequestBuilder)(nil) func (b *_CipConnectionManagerRequestBuilder) setParent(contract CipServiceContract) { b.CipServiceContract = contract contract.(*_CipService)._SubType = b._CipConnectionManagerRequest } func (b *_CipConnectionManagerRequestBuilder) WithMandatoryFields(classSegment PathSegment, instanceSegment PathSegment, priority uint8, tickTime uint8, timeoutTicks uint8, otConnectionId uint32, toConnectionId uint32, connectionSerialNumber uint16, originatorVendorId uint16, originatorSerialNumber uint32, timeoutMultiplier uint8, otRpi uint32, otConnectionParameters NetworkConnectionParameters, toRpi uint32, toConnectionParameters NetworkConnectionParameters, transportType TransportType, connectionPathSize uint8, connectionPaths []PathSegment) CipConnectionManagerRequestBuilder { return b.WithClassSegment(classSegment).WithInstanceSegment(instanceSegment).WithPriority(priority).WithTickTime(tickTime).WithTimeoutTicks(timeoutTicks).WithOtConnectionId(otConnectionId).WithToConnectionId(toConnectionId).WithConnectionSerialNumber(connectionSerialNumber).WithOriginatorVendorId(originatorVendorId).WithOriginatorSerialNumber(originatorSerialNumber).WithTimeoutMultiplier(timeoutMultiplier).WithOtRpi(otRpi).WithOtConnectionParameters(otConnectionParameters).WithToRpi(toRpi).WithToConnectionParameters(toConnectionParameters).WithTransportType(transportType).WithConnectionPathSize(connectionPathSize).WithConnectionPaths(connectionPaths...) } func (b *_CipConnectionManagerRequestBuilder) WithClassSegment(classSegment PathSegment) CipConnectionManagerRequestBuilder { b.ClassSegment = classSegment return b } func (b *_CipConnectionManagerRequestBuilder) WithClassSegmentBuilder(builderSupplier func(PathSegmentBuilder) PathSegmentBuilder) CipConnectionManagerRequestBuilder { builder := builderSupplier(b.ClassSegment.CreatePathSegmentBuilder()) var err error b.ClassSegment, err = builder.Build() if err != nil { if b.err == nil { b.err = &utils.MultiError{MainError: errors.New("sub builder failed")} } b.err.Append(errors.Wrap(err, "PathSegmentBuilder failed")) } return b } func (b *_CipConnectionManagerRequestBuilder) WithInstanceSegment(instanceSegment PathSegment) CipConnectionManagerRequestBuilder { b.InstanceSegment = instanceSegment return b } func (b *_CipConnectionManagerRequestBuilder) WithInstanceSegmentBuilder(builderSupplier func(PathSegmentBuilder) PathSegmentBuilder) CipConnectionManagerRequestBuilder { builder := builderSupplier(b.InstanceSegment.CreatePathSegmentBuilder()) var err error b.InstanceSegment, err = builder.Build() if err != nil { if b.err == nil { b.err = &utils.MultiError{MainError: errors.New("sub builder failed")} } b.err.Append(errors.Wrap(err, "PathSegmentBuilder failed")) } return b } func (b *_CipConnectionManagerRequestBuilder) WithPriority(priority uint8) CipConnectionManagerRequestBuilder { b.Priority = priority return b } func (b *_CipConnectionManagerRequestBuilder) WithTickTime(tickTime uint8) CipConnectionManagerRequestBuilder { b.TickTime = tickTime return b } func (b *_CipConnectionManagerRequestBuilder) WithTimeoutTicks(timeoutTicks uint8) CipConnectionManagerRequestBuilder { b.TimeoutTicks = timeoutTicks return b } func (b *_CipConnectionManagerRequestBuilder) WithOtConnectionId(otConnectionId uint32) CipConnectionManagerRequestBuilder { b.OtConnectionId = otConnectionId return b } func (b *_CipConnectionManagerRequestBuilder) WithToConnectionId(toConnectionId uint32) CipConnectionManagerRequestBuilder { b.ToConnectionId = toConnectionId return b } func (b *_CipConnectionManagerRequestBuilder) WithConnectionSerialNumber(connectionSerialNumber uint16) CipConnectionManagerRequestBuilder { b.ConnectionSerialNumber = connectionSerialNumber return b } func (b *_CipConnectionManagerRequestBuilder) WithOriginatorVendorId(originatorVendorId uint16) CipConnectionManagerRequestBuilder { b.OriginatorVendorId = originatorVendorId return b } func (b *_CipConnectionManagerRequestBuilder) WithOriginatorSerialNumber(originatorSerialNumber uint32) CipConnectionManagerRequestBuilder { b.OriginatorSerialNumber = originatorSerialNumber return b } func (b *_CipConnectionManagerRequestBuilder) WithTimeoutMultiplier(timeoutMultiplier uint8) CipConnectionManagerRequestBuilder { b.TimeoutMultiplier = timeoutMultiplier return b } func (b *_CipConnectionManagerRequestBuilder) WithOtRpi(otRpi uint32) CipConnectionManagerRequestBuilder { b.OtRpi = otRpi return b } func (b *_CipConnectionManagerRequestBuilder) WithOtConnectionParameters(otConnectionParameters NetworkConnectionParameters) CipConnectionManagerRequestBuilder { b.OtConnectionParameters = otConnectionParameters return b } func (b *_CipConnectionManagerRequestBuilder) WithOtConnectionParametersBuilder(builderSupplier func(NetworkConnectionParametersBuilder) NetworkConnectionParametersBuilder) CipConnectionManagerRequestBuilder { builder := builderSupplier(b.OtConnectionParameters.CreateNetworkConnectionParametersBuilder()) var err error b.OtConnectionParameters, err = builder.Build() if err != nil { if b.err == nil { b.err = &utils.MultiError{MainError: errors.New("sub builder failed")} } b.err.Append(errors.Wrap(err, "NetworkConnectionParametersBuilder failed")) } return b } func (b *_CipConnectionManagerRequestBuilder) WithToRpi(toRpi uint32) CipConnectionManagerRequestBuilder { b.ToRpi = toRpi return b } func (b *_CipConnectionManagerRequestBuilder) WithToConnectionParameters(toConnectionParameters NetworkConnectionParameters) CipConnectionManagerRequestBuilder { b.ToConnectionParameters = toConnectionParameters return b } func (b *_CipConnectionManagerRequestBuilder) WithToConnectionParametersBuilder(builderSupplier func(NetworkConnectionParametersBuilder) NetworkConnectionParametersBuilder) CipConnectionManagerRequestBuilder { builder := builderSupplier(b.ToConnectionParameters.CreateNetworkConnectionParametersBuilder()) var err error b.ToConnectionParameters, err = builder.Build() if err != nil { if b.err == nil { b.err = &utils.MultiError{MainError: errors.New("sub builder failed")} } b.err.Append(errors.Wrap(err, "NetworkConnectionParametersBuilder failed")) } return b } func (b *_CipConnectionManagerRequestBuilder) WithTransportType(transportType TransportType) CipConnectionManagerRequestBuilder { b.TransportType = transportType return b } func (b *_CipConnectionManagerRequestBuilder) WithTransportTypeBuilder(builderSupplier func(TransportTypeBuilder) TransportTypeBuilder) CipConnectionManagerRequestBuilder { builder := builderSupplier(b.TransportType.CreateTransportTypeBuilder()) var err error b.TransportType, err = builder.Build() if err != nil { if b.err == nil { b.err = &utils.MultiError{MainError: errors.New("sub builder failed")} } b.err.Append(errors.Wrap(err, "TransportTypeBuilder failed")) } return b } func (b *_CipConnectionManagerRequestBuilder) WithConnectionPathSize(connectionPathSize uint8) CipConnectionManagerRequestBuilder { b.ConnectionPathSize = connectionPathSize return b } func (b *_CipConnectionManagerRequestBuilder) WithConnectionPaths(connectionPaths ...PathSegment) CipConnectionManagerRequestBuilder { b.ConnectionPaths = connectionPaths return b } func (b *_CipConnectionManagerRequestBuilder) Build() (CipConnectionManagerRequest, error) { if b.ClassSegment == nil { if b.err == nil { b.err = new(utils.MultiError) } b.err.Append(errors.New("mandatory field 'classSegment' not set")) } if b.InstanceSegment == nil { if b.err == nil { b.err = new(utils.MultiError) } b.err.Append(errors.New("mandatory field 'instanceSegment' not set")) } if b.OtConnectionParameters == nil { if b.err == nil { b.err = new(utils.MultiError) } b.err.Append(errors.New("mandatory field 'otConnectionParameters' not set")) } if b.ToConnectionParameters == nil { if b.err == nil { b.err = new(utils.MultiError) } b.err.Append(errors.New("mandatory field 'toConnectionParameters' not set")) } if b.TransportType == nil { if b.err == nil { b.err = new(utils.MultiError) } b.err.Append(errors.New("mandatory field 'transportType' not set")) } if b.err != nil { return nil, errors.Wrap(b.err, "error occurred during build") } return b._CipConnectionManagerRequest.deepCopy(), nil } func (b *_CipConnectionManagerRequestBuilder) MustBuild() CipConnectionManagerRequest { build, err := b.Build() if err != nil { panic(err) } return build } func (b *_CipConnectionManagerRequestBuilder) Done() CipServiceBuilder { if b.parentBuilder == nil { b.parentBuilder = NewCipServiceBuilder().(*_CipServiceBuilder) } return b.parentBuilder } func (b *_CipConnectionManagerRequestBuilder) buildForCipService() (CipService, error) { return b.Build() } func (b *_CipConnectionManagerRequestBuilder) DeepCopy() any { _copy := b.CreateCipConnectionManagerRequestBuilder().(*_CipConnectionManagerRequestBuilder) if b.err != nil { _copy.err = b.err.DeepCopy().(*utils.MultiError) } return _copy } // CreateCipConnectionManagerRequestBuilder creates a CipConnectionManagerRequestBuilder func (b *_CipConnectionManagerRequest) CreateCipConnectionManagerRequestBuilder() CipConnectionManagerRequestBuilder { if b == nil { return NewCipConnectionManagerRequestBuilder() } return &_CipConnectionManagerRequestBuilder{_CipConnectionManagerRequest: b.deepCopy()} } /////////////////////// /////////////////////// /////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////// /////////////////////// Accessors for discriminator values. /////////////////////// func (m *_CipConnectionManagerRequest) GetService() uint8 { return 0x5B } func (m *_CipConnectionManagerRequest) GetResponse() bool { return bool(false) } func (m *_CipConnectionManagerRequest) GetConnected() bool { return false } /////////////////////// /////////////////////// /////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////// func (m *_CipConnectionManagerRequest) GetParent() CipServiceContract { return m.CipServiceContract } /////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////// /////////////////////// Accessors for property fields. /////////////////////// func (m *_CipConnectionManagerRequest) GetClassSegment() PathSegment { return m.ClassSegment } func (m *_CipConnectionManagerRequest) GetInstanceSegment() PathSegment { return m.InstanceSegment } func (m *_CipConnectionManagerRequest) GetPriority() uint8 { return m.Priority } func (m *_CipConnectionManagerRequest) GetTickTime() uint8 { return m.TickTime } func (m *_CipConnectionManagerRequest) GetTimeoutTicks() uint8 { return m.TimeoutTicks } func (m *_CipConnectionManagerRequest) GetOtConnectionId() uint32 { return m.OtConnectionId } func (m *_CipConnectionManagerRequest) GetToConnectionId() uint32 { return m.ToConnectionId } func (m *_CipConnectionManagerRequest) GetConnectionSerialNumber() uint16 { return m.ConnectionSerialNumber } func (m *_CipConnectionManagerRequest) GetOriginatorVendorId() uint16 { return m.OriginatorVendorId } func (m *_CipConnectionManagerRequest) GetOriginatorSerialNumber() uint32 { return m.OriginatorSerialNumber } func (m *_CipConnectionManagerRequest) GetTimeoutMultiplier() uint8 { return m.TimeoutMultiplier } func (m *_CipConnectionManagerRequest) GetOtRpi() uint32 { return m.OtRpi } func (m *_CipConnectionManagerRequest) GetOtConnectionParameters() NetworkConnectionParameters { return m.OtConnectionParameters } func (m *_CipConnectionManagerRequest) GetToRpi() uint32 { return m.ToRpi } func (m *_CipConnectionManagerRequest) GetToConnectionParameters() NetworkConnectionParameters { return m.ToConnectionParameters } func (m *_CipConnectionManagerRequest) GetTransportType() TransportType { return m.TransportType } func (m *_CipConnectionManagerRequest) GetConnectionPathSize() uint8 { return m.ConnectionPathSize } func (m *_CipConnectionManagerRequest) GetConnectionPaths() []PathSegment { return m.ConnectionPaths } /////////////////////// /////////////////////// /////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////// // Deprecated: use the interface for direct cast func CastCipConnectionManagerRequest(structType any) CipConnectionManagerRequest { if casted, ok := structType.(CipConnectionManagerRequest); ok { return casted } if casted, ok := structType.(*CipConnectionManagerRequest); ok { return *casted } return nil } func (m *_CipConnectionManagerRequest) GetTypeName() string { return "CipConnectionManagerRequest" } func (m *_CipConnectionManagerRequest) GetLengthInBits(ctx context.Context) uint16 { lengthInBits := uint16(m.CipServiceContract.(*_CipService).getLengthInBits(ctx)) // Implicit Field (requestPathSize) lengthInBits += 8 // Simple field (classSegment) lengthInBits += m.ClassSegment.GetLengthInBits(ctx) // Simple field (instanceSegment) lengthInBits += m.InstanceSegment.GetLengthInBits(ctx) // Simple field (priority) lengthInBits += 4 // Simple field (tickTime) lengthInBits += 4 // Simple field (timeoutTicks) lengthInBits += 8 // Simple field (otConnectionId) lengthInBits += 32 // Simple field (toConnectionId) lengthInBits += 32 // Simple field (connectionSerialNumber) lengthInBits += 16 // Simple field (originatorVendorId) lengthInBits += 16 // Simple field (originatorSerialNumber) lengthInBits += 32 // Simple field (timeoutMultiplier) lengthInBits += 8 // Reserved Field (reserved) lengthInBits += 24 // Simple field (otRpi) lengthInBits += 32 // Simple field (otConnectionParameters) lengthInBits += m.OtConnectionParameters.GetLengthInBits(ctx) // Simple field (toRpi) lengthInBits += 32 // Simple field (toConnectionParameters) lengthInBits += m.ToConnectionParameters.GetLengthInBits(ctx) // Simple field (transportType) lengthInBits += m.TransportType.GetLengthInBits(ctx) // Simple field (connectionPathSize) lengthInBits += 8 // Array field if len(m.ConnectionPaths) > 0 { for _, element := range m.ConnectionPaths { lengthInBits += element.GetLengthInBits(ctx) } } return lengthInBits } func (m *_CipConnectionManagerRequest) GetLengthInBytes(ctx context.Context) uint16 { return m.GetLengthInBits(ctx) / 8 } func (m *_CipConnectionManagerRequest) parse(ctx context.Context, readBuffer utils.ReadBuffer, parent *_CipService, connected bool, serviceLen uint16) (__cipConnectionManagerRequest CipConnectionManagerRequest, err error) { m.CipServiceContract = parent parent._SubType = m positionAware := readBuffer _ = positionAware if pullErr := readBuffer.PullContext("CipConnectionManagerRequest"); pullErr != nil { return nil, errors.Wrap(pullErr, "Error pulling for CipConnectionManagerRequest") } currentPos := positionAware.GetPos() _ = currentPos requestPathSize, err := ReadImplicitField[uint8](ctx, "requestPathSize", ReadUnsignedByte(readBuffer, uint8(8))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'requestPathSize' field")) } _ = requestPathSize classSegment, err := ReadSimpleField[PathSegment](ctx, "classSegment", ReadComplex[PathSegment](PathSegmentParseWithBuffer, readBuffer)) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'classSegment' field")) } m.ClassSegment = classSegment instanceSegment, err := ReadSimpleField[PathSegment](ctx, "instanceSegment", ReadComplex[PathSegment](PathSegmentParseWithBuffer, readBuffer)) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'instanceSegment' field")) } m.InstanceSegment = instanceSegment priority, err := ReadSimpleField(ctx, "priority", ReadUnsignedByte(readBuffer, uint8(4))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'priority' field")) } m.Priority = priority tickTime, err := ReadSimpleField(ctx, "tickTime", ReadUnsignedByte(readBuffer, uint8(4))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'tickTime' field")) } m.TickTime = tickTime timeoutTicks, err := ReadSimpleField(ctx, "timeoutTicks", ReadUnsignedByte(readBuffer, uint8(8))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'timeoutTicks' field")) } m.TimeoutTicks = timeoutTicks otConnectionId, err := ReadSimpleField(ctx, "otConnectionId", ReadUnsignedInt(readBuffer, uint8(32))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'otConnectionId' field")) } m.OtConnectionId = otConnectionId toConnectionId, err := ReadSimpleField(ctx, "toConnectionId", ReadUnsignedInt(readBuffer, uint8(32))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'toConnectionId' field")) } m.ToConnectionId = toConnectionId connectionSerialNumber, err := ReadSimpleField(ctx, "connectionSerialNumber", ReadUnsignedShort(readBuffer, uint8(16))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'connectionSerialNumber' field")) } m.ConnectionSerialNumber = connectionSerialNumber originatorVendorId, err := ReadSimpleField(ctx, "originatorVendorId", ReadUnsignedShort(readBuffer, uint8(16))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'originatorVendorId' field")) } m.OriginatorVendorId = originatorVendorId originatorSerialNumber, err := ReadSimpleField(ctx, "originatorSerialNumber", ReadUnsignedInt(readBuffer, uint8(32))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'originatorSerialNumber' field")) } m.OriginatorSerialNumber = originatorSerialNumber timeoutMultiplier, err := ReadSimpleField(ctx, "timeoutMultiplier", ReadUnsignedByte(readBuffer, uint8(8))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'timeoutMultiplier' field")) } m.TimeoutMultiplier = timeoutMultiplier reservedField0, err := ReadReservedField(ctx, "reserved", ReadUnsignedInt(readBuffer, uint8(24)), uint32(0x000000)) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing reserved field")) } m.reservedField0 = reservedField0 otRpi, err := ReadSimpleField(ctx, "otRpi", ReadUnsignedInt(readBuffer, uint8(32))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'otRpi' field")) } m.OtRpi = otRpi otConnectionParameters, err := ReadSimpleField[NetworkConnectionParameters](ctx, "otConnectionParameters", ReadComplex[NetworkConnectionParameters](NetworkConnectionParametersParseWithBuffer, readBuffer)) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'otConnectionParameters' field")) } m.OtConnectionParameters = otConnectionParameters toRpi, err := ReadSimpleField(ctx, "toRpi", ReadUnsignedInt(readBuffer, uint8(32))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'toRpi' field")) } m.ToRpi = toRpi toConnectionParameters, err := ReadSimpleField[NetworkConnectionParameters](ctx, "toConnectionParameters", ReadComplex[NetworkConnectionParameters](NetworkConnectionParametersParseWithBuffer, readBuffer)) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'toConnectionParameters' field")) } m.ToConnectionParameters = toConnectionParameters transportType, err := ReadSimpleField[TransportType](ctx, "transportType", ReadComplex[TransportType](TransportTypeParseWithBuffer, readBuffer)) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'transportType' field")) } m.TransportType = transportType connectionPathSize, err := ReadSimpleField(ctx, "connectionPathSize", ReadUnsignedByte(readBuffer, uint8(8))) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'connectionPathSize' field")) } m.ConnectionPathSize = connectionPathSize connectionPaths, err := ReadTerminatedArrayField[PathSegment](ctx, "connectionPaths", ReadComplex[PathSegment](PathSegmentParseWithBuffer, readBuffer), NoMorePathSegments(ctx, readBuffer)) if err != nil { return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'connectionPaths' field")) } m.ConnectionPaths = connectionPaths if closeErr := readBuffer.CloseContext("CipConnectionManagerRequest"); closeErr != nil { return nil, errors.Wrap(closeErr, "Error closing for CipConnectionManagerRequest") } return m, nil } func (m *_CipConnectionManagerRequest) Serialize() ([]byte, error) { wb := utils.NewWriteBufferByteBased(utils.WithInitialSizeForByteBasedBuffer(int(m.GetLengthInBytes(context.Background())))) if err := m.SerializeWithWriteBuffer(context.Background(), wb); err != nil { return nil, err } return wb.GetBytes(), nil } func (m *_CipConnectionManagerRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error { positionAware := writeBuffer _ = positionAware log := zerolog.Ctx(ctx) _ = log ser := func() error { if pushErr := writeBuffer.PushContext("CipConnectionManagerRequest"); pushErr != nil { return errors.Wrap(pushErr, "Error pushing for CipConnectionManagerRequest") } requestPathSize := uint8(uint8((uint8(m.GetClassSegment().GetLengthInBytes(ctx)) + uint8(m.GetInstanceSegment().GetLengthInBytes(ctx)))) / uint8(uint8(2))) if err := WriteImplicitField(ctx, "requestPathSize", requestPathSize, WriteUnsignedByte(writeBuffer, 8)); err != nil { return errors.Wrap(err, "Error serializing 'requestPathSize' field") } if err := WriteSimpleField[PathSegment](ctx, "classSegment", m.GetClassSegment(), WriteComplex[PathSegment](writeBuffer)); err != nil { return errors.Wrap(err, "Error serializing 'classSegment' field") } if err := WriteSimpleField[PathSegment](ctx, "instanceSegment", m.GetInstanceSegment(), WriteComplex[PathSegment](writeBuffer)); err != nil { return errors.Wrap(err, "Error serializing 'instanceSegment' field") } if err := WriteSimpleField[uint8](ctx, "priority", m.GetPriority(), WriteUnsignedByte(writeBuffer, 4)); err != nil { return errors.Wrap(err, "Error serializing 'priority' field") } if err := WriteSimpleField[uint8](ctx, "tickTime", m.GetTickTime(), WriteUnsignedByte(writeBuffer, 4)); err != nil { return errors.Wrap(err, "Error serializing 'tickTime' field") } if err := WriteSimpleField[uint8](ctx, "timeoutTicks", m.GetTimeoutTicks(), WriteUnsignedByte(writeBuffer, 8)); err != nil { return errors.Wrap(err, "Error serializing 'timeoutTicks' field") } if err := WriteSimpleField[uint32](ctx, "otConnectionId", m.GetOtConnectionId(), WriteUnsignedInt(writeBuffer, 32)); err != nil { return errors.Wrap(err, "Error serializing 'otConnectionId' field") } if err := WriteSimpleField[uint32](ctx, "toConnectionId", m.GetToConnectionId(), WriteUnsignedInt(writeBuffer, 32)); err != nil { return errors.Wrap(err, "Error serializing 'toConnectionId' field") } if err := WriteSimpleField[uint16](ctx, "connectionSerialNumber", m.GetConnectionSerialNumber(), WriteUnsignedShort(writeBuffer, 16)); err != nil { return errors.Wrap(err, "Error serializing 'connectionSerialNumber' field") } if err := WriteSimpleField[uint16](ctx, "originatorVendorId", m.GetOriginatorVendorId(), WriteUnsignedShort(writeBuffer, 16)); err != nil { return errors.Wrap(err, "Error serializing 'originatorVendorId' field") } if err := WriteSimpleField[uint32](ctx, "originatorSerialNumber", m.GetOriginatorSerialNumber(), WriteUnsignedInt(writeBuffer, 32)); err != nil { return errors.Wrap(err, "Error serializing 'originatorSerialNumber' field") } if err := WriteSimpleField[uint8](ctx, "timeoutMultiplier", m.GetTimeoutMultiplier(), WriteUnsignedByte(writeBuffer, 8)); err != nil { return errors.Wrap(err, "Error serializing 'timeoutMultiplier' field") } if err := WriteReservedField[uint32](ctx, "reserved", uint32(0x000000), WriteUnsignedInt(writeBuffer, 24)); err != nil { return errors.Wrap(err, "Error serializing 'reserved' field number 1") } if err := WriteSimpleField[uint32](ctx, "otRpi", m.GetOtRpi(), WriteUnsignedInt(writeBuffer, 32)); err != nil { return errors.Wrap(err, "Error serializing 'otRpi' field") } if err := WriteSimpleField[NetworkConnectionParameters](ctx, "otConnectionParameters", m.GetOtConnectionParameters(), WriteComplex[NetworkConnectionParameters](writeBuffer)); err != nil { return errors.Wrap(err, "Error serializing 'otConnectionParameters' field") } if err := WriteSimpleField[uint32](ctx, "toRpi", m.GetToRpi(), WriteUnsignedInt(writeBuffer, 32)); err != nil { return errors.Wrap(err, "Error serializing 'toRpi' field") } if err := WriteSimpleField[NetworkConnectionParameters](ctx, "toConnectionParameters", m.GetToConnectionParameters(), WriteComplex[NetworkConnectionParameters](writeBuffer)); err != nil { return errors.Wrap(err, "Error serializing 'toConnectionParameters' field") } if err := WriteSimpleField[TransportType](ctx, "transportType", m.GetTransportType(), WriteComplex[TransportType](writeBuffer)); err != nil { return errors.Wrap(err, "Error serializing 'transportType' field") } if err := WriteSimpleField[uint8](ctx, "connectionPathSize", m.GetConnectionPathSize(), WriteUnsignedByte(writeBuffer, 8)); err != nil { return errors.Wrap(err, "Error serializing 'connectionPathSize' field") } if err := WriteComplexTypeArrayField(ctx, "connectionPaths", m.GetConnectionPaths(), writeBuffer); err != nil { return errors.Wrap(err, "Error serializing 'connectionPaths' field") } if popErr := writeBuffer.PopContext("CipConnectionManagerRequest"); popErr != nil { return errors.Wrap(popErr, "Error popping for CipConnectionManagerRequest") } return nil } return m.CipServiceContract.(*_CipService).serializeParent(ctx, writeBuffer, m, ser) } func (m *_CipConnectionManagerRequest) IsCipConnectionManagerRequest() {} func (m *_CipConnectionManagerRequest) DeepCopy() any { return m.deepCopy() } func (m *_CipConnectionManagerRequest) deepCopy() *_CipConnectionManagerRequest { if m == nil { return nil } _CipConnectionManagerRequestCopy := &_CipConnectionManagerRequest{ m.CipServiceContract.(*_CipService).deepCopy(), utils.DeepCopy[PathSegment](m.ClassSegment), utils.DeepCopy[PathSegment](m.InstanceSegment), m.Priority, m.TickTime, m.TimeoutTicks, m.OtConnectionId, m.ToConnectionId, m.ConnectionSerialNumber, m.OriginatorVendorId, m.OriginatorSerialNumber, m.TimeoutMultiplier, m.OtRpi, utils.DeepCopy[NetworkConnectionParameters](m.OtConnectionParameters), m.ToRpi, utils.DeepCopy[NetworkConnectionParameters](m.ToConnectionParameters), utils.DeepCopy[TransportType](m.TransportType), m.ConnectionPathSize, utils.DeepCopySlice[PathSegment, PathSegment](m.ConnectionPaths), m.reservedField0, } _CipConnectionManagerRequestCopy.CipServiceContract.(*_CipService)._SubType = m return _CipConnectionManagerRequestCopy } func (m *_CipConnectionManagerRequest) String() string { if m == nil { return "<nil>" } wb := utils.NewWriteBufferBoxBased( utils.WithWriteBufferBoxBasedMergeSingleBoxes(), utils.WithWriteBufferBoxBasedOmitEmptyBoxes(), utils.WithWriteBufferBoxBasedPrintPosLengthFooter(), ) if err := wb.WriteSerializable(context.Background(), m); err != nil { return err.Error() } return wb.GetBox().String() }