feat: OPC-UA mspec updates.

Updates include concept of binary and extensible payload which is used at runtime.
Both binary and extensible payload have same representation on the wire. Difference is - chunked data becomes a binary payload.
The extensible payload is definition of message body pushed and expected by driver at higher, application level.
All received message chunks, if they happen to be chunks are assembled back into larger message which can be handled as one by protocol logic.

Signed-off-by: Łukasz Dywicki <[email protected]>

plc4j/drivers/opcua/src/main/generated/org/apache/plc4x/java/opcua/readwrite/BinaryPayload.java

@@ -0,0 +1,141 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.plc4x.java.opcua.readwrite;
+
+import static org.apache.plc4x.java.spi.codegen.fields.FieldReaderFactory.*;
+import static org.apache.plc4x.java.spi.codegen.fields.FieldWriterFactory.*;
+import static org.apache.plc4x.java.spi.codegen.io.DataReaderFactory.*;
+import static org.apache.plc4x.java.spi.codegen.io.DataWriterFactory.*;
+import static org.apache.plc4x.java.spi.generation.StaticHelper.*;
+
+import java.time.*;
+import java.util.*;
+import org.apache.plc4x.java.api.exceptions.*;
+import org.apache.plc4x.java.api.value.*;
+import org.apache.plc4x.java.spi.codegen.*;
+import org.apache.plc4x.java.spi.codegen.fields.*;
+import org.apache.plc4x.java.spi.codegen.io.*;
+import org.apache.plc4x.java.spi.generation.*;
+
+// Code generated by code-generation. DO NOT EDIT.
+
+public class BinaryPayload extends Payload implements Message {
+
+  // Accessors for discriminator values.
+  public Boolean getExtensible() {
+    return (boolean) false;
+  }
+
+  // Properties.
+  protected final byte[] payload;
+
+  public BinaryPayload(SequenceHeader sequenceHeader, byte[] payload) {
+    super(sequenceHeader);
+    this.payload = payload;
+  }
+
+  public byte[] getPayload() {
+    return payload;
+  }
+
+  @Override
+  protected void serializePayloadChild(WriteBuffer writeBuffer) throws SerializationException {
+    PositionAware positionAware = writeBuffer;
+    boolean _lastItem = ThreadLocalHelper.lastItemThreadLocal.get();
+    writeBuffer.pushContext("BinaryPayload");
+
+    // Array Field (payload)
+    writeByteArrayField("payload", payload, writeByteArray(writeBuffer, 8));
+
+    writeBuffer.popContext("BinaryPayload");
+  }
+
+  @Override
+  public int getLengthInBytes() {
+    return (int) Math.ceil((float) getLengthInBits() / 8.0);
+  }
+
+  @Override
+  public int getLengthInBits() {
+    int lengthInBits = super.getLengthInBits();
+    BinaryPayload _value = this;
+    boolean _lastItem = ThreadLocalHelper.lastItemThreadLocal.get();
+
+    // Array field
+    if (payload != null) {
+      lengthInBits += 8 * payload.length;
+    }
+
+    return lengthInBits;
+  }
+
+  public static PayloadBuilder staticParsePayloadBuilder(
+      ReadBuffer readBuffer, Boolean extensible, Long byteCount) throws ParseException {
+    readBuffer.pullContext("BinaryPayload");
+    PositionAware positionAware = readBuffer;
+    boolean _lastItem = ThreadLocalHelper.lastItemThreadLocal.get();
+
+    byte[] payload = readBuffer.readByteArray("payload", Math.toIntExact(byteCount));
+
+    readBuffer.closeContext("BinaryPayload");
+    // Create the instance
+    return new BinaryPayloadBuilderImpl(payload);
+  }
+
+  public static class BinaryPayloadBuilderImpl implements Payload.PayloadBuilder {
+    private final byte[] payload;
+
+    public BinaryPayloadBuilderImpl(byte[] payload) {
+      this.payload = payload;
+    }
+
+    public BinaryPayload build(SequenceHeader sequenceHeader) {
+      BinaryPayload binaryPayload = new BinaryPayload(sequenceHeader, payload);
+      return binaryPayload;
+    }
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (!(o instanceof BinaryPayload)) {
+      return false;
+    }
+    BinaryPayload that = (BinaryPayload) o;
+    return (getPayload() == that.getPayload()) && super.equals(that) && true;
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(super.hashCode(), getPayload());
+  }
+
+  @Override
+  public String toString() {
+    WriteBufferBoxBased writeBufferBoxBased = new WriteBufferBoxBased(true, true);
+    try {
+      writeBufferBoxBased.writeSerializable(this);
+    } catch (SerializationException e) {
+      throw new RuntimeException(e);
+    }
+    return "\n" + writeBufferBoxBased.getBox().toString() + "\n";
+  }
+}

plc4j/drivers/opcua/src/main/generated/org/apache/plc4x/java/opcua/readwrite/ChunkType.java

