You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by sr...@apache.org on 2024/09/04 20:54:36 UTC
(plc4x) 01/05: feat(plc4go/plc4xGenerator): add support for nil values and a direct serialize
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 bf9415feb938fc8803b72be045ff0643adbcd70c
Author: Sebastian Rühl <sr...@apache.org>
AuthorDate: Wed Sep 4 21:52:19 2024 +0200
feat(plc4go/plc4xGenerator): add support for nil values and a direct serialize
---
plc4go/internal/ads/MessageCodec_plc4xgen.go | 11 +++
.../ads/model/AdsSubscriptionHandle_plc4xgen.go | 17 ++++-
.../ApplicationLayerMessageCodec_plc4xgen.go | 25 +++++--
plc4go/internal/bacnetip/MessageCodec_plc4xgen.go | 11 +++
plc4go/internal/bacnetip/Subscriber_plc4xgen.go | 23 ++++--
.../bacgopes/app_BIPSimpleApplication_plc4xgen.go | 81 ++++++++++++++--------
.../bacnetip/bacgopes/app_DeviceInfo_plc4xgen.go | 23 ++++--
.../bacgopes/capability_Capability_plc4xgen.go | 11 +++
.../bacgopes/device_WhoIsIAmServices_plc4xgen.go | 21 ++++--
.../bacnetip/bacgopes/iocb_IOCB_plc4xgen.go | 21 ++++--
.../bacgopes/iocb_IOController_plc4xgen.go | 11 +++
.../bacgopes/iocb_IOQController_plc4xgen.go | 23 ++++--
.../bacnetip/bacgopes/iocb_IOQueue_plc4xgen.go | 11 +++
.../bacnetip/bacgopes/iocb_SieveQueue_plc4xgen.go | 21 ++++--
.../object_ReadWritePropertyServices_plc4xgen.go | 11 +++
.../bacnetip/bacgopes/udp_UDPActor_plc4xgen.go | 31 ++++++---
plc4go/internal/cbus/AlphaGenerator_plc4xgen.go | 11 +++
plc4go/internal/cbus/Configuration_plc4xgen.go | 11 +++
plc4go/internal/cbus/Connection_plc4xgen.go | 27 ++++++--
plc4go/internal/cbus/DriverContext_plc4xgen.go | 11 +++
plc4go/internal/cbus/MessageCodec_plc4xgen.go | 15 +++-
plc4go/internal/cbus/Subscriber_plc4xgen.go | 11 +++
plc4go/internal/eip/MessageCodec_plc4xgen.go | 11 +++
.../knxnetip/ConnectionMetadata_plc4xgen.go | 11 +++
plc4go/internal/knxnetip/MessageCodec_plc4xgen.go | 11 +++
plc4go/internal/knxnetip/Subscriber_plc4xgen.go | 23 ++++--
plc4go/internal/modbus/MessageCodec_plc4xgen.go | 11 +++
plc4go/internal/opcua/Configuration_plc4xgen.go | 23 ++++--
plc4go/internal/opcua/Connection_plc4xgen.go | 39 +++++++----
plc4go/internal/opcua/DriverContext_plc4xgen.go | 11 +++
plc4go/internal/opcua/MessageCodec_plc4xgen.go | 11 +++
.../SecureChannelTransactionManager_plc4xgen.go | 11 +++
plc4go/internal/opcua/SecureChannel_plc4xgen.go | 53 +++++++++-----
plc4go/internal/opcua/Subscriber_plc4xgen.go | 21 ++++--
plc4go/internal/s7/MessageCodec_plc4xgen.go | 11 +++
.../pkg/api/plcConnectionConnectResult_plc4xgen.go | 11 +++
plc4go/pkg/api/plcDriverManger_plc4xgen.go | 11 +++
.../default/DefaultConnectionMetadata_plc4xgen.go | 11 +++
plc4go/spi/default/defaultCodec_plc4xgen.go | 17 ++++-
plc4go/spi/default/defaultConnection_plc4xgen.go | 17 ++++-
.../defaultPlcConnectionCloseResult_plc4xgen.go | 15 +++-
.../defaultPlcConnectionConnectResult_plc4xgen.go | 13 +++-
.../defaultPlcConnectionPingResult_plc4xgen.go | 11 +++
.../interceptedPlcReadRequestResult_plc4xgen.go | 15 +++-
.../interceptedPlcWriteRequestResult_plc4xgen.go | 15 +++-
plc4go/spi/model/DefaultArrayInfo_plc4xgen.go | 11 +++
plc4go/spi/model/DefaultPlcBrowseItem_plc4xgen.go | 13 +++-
.../DefaultPlcBrowseRequestBuilder_plc4xgen.go | 11 +++
.../DefaultPlcBrowseRequestResult_plc4xgen.go | 15 +++-
.../spi/model/DefaultPlcBrowseRequest_plc4xgen.go | 13 +++-
.../model/DefaultPlcBrowseResponseItem_plc4xgen.go | 13 +++-
.../spi/model/DefaultPlcBrowseResponse_plc4xgen.go | 13 +++-
.../DefaultPlcConsumerRegistration_plc4xgen.go | 13 +++-
.../spi/model/DefaultPlcDiscoveryItem_plc4xgen.go | 11 +++
.../model/DefaultPlcReadRequestBuilder_plc4xgen.go | 11 +++
.../model/DefaultPlcReadRequestResult_plc4xgen.go | 15 +++-
plc4go/spi/model/DefaultPlcReadRequest_plc4xgen.go | 11 +++
.../spi/model/DefaultPlcReadResponse_plc4xgen.go | 13 +++-
.../DefaultPlcSubscriptionEventItem_plc4xgen.go | 17 ++++-
.../model/DefaultPlcSubscriptionEvent_plc4xgen.go | 11 +++
.../model/DefaultPlcSubscriptionHandle_plc4xgen.go | 11 +++
...efaultPlcSubscriptionRequestBuilder_plc4xgen.go | 11 +++
...DefaultPlcSubscriptionRequestResult_plc4xgen.go | 15 +++-
.../DefaultPlcSubscriptionRequest_plc4xgen.go | 13 +++-
.../DefaultPlcSubscriptionResponseItem_plc4xgen.go | 13 +++-
.../DefaultPlcSubscriptionResponse_plc4xgen.go | 13 +++-
.../model/DefaultPlcSubscriptionTag_plc4xgen.go | 13 +++-
plc4go/spi/model/DefaultPlcTagRequest_plc4xgen.go | 11 +++
...aultPlcUnsubscriptionRequestBuilder_plc4xgen.go | 13 +++-
...faultPlcUnsubscriptionRequestResult_plc4xgen.go | 15 +++-
.../DefaultPlcUnsubscriptionRequest_plc4xgen.go | 13 +++-
.../DefaultPlcUnsubscriptionResponse_plc4xgen.go | 11 +++
.../DefaultPlcWriteRequestBuilder_plc4xgen.go | 11 +++
.../model/DefaultPlcWriteRequestResult_plc4xgen.go | 15 +++-
.../spi/model/DefaultPlcWriteRequest_plc4xgen.go | 11 +++
.../spi/model/DefaultPlcWriteResponse_plc4xgen.go | 13 +++-
plc4go/spi/model/ResponseItem_plc4xgen.go | 13 +++-
plc4go/spi/pool/dynamicExecutor_plc4xgen.go | 11 +++
plc4go/spi/pool/executor_plc4xgen.go | 13 +++-
plc4go/spi/pool/future_plc4xgen.go | 13 +++-
plc4go/spi/pool/workItem_plc4xgen.go | 21 ++++--
plc4go/spi/pool/worker_plc4xgen.go | 13 +++-
.../spi/transactions/completedFuture_plc4xgen.go | 11 +++
.../requestTransactionManager_plc4xgen.go | 15 +++-
.../transactions/requestTransaction_plc4xgen.go | 11 +++
plc4go/tools/plc4xGenerator/ExampleStruct_test.go | 26 +++++++
plc4go/tools/plc4xGenerator/main.go | 52 ++++++++++----
87 files changed, 1227 insertions(+), 186 deletions(-)
diff --git a/plc4go/internal/ads/MessageCodec_plc4xgen.go b/plc4go/internal/ads/MessageCodec_plc4xgen.go
index 2e64b80eb3..6abf6e9988 100644
--- a/plc4go/internal/ads/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/ads/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -56,6 +62,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/ads/model/AdsSubscriptionHandle_plc4xgen.go b/plc4go/internal/ads/model/AdsSubscriptionHandle_plc4xgen.go
index 40cb70b7a0..449ee8bcdb 100644
--- a/plc4go/internal/ads/model/AdsSubscriptionHandle_plc4xgen.go
+++ b/plc4go/internal/ads/model/AdsSubscriptionHandle_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *AdsSubscriptionHandle) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *AdsSubscriptionHandle) Serialize() ([]byte, error) {
}
func (d *AdsSubscriptionHandle) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("AdsSubscriptionHandle"); err != nil {
return err
}
- if any(d.subscriber) != nil {
+ if d.subscriber != nil {
if serializableField, ok := any(d.subscriber).(utils.Serializable); ok {
if err := writeBuffer.PushContext("subscriber"); err != nil {
return err
@@ -78,7 +84,7 @@ func (d *AdsSubscriptionHandle) SerializeWithWriteBuffer(ctx context.Context, wr
for _, elem := range d.consumers {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -106,7 +112,7 @@ func (d *AdsSubscriptionHandle) SerializeWithWriteBuffer(ctx context.Context, wr
for _, elem := range d._options {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -135,6 +141,11 @@ func (d *AdsSubscriptionHandle) SerializeWithWriteBuffer(ctx context.Context, wr
}
func (d *AdsSubscriptionHandle) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/ApplicationLayerMessageCodec_plc4xgen.go b/plc4go/internal/bacnetip/ApplicationLayerMessageCodec_plc4xgen.go
index 22b6fca922..7b62812975 100644
--- a/plc4go/internal/bacnetip/ApplicationLayerMessageCodec_plc4xgen.go
+++ b/plc4go/internal/bacnetip/ApplicationLayerMessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *ApplicationLayerMessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *ApplicationLayerMessageCodec) Serialize() ([]byte, error) {
}
func (d *ApplicationLayerMessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("ApplicationLayerMessageCodec"); err != nil {
return err
}
- if any(d.bipSimpleApplication) != nil {
+ if d.bipSimpleApplication != nil {
if serializableField, ok := any(d.bipSimpleApplication).(utils.Serializable); ok {
if err := writeBuffer.PushContext("bipSimpleApplication"); err != nil {
return err
@@ -61,15 +67,17 @@ func (d *ApplicationLayerMessageCodec) SerializeWithWriteBuffer(ctx context.Cont
}
}
}
- {
- _value := fmt.Sprintf("%v", d.messageCode)
+ if d.messageCode != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.messageCode)
- if err := writeBuffer.WriteString("messageCode", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("messageCode", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- if any(d.deviceInfoCache) != nil {
+ if d.deviceInfoCache != nil {
if serializableField, ok := any(d.deviceInfoCache).(utils.Serializable); ok {
if err := writeBuffer.PushContext("deviceInfoCache"); err != nil {
return err
@@ -104,6 +112,11 @@ func (d *ApplicationLayerMessageCodec) SerializeWithWriteBuffer(ctx context.Cont
}
func (d *ApplicationLayerMessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/MessageCodec_plc4xgen.go b/plc4go/internal/bacnetip/MessageCodec_plc4xgen.go
index 8bdebd9a0b..c3bef75c54 100644
--- a/plc4go/internal/bacnetip/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/bacnetip/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -56,6 +62,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/Subscriber_plc4xgen.go b/plc4go/internal/bacnetip/Subscriber_plc4xgen.go
index cb4be8a179..e8aa0d30a7 100644
--- a/plc4go/internal/bacnetip/Subscriber_plc4xgen.go
+++ b/plc4go/internal/bacnetip/Subscriber_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Subscriber) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,14 +42,19 @@ func (d *Subscriber) Serialize() ([]byte, error) {
}
func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Subscriber"); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.connection)
+ if d.connection != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.connection)
- if err := writeBuffer.WriteString("connection", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("connection", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PushContext("consumers", utils.WithRenderAsList(true)); err != nil {
@@ -82,7 +90,7 @@ func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
for _, elem := range d._options {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -111,6 +119,11 @@ func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *Subscriber) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/app_BIPSimpleApplication_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/app_BIPSimpleApplication_plc4xgen.go
index 7745dcf12a..a3a5e6844d 100644
--- a/plc4go/internal/bacnetip/bacgopes/app_BIPSimpleApplication_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/app_BIPSimpleApplication_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *BIPSimpleApplication) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *BIPSimpleApplication) Serialize() ([]byte, error) {
}
func (d *BIPSimpleApplication) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("BIPSimpleApplication"); err != nil {
return err
}
@@ -58,53 +64,67 @@ func (d *BIPSimpleApplication) SerializeWithWriteBuffer(ctx context.Context, wri
return err
}
}
- {
- _value := fmt.Sprintf("%v", d.asap)
+ if d.asap != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.asap)
- if err := writeBuffer.WriteString("asap", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("asap", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- {
- _value := fmt.Sprintf("%v", d.smap)
+ if d.smap != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.smap)
- if err := writeBuffer.WriteString("smap", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("smap", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- {
- _value := fmt.Sprintf("%v", d.nsap)
+ if d.nsap != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.nsap)
- if err := writeBuffer.WriteString("nsap", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("nsap", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- {
- _value := fmt.Sprintf("%v", d.nse)
+ if d.nse != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.nse)
- if err := writeBuffer.WriteString("nse", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("nse", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- {
- _value := fmt.Sprintf("%v", d.bip)
+ if d.bip != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.bip)
- if err := writeBuffer.WriteString("bip", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("bip", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- {
- _value := fmt.Sprintf("%v", d.annexj)
+ if d.annexj != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.annexj)
- if err := writeBuffer.WriteString("annexj", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("annexj", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- {
- _value := fmt.Sprintf("%v", d.mux)
+ if d.mux != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.mux)
- if err := writeBuffer.WriteString("mux", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("mux", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PopContext("BIPSimpleApplication"); err != nil {
@@ -114,6 +134,11 @@ func (d *BIPSimpleApplication) SerializeWithWriteBuffer(ctx context.Context, wri
}
func (d *BIPSimpleApplication) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/app_DeviceInfo_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/app_DeviceInfo_plc4xgen.go
index 7b336d0005..4e1ebb08e7 100644
--- a/plc4go/internal/bacnetip/bacgopes/app_DeviceInfo_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/app_DeviceInfo_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DeviceInfo) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DeviceInfo) Serialize() ([]byte, error) {
}
func (d *DeviceInfo) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("DeviceInfo"); err != nil {
return err
}
- if any(d.DeviceIdentifier) != nil {
+ if d.DeviceIdentifier != nil {
if serializableField, ok := any(d.DeviceIdentifier).(utils.Serializable); ok {
if err := writeBuffer.PushContext("deviceIdentifier"); err != nil {
return err
@@ -88,11 +94,13 @@ func (d *DeviceInfo) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
return err
}
}
- {
- _value := fmt.Sprintf("%v", d.MaximumNpduLength)
+ if d.MaximumNpduLength != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.MaximumNpduLength)
- if err := writeBuffer.WriteString("maximumNpduLength", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("maximumNpduLength", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
@@ -113,6 +121,11 @@ func (d *DeviceInfo) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *DeviceInfo) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/capability_Capability_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/capability_Capability_plc4xgen.go
index 7fab80dad4..2cf28817ff 100644
--- a/plc4go/internal/bacnetip/bacgopes/capability_Capability_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/capability_Capability_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Capability) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *Capability) Serialize() ([]byte, error) {
}
func (d *Capability) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Capability"); err != nil {
return err
}
@@ -49,6 +55,11 @@ func (d *Capability) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *Capability) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/device_WhoIsIAmServices_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/device_WhoIsIAmServices_plc4xgen.go
index 01a5a9a79e..515cf83a7c 100644
--- a/plc4go/internal/bacnetip/bacgopes/device_WhoIsIAmServices_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/device_WhoIsIAmServices_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *WhoIsIAmServices) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *WhoIsIAmServices) Serialize() ([]byte, error) {
}
func (d *WhoIsIAmServices) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("WhoIsIAmServices"); err != nil {
return err
}
@@ -52,11 +58,13 @@ func (d *WhoIsIAmServices) SerializeWithWriteBuffer(ctx context.Context, writeBu
if err := d.Capability.SerializeWithWriteBuffer(ctx, writeBuffer); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.localDevice)
+ if d.localDevice != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.localDevice)
- if err := writeBuffer.WriteString("localDevice", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("localDevice", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PopContext("WhoIsIAmServices"); err != nil {
@@ -66,6 +74,11 @@ func (d *WhoIsIAmServices) SerializeWithWriteBuffer(ctx context.Context, writeBu
}
func (d *WhoIsIAmServices) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/iocb_IOCB_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/iocb_IOCB_plc4xgen.go
index 26d53dad85..0bb7b054fe 100644
--- a/plc4go/internal/bacnetip/bacgopes/iocb_IOCB_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/iocb_IOCB_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *IOCB) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *IOCB) Serialize() ([]byte, error) {
}
func (d *IOCB) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("IOCB"); err != nil {
return err
}
@@ -53,11 +59,13 @@ func (d *IOCB) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.W
return err
}
}
- {
- _value := fmt.Sprintf("%v", d.destination)
+ if d.destination != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.destination)
- if err := writeBuffer.WriteString("destination", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("destination", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
{
@@ -121,6 +129,11 @@ func (d *IOCB) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.W
}
func (d *IOCB) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/iocb_IOController_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/iocb_IOController_plc4xgen.go
index e4e458ed5b..9185bf7760 100644
--- a/plc4go/internal/bacnetip/bacgopes/iocb_IOController_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/iocb_IOController_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *IOController) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *IOController) Serialize() ([]byte, error) {
}
func (d *IOController) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("IOController"); err != nil {
return err
}
@@ -60,6 +66,11 @@ func (d *IOController) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *IOController) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/iocb_IOQController_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/iocb_IOQController_plc4xgen.go
index dfe43b77ce..2f62db4c31 100644
--- a/plc4go/internal/bacnetip/bacgopes/iocb_IOQController_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/iocb_IOQController_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *IOQController) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *IOQController) Serialize() ([]byte, error) {
}
func (d *IOQController) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("IOQController"); err != nil {
return err
}
@@ -59,15 +65,17 @@ func (d *IOQController) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
return err
}
}
- {
- _value := fmt.Sprintf("%v", d.ioQueue)
+ if d.ioQueue != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.ioQueue)
- if err := writeBuffer.WriteString("ioQueue", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("ioQueue", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- if err := writeBuffer.WriteString("waitTime", uint32(len(d.waitTime.String())*8), d.waitTime.String()); err != nil {
+ if err := writeBuffer.WriteString("waitTime", uint32(len(fmt.Sprintf("%p", d.waitTime))*8), fmt.Sprintf("%p", d.waitTime)); err != nil {
return err
}
if err := writeBuffer.PopContext("IOQController"); err != nil {
@@ -77,6 +85,11 @@ func (d *IOQController) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
func (d *IOQController) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/iocb_IOQueue_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/iocb_IOQueue_plc4xgen.go
index d974223946..5e83664899 100644
--- a/plc4go/internal/bacnetip/bacgopes/iocb_IOQueue_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/iocb_IOQueue_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *IOQueue) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *IOQueue) Serialize() ([]byte, error) {
}
func (d *IOQueue) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("IOQueue"); err != nil {
return err
}
@@ -53,6 +59,11 @@ func (d *IOQueue) SerializeWithWriteBuffer(ctx context.Context, writeBuffer util
}
func (d *IOQueue) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/iocb_SieveQueue_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/iocb_SieveQueue_plc4xgen.go
index 64a0b5b06f..574077a4e1 100644
--- a/plc4go/internal/bacnetip/bacgopes/iocb_SieveQueue_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/iocb_SieveQueue_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *SieveQueue) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *SieveQueue) Serialize() ([]byte, error) {
}
func (d *SieveQueue) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("SieveQueue"); err != nil {
return err
}
@@ -49,11 +55,13 @@ func (d *SieveQueue) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
if err := writeBuffer.WriteBit("requestFn", d.requestFn != nil); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.address)
+ if d.address != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.address)
- if err := writeBuffer.WriteString("address", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("address", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PopContext("SieveQueue"); err != nil {
@@ -63,6 +71,11 @@ func (d *SieveQueue) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *SieveQueue) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/object_ReadWritePropertyServices_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/object_ReadWritePropertyServices_plc4xgen.go
index 93f3b2b1b3..37b1ed5f80 100644
--- a/plc4go/internal/bacnetip/bacgopes/object_ReadWritePropertyServices_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/object_ReadWritePropertyServices_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *ReadWritePropertyServices) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *ReadWritePropertyServices) Serialize() ([]byte, error) {
}
func (d *ReadWritePropertyServices) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("ReadWritePropertyServices"); err != nil {
return err
}
@@ -49,6 +55,11 @@ func (d *ReadWritePropertyServices) SerializeWithWriteBuffer(ctx context.Context
}
func (d *ReadWritePropertyServices) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/bacnetip/bacgopes/udp_UDPActor_plc4xgen.go b/plc4go/internal/bacnetip/bacgopes/udp_UDPActor_plc4xgen.go
index d9752b396a..b11d814fc0 100644
--- a/plc4go/internal/bacnetip/bacgopes/udp_UDPActor_plc4xgen.go
+++ b/plc4go/internal/bacnetip/bacgopes/udp_UDPActor_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *UDPActor) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,25 +42,32 @@ func (d *UDPActor) Serialize() ([]byte, error) {
}
func (d *UDPActor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("UDPActor"); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.director)
+ if d.director != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.director)
- if err := writeBuffer.WriteString("director", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("director", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.WriteUint32("timeout", 32, d.timeout); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.timer)
+ if d.timer != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.timer)
- if err := writeBuffer.WriteString("timer", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("timer", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
@@ -71,6 +81,11 @@ func (d *UDPActor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer uti
}
func (d *UDPActor) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/cbus/AlphaGenerator_plc4xgen.go b/plc4go/internal/cbus/AlphaGenerator_plc4xgen.go
index 48c031095e..1942fe1362 100644
--- a/plc4go/internal/cbus/AlphaGenerator_plc4xgen.go
+++ b/plc4go/internal/cbus/AlphaGenerator_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *AlphaGenerator) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *AlphaGenerator) Serialize() ([]byte, error) {
}
func (d *AlphaGenerator) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("AlphaGenerator"); err != nil {
return err
}
@@ -60,6 +66,11 @@ func (d *AlphaGenerator) SerializeWithWriteBuffer(ctx context.Context, writeBuff
}
func (d *AlphaGenerator) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/cbus/Configuration_plc4xgen.go b/plc4go/internal/cbus/Configuration_plc4xgen.go
index bf68bcf577..2e98cf8faf 100644
--- a/plc4go/internal/cbus/Configuration_plc4xgen.go
+++ b/plc4go/internal/cbus/Configuration_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Configuration) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *Configuration) Serialize() ([]byte, error) {
}
func (d *Configuration) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Configuration"); err != nil {
return err
}
@@ -97,6 +103,11 @@ func (d *Configuration) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
func (d *Configuration) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/cbus/Connection_plc4xgen.go b/plc4go/internal/cbus/Connection_plc4xgen.go
index af9fb947c5..6822b68490 100644
--- a/plc4go/internal/cbus/Connection_plc4xgen.go
+++ b/plc4go/internal/cbus/Connection_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Connection) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *Connection) Serialize() ([]byte, error) {
}
func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Connection"); err != nil {
return err
}
@@ -49,11 +55,13 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
if err := writeBuffer.WriteString("alphaGenerator", uint32(len(d.alphaGenerator.String())*8), d.alphaGenerator.String()); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.messageCodec)
+ if d.messageCodec != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.messageCodec)
- if err := writeBuffer.WriteString("messageCodec", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("messageCodec", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PushContext("subscribers", utils.WithRenderAsList(true)); err != nil {
@@ -62,7 +70,7 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
for _, elem := range d.subscribers {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -85,7 +93,7 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
return err
}
- if any(d.tm) != nil {
+ if d.tm != nil {
if serializableField, ok := any(d.tm).(utils.Serializable); ok {
if err := writeBuffer.PushContext("tm"); err != nil {
return err
@@ -116,7 +124,7 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
return err
}
- if any(d.tracer) != nil {
+ if d.tracer != nil {
if serializableField, ok := any(d.tracer).(utils.Serializable); ok {
if err := writeBuffer.PushContext("tracer"); err != nil {
return err
@@ -141,6 +149,11 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *Connection) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/cbus/DriverContext_plc4xgen.go b/plc4go/internal/cbus/DriverContext_plc4xgen.go
index b2ac0f05e9..91b1be988d 100644
--- a/plc4go/internal/cbus/DriverContext_plc4xgen.go
+++ b/plc4go/internal/cbus/DriverContext_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DriverContext) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DriverContext) Serialize() ([]byte, error) {
}
func (d *DriverContext) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("DriverContext"); err != nil {
return err
}
@@ -57,6 +63,11 @@ func (d *DriverContext) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
func (d *DriverContext) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/cbus/MessageCodec_plc4xgen.go b/plc4go/internal/cbus/MessageCodec_plc4xgen.go
index bc266295bc..ca86b55348 100644
--- a/plc4go/internal/cbus/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/cbus/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -46,7 +52,7 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
return err
}
- if any(d.requestContext) != nil {
+ if d.requestContext != nil {
if serializableField, ok := any(d.requestContext).(utils.Serializable); ok {
if err := writeBuffer.PushContext("requestContext"); err != nil {
return err
@@ -65,7 +71,7 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
}
- if any(d.cbusOptions) != nil {
+ if d.cbusOptions != nil {
if serializableField, ok := any(d.cbusOptions).(utils.Serializable); ok {
if err := writeBuffer.PushContext("cbusOptions"); err != nil {
return err
@@ -112,6 +118,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/cbus/Subscriber_plc4xgen.go b/plc4go/internal/cbus/Subscriber_plc4xgen.go
index 2527ece131..34ab13b3a6 100644
--- a/plc4go/internal/cbus/Subscriber_plc4xgen.go
+++ b/plc4go/internal/cbus/Subscriber_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Subscriber) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *Subscriber) Serialize() ([]byte, error) {
}
func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Subscriber"); err != nil {
return err
}
@@ -87,6 +93,11 @@ func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *Subscriber) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/eip/MessageCodec_plc4xgen.go b/plc4go/internal/eip/MessageCodec_plc4xgen.go
index 87e4e0518f..239e9b1ca0 100644
--- a/plc4go/internal/eip/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/eip/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -56,6 +62,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/knxnetip/ConnectionMetadata_plc4xgen.go b/plc4go/internal/knxnetip/ConnectionMetadata_plc4xgen.go
index 98db62a72d..082b953896 100644
--- a/plc4go/internal/knxnetip/ConnectionMetadata_plc4xgen.go
+++ b/plc4go/internal/knxnetip/ConnectionMetadata_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *ConnectionMetadata) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *ConnectionMetadata) Serialize() ([]byte, error) {
}
func (d *ConnectionMetadata) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("ConnectionMetadata"); err != nil {
return err
}
@@ -99,6 +105,11 @@ func (d *ConnectionMetadata) SerializeWithWriteBuffer(ctx context.Context, write
}
func (d *ConnectionMetadata) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/knxnetip/MessageCodec_plc4xgen.go b/plc4go/internal/knxnetip/MessageCodec_plc4xgen.go
index 4947e7339e..5ebcf7334f 100644
--- a/plc4go/internal/knxnetip/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/knxnetip/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -64,6 +70,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/knxnetip/Subscriber_plc4xgen.go b/plc4go/internal/knxnetip/Subscriber_plc4xgen.go
index 432806d059..cbce46c9e0 100644
--- a/plc4go/internal/knxnetip/Subscriber_plc4xgen.go
+++ b/plc4go/internal/knxnetip/Subscriber_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Subscriber) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,14 +42,19 @@ func (d *Subscriber) Serialize() ([]byte, error) {
}
func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Subscriber"); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.connection)
+ if d.connection != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.connection)
- if err := writeBuffer.WriteString("connection", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("connection", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PushContext("consumers", utils.WithRenderAsList(true)); err != nil {
@@ -86,7 +94,7 @@ func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
for _, elem := range d._options {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -115,6 +123,11 @@ func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *Subscriber) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/modbus/MessageCodec_plc4xgen.go b/plc4go/internal/modbus/MessageCodec_plc4xgen.go
index 4cf5ec4231..60dee077f1 100644
--- a/plc4go/internal/modbus/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/modbus/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -60,6 +66,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/opcua/Configuration_plc4xgen.go b/plc4go/internal/opcua/Configuration_plc4xgen.go
index 7fc0cd146e..875431b118 100644
--- a/plc4go/internal/opcua/Configuration_plc4xgen.go
+++ b/plc4go/internal/opcua/Configuration_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Configuration) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *Configuration) Serialize() ([]byte, error) {
}
func (d *Configuration) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Configuration"); err != nil {
return err
}
@@ -71,7 +77,7 @@ func (d *Configuration) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
return err
}
- if any(d.Thumbprint) != nil {
+ if d.Thumbprint != nil {
if serializableField, ok := any(d.Thumbprint).(utils.Serializable); ok {
if err := writeBuffer.PushContext("thumbprint"); err != nil {
return err
@@ -120,11 +126,13 @@ func (d *Configuration) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
if err := writeBuffer.WriteString("keyStorePassword", uint32(len(d.KeyStorePassword)*8), d.KeyStorePassword); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.Ckp)
+ if d.Ckp != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.Ckp)
- if err := writeBuffer.WriteString("ckp", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("ckp", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PopContext("Configuration"); err != nil {
@@ -134,6 +142,11 @@ func (d *Configuration) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
func (d *Configuration) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/opcua/Connection_plc4xgen.go b/plc4go/internal/opcua/Connection_plc4xgen.go
index 1efc2574a0..1e5f377672 100644
--- a/plc4go/internal/opcua/Connection_plc4xgen.go
+++ b/plc4go/internal/opcua/Connection_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Connection) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,17 +42,22 @@ func (d *Connection) Serialize() ([]byte, error) {
}
func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Connection"); err != nil {
return err
}
if err := d.DefaultConnection.SerializeWithWriteBuffer(ctx, writeBuffer); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.messageCodec)
+ if d.messageCodec != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.messageCodec)
- if err := writeBuffer.WriteString("messageCodec", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("messageCodec", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PushContext("subscribers", utils.WithRenderAsList(true)); err != nil {
@@ -58,7 +66,7 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
for _, elem := range d.subscribers {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -88,11 +96,13 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
if err := writeBuffer.WriteString("driverContext", uint32(len(d.driverContext.String())*8), d.driverContext.String()); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.channel)
+ if d.channel != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.channel)
- if err := writeBuffer.WriteString("channel", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("channel", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
@@ -101,7 +111,7 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
return err
}
- if err := writeBuffer.WriteString("connectTimeout", uint32(len(d.connectTimeout.String())*8), d.connectTimeout.String()); err != nil {
+ if err := writeBuffer.WriteString("connectTimeout", uint32(len(fmt.Sprintf("%p", d.connectTimeout))*8), fmt.Sprintf("%p", d.connectTimeout)); err != nil {
return err
}
@@ -110,7 +120,7 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
return err
}
- if err := writeBuffer.WriteString("disconnectTimeout", uint32(len(d.disconnectTimeout.String())*8), d.disconnectTimeout.String()); err != nil {
+ if err := writeBuffer.WriteString("disconnectTimeout", uint32(len(fmt.Sprintf("%p", d.disconnectTimeout))*8), fmt.Sprintf("%p", d.disconnectTimeout)); err != nil {
return err
}
@@ -118,7 +128,7 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
return err
}
- if any(d.tracer) != nil {
+ if d.tracer != nil {
if serializableField, ok := any(d.tracer).(utils.Serializable); ok {
if err := writeBuffer.PushContext("tracer"); err != nil {
return err
@@ -143,6 +153,11 @@ func (d *Connection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *Connection) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/opcua/DriverContext_plc4xgen.go b/plc4go/internal/opcua/DriverContext_plc4xgen.go
index 9898cd8342..39a1dab32a 100644
--- a/plc4go/internal/opcua/DriverContext_plc4xgen.go
+++ b/plc4go/internal/opcua/DriverContext_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DriverContext) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DriverContext) Serialize() ([]byte, error) {
}
func (d *DriverContext) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("DriverContext"); err != nil {
return err
}
@@ -65,6 +71,11 @@ func (d *DriverContext) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
func (d *DriverContext) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/opcua/MessageCodec_plc4xgen.go b/plc4go/internal/opcua/MessageCodec_plc4xgen.go
index 53423e1472..74ee7611c9 100644
--- a/plc4go/internal/opcua/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/opcua/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -52,6 +58,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/opcua/SecureChannelTransactionManager_plc4xgen.go b/plc4go/internal/opcua/SecureChannelTransactionManager_plc4xgen.go
index 9b0d46b073..8ba7536d2a 100644
--- a/plc4go/internal/opcua/SecureChannelTransactionManager_plc4xgen.go
+++ b/plc4go/internal/opcua/SecureChannelTransactionManager_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *SecureChannelTransactionManager) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *SecureChannelTransactionManager) Serialize() ([]byte, error) {
}
func (d *SecureChannelTransactionManager) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("SecureChannelTransactionManager"); err != nil {
return err
}
@@ -75,6 +81,11 @@ func (d *SecureChannelTransactionManager) SerializeWithWriteBuffer(ctx context.C
}
func (d *SecureChannelTransactionManager) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/opcua/SecureChannel_plc4xgen.go b/plc4go/internal/opcua/SecureChannel_plc4xgen.go
index a3d24e2582..c87d801956 100644
--- a/plc4go/internal/opcua/SecureChannel_plc4xgen.go
+++ b/plc4go/internal/opcua/SecureChannel_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *SecureChannel) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *SecureChannel) Serialize() ([]byte, error) {
}
func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("SecureChannel"); err != nil {
return err
}
@@ -54,7 +60,7 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
return err
}
- if any(d.policyId) != nil {
+ if d.policyId != nil {
if serializableField, ok := any(d.policyId).(utils.Serializable); ok {
if err := writeBuffer.PushContext("policyId"); err != nil {
return err
@@ -96,7 +102,7 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
}
- if any(d.endpoint) != nil {
+ if d.endpoint != nil {
if serializableField, ok := any(d.endpoint).(utils.Serializable); ok {
if err := writeBuffer.PushContext("endpoint"); err != nil {
return err
@@ -127,7 +133,7 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
return err
}
- if any(d.publicCertificate) != nil {
+ if d.publicCertificate != nil {
if serializableField, ok := any(d.publicCertificate).(utils.Serializable); ok {
if err := writeBuffer.PushContext("publicCertificate"); err != nil {
return err
@@ -146,7 +152,7 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
}
- if any(d.thumbprint) != nil {
+ if d.thumbprint != nil {
if serializableField, ok := any(d.thumbprint).(utils.Serializable); ok {
if err := writeBuffer.PushContext("thumbprint"); err != nil {
return err
@@ -175,7 +181,7 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
return err
}
- if any(d.certificateThumbprint) != nil {
+ if d.certificateThumbprint != nil {
if serializableField, ok := any(d.certificateThumbprint).(utils.Serializable); ok {
if err := writeBuffer.PushContext("certificateThumbprint"); err != nil {
return err
@@ -197,11 +203,13 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
if err := writeBuffer.WriteBit("checkedEndpoints", d.checkedEndpoints); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.encryptionHandler)
+ if d.encryptionHandler != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.encryptionHandler)
- if err := writeBuffer.WriteString("encryptionHandler", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("encryptionHandler", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
@@ -217,7 +225,7 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
return err
}
- if any(d.authenticationToken) != nil {
+ if d.authenticationToken != nil {
if serializableField, ok := any(d.authenticationToken).(utils.Serializable); ok {
if err := writeBuffer.PushContext("authenticationToken"); err != nil {
return err
@@ -235,18 +243,22 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
}
}
- {
- _value := fmt.Sprintf("%v", d.codec)
+ if d.codec != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.codec)
- if err := writeBuffer.WriteString("codec", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("codec", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
- {
- _value := fmt.Sprintf("%v", d.channelTransactionManager)
+ if d.channelTransactionManager != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.channelTransactionManager)
- if err := writeBuffer.WriteString("channelTransactionManager", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("channelTransactionManager", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
@@ -287,6 +299,11 @@ func (d *SecureChannel) SerializeWithWriteBuffer(ctx context.Context, writeBuffe
}
func (d *SecureChannel) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/opcua/Subscriber_plc4xgen.go b/plc4go/internal/opcua/Subscriber_plc4xgen.go
index 389ae5a53d..785ba3bb43 100644
--- a/plc4go/internal/opcua/Subscriber_plc4xgen.go
+++ b/plc4go/internal/opcua/Subscriber_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *Subscriber) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *Subscriber) Serialize() ([]byte, error) {
}
func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("Subscriber"); err != nil {
return err
}
@@ -73,11 +79,13 @@ func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
if err := writeBuffer.WriteBit("addSubscriber", d.addSubscriber != nil); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.connection)
+ if d.connection != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.connection)
- if err := writeBuffer.WriteString("connection", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("connection", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PopContext("Subscriber"); err != nil {
@@ -87,6 +95,11 @@ func (d *Subscriber) SerializeWithWriteBuffer(ctx context.Context, writeBuffer u
}
func (d *Subscriber) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/internal/s7/MessageCodec_plc4xgen.go b/plc4go/internal/s7/MessageCodec_plc4xgen.go
index fa527c14d3..8a33bea1d8 100644
--- a/plc4go/internal/s7/MessageCodec_plc4xgen.go
+++ b/plc4go/internal/s7/MessageCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *MessageCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *MessageCodec) Serialize() ([]byte, error) {
}
func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("MessageCodec"); err != nil {
return err
}
@@ -56,6 +62,11 @@ func (d *MessageCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *MessageCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/pkg/api/plcConnectionConnectResult_plc4xgen.go b/plc4go/pkg/api/plcConnectionConnectResult_plc4xgen.go
index c200640dc3..e4de4356a1 100644
--- a/plc4go/pkg/api/plcConnectionConnectResult_plc4xgen.go
+++ b/plc4go/pkg/api/plcConnectionConnectResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *plcConnectionConnectResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *plcConnectionConnectResult) Serialize() ([]byte, error) {
}
func (d *plcConnectionConnectResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("plcConnectionConnectResult"); err != nil {
return err
}
@@ -63,6 +69,11 @@ func (d *plcConnectionConnectResult) SerializeWithWriteBuffer(ctx context.Contex
}
func (d *plcConnectionConnectResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/pkg/api/plcDriverManger_plc4xgen.go b/plc4go/pkg/api/plcDriverManger_plc4xgen.go
index 15337f94a4..0df82647a8 100644
--- a/plc4go/pkg/api/plcDriverManger_plc4xgen.go
+++ b/plc4go/pkg/api/plcDriverManger_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *plcDriverManger) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *plcDriverManger) Serialize() ([]byte, error) {
}
func (d *plcDriverManger) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("plcDriverManger"); err != nil {
return err
}
@@ -90,6 +96,11 @@ func (d *plcDriverManger) SerializeWithWriteBuffer(ctx context.Context, writeBuf
}
func (d *plcDriverManger) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/default/DefaultConnectionMetadata_plc4xgen.go b/plc4go/spi/default/DefaultConnectionMetadata_plc4xgen.go
index d1fff89dc4..ab7e36f710 100644
--- a/plc4go/spi/default/DefaultConnectionMetadata_plc4xgen.go
+++ b/plc4go/spi/default/DefaultConnectionMetadata_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultConnectionMetadata) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultConnectionMetadata) Serialize() ([]byte, error) {
}
func (d *DefaultConnectionMetadata) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("ConnectionMetadata"); err != nil {
return err
}
@@ -78,6 +84,11 @@ func (d *DefaultConnectionMetadata) SerializeWithWriteBuffer(ctx context.Context
}
func (d *DefaultConnectionMetadata) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/default/defaultCodec_plc4xgen.go b/plc4go/spi/default/defaultCodec_plc4xgen.go
index a815bcb651..e790d443d6 100644
--- a/plc4go/spi/default/defaultCodec_plc4xgen.go
+++ b/plc4go/spi/default/defaultCodec_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *defaultCodec) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *defaultCodec) Serialize() ([]byte, error) {
}
func (d *defaultCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("defaultCodec"); err != nil {
return err
}
- if any(d.transportInstance) != nil {
+ if d.transportInstance != nil {
if serializableField, ok := any(d.transportInstance).(utils.Serializable); ok {
if err := writeBuffer.PushContext("transportInstance"); err != nil {
return err
@@ -67,7 +73,7 @@ func (d *defaultCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
for _, elem := range d.expectations {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -103,7 +109,7 @@ func (d *defaultCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
return err
}
- if err := writeBuffer.WriteString("receiveTimeout", uint32(len(d.receiveTimeout.String())*8), d.receiveTimeout.String()); err != nil {
+ if err := writeBuffer.WriteString("receiveTimeout", uint32(len(fmt.Sprintf("%p", d.receiveTimeout))*8), fmt.Sprintf("%p", d.receiveTimeout)); err != nil {
return err
}
@@ -117,6 +123,11 @@ func (d *defaultCodec) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *defaultCodec) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/default/defaultConnection_plc4xgen.go b/plc4go/spi/default/defaultConnection_plc4xgen.go
index 651282ad6c..d5cb9aeac3 100644
--- a/plc4go/spi/default/defaultConnection_plc4xgen.go
+++ b/plc4go/spi/default/defaultConnection_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *defaultConnection) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *defaultConnection) Serialize() ([]byte, error) {
}
func (d *defaultConnection) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("defaultConnection"); err != nil {
return err
}
- if err := writeBuffer.WriteString("defaultTtl", uint32(len(d.defaultTtl.String())*8), d.defaultTtl.String()); err != nil {
+ if err := writeBuffer.WriteString("defaultTtl", uint32(len(fmt.Sprintf("%p", d.defaultTtl))*8), fmt.Sprintf("%p", d.defaultTtl)); err != nil {
return err
}
@@ -51,7 +57,7 @@ func (d *defaultConnection) SerializeWithWriteBuffer(ctx context.Context, writeB
return err
}
- if any(d.tagHandler) != nil {
+ if d.tagHandler != nil {
if serializableField, ok := any(d.tagHandler).(utils.Serializable); ok {
if err := writeBuffer.PushContext("tagHandler"); err != nil {
return err
@@ -70,7 +76,7 @@ func (d *defaultConnection) SerializeWithWriteBuffer(ctx context.Context, writeB
}
}
- if any(d.valueHandler) != nil {
+ if d.valueHandler != nil {
if serializableField, ok := any(d.valueHandler).(utils.Serializable); ok {
if err := writeBuffer.PushContext("valueHandler"); err != nil {
return err
@@ -95,6 +101,11 @@ func (d *defaultConnection) SerializeWithWriteBuffer(ctx context.Context, writeB
}
func (d *defaultConnection) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/default/defaultPlcConnectionCloseResult_plc4xgen.go b/plc4go/spi/default/defaultPlcConnectionCloseResult_plc4xgen.go
index b45dcc47b3..668556037c 100644
--- a/plc4go/spi/default/defaultPlcConnectionCloseResult_plc4xgen.go
+++ b/plc4go/spi/default/defaultPlcConnectionCloseResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *defaultPlcConnectionCloseResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *defaultPlcConnectionCloseResult) Serialize() ([]byte, error) {
}
func (d *defaultPlcConnectionCloseResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("defaultPlcConnectionCloseResult"); err != nil {
return err
}
- if any(d.connection) != nil {
+ if d.connection != nil {
if serializableField, ok := any(d.connection).(utils.Serializable); ok {
if err := writeBuffer.PushContext("connection"); err != nil {
return err
@@ -74,7 +80,7 @@ func (d *defaultPlcConnectionCloseResult) SerializeWithWriteBuffer(ctx context.C
for _, elem := range d.traces {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -103,6 +109,11 @@ func (d *defaultPlcConnectionCloseResult) SerializeWithWriteBuffer(ctx context.C
}
func (d *defaultPlcConnectionCloseResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/default/defaultPlcConnectionConnectResult_plc4xgen.go b/plc4go/spi/default/defaultPlcConnectionConnectResult_plc4xgen.go
index 67158081fe..ace275176c 100644
--- a/plc4go/spi/default/defaultPlcConnectionConnectResult_plc4xgen.go
+++ b/plc4go/spi/default/defaultPlcConnectionConnectResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *defaultPlcConnectionConnectResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *defaultPlcConnectionConnectResult) Serialize() ([]byte, error) {
}
func (d *defaultPlcConnectionConnectResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("defaultPlcConnectionConnectResult"); err != nil {
return err
}
- if any(d.connection) != nil {
+ if d.connection != nil {
if serializableField, ok := any(d.connection).(utils.Serializable); ok {
if err := writeBuffer.PushContext("connection"); err != nil {
return err
@@ -75,6 +81,11 @@ func (d *defaultPlcConnectionConnectResult) SerializeWithWriteBuffer(ctx context
}
func (d *defaultPlcConnectionConnectResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/default/defaultPlcConnectionPingResult_plc4xgen.go b/plc4go/spi/default/defaultPlcConnectionPingResult_plc4xgen.go
index 05edcb9b59..223d82a0c2 100644
--- a/plc4go/spi/default/defaultPlcConnectionPingResult_plc4xgen.go
+++ b/plc4go/spi/default/defaultPlcConnectionPingResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *defaultPlcConnectionPingResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *defaultPlcConnectionPingResult) Serialize() ([]byte, error) {
}
func (d *defaultPlcConnectionPingResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("defaultPlcConnectionPingResult"); err != nil {
return err
}
@@ -56,6 +62,11 @@ func (d *defaultPlcConnectionPingResult) SerializeWithWriteBuffer(ctx context.Co
}
func (d *defaultPlcConnectionPingResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/interceptors/interceptedPlcReadRequestResult_plc4xgen.go b/plc4go/spi/interceptors/interceptedPlcReadRequestResult_plc4xgen.go
index 6ed786421c..46328aabb2 100644
--- a/plc4go/spi/interceptors/interceptedPlcReadRequestResult_plc4xgen.go
+++ b/plc4go/spi/interceptors/interceptedPlcReadRequestResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *interceptedPlcReadRequestResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *interceptedPlcReadRequestResult) Serialize() ([]byte, error) {
}
func (d *interceptedPlcReadRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("interceptedPlcReadRequestResult"); err != nil {
return err
}
- if any(d.Request) != nil {
+ if d.Request != nil {
if serializableField, ok := any(d.Request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -62,7 +68,7 @@ func (d *interceptedPlcReadRequestResult) SerializeWithWriteBuffer(ctx context.C
}
}
- if any(d.Response) != nil {
+ if d.Response != nil {
if serializableField, ok := any(d.Response).(utils.Serializable); ok {
if err := writeBuffer.PushContext("response"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *interceptedPlcReadRequestResult) SerializeWithWriteBuffer(ctx context.C
}
func (d *interceptedPlcReadRequestResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/interceptors/interceptedPlcWriteRequestResult_plc4xgen.go b/plc4go/spi/interceptors/interceptedPlcWriteRequestResult_plc4xgen.go
index b7e4d532ec..d8c1c4b981 100644
--- a/plc4go/spi/interceptors/interceptedPlcWriteRequestResult_plc4xgen.go
+++ b/plc4go/spi/interceptors/interceptedPlcWriteRequestResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *interceptedPlcWriteRequestResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *interceptedPlcWriteRequestResult) Serialize() ([]byte, error) {
}
func (d *interceptedPlcWriteRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("interceptedPlcWriteRequestResult"); err != nil {
return err
}
- if any(d.Request) != nil {
+ if d.Request != nil {
if serializableField, ok := any(d.Request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -62,7 +68,7 @@ func (d *interceptedPlcWriteRequestResult) SerializeWithWriteBuffer(ctx context.
}
}
- if any(d.Response) != nil {
+ if d.Response != nil {
if serializableField, ok := any(d.Response).(utils.Serializable); ok {
if err := writeBuffer.PushContext("response"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *interceptedPlcWriteRequestResult) SerializeWithWriteBuffer(ctx context.
}
func (d *interceptedPlcWriteRequestResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultArrayInfo_plc4xgen.go b/plc4go/spi/model/DefaultArrayInfo_plc4xgen.go
index 113969b0ba..3ad45998c7 100644
--- a/plc4go/spi/model/DefaultArrayInfo_plc4xgen.go
+++ b/plc4go/spi/model/DefaultArrayInfo_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultArrayInfo) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultArrayInfo) Serialize() ([]byte, error) {
}
func (d *DefaultArrayInfo) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("ArrayInfo"); err != nil {
return err
}
@@ -57,6 +63,11 @@ func (d *DefaultArrayInfo) SerializeWithWriteBuffer(ctx context.Context, writeBu
}
func (d *DefaultArrayInfo) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcBrowseItem_plc4xgen.go b/plc4go/spi/model/DefaultPlcBrowseItem_plc4xgen.go
index 1bc91a84d4..2333d21d2a 100644
--- a/plc4go/spi/model/DefaultPlcBrowseItem_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcBrowseItem_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcBrowseItem) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcBrowseItem) Serialize() ([]byte, error) {
}
func (d *DefaultPlcBrowseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcBrowseItem"); err != nil {
return err
}
- if any(d.Tag) != nil {
+ if d.Tag != nil {
if serializableField, ok := any(d.Tag).(utils.Serializable); ok {
if err := writeBuffer.PushContext("tag"); err != nil {
return err
@@ -142,6 +148,11 @@ func (d *DefaultPlcBrowseItem) SerializeWithWriteBuffer(ctx context.Context, wri
}
func (d *DefaultPlcBrowseItem) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcBrowseRequestBuilder_plc4xgen.go b/plc4go/spi/model/DefaultPlcBrowseRequestBuilder_plc4xgen.go
index 6068bfc258..52db447f28 100644
--- a/plc4go/spi/model/DefaultPlcBrowseRequestBuilder_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcBrowseRequestBuilder_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcBrowseRequestBuilder) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcBrowseRequestBuilder) Serialize() ([]byte, error) {
}
func (d *DefaultPlcBrowseRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcBrowseRequestBuilder"); err != nil {
return err
}
@@ -73,6 +79,11 @@ func (d *DefaultPlcBrowseRequestBuilder) SerializeWithWriteBuffer(ctx context.Co
}
func (d *DefaultPlcBrowseRequestBuilder) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcBrowseRequestResult_plc4xgen.go b/plc4go/spi/model/DefaultPlcBrowseRequestResult_plc4xgen.go
index d0f55a144c..4141e9cb5b 100644
--- a/plc4go/spi/model/DefaultPlcBrowseRequestResult_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcBrowseRequestResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcBrowseRequestResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcBrowseRequestResult) Serialize() ([]byte, error) {
}
func (d *DefaultPlcBrowseRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcBrowseRequestResult"); err != nil {
return err
}
- if any(d.Request) != nil {
+ if d.Request != nil {
if serializableField, ok := any(d.Request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -62,7 +68,7 @@ func (d *DefaultPlcBrowseRequestResult) SerializeWithWriteBuffer(ctx context.Con
}
}
- if any(d.Response) != nil {
+ if d.Response != nil {
if serializableField, ok := any(d.Response).(utils.Serializable); ok {
if err := writeBuffer.PushContext("response"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *DefaultPlcBrowseRequestResult) SerializeWithWriteBuffer(ctx context.Con
}
func (d *DefaultPlcBrowseRequestResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcBrowseRequest_plc4xgen.go b/plc4go/spi/model/DefaultPlcBrowseRequest_plc4xgen.go
index c28d35f78f..4be3b15c2a 100644
--- a/plc4go/spi/model/DefaultPlcBrowseRequest_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcBrowseRequest_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcBrowseRequest) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcBrowseRequest) Serialize() ([]byte, error) {
}
func (d *DefaultPlcBrowseRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcBrowseRequest"); err != nil {
return err
}
- if any(d.browser) != nil {
+ if d.browser != nil {
if serializableField, ok := any(d.browser).(utils.Serializable); ok {
if err := writeBuffer.PushContext("browser"); err != nil {
return err
@@ -106,6 +112,11 @@ func (d *DefaultPlcBrowseRequest) SerializeWithWriteBuffer(ctx context.Context,
}
func (d *DefaultPlcBrowseRequest) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcBrowseResponseItem_plc4xgen.go b/plc4go/spi/model/DefaultPlcBrowseResponseItem_plc4xgen.go
index 531f008ed2..92deb70413 100644
--- a/plc4go/spi/model/DefaultPlcBrowseResponseItem_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcBrowseResponseItem_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcBrowseResponseItem) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcBrowseResponseItem) Serialize() ([]byte, error) {
}
func (d *DefaultPlcBrowseResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcBrowseResponseItem"); err != nil {
return err
}
@@ -52,7 +58,7 @@ func (d *DefaultPlcBrowseResponseItem) SerializeWithWriteBuffer(ctx context.Cont
for _, elem := range d.results {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -81,6 +87,11 @@ func (d *DefaultPlcBrowseResponseItem) SerializeWithWriteBuffer(ctx context.Cont
}
func (d *DefaultPlcBrowseResponseItem) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcBrowseResponse_plc4xgen.go b/plc4go/spi/model/DefaultPlcBrowseResponse_plc4xgen.go
index 0811ec9ea5..0225b3d698 100644
--- a/plc4go/spi/model/DefaultPlcBrowseResponse_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcBrowseResponse_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcBrowseResponse) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcBrowseResponse) Serialize() ([]byte, error) {
}
func (d *DefaultPlcBrowseResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcBrowseResponse"); err != nil {
return err
}
- if any(d.request) != nil {
+ if d.request != nil {
if serializableField, ok := any(d.request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -99,6 +105,11 @@ func (d *DefaultPlcBrowseResponse) SerializeWithWriteBuffer(ctx context.Context,
}
func (d *DefaultPlcBrowseResponse) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcConsumerRegistration_plc4xgen.go b/plc4go/spi/model/DefaultPlcConsumerRegistration_plc4xgen.go
index c27f0f3b1a..f0abc52e95 100644
--- a/plc4go/spi/model/DefaultPlcConsumerRegistration_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcConsumerRegistration_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcConsumerRegistration) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcConsumerRegistration) Serialize() ([]byte, error) {
}
func (d *DefaultPlcConsumerRegistration) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcConsumerRegistration"); err != nil {
return err
}
@@ -52,7 +58,7 @@ func (d *DefaultPlcConsumerRegistration) SerializeWithWriteBuffer(ctx context.Co
for _, elem := range d.handles {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -81,6 +87,11 @@ func (d *DefaultPlcConsumerRegistration) SerializeWithWriteBuffer(ctx context.Co
}
func (d *DefaultPlcConsumerRegistration) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcDiscoveryItem_plc4xgen.go b/plc4go/spi/model/DefaultPlcDiscoveryItem_plc4xgen.go
index 0b7421c004..3e656857fb 100644
--- a/plc4go/spi/model/DefaultPlcDiscoveryItem_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcDiscoveryItem_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcDiscoveryItem) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcDiscoveryItem) Serialize() ([]byte, error) {
}
func (d *DefaultPlcDiscoveryItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcDiscoveryItem"); err != nil {
return err
}
@@ -102,6 +108,11 @@ func (d *DefaultPlcDiscoveryItem) SerializeWithWriteBuffer(ctx context.Context,
}
func (d *DefaultPlcDiscoveryItem) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcReadRequestBuilder_plc4xgen.go b/plc4go/spi/model/DefaultPlcReadRequestBuilder_plc4xgen.go
index 16e032a4d7..4ac39d19b7 100644
--- a/plc4go/spi/model/DefaultPlcReadRequestBuilder_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcReadRequestBuilder_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcReadRequestBuilder) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcReadRequestBuilder) Serialize() ([]byte, error) {
}
func (d *DefaultPlcReadRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcReadRequestBuilder"); err != nil {
return err
}
@@ -100,6 +106,11 @@ func (d *DefaultPlcReadRequestBuilder) SerializeWithWriteBuffer(ctx context.Cont
}
func (d *DefaultPlcReadRequestBuilder) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcReadRequestResult_plc4xgen.go b/plc4go/spi/model/DefaultPlcReadRequestResult_plc4xgen.go
index 3f5561c9f8..08f6896215 100644
--- a/plc4go/spi/model/DefaultPlcReadRequestResult_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcReadRequestResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcReadRequestResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcReadRequestResult) Serialize() ([]byte, error) {
}
func (d *DefaultPlcReadRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcReadRequestResult"); err != nil {
return err
}
- if any(d.Request) != nil {
+ if d.Request != nil {
if serializableField, ok := any(d.Request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -62,7 +68,7 @@ func (d *DefaultPlcReadRequestResult) SerializeWithWriteBuffer(ctx context.Conte
}
}
- if any(d.Response) != nil {
+ if d.Response != nil {
if serializableField, ok := any(d.Response).(utils.Serializable); ok {
if err := writeBuffer.PushContext("response"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *DefaultPlcReadRequestResult) SerializeWithWriteBuffer(ctx context.Conte
}
func (d *DefaultPlcReadRequestResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcReadRequest_plc4xgen.go b/plc4go/spi/model/DefaultPlcReadRequest_plc4xgen.go
index 893860a26a..239e44763e 100644
--- a/plc4go/spi/model/DefaultPlcReadRequest_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcReadRequest_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcReadRequest) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcReadRequest) Serialize() ([]byte, error) {
}
func (d *DefaultPlcReadRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcReadRequest"); err != nil {
return err
}
@@ -52,6 +58,11 @@ func (d *DefaultPlcReadRequest) SerializeWithWriteBuffer(ctx context.Context, wr
}
func (d *DefaultPlcReadRequest) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcReadResponse_plc4xgen.go b/plc4go/spi/model/DefaultPlcReadResponse_plc4xgen.go
index b53dc1e8c4..b684097e7f 100644
--- a/plc4go/spi/model/DefaultPlcReadResponse_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcReadResponse_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcReadResponse) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcReadResponse) Serialize() ([]byte, error) {
}
func (d *DefaultPlcReadResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcReadResponse"); err != nil {
return err
}
- if any(d.request) != nil {
+ if d.request != nil {
if serializableField, ok := any(d.request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -95,6 +101,11 @@ func (d *DefaultPlcReadResponse) SerializeWithWriteBuffer(ctx context.Context, w
}
func (d *DefaultPlcReadResponse) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionEventItem_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionEventItem_plc4xgen.go
index 5c84e93360..7034961613 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionEventItem_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionEventItem_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionEventItem) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcSubscriptionEventItem) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionEventItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionEventItem"); err != nil {
return err
}
@@ -47,7 +53,7 @@ func (d *DefaultPlcSubscriptionEventItem) SerializeWithWriteBuffer(ctx context.C
return err
}
- if any(d.tag) != nil {
+ if d.tag != nil {
if serializableField, ok := any(d.tag).(utils.Serializable); ok {
if err := writeBuffer.PushContext("tag"); err != nil {
return err
@@ -70,11 +76,11 @@ func (d *DefaultPlcSubscriptionEventItem) SerializeWithWriteBuffer(ctx context.C
return err
}
- if err := writeBuffer.WriteString("interval", uint32(len(d.interval.String())*8), d.interval.String()); err != nil {
+ if err := writeBuffer.WriteString("interval", uint32(len(fmt.Sprintf("%p", d.interval))*8), fmt.Sprintf("%p", d.interval)); err != nil {
return err
}
- if any(d.value) != nil {
+ if d.value != nil {
if serializableField, ok := any(d.value).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -99,6 +105,11 @@ func (d *DefaultPlcSubscriptionEventItem) SerializeWithWriteBuffer(ctx context.C
}
func (d *DefaultPlcSubscriptionEventItem) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionEvent_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionEvent_plc4xgen.go
index c088533e54..6abb06816c 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionEvent_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionEvent_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionEvent) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcSubscriptionEvent) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionEvent) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionEvent"); err != nil {
return err
}
@@ -76,6 +82,11 @@ func (d *DefaultPlcSubscriptionEvent) SerializeWithWriteBuffer(ctx context.Conte
}
func (d *DefaultPlcSubscriptionEvent) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionHandle_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionHandle_plc4xgen.go
index cfed960fb2..207f65a0ab 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionHandle_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionHandle_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionHandle) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcSubscriptionHandle) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionHandle) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionHandle"); err != nil {
return err
}
@@ -53,6 +59,11 @@ func (d *DefaultPlcSubscriptionHandle) SerializeWithWriteBuffer(ctx context.Cont
}
func (d *DefaultPlcSubscriptionHandle) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionRequestBuilder_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionRequestBuilder_plc4xgen.go
index abf758b917..1f348815f1 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionRequestBuilder_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionRequestBuilder_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionRequestBuilder) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcSubscriptionRequestBuilder) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionRequestBuilder"); err != nil {
return err
}
@@ -168,6 +174,11 @@ func (d *DefaultPlcSubscriptionRequestBuilder) SerializeWithWriteBuffer(ctx cont
}
func (d *DefaultPlcSubscriptionRequestBuilder) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionRequestResult_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionRequestResult_plc4xgen.go
index 132dd3b748..91e024d98b 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionRequestResult_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionRequestResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionRequestResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcSubscriptionRequestResult) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionRequestResult"); err != nil {
return err
}
- if any(d.Request) != nil {
+ if d.Request != nil {
if serializableField, ok := any(d.Request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -62,7 +68,7 @@ func (d *DefaultPlcSubscriptionRequestResult) SerializeWithWriteBuffer(ctx conte
}
}
- if any(d.Response) != nil {
+ if d.Response != nil {
if serializableField, ok := any(d.Response).(utils.Serializable); ok {
if err := writeBuffer.PushContext("response"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *DefaultPlcSubscriptionRequestResult) SerializeWithWriteBuffer(ctx conte
}
func (d *DefaultPlcSubscriptionRequestResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionRequest_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionRequest_plc4xgen.go
index 51b13cb295..b974653257 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionRequest_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionRequest_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionRequest) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcSubscriptionRequest) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionRequest"); err != nil {
return err
}
@@ -100,7 +106,7 @@ func (d *DefaultPlcSubscriptionRequest) SerializeWithWriteBuffer(ctx context.Con
return err
}
- if any(d.subscriber) != nil {
+ if d.subscriber != nil {
if serializableField, ok := any(d.subscriber).(utils.Serializable); ok {
if err := writeBuffer.PushContext("subscriber"); err != nil {
return err
@@ -125,6 +131,11 @@ func (d *DefaultPlcSubscriptionRequest) SerializeWithWriteBuffer(ctx context.Con
}
func (d *DefaultPlcSubscriptionRequest) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionResponseItem_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionResponseItem_plc4xgen.go
index 77be4a7244..101077f905 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionResponseItem_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionResponseItem_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionResponseItem) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcSubscriptionResponseItem) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionResponseItem"); err != nil {
return err
}
@@ -47,7 +53,7 @@ func (d *DefaultPlcSubscriptionResponseItem) SerializeWithWriteBuffer(ctx contex
return err
}
- if any(d.subscriptionHandle) != nil {
+ if d.subscriptionHandle != nil {
if serializableField, ok := any(d.subscriptionHandle).(utils.Serializable); ok {
if err := writeBuffer.PushContext("subscriptionHandle"); err != nil {
return err
@@ -72,6 +78,11 @@ func (d *DefaultPlcSubscriptionResponseItem) SerializeWithWriteBuffer(ctx contex
}
func (d *DefaultPlcSubscriptionResponseItem) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionResponse_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionResponse_plc4xgen.go
index de2931543e..1fc49db72b 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionResponse_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionResponse_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionResponse) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcSubscriptionResponse) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionResponse"); err != nil {
return err
}
- if any(d.request) != nil {
+ if d.request != nil {
if serializableField, ok := any(d.request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -95,6 +101,11 @@ func (d *DefaultPlcSubscriptionResponse) SerializeWithWriteBuffer(ctx context.Co
}
func (d *DefaultPlcSubscriptionResponse) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcSubscriptionTag_plc4xgen.go b/plc4go/spi/model/DefaultPlcSubscriptionTag_plc4xgen.go
index 09f801dd56..73e148eb3d 100644
--- a/plc4go/spi/model/DefaultPlcSubscriptionTag_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcSubscriptionTag_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcSubscriptionTag) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcSubscriptionTag) Serialize() ([]byte, error) {
}
func (d *DefaultPlcSubscriptionTag) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcSubscriptionTag"); err != nil {
return err
}
@@ -51,7 +57,7 @@ func (d *DefaultPlcSubscriptionTag) SerializeWithWriteBuffer(ctx context.Context
return err
}
- if err := writeBuffer.WriteString("duration", uint32(len(d.duration.String())*8), d.duration.String()); err != nil {
+ if err := writeBuffer.WriteString("duration", uint32(len(fmt.Sprintf("%p", d.duration))*8), fmt.Sprintf("%p", d.duration)); err != nil {
return err
}
if err := writeBuffer.PopContext("PlcSubscriptionTag"); err != nil {
@@ -61,6 +67,11 @@ func (d *DefaultPlcSubscriptionTag) SerializeWithWriteBuffer(ctx context.Context
}
func (d *DefaultPlcSubscriptionTag) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcTagRequest_plc4xgen.go b/plc4go/spi/model/DefaultPlcTagRequest_plc4xgen.go
index 289abea304..5fa575a178 100644
--- a/plc4go/spi/model/DefaultPlcTagRequest_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcTagRequest_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcTagRequest) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcTagRequest) Serialize() ([]byte, error) {
}
func (d *DefaultPlcTagRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcTagRequest"); err != nil {
return err
}
@@ -76,6 +82,11 @@ func (d *DefaultPlcTagRequest) SerializeWithWriteBuffer(ctx context.Context, wri
}
func (d *DefaultPlcTagRequest) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcUnsubscriptionRequestBuilder_plc4xgen.go b/plc4go/spi/model/DefaultPlcUnsubscriptionRequestBuilder_plc4xgen.go
index 985016f5ca..e5279bdcbf 100644
--- a/plc4go/spi/model/DefaultPlcUnsubscriptionRequestBuilder_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcUnsubscriptionRequestBuilder_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcUnsubscriptionRequestBuilder) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcUnsubscriptionRequestBuilder) Serialize() ([]byte, error) {
}
func (d *DefaultPlcUnsubscriptionRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcUnsubscriptionRequestBuilder"); err != nil {
return err
}
@@ -48,7 +54,7 @@ func (d *DefaultPlcUnsubscriptionRequestBuilder) SerializeWithWriteBuffer(ctx co
for _, elem := range d.subscriptionHandles {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -77,6 +83,11 @@ func (d *DefaultPlcUnsubscriptionRequestBuilder) SerializeWithWriteBuffer(ctx co
}
func (d *DefaultPlcUnsubscriptionRequestBuilder) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcUnsubscriptionRequestResult_plc4xgen.go b/plc4go/spi/model/DefaultPlcUnsubscriptionRequestResult_plc4xgen.go
index 992897ceea..79ca79cf09 100644
--- a/plc4go/spi/model/DefaultPlcUnsubscriptionRequestResult_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcUnsubscriptionRequestResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcUnsubscriptionRequestResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcUnsubscriptionRequestResult) Serialize() ([]byte, error) {
}
func (d *DefaultPlcUnsubscriptionRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcUnsubscriptionRequestResult"); err != nil {
return err
}
- if any(d.Request) != nil {
+ if d.Request != nil {
if serializableField, ok := any(d.Request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -62,7 +68,7 @@ func (d *DefaultPlcUnsubscriptionRequestResult) SerializeWithWriteBuffer(ctx con
}
}
- if any(d.Response) != nil {
+ if d.Response != nil {
if serializableField, ok := any(d.Response).(utils.Serializable); ok {
if err := writeBuffer.PushContext("response"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *DefaultPlcUnsubscriptionRequestResult) SerializeWithWriteBuffer(ctx con
}
func (d *DefaultPlcUnsubscriptionRequestResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcUnsubscriptionRequest_plc4xgen.go b/plc4go/spi/model/DefaultPlcUnsubscriptionRequest_plc4xgen.go
index 3ff6c14bed..0855205fbe 100644
--- a/plc4go/spi/model/DefaultPlcUnsubscriptionRequest_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcUnsubscriptionRequest_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcUnsubscriptionRequest) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcUnsubscriptionRequest) Serialize() ([]byte, error) {
}
func (d *DefaultPlcUnsubscriptionRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcUnsubscriptionRequest"); err != nil {
return err
}
@@ -48,7 +54,7 @@ func (d *DefaultPlcUnsubscriptionRequest) SerializeWithWriteBuffer(ctx context.C
for _, elem := range d.subscriptionHandles {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -77,6 +83,11 @@ func (d *DefaultPlcUnsubscriptionRequest) SerializeWithWriteBuffer(ctx context.C
}
func (d *DefaultPlcUnsubscriptionRequest) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcUnsubscriptionResponse_plc4xgen.go b/plc4go/spi/model/DefaultPlcUnsubscriptionResponse_plc4xgen.go
index 2c5e66bfc9..9c076c48ae 100644
--- a/plc4go/spi/model/DefaultPlcUnsubscriptionResponse_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcUnsubscriptionResponse_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcUnsubscriptionResponse) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcUnsubscriptionResponse) Serialize() ([]byte, error) {
}
func (d *DefaultPlcUnsubscriptionResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcUnsubscriptionResponse"); err != nil {
return err
}
@@ -53,6 +59,11 @@ func (d *DefaultPlcUnsubscriptionResponse) SerializeWithWriteBuffer(ctx context.
}
func (d *DefaultPlcUnsubscriptionResponse) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcWriteRequestBuilder_plc4xgen.go b/plc4go/spi/model/DefaultPlcWriteRequestBuilder_plc4xgen.go
index 4187c3c446..7fa5887682 100644
--- a/plc4go/spi/model/DefaultPlcWriteRequestBuilder_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcWriteRequestBuilder_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcWriteRequestBuilder) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcWriteRequestBuilder) Serialize() ([]byte, error) {
}
func (d *DefaultPlcWriteRequestBuilder) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcWriteRequestBuilder"); err != nil {
return err
}
@@ -114,6 +120,11 @@ func (d *DefaultPlcWriteRequestBuilder) SerializeWithWriteBuffer(ctx context.Con
}
func (d *DefaultPlcWriteRequestBuilder) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcWriteRequestResult_plc4xgen.go b/plc4go/spi/model/DefaultPlcWriteRequestResult_plc4xgen.go
index 202ad8aca3..d339d38369 100644
--- a/plc4go/spi/model/DefaultPlcWriteRequestResult_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcWriteRequestResult_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcWriteRequestResult) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcWriteRequestResult) Serialize() ([]byte, error) {
}
func (d *DefaultPlcWriteRequestResult) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcWriteRequestResult"); err != nil {
return err
}
- if any(d.Request) != nil {
+ if d.Request != nil {
if serializableField, ok := any(d.Request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -62,7 +68,7 @@ func (d *DefaultPlcWriteRequestResult) SerializeWithWriteBuffer(ctx context.Cont
}
}
- if any(d.Response) != nil {
+ if d.Response != nil {
if serializableField, ok := any(d.Response).(utils.Serializable); ok {
if err := writeBuffer.PushContext("response"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *DefaultPlcWriteRequestResult) SerializeWithWriteBuffer(ctx context.Cont
}
func (d *DefaultPlcWriteRequestResult) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcWriteRequest_plc4xgen.go b/plc4go/spi/model/DefaultPlcWriteRequest_plc4xgen.go
index 2b29e3e905..fd3eb85f40 100644
--- a/plc4go/spi/model/DefaultPlcWriteRequest_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcWriteRequest_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcWriteRequest) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *DefaultPlcWriteRequest) Serialize() ([]byte, error) {
}
func (d *DefaultPlcWriteRequest) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcWriteRequest"); err != nil {
return err
}
@@ -79,6 +85,11 @@ func (d *DefaultPlcWriteRequest) SerializeWithWriteBuffer(ctx context.Context, w
}
func (d *DefaultPlcWriteRequest) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/DefaultPlcWriteResponse_plc4xgen.go b/plc4go/spi/model/DefaultPlcWriteResponse_plc4xgen.go
index d173fb9041..996362d976 100644
--- a/plc4go/spi/model/DefaultPlcWriteResponse_plc4xgen.go
+++ b/plc4go/spi/model/DefaultPlcWriteResponse_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *DefaultPlcWriteResponse) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,11 +42,14 @@ func (d *DefaultPlcWriteResponse) Serialize() ([]byte, error) {
}
func (d *DefaultPlcWriteResponse) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("PlcWriteResponse"); err != nil {
return err
}
- if any(d.request) != nil {
+ if d.request != nil {
if serializableField, ok := any(d.request).(utils.Serializable); ok {
if err := writeBuffer.PushContext("request"); err != nil {
return err
@@ -95,6 +101,11 @@ func (d *DefaultPlcWriteResponse) SerializeWithWriteBuffer(ctx context.Context,
}
func (d *DefaultPlcWriteResponse) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/model/ResponseItem_plc4xgen.go b/plc4go/spi/model/ResponseItem_plc4xgen.go
index e0e0102504..9ad060be3d 100644
--- a/plc4go/spi/model/ResponseItem_plc4xgen.go
+++ b/plc4go/spi/model/ResponseItem_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *ResponseItem) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *ResponseItem) Serialize() ([]byte, error) {
}
func (d *ResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("ResponseItem"); err != nil {
return err
}
@@ -47,7 +53,7 @@ func (d *ResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
return err
}
- if any(d.value) != nil {
+ if d.value != nil {
if serializableField, ok := any(d.value).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -72,6 +78,11 @@ func (d *ResponseItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer
}
func (d *ResponseItem) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/pool/dynamicExecutor_plc4xgen.go b/plc4go/spi/pool/dynamicExecutor_plc4xgen.go
index d6f8dffd0f..f4f66179b2 100644
--- a/plc4go/spi/pool/dynamicExecutor_plc4xgen.go
+++ b/plc4go/spi/pool/dynamicExecutor_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *dynamicExecutor) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *dynamicExecutor) Serialize() ([]byte, error) {
}
func (d *dynamicExecutor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("dynamicExecutor"); err != nil {
return err
}
@@ -65,6 +71,11 @@ func (d *dynamicExecutor) SerializeWithWriteBuffer(ctx context.Context, writeBuf
}
func (d *dynamicExecutor) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/pool/executor_plc4xgen.go b/plc4go/spi/pool/executor_plc4xgen.go
index 7d45d82b6e..40356750ee 100644
--- a/plc4go/spi/pool/executor_plc4xgen.go
+++ b/plc4go/spi/pool/executor_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *executor) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *executor) Serialize() ([]byte, error) {
}
func (d *executor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("executor"); err != nil {
return err
}
@@ -56,7 +62,7 @@ func (d *executor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer uti
for _, elem := range d.worker {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -94,6 +100,11 @@ func (d *executor) SerializeWithWriteBuffer(ctx context.Context, writeBuffer uti
}
func (d *executor) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/pool/future_plc4xgen.go b/plc4go/spi/pool/future_plc4xgen.go
index d3298dc9ff..3b19d8494c 100644
--- a/plc4go/spi/pool/future_plc4xgen.go
+++ b/plc4go/spi/pool/future_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *future) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *future) Serialize() ([]byte, error) {
}
func (d *future) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("future"); err != nil {
return err
}
@@ -59,7 +65,7 @@ func (d *future) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils
return err
}
- if any(d.err.Load()) != nil {
+ if d.err.Load() != nil {
if serializableField, ok := any(d.err.Load()).(utils.Serializable); ok {
if err := writeBuffer.PushContext("err"); err != nil {
return err
@@ -84,6 +90,11 @@ func (d *future) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils
}
func (d *future) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/pool/workItem_plc4xgen.go b/plc4go/spi/pool/workItem_plc4xgen.go
index a1c5806b25..3e579dce12 100644
--- a/plc4go/spi/pool/workItem_plc4xgen.go
+++ b/plc4go/spi/pool/workItem_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *workItem) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *workItem) Serialize() ([]byte, error) {
}
func (d *workItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("workItem"); err != nil {
return err
}
@@ -46,11 +52,13 @@ func (d *workItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer uti
if err := writeBuffer.WriteInt32("workItemId", 32, int32(d.workItemId)); err != nil {
return err
}
- {
- _value := fmt.Sprintf("%v", d.completionFuture)
+ if d.completionFuture != nil {
+ {
+ _value := fmt.Sprintf("%v", *d.completionFuture)
- if err := writeBuffer.WriteString("completionFuture", uint32(len(_value)*8), _value); err != nil {
- return err
+ if err := writeBuffer.WriteString("completionFuture", uint32(len(_value)*8), _value); err != nil {
+ return err
+ }
}
}
if err := writeBuffer.PopContext("workItem"); err != nil {
@@ -60,6 +68,11 @@ func (d *workItem) SerializeWithWriteBuffer(ctx context.Context, writeBuffer uti
}
func (d *workItem) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/pool/worker_plc4xgen.go b/plc4go/spi/pool/worker_plc4xgen.go
index 1d64bbd3c3..671cf1e5d4 100644
--- a/plc4go/spi/pool/worker_plc4xgen.go
+++ b/plc4go/spi/pool/worker_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *worker) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *worker) Serialize() ([]byte, error) {
}
func (d *worker) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("worker"); err != nil {
return err
}
@@ -47,7 +53,7 @@ func (d *worker) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils
return err
}
- if any(d.lastReceived.Load()) != nil {
+ if d.lastReceived.Load() != nil {
if serializableField, ok := any(d.lastReceived.Load()).(utils.Serializable); ok {
if err := writeBuffer.PushContext("lastReceived"); err != nil {
return err
@@ -89,6 +95,11 @@ func (d *worker) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils
}
func (d *worker) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/transactions/completedFuture_plc4xgen.go b/plc4go/spi/transactions/completedFuture_plc4xgen.go
index 97aa0f5a2d..9167be565c 100644
--- a/plc4go/spi/transactions/completedFuture_plc4xgen.go
+++ b/plc4go/spi/transactions/completedFuture_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *completedFuture) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *completedFuture) Serialize() ([]byte, error) {
}
func (d *completedFuture) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("completedFuture"); err != nil {
return err
}
@@ -56,6 +62,11 @@ func (d *completedFuture) SerializeWithWriteBuffer(ctx context.Context, writeBuf
}
func (d *completedFuture) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/transactions/requestTransactionManager_plc4xgen.go b/plc4go/spi/transactions/requestTransactionManager_plc4xgen.go
index 36cbc81391..c948eefa38 100644
--- a/plc4go/spi/transactions/requestTransactionManager_plc4xgen.go
+++ b/plc4go/spi/transactions/requestTransactionManager_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *requestTransactionManager) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *requestTransactionManager) Serialize() ([]byte, error) {
}
func (d *requestTransactionManager) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("requestTransactionManager"); err != nil {
return err
}
@@ -48,7 +54,7 @@ func (d *requestTransactionManager) SerializeWithWriteBuffer(ctx context.Context
for _, elem := range d.runningRequests {
var elem any = elem
- if any(elem) != nil {
+ if elem != nil {
if serializableField, ok := any(elem).(utils.Serializable); ok {
if err := writeBuffer.PushContext("value"); err != nil {
return err
@@ -79,7 +85,7 @@ func (d *requestTransactionManager) SerializeWithWriteBuffer(ctx context.Context
return err
}
- if any(d.executor) != nil {
+ if d.executor != nil {
if serializableField, ok := any(d.executor).(utils.Serializable); ok {
if err := writeBuffer.PushContext("executor"); err != nil {
return err
@@ -112,6 +118,11 @@ func (d *requestTransactionManager) SerializeWithWriteBuffer(ctx context.Context
}
func (d *requestTransactionManager) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/spi/transactions/requestTransaction_plc4xgen.go b/plc4go/spi/transactions/requestTransaction_plc4xgen.go
index 8d9a31aa88..b7cfe36e86 100644
--- a/plc4go/spi/transactions/requestTransaction_plc4xgen.go
+++ b/plc4go/spi/transactions/requestTransaction_plc4xgen.go
@@ -31,6 +31,9 @@ import (
var _ = fmt.Printf
func (d *requestTransaction) Serialize() ([]byte, error) {
+ if d == nil {
+ return nil, fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))
if err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {
return nil, err
@@ -39,6 +42,9 @@ func (d *requestTransaction) Serialize() ([]byte, error) {
}
func (d *requestTransaction) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {
+ if d == nil {
+ return fmt.Errorf("(*DeviceInfoCache)(nil)")
+ }
if err := writeBuffer.PushContext("requestTransaction"); err != nil {
return err
}
@@ -77,6 +83,11 @@ func (d *requestTransaction) SerializeWithWriteBuffer(ctx context.Context, write
}
func (d *requestTransaction) String() string {
+ if alternateStringer, ok := any(d).(utils.AlternateStringer); ok {
+ if alternateString, use := alternateStringer.AlternateString(); use {
+ return alternateString
+ }
+ }
writeBuffer := utils.NewWriteBufferBoxBasedWithOptions(true, true)
if err := writeBuffer.WriteSerializable(context.Background(), d); err != nil {
return err.Error()
diff --git a/plc4go/tools/plc4xGenerator/ExampleStruct_test.go b/plc4go/tools/plc4xGenerator/ExampleStruct_test.go
index 8f68f5076c..ad5d95e91c 100644
--- a/plc4go/tools/plc4xGenerator/ExampleStruct_test.go
+++ b/plc4go/tools/plc4xGenerator/ExampleStruct_test.go
@@ -21,6 +21,7 @@ package main
import (
"context"
+ "fmt"
"github.com/apache/plc4x/plc4go/spi/utils"
"time"
)
@@ -37,6 +38,9 @@ type Example struct {
gField *ExampleStringer
hField time.Time
iField time.Duration
+ jField TestStruct1
+ kField *TestStruct1
+ lField TestStruct2
}
type ExampleDelegate1 struct {
@@ -64,3 +68,25 @@ type ExampleStringer struct {
func (ExampleStringer) String() string {
return ""
}
+
+type TestStruct1 struct {
+}
+
+func (t *TestStruct1) Serialize() ([]byte, error) {
+ panic("no use")
+}
+
+func (t *TestStruct1) SerializeWithWriteBuffer(_ context.Context, _ utils.WriteBuffer) error {
+ panic("no use")
+}
+
+var _ utils.Serializable = (*TestStruct1)(nil)
+
+type TestStruct2 struct {
+}
+
+func (t TestStruct2) String() string {
+ panic("no use")
+}
+
+var _ fmt.Stringer = (*TestStruct2)(nil)
diff --git a/plc4go/tools/plc4xGenerator/main.go b/plc4go/tools/plc4xGenerator/main.go
index 2ef3140598..f455f6c3ec 100644
--- a/plc4go/tools/plc4xGenerator/main.go
+++ b/plc4go/tools/plc4xGenerator/main.go
@@ -243,13 +243,19 @@ func (g *Generator) generate(typeName string) {
// Generate code that will fail if the constants change value.
g.Printf("func (d *%s) Serialize() ([]byte, error) {\n", typeName)
- g.Printf("wb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))\n")
+ g.Printf("\tif d == nil {\n")
+ g.Printf("\t\treturn nil, fmt.Errorf(\"(*DeviceInfoCache)(nil)\")\n")
+ g.Printf("\t}\n")
+ g.Printf("\twb := utils.NewWriteBufferByteBased(utils.WithByteOrderForByteBasedBuffer(binary.BigEndian))\n")
g.Printf("\tif err := d.SerializeWithWriteBuffer(context.Background(), wb); err != nil {\n")
g.Printf("\t\treturn nil, err\n")
g.Printf("\t}\n")
g.Printf("\treturn wb.GetBytes(), nil\n")
g.Printf("}\n\n")
g.Printf("func (d *%s) SerializeWithWriteBuffer(ctx context.Context, writeBuffer utils.WriteBuffer) error {\n", typeName)
+ g.Printf("\tif d == nil {\n")
+ g.Printf("\t\treturn fmt.Errorf(\"(*DeviceInfoCache)(nil)\")\n")
+ g.Printf("\t}\n")
g.Printf("\tif err := writeBuffer.PushContext(%s); err != nil {\n", logicalTypeName)
g.Printf("\t\treturn err\n")
g.Printf("\t}\n")
@@ -293,6 +299,10 @@ func (g *Generator) generate(typeName string) {
g.Printf(stringFieldSerialize, "fmt.Sprintf(\"%p\", d."+field.name+")", fieldNameUntitled)
continue
}
+ if field.directSerialize {
+ g.Printf(serializableDirectFieldTemplate, "d."+field.name+"", fieldNameUntitled)
+ continue
+ }
switch fieldType := fieldType.(type) {
case *ast.SelectorExpr:
{
@@ -556,12 +566,13 @@ func (g *Generator) format() []byte {
// Field represents a declared field.
type Field struct {
- name string
- fieldType ast.Expr
- isDelegate bool
- isStringer bool
- asPtr bool
- hasLocker string
+ name string
+ fieldType ast.Expr
+ isDelegate bool
+ isStringer bool
+ asPtr bool
+ directSerialize bool
+ hasLocker string
}
func (f *Field) String() string {
@@ -609,6 +620,10 @@ func (f *File) genDecl(node ast.Node) bool {
if field.Tag != nil && field.Tag.Value == "`asPtr:\"true\"`" { // TODO: Check if we do that a bit smarter
asPtr = true
}
+ directSerialize := false
+ if field.Tag != nil && field.Tag.Value == "`directSerialize:\"true\"`" { // TODO: Check if we do that a bit smarter
+ directSerialize = true
+ }
if len(field.Names) == 0 {
fmt.Printf("\t adding delegate\n")
switch ft := field.Type.(type) {
@@ -659,11 +674,12 @@ func (f *File) genDecl(node ast.Node) bool {
}
fmt.Printf("\t adding field %s %v\n", field.Names[0].Name, field.Type)
f.fields = append(f.fields, Field{
- name: field.Names[0].Name,
- fieldType: field.Type,
- isStringer: isStringer,
- asPtr: asPtr,
- hasLocker: hasLocker,
+ name: field.Names[0].Name,
+ fieldType: field.Type,
+ isStringer: isStringer,
+ asPtr: asPtr,
+ directSerialize: directSerialize,
+ hasLocker: hasLocker,
})
}
}
@@ -694,6 +710,18 @@ func (d *%s) String() string {
}
`
+var serializableDirectFieldTemplate = `
+ if err := writeBuffer.PushContext(%[2]s); err != nil {
+ return err
+ }
+ if err := %[1]s.SerializeWithWriteBuffer(ctx, writeBuffer); err != nil {
+ return err
+ }
+ if err := writeBuffer.PopContext(%[2]s); err != nil {
+ return err
+ }
+`
+
var serializableFieldTemplate = `
if %[1]s != nil {
if serializableField, ok := any(%[1]s).(utils.Serializable); ok {