This is an automated email from the ASF dual-hosted git repository.
sruehl pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/plc4x.git
commit c47bb964c0815f72cdbe34449fd85e1444bcbfc4
Author: Sebastian Rühl <sru...@apache.org>
AuthorDate: Sat Aug 31 21:42:25 2024 +0200
fix(code-gen/go): peek field reader
---
.../src/main/resources/templates/go/complex-type-template.go.ftlh | 5 ++++-
plc4go/protocols/bacnetip/readwrite/model/BACnetCalendarEntry.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetChannelValue.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetClientCOV.go | 3 +++
.../BACnetConfirmedServiceRequestAtomicReadFileStreamOrRecord.go | 3 +++
...BACnetConfirmedServiceRequestConfirmedTextMessageMessageClass.go | 3 +++
.../BACnetConfirmedServiceRequestCreateObjectObjectSpecifier.go | 2 +-
.../readwrite/model/BACnetConfirmedServiceRequestReadRangeRange.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedData.go | 3 +++
.../bacnetip/readwrite/model/BACnetConstructedDataElement.go | 3 +++
.../bacnetip/readwrite/model/BACnetEventLogRecordLogDatum.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameter.go | 3 +++
.../readwrite/model/BACnetEventParameterChangeOfValueCivCriteria.go | 3 +++
.../readwrite/model/BACnetEventParameterExtendedParameters.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameter.go | 3 +++
.../model/BACnetFaultParameterFaultExtendedParametersEntry.go | 3 +++
.../model/BACnetFaultParameterFaultOutOfRangeMaxNormalValue.go | 3 +++
.../model/BACnetFaultParameterFaultOutOfRangeMinNormalValue.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetHostAddress.go | 3 +++
.../bacnetip/readwrite/model/BACnetLandingCallStatusCommand.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetLogData.go | 3 +++
.../protocols/bacnetip/readwrite/model/BACnetLogDataLogDataEntry.go | 3 +++
.../protocols/bacnetip/readwrite/model/BACnetLogRecordLogDatum.go | 3 +++
.../bacnetip/readwrite/model/BACnetNotificationParameters.go | 3 +++
.../BACnetNotificationParametersChangeOfDiscreteValueNewValue.go | 3 +++
.../model/BACnetNotificationParametersChangeOfValueNewValue.go | 3 +++
.../model/BACnetNotificationParametersExtendedParameters.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalBinaryPV.go | 3 +++
.../bacnetip/readwrite/model/BACnetOptionalCharacterString.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalREAL.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalUnsigned.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetPriorityValue.go | 3 +++
.../protocols/bacnetip/readwrite/model/BACnetProcessIdSelection.go | 3 +++
.../readwrite/model/BACnetPropertyAccessResultAccessResult.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyStates.go | 3 +++
.../bacnetip/readwrite/model/BACnetReadAccessPropertyReadResult.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetRecipient.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetScale.go | 3 +++
.../readwrite/model/BACnetServiceAckAtomicReadFileStreamOrRecord.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetShedLevel.go | 3 +++
.../protocols/bacnetip/readwrite/model/BACnetSpecialEventPeriod.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetTimeStamp.go | 3 +++
.../bacnetip/readwrite/model/BACnetTimerStateChangeValue.go | 3 +++
.../readwrite/model/BACnetUnconfirmedServiceRequestWhoHasObject.go | 3 +++
plc4go/protocols/bacnetip/readwrite/model/BACnetValueSource.go | 3 +++
plc4go/protocols/cbus/readwrite/model/CALReply.go | 3 +++
plc4go/protocols/cbus/readwrite/model/CALReplyLong.go | 3 +++
.../protocols/cbus/readwrite/model/CBusPointToMultiPointCommand.go | 3 +++
plc4go/protocols/cbus/readwrite/model/CBusPointToPointCommand.go | 3 +++
.../cbus/readwrite/model/CBusPointToPointToMultiPointCommand.go | 3 +++
plc4go/protocols/cbus/readwrite/model/EncodedReply.go | 3 +++
plc4go/protocols/cbus/readwrite/model/LevelInformation.go | 3 +++
plc4go/protocols/cbus/readwrite/model/MonitoredSAL.go | 3 +++
.../protocols/cbus/readwrite/model/MonitoredSALLongFormSmartMode.go | 3 +++
.../cbus/readwrite/model/MonitoredSALShortFormBasicMode.go | 3 +++
plc4go/protocols/cbus/readwrite/model/Reply.go | 3 +++
plc4go/protocols/cbus/readwrite/model/ReplyOrConfirmation.go | 3 +++
plc4go/protocols/cbus/readwrite/model/Request.go | 6 ++++++
plc4go/protocols/cbus/readwrite/model/RequestReset.go | 6 ++++++
.../protocols/cbus/readwrite/model/RequestSmartConnectShortcut.go | 3 +++
plc4go/protocols/cbus/readwrite/model/StatusRequest.go | 3 +++
61 files changed, 188 insertions(+), 2 deletions(-)
diff --git
a/code-generation/language-go/src/main/resources/templates/go/complex-type-template.go.ftlh
b/code-generation/language-go/src/main/resources/templates/go/complex-type-template.go.ftlh
index 15edc267b7..a8965b2785 100644
---
a/code-generation/language-go/src/main/resources/templates/go/complex-type-template.go.ftlh
+++
b/code-generation/language-go/src/main/resources/templates/go/complex-type-template.go.ftlh
@@ -1076,7 +1076,7 @@ func ${type.name}ParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffe
<#assign typedField =
field.asTypedField().orElseThrow()>
<#assign namedField =
field.asNamedField().orElseThrow()>
- ${namedField.name},err :=
Read${field.typeName?cap_first}Field[${helper.getLanguageTypeNameForField(field)}](ctx,
"${namedField.name}", (*${helper.getLanguageTypeNameForField(field)})(nil),
${helper.toParseExpression(virtualField, virtualField.type,
virtualField.valueExpression,
parserArguments)}${helper.getFieldOptions(typedField, parserArguments)});
+ ${namedField.name},err :=
Read${field.typeName?cap_first}Field[${helper.getLanguageTypeNameForField(field)}](ctx,
"${namedField.name}", (*${helper.getLanguageTypeNameForField(field)})(nil),
${helper.toParseExpression(virtualField, virtualField.type,
virtualField.valueExpression,
parserArguments,true)}${helper.getFieldOptions(typedField, parserArguments)});
if err != nil {
return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'${namedField.name}' field"))<@emitImport import="github.com/pkg/errors" />
}
@@ -1098,6 +1098,9 @@ func ${type.name}ParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffe
<#assign namedField =
field.asNamedField().orElseThrow()>
${namedField.name},err :=
Read${field.typeName?cap_first}Field[${helper.getLanguageTypeNameForField(field)}](ctx,
"${namedField.name}", ${helper.getDataReaderCall(typedField.type)}<#if
peekField.offsetExpression.present>, ${helper.toParseExpression(peekField,
helper.boolTypeReference, peekField.offsetExpression.get(),
parserArguments)}<#else>, 0</#if>${helper.getFieldOptions(typedField,
parserArguments)});
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'${namedField.name}' field"))<@emitImport import="github.com/pkg/errors" />
+ }
<#break>
</#switch>
</#list>
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetCalendarEntry.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetCalendarEntry.go
index 51d16f5b94..fb41921ab7 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetCalendarEntry.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetCalendarEntry.go
@@ -165,6 +165,9 @@ func BACnetCalendarEntryParseWithBuffer(ctx
context.Context, readBuffer utils.Re
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetChannelValue.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetChannelValue.go
index 6d48618361..62efee0e9e 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetChannelValue.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetChannelValue.go
@@ -176,6 +176,9 @@ func BACnetChannelValueParseWithBuffer(ctx context.Context,
readBuffer utils.Rea
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetClientCOV.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetClientCOV.go
index 0f0b391d0b..245bf8e1a9 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetClientCOV.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetClientCOV.go
@@ -165,6 +165,9 @@ func BACnetClientCOVParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBu
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestAtomicReadFileStreamOrRecord.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestAtomicReadFileStreamOrRecord.go
index 63c423c38e..a6caf2451c 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestAtomicReadFileStreamOrRecord.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestAtomicReadFileStreamOrRecord.go
@@ -185,6 +185,9 @@ func
BACnetConfirmedServiceRequestAtomicReadFileStreamOrRecordParseWithBuffer(ct
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
openingTag, err := ReadSimpleField[BACnetOpeningTag](ctx, "openingTag",
ReadComplex[BACnetOpeningTag](BACnetOpeningTagParseWithBufferProducer((uint8)(peekedTagHeader.GetActualTagNumber())),
readBuffer))
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestConfirmedTextMessageMessageClass.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestConfirmedTextMessageMessageClass.go
index 1d16a85f23..7dfc2d5094 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestConfirmedTextMessageMessageClass.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestConfirmedTextMessageMessageClass.go
@@ -193,6 +193,9 @@ func
BACnetConfirmedServiceRequestConfirmedTextMessageMessageClassParseWithBuffe
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestCreateObjectObjectSpecifier.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestCreateObjectObjectSpecifier.go
index 1d09895f26..aa8d0b55b6 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestCreateObjectObjectSpecifier.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestCreateObjectObjectSpecifier.go
@@ -230,7 +230,7 @@ func
BACnetConfirmedServiceRequestCreateObjectObjectSpecifierParseWithBuffer(ctx
}
_ = isObjectType
- objectType, err := ReadVirtualField[BACnetObjectType](ctx,
"objectType", (*BACnetObjectType)(nil), MapBACnetObjectType(ctx,
(*rawObjectType)))
+ objectType, err := ReadVirtualField[BACnetObjectType](ctx,
"objectType", (*BACnetObjectType)(nil), MapBACnetObjectType(ctx,
(rawObjectType)))
if err != nil {
return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'objectType' field"))
}
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestReadRangeRange.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestReadRangeRange.go
index b39c755c01..1392482d3d 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestReadRangeRange.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConfirmedServiceRequestReadRangeRange.go
@@ -185,6 +185,9 @@ func
BACnetConfirmedServiceRequestReadRangeRangeParseWithBuffer(ctx context.Cont
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
openingTag, err := ReadSimpleField[BACnetOpeningTag](ctx, "openingTag",
ReadComplex[BACnetOpeningTag](BACnetOpeningTagParseWithBufferProducer((uint8)(peekedTagHeader.GetActualTagNumber())),
readBuffer))
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedData.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedData.go
index dc0c459361..5cf88d6f35 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedData.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedData.go
@@ -200,6 +200,9 @@ func BACnetConstructedDataParseWithBuffer(ctx
context.Context, readBuffer utils.
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedDataElement.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedDataElement.go
index 283e182daf..5b096eb496 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedDataElement.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetConstructedDataElement.go
@@ -234,6 +234,9 @@ func BACnetConstructedDataElementParseWithBuffer(ctx
context.Context, readBuffer
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventLogRecordLogDatum.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventLogRecordLogDatum.go
index 3dd6f35c03..b2cf09a071 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventLogRecordLogDatum.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventLogRecordLogDatum.go
@@ -193,6 +193,9 @@ func BACnetEventLogRecordLogDatumParseWithBuffer(ctx
context.Context, readBuffer
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameter.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameter.go
index 0827906ae0..7549aef8be 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameter.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameter.go
@@ -165,6 +165,9 @@ func BACnetEventParameterParseWithBuffer(ctx
context.Context, readBuffer utils.R
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterChangeOfValueCivCriteria.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterChangeOfValueCivCriteria.go
index 1552c2c9da..b2eb0f670d 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterChangeOfValueCivCriteria.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterChangeOfValueCivCriteria.go
@@ -193,6 +193,9 @@ func
BACnetEventParameterChangeOfValueCivCriteriaParseWithBuffer(ctx context.Con
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterExtendedParameters.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterExtendedParameters.go
index 970dec2cf4..74f69efd84 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterExtendedParameters.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetEventParameterExtendedParameters.go
@@ -439,6 +439,9 @@ func
BACnetEventParameterExtendedParametersParseWithBuffer(ctx context.Context,
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameter.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameter.go
index 483fc2d91b..8b21fade89 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameter.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameter.go
@@ -165,6 +165,9 @@ func BACnetFaultParameterParseWithBuffer(ctx
context.Context, readBuffer utils.R
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultExtendedParametersEntry.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultExtendedParametersEntry.go
index cd1aa82828..5aa2aeaf3a 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultExtendedParametersEntry.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultExtendedParametersEntry.go
@@ -176,6 +176,9 @@ func
BACnetFaultParameterFaultExtendedParametersEntryParseWithBuffer(ctx context
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMaxNormalValue.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMaxNormalValue.go
index 6fe57a1335..93bac08b19 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMaxNormalValue.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMaxNormalValue.go
@@ -193,6 +193,9 @@ func
BACnetFaultParameterFaultOutOfRangeMaxNormalValueParseWithBuffer(ctx contex
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMinNormalValue.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMinNormalValue.go
index 730d73ffb0..3d8ea5081c 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMinNormalValue.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetFaultParameterFaultOutOfRangeMinNormalValue.go
@@ -193,6 +193,9 @@ func
BACnetFaultParameterFaultOutOfRangeMinNormalValueParseWithBuffer(ctx contex
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetHostAddress.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetHostAddress.go
index 78f4f4be51..fd5d4c8b30 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetHostAddress.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetHostAddress.go
@@ -165,6 +165,9 @@ func BACnetHostAddressParseWithBuffer(ctx context.Context,
readBuffer utils.Read
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetLandingCallStatusCommand.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetLandingCallStatusCommand.go
index 96a387aa8d..0e6c2ca637 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetLandingCallStatusCommand.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetLandingCallStatusCommand.go
@@ -165,6 +165,9 @@ func BACnetLandingCallStatusCommandParseWithBuffer(ctx
context.Context, readBuff
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetLogData.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetLogData.go
index 93bfe38d25..8587ba4b54 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetLogData.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetLogData.go
@@ -193,6 +193,9 @@ func BACnetLogDataParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuff
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetLogDataLogDataEntry.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetLogDataLogDataEntry.go
index c3871f80b0..c641e90a2d 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetLogDataLogDataEntry.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetLogDataLogDataEntry.go
@@ -165,6 +165,9 @@ func BACnetLogDataLogDataEntryParseWithBuffer(ctx
context.Context, readBuffer ut
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetLogRecordLogDatum.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetLogRecordLogDatum.go
index 6713d67de7..46b5ed9665 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetLogRecordLogDatum.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetLogRecordLogDatum.go
@@ -193,6 +193,9 @@ func BACnetLogRecordLogDatumParseWithBuffer(ctx
context.Context, readBuffer util
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParameters.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParameters.go
index c68ae7eee0..35e5e8ab4a 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParameters.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParameters.go
@@ -194,6 +194,9 @@ func BACnetNotificationParametersParseWithBuffer(ctx
context.Context, readBuffer
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfDiscreteValueNewValue.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfDiscreteValueNewValue.go
index c33e094d0b..39ec4d914a 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfDiscreteValueNewValue.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfDiscreteValueNewValue.go
@@ -204,6 +204,9 @@ func
BACnetNotificationParametersChangeOfDiscreteValueNewValueParseWithBuffer(ct
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfValueNewValue.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfValueNewValue.go
index a8d55737ed..1b768df7a8 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfValueNewValue.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersChangeOfValueNewValue.go
@@ -193,6 +193,9 @@ func
BACnetNotificationParametersChangeOfValueNewValueParseWithBuffer(ctx contex
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersExtendedParameters.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersExtendedParameters.go
index 2eae9b5159..fd9adddddf 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersExtendedParameters.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetNotificationParametersExtendedParameters.go
@@ -439,6 +439,9 @@ func
BACnetNotificationParametersExtendedParametersParseWithBuffer(ctx context.C
}
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalBinaryPV.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalBinaryPV.go
index 042e30b514..ae6c5c4c86 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalBinaryPV.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalBinaryPV.go
@@ -165,6 +165,9 @@ func BACnetOptionalBinaryPVParseWithBuffer(ctx
context.Context, readBuffer utils
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalCharacterString.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalCharacterString.go
index e4cec6002f..a4504e7211 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalCharacterString.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalCharacterString.go
@@ -165,6 +165,9 @@ func BACnetOptionalCharacterStringParseWithBuffer(ctx
context.Context, readBuffe
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalREAL.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalREAL.go
index 5b9cbae29e..05d3270fa8 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalREAL.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalREAL.go
@@ -165,6 +165,9 @@ func BACnetOptionalREALParseWithBuffer(ctx context.Context,
readBuffer utils.Rea
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalUnsigned.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalUnsigned.go
index c1f5301ed8..36bf2be541 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalUnsigned.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetOptionalUnsigned.go
@@ -165,6 +165,9 @@ func BACnetOptionalUnsignedParseWithBuffer(ctx
context.Context, readBuffer utils
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetPriorityValue.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetPriorityValue.go
index e51df56aaa..b62a5fc01f 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetPriorityValue.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetPriorityValue.go
@@ -179,6 +179,9 @@ func BACnetPriorityValueParseWithBuffer(ctx
context.Context, readBuffer utils.Re
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetProcessIdSelection.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetProcessIdSelection.go
index 0716a9c2b7..aec27d8a4a 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetProcessIdSelection.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetProcessIdSelection.go
@@ -165,6 +165,9 @@ func BACnetProcessIdSelectionParseWithBuffer(ctx
context.Context, readBuffer uti
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyAccessResultAccessResult.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyAccessResultAccessResult.go
index 78d5d75c09..71f8552a98 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyAccessResultAccessResult.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyAccessResultAccessResult.go
@@ -170,6 +170,9 @@ func
BACnetPropertyAccessResultAccessResultParseWithBuffer(ctx context.Context,
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyStates.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyStates.go
index e5c3e5bc86..e09d2d569b 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyStates.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetPropertyStates.go
@@ -165,6 +165,9 @@ func BACnetPropertyStatesParseWithBuffer(ctx
context.Context, readBuffer utils.R
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetReadAccessPropertyReadResult.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetReadAccessPropertyReadResult.go
index 92371c3c68..a039ccb217 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetReadAccessPropertyReadResult.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetReadAccessPropertyReadResult.go
@@ -172,6 +172,9 @@ func BACnetReadAccessPropertyReadResultParseWithBuffer(ctx
context.Context, read
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetRecipient.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetRecipient.go
index c2b0e608be..30e5ff277b 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetRecipient.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetRecipient.go
@@ -165,6 +165,9 @@ func BACnetRecipientParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBu
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetScale.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetScale.go
index edbf358f7a..61fb315a32 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetScale.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetScale.go
@@ -165,6 +165,9 @@ func BACnetScaleParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffer
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetServiceAckAtomicReadFileStreamOrRecord.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetServiceAckAtomicReadFileStreamOrRecord.go
index a33501f1ee..cd92008fe2 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetServiceAckAtomicReadFileStreamOrRecord.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetServiceAckAtomicReadFileStreamOrRecord.go
@@ -185,6 +185,9 @@ func
BACnetServiceAckAtomicReadFileStreamOrRecordParseWithBuffer(ctx context.Con
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
openingTag, err := ReadSimpleField[BACnetOpeningTag](ctx, "openingTag",
ReadComplex[BACnetOpeningTag](BACnetOpeningTagParseWithBufferProducer((uint8)(peekedTagHeader.GetActualTagNumber())),
readBuffer))
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetShedLevel.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetShedLevel.go
index 6aba8ef30a..7e8ccac0b9 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetShedLevel.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetShedLevel.go
@@ -165,6 +165,9 @@ func BACnetShedLevelParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBu
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetSpecialEventPeriod.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetSpecialEventPeriod.go
index 7af655c1e3..5009470095 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetSpecialEventPeriod.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetSpecialEventPeriod.go
@@ -165,6 +165,9 @@ func BACnetSpecialEventPeriodParseWithBuffer(ctx
context.Context, readBuffer uti
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetTimeStamp.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetTimeStamp.go
index 5fc8cac9f1..9c9b005b1d 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetTimeStamp.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetTimeStamp.go
@@ -165,6 +165,9 @@ func BACnetTimeStampParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBu
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetTimerStateChangeValue.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetTimerStateChangeValue.go
index e1bbdab609..fe6def7363 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetTimerStateChangeValue.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetTimerStateChangeValue.go
@@ -179,6 +179,9 @@ func BACnetTimerStateChangeValueParseWithBuffer(ctx
context.Context, readBuffer
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git
a/plc4go/protocols/bacnetip/readwrite/model/BACnetUnconfirmedServiceRequestWhoHasObject.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetUnconfirmedServiceRequestWhoHasObject.go
index d0b038fe60..277314fcdc 100644
---
a/plc4go/protocols/bacnetip/readwrite/model/BACnetUnconfirmedServiceRequestWhoHasObject.go
+++
b/plc4go/protocols/bacnetip/readwrite/model/BACnetUnconfirmedServiceRequestWhoHasObject.go
@@ -165,6 +165,9 @@ func
BACnetUnconfirmedServiceRequestWhoHasObjectParseWithBuffer(ctx context.Cont
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/bacnetip/readwrite/model/BACnetValueSource.go
b/plc4go/protocols/bacnetip/readwrite/model/BACnetValueSource.go
index a651c0989d..f635cff4c1 100644
--- a/plc4go/protocols/bacnetip/readwrite/model/BACnetValueSource.go
+++ b/plc4go/protocols/bacnetip/readwrite/model/BACnetValueSource.go
@@ -165,6 +165,9 @@ func BACnetValueSourceParseWithBuffer(ctx context.Context,
readBuffer utils.Read
_ = currentPos
peekedTagHeader, err := ReadPeekField[BACnetTagHeader](ctx,
"peekedTagHeader", ReadComplex[BACnetTagHeader](BACnetTagHeaderParseWithBuffer,
readBuffer), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedTagHeader' field"))
+ }
peekedTagNumber, err := ReadVirtualField[uint8](ctx, "peekedTagNumber",
(*uint8)(nil), peekedTagHeader.GetActualTagNumber())
if err != nil {
diff --git a/plc4go/protocols/cbus/readwrite/model/CALReply.go
b/plc4go/protocols/cbus/readwrite/model/CALReply.go
index 21b287470e..306c9c57ae 100644
--- a/plc4go/protocols/cbus/readwrite/model/CALReply.go
+++ b/plc4go/protocols/cbus/readwrite/model/CALReply.go
@@ -160,6 +160,9 @@ func CALReplyParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffer, c
_ = currentPos
calType, err := ReadPeekField[byte](ctx, "calType",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'calType' field"))
+ }
// Switch Field (Depending on the discriminator values, passes the
instantiation to a sub-type)
type CALReplyChildSerializeRequirement interface {
diff --git a/plc4go/protocols/cbus/readwrite/model/CALReplyLong.go
b/plc4go/protocols/cbus/readwrite/model/CALReplyLong.go
index 5d6f53fb34..becee69448 100644
--- a/plc4go/protocols/cbus/readwrite/model/CALReplyLong.go
+++ b/plc4go/protocols/cbus/readwrite/model/CALReplyLong.go
@@ -246,6 +246,9 @@ func CALReplyLongParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffe
}
terminatingByte, err := ReadPeekField[uint32](ctx, "terminatingByte",
ReadUnsignedInt(readBuffer, uint8(24)), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'terminatingByte' field"))
+ }
isUnitAddress, err := ReadVirtualField[bool](ctx, "isUnitAddress",
(*bool)(nil), bool((terminatingByte&0xff) == (0x00)))
if err != nil {
diff --git
a/plc4go/protocols/cbus/readwrite/model/CBusPointToMultiPointCommand.go
b/plc4go/protocols/cbus/readwrite/model/CBusPointToMultiPointCommand.go
index 230d99f3d0..93f68395a1 100644
--- a/plc4go/protocols/cbus/readwrite/model/CBusPointToMultiPointCommand.go
+++ b/plc4go/protocols/cbus/readwrite/model/CBusPointToMultiPointCommand.go
@@ -149,6 +149,9 @@ func CBusPointToMultiPointCommandParseWithBuffer(ctx
context.Context, readBuffer
_ = currentPos
peekedApplication, err := ReadPeekField[byte](ctx, "peekedApplication",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedApplication' field"))
+ }
// Switch Field (Depending on the discriminator values, passes the
instantiation to a sub-type)
type CBusPointToMultiPointCommandChildSerializeRequirement interface {
diff --git a/plc4go/protocols/cbus/readwrite/model/CBusPointToPointCommand.go
b/plc4go/protocols/cbus/readwrite/model/CBusPointToPointCommand.go
index 59e1aa73a7..16fc49ae5d 100644
--- a/plc4go/protocols/cbus/readwrite/model/CBusPointToPointCommand.go
+++ b/plc4go/protocols/cbus/readwrite/model/CBusPointToPointCommand.go
@@ -178,6 +178,9 @@ func CBusPointToPointCommandParseWithBuffer(ctx
context.Context, readBuffer util
_ = currentPos
bridgeAddressCountPeek, err := ReadPeekField[uint16](ctx,
"bridgeAddressCountPeek", ReadUnsignedShort(readBuffer, uint8(16)), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'bridgeAddressCountPeek' field"))
+ }
isDirect, err := ReadVirtualField[bool](ctx, "isDirect", (*bool)(nil),
bool((bridgeAddressCountPeek&0x00FF) == (0x0000)))
if err != nil {
diff --git
a/plc4go/protocols/cbus/readwrite/model/CBusPointToPointToMultiPointCommand.go
b/plc4go/protocols/cbus/readwrite/model/CBusPointToPointToMultiPointCommand.go
index f1e8bddb2c..0a0b439c77 100644
---
a/plc4go/protocols/cbus/readwrite/model/CBusPointToPointToMultiPointCommand.go
+++
b/plc4go/protocols/cbus/readwrite/model/CBusPointToPointToMultiPointCommand.go
@@ -179,6 +179,9 @@ func CBusPointToPointToMultiPointCommandParseWithBuffer(ctx
context.Context, rea
}
peekedApplication, err := ReadPeekField[byte](ctx, "peekedApplication",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedApplication' field"))
+ }
// Switch Field (Depending on the discriminator values, passes the
instantiation to a sub-type)
type CBusPointToPointToMultiPointCommandChildSerializeRequirement
interface {
diff --git a/plc4go/protocols/cbus/readwrite/model/EncodedReply.go
b/plc4go/protocols/cbus/readwrite/model/EncodedReply.go
index 272f09c37b..1b7af5ee71 100644
--- a/plc4go/protocols/cbus/readwrite/model/EncodedReply.go
+++ b/plc4go/protocols/cbus/readwrite/model/EncodedReply.go
@@ -169,6 +169,9 @@ func EncodedReplyParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffe
_ = currentPos
peekedByte, err := ReadPeekField[byte](ctx, "peekedByte",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedByte' field"))
+ }
isMonitoredSAL, err := ReadVirtualField[bool](ctx, "isMonitoredSAL",
(*bool)(nil), bool((bool(bool(bool((peekedByte&0x3F) == (0x05))) ||
bool(bool((peekedByte) == (0x00)))) || bool(bool((peekedByte&0xF8) ==
(0x00))))) && bool(!(requestContext.GetSendIdentifyRequestBefore())))
if err != nil {
diff --git a/plc4go/protocols/cbus/readwrite/model/LevelInformation.go
b/plc4go/protocols/cbus/readwrite/model/LevelInformation.go
index 54a0ebb3e4..ca3060da9e 100644
--- a/plc4go/protocols/cbus/readwrite/model/LevelInformation.go
+++ b/plc4go/protocols/cbus/readwrite/model/LevelInformation.go
@@ -236,6 +236,9 @@ func LevelInformationParseWithBuffer(ctx context.Context,
readBuffer utils.ReadB
_ = currentPos
raw, err := ReadPeekField[uint16](ctx, "raw",
ReadUnsignedShort(readBuffer, uint8(16)), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing 'raw'
field"))
+ }
nibble1, err := ReadVirtualField[uint8](ctx, "nibble1", (*uint8)(nil),
(raw&0xF000)>>uint8(12))
if err != nil {
diff --git a/plc4go/protocols/cbus/readwrite/model/MonitoredSAL.go
b/plc4go/protocols/cbus/readwrite/model/MonitoredSAL.go
index b1b0e0e11c..32f7a9fa61 100644
--- a/plc4go/protocols/cbus/readwrite/model/MonitoredSAL.go
+++ b/plc4go/protocols/cbus/readwrite/model/MonitoredSAL.go
@@ -149,6 +149,9 @@ func MonitoredSALParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffe
_ = currentPos
salType, err := ReadPeekField[byte](ctx, "salType",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'salType' field"))
+ }
// Switch Field (Depending on the discriminator values, passes the
instantiation to a sub-type)
type MonitoredSALChildSerializeRequirement interface {
diff --git
a/plc4go/protocols/cbus/readwrite/model/MonitoredSALLongFormSmartMode.go
b/plc4go/protocols/cbus/readwrite/model/MonitoredSALLongFormSmartMode.go
index 2f3e17e6fb..0e4800d276 100644
--- a/plc4go/protocols/cbus/readwrite/model/MonitoredSALLongFormSmartMode.go
+++ b/plc4go/protocols/cbus/readwrite/model/MonitoredSALLongFormSmartMode.go
@@ -260,6 +260,9 @@ func MonitoredSALLongFormSmartModeParseWithBuffer(ctx
context.Context, readBuffe
}
terminatingByte, err := ReadPeekField[uint32](ctx, "terminatingByte",
ReadUnsignedInt(readBuffer, uint8(24)), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'terminatingByte' field"))
+ }
isUnitAddress, err := ReadVirtualField[bool](ctx, "isUnitAddress",
(*bool)(nil), bool((terminatingByte&0xff) == (0x00)))
if err != nil {
diff --git
a/plc4go/protocols/cbus/readwrite/model/MonitoredSALShortFormBasicMode.go
b/plc4go/protocols/cbus/readwrite/model/MonitoredSALShortFormBasicMode.go
index f783025a40..09b0cd550f 100644
--- a/plc4go/protocols/cbus/readwrite/model/MonitoredSALShortFormBasicMode.go
+++ b/plc4go/protocols/cbus/readwrite/model/MonitoredSALShortFormBasicMode.go
@@ -208,6 +208,9 @@ func MonitoredSALShortFormBasicModeParseWithBuffer(ctx
context.Context, readBuff
_ = currentPos
counts, err := ReadPeekField[byte](ctx, "counts", ReadByte(readBuffer,
8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'counts' field"))
+ }
bridgeCount, err := ReadOptionalField[uint8](ctx, "bridgeCount",
ReadUnsignedByte(readBuffer, uint8(8)), bool((counts) != (0x00)))
if err != nil {
diff --git a/plc4go/protocols/cbus/readwrite/model/Reply.go
b/plc4go/protocols/cbus/readwrite/model/Reply.go
index fcbb253790..0148f4051a 100644
--- a/plc4go/protocols/cbus/readwrite/model/Reply.go
+++ b/plc4go/protocols/cbus/readwrite/model/Reply.go
@@ -150,6 +150,9 @@ func ReplyParseWithBuffer(ctx context.Context, readBuffer
utils.ReadBuffer, cBus
_ = currentPos
peekedByte, err := ReadPeekField[byte](ctx, "peekedByte",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedByte' field"))
+ }
// Switch Field (Depending on the discriminator values, passes the
instantiation to a sub-type)
type ReplyChildSerializeRequirement interface {
diff --git a/plc4go/protocols/cbus/readwrite/model/ReplyOrConfirmation.go
b/plc4go/protocols/cbus/readwrite/model/ReplyOrConfirmation.go
index 008f709070..fc43449975 100644
--- a/plc4go/protocols/cbus/readwrite/model/ReplyOrConfirmation.go
+++ b/plc4go/protocols/cbus/readwrite/model/ReplyOrConfirmation.go
@@ -170,6 +170,9 @@ func ReplyOrConfirmationParseWithBuffer(ctx
context.Context, readBuffer utils.Re
_ = currentPos
peekedByte, err := ReadPeekField[byte](ctx, "peekedByte",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedByte' field"))
+ }
isAlpha, err := ReadVirtualField[bool](ctx, "isAlpha", (*bool)(nil),
bool((bool((peekedByte) >= (0x67)))) && bool((bool((peekedByte) <= (0x7A)))))
if err != nil {
diff --git a/plc4go/protocols/cbus/readwrite/model/Request.go
b/plc4go/protocols/cbus/readwrite/model/Request.go
index 70a15f8d1c..7f981e3395 100644
--- a/plc4go/protocols/cbus/readwrite/model/Request.go
+++ b/plc4go/protocols/cbus/readwrite/model/Request.go
@@ -213,6 +213,9 @@ func RequestParseWithBuffer(ctx context.Context, readBuffer
utils.ReadBuffer, cB
_ = currentPos
peekedByte, err := ReadPeekField[RequestType](ctx, "peekedByte",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'peekedByte' field"))
+ }
startingCR, err := ReadOptionalField[RequestType](ctx, "startingCR",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))),
bool((peekedByte) == (RequestType_EMPTY)))
if err != nil {
@@ -225,6 +228,9 @@ func RequestParseWithBuffer(ctx context.Context, readBuffer
utils.ReadBuffer, cB
}
secondPeek, err := ReadPeekField[RequestType](ctx, "secondPeek",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'secondPeek' field"))
+ }
actualPeek, err := ReadVirtualField[RequestType](ctx, "actualPeek",
(*RequestType)(nil),
CastRequestType(utils.InlineIf(bool((bool(bool((startingCR) == (nil))) &&
bool(bool((resetMode) == (nil))))) || bool((bool(bool(bool((startingCR) ==
(nil))) && bool(bool((resetMode) != (nil)))) && bool(bool((secondPeek) ==
(RequestType_EMPTY))))), func() any { return CastRequestType(peekedByte) },
func() any { return CastRequestType(secondPeek) })))
if err != nil {
diff --git a/plc4go/protocols/cbus/readwrite/model/RequestReset.go
b/plc4go/protocols/cbus/readwrite/model/RequestReset.go
index c66429389a..2f138c9ddd 100644
--- a/plc4go/protocols/cbus/readwrite/model/RequestReset.go
+++ b/plc4go/protocols/cbus/readwrite/model/RequestReset.go
@@ -183,6 +183,9 @@ func RequestResetParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffe
_ = currentPos
tildePeek, err := ReadPeekField[RequestType](ctx, "tildePeek",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'tildePeek' field"))
+ }
secondTilde, err := ReadOptionalField[RequestType](ctx, "secondTilde",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))),
bool((tildePeek) == (RequestType_RESET)))
if err != nil {
@@ -190,6 +193,9 @@ func RequestResetParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuffe
}
tildePeek2, err := ReadPeekField[RequestType](ctx, "tildePeek2",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'tildePeek2' field"))
+ }
thirdTilde, err := ReadOptionalField[RequestType](ctx, "thirdTilde",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))),
bool((tildePeek2) == (RequestType_RESET)))
if err != nil {
diff --git
a/plc4go/protocols/cbus/readwrite/model/RequestSmartConnectShortcut.go
b/plc4go/protocols/cbus/readwrite/model/RequestSmartConnectShortcut.go
index 66d8141183..4eee22b4df 100644
--- a/plc4go/protocols/cbus/readwrite/model/RequestSmartConnectShortcut.go
+++ b/plc4go/protocols/cbus/readwrite/model/RequestSmartConnectShortcut.go
@@ -187,6 +187,9 @@ func RequestSmartConnectShortcutParseWithBuffer(ctx
context.Context, readBuffer
_ = pipe
pipePeek, err := ReadPeekField[RequestType](ctx, "pipePeek",
ReadEnum(RequestTypeByValue, ReadUnsignedByte(readBuffer, uint8(8))), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'pipePeek' field"))
+ }
secondPipe, err := ReadOptionalField[byte](ctx, "secondPipe",
ReadByte(readBuffer, 8), bool((pipePeek) ==
(RequestType_SMART_CONNECT_SHORTCUT)))
if err != nil {
diff --git a/plc4go/protocols/cbus/readwrite/model/StatusRequest.go
b/plc4go/protocols/cbus/readwrite/model/StatusRequest.go
index ca4159470e..564a0d14e1 100644
--- a/plc4go/protocols/cbus/readwrite/model/StatusRequest.go
+++ b/plc4go/protocols/cbus/readwrite/model/StatusRequest.go
@@ -146,6 +146,9 @@ func StatusRequestParseWithBuffer(ctx context.Context,
readBuffer utils.ReadBuff
_ = currentPos
statusType, err := ReadPeekField[byte](ctx, "statusType",
ReadByte(readBuffer, 8), 0)
+ if err != nil {
+ return nil, errors.Wrap(err, fmt.Sprintf("Error parsing
'statusType' field"))
+ }
// Switch Field (Depending on the discriminator values, passes the
instantiation to a sub-type)
type StatusRequestChildSerializeRequirement interface {