@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.plc4x.java.opcua.readwrite;
+
+import java.util.HashMap;
+import java.util.Map;
+
+// Code generated by code-generation. DO NOT EDIT.
+
+public enum ChunkType {
+  CONTINUE((String) "C"),
+  FINAL((String) "F"),
+  ABORT((String) "A");
+  private static final Map<String, ChunkType> map;
+
+  static {
+    map = new HashMap<>();
+    for (ChunkType value : ChunkType.values()) {
+      map.put((String) value.getValue(), value);
+    }
+  }
+
+  private final String value;
+
+  ChunkType(String value) {
+    this.value = value;
+  }
+
+  public String getValue() {
+    return value;
+  }
+
+  public static ChunkType enumForValue(String value) {
+    return map.get(value);
+  }
+
+  public static Boolean isDefined(String value) {
+    return map.containsKey(value);
+  }
+}

plc4j/drivers/opcua/src/main/generated/org/apache/plc4x/java/opcua/readwrite/ExtensiblePayload.java

@@ -0,0 +1,143 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.plc4x.java.opcua.readwrite;
+
+import static org.apache.plc4x.java.spi.codegen.fields.FieldReaderFactory.*;
+import static org.apache.plc4x.java.spi.codegen.fields.FieldWriterFactory.*;
+import static org.apache.plc4x.java.spi.codegen.io.DataReaderFactory.*;
+import static org.apache.plc4x.java.spi.codegen.io.DataWriterFactory.*;
+import static org.apache.plc4x.java.spi.generation.StaticHelper.*;
+
+import java.time.*;
+import java.util.*;
+import org.apache.plc4x.java.api.exceptions.*;
+import org.apache.plc4x.java.api.value.*;
+import org.apache.plc4x.java.spi.codegen.*;
+import org.apache.plc4x.java.spi.codegen.fields.*;
+import org.apache.plc4x.java.spi.codegen.io.*;
+import org.apache.plc4x.java.spi.generation.*;
+
+// Code generated by code-generation. DO NOT EDIT.
+
+public class ExtensiblePayload extends Payload implements Message {
+
+  // Accessors for discriminator values.
+  public Boolean getExtensible() {
+    return (boolean) true;
+  }
+
+  // Properties.
+  protected final ExtensionObject payload;
+
+  public ExtensiblePayload(SequenceHeader sequenceHeader, ExtensionObject payload) {
+    super(sequenceHeader);
+    this.payload = payload;
+  }
+
+  public ExtensionObject getPayload() {
+    return payload;
+  }
+
+  @Override
+  protected void serializePayloadChild(WriteBuffer writeBuffer) throws SerializationException {
+    PositionAware positionAware = writeBuffer;
+    boolean _lastItem = ThreadLocalHelper.lastItemThreadLocal.get();
+    writeBuffer.pushContext("ExtensiblePayload");
+
+    // Simple Field (payload)
+    writeSimpleField("payload", payload, new DataWriterComplexDefault<>(writeBuffer));
+
+    writeBuffer.popContext("ExtensiblePayload");
+  }
+
+  @Override
+  public int getLengthInBytes() {
+    return (int) Math.ceil((float) getLengthInBits() / 8.0);
+  }
+
+  @Override
+  public int getLengthInBits() {
+    int lengthInBits = super.getLengthInBits();
+    ExtensiblePayload _value = this;
+    boolean _lastItem = ThreadLocalHelper.lastItemThreadLocal.get();
+
+    // Simple field (payload)
+    lengthInBits += payload.getLengthInBits();
+
+    return lengthInBits;
+  }
+
+  public static PayloadBuilder staticParsePayloadBuilder(
+      ReadBuffer readBuffer, Boolean extensible, Long byteCount) throws ParseException {
+    readBuffer.pullContext("ExtensiblePayload");
+    PositionAware positionAware = readBuffer;
+    boolean _lastItem = ThreadLocalHelper.lastItemThreadLocal.get();
+
+    ExtensionObject payload =
+        readSimpleField(
+            "payload",
+            new DataReaderComplexDefault<>(
+                () -> ExtensionObject.staticParse(readBuffer, (boolean) (false)), readBuffer));
+
+    readBuffer.closeContext("ExtensiblePayload");
+    // Create the instance
+    return new ExtensiblePayloadBuilderImpl(payload);
+  }
+
+  public static class ExtensiblePayloadBuilderImpl implements Payload.PayloadBuilder {
+    private final ExtensionObject payload;
+
+    public ExtensiblePayloadBuilderImpl(ExtensionObject payload) {
+      this.payload = payload;
+    }
+
+    public ExtensiblePayload build(SequenceHeader sequenceHeader) {
+      ExtensiblePayload extensiblePayload = new ExtensiblePayload(sequenceHeader, payload);
+      return extensiblePayload;
+    }
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (!(o instanceof ExtensiblePayload)) {
+      return false;
+    }
+    ExtensiblePayload that = (ExtensiblePayload) o;
+    return (getPayload() == that.getPayload()) && super.equals(that) && true;
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(super.hashCode(), getPayload());
+  }
+
+  @Override
+  public String toString() {
+    WriteBufferBoxBased writeBufferBoxBased = new WriteBufferBoxBased(true, true);
+    try {
+      writeBufferBoxBased.writeSerializable(this);
+    } catch (SerializationException e) {
+      throw new RuntimeException(e);
+    }
+    return "\n" + writeBufferBoxBased.getBox().toString() + "\n";
+  }
+}